o V h @sddlmZmZmZmZmZmZmZddlm Z m Z m Z m Z ddl m Z ddlmZmZddlmZddlmZddlmZmZmZmZmZmZmZeZGd d d eZGd d d eZGd ddeZ GdddeZ!ej"de!deej#eefdedej$fddZ%ej&de e!dedddedddedddedddeej#eefde'd e e'd!e(d"e(dej$f d#d$Z)ej&d%e!dedd&deej#eefd'e'dej$fd(d)Z*ej+d%e!deej#eefd'e'd*e dej$fd+d,Z,ej-d%e!dedd&deej#eefd'e'dej$fd-d.Z.ej&d/e e'e fdedd0deej#eefde'dej$fd1d2Z/ej"d3e!dedd4d5d6edd4d7d6eej#eefde'd8e'dej$fd9d:Z0dS);) APIRouterDepends HTTPExceptionQueryPathBodyRequest)OptionalListDictAny)datetime) BaseModelField)database)get_current_userdetails)create_activity_servicelist_activities_serviceget_activity_serviceupdate_activity_servicedelete_activity_serviceget_support_dashboard_serviceupdate_pipeline_status_servicec@seZdZUedddZeed<edddZeed<edddZe eed <edd dZ e eed <edd dZ e e ee fed <dS)SupportActivityBase.zFType of activity, e.g. 'comment', 'meeting', 'note', 'pipeline_update' descriptiontypez(Account ID associated with this activity account_idNz&ID of the user performing the activityuser_idz0Main content (comment text, meeting notes, etc.)contentz\Extra details (for meetings: scheduled_date, for pipeline updates: old and new status, etc.)additional_data)__name__ __module__ __qualname__rrstr__annotations__rrr r r!r r r'r'7/var/www/html/moveengine/app/v1/routers/saas/support.pyrs rc@s eZdZdS)SupportActivityCreateN)r"r#r$r'r'r'r(r) sr)c@sFeZdZUedddZeeed<edddZee ee fed<dS)SupportActivityUpdateNzUpdated contentrr zUpdated extra detailsr!) r"r#r$rr r r%r&r!r r r'r'r'r(r*#s $r*c@s*eZdZUedddZeed<eed<dS)SupportActivity._id)alias activity_id created_dateN)r"r#r$rr.r%r&r r'r'r'r(r+'s  r+/)response_modelactivitydbc sd|js|jd|did}z t||IdH}|WSty1}z tddt|dd}~ww)zy Create a new support activity record. If account_id is not provided, the current user's account_id is used. r)updateNzFailed to create activity:  status_codedetail)rcopygetr Exceptionrr%)r2r3 current_user new_activityer'r'r(create_activity/s r?.zAccount ID to filter activitiesrNz'Filter by activity type, e.g. 'comment')ge r activity_typeskiplimitc sNzt|||||IdH}|WSty&}z tddt|dd}~ww)zq Retrieve a paginated list of support activities for an account. You may filter by the 'type' field. Nr5zFailed to list activities: r6)rr;rr%)rrCrDrEr3r< activitiesr>r'r'r(list_activitiesAs rGz/{activity_id}zSupport activity IDr.c Xzt||IdH}|stddd|WSty+}z tddt|dd}~ww)z> Retrieve a single support activity record by its ID. NActivity not foundr6r5zFailed to retrieve activity: )rrr;r%)r.r3r<r2r>r'r'r( get_activityT  rKactivity_updatec sZzt|||IdH}|stddd|WSty,}z tddt|dd}~ww)z. Update an existing support activity. NrIrJr6r5zFailed to update activity: )rrr;r%)r.rMr3r<updatedr>r'r'r(update_activityes  rOc rH)z+ Delete a support activity record. NrIrJr6r5zFailed to delete activity: )rrr;r%)r.r3r<deletedr>r'r'r(delete_activitywrLrQz/dashboard/{account_id}z(Account ID for support dashboard metricsc sHz t||IdH}|WSty#}z tddt|dd}~ww)z Return aggregated support metrics for the account: - Count of support comments/notes - Count of upcoming meetings - (Trial info is handled in subscriptions) Nr5zDashboard error: r6)rr;rr%)rr3r< dashboardr>r'r'r(support_dashboards rSz /pipelineTzAccount ID for pipeline update)embedrz5New sales pipeline status (e.g. 'trial', 'live paid') new_statusc sJz t|||IdH}|WSty$}z tddt|dd}~ww)z Update the sales pipeline status for an account. This endpoint updates the account record and logs the change as a support activity. Nr5zPipeline update failed: r6)rr;rr%)rrUr3r<r2r>r'r'r(update_pipeline_statuss rV)1fastapirrrrrrrtypingr r r r r pydanticrrapp.dbrdependencies.authrservices.saas.supportrrrrrrrrouterrr)r*r+post get_mongo_dbMongoDBr?r:r%intrGrKputrOdeleterQrSrVr'r'r'r(s$   $