*Di*8dZddlZddlZddlmZGddZy)u Checkpoint Manager Module إدارة نقاط الحفظ (Checkpoints) لكل سكريبت يقرأ من log.csv لمعرفة آخر سجل تم معالجته N)datetimecReZdZdZd dZdZdZddZdZdZ d Z d Z dd Z d Z y)CheckpointManageru كلاس لإدارة نقاط الحفظ (Checkpoints) يقرأ من log.csv بدلاً من ملفات منفصلة c|j|_||_t|_d|_|j y)u تهيئة الكلاس Args: script_name (str): اسم السكريبت (مثل: "SAM", "OFAC", "Exclusions") log_file (str): مسار ملف السجلات rN)upper script_namelog_filesetprocessed_nameslast_processed_count_load_processed_records)selfrr s 0/var/www/zoho/zoho_quality/checkpoint_manager.py__init__zCheckpointManager.__init__s<',,.  "u$%! $$&cTtjj|jsy t |jdd5}t j |}|D]}|jddj|jk(s1|jdd}|jdd}|sX|s[|d |}|jj||xjd z c_  dddy#1swYyxYw#t$r}td |Yd}~yd}~wwxYw) uI قراءة السجلات المعالجة من log.csv Nrutf-8encodingWebsiteNameDatabase|[!] Error reading log file: )ospathexistsr opencsv DictReadergetrrr addr Exceptionprint)rfreaderrownamedatabasekeyes rr z)CheckpointManager._load_processed_records"sww~~dmm,  6dmmS7; ;q*! ;Cwwy"-3359I9II"wwvr2#&77:r#:H%)F!H:"6C 0044S9 55:5 ; ; ; ; 6 04 5 5 6sHDAC: &C:4C:79C:1D:D?DD D'D""D'c,|d|}||jvS)u التحقق من أن السجل تم معالجته مسبقاً Args: name (str): اسم الشخص database (str): اسم قاعدة البيانات Returns: bool: True إذا تم معالجته مسبقاً r)r )rr+r,r-s r is_processedzCheckpointManager.is_processed;s%az"d****rNcy)u حفظ نقطة الحفظ (لا يفعل شيء - للتوافق مع الكود القديم) البيانات يتم حفظها في log.csv مباشرة N)rindextotal item_datas rsave_checkpointz!CheckpointManager.save_checkpointI rc|jS)u الحصول على عدد السجلات المعالجة Returns: int: عدد السجلات المعالجة r rs rget_processed_countz%CheckpointManager.get_processed_countPs(((rcy)uq حذف نقطة الحفظ (لا يفعل شيء - للتوافق مع الكود القديم) Nr2r:s rclear_checkpointz"CheckpointManager.clear_checkpointYs rc |jdkDS)u التحقق من وجود سجلات معالجة مسبقاً Returns: bool: True إذا كان هناك سجلات معالجة rr9r:s rhas_checkpointz CheckpointManager.has_checkpoint_s((1,,rc||jdk(ryd|jd|jd}|jS)u الحصول على معلومات السجلات المعالجة Returns: str: نص يحتوي على معلومات السجلات المعالجة rz3No previous records found - Starting from beginningz9 Previous Records Found in log.csv: Already processed: z records for z6 Will skip these records and continue with new ones )r rstrip)rinfos rget_checkpoint_infoz%CheckpointManager.get_checkpoint_infohsN  $ $ )H//0 d>N>N=OP zz|rcy)u تحديث التقدم (لا يفعل شيء - للتوافق مع الكود القديم) البيانات يتم حفظها في log.csv مباشرة Nr2)rr3r4r5 save_everys rupdate_progressz!CheckpointManager.update_progressyr7rctjj|jsyd} t |jdd5}t j |}|D]}|jddj|jk(s5|jdd}|jdd}t|D]<\} } | jd |k(s| jd |k(s0t|| } d d d |S#1swY|SxYw#t$r} td | Yd } ~ |Sd } ~ wwxYw) uo الحصول على آخر index تم معالجته من log.csv Args: script_type (str): نوع السكريبت (SAM, OFAC, Exclusions) data_list (list): قائمة البيانات الكاملة Returns: int: آخر index تم معالجته (-1 إذا لم يتم معالجة أي شيء) rrrrrrrr+r,Nr) rrr r r!r"r#r$r enumeratemaxr&r') r script_type data_list last_indexr(r)r*r+r,iitemr.s rget_last_processed_indexz*CheckpointManager.get_last_processed_indexs.ww~~dmm,  6dmmS7; &q*! &Cwwy"-3359J9J9LL"wwvr2#&77:r#:(1';&GAt#xx/47DHHZrUs!  VVr