(8iL5ddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z m Z mZmZddlmZmZmZmZdd lmZmZmZmZdd lmZmZmZmZej>e Z!ed d g Z"e"jGdddeddideddeddedddedddedddeeeefdee$d ee$d!ee$d"dd#e f d$Z%e"jGd%d&d'edd(ideddeddedddeeeefd ee$d"dd#e fd)Z&e"jGd*d+d,edd-ideddeddedddeeeefd ee$d"dd#e fd.Z'e"jGd/d0d1edd2ideddeddedddedd3d4edd5d6eddd7eeeefd ee$d8eed9eed!ee$d"dd#e f d:Z(y);N)date)Optional) get_mysql_db)require_fix_token) AsyncSession)OmieContratoResponseOmieContratoServicoResponse OmieContratoDepartamentoResponseOmieContratoVencimentoResponse)OmieContratoServiceOmieContratoServicoServiceOmieContratoDepartamentoServiceOmieContratoVencimentoService) APIRouterDependsQuerystatus)build_success_payloadto_schema_dictSuccessResponse ErrorResponsez /contratoszOmie - Contratos)prefixtagszListar contratos da Omieu] Consulta a tabela **omie_contrato** 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_contrato` (MySQL) **Filtros suportados (todos opcionais):** - `cnpj`: Filtra por CNPJ (busca parcial) - `codigo_contrato`: Filtra por código do contrato - `status`: Filtra por status do contrato **Exemplos:** 1. **Buscar todos os contratos:** ```bash curl -X GET 'http://localhost:8000/contratos' -H 'Authorization: Bearer ' ``` 2. **Buscar por CNPJ:** ```bash curl -X GET 'http://localhost:8000/contratos?cnpj=12345678000190' -H 'Authorization: Bearer ' ``` 3. **Buscar por código de contrato:** ```bash curl -X GET 'http://localhost:8000/contratos?codigo_contrato=12345' -H 'Authorization: Bearer ' ``` **SQL Base:** ```sql SELECT * FROM omie_contrato WHERE (cnpj LIKE '%{cnpj}%' OR :cnpj IS NULL) AND (codigo_contrato = :codigo_contrato OR :codigo_contrato IS NULL) AND (status = :status OR :status IS NULL) ``` descriptionzLista de contratosu"Credenciais inválidas ou ausentes)rmodelz Erro interno)ii)summaryrresponse_model responsesz Filtrar por CNPJ (busca parcial)12345678000190)rexampleuFiltrar por código do contrato12345zFiltrar por statusAtivocnpjcodigo_contrator_dbcKtjd|d|d| tj||||d{}g}|D]$} t t |}|j |&t|} g} |r| j d|d|r| j d|d|r| j d |d| rd d j| nd } | d k(rd| } n| dk(rd| } n| d| } tjd| t|| S7#t$r} tjd| d} ~ wwxYw#t$r } tjd| dd} ~ wwxYww)Nz%Iniciando busca de contratos - CNPJ: u , Código: , Status: )r%r&r$Erro ao converter item para schema: zCNPJ contendo ''Código Contrato 'Status ' com filtros: , rrzNenhum contrato encontradoz1 contrato encontradoz contratos encontradosBusca concluída com sucesso: datamessagezErro ao listar contratos: Texc_info) loggerinfor listarrrappend Exceptionerrorlenjoinr)r%r&rr'r(itemsr4item convertedeqtdfiltrossufixor5s 1/srv/www/app-alerta/controllers/omie_contratos.pylistar_contratosrHst KK7v[HYYcdjcklm')00 +    D *+?F  I& $i  NN_TF!4 5  NN//@B C  NNXfXQ/ 0:A>$))G"4!56r !826(;G AX-fX6G3F8?$$@@E   CA3GH 0  1!5 E s]E2ED E !D,B-EE2E E%D>>EE E/E**E//E2z /servicosu&Listar serviços dos contratos da OmieuW Consulta a tabela **omie_contrato_servico** 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_contrato_servico` (MySQL) **Filtros suportados (todos opcionais):** - `codigo_contrato`: Filtra por código do contrato **Exemplos:** 1. **Buscar todos os serviços:** ```bash curl -X GET 'http://localhost:8000/contratos/servicos' -H 'Authorization: Bearer ' ``` 2. **Buscar serviços de um contrato específico:** ```bash curl -X GET 'http://localhost:8000/contratos/servicos?codigo_contrato=12345' -H 'Authorization: Bearer ' ``` **SQL Base:** ```sql SELECT * FROM omie_contrato_servico WHERE (codigo_contrato = :codigo_contrato OR :codigo_contrato IS NULL) ``` u Lista de serviços dos contratosc.Ktjd| tj||d{}g}|D]$} t t |}|j |&t|}|rd|dnd} |dk(rd| } n|d k(rd | } n|d | } tjd | t|| S7#t$r}tjd|d}~wwxYw#t$r }tjd|dd}~wwxYww)Nu1Iniciando busca de serviços - Código Contrato: r&r+ com filtro: Código Contrato 'r,rruNenhum serviço encontrador1u1 serviço encontradou serviços encontradosr2r3uErro ao listar serviços: Tr6) r8r9r r:rr r;r<r=r>r r&r'r(r@r4rArBrCrDfiltror5s rGlistar_servicosrNs<Z KKCOCTUV077O\\ D *+FM  I& $iIX2?2C1E^` !826(;G AX-fX6G3F8?$$@@+]  CA3GH   1!5 E ]DC)B= C)!B?$AC)<D=C)? C&C!!C&&C)) D2D  DDz/departamentosz*Listar departamentos dos contratos da Omieux Consulta a tabela **omie_contrato_departamento** 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_contrato_departamento` (MySQL) **Filtros suportados (todos opcionais):** - `codigo_contrato`: Filtra por código do contrato **Exemplos:** 1. **Buscar todos os departamentos:** ```bash curl -X GET 'http://localhost:8000/contratos/departamentos' -H 'Authorization: Bearer ' ``` 2. **Buscar departamentos de um contrato específico:** ```bash curl -X GET 'http://localhost:8000/contratos/departamentos?codigo_contrato=12345' -H 'Authorization: Bearer ' ``` **SQL Base:** ```sql SELECT * FROM omie_contrato_departamento WHERE (codigo_contrato = :codigo_contrato OR :codigo_contrato IS NULL) ``` z$Lista de departamentos dos contratosc.Ktjd| tj||d{}g}|D]$} t t |}|j |&t|}|rd|dnd} |dk(rd| } n|d k(rd | } n|d | } tjd | t|| S7#t$r}tjd|d}~wwxYw#t$r }tjd|dd}~wwxYww)Nu5Iniciando busca de departamentos - Código Contrato: rJr+rKr,rrzNenhum departamento encontrador1z1 departamento encontradoz departamentos encontradosr2r3zErro ao listar departamentos: Tr6) r8r9rr:rr r;r<r=r>rrLs rGlistar_departamentosrQs=Z KKGGXYZ5<?$$@@+b  CA3GH   5aS9D I rOz /vencimentosz(Listar vencimentos dos contratos da Omieu Consulta a tabela **omie_contrato_vencimentoTexto** 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_contrato_vencimentoTexto` (MySQL) **Filtros suportados (todos opcionais):** - `codigo_contrato`: Filtra por código do contrato - `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 do vencimento **Exemplos:** 1. **Buscar todos os vencimentos:** ```bash curl -X GET 'http://localhost:8000/contratos/vencimentos' -H 'Authorization: Bearer ' ``` 2. **Buscar vencimentos de um contrato específico:** ```bash curl -X GET 'http://localhost:8000/contratos/vencimentos?codigo_contrato=12345' -H 'Authorization: Bearer ' ``` 3. **Buscar vencimentos por período:** ```bash curl -X GET 'http://localhost:8000/contratos/vencimentos?data_inicio=2024-01-01&data_fim=2024-12-31' -H 'Authorization: Bearer ' ``` **SQL Base:** ```sql SELECT * FROM omie_contrato_vencimentoTexto WHERE (codigo_contrato = :codigo_contrato OR :codigo_contrato 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) ``` z"Lista de vencimentos dos contratosz3Data inicial para filtro de vencimento (YYYY-MM-DD)z 2024-01-01z1Data final para filtro de vencimento (YYYY-MM-DD)z 2024-12-31Pendente data_iniciodata_fimc 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)Nu*Iniciando busca de vencimentos - Código: z, Data: z a r*)r&rSrTrr+r-r,zVencimento a partir de 'uVencimento até 'r.r/r0rrzNenhum vencimento encontrador1z1 vencimento encontradoz vencimentos encontradosr2r3zErro ao listar vencimentos: Tr6) r8r9rr:rr r;r<r=r>r?r)r&rSrTrr'r(r@r4rArBrCrDrErFr5s rGlistar_vencimentosrVsz KK<_$))G"4!56r !84VH=G AX/x8G5fX>G 4WI>?$$@@K   CA3GH 4  3A37$ G s_"F E!D5 E!!D70CE!4F 5E!7 EEEE!! F *FF  F ))loggingdatetimertypingr core.databaser core.authrsqlalchemy.ext.asynciorschemas.omie_contratosrr r r services.omie_contratosr r rrfastapirrrrcore.api_responsesrrrr getLogger__name__r8routergetstrrHrNrQrVrGrhsI&'/  65dd   8 $       &(R#1 2AM Z+m D[ 2h 2T^no%*4=^ho%p!$4HRYZ'(|, 0 3-0c]0 SM0 0  0g2f0d 4<#? @AM Z+m DE 'R&+4=^ho%p'(|,!c]! ! !Q'P!F 8<#C DAM Z+m DE 'R&+4=^ho%p'(|,!c]! ! !Q'P!F 6*V#A BAM Z+m D_ 4l&+4=^ho%p"':ozF#G$T7juA B!$4HR\]'(|, 4c]4$4tn4 SM 4  4  4k4j4rg