Upload database.py

database.py

@@ -148,7 +148,7 @@ def init_db():
     if not c.fetchone():
         salt = bcrypt.gensalt()
         hashed_pw = bcrypt.hashpw(b"admin", salt).decode('utf-8')
-        c.execute("INSERT INTO users VALUES ('admin', ?, 'Gerencia', '', '', '', '')", (hashed_pw,))
+        c.execute("INSERT INTO users VALUES ('admin', %s, 'Gerencia', '', '', '', '')", (hashed_pw,))
 
     conn.commit()
     conn.close()
@@ -307,7 +307,7 @@ def registrar_intento_fallido(username: str):
     intentos = c.fetchone()[0]
     if intentos >= MAX_INTENTOS:
         hasta = (datetime.now() + timedelta(minutes=TIEMPO_BLOQUEO)).isoformat()
-        c.execute("UPDATE login_attempts SET bloqueado_hasta=? WHERE username=%s", (hasta, username))
+        c.execute("UPDATE login_attempts SET bloqueado_hasta=%s WHERE username=%s", (hasta, username))
     conn.commit()
     conn.close()
 
@@ -348,7 +348,7 @@ def update_user_profile(username, gemini, tavily, email, enc_pass):
     c = conn.cursor()
     enc_gemini = crypto.encrypt_data(gemini) if gemini else ""
     enc_tavily = crypto.encrypt_data(tavily) if tavily else ""
-    c.execute("UPDATE users SET gemini_key=?, tavily_key=?, email_user=?, email_pass_enc=? WHERE username=%s",
+    c.execute("UPDATE users SET gemini_key=%s, tavily_key=%s, email_user=%s, email_pass_enc=%s WHERE username=%s",
               (enc_gemini, enc_tavily, email, enc_pass, username))
     conn.commit()
     conn.close()
@@ -419,7 +419,7 @@ def insert_smart_inbox(licitacion, remitente, asunto, fecha, resumen, renglones,
     conn = get_connection()
     c = conn.cursor()
     c.execute(
-        "INSERT INTO smart_inbox (licitacion, remitente, asunto, fecha, resumen, renglones_relacionados, cuerpo, borrador_respuesta) VALUES (%s, %s, %s, %s, ?, ?, ?, ?)",
+        "INSERT INTO smart_inbox (licitacion, remitente, asunto, fecha, resumen, renglones_relacionados, cuerpo, borrador_respuesta) VALUES (%s, %s, %s, %s, %s, %s, %s, %s)",
         (licitacion, remitente, asunto, fecha, resumen, renglones, cuerpo, borrador))
     conn.commit()
     conn.close()
@@ -428,7 +428,7 @@ def insert_cotizacion(licitacion, renglon, proveedor, precio_unitario, moneda, t
     conn = get_connection()
     c = conn.cursor()
     c.execute(
-        "INSERT INTO cotizaciones (licitacion, renglon, proveedor, precio_unitario, moneda, tiempo_entrega, condiciones, fecha, email_asunto) VALUES (%s, %s, %s, %s, ?, ?, ?, ?, ?)",
+        "INSERT INTO cotizaciones (licitacion, renglon, proveedor, precio_unitario, moneda, tiempo_entrega, condiciones, fecha, email_asunto) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s)",
         (licitacion, renglon, proveedor, precio_unitario, moneda, tiempo_entrega, condiciones, fecha, email_asunto))
     conn.commit()
     conn.close()
@@ -436,7 +436,7 @@ def insert_cotizacion(licitacion, renglon, proveedor, precio_unitario, moneda, t
 def check_cotizacion_exists(licitacion, renglon, proveedor):
     conn = get_connection()
     c = conn.cursor()
-    c.execute("SELECT id FROM cotizaciones WHERE licitacion=%s AND renglon=? AND proveedor=?",
+    c.execute("SELECT id FROM cotizaciones WHERE licitacion=%s AND renglon=%s AND proveedor=%s",
               (licitacion, renglon, proveedor))
     exists = c.fetchone() is not None
     conn.close()
@@ -485,7 +485,7 @@ def crear_seguimiento(numero_licitacion, objeto, fecha_asignacion, fecha_envio_o
         c.execute("""INSERT INTO seguimiento_licitaciones
             (numero_licitacion, objeto, fecha_asignacion, fecha_envio_oferta,
              monto_ofertado, moneda, estado, link_sli, notas, responsable, fecha_registro)
-            VALUES (%s, %s, %s, %s, ?, ?, 'En Preparacion', ?, ?, ?, ?)""",
+            VALUES (%s, %s, %s, %s, %s, %s, 'En Preparacion', %s, %s, %s, %s)""",
             (numero_licitacion, objeto, fecha_asignacion, fecha_envio_oferta,
              monto_ofertado, moneda, link_sli, notas, responsable, fecha))
         conn.commit()
@@ -506,7 +506,7 @@ def actualizar_estado(licitacion_id, nuevo_estado, nota, registrado_por):
     conn = get_connection()
     c = conn.cursor()
     fecha = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-    c.execute("UPDATE seguimiento_licitaciones SET estado=? WHERE id=?", (nuevo_estado, licitacion_id))
+    c.execute("UPDATE seguimiento_licitaciones SET estado=%s WHERE id=%s", (nuevo_estado, licitacion_id))
     c.execute("""INSERT INTO seguimiento_historial (licitacion_id, fecha, estado_nuevo, nota, registrado_por)
                  VALUES (%s, %s, %s, %s, %s)""", (licitacion_id, fecha, nuevo_estado, nota, registrado_por))
     conn.commit()
@@ -515,7 +515,7 @@ def actualizar_estado(licitacion_id, nuevo_estado, nota, registrado_por):
 def get_historial_seguimiento(licitacion_id):
     conn = get_connection()
     df = pd.read_sql_query(
-        "SELECT fecha, estado_nuevo, nota, registrado_por FROM seguimiento_historial WHERE licitacion_id=? ORDER BY id DESC",
+        "SELECT fecha, estado_nuevo, nota, registrado_por FROM seguimiento_historial WHERE licitacion_id=%s ORDER BY id DESC",
         conn, params=(licitacion_id,))
     conn.close()
     return df
@@ -523,8 +523,8 @@ def get_historial_seguimiento(licitacion_id):
 def eliminar_seguimiento(licitacion_id):
     conn = get_connection()
     c = conn.cursor()
-    c.execute("DELETE FROM seguimiento_historial WHERE licitacion_id=?", (licitacion_id,))
-    c.execute("DELETE FROM seguimiento_licitaciones WHERE id=?", (licitacion_id,))
+    c.execute("DELETE FROM seguimiento_historial WHERE licitacion_id=%s", (licitacion_id,))
+    c.execute("DELETE FROM seguimiento_licitaciones WHERE id=%s", (licitacion_id,))
     conn.commit()
     conn.close()