+ 6sejRt^RIt^RIHt^RIHt^RIHt]P!] 4t R t RRlt RRlt RR R lltR R ltR#)uCruzamento dos anúncios CIRE contra a watchlist e as empresas monitorizadas. O match é **só por NIF**. Há a tentação de o fazer também por nome com trigram, como o `search.py` faz, mas aqui o custo de um falso positivo é alto: alguém avisado de que um cliente entrou em insolvência vai agir com base nisso. Nomes de empresas portuguesas repetem-se muito ("Silva & Filhos, Lda"), e o anúncio traz sempre o NIF das partes relevantes. Preferimos falhar um match a inventar um. N)Any)text) AsyncSessionc<V^8dQhR\R\R\/#)sessionannouncement_idreturnrstrint)formats"#app/services/insolvency_matching.py __annotate__rs!**l*S*S*c"VP\R4RV/4GRjxL P4pV'd!\P RV\ V44\ V4#LE5i)uGCria os hits para um anúncio acabado de inserir. Devolve quantos criou. Cruza as partes contra `insolvency_watchlist` (clientes vindos do Sabichão) e `companies` (concorrentes, internas, relacionadas). Não envia nada — o envio é feito depois, a partir dos hits por notificar, para o sweep não ficar dependente do SMTP. a INSERT INTO insolvency_hits ( announcement_id, watchlist_id, company_id, matched_nif, matched_name, matched_role, claim_deadline ) SELECT a.id, w.id, c.id, p.nif, COALESCE(w.name, c.legal_name, p.name), p.role, a.claim_deadline FROM cire_announcement_parties p JOIN cire_announcements a ON a.id = p.announcement_id LEFT JOIN insolvency_watchlist w ON w.nif = p.nif AND w.active LEFT JOIN companies c ON c.nif = p.nif WHERE p.announcement_id = :aid AND p.nif IS NOT NULL AND (w.id IS NOT NULL OR c.id IS NOT NULL) ON CONFLICT (announcement_id, matched_nif) DO NOTHING RETURNING id::text aidNu,anúncio %s: %d hit(s) na watchlist/empresas)executerallloggerinfolen)rrrowss&& rmatch_announcementrskoo  6O $9  < ce? @  BOUXY]U^_ t9C s!A+A)A+,A+c<V^8dQhR\R\R\/#)rrnifr r )r s"rrrDs!|##rc"VP\R4RV/4GRjxL P4p\V4#L5i)uCruza um NIF novo contra **todo** o histórico de anúncios já guardado. É isto que dá sentido a guardar os anúncios nacionais: quando um cliente é adicionado à watchlist hoje, queremos saber se ele já foi declarado insolvente na semana passada, não só de hoje em diante. a; INSERT INTO insolvency_hits ( announcement_id, watchlist_id, company_id, matched_nif, matched_name, matched_role, claim_deadline ) SELECT a.id, w.id, c.id, p.nif, COALESCE(w.name, c.legal_name, p.name), p.role, a.claim_deadline FROM cire_announcement_parties p JOIN cire_announcements a ON a.id = p.announcement_id LEFT JOIN insolvency_watchlist w ON w.nif = p.nif AND w.active LEFT JOIN companies c ON c.nif = p.nif WHERE p.nif = :nif AND (w.id IS NOT NULL OR c.id IS NOT NULL) ON CONFLICT (announcement_id, matched_nif) DO NOTHING RETURNING id::text rN)rrrr)rrrs&& r rematch_nifrDsMoo  &CL)  , ce/ 0 t9/ s!AAAc tV^8dQhR\R\R\\\\ 3,,/#)rrlimitr )rr listdictr r)r s"rrrfs3$#$#$#c$#DQUVY[^V^Q_L`$#rc"VP\R4R\\4RV/4GRjxL P 4P 4pVUu.uFp\ V4NK up#L;uupi5i)urHits por notificar em que a entidade vigiada é a insolvente e há prazo **ainda por cumprir**. Dois filtros, por razões diferentes: * **Só o papel de insolvente.** É onde existe uma acção com prazo a perder; aparecer como credor num processo alheio não abre prazo nenhum. * **Só prazos que ainda não expiraram.** Um backfill histórico encontra insolvências antigas cujo prazo já passou; enviar "reclamar créditos até" uma data do mês passado é ruído, e em lote seria alarmante. Continuam visíveis em `/insolvencies`, marcados como expirados — a informação não se perde, só não vira email. a: SELECT h.id::text, h.matched_nif, h.matched_name, h.matched_role, h.claim_deadline, a.id::text AS announcement_id, a.process_number, a.tribunal, a.ato, a.pub_date, a.claim_days, a.claim_days_source, a.claim_deadline_estimated, a.admin_name, a.admin_email FROM insolvency_hits h JOIN cire_announcements a ON a.id = h.announcement_id WHERE h.notified_at IS NULL AND a.opens_claim_window AND lower(COALESCE(h.matched_role,'')) = ANY(:roles) AND (h.claim_deadline IS NULL OR h.claim_deadline >= CURRENT_DATE) ORDER BY h.claim_deadline NULLS LAST, h.created_at LIMIT :lim roleslimN)rrr DEBTOR_ROLESmappingsrr!)rrrrs&& rpending_notificationsr(fsqoo  "d<(% 7%  (hj+ ," "TDGT ""+ * #s!0A5A.$A5A0+A50A5c4V^8dQhR\R\RR/#)rrhit_idr N)rr )r s"rrrs!strc\"VP\R4RV/4GRjxL R#L5i)z=UPDATE insolvency_hits SET notified_at = now() WHERE id = :ididN)rr)rr*s&&r mark_notifiedr-s+ // LM v s !,*,) insolventedevedor requerido)d)__doc__loggingtypingr sqlalchemyrsqlalchemy.ext.asyncior getLogger__name__rr%rrr(r-rrr:sF/   8 $ 6 *ZD$#Nr