§
    ÀÖ”j˜  ã                   ób   — d dl Z d dlZd dlZd dlmZ d dlmZ  ej        d¦  «        Zd„ Z	d„ Z
dS )é    N)ÚPostgresClient)ÚTelegramBridgezdscons.crm_cronc               ƒ   óŽ  K  — d„ } ddl m}  || ¦  «        ƒ d{V —†}|sdS 	 t          j        ¦   «          n# t          $ r Y nw xY wt          ¦   «         }|D ]n}|                     d¦  «        rŒt                               d|d         › �¦  «         d|d         › d	�}d}d
}| 	                    |d         ||¦  «        ƒ d{V —† ŒodS )zBScan external contacts and use AgentScope to generate AI messages.c                  óB   — t          ¦   «                              ¦   «         S )N)r   Úget_external_contacts© ó    ú>C:\Projects\DSCons\app\modules\core\application\crm_ai_cron.pyÚ_get_contactsz,scan_pending_contacts.<locals>._get_contacts   s   € ÝÑÔ×5Ò5Ñ7Ô7Ð7r	   r   )Úrun_in_threadpoolNÚis_internalzTriggering AI for contact Únameu   ChÃ o u,   , chÃºng tÃ´i cÃ³ thá»ƒ giÃºp gÃ¬ cho báº¡n?Ú123Úid)
Ústarlette.concurrencyr   Ú
agentscopeÚinitÚ	Exceptionr   ÚgetÚloggerÚinfoÚsend_draft_for_approval)r   r   ÚcontactsÚbridgeÚcontactÚ
draft_textÚtopic_idÚfallback_topic_ids           r
   Úscan_pending_contactsr      sW  è è € ð8ð 8ð 8ð 8Ð7Ð7Ð7Ð7Ð7Ø&Ð& }Ñ5Ô5Ð5Ð5Ð5Ð5Ð5Ð5€Hàð ØˆðÝŒÑÔÐÐøÝð ð ð Øˆðøøøõ ÑÔ€FØð 
ð 
ˆØ�;Š;�}Ñ%Ô%ð 	Øå�ŠÐB°¸´ÐBÐBÑCÔCÐCð \˜g fœoÐ[Ð[Ð[ˆ
ð ˆð "Ðà×,Ò,Ø�DŒMÐ,¨jñ
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð+
ð 
s   ¢6 ¶
AÁAc               ƒ   óÒ   K  — 	 	 t          ¦   «         ƒ d{V —† n4# t          $ r'} t                               d| › �¦  «         Y d} ~ nd} ~ ww xY wt	          j        d¦  «        ƒ d{V —† Œe)z Background task loop for CRM AI.TNzError in CRM AI cron: é<   )r   r   r   ÚerrorÚasyncioÚsleep)Úes    r
   Ústart_crm_ai_cron_loopr&   8   s£   è è € ð ð	7Ý'Ñ)Ô)Ð)Ð)Ð)Ð)Ð)Ð)Ð)Ð)øÝð 	7ð 	7ð 	7Ý�LŠLÐ5°!Ð5Ð5Ñ6Ô6Ð6Ð6Ð6Ð6Ð6Ð6øøøøð	7øøøõ Œm˜BÑÔÐÐÐÐÐÐÐð s   … š
A¤AÁA)r#   Úloggingr   Úapp.core.postgresr   Ú4app.modules.integrations.application.telegram_bridger   Ú	getLoggerr   r   r&   r   r	   r
   ú<module>r+      sƒ   ðØ €€€Ø €€€à Ð Ð Ð à ,Ð ,Ð ,Ð ,Ð ,Ð ,Ø OÐ OÐ OÐ OÐ OÐ Oà	ˆÔ	Ð,Ñ	-Ô	-€ð)
ð )
ð )
ðX ð  ð  ð  ð  r	   