+ mej3!Rt^RIt^RIt^RIHt^RIHt^RIHt^RI H t ^RI H t ^RI HtHtHt^RIHt^R IHt^R IHt^R IHtHt]P4!]4tR R ltRRltRRltRRRllt R#)zOn-demand company analysis. Given a NIF (+ optional name), ensure a `companies` row exists (creating one with monitoring_type='analysis' if missing), run scrapers synchronously for that single company, then compute metrics + risk score. N)Any)text) AsyncSession)AsyncSessionLocal)scrape_cire_for_nif)discover_tribunal_codesscrape_distribuicao_rangeshort_search_term) lookup_nif)upsert_process) is_valid_nif) compute_riskupdate_company_riskc V^8dQhR\R\R\R,R\\\\3,\ 3,/#)sessionnif name_hintNreturn)rstrtupledictrbool)formats"app/services/analysis.py __annotate__rsB.. . #.03d . 4S>4  .cR"VP\R4RV/4GRjxL P4pV'd)RV^,RV^,RV^,RV^,/R3#\V4GRjxL pT;'gVP R4;'gR V 2pVP R 4R 8XdVP R 4MRpTP\R 4RTRTRVP R4RVP R4RVP R4RV'd\ P !V4MRR\V4/4GRjxL P4pVP4GRjxL RV^,RV^,RV^,RV^,/R3#ELzEL,LXL45i)z-Return ({id, nif, legal_name}, created_flag).zOSELECT id::text, nif, legal_name, monitoring_type FROM companies WHERE nif = :nnNidr legal_namemonitoring_typeFzNIF sourceptdatarawa INSERT INTO companies (nif, legal_name, cae, address, status, ptdata_payload, ptdata_fetched_at, monitored, monitoring_type) VALUES (:nif, :ln, :cae, :addr, :st, CAST(:pl AS JSONB), CASE WHEN :pt THEN now() ELSE NULL END, TRUE, 'analysis') RETURNING id::text, nif, legal_name, monitoring_type lncaeaddraddressststatusplptT) executerfirstr getjsondumpsrcommit)rrrrowdatalegalpayloadcreateds&&& r_ensure_companyr8s oo b c #J   eg   3q65#a&,A@QSVWXSY Z   C D  ? ?,/ ? ?T#.__annotate__ls"  DcN t rc |<"S;_uu_4GRjxL \VR,VR,SSS.SR7GRjxL pSPV4RRR4GRjxL R#LPL) \d)p\P RTR,T4Rp?LDRp?ii;iL@ +GRjxL 'giR#;i5i)Nvaluelabel) party_filterz$analysis Dist tribunal=%s failed: %s)rextend Exceptionloggerwarning) rBme all_matchesr: date_fromdate_tosearchsems & rworker"_scrape_and_ingest..workerlsss 7' AgJ 7 A &&q) ss !NN>' Assss}B<A#B<B#A'A%A' B<BB<%A'' B2BBBBB<B9 %B(& B9 1B9 3 B<c34<"TF pS!V4xK R#5iN).0rBrSs& r %_scrape_and_ingest..ys<)Qvayy)su-analysis Distribuição failed for nif=%s: %si!)rrr r2rIrJrKasyncio app.configr>rr SemaphoreSCRAPE_CONCURRENCYdatetimer?r@todaygather)r:matchessr3rMr[ _settings tribunalsr?r@rrNrOrPrQrRrSsf @@@@@@r_scrape_and_ingestrgNsQ+GENGDMPWXX (***a"C(000#hhj  +** %[4133 "7<#89  < <=,JJL9'#:: **,,.   nn<)<=== (***a$A(...%hhj  +** SY*0 +*** Q+. +*** [FPUXYZZ[sJG+F? G+G+ GG+G%G &GGG G+G G+JI 0H"1I JA>I H% I I 2H'3I 6H/ H) H/&H+'H/+ I 6H-7I ;J?G+G+GG G+G( G G( G( "G+&J(G++ H6HJHJ"I %I 'I )H/+H/-I /I 5H86 I I I J I JI;5J;JJc^V^8dQhR\R\R\\\3,/#)rr company_idr)rrrr)rs"rrrs,44 4'*4 #s(^4rcj"VP\R4RV/4GRjxL P4pVP\R4RV/4GRjxL P4pVUu/uFqD^,V^,bK ppVP\R4RV/4GRjxL P4pVUu.uF pRV^,R\ V^,4/NK" pp\ W4GRjxL wrRV^,RV^,R V^,R VR VR VR V /#LLuupiLuupiL;5i)aK SELECT count(*) AS total, count(*) FILTER (WHERE date_filed >= (now() - interval '30 days')::date) AS d30, count(*) FILTER (WHERE date_filed >= (now() - interval '180 days')::date) AS d180 FROM processes WHERE company_id = :cid cidNzNSELECT source, count(*) FROM processes WHERE company_id = :cid GROUP BY sourceaY SELECT to_char(date_trunc('month', date_filed), 'YYYY-MM') AS month, count(*) AS c FROM processes WHERE company_id = :cid AND date_filed >= (now() - interval '24 months')::date GROUP BY month ORDER BY month monthcounttotal_processeslast_30dlast_6m by_sourcetimeline risk_score risk_reasons)r-rr.allintr ) rritotalsby_source_rowsrfrq timeline_rowsrrrsrts && r_compute_metricsrzs\oo  J    eg oo ` J     ce&44^1qt^I4oo  J    ce >KK]!A$QqT3]HK%1'%FFJ6!9F1I6!9YHj  Q  5 LFs]!D3D!2D3D#D3-D%"D3(D*)D3?&D,%D35D16,D3#D3%D3,D3clV^8dQhR\R\R,R\\\3,/#)rrrNr)rrr)rs"rrrs-77C7C$J7$sCx.7rc @"\V4'g \R4h\4;_uu_4GRjxL p\W V4GRjxL wr4RRR4GRjxL \4;_uu_4GRjxL pVP \ R4R\ P!RVRXR,/4/4GRjxL P4^,pVP4GRjxL RRR4GRjxL \X4GRjxL \4;_uu_4GRjxL p\W#R,4GRjxL p\W#R,4GRjxL VP \ R4RXRVR ,/4GRjxL VP4GRjxL RRR4GRjxL RTR,RTR,RTR,RTR,RXRX/#ELELEL +GRjxL 'giEL;iELELNEL$EL +GRjxL 'giEL/;iEL#EL LLLLL +GRjxL 'giL;i \dp\PR T4\4;_uu_4GRjxL pTP \ R 4RXR \!T4R ,/4GRjxL TP4GRjxL RRR4GRjxL h +GRjxL 'gih;iRp?ii;i5i)z invalid NIFNz INSERT INTO scraping_logs (source, started_at, status, params) VALUES ('analysis', now(), 'running', CAST(:p AS JSONB)) RETURNING id::text prrirzZUPDATE scraping_logs SET finished_at = now(), status = 'ok', rows_seen = :n WHERE id = :idrrnzanalysis failed: %szYUPDATE scraping_logs SET finished_at = now(), status = 'error', error = :e WHERE id = :idrM:NiNr r!metricsr7)r ValueErrorrr8r-rr0r1r.r2rgrzrrIrJ exceptionr)rrrr:r7log_idr~rMs&& r run_analysisrs   '' """g!0y!II#"!"""g//djj%lGDM!JKL   %'! nn#"  )))$&&&',WdmDDG%gt}= = =//pvsG,=$>?    .." " "'&. gdm wu~gl+7#4577  Y#I#"""#  #"""" *&D =  #'&&&  .2$&&&'//ovsCF5M2    .." " "'&& '&&  s3LGLG( G" G( LG%L6H7L:AH:H;,H'H (H, L7H8L=I H. I&H1'I*H>H4H>H6-H>H8 H> H:!H>% I0H<1I5+L"G(%L(H .G1/ H :H < LH HLH+ H H+ #H+ % L.I1I4H>6H>8H>:H><I>I I I I ILI L%,LJ L3K: K K:"K% #K:( L3K64L:L L L L LLLrV)!__doc__r0loggingtypingr sqlalchemyrsqlalchemy.ext.asynciorapp.dbrapp.scrapers.cirerapp.scrapers.distribuicaorrr app.services.nif_lookupr app.services.ingestr app.services.nifr app.services.riskr r getLogger__name__rJr8rgrzrrWrrrsf  /$1 /.)?   8 $.b3[l4n77r