u(idZddlZddlmZddlmZddlmZddlmZ ddl m Z ddl m Z dd l mZej$eZeZd Zd Zd ZdZdZy#e$rZed eYdZ[>dZ[wwxYw)zt Daily Service Level Computation Cron Jobs Simple cron jobs for daily service level computation using APScheduler. N)BackgroundScheduler) CronTrigger)datetime)Session)get_db_session) CronJobLog)compute_service_level_dailyz,Warning: Could not import required modules: cDt}d} tjdtddt j }|j ||j|j|tjd|jtj}tjd|j|j|_ |jtjd|j'y#t$rm}tjd t||r@d |_t||_t j |_|jYd}~d}~wwxYw#|j'wxYw) z/Daily cron job to compute service level metricsNz+Starting service level computation cron job service_levelstarted) task_typestatus started_atz Created cron log entry with ID: z0Service level computation task started with ID: zIService level computation cron job completed - task running in backgroundz-Error in service level computation cron job: failed)rloggerinforrutcnowaddcommitrefreshidr delaytask_id Exceptionerrorstrr error_message completed_atclose)dbcron_logtaskes X/var/www/html/hubwallet-dev/src/smart_inventory/jobs/daily_service_level_compute_cron.pyservice_level_compute_jobr%s6 "BH& AB%(  x  8 6x{{mDE+002 FtwwiPQ 77   _`    DSVHMN &HO%(VH "$,OO$5H ! IIK  s+C5D F A#FF F  F Fcd tjrtjdytj t t ddddd tjtjd y#t$r+}tjd t|Yd}~yd}~wwxYw) z-Start the service level computation cron jobsz6Service level computation scheduler is already runningNr)hourminuteservice_level_computezService Level ComputationT)functriggerrnamereplace_existingzSService level computation cron job started successfully - will run daily at 2:00 AMz3Error starting service level computation cron job: ) schedulerrunningrradd_jobr%rstartrrrr#s r$start_service_level_cronr4HsU    KKP Q  *Qq1&,!    ij U J3q6(STTUs%A;AA;; B/!B**B/c tjr*tjtj dytj dy#t $r+}tj dt|Yd}~yd}~wwxYw)z,Stop the service level computation cron jobsz+Service level computation cron jobs stoppedz6Service level computation scheduler is already stoppedz4Error stopping service level computation cron jobs: N)r/r0shutdownrrrrrr3s r$stop_service_level_cronr7`seV       KKE F KKP Q V KCPQF8TUUVs9AA B!BBc  g}tjD]e}|j|j|j|j r|j j ndt|jdgtj|dS#t$r8}tjdt|dt|icYd}~Sd}~wwxYw)z5Get the status of service level computation cron jobsN)rr- next_run_timer,)scheduler_runningjobszError getting cron status: r) r/get_jobsappendrr-r9 isoformatrr,r0rrr)r;jobr#s r$get_cron_statusr@ls!%%' C KKffBEBSBS!2!2!Y]s{{+   "+!2!2   ! 23q6(;<Q  !sBB C-C CCc tjdtdddS#t$r9}tj dt |dt |dcYd}~Sd}~wwxYw)z8Manually trigger service level computation (for testing)z-Manually triggering service level computationTz*Manual service level computation triggered)successmessagez+Error in manual service level computation: FN)rrr%rrrr3s r$trigger_manual_computerDs_ 5 CD "#,XYY 5 B3q6(KL SV445s#& A(.A#A(#A()__doc__logging!apscheduler.schedulers.backgroundrapscheduler.triggers.cronrrsqlalchemy.ormr src.utils.dbr.src.smart_inventory.apps.inventory.cron_modelsrsrc.smart_inventory.tasks.tasksr ImportErrorr#print getLogger__name__rr/r%r4r7r@rDr$rSs A1">+IK   8 $ ! +\U0 V!* 5a> 8 <==>sAA5 A00A5