add consulta telefone

app.py

@@ -4,8 +4,8 @@ from typing import List
 from sqlite3 import connect, Connection
 from uvicorn import run
 import os
-app = FastAPI()
 
+app = FastAPI()
 
 # Adiciona um log para listar os arquivos e as permissões
 os.system("ls -l /app/")
@@ -233,98 +233,39 @@ def create_atendimento_geral(atendimento_geral: AtendimentoGeral, db: Connection
     finally:
         cursor.close()
 
-@app.get("/verificar-cliente/{cpf}")
-def verificar_cliente(cpf: str, db: Connection = Depends(get_db)):
+@app.post("/abrir-chamado/")
+def abrir_chamado(chamado: Chamado, db: Connection = Depends(get_db)):
     cursor = db.cursor()
     try:
-        cursor.execute("SELECT * FROM Clientes WHERE cpf = ?", (cpf,))
+        cursor.execute("SELECT id_cliente FROM Clientes WHERE cpf = ?", (chamado.cpf,))
         cliente = cursor.fetchone()
-        if cliente:
-            return {"message": "Cliente encontrado", "cliente": cliente}
-        else:
+        if cliente is None:
             raise HTTPException(status_code=404, detail="Cliente não encontrado")
-    finally:
-        cursor.close()
 
-@app.get("/verificar-planos/{cpf}")
-def verificar_planos(cpf: str, db: Connection = Depends(get_db)):
-    cursor = db.cursor()
-    try:
-        cursor.execute("""
-            SELECT Planos.*, Pagamentos.status_pagamento 
-            FROM Clientes
-            JOIN Contratos ON Clientes.id_cliente = Contratos.id_cliente
-            JOIN Planos ON Contratos.id_plano = Planos.id_plano
-            LEFT JOIN Pagamentos ON Contratos.id_contrato = Pagamentos.id_contrato
-            WHERE Clientes.cpf = ?
-        """, (cpf,))
-        planos = cursor.fetchall()
+        id_cliente = cliente[0]
 
-        if not planos:
-            raise HTTPException(status_code=404, detail="Nenhum plano encontrado para este cliente")
+        cursor.execute("INSERT INTO Solicitacoes (id_cliente, tipo_solicitacao, descricao_solicitacao, data_solicitacao, status_solicitacao) VALUES (?, ?, ?, datetime('now'), 'aberto')",
+                       (id_cliente, chamado.tipo_solicitacao, chamado.descricao))
+        db.commit()
 
-        planos_em_dia = all(plano[-1] == 'Pago' for plano in planos)
-        return {"planos": planos, "em_dia": planos_em_dia}
+        return {"message": "Chamado aberto com sucesso"}
     finally:
         cursor.close()
 
-@app.get("/verificar-chamados-abertos/{cpf}")
-def verificar_chamados_abertos(cpf: str, db: Connection = Depends(get_db)):
+# Adicionando rota para verificar cliente por telefone
+@app.get("/verificar-cliente-telefone/{telefone}", response_model=Cliente)
+def verificar_cliente_telefone(telefone: str, db: Connection = Depends(get_db)):
     cursor = db.cursor()
     try:
-        cursor.execute("""
-            SELECT Solicitacoes.* 
-            FROM Clientes
-            JOIN Solicitacoes ON Clientes.id_cliente = Solicitacoes.id_cliente
-            WHERE Clientes.cpf = ? AND Solicitacoes.status_solicitacao = 'Aberto'
-        """, (cpf,))
-        chamados_abertos = cursor.fetchall()
-
-        if chamados_abertos:
-            return {"message": "Chamados abertos encontrados", "chamados": chamados_abertos}
-        else:
-            return {"message": "Nenhum chamado aberto encontrado"}
-    finally:
-        cursor.close() 
-
-@app.post("/criar-chamado/")
-def criar_chamado(chamado: Chamado, db: Connection = Depends(get_db)):
-    cursor = db.cursor()
-    try:
-        cursor.execute("SELECT * FROM Clientes WHERE cpf = ?", (chamado.cpf,))
+        cursor.execute("SELECT * FROM Clientes WHERE telefone = ?", (telefone,))
         cliente = cursor.fetchone()
-
-        if not cliente:
+        if cliente is None:
             raise HTTPException(status_code=404, detail="Cliente não encontrado")
-
-        # Verificar plano e chamados abertos
-        planos_response = verificar_planos(chamado.cpf, db)
-        chamados_response = verificar_chamados_abertos(chamado.cpf, db)
-
-        if not planos_response["em_dia"]:
-            return {"message": "Cliente com planos pendentes", "redirecionamento": "financeiro"}
-
-        if chamados_response["chamados"]:
-            return {"message": "Cliente já possui chamados abertos", "chamados": chamados_response["chamados"]}
-
-        # Direcionar com base no tipo de solicitação
-        if chamado.tipo_solicitacao == "técnico":
-            cursor.execute("INSERT INTO Suporte_Tecnico (id_cliente, descricao_suporte, data_suporte, status_suporte) VALUES (?, ?, date('now'), 'Aberto')",
-                           (cliente[0], chamado.descricao))
-            setor = "suporte técnico"
-        elif chamado.tipo_solicitacao == "financeiro":
-            cursor.execute("INSERT INTO Solicitacoes (id_cliente, tipo_solicitacao, descricao_solicitacao, data_solicitacao, status_solicitacao) VALUES (?, 'financeiro', ?, date('now'), 'Aberto')",
-                           (cliente[0], chamado.descricao))
-            setor = "financeiro"
-        else:
-            cursor.execute("INSERT INTO Solicitacoes (id_cliente, tipo_solicitacao, descricao_solicitacao, data_solicitacao, status_solicitacao) VALUES (?, 'comercial', ?, date('now'), 'Aberto')",
-                           (cliente[0], chamado.descricao))
-            setor = "comercial"
-
-        db.commit()
-        return {"message": f"Chamado criado e direcionado para o setor {setor}"}
+        
+        return Cliente(**{"id_cliente": cliente[0], "cpf": cliente[1], "nome": cliente[2], "telefone": cliente[3], "email": cliente[4], "cidade": cliente[5], "estado": cliente[6]})
     finally:
-        cursor.close()  
+        cursor.close()
 
+# Configuração para execução do servidor
 if __name__ == "__main__":
-    run(app, host="0.0.0.0", port=7860)             
+    run(app, host="0.0.0.0", port=8000)