a 9.j1@sddlZddlZddlZddlZddlmZdZdddddd Zd d Zd d Z ddZ d3ddZ ddZ ddZ ddZd4ddZddZddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd5d/d0Zd1d2ZdS)6N)datetimez/var/www/html/chat.logZ localhostZ whatsapp_userz @dlkobs901Zwhatsapp_atendimento_hibridoZutf8mb4)ZhostuserZpasswordZdatabasecharsetcCstjjfitS)u:Retorna uma nova conexão ativa com a base de dados MySQL.)mysqlZ connectorZconnect DB_CONFIGrr/var/www/html/utils_hibrido.py obter_conexaosr c Cstd}d|d|d|}t|z@ttddd}||dWd n1sd0YWn6ty}ztd t |WYd }~n d }~00d S) uLGrava as ações centralizadamente no arquivo chat.log e espelha no console.z%Y-%m-%d %H:%M:%S[z] [z] azutf-8)encoding Nu❌ Erro ao escrever log: ) rZnowstrftimeupperprintopen LOG_FILE_PATHwrite Exceptionstr)ZorigemmensagemZ timestampZ log_linhaferrr registrar_logs0rcCs|sdStdd|S)uCFiltra o input do cliente mantendo apenas os caracteres numéricos.z\D)resub)textorrrlimpar_cpf_cnpj#srrc Cstz0|d|f|}|r.|dr.|dWSWn>tyn}z&tdd|dt|WYd}~n d}~00|S)zSRecupera dinamicamente as respostas configuradas na tabela robot_prompts_mensagens.z=SELECT conteudo FROM robot_prompts_mensagens WHERE chave = %sZconteudo SYSTEM_ERRORzErro ao ler mensagem 'z': N)executefetchonerrr)cursorchaveZfallbackresultrrrrobter_mensagem_db)s 0r%cCs&|d|f|}|r"|dSdS)u7Busca uma configuração específica no banco de dados.z1SELECT valor FROM config_sistema WHERE chave = %svalorN)r r!)r"r#resrrr buscar_config4sr(c Cs|d}|d}|r|s*tdddSd|d}d|d d }d |d d |id}z`tj|||dd}|jdkrtdd|dWdStdd|jd|jddWdSWn<ty} z"tddt| WYd} ~ dSd} ~ 00dS)zGEfetua o envio de mensagens de texto via API Cloud oficial do WhatsApp.ZWHATSAPP_TOKENZPHONE_NUMBER_IDrzEFalha ao enviar WhatsApp: WHATSAPP_TOKEN ou PHONE_NUMBER_ID ausentes.Fz!https://graph.facebook.com/v25.0/z /messagesBearer application/jsonZ Authorization Content-TypeZwhatsapptextbody)Zmessaging_producttotyper-jsonheaderstimeoutZ WHATSAPP_APIu&✔ Mensagem enviada com sucesso para .Tu❌ Erro de envio (): NuExceção ao enviar mensagem: )getrrequestspost status_coder-rr) configsZnumerorZtokenZphone_idurlr4payloadresponserrrrenviar_whatsapp:s0     " rAc Cs*|d}|d}|r|s*tdddSd|dd}d d |d d |d gd ddid}ztj|||dd}|jdkr|}|dddd} tdd| ddt| WStdd|jd|jddWdSWn<t y$} z"tddt | WYd} ~ dSd} ~ 00dS)zNConsulta a API do DeepSeek retornando estritamente um objeto JSON estruturado.ZDEEPSEEK_API_KEYZDEEPSEEK_API_URLZ IA_CLASSIFIERu-Credenciais da API DeepSeek não encontradas.Nr)r*r+z deepseek-chatsystem)Zrolecontentrgr0Z json_object)ZmodelZmessagesZ temperatureZresponse_formatr2r6ZchoicesrmessagerCzResposta da IA: uErro na requisição (r8u!Exceção ao consultar DeepSeek: ) r9rr:r;r<r3striploadsr-rr) r=Zmensagem_usuarioZprompt_sistemaapi_keyZapi_urlr4r?r@ resultadoZ retorno_textorrrrconsultar_deepseek[s6      " rJGETc st|d}t|d}|r|s0tdddddS|d}|rx|D],\}}d |d } | |vrJ|| t|}qJ|d d } tdd |d|z|dkrtj|| dd} n|dkr|r؇fdd|Dni} tj|| | dd} nR|dkr.|rfdd|Dni} tj || | dd} ndd|ddWStdd| j | j dkrpd| dWStdd| j d| j d d!dd"| j | j d#WSWnHt y} z.tdd$t| dt| dWYd } ~ Sd } ~ 00d S)%um Chama a API RadiusNet usando as configurações do banco. Args: cursor: cursor do banco de dados endpoint: string do endpoint (ex: '/cp/{cpf}/2') params: dict com parâmetros para substituir na URL metodo: 'GET', 'POST' ou 'PUT' Returns: dict: {'success': bool, 'data': dict ou list, 'error': str} ZRADIUSNET_API_URLZRADIUSNET_API_KEY RADIUSNETu.Credenciais não encontradas no config_sistemaFuCredenciais não configuradas)successerror/{}r*)ZRTOKENr,zChamando API:  rKr1)r4r5POSTcs&i|]\}}d|dvr||qSrPrQr.0kvendpointrr z(chamar_api_radiusnet..r2PUTcs&i|]\}}d|dvr||qSrTrrUrYrrr[r\uMétodo u não suportadozResposta HTTP: r6T)rMdataz Erro HTTP z: NizHTTP )rMrNZdetailsu Exceção: )r(rrstripitemsreplacerr:r9r;Zputr<r3r-r)r"rZparamsmetodoZbase_urlrHr>keyvalueZ placeholderr4Zrespr.rrrYrchamar_api_radiusnetsB        "rfcCsd}d|i}t|||dd}|dr|d}t|trfd|vrftdd |d d d ||dSt|trtdd t|d ||Stdd t|gSntdd|dgSdS)z Busca cliente por CPF. Endpoint: GET /cp/{cpf}/2 Retorna lista de cadastros (extrai do campo 'rows' da resposta) z /cp/{cpf}/2cpfrKrcrMr^rowsrLz Encontrados countrz cadastros para CPF z"Estrutura de resposta inesperada: zErro na consulta: rNN)rfr9 isinstancedictrlistlenr0)r"rgrZrbrIr^rrrconsultar_cliente_por_cpfs  rocCsPd}d|i}t|||dd}|drL|d}t|trHd|vrH|dS|SdS) z Busca dados completos do cliente por ID. Endpoint: GET /cpcd/cli/{id_cliente} Retorna: dados do cliente incluindo emails e telefones z/cpcd/cli/{id_cliente} id_clienterKrhrMr^riN)rfr9rkrl)r"rprZrbrIr^rrrconsultar_cliente_por_ids rqcCs2d}d|i}t|||dd}|dr.|dSgS)uW Busca cobranças em atraso do cliente. Endpoint: GET /cbc/at/{id_cliente} z/cbc/at/{id_cliente}rprKrhrMr^rfr9r"rprZrbrIrrrcobrancas_cliente_atrasos  rtcCs2d}d|i}t|||dd}|dr.|dSgS)uu Busca cobranças não pagas do cliente (inclui vencidas e a vencer). Endpoint: GET /cbc/np/{id_cliente} z/cbc/np/{id_cliente}rprKrhrMr^rrrsrrrcobrancas_cliente_nao_pagass  rucCs2d}d|i}t|||dd}|dr.|dSgS)uj Busca cobranças em atraso de um plano específico. Endpoint: GET /cbp/at/{id_cliente_plano} z/cbp/at/{id_cliente_plano}id_cliente_planorKrhrMr^rrr"rvrZrbrIrrrcobrancas_plano_atraso s  rxcCs2d}d|i}t|||dd}|dr.|dSgS)uk Busca cobranças não pagas de um plano específico. Endpoint: GET /cbp/np/{id_cliente_plano} z/cbp/np/{id_cliente_plano}rvrKrhrMr^rrrwrrrcobrancas_plano_nao_pagass  rycCs2d}d|i}t|||dd}|dr.|dSdS)zi Gera URL do boleto PDF. Endpoint: GET /bc/{id_cobranca} Retorna: {'url': 'https://...'} z/bc/{id_cobranca} id_cobrancarKrhrMr^Nrrr"rzrZrbrIrrr gerar_boleto(s  r|cCs2d}d|i}t|||dd}|dr.|dSdS)uR Solicita desbloqueio em confiança. Endpoint: PUT /ppg/{id_cobranca} z/ppg/{id_cobranca}rzr]rhrMr^Nrrr{rrrdesbloquear_confianca7s  r}cCs*d}||d}t|||dd}|ddS)zz Adiciona novo e-mail ao cadastro. Endpoint: POST /adicemail/ Body: {"IDCLI": id_cliente, "EMAIL": email} z /adicemail/)IDCLIZEMAILrSrhrMFrr)r"rpZemailrZrbrIrrratualizar_emailEs rcCs.d}||||d}t|||dd}|ddS)z Adiciona novo telefone ao cadastro. Endpoint: POST /ct/ Body: {"IDCLI": id_cliente, "DDD": ddd, "TEL": telefone, "TT": tipo} Tipos: 1-Residencial, 2-Celular, 3-Comercial z/ct/)r~ZDDDZTELZTTrSrhrMFrr)r"rpZdddZtelefoneZtiporZrbrIrrratualizar_telefoneQsrcCs2d}d|i}t|||dd}|dr.|dSdS)uX Verifica se o cliente está online (conectado). Endpoint: GET /cpl/{login} z /cpl/{login}loginrKrhrMr^Nrr)r"rrZrbrIrrrverificar_status_online^s  r)r)NrK)r)r3rr:Zmysql.connectorrrrrr rrr%r(rArJrfrorqrtrurxryr|r}rrrrrrrs<   !+ <