(8i U,ddlZddlmZddlmZmZddlmZddlm Z ddl m Z ddl m Z mZmZmZej"eZddlmZmZmZdd lmZmZmZdd lmZmZmZm Z ej"eZe d d g Z!e!jEdddeddide dde ddedddedddedddeddd ee eefd!ee#d"eed#eed$ee#d%dd&e f d'Z$e!jEd(d)d*edd+ide dde ddedd,d-edddedddeddd ee eefd.ee#d"eed#eed$ee#d%dd&e f d/Z%e!jEd0d1d2edd3ide dde ddedd4dedddedddedd5dedd6dedd7d edd8d9ee eef d!ee#d:eed;eedee#d?ee&d%dd&e fd@Z'y)AN)date)OptionalUnion) get_mysql_db)require_fix_token) AsyncSession) APIRouterDependsQuerystatus)OmieContaReceberResponseOmieContaReceberBoletoResponseOmieBoletoCompletoResponse)OmieContaReceberServiceOmieContaReceberBoletoServiceOmieBoletoCompletoService)build_success_payloadto_schema_dictSuccessResponse ErrorResponsez/contas-receberzOmie - Contas a Receber)prefixtagszListar contas a receber da Omieu Consulta a tabela **omie_contaReceber** no banco de dados **MySQL (DataLake)**. **⚠️ IMPORTANTE:** Esta rota consulta dados da **Omie** armazenados no **MySQL**, diferente das rotas do sistema Alerta Fiscal que consultam o **SQL Server**. **Tabela:** `omie_contaReceber` (MySQL) **Filtros suportados (todos opcionais):** - `cnpj`: Filtra por CNPJ (busca parcial) - `data_inicio`: Data inicial para filtro de vencimento (formato: YYYY-MM-DD) - `data_fim`: Data final para filtro de vencimento (formato: YYYY-MM-DD) - `status`: Filtra por status da conta **Exemplos:** 1. **Buscar todas as contas a receber:** ```bash curl -X GET 'http://localhost:8000/contas-receber' -H 'Authorization: Bearer ' ``` 2. **Buscar por CNPJ:** ```bash curl -X GET 'http://localhost:8000/contas-receber?cnpj=12345678000190' -H 'Authorization: Bearer ' ``` 3. **Buscar por período de vencimento:** ```bash curl -X GET 'http://localhost:8000/contas-receber?data_inicio=2024-01-01&data_fim=2024-12-31' -H 'Authorization: Bearer ' ``` 4. **Buscar por status:** ```bash curl -X GET 'http://localhost:8000/contas-receber?status=Pendente' -H 'Authorization: Bearer ' ``` **SQL Base:** ```sql SELECT * FROM omie_contaReceber WHERE (cnpj LIKE '%{cnpj}%' OR :cnpj IS NULL) AND (data_vencimento >= :data_inicio OR :data_inicio IS NULL) AND (data_vencimento <= :data_fim OR :data_fim IS NULL) AND (status = :status OR :status IS NULL) ``` descriptionzLista de contas a receberu"Credenciais inválidas ou ausentes)rmodelz Erro interno)ii)summaryrresponse_model responsesz Filtrar por CNPJ (busca parcial)12345678000190)rexamplez3Data inicial para filtro de vencimento (YYYY-MM-DD)z 2024-01-01z1Data final para filtro de vencimento (YYYY-MM-DD)z 2024-12-31zFiltrar por statusPendentecnpj data_iniciodata_fimr _dbc Ktjd|d|d|d| tj|||||d{}g}|D]$} t t |} |j | &t|} g} |r| j d|d|r| j d |d|r| j d |d|r| j d |d| rd d j| nd} | dk(rd| }n| dk(rd| }n| d| }tjd|t||S7#t$r} tjd| d} ~ wwxYw#t$r } tjd| dd} ~ wwxYww)Nz,Iniciando busca de contas a receber - CNPJ: , Data:  a , Status: )r#r$r%r $Erro ao converter item para schema: CNPJ contendo ''Vencimento a partir de 'Vencimento até 'Status ' com filtros: , rrz"Nenhuma conta a receber encontradaz1 conta a receber encontradaz contas a receber encontradasBusca concluída com sucesso: datamessagez!Erro ao listar contas a receber: Texc_info) loggerinforlistarrr append Exceptionerrorlenjoinr)r#r$r%r r&r'itemsr7item convertedeqtdfiltrossufixor8s 6/srv/www/app-alerta/controllers/omie_contas_receber.pylistar_contas_receberrKsF KK>tfH[MY\]e\ffpqwpxyz*-44 #    D *+CTJ  I& $i  NN_TF!4 5  NN5k]!D E  NN.xj: ;  NNXfXQ/ 0:A>$))G"4!56r !8:6(CG AX4VH=G:6(CG 4WI>?$$@@K   CA3GH 4  8' ``` 2. **Buscar por código de lançamento:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto?codigo_lancamento=12345' -H 'Authorization: Bearer ' ``` 3. **Buscar por período de vencimento:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto?data_inicio=2024-01-01&data_fim=2024-12-31' -H 'Authorization: Bearer ' ``` **SQL Base:** ```sql SELECT * FROM omie_contaReceber_boleto WHERE (codigo_lancamento = :codigo_lancamento OR :codigo_lancamento IS NULL) AND (data_vencimento >= :data_inicio OR :data_inicio IS NULL) AND (data_vencimento <= :data_fim OR :data_fim IS NULL) AND (status = :status OR :status IS NULL) ``` zLista de boletosu"Filtrar por código do lançamento12345codigo_lancamentoc Ktjd|d|d|d| tj|||||d{}g}|D]$} t t |} |j | &t|} g} |r| j d|d|r| j d |d|r| j d |d|r| j d |d| rd d j| nd} | dk(rd| }n| dk(rd| }n| d| }tjd|t||S7#t$r} tjd| d} ~ wwxYw#t$r } tjd| dd} ~ wwxYww)Nu2Iniciando busca de boletos - Código Lançamento: r)r*r+)rNr$r%r r,uCódigo Lançamento 'r.r/r0r1r2r3rrzNenhum boleto encontrador4z1 boleto encontradoz boletos encontradosr5r6zErro ao listar boletos: Tr9) r;r<rr=rrr>r?r@rArBr)rNr$r%r r&r'rCr7rDrErFrGrHrIr8s rJlistar_boletosrPsz KKDEVDWW_`k_llopxoyzDEKDLMN*3:: /#    D *+I4P  I& $i  NN23D2EQG H  NN5k]!D E  NN.xj: ;  NNXfXQ/ 0:A>$))G"4!56r !809G AX+F84G1&:G 4WI>?$$@@K   CA3GH 4  /s3d C rLz/boleto/completoz:Listar boletos completos com dados da empresa e vencimentou Consulta **boletos com JOIN** nas tabelas **omie_contaReceber_boleto** e **omie_contaReceber** no banco de dados **MySQL (DataLake)**. **⚠️ IMPORTANTE:** Esta rota retorna dados combinados de ambas as tabelas, incluindo: - **Data de emissão do boleto** (`dDtEmBol` da tabela `omie_contaReceber_boleto`) - **Data de vencimento** (`data_vencimento` da tabela `omie_contaReceber`) - **CNPJ da empresa** (`cnpj` da tabela `omie_contaReceber`) - Outros dados relevantes de ambas as tabelas **Tabelas:** `omie_contaReceber_boleto` + `omie_contaReceber` (MySQL) com JOIN **Filtros suportados (todos opcionais):** - `cnpj`: Filtra por CNPJ da empresa (busca parcial) - `data_vencimento_inicio`: Data inicial para filtro de vencimento (formato: YYYY-MM-DD) - `data_vencimento_fim`: Data final para filtro de vencimento (formato: YYYY-MM-DD) - `data_emissao_boleto_inicio`: Data inicial para filtro de emissão do boleto (formato: YYYY-MM-DD) - `data_emissao_boleto_fim`: Data final para filtro de emissão do boleto (formato: YYYY-MM-DD) - `status_titulo`: Filtra por status do título - `pago`: Filtra por status de pagamento (true = apenas pagos, false = apenas não pagos) **Exemplos:** 1. **Buscar todos os boletos completos:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto/completo' -H 'Authorization: Bearer ' ``` 2. **Buscar por CNPJ da empresa:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto/completo?cnpj=12345678000190' -H 'Authorization: Bearer ' ``` 3. **Buscar por período de vencimento:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto/completo?data_vencimento_inicio=2024-01-01&data_vencimento_fim=2024-12-31' -H 'Authorization: Bearer ' ``` 4. **Buscar por período de emissão do boleto:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto/completo?data_emissao_boleto_inicio=2024-01-01&data_emissao_boleto_fim=2024-12-31' -H 'Authorization: Bearer ' ``` 5. **Buscar por CNPJ e período de vencimento:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto/completo?cnpj=12345678000190&data_vencimento_inicio=2024-01-01&data_vencimento_fim=2024-12-31' -H 'Authorization: Bearer ' ``` 6. **Buscar apenas boletos PAGOS:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto/completo?pago=true' -H 'Authorization: Bearer ' ``` 7. **Buscar apenas boletos NÃO PAGOS:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto/completo?pago=false' -H 'Authorization: Bearer ' ``` 8. **Buscar boletos não pagos de uma empresa específica:** ```bash curl -X GET 'http://localhost:8000/contas-receber/boleto/completo?cnpj=12345678000190&pago=false' -H 'Authorization: Bearer ' ``` **SQL Base:** ```sql SELECT b.codigo_lancamento_omie, b.dDtEmBol as data_emissao_boleto, b.cNumBoleto as numero_boleto, b.cCodBarras as codigo_barras, b.cLinkBoleto as link_boleto, b.cCodStatus as status_boleto, b.cDesStatus as descricao_status, c.cnpj, c.data_vencimento, c.data_emissao, c.valor_documento, c.numero_documento, c.status_titulo, c.codigo_cliente_fornecedor FROM omie_contaReceber_boleto b INNER JOIN omie_contaReceber c ON b.codigo_lancamento_omie = c.codigo_lancamento_omie WHERE (c.cnpj LIKE '%{cnpj}%' OR :cnpj IS NULL) AND (c.data_vencimento >= :data_vencimento_inicio OR :data_vencimento_inicio IS NULL) AND (c.data_vencimento <= :data_vencimento_fim OR :data_vencimento_fim IS NULL) AND (b.dDtEmBol >= :data_emissao_boleto_inicio OR :data_emissao_boleto_inicio IS NULL) AND (b.dDtEmBol <= :data_emissao_boleto_fim OR :data_emissao_boleto_fim IS NULL) AND (c.status_titulo = :status_titulo OR :status_titulo IS NULL) AND ( (:pago IS NULL) OR (:pago = true AND (c.data_pagamento IS NOT NULL OR c.valor_pago > 0)) OR (:pago = false AND c.data_pagamento IS NULL AND (c.valor_pago IS NULL OR c.valor_pago = 0)) ) ``` zLista de boletos completosz+Filtrar por CNPJ da empresa (busca parcial)udData inicial para filtro de emissão do boleto (YYYY-MM-DD). Deixe vazio ou omita para não filtrar.ubData final para filtro de emissão do boleto (YYYY-MM-DD). Deixe vazio ou omita para não filtrar.uFiltrar por status do títulouPFiltrar por status de pagamento (true = apenas pagos, false = apenas não pagos)Tdata_vencimento_iniciodata_vencimento_fimdata_emissao_boleto_iniciodata_emissao_boleto_fim status_titulopagoc  Kd} d} |r4|jr$ tj|j} |r4|jr$ tj|j} | }| }t jd|d|d|d|d|d|d| tj|||||||| d{} g} | D]#} t| d r | jnd}t| d r | jnd}t| d r | jnd}t| d r | jnd}|(|&t jdt!| ddd|d}|rt#|j%}|dv}|duxs'|duxr|duxrt'|t'|k\xs|}| t'|nd}|r|dk(r |r t'|}id| j(d| j*d| j,d| j.d| j0d| j2d| j4d| j6d| j8d| j:d | jrt'| jndd| j<d | jd | j>d |d |d!|t!| d"dt!| d#dt!| d$dt!| d%dd&}| jA|&tK| }g}|r|jAd-|d.|r|jAd/|d.|r|jAd0|d.|r|jAd1|d.|r|jAd2|d.|r|jAd3|d.||jAd4|rd5nd6|rd7d8jM|nd9}|dk(rd:|}n|d;k(rd<|}n|d=|}t jd>|tO| |?S#ttf$rt j d|YwxYw#ttf$rt j d|YwxYw7#tB$rP}t jEd'|d()t jd*tG| d+tI| dd,d}~wwxYw#tB$r }t jEd@|d()d}~wwxYww)ANu+Data de emissão boleto início inválida: u'Data de emissão boleto fim inválida: z-Iniciando busca de boletos completos - CNPJ: z, Vencimento: r*u, Emissão Boleto: r+z, Pago: )r#rQrRrSrTrUrVdata_pagamento valor_pagorUvalor_documentoz Registro codigo_lancamento_omiezN/Au=: data_pagamento e valor_pago estão NULL, mas status_titulo=F)RECEBIDOPAGOBAIXADO LIQUIDADOzRECEBIDO PARCIALMENTEzPAGO PARCIALMENTEgrdata_emissao_boleto numero_boleto codigo_barras link_boleto status_boletodescricao_statusr#data_vencimento data_emissaonumero_documentocodigo_cliente_fornecedorrVcodigo_cliente_omie cnpj_clienterazao_social_clientenome_fantasia_cliente)rjrkrlrmu)Erro ao converter item para dicionário: Tr9z Item type: z , Item repr: rr-r.r/r0uEmissão boleto a partir de 'uEmissão boleto até 'r1zPago: SimuNãor2r3rz!Nenhum boleto completo encontrador4z1 boleto completo encontradoz boletos completos encontradosr5r6z"Erro ao listar boletos completos: )(stripr fromisoformat ValueErrorAttributeErrorr;warningr<rlistar_completohasattrrXrYrUrZdebuggetattrstrupperfloatr[r`rarbrcrdrer#rfrgrhrir>r?r@typereprrArBr)r#rQrRrSrTrUrVr&r'!data_emissao_boleto_inicio_parseddata_emissao_boleto_fim_parsedrCr7rDrXrYrZ status_pago status_upperfoi_pagovalor_pago_final item_dictrFrGrHrIr8s rJlistar_boletos_completosrs|9=%59"!&@&F&F&H g040B0BC]CcCcCe0f -#:#@#@#B `-1-?-?@W@]@]@_-` * "C< KK -.c2E1FG67s;R:ST /"  p/?? #9 3'A$;'   B DA 9@FV8W!4!4]a07l0KT__QU 6=dO6T 2 2Z^ :A$HY:Z$"6"6`d")j.@LL9WT;SUZ-[,\]Z[hZi"jk $  #&}#5#;#;#=L".3#K #$. t+{t0K{PUV`Paejkze{P{ 9C8N5#4TW  0A 5/',_'=$,d.I.I)4+C+C$T%7%7$T%7%7  "4#3#3  $T%7%7 '(=(=DII&t';';#D$5$5&dFZFZuT-A-A'B`c'(=(=$T%7%701O1O%n !"2!"H#&,349NPT+U$+D.$$G,3D:PRV,W-4T;RTX-Y- 0 I&{B H$i  NN_TF!4 5 ! NN56L5MQO P  NN./B.C1E F % NN:;U:VVWX Y " NN34K3LAN O  NNXm_A6 7   NNVTEv#>? @:A>$))G"4!56r !89&BG AX4VH=G;F8DG 4WI>?$$@@CN+ g NNHIcHde f g N+ ` NNDE\D]^ _ `  V  HLW[ \ {4:,mDJtPSDTCUVW  D  9!= M sS$#O=S$#P+3.S$" R8Q R8HQ/D R8<S$='P($S$'P((S$+'QS$QS$R8 R5%A R00R55R88 S!SS!!S$)(loggingdatetimertypingrr core.databaser core.authrsqlalchemy.ext.asynciorfastapir r r r getLogger__name__r;schemas.omie_contas_receberr rrservices.omie_contas_receberrrrcore.api_responsesrrrrroutergetrxrKrPboolrrJrs"&'/55   8 $||zzdd   8 $   # $   -0b#8 9AM Z+m Dk :x 2T^no"':ozF#G$T7juA B!$4HR\]'(|, 4 3-4$4tn4 SM 4  4  4w:v4l 9*V#/ 0AM Z+m D_ 4l(-T?cmt'u"':ozF#G$T7juA B!$4HR\]'(|, 4}4$4tn4 SM 4  4  4k4j4l HgP#9 :AM Z+m DY qf 2_iyz-24EzEQ.R*/Bu@L+M05dIoyE1F-24Fjt@.A#(;Zdn#o 4FPTU'(|,W 3-W$TNW"$W!) W &c] W C= W 4.W W WeqdWr