KCjzdZddlmZddlmZmZmZddlmZddl m Z m Z ee Z dddd Zd ed ed zd d fdZy )u  Notification creation service (module 1.1.11). This is called from the Celery task (app/workers/tasks.py) after a successful analysis tied to a crop_plan_id, comparing the new feasibility label against the plan's previous one. A change triggers both an in-app Notification row and a best-effort email via app/services/email_service.py. Kept as a plain synchronous function (not async) since it's invoked from the synchronous Celery task context — see sync_db_session usage elsewhere in tasks.py for the same pattern. ) get_logger)CropPlan NotificationUser)sync_db_session)build_feasibility_change_email send_emailinfowarningcritical)suitablerisky not_suitable crop_plan_idnew_feasibility_labelNreturnc \|r|sy t5}|jt|}| dddy|jt|j}| dddyddlm}m}ddlm }|j||j|j|k(j||jjdj!j#}t%|dkDr|dj&nd} t%|dk} | duxr| |k7} | s | s dddyt(j|d} | r|j*j-dn|j*j-d } d |j.d |j1d d d}t3|j4| || |j4}|j7||j9t;|j*|j<| |\}}}t?|j@|||}||_!tDjGd|j4d|j4d|d|d dddy#1swYyxYw#tH$r'}tDjKd|d|dYd}~yd}~wwxYw)u Looks up the plan's previous latest analysis to determine the prior label, and creates a notification only if the label actually changed (or this is the plan's first analysis) — avoids spamming a notification on every re-run if nothing about the outlook changed. Nr)descselect)AnalysisRecordr z plan analyzedz plan status changedzYour 'z' plan is now classified as '_ z'.)user_idtitlemessageseverityrelated_crop_plan_idzCreated notification z for user_id=z crop_plan_id=z (email_sent=)z/Failed to create notification for crop_plan_id=z: T)exc_info)&rgetrrr sqlalchemyrr app.db.modelsrexecutewhererorder_by created_atlimitscalarsalllenfeasibility_labelSEVERITY_FOR_LABELcroprnamereplaceridaddflushrlocationr email email_sentloggerr Exceptionerror)rrsessionplanuserrrrprevious_records old_labelis_first_analysis label_changedrrr notificationsubject text_body html_bodyr7excs NC:\Crop_Prediction\Backend\crop-ai-system\app\services\notification_service.py#notify_feasibility_change_if_neededrHs 4J  A ';;x6D|A A  ;;tT\\2D|A A  0 4>*U>66,FGXd>#<#<=>U1X   BEEUAVYZAZ(+==`dI #$4 5 : %T1XiCX6XM$]CA A F*--.CVLH%99??$%^4 )**>?   $)11#s;rQs_ /66/Q H  W W :W  W rP