#!/usr/bin/env python3
# -*- coding: utf-8 -*-
import sys
import mysql.connector
from datetime import datetime
import smtplib
from email.mime.text import MIMEText
from email.mime.multipart import MIMEMultipart
# ─────────────────────────────────────────────
# CONFIGURAÇÕES DE EMAIL
# ─────────────────────────────────────────────
SMTP_CONFIG = {
'host': 'smtp.gmail.com',
'port': 587,
'user': 'ticocodovale@gmail.com',
'password': 'yzco wtbs plfu abhh',
'use_tls': True
}
# ─────────────────────────────────────────────
# MAPEAMENTO SETOR -> EMAIL
# ─────────────────────────────────────────────
EMAILS_SETORES = {
'almoxarifado': 'joseildof1@gmail.com',
'expedicao': 'expedicao@cocodovale.com.br',
'industria': 'industria@cocodovale.com.br',
'agricola': 'agricola@cocodovale.com.br',
'qualidade': 'qualidade@cocodovale.com.br',
}
# ─────────────────────────────────────────────
# CONFIGURACAO DO BANCO
# ─────────────────────────────────────────────
DB_CONFIG = {
'host': 'localhost',
'user': 'ti',
'password': '@vale.123',
'database': 'balanca',
'charset': 'utf8mb4'
}
# ─────────────────────────────────────────────
# ACOES CONTEXTUAIS POR PALAVRA-CHAVE NO MOTIVO
# ─────────────────────────────────────────────
ACOES_CONTEXTUAIS = [
(
['valor', 'preco', 'preco', 'unitario', 'divergente', 'diferente'],
'💰',
'Verifique os valores unitários da nota fiscal e compare com o pedido de compra. '
'Solicite ao fornecedor a emissão de nota corrigida ou carta de correção.'
),
(
['quantidade', 'qtd', 'qtde', 'volume', 'excede', 'menor', 'maior'],
'📦',
'Confira as quantidades da nota fiscal versus o pedido aprovado. '
'Alinhe com o fornecedor o ajuste antes da nova tentativa de entrega.'
),
(
['nota', 'fiscal', 'nf', 'nfe', 'danfe', 'ilegivel', 'incorreta', 'invalida'],
'📄',
'A nota fiscal apresenta inconsistência. Solicite ao fornecedor a emissão de '
'nota corrigida ou carta de correção eletrônica (CC-e) antes de retornar.'
),
(
['pedido', 'po', 'ordem', 'compra', 'nao aprovado', 'sem pedido', 'autorizado'],
'📋',
None # texto gerado dinamicamente com nome do setor
),
(
['fornecedor', 'empresa', 'cnpj', 'nao corresponde', 'diverge'],
'🏢',
'O fornecedor da nota fiscal não corresponde ao cadastrado no pedido. '
'Verifique se houve erro de emissão ou se o pedido precisa ser atualizado.'
),
]
def normalizar_texto(texto):
"""Remove acentos e converte para minusculas"""
if not texto:
return ''
mapa = {
'a':'a','a':'a','a':'a','a':'a','e':'e','e':'e',
'i':'i','o':'o','o':'o','o':'o','u':'u','u':'u','c':'c',
'\xe1':'a','\xe0':'a','\xe3':'a','\xe2':'a',
'\xe9':'e','\xea':'e','\xed':'i',
'\xf3':'o','\xf4':'o','\xf5':'o',
'\xfa':'u','\xfc':'u','\xe7':'c'
}
resultado = texto.lower().strip()
for ac, sem in mapa.items():
resultado = resultado.replace(ac, sem)
return resultado
def obter_email_setor(setor):
setor_norm = normalizar_texto(setor)
for chave, email in EMAILS_SETORES.items():
if normalizar_texto(chave) == setor_norm:
return email
for chave, email in EMAILS_SETORES.items():
if normalizar_texto(chave) in setor_norm or setor_norm in normalizar_texto(chave):
return email
return None
def detectar_acoes(motivo, setor='Setor Responsável'):
"""Retorna lista de acoes contextuais baseadas no motivo"""
if not motivo:
return []
motivo_norm = normalizar_texto(motivo)
setor_upper = (setor or 'Setor Responsável').upper()
acoes = []
for palavras, icone, texto in ACOES_CONTEXTUAIS:
if any(p in motivo_norm for p in palavras):
if texto is None:
# Ação de pedido — usa nome real do setor
texto = (
'O pedido de compra não está aprovado no sistema. '
'O setor ' + setor_upper + ' deve regularizar a aprovação '
'antes de autorizar o recebimento desta entrega.'
)
acoes.append((icone, texto))
if not acoes:
acoes.append(('📞', 'Entre em contato com o fornecedor e solicite a correção das '
'inconsistências apontadas. Após regularização, o setor de Compras '
'liberará a entrega no sistema YMS.'))
return acoes
def buscar_dados_veiculo(veiculo_id):
try:
con = mysql.connector.connect(**DB_CONFIG)
cur = con.cursor(dictionary=True)
cur.execute("""
SELECT
v.id, v.placa, v.condutor, v.fornecedor,
v.setorautoriza, v.finalidade, v.status,
v.compras_checklist,
h.observacao AS motivo_reprovacao,
h.usuario AS reprovado_por,
h.data_hora AS data_reprovacao
FROM entrada_veiculo v
LEFT JOIN historico_status h
ON h.veiculo_id = v.id
AND h.status_novo = 'Reprovado Compras'
WHERE v.id = %s
ORDER BY h.data_hora DESC
LIMIT 1
""", (veiculo_id,))
resultado = cur.fetchone()
cur.close()
con.close()
return resultado
except mysql.connector.Error as e:
print(f"Erro BD: {e}")
return None
def formatar_data(dt):
if not dt:
return 'N/A'
if isinstance(dt, str):
return dt
return dt.strftime('%d/%m/%Y \xe0s %H:%M')
def gerar_html_email(dados):
"""Gera o HTML compacto e bonito do email"""
# Limpa o motivo
motivo = dados.get('motivo_reprovacao') or 'Nao informado'
for prefixo in ['ENTREGA REPROVADA - Motivo:', 'ENTREGA REPROVADA -', 'Motivo:']:
if motivo.startswith(prefixo):
motivo = motivo[len(prefixo):].strip()
setor = dados.get('setorautoriza') or ''
setor_disp = setor.upper() if setor else 'N/A'
# Detecta ações contextuais passando o setor real
acoes = detectar_acoes(motivo, setor)
# Monta blocos de ação HTML
blocos_acao = ''
for icone, texto in acoes:
blocos_acao += (
''
'| ' + icone + ' | '
'' + texto + ' | '
'
'
)
# ── Bloco "Quem deve agir" baseado no checklist salvo ──────────────────
checklist = dados.get('compras_checklist') or ''
responsaveis_html = ''
if checklist:
issues_forn = []
if 'Valores OK' not in checklist: issues_forn.append('Valores unitários')
if 'Quantidades OK' not in checklist: issues_forn.append('Quantidades')
if 'Nota Fiscal OK' not in checklist: issues_forn.append('Nota Fiscal')
if 'Fornecedor OK' not in checklist: issues_forn.append('Fornecedor')
issue_pedido = 'Pedido Aprovado' not in checklist
blocos_resp = ''
if issue_pedido and setor:
blocos_resp += (
'| 🏢 | '
''
'' + setor.upper() + ': aprovar o pedido de compra no sistema '
'para liberar o recebimento desta entrega. |
'
)
if issues_forn:
lista = ', '.join(issues_forn)
blocos_resp += (
'| 🚚 | '
''
'FORNECEDOR: corrigir ' + lista + ' antes da próxima tentativa de entrega. |
'
)
if blocos_resp:
responsaveis_html = (
''
'Quem deve agir
'
''
)
placa = dados.get('placa') or 'N/A'
condutor = dados.get('condutor') or 'N/A'
fornecedor = dados.get('fornecedor') or 'N/A'
finalidade = dados.get('finalidade') or 'N/A'
reprovado = dados.get('reprovado_por') or 'N/A'
data_repr = formatar_data(dados.get('data_reprovacao'))
def linha_tabela(icone, label, valor, destaque=False, zebra=False):
bg = '#f9fafb' if zebra else '#ffffff'
peso = 'font-weight:700;' if destaque else ''
return (
''
'| '
+ icone + ' ' + label + ' | '
''
+ valor + ' | '
'
'
)
linhas_tabela = (
linha_tabela('🚚', 'Placa', placa, destaque=True, zebra=True) +
linha_tabela('👤', 'Condutor', condutor, zebra=False) +
linha_tabela('🏢', 'Fornecedor', fornecedor, destaque=True, zebra=True) +
linha_tabela('📦', 'Finalidade', finalidade, zebra=False) +
linha_tabela('🏭', 'Setor responsavel', setor_disp, zebra=True) +
linha_tabela('⏱', 'Reprovado em', data_repr, zebra=False) +
linha_tabela('👨💼', 'Reprovado por', reprovado, zebra=True)
)
html = """\
Entrega Reprovada
|
🚫
Entrega Reprovada — Compras
Sistema YMS · Controle de Pátio · Coco do Vale
|
|
⚠ Ação necessária:
Corrija as inconsistências abaixo e acione o setor de Compras
para liberar a entrega.
|
|
Dados da Entrega
""" + linhas_tabela + """
Motivo da Reprovação
""" + motivo + """
""" + responsaveis_html + """
O que fazer agora
|
|
Mensagem automática do
Sistema YMS
Companhia Alimentícia do Vale · Coco do Vale
· Não responda este e-mail
|
|
"""
return html
def enviar_email(destinatario, assunto, corpo_html):
try:
msg = MIMEMultipart('alternative')
msg['From'] = SMTP_CONFIG['user']
msg['To'] = destinatario
msg['Subject'] = assunto
msg.attach(MIMEText(corpo_html, 'html', 'utf-8'))
if SMTP_CONFIG['use_tls']:
srv = smtplib.SMTP(SMTP_CONFIG['host'], SMTP_CONFIG['port'])
srv.starttls()
else:
srv = smtplib.SMTP_SSL(SMTP_CONFIG['host'], SMTP_CONFIG['port'])
srv.login(SMTP_CONFIG['user'], SMTP_CONFIG['password'])
srv.send_message(msg)
srv.quit()
return True
except Exception as e:
print(f"Erro SMTP: {e}")
return False
def main():
if len(sys.argv) < 2:
print("Uso: python3 notificar_reprovacao.py ")
sys.exit(1)
veiculo_id = sys.argv[1]
print(f"Buscando veiculo ID {veiculo_id}...")
dados = buscar_dados_veiculo(veiculo_id)
if not dados:
print(f"Veiculo ID {veiculo_id} nao encontrado.")
sys.exit(1)
if dados['status'] != 'Reprovado Compras':
print(f"Status atual: {dados['status']} - sem necessidade de notificacao.")
sys.exit(0)
setor = dados['setorautoriza']
email_dest = obter_email_setor(setor)
if not email_dest:
print(f"Setor '{setor}' sem email cadastrado.")
print(f"Setores disponiveis: {', '.join(EMAILS_SETORES.keys())}")
sys.exit(1)
print(f"Destino: {email_dest} (setor: {setor})")
corpo = gerar_html_email(dados)
assunto = (
f"Entrega reprovada - {dados.get('fornecedor','?')} "
f"- Placa {dados.get('placa','?')}"
)
print("Enviando...")
if enviar_email(email_dest, assunto, corpo):
print(f"Email enviado para {email_dest}!")
# Registra envio (ignora se tabela nao existir)
try:
con = mysql.connector.connect(**DB_CONFIG)
cur = con.cursor()
cur.execute("""
INSERT INTO notificacoes_enviadas
(veiculo_id, tipo, destinatario, assunto, data_envio)
VALUES (%s, %s, %s, %s, NOW())
""", (veiculo_id, 'reprovacao_compras', email_dest, assunto))
con.commit()
cur.close()
con.close()
except mysql.connector.Error:
pass
sys.exit(0)
else:
print("Falha no envio.")
sys.exit(1)
if __name__ == "__main__":
main()