a «7.jã@s4ddlZddlZddlmZmZmZmZdd„ZdS)éN)Ú registrar_logÚenviar_whatsappÚobter_mensagem_dbÚlimpar_cpf_cnpjcCsŠ|d}|d}| dd¡}| d¡} | r4t | ¡ni} tdd| d¡›d |›ƒt|ƒ} t| ƒd vrêtdd | ›ƒ| d | t d | i¡|f¡| ¡| d|f¡t |  ¡ƒ} t d | i¡| d<t   d¡} |   |||| ||¡dS|dkr*t|dƒ}|rt|||ƒ| d|f¡| ¡dS|dkrît|ƒ} t| ƒd vr¸| d| t d | i¡|f¡| ¡t   d¡} t |ƒ} d| d<d| d<t d | i¡| d<|   |||| ||¡n4| d|f¡| ¡t   d¡}|  ||||||¡nŽ| d¡dkr|d|d ¡›}z"t   |¡}|  ||||||¡WnHtyztdd|›dƒt||dƒ| d|f¡| ¡Yn0tddƒdS) NÚidZcliente_numeroÚ estado_atualZINICIOZ contexto_jsonZFLUXO_ROTEADORz Protocolo Z protocoloz - Estado: )é ézCPF detectado: z½ UPDATE atendimentos SET cliente_cpf = %s, fluxo_atual = 'IDENTIFICACAO', estado_atual = 'PROCESSAR_DOCUMENTO', contexto_json = %s WHERE id = %s Úcpfz(SELECT * FROM atendimentos WHERE id = %sÚfluxo_identificacaoZmsg_saudacao_inicialzx UPDATE atendimentos SET estado_atual = 'AGUARDANDO_RESPOSTA' WHERE id = %s ZAGUARDANDO_RESPOSTAzÍ UPDATE atendimentos SET cliente_cpf = %s, fluxo_atual = 'IDENTIFICACAO', estado_atual = 'PROCESSAR_DOCUMENTO', contexto_json = %s WHERE id = %s Z IDENTIFICACAOÚ fluxo_atualZPROCESSAR_DOCUMENTOz§ UPDATE atendimentos SET fluxo_atual = 'CLASSIFICACAO', estado_atual = 'AGUARDANDO_MENSAGEM' WHERE id = %s Úfluxo_classificacaoZROTEADORÚfluxo_uMódulo u não encontradozTransferindo para um atendente.zMUPDATE atendimentos SET status = 'fila', fluxo_atual = 'HUMANO' WHERE id = %suProcessamento concluído)ÚgetÚjsonÚloadsrrÚlenÚexecuteÚdumpsÚcommitÚdictÚfetchoneÚ importlibÚ import_moduleÚ processarrrÚlowerÚ ImportError)ÚconnÚcursorÚjobÚ atendimentoÚconfigsÚmensagem_brutaÚatendimento_idÚnumerorZraw_ctxÚctxZcpf_cnpjZ novo_atendr Z msg_saudacaor Ú modulo_nomeÚmodulo©r(ú/var/www/html/fluxo_roteador.pyrst   ü     ü ü ü   r)rrÚ utils_hibridorrrrrr(r(r(r)Ús