xyMjH,dZddlZddlZddlmZddlmZddlmZmZm Z m Z ddl Z ejZ edZdZdZd ed eed eed eed ededeefdZd edee ee ffdZdee ee ffdZdededefdZdededefdZy)uB Camada de persistência SQLite para o serviço PX3Lab Follow-up. N)contextmanager)datetime)OptionalListDictAnyc#Kt5tjtjd}tj |_|jd|jd ||j |j dddy#t$r|jwxYw#|jwxYw#1swYyxYww)uHContexto seguro para uso em multi-thread (SQLite requer serialização).g>@)timeoutzPRAGMA journal_mode=WAL;zPRAGMA foreign_keys=ON;N) _locksqlite3connectconfigDB_PATHRow row_factoryexecutecommit Exceptionrollbackcloseconns 7/opt/mia/workspace/clientes/px3lab/followup_notif/db.pyget_connrs  v~~t<";; /0 ./ J KKM JJL    MMO   JJL  sACAC 'B<C  CB11B44CC  CCa CREATE TABLE IF NOT EXISTS events ( id INTEGER PRIMARY KEY AUTOINCREMENT, contact_id TEXT NOT NULL, contact_name TEXT, contact_phone TEXT, assigned_user_id TEXT, tag TEXT NOT NULL, tag_added_at TIMESTAMP NOT NULL, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, UNIQUE(contact_id, tag) ); CREATE INDEX IF NOT EXISTS idx_events_tag_added_at ON events(tag_added_at); CREATE TABLE IF NOT EXISTS notifications_sent ( id INTEGER PRIMARY KEY AUTOINCREMENT, event_id INTEGER REFERENCES events(id) ON DELETE CASCADE, delay_hours INTEGER NOT NULL, sent_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, UNIQUE(event_id, delay_hours) ); clt5}|jtdddy#1swYyxYw)N)r executescriptSCHEMArs rinit_dbrAs, #t 6"###s*3 contact_id contact_name contact_phoneassigned_user_idtag tag_added_atreturnc t5}|jd||||||jf}|jr |jndcdddS#1swYyxYw)u Insere um novo evento (tag adicionada). Se já existe (contact_id + tag), retorna None e ignora - isso evita reiniciar a contagem de follow-up caso o Linkia emita eventos repetidos. z INSERT OR IGNORE INTO events (contact_id, contact_name, contact_phone, assigned_user_id, tag, tag_added_at) VALUES (?, ?, ?, ?, ?, ?) N)rr isoformatrowcount lastrowid)rr r!r"r#r$rcurs r insert_eventr+Isf 7tll   &&(    !$ s}}$!777s AAAct5}|jd|fj}|Dcgc] }t|c}cdddScc}w#1swYyxYw)Nz"SELECT * FROM events WHERE tag = ?rrfetchalldict)r#rrowsrs rlist_events_for_tagr2is^ 't|| 0 F  (* "&&AQ& '' ' ''s&AAAAAct5}|jdj}|Dcgc] }t|c}cdddScc}w#1swYyxYw)NzSELECT * FROM eventsr-)rr0r1s rlist_all_eventsr4rsP 't||23<<>!%&AQ&''&''s$AA A AAevent_id delay_hoursct5}|jd||fj}|ducdddS#1swYyxYw)NzCSELECT 1 FROM notifications_sent WHERE event_id=? AND delay_hours=?)rrfetchone)r5r6rrows rnotification_already_sentr:xsL tll Q { #  (* $ s &;Act5}|jd||f}|jdkDcdddS#1swYyxYw)uJRetorna True se marcou (não existia). False se já existia (idempotente).zt INSERT OR IGNORE INTO notifications_sent (event_id, delay_hours) VALUES (?, ?) rN)rrr()r5r6rr*s rmark_notification_sentr<sI  tll { #  ||a   s #8A)__doc__r threading contextlibrrtypingrrrrrLockr rrrstrintr+r2r4boolr:r<rrGs%,,   ( 4#773-7C=7sm 7 7  7c]7@'S'T$sCx.%9''d38n-' #$  S  s  t  rF