hSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK J r SSK J r Sr SrSrS r"S S 5rS rS rSrSrSrSrSrSrg)N)datetime) AttendanceLog)RegisteredUser)Staffzscheduler_state.jsonzuser_data.jsoninsightface_embeddingsgr@c&\rSrSrSrSrSrSrg)TimerSchedulerc8SUlXlX lSUlgNF)_timerintervaltask is_running)selfrrs */var/www/fran/franai/services/scheduler.py__init__TimerScheduler.__init__s   cRSUlUR5 UR5 gr )rstartrrs r_runTimerScheduler._runs  rcUR(dc[R"URUR5UlSUR lUR R5 SUlgg)NT)r threadingTimerrrr daemonrrs rrTimerScheduler.startsK#//$--CDK!%DKK  KK   "DO r)r rrrN)__name__ __module__ __qualname____firstlineno__rrr__static_attributes__rrr r s  #rr cT[RR[5(dg[ [S5n[ R "U5n[R"US5sSSS5 $!,(df  g=f![[ R[4a gf=f)z2Reads the last sync timestamp from the state file.Nrlast_sync_timestamp) ospathexists STATE_FILEopenjsonloadr fromisoformatIOErrorJSONDecodeErrorKeyError)fdatas rget_last_sync_timer6$sv 77>>* % % *c "a99QBBB'&B'c[[S5n[R"SUR 50U5 SSS5 g!,(df  g=f![ an[ SU35 SnAgSnAff=f)z1Writes the last sync timestamp to the state file.wr(Nu!❌ Error writing to state file: )r-r,r.dump isoformatr1print) sync_timer4es rset_last_sync_timer>/s^7 *c "a II,i.A.A.CDa H# " " 7 1!5667s3A(AA A AA A6A11A6c[S5 [R"5nUc [S5 g0nUHJn[US5nUR SS5UR SS5UR SS5S S .X'ML 0n[ R R[5(a0[[S 5n[R"U5nSSS5 X:waO[[S5n[R"XSS9 SSS5 [S[S[U5S35 g[S5 g!,(df  Nn=f![[R4a [S [S 35 Nf=f!,(df  N~=f![an[S[SU35 SnAgSnAff=f![ an[SU35 SnAgSnAff=f)z?Fetches all users from the database and updates user_data.json.z-Scheduler: Waking up to run user sync task...Nz=Scheduler: Could not fetch users from DB. Skipping user sync.pidnamezN/Aemail team_nameactive)rArBteamstatusr'z#Scheduler: Could not read existing z. Overwriting.r8)indentu%🔄 User Sync: Successfully updated z with z users.u❌ Error writing to : z1Scheduler: No changes in user data. Sync skipped.u-❌ An error occurred in the user sync task: )r;rget_all_with_hris_infostrgetr)r*r+USER_DATA_FILEr-r.r/r1r2r9len Exception) users_from_db new_user_datauserr@existing_user_datar4r=s ruser_sync_taskrT7s 9:$C&==?  Q R  !Dd5k"C/'51e4" "M "  77>>. ) ) \.#.!)-1&/  . E.#.!IImq9/=n=MVTWXeTfSggnop E F/.T112 \;N;K>Z[ \ /. E-n-=RsCDD E C =aSABBCs#F>A.E>D=EF>#F3F 'F1 F>= E E F> E-E>;F>=E>>F> F F F;F61F>6F;;F>> G GG c[S5 [5n[R"US9nU(a([ U5 [SUR 535 gg![ an[SU35 SnAgSnAff=f)zc The task to be run by the scheduler. It performs an incremental sync based on the last sync time. z4Scheduler: Waking up to run incremental sync task...)last_sync_timez0Scheduler: State updated. Last sync time is now u4❌ An error occurred in the incremental sync task: N)r;r6rsync_from_csv_incrementalr>r:rO)rVnew_latest_timestampr=s rincremental_sync_taskrYas  @A J+-,FFVde  3 4 DEYEcEcEeDfg h  J DQCHIIJsA A A=%A88A=c&[S5 [R"5nU(d [S5 gUVs0sHn[US5U_M nn[R R [5(d[S[S35 g[R"[5Vs/sHo3RS5(dMUPM nnSnUGH-n[R R[U5n[US 5n[R"U5nSSS5 [WRS 55n URS 5n URS 5n X;aX)n U S SU S3n U RSS5nX:wdX:waV[SU SU SU SU SUS3 5 XS 'XS '[US5n[R"X5 SSS5 US- nGMGM[SU SUS35 GM0 [SUS35 gs snfs snf!,(df  GN=f!,(df  N\=f![ an[SUSU35 SnAGMSnAff=f![ an[S U35 SnAgSnAff=f)!ze Periodically updates name and department in .pkl files with the latest info from the HRIS database. u/🔄 Starting scheduled update of .pkl files...u=⚠️ No hired staff found in the database. Aborting update.Nr@u⚠️ Embeddings directory 'z' not found. Aborting.z.pklrrbuser_idrA department first_name last_namerCu🔄 Updating user z: Name 'z' -> 'z ', Dept ''wbu⚠️ User ID z from 'z+' not found in the list of hired employees.u❌ Error processing file rIu'✅ Scheduled update finished. Updated z files.u>❌ An unexpected error occurred during the scheduled update: )r;rget_all_hired_staff_for_updaterKr)r*r+EMBEDDINGS_DIRlistdirendswithjoinr-pickler/rLr9rO)all_hired_staffstaff staff_dictr4embedding_files updated_filesfilename file_pathr5r\ current_namecurrent_departmentemployeenew_namenew_departmentr=s rupdate_pkl_filesrwss  ;<5T>>@ Q R =LLO5c%,'.O Lww~~n-- 1.1AAWX Y &(jj&@W&@JJvDV1&@W 'H ^X>I D)T*a!;;q>D+dhhy12#xx/ %)XXl%;"()2H"*<"8!98K;P:QRH%-\\+r%BN />3W 3G9H\NRXYaXbbkl~k@FGUFVVWXY'/V -;\*")T2a"KK03%* 4XOG9GH:Epqr7(@ 7 gNOUMX +*(32  D28*BqcBCC D T NqcRSSTs'I.I.H=I.I.,H H.I.> I H!!B%IH3 I*I.0II. I.! H0 +I3 I =I I+I&I.&I++I.. J8J  Jc,[5 [5 g)z2Runs both the user sync and attendance sync tasks.N)rTrYr%rrcombined_sync_taskrysrc^[R"5 [R"S5 M-)z*Runs the scheduler in a background thread.rd)schedule run_pendingtimesleepr%rr run_schedulerrs#  1  rcb[R"[S9nSUlUR 5 g)zH Initializes and starts the background scheduler using threading.Timer. )targetTN)rThreadrrr)scheduler_threads rstart_schedulerrs*!''}="r)r}rr.r)rjr{rfranai.models.attendance_modelr#franai.models.registered_user_modelrfranai.models.staff_modelrr,rMrfINTERVAL_SECONDSr r6r>rTrYrwryrrr%rrrso  8>+ # !)##& 7'CTJ$<T|  r