+ 3oj&!Rt^RIHt^RIHtHt^RIHtHtH t H t H t ^RI H t ^RIHt^RIHtHtHt^RIHt^RIHt^R IHt]!R R .R 7t]P7R 4] !R^R7] !R^R7] !R^R7RRR] !^^R7] !^2^^R73RRll4t]P7R4RRl4t]P7R4RRl4t]P?R4RRRll4t R#)uyArquivo nacional da Distribuição: consulta e recruzamento. Ao contrário da `/processes`, que é a vista das empresas monitorizadas, isto é o arquivo cru — tudo o que os 197 tribunais distribuíram, dê ou não match. É o que permite responder "e no mês passado?" sobre uma empresa que só hoje passou a interessar, sem depender dos ~180 dias que o CITIUS ainda serve. )date) AnnotatedAny) APIRouterDepends HTTPExceptionQuerystatus)text) AsyncSession) CurrentUser current_user require_admin) get_session rematch_all)normalize_namez/court-filingsz court-filings)prefixtagsN)default max_lengthF)rge)rrleclV^8dQhR\\\\43,R\\\\ 43,R\ R,R\ R,R\ R,R\R,R\R,R \R \R \R \\ \3,/ #) session_userqNtribunalespeciedesdeate so_com_acertopage page_sizereturn) rr rrr r strrboolintdictr)formats"app/api/court_filings.py __annotate__r-sOWOW |W[%99 :OW [',"77 8OW TzOWDj OW 4Z OW $; OW OWOW OWOW #s(^OWc ".p /p V'd7V PR4RVP4 R2V R&\V4V R&V'dV PR4W;R&V'dV PR4WKR&V'dV PR 4W[R &V'dV PR 4WkR &V'dV PR 4V 'dRRPV 4 2MRp VP \ RV 24V 4GRjxL P 4p WR&V^, V ,V R&VP \ RV R24V 4GRjxL P4P4p.pVFWp\V4pVR,e\VR,4MRVR&VR,;'g.VR&VPV4KY RVR\V 4RVRV /#LL5i)uJPesquisa no arquivo. `q` procura por nome de parte ou número de processo.z(f.process_number ILIKE :qlike OR EXISTS ( SELECT 1 FROM court_filing_parties p WHERE p.filing_id = f.id AND p.name_norm % :qnorm))%qlikeqnormzf.tribunal = :tribunalrzf.especie = :especier zf.data_distribuicao >= :desder!zf.data_distribuicao <= :ater"zCEXISTS (SELECT 1 FROM court_filing_hits h WHERE h.filing_id = f.id)zWHERE z AND rz%SELECT count(*) FROM court_filings f NlimoffaC SELECT f.id::text, f.process_number, f.tribunal, f.unorganica, f.especie, f.valor, f.data_distribuicao, f.data_entrada, f.observacoes, (SELECT count(*) FROM court_filing_parties p WHERE p.filing_id = f.id) AS n_partes, (SELECT count(*) FROM court_filing_hits h WHERE h.filing_id = f.id) AS n_acertos, (SELECT json_agg(json_build_object( 'name', p.name, 'role', p.role, 'nif', p.nif) ORDER BY p.role NULLS LAST, p.name) FROM court_filing_parties p WHERE p.filing_id = f.id) AS partes FROM court_filings f z ORDER BY f.data_distribuicao DESC NULLS LAST, f.first_seen_at DESC LIMIT :lim OFFSET :off valorpartesitemstotalr$r%) appendstriprjoinexecuter scalar_onemappingsallr*floatr))rrrrr r!r"r#r$r%whereparamsclauser8rowsr7ritems&&&&&&&&&& r,search_filingsrGsEF   D aggi[*w(+w -.%z +,#y  45w  23u  Z[/4vgll5)* +"Foo 8A BF  jl  5MAX*F5Moo  ( +  .hj1 2 E Aw04W 0Id7m,tW h--2X T  UGSZ{I VVK  sPA G4 G4*G4G4$G4G47G4G0A G4G2A#G4/G42G4z/facetscV^8dQhR\\\\43,R\\\\ 43,R\ \\3,/#)rrrr&) rr rrr r r*r'r)r+s"r,r-r-ksL&& |W[%99 :& [',"77 8& #s(^&r.c "VP\R44GRjxL P4pVP\R44GRjxL P4pVP\R44GRjxL P4P 4pRVUUu.uF wrVRVRV/NK uppRVUUu.uF wrvRVRV/NK uppR \ T;'g/4/#LLLouuppiuuppi5i) uCOs valores que a fonte usa, para os filtros não serem adivinhados.zVSELECT tribunal, count(*) AS n FROM court_filings GROUP BY 1 ORDER BY 2 DESC LIMIT 250NzoSELECT especie, count(*) AS n FROM court_filings WHERE especie IS NOT NULL GROUP BY 1 ORDER BY 2 DESC LIMIT 120a( SELECT count(*) AS total, min(data_distribuicao) AS mais_antigo, max(data_distribuicao) AS mais_recente, (SELECT count(*) FROM court_filing_hits) AS acertos FROM court_filings tribunaisr5nespeciesresumo)r<r r?r>firstr*)rrrJrLrMtrKes&& r, filing_facetsrQjsoo 8    ceoo R    ce oo    hj  yAytqw3*yAh?hdagq#q)h?$v||$ 9   B?sWC>C,/C>C./C>C0&C>'C28 C>C8 C>$ C>.C>0C>2 C>z /{filing_id}c V^8dQhR\R\\\\43,R\\ \\ 43,R\\\3,/#)r filing_idrrr&) r'rr rrr r r*r)r+s"r,r-r-sV;;; |W[%99 :; [',"77 8; #s(^ ;r.c"VP\R4RV/4GRjxL P4P4pV'g\ \ P RR7hVP\R4RV/4GRjxL P4P4pVP\R4RV/4GRjxL P4P4p\V4pVR,e\VR,4MRVR&VUu.uFp\V4NK upVR &VUu.uFp\V4NK upVR &V#EL1LLuupiuupi5i) u4Um processo do arquivo, com todas as partes e o que o cruzamento decidiu. Os acertos vêm com o `match_kind`: quem foi identificado pelo NIF resolvido contra o registo comercial e quem foi só pelo nome. É a diferença entre uma certeza e uma semelhança, e quem lê a página tem direito a saber qual é. a- SELECT id::text, process_number, tribunal, unorganica, especie, valor, valor_raw, data_distribuicao, data_entrada, observacoes, first_seen_at, last_seen_at FROM court_filings WHERE id = CAST(:id AS UUID) idNunão encontrado) status_codedetailzSELECT id::text, name, role, nif, nif_source FROM court_filing_parties WHERE filing_id = CAST(:id AS UUID) ORDER BY role NULLS LAST, namea SELECT h.id::text, h.match_kind, h.matched_role, h.matched_nif, c.id::text AS company_id, c.legal_name, c.monitoring_type, c.nif, p.name AS party_name FROM court_filing_hits h LEFT JOIN companies c ON c.id = h.company_id LEFT JOIN court_filing_parties p ON p.id = h.party_id WHERE h.filing_id = CAST(:id AS UUID) r5r6acertos) r<r r>rNrr HTTP_404_NOT_FOUNDr?r*r@) rSrrlinhar6rXrFpas &&& r, filing_detailr]sUoo  9   hj  (A(AJ[\\oo 2  9    hj oo  9   hj " ;D,0M,EE$w-(4DM'-.v!d1gv.DN(/01tAw0DO K_   $/0sY!E%E'E% ;E%EAE%E AE%E. E%8E  E%E%E% E%z/rematchc V^8dQhR\\\\43,R\\\\ 43,R\ R,R\\\3,/#)rr_adminr!Nr&) rr rrr rrr*r'r))r+s"r,r-r-sZ 3 3 |W[%99 : 3 k7=#99 : 3 $; 3 #s(^ 3r.c6"\WR7GRjxL #L5i)uReaplica o cruzamento ao arquivo. É o que se corre quando entra uma empresa nova ou quando a regra de correspondência muda: sem isto, uma falha de correspondência era silenciosa e definitiva, porque a linha tinha sido deitada fora no momento da recolha. )sinceNr)rr_r!s&&&r,rematchrbsW2 22 2s )N)!__doc__datetimertypingrrfastapirrrrr sqlalchemyr sqlalchemy.ext.asyncior app.auth.depsr r rapp.dbrapp.services.court_filingsr app.services.registry_act_parserrroutergetrGrQr]postrbr.r,rqs!DD/BB2; */1B CB$37 #>=aA&2!4OWOWdI&&RN;;|Z 3 3r.