import time
import requests
import pymysql

API_URL = 'http://localhost:5000/produtos'
MYSQL_HOST = 'localhost'
MYSQL_USER = 'root'
MYSQL_PASS = ''
MYSQL_DB   = 'delivery'

def atualizar():
    try:
        resp = requests.get(API_URL)
        produtos = resp.json()

        conn = pymysql.connect(host=MYSQL_HOST, user=MYSQL_USER, password=MYSQL_PASS, database=MYSQL_DB, charset='utf8mb4')
        cursor = conn.cursor()
        for p in produtos:
            codigo = str(p.get('codigo', '')).strip()
            nome   = str(p.get('descricao', '')).strip()
            preco  = float(p.get('p_venda', 0))
            cursor.execute("""
                INSERT INTO produtos (codigo, nome, preco)
                VALUES (%s, %s, %s)
                ON DUPLICATE KEY UPDATE
                    nome=VALUES(nome), preco=VALUES(preco)
            """, (codigo, nome, preco))
            conn.commit()
        cursor.close()
        conn.close()
        print("Atualização feita!")
    except Exception as e:
        print("Erro:", e)

while True:
    atualizar()
    time.sleep(60)  # verifica a cada 60 segundos