+ [ej xRt^RIt^RIHtHt^RIHtHtHt^RI H t H t ^RI H t ^RIHt^RIHt^RIHt^R IHt^R IHt]P0!]4t]!R R .R 7t!RR] 4t!RR] 4t!RR] 4tRRlt]PAR]R7]PB!R4RRl44t"R#)uWatchlist de insolvências (v1 public API). Alimentada pelo Sabichão: ao criar um cliente, o NIF é empurrado para cá e a entidade passa a ser vigiada nos anúncios de insolvência do CITIUS. Duas garantias que moldam o desenho: * **Nunca se remove.** Um cliente desactivado continua a ser um devedor cujo processo de insolvência interessa acompanhar. O endpoint só faz upsert. * **Idempotente e tolerante.** O Sabichão chama isto no fluxo de criação de cliente; se falhar, o cliente tem de ser criado na mesma. Do lado de cá isso traduz-se em aceitar repetições sem erro e em normalizar o NIF (o Sabichão guarda-os com espaços, "517 607 891"). N) AnnotatedAny) APIRouterDependsRequest) BaseModelField)text) AsyncSession)require_api_key) get_session)limiter) rematch_nifz /watchlistz public-api)prefixtagscVa]tRt^!to]!RR7tRt]!RRR7tV3RltRt Vt R#) WatchlistItemu'NIF/NIPC; aceita espaços e pontuação descriptionNu2Referência do sistema de origem (nº de contrato))defaultrcZ<V^8dQh/S[;R&S[R,;R&S[R,;R&#)nifNname external_refstr)format __classdict__s"app/api/v1/watchlist.py __annotate__WatchlistItem.__annotate__!s2 K **) __name__ __module__ __qualname____firstlineno__rrrr__annotate_func____static_attributes____classdictcell__rs@rrr!s,!JKCD$"V Lr"rc,a]tRt^)toV3RltRtVtR#) WatchlistSyncc6<V^8dQh/S[S[,;R&#)ritems)listr)rrs"rr WatchlistSync.__annotate__)s  r"r#N)r$r%r&r'r(r)r*r+s@rr-r-)sr"r-cPa]tRt^-to]!RR7t]!RR7tV3RltRtVt R#)WatchlistResultu)NIFs rejeitados por não terem 9 dígitosru@Anúncios já arquivados que passaram a dar match com estes NIFscZ<V^8dQh/S[;R&S[;R&S[S[,;R&S[;R&#)r recebidosaceites ignoradoshits_retroactivos)intr0r)rrs"rr WatchlistResult.__annotate__-s9N LCyY r"r#N) r$r%r&r'rr7r8r(r)r*r+s@rr3r3-s'!-XYI"V r"r3cLV^8dQhR\R,R\R,/#)rrawNreturnr)rs"rr r 6s"003:0#*0r"cnV'gR#RPRV44p\V4^ 8XdV#R#)Nc3T"TFqP4'gKVxK R#5i)N)isdigit).0chs& r _norm_nif..9s6#BRR#s( ()joinlen)r<digitss& r _norm_nifrI6s2  WW6#6 6F[A%6/4/r"r?)response_modelz 60/minutec V^8dQhR\R\R\\\ \ 43,R\\ \\3,\ \43,R\/#)rrequestpayloadsessionkeyr=) rr-rr rr dictrrr r3)rs"rr r ?s`== = =|W[%99 := 4S>7?#;; < =  =r"c "^p.p^pVPFp\VP4pV'gVPVP4K=VP \ R4RVRVP RVP/4GRjxL TP \ R4RTRVP ;'gRV 2/4GRjxL T\W(4GRjxL , pV^, pK VP4GRjxL \PRVPR 4V\V4V4\\VP4VVVR 7#LLLL]5i) u$Regista (ou actualiza) entidades a vigiar. Aceita um ou muitos. Cada NIF novo é imediatamente cruzado contra **todo** o arquivo de anúncios já guardado — é o que dá sentido a varrer o país inteiro: um cliente adicionado hoje pode já ter sido declarado insolvente na semana passada. a INSERT INTO insolvency_watchlist (nif, name, source, external_ref) VALUES (:nif, :name, 'sabichao', :ref) ON CONFLICT (nif) DO UPDATE SET name = COALESCE(EXCLUDED.name, insolvency_watchlist.name), external_ref = COALESCE( EXCLUDED.external_ref, insolvency_watchlist.external_ref), active = true, updated_at = now() rrrefNz INSERT INTO companies (nif, legal_name, monitoring_type, monitored) VALUES (:nif, :name, 'client', true) ON CONFLICT (nif) DO NOTHING zNIF zGwatchlist sync (key=%s): %d aceites, %d ignorados, %d hits retroactivoslabel)r5r6r7r8)r/rIrappendexecuter rrrcommitloggerinfogetrGr3) rLrMrNrOr6r7hitsitemrs &&&& rsync_watchlistr\=s]GI D !   TXX & oo   CE43D3D E   "oo  C!:!:SEl ;   k'///1 CF ..  KKQ '3y>4 gmm$  G " 0sOBE' E .E':E'E! E'E#*E'E%AE'!E'#E'%E')#__doc__loggingtypingrrfastapirrrpydanticrr sqlalchemyr sqlalchemy.ext.asyncior app.auth.api_key_authr app.dbr app.rate_limitr app.services.insolvency_matchingr getLoggerr$rWrouterrr-r3rIpostlimitr\r#r"rrls !//%/1"8   8 $ ,l^ <IIi0R0{=1=r"