V h SSKJrJr SSKJr SSKJr SSKJrJr SSK J r SSK J r J r SSKr\R"\5rS rS \S \R&S \4S jrS\S\ \S\S\S \R&S \ \4 SjrS\S \R&S \ \4SjrS\S\S \R&S \ \4SjrS\S \R&S \ \4SjrS\S \R&S \4SjrS\S\S \R&S \4Sjrg))datetime timedelta) Collection)database)SupportActivityCreateSupportActivityUpdate)str_to_objectid)OptionalListNsupport_activitiesactivitydbreturncX# U[nUR5n[R"5US'UR U5n[ UR 5US'USUS'[RSUS5 U$![an[RSU5 eSnAff=f7f)zG Insert a new support activity into the support_activities collection. created_date_id activity_idzCreated activity %szError creating activity: %sN) COLLECTION_NAMEdictrutcnow insert_onestr inserted_idloggerinfo Exceptionerror)rractivities_collection activity_dataresultes JC:\Suresh\moveshuttle\MDcreated\moveengine\app\v1\services\saas\support.pycreate_activity_servicer$ s ,.,?  (0(9 n%&11-@"6#5#56 e'4U'; m$ )=+GH  2A6 s)B*A &115/+:V2WZ`bmYno   1 $(115/+:V2WX !(5/2HUO&.uoH] #  5{F s5B3AB B3 =B B3 B0B++B00B3c&# U[nURS[U505nU(dgURS[U505 [ US5US'USUS'U$![ an[ RSX5 eSnAff=f7f)z: Delete a support activity and return the deleted record. rNrzError deleting activity %s: %s)rr5r delete_onerrrrr6s r#delete_activity_servicerBUs ,.,?(115/+:V2WX((%1M)NOhuo."*5/  5{F s2B,A(B6A('B( B2B  BBcT# U[nURUSSS/0S.5n[R"5nUR USSU0S.5nSnUS hvN nUS - nMN UUS UR 5S .nU$![ an [RS U 5 eS n A ff=f7f) a Aggregate support metrics for an account: - Total count of support activities (of type 'comment' or 'note') - Count of upcoming meetings (activity type 'meeting' with scheduled date in additional_data) - For pipeline, the latest update might be shown elsewhere (here set as None) z$incommentnote)r%r*meetingz$gte)r%r*zadditional_data.scheduled_daterN)comments_countupcoming_meetings_counttrial_days_remaining last_updatedz'Error aggregating dashboard metrics: %s) rcount_documentsrrr, isoformatrrr) r%rrrHnowmeetings_cursormeetings_count_ dashboardr"s r#get_support_dashboard_servicerSfs,.,?.>>$Y/0@  oo/44$/5sm6   & ! a N -'5$(MMO    >B sMB(AA?A'A%A'A?%A''A?>B(? B% B  B%%B( new_statusc# USnURS[U505nU(d [S5eURSS5nUR S[U50SU[ R "5S.05 SUS S US U3XQS .[ R "5S .nU[nURU5n[UR5US'USUS'U$![an [RSX 5 eS n A ff=f7f)z Update the sales pipeline status for an account. This function does two things: 1. Updates the account record in the 'accounts' collection. 2. Inserts a support activity record of type 'pipeline_update' to log the change. accountsrzAccount not foundsales_pipeline_statusunknownr;)rW updated_datepipeline_updateNzPipeline status changed from z to ) old_statusrT)r*r%user_idcontentadditional_datarrz1Error updating pipeline status for account %s: %s)r5r ValueErrorgetr<rrrrrrrrr) r%rTraccounts_collectionaccountr[r rr!r"s r#update_pipeline_status_servicercs n%..z7R/ST01 1[[!8)D && OJ/ 0 z8??K\] ^ &$6zl$zlS.8S$OO-  -/,?&11-@"6#5#56 e'4U'; m$  H*X s)DCCD D(C??DD)rrpymongo.collectionrapp.dbrmodels.saas.supportmodelrr libraries.objectr typingr r logging getLogger__name__rrMongoDBrr$rintr3r7r?rBrSrcr#rpsl()T/!   8 $&,AxGWGW\`"c UXadjrjzjz@DEI@J* C X5E5E (SW. sEZ`h`p`pu}CvD&s8H8HXVZ^" C X=M=M RV D"S"c"xO_O_"dh"ro