Li <dZddlZddlmZddlmZddlmZddlm Z ddl m Z dd ed e d e d e d e ddf dZ dd eded e d e d e ddf dZdd ed e d e d e ddf dZdd ed e d e d e de dzddf dZdd ed e d e d e ddf dZdde d e d e d e dedzddf dZde d e d e d e ddf dZdS)uDUnified notification helper — in-app + Telegram groups + FCM push.N) AsyncSession)select) Notification)User) AppSettingdbusertitlebodylinkreturncK|t|j||||jr+t jt |j|||dSdS)z Create an in-app notification for `user` + fire FCM push in the background. Telegram is sent via group channels (notify_user_group / notify_admin_group). Caller is responsible for db.commit(). )user_idr r r N)addrid push_tokenasyncio create_task _send_fcm)r r r r r s =/var/www/html/jarvis.com/web/backend/app/services/notifier.pynotifyr sk FF<u4d K K KLLL KIdoudDIIJJJJJKKrcK|t|d{V}|r"|jrt|||||d{VdSdSdS)z=Fetch user by ID and create in-app notification (+ FCM push).N)getr is_activer)r rr r r r s rnotify_user_by_idrsg&& & & & & & &D 22RudD111111111112222rcHK|tttjdktjdkd{V}|D]}t|||||d{VdS)zHCreate in-app notification for all active admins (+ FCM push per admin).adminTN) executerrwhererolerscalarsallr)r r r r resultrs r notify_adminsr&s::t 49/41GHHF!!%%''33RtT222222222233r thread_keyc ^K|tdd{V}|r|jsdSd}|rP|t|d{V}|r-|jr& t|j}n#t$rYnwxYwt jt|j||||dS)zWSend Telegram message to the user group channel, optionally to a specific topic thread.telegram_user_group_idN)rrvalueint ValueErrorrr_send_telegram)r r r r r'setting thread_idthread_settings rnotify_user_groupr1'sFF:'?@@@@@@@@G '- I!vvj*========  n2   455      w}eT4SSTTTTTsA33 B?BcK|tdd{V}|r2|jr-tjt |j|||dSdSdS)z1Send Telegram message to the admin group channel.telegram_admin_group_idN)rrr*rrr-)r r r r r.s rnotify_admin_groupr47s~FF:'@AAAAAAAAGN7=NN7=%tLLMMMMMNNNNrchat_idmessage_thread_idcK ddlm}d|d|}|r|d|z }||||d{VdS#t$r}td|Yd}~dSd}~wwxYw)Nr) send_telegramz *[Jarvis] z* z https://jarvis.goteku.comzotifier] Telegram error: )app.services.telegramr8 Exceptionprint)r5r r r r6r8msges rr-r-@s1777777+5++T++  8 777 7CmGS*;<<<<<<<<<<< 111 /A//0000000001s+1 AAAtokencK ddlm}||||d|id{VdS#t$r}td|Yd}~dSd}~wwxYw)Nr) send_pushr z[notifier] FCM error: )app.services.push_notificationr@r:r;)r>r r r r@r=s rrrKs,<<<<<<iudVTN;;;;;;;;;;; ,,, *q**+++++++++,s" A AA )r)rN)N)__doc__rsqlalchemy.ext.asyncior sqlalchemyrapp.models.notificationrapp.models.userrapp.models.app_settingrstrrr+rr&r1r4r-rrrrJsnJJ//////000000 ------ K K\ K Kc K KC KY] K K K K5722 2s232#&2.12;?222233L33C3s3TX3333 U U US U U3 Uadgkak Uw{ U U U U NNNcNNCNY]NNNN11#1c11C1\_bf\f1rv1111,3,s,#,S,T,,,,,,r