U iom@spddlZddlZddlmZmZmZddlmZddlmZddl m Z ddl m Z m Z ddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddl m!Z!m"Z"m#Z#m$Z$e%e%e%e&ee&dddZ'ddZ(ddZ)ddZ*ddZ+ddZ,ddZ-e%e.d d!d"Z/e%e&e.d#d$d%Z0e%dd d&d'Z1e2d(d)d*Z3d+d,Z4dS)-N)date timedeltadatetime) MIMEMultipart)MIMEText) AsyncSession)selectfunc)AsyncSessionLocal)Contract) RecurringTask)Task) LeaveRequest) Notification)User)settings)get_next_due_date)notify_user_by_id notify_adminsnotify_user_groupnotify_admin_groupto_emailusernamecontract_title days_left expires_on contract_idc sztd}d|d||d<tj|d<||d<d|d|d |d |d |d }|t|d tj|tjtjdddIdHWn6t k r}zt d|d|W5d}~XYnXdS)z5Send contract expiry warning email via local Postfix. alternativez[Jarvis] Contract expiring in z days: SubjectFromToz

Hi a,

This is a reminder that the following contract is expiring soon:

Contract z
Expires on z
Days left zm days

View Contract

— Jarvis · no-reply@jarvis.goteku.com

htmlFhostnameportZuse_tls start_tlsNzcheduler] email error to : ) rr SMTP_FROMattachr aiosmtplibsend SMTP_HOST SMTP_PORT Exceptionprint) rrrrrrmsgr"er2>/var/www/html/jarvis.com/web/backend/app/services/scheduler.pysend_expiry_emails4   r4c sDt}|tdd}|tdd}t4IdH}z|tttj|ktj|kIdH}| }|D]h}|j|j }t }|j r||j |tttjdktjdkIdH} | D]} || jq|tttj|IdH} dd| D} |D]} |tttj| ktjd |jktjd IdH}|rfq|t| d |jd |d |jdd |jd| | }|r|jrt|j|j|j||j|jdIdHqqr|IdHWn@tk r.}z | IdHt!d|W5d}~XYnXW5QIdHRXdS)zKCheck contracts expiring in ~90 days and send in-app + email notifications.Udays_NadminTcSsi|] }|j|qSr2)id.0ur2r2r3 _sz)check_contract_expiry.. /contracts/zContract expiring%zKontrak hampir berakhir: zBerakhir dalam z hari ())user_idtitlebodylinkrz [scheduler] expiry check error: )"rtodayrr executerr where period_endscalarsallr7set created_byaddrrole is_activer:in_scalarrrArDrBZlikegetemailr4rcommitr.rollbackr/)rEZ notify_fromZ notify_todbresult contractscontractruser_idsZadminsr9Z users_resultZusersrAexistinguserr1r2r2r3check_contract_expiryAsh     ("      r]c s(t}t4IdH}z|tttjdktj ddgIdH}| }|D]b}z |j px|t dd}t|j|j|}|t |jd}||kr|tttj|jktj|kIdH}|st|j|j|j||jd} || |IdH||_ td|jd ||jrXt||jd |jd |d | jIdHt|d |jd |d | jIdHWq\tk r} ztd |jd| W5d} ~ XYq\Xq\| IdHWn@tk r} z |!IdHtd| W5d} ~ XYnXW5QIdHRXdS)zDCheck all active recurring tasks and create task instances when due.NTZ on_scheduleZbothr6)rB assigned_torLdue_daterecurring_task_idz&[scheduler] generated recurring task 'z' due zTask recurring baru: Due date: /tasks/zcheduler] recurring task z error: z,[scheduler] generate_recurring_tasks error: )"rrEr rFrr rGrOZ trigger_moderPrIrJZlast_generated_duerrZrecurrence_typeZrecurrence_configZ advance_daysrQr rar:r`rBr_rLrMflushr/rrr.rTrU) rErVrWZrecurring_listZrtZafterZnext_dueZ trigger_dater[new_taskr1r2r2r3generate_recurring_taskssl           *rfc s2t}t4IdH }z|tttj|tddktj dktj dkIdH}| }|D]d}t ||j d|jd|jdd|jIdHt|d|jd |jd d|jIdHqf|IdHWn@tk r}z |IdHtd |W5d}~XYnXW5QIdHRXdS) z7Notify assignees about tasks that became overdue today.Nr^r6donezTask overdue: zTask ini melewati due date (z).rcz Due date z terlewat.![scheduler] overdue tasks error: )rrEr rFrr rGr`rstatusr_rIrJrrBr:rrTr.rUr/)rErVrWtaskstaskr1r2r2r3check_overdue_taskss:        rlc s(ttdd}t4IdH}z|tttj|ktj dktj dkIdH}| }|D]\}t ||j d|jd|d|jIdHt|d|jd|d|jIdHqd|IdHWn@tk r}z |IdHtd|W5d}~XYnXW5QIdHRXdS) z9Notify assignees about tasks due tomorrow (H-1 reminder).r^r6NrgzTask due besok: rbrc [scheduler] due tomorrow error: )rrErr rFrr rGr`rir_rIrJrrBr:rrTr.rUr/)ZtomorrowrVrWrjrkr1r2r2r3check_due_tomorrows:      rnc sBt}t4IdH}z|tttj|tddkIdH}| }|D]}d|j }d|jd}d|j }|j rt||j |||IdHt||||IdHt||||IdHt||||IdHqV|IdHWn@tk r,}z |IdHtd|W5d}~XYnXW5QIdHRXdS) z6Notify creator + admins when a contract expires today.Nr^r6zKontrak telah berakhir: zKontrak berakhir pada .r?%[scheduler] contracts expired error: )rrEr rFrr rGrHrrIrJrBr:rLrrrrrTr.rUr/) rErVrWrXrYrBrCrDr1r2r2r3check_contracts_expired_todays(    rqcsJtt4IdH"}z|ttt tj ddgIdHpPd}|ttt  t j dkIdHp~d}|ttt  t jkt jtddkIdHpd}|tt tjktj dktjd IdH}|t}|tt  t j dkt jd IdH}||tt  t jkt jtddkt jd IdH}|t}D]} | jr|| jqD]} || jqi|r|tt tj |IdH} d d | Dtd fd d } td fdd } td fdd }d}d}r~d|d|jdddd| d}d}rd|d|jdddd| d}d}rd |d|jd!d"d#d|d}d$d%|d&|d'|d(|d)|d*|d*|d+}|tt tj d,ktj!d-kIdH}|D]}|j"sTqDzlt#d.}d/|d0<t$j%|d1<|j"|d2<|&t'|d3t(j)|t$j*t$j+d4d4d5IdHt,d6|j"Wn:t-k r}zt,d7|j"d8|W5d}~XYnXqDWn2t-k r4}zt,d9|W5d}~XYnXW5QIdHRXdS):z+Send daily digest HTML email to all admins.NtodoZ in_progressrpendingr6rg cSsi|]}|j|jqSr2)r:rr;r2r2r3r>Zsz%send_daily_digest..returnc shd}tD]V\}}|dr dnd}|jr8|jdnd}|d|d|jd|d|jd 7}q |S) Nbackground:#fafafa;- Mz` ) enumerater_rRrBr`)rowsitbgZassignee) overdue_tasks users_mapr2r3 _overdue_rows]s z(send_daily_digest.._overdue_rowscsd}tD]p\}}|dr dnd}|jd}|j|jjd}|d|d|d|jd |jd |d |jprdd 7}q |S) Nrxryrzr{r^r|O">r}u → zg  zY harir~)rrRrAZend_dateZ start_dater7reason)rrlrrunamer7) leave_listrr2r3 _leave_rowsks2 z&send_daily_digest.._leave_rowsc s\d}tD]J\}}|dr dnd}|jj}|d|d|jd|jd|d 7}q |S) Nrxryrzr|rr}zz hari)rrHr7rB)rrcrr)contracts_listrEr2r3_contract_rows}s   z)send_daily_digest.._contract_rowsa{h1}{h2}{h3}rxu
🔴 Task Overdue (zk)
ZTASKZASSIGNEEzDUE DATE)Zh1Zh2Zh3z
u
🏖 Cuti Pending (ZEMPLOYEEZPERIODEZALASANu
⚠️ Kontrak Berakhir ≤30 Hari (ZKONTRAKZBERAKHIRZSISAu
z a}
📊 Daily Digest
u%  ·  Jarvis Internal
08:00 WIB
as
OVERDUE
av
TASK AKTIF
ax
CUTI PENDING
u
KONTRAK ≤30H
Anda menerima email ini karena Anda adalah admin Jarvis.
no-reply@jarvis.goteku.com
r9Tru[Jarvis] Daily Digest — rr r!r"Fr#z![scheduler] daily digest sent to z"[scheduler] digest email error to r' [scheduler] daily digest error: ).rrEr rQrr countZ select_fromr rGrirPrr rHrrFr`Zorder_bylimitrIrJlenZ created_atrKr_rMrArr:strformatrNrOrSrrr(r)rr*r+r,r-r/r.)rV active_countZpending_leave_countZexpiring_countZ overdue_resZ overdue_countZ leave_resZ contracts_resrZrrZu_resrrrZthZoverdue_sectionZ leave_sectionZcontracts_sectionr"Z admins_resr9Z email_msgr1r2)rrrrErr3send_daily_digest s         """"#$%7    0r)keyrwc snddlm}t}t4IdH8}|||IdH}|dk oJ|j|kW5QIdHRSQIdHRXdS)zEReturn True if this check already ran today (dedup via app_settings).r AppSettingN)app.models.app_settingrrrE isoformatr rRvaluerrZ today_strrVsettingr2r2r3_already_ran_todays   r)rr7rwc sddlm}t}t4IdH}|||IdH}|r@|jsTW5QIdHRdSz.t|j}||j|kWW5QIdHRSt k rYW5QIdHRdSXW5QIdHRXdS)zBReturn True if this check already ran within the last `days` days.rrNF) rrrrEr rRrZ fromisoformatr7 ValueError)rr7rrErVrZlast_runr2r2r3_already_ran_within_days s   "rc szddlm}t}t4IdHD}|||IdH}|rF||_n||||d| IdHW5QIdHRXdS)z!Record that this check ran today.rrN)rr) rrrrErr rRrrMrTrr2r2r3_mark_ran_todays  rrvcsFttdd}|jddddd}||kr:|tdd7}||S)z4Return seconds to wait until next 08:00 WIB (UTC+7).)Zhoursr)ZhourZminutesecondZ microsecondr^r6)rZutcnowrreplaceZ total_seconds)Znow_wibtargetr2r2r3_seconds_until_8am_wib(s rc s|tIdH}td|dddt|IdHtddIdHsztIdHtdIdHWn0tk r}ztd|W5d}~XYnXtd IdHszt IdHtd IdHWn0tk r}ztd |W5d}~XYnXtd IdHsRzt IdHtd IdHWn2tk rP}ztd |W5d}~XYnXtd IdHszt IdHtd IdHWn2tk r}ztd|W5d}~XYnXtdIdHszt IdHtdIdHWn2tk r}ztd|W5d}~XYnXtdIdHszt IdHtdIdHWqtk rt}ztd|W5d}~XYqXqdS)zDRun daily checks at 08:00 WIB. Dedup prevents double-run on restart.Nz[scheduler] sleeping iz.1fzh until 08:00 WIBZsched_contract_expiryz#[scheduler] contract expiry error: Zsched_recurringz#[scheduler] recurring tasks error: Z sched_overduerhZsched_due_tomorrowrmZsched_contracts_expiredrpZsched_daily_digestr)rr/asynciosleeprr]rr.rrfrlrnrqr)waitr1r2r2r3 run_scheduler1sN            r)5rr*rrrZemail.mime.multipartrZemail.mime.textrZsqlalchemy.ext.asynciorZ sqlalchemyrr Z app.databaser Zapp.models.contractr Zapp.models.recurring_taskr Zapp.models.taskr Zapp.models.leave_requestrZapp.models.notificationrZapp.models.userrZ app.configrZapp.services.recurrencerZapp.services.notifierrrrrrintr4r]rfrlrnrqrboolrrrfloatrrr2r2r2r3sB             -F?  d