Revise paste KARDEX

import mysql.connector
from datetime import datetime

class Database:
    def __init__(self):
        self.connection = mysql.connector.connect(
            host="192.168.1.2",
            user="root",
            password="Perla17*+",
            database="kardex"
        )
        self.cursor = self.connection.cursor(dictionary=True)
    
    def execute_query(self, query, params=None):
        self.cursor.execute(query, params or ())
        return self.cursor.fetchall()
    
    def execute_insert(self, query, params=None):
        self.cursor.execute(query, params or ())
        self.connection.commit()
        return self.cursor.lastrowid
    
    def get_next_auto_increment(self, table_name):
        self.cursor.execute(f"SHOW TABLE STATUS LIKE '{table_name}'")
        result = self.cursor.fetchone()
        return result['Auto_increment']

class UnidadProducto:
    def __init__(self, db):
        self.db = db
    
    def listar(self):
        return self.db.execute_query("SELECT * FROM unidadesproducto")
    
    def obtener_por_id(self, id_unidad):
        result = self.db.execute_query(
            "SELECT * FROM unidadesproducto WHERE idUnidad = %s",
            (id_unidad,)
        )
        return result[0] if result else None

class Producto:
    def __init__(self, db):
        self.db = db
    
    def listar(self):
        return self.db.execute_query("""
            SELECT p.*, u.nombreUnidad 
            FROM productos p
            JOIN unidadesproducto u ON p.idUnidadBase = u.idUnidad
        """)
    
    def obtener(self, id_producto):
        result = self.db.execute_query(
            "SELECT * FROM productos WHERE idProducto = %s",
            (id_producto,)
        )
        return result[0] if result else None
    
    def obtener_equivalencias(self, id_producto):
        return self.db.execute_query(
            "SELECT * FROM equivalencias WHERE idProducto = %s",
            (id_producto,)
        )
    
    def existe_nombre(self, nombre):
        result = self.db.execute_query(
            "SELECT idProducto FROM productos WHERE nombreProducto = %s",
            (nombre,)
        )
        return bool(result)
    
    def insertar(self, codigo, nombre, id_unidad_base, stock):
        return self.db.execute_insert(
            """INSERT INTO productos 
            (codigoProducto, nombreProducto, idUnidadBase, stockInicial) 
            VALUES (%s, %s, %s, %s)""",
            (codigo, nombre, id_unidad_base, stock)
        )
    
    def obtener_movimientos(self):
        return self.db.execute_query("""
            SELECT p.idProducto, 
                   SUM(CASE WHEN m.tipoMovimiento = 'ENTRADA' THEN m.cantidad ELSE 0 END) as entradas,
                   SUM(CASE WHEN m.tipoMovimiento = 'SALIDA' THEN m.cantidad ELSE 0 END) as salidas
            FROM productos p
            LEFT JOIN movimientos m ON p.idProducto = m.idProducto
            GROUP BY p.idProducto
        """)

def print_tabla(header, rows):
    if not rows:
        print("No hay datos para mostrar")
        return
    
    column_widths = [len(str(campo)) for campo in header]
    for row in rows:
        for i, campo in enumerate(row):
            column_widths[i] = max(column_widths[i], len(str(campo)))
    
    border = "+" + "+".join(["-" * (w + 2) for w in column_widths]) + "+"
    row_format = "| " + " | ".join(["{:<" + str(w) + "}" for w in column_widths]) + " |"
    
    print(border)
    print(row_format.format(*header))
    print(border)
    for row in rows:
        print(row_format.format(*row))
    print(border)

def registrar_unidades(db):
    print("\nREGISTRO DE UNIDADES (0 para volver)")
    nombre = input("Nombre de la unidad: ").strip()
    if nombre == "0":
        return
    if not nombre:
        print("El nombre no puede estar vacío")
        return
    
    try:
        db.execute_insert(
            "INSERT INTO unidadesproducto (nombreUnidad) VALUES (%s)",
            (nombre,)
        )
        print("\n¡Unidad registrada exitosamente!")
    except Exception as e:
        print(f"\nError al registrar unidad: {str(e)}")

def listar_unidades(db):
    unidades = UnidadProducto(db).listar()
    if not unidades:
        print("\nNo hay unidades registradas")
        return
    
    header = ["N°", "NOMBRE DE UNIDAD"]
    rows = [(str(i+1), u['nombreUnidad']) for i, u in enumerate(unidades)]
    
    print("\nLISTADO DE UNIDADES REGISTRADAS")
    print_tabla(header, rows)

def listar_productos(db):
    productos = Producto(db).listar()
    if not productos:
        print("\nNo hay productos registrados")
        return
    
    header = ["N°", "CÓDIGO", "NOMBRE DEL PRODUCTOS", "UNIDAD BASE"]
    rows = []
    for i, p in enumerate(productos, 1):
        rows.append((
            f"{i:02d}",
            p['codigoProducto'],
            p['nombreProducto'],
            p['nombreUnidad']
        ))
    
    print("\nLISTADO DE PRODUCTOS REGISTRADOS")
    print_tabla(header, rows)

def registrar_producto(db):
    print("\nREGISTRO DE PRODUCTO (0 para volver)")
    producto = Producto(db)
    unidades = UnidadProducto(db)
    
    while True:
        nombre = input("Nombre del producto: ").strip()
        if nombre == "0":
            return
        if not nombre:
            print("El nombre no puede estar vacío")
            continue
        if producto.existe_nombre(nombre):
            print("¡El producto ya existe!")
        else:
            break

# Continúa en la siguiente parte...

while True:
        try:
            num_medidas = int(input("\n¿Cuántas medidas para cuantificar el producto? (1-4): "))
            if 1 <= num_medidas <= 4: 
                break
            print("Debe ser un número entre 1 y 4")
        except ValueError:
            print("Entrada inválida, debe ser un número")
    
    unidades_seleccionadas = []
    for i in range(num_medidas):
        while True:
            unidades_disponibles = unidades.listar()
            print(f"\nSelección de medida {i+1}:")
            print("Unidades disponibles:")
            
            for idx, u in enumerate(unidades_disponibles, 1):
                print(f"{idx}. {u['nombreUnidad']}")
            print(f"{len(unidades_disponibles)+1}. Agregar nueva unidad")
            
            try:
                opcion = int(input("Seleccione una opción: "))
                if 1 <= opcion <= len(unidades_disponibles):
                    unidades_seleccionadas.append(unidades_disponibles[opcion-1])
                    break
                elif opcion == len(unidades_disponibles)+1:
                    nombre_unidad = input("Nombre de la nueva unidad: ").strip()
                    if not nombre_unidad:
                        print("El nombre no puede estar vacío")
                        continue
                    db.execute_insert(
                        "INSERT INTO unidadesproducto (nombreUnidad) VALUES (%s)",
                        (nombre_unidad,)
                    )
                    print("¡Nueva unidad registrada!")
                else:
                    print("Opción inválida")
            except ValueError:
                print("Entrada inválida, debe ser un número")
    
    equivalencias = []
    for i in range(num_medidas-1):
        while True:
            try:
                cantidad = int(input(
                    f"\n1 {unidades_seleccionadas[i+1]['nombreUnidad']} = ¿Cuántas {unidades_seleccionadas[i]['nombreUnidad']}? "
                ))
                if cantidad > 0:
                    equivalencias.append((
                        unidades_seleccionadas[i+1]['idUnidad'],
                        unidades_seleccionadas[i]['idUnidad'],
                        cantidad
                    ))
                    break
                print("La cantidad debe ser mayor a 0")
            except ValueError:
                print("Entrada inválida, debe ser un número")
    
    while True:
        print("\nSelección de unidad para stock inicial:")
        for idx, u in enumerate(unidades_seleccionadas, 1):
            print(f"{idx}. {u['nombreUnidad']}")
        try:
            opcion = int(input("Seleccione una opción: ")) - 1
            if 0 <= opcion < len(unidades_seleccionadas):
                unidad_stock = unidades_seleccionadas[opcion]
                stock = int(input("Stock inicial: "))
                if stock < 0:
                    print("El stock no puede ser negativo")
                    continue
                break
        except ValueError:
            print("Entrada inválida")
    
    factor = 1
    for i in range(opcion):
        factor *= equivalencias[i][2]
    stock_base = stock * factor
    
    next_id = db.get_next_auto_increment('productos')
    codigo = f"ACU-{next_id:02d}"
    
    id_producto = producto.insertar(
        codigo,
        nombre,
        unidades_seleccionadas[0]['idUnidad'],
        stock_base
    )
    
    for sup, inf, cant in equivalencias:
        db.execute_insert(
            """INSERT INTO equivalencias 
            (idProducto, idUnidadSuperior, idUnidadInferior, cantidadEquivalente) 
            VALUES (%s, %s, %s, %s)""",
            (id_producto, sup, inf, cant)
        )
    
    fecha_registro = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    header = ["CÓDIGO", "NOMBRE DEL PRODUCTO", "STOCK", "UNIDAD", "F. REGISTRO"]
    row = [codigo, nombre, str(stock), unidad_stock['nombreUnidad'], fecha_registro]
    
    print("\n¡PRODUCTO REGISTRADO EXITOSAMENTE!")
    print_tabla(header, [row])

def registrar_entrada(db):
    print("\nREGISTRO DE ENTRADA DE PRODUCTOS (0 para volver)")
    
    productos = Producto(db).listar()
    if not productos:
        print("No hay productos registrados")
        return
    
    print("\nSeleccione un producto:")
    header = ["N°", "CÓDIGO", "NOMBRE DEL PRODUCTO", "STOCK", "UNIDAD"]
    rows = [(str(i+1), p['codigoProducto'], p['nombreProducto'], str(p['stockInicial']), p['nombreUnidad']) 
            for i, p in enumerate(productos)]
    print_tabla(header, rows)
    
    try:
        opcion = input("\nIngrese el número de producto (0 para volver): ").strip()
        if opcion == "0":
            return
        opcion = int(opcion) - 1
        producto = productos[opcion]
    except (ValueError, IndexError):
        print("Selección inválida")
        return
    
    unidades_ids = {producto['idUnidadBase']}
    equivalencias = db.execute_query(
        "SELECT idUnidadSuperior, idUnidadInferior FROM equivalencias WHERE idProducto = %s",
        (producto['idProducto'],)
    )
    for eq in equivalencias:
        unidades_ids.add(eq['idUnidadSuperior'])
        unidades_ids.add(eq['idUnidadInferior'])
    
    unidades = []
    for uid in unidades_ids:
        unidad = db.execute_query(
            "SELECT * FROM unidadesproducto WHERE idUnidad = %s",
            (uid,)
        )
        if unidad:
            unidades.append(unidad[0])
    
    if not unidades:
        print("No hay unidades asociadas al producto")
        return
    
    print("\nUnidades disponibles para este producto:")
    header = ["N°", "NOMBRE DE UNIDAD"]
    rows = [(str(i+1), u['nombreUnidad']) for i, u in enumerate(unidades)]
    print_tabla(header, rows)
    
    try:
        opcion_unidad = int(input("\nIngrese el número de unidad: ")) - 1
        unidad = unidades[opcion_unidad]
    except (ValueError, IndexError):
        print("Selección inválida")
        return
    
    factor = 1
    current_unit = unidad['idUnidad']
    base_unit = producto['idUnidadBase']
    equivalencias = db.execute_query(
        "SELECT * FROM equivalencias WHERE idProducto = %s",
        (producto['idProducto'],)
    )
    
    while current_unit != base_unit:
        encontrado = False
        for eq in equivalencias:
            if eq['idUnidadSuperior'] == current_unit:
                factor *= eq['cantidadEquivalente']
                current_unit = eq['idUnidadInferior']
                encontrado = True
                break
        if not encontrado:
            print("No se puede convertir a la unidad base")
            return
    
    try:
        stock = int(input("\nStock de ingreso: "))
        if stock <= 0:
            print("El stock debe ser mayor a 0")
            return
    except ValueError:
        print("Valor inválido")
        return
    
    documentos = db.execute_query("SELECT * FROM documentos")
    print("\nSeleccione tipo de documento:")
    for i, doc in enumerate(documentos, 1):
        print(f"{i}. {doc['nombreDocumento']}")
    
    try:
        doc_opcion = int(input("Opción: ")) - 1
        documento = documentos[doc_opcion]
    except (ValueError, IndexError):
        print("Selección inválida")
        return
    
    numero_doc = input("Número de documento: ").strip()
    
    # Seleccionar proveedor
    proveedores = db.execute_query(
        "SELECT * FROM entidades WHERE tipoEntidad = 'EMPRESA'"
    )
    if not proveedores:
        print("\nNo hay proveedores registrados. Registre uno primero.")
        return
    
    print("\nLISTADO DE PROVEEDORES REGISTRADOS")
    header = ["N°", "TIPO", "DOCUMENTO", "NOMBRE"]
    rows = [(str(i+1), p['tipoDocumento'], p['numeroDocumento'], p['nomEntidad']) 
            for i, p in enumerate(proveedores)]
    print_tabla(header, rows)
    
    try:
        opcion = int(input("\nSeleccione proveedor (0 para cancelar): "))
        if opcion == 0:
            return
        proveedor = proveedores[opcion-1]['numeroDocumento']
    except:
        print("Selección inválida")
        return

fecha = input("Ingrese fecha (DD-MM-AA) o 0 para fecha actual: ").strip()
    if fecha == '0':
        fecha_movimiento = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    else:
        try:
            fecha_dt = datetime.strptime(fecha, '%d-%m-%y')
            fecha_movimiento = fecha_dt.strftime('%Y-%m-%d %H:%M:%S')
        except ValueError:
            print("Formato de fecha inválido, usando fecha actual")
            fecha_movimiento = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    
    stock_base = stock * factor
    
    try:
        db.execute_insert(
            """INSERT INTO movimientos 
            (tipoMovimiento, idProducto, cantidad, idDocumento, 
             numeroDocumento, proveedor, fechaMovimiento)
            VALUES (%s, %s, %s, %s, %s, %s, %s)""",
            ('ENTRADA', producto['idProducto'], stock_base, 
             documento['idDocumento'], numero_doc, proveedor, fecha_movimiento)
        )
        print("\n¡Entrada registrada exitosamente!")
    except Exception as e:
        print(f"Error al registrar entrada: {str(e)}")

# Continúa en la siguiente parte...

def registrar_salida(db):
    print("\nREGISTRO DE SALIDA DE PRODUCTOS (0 para volver)")
    
    productos = Producto(db).listar()
    if not productos:
        print("No hay productos registrados")
        return
    
    print("\nSeleccione un producto:")
    header = ["N°", "CÓDIGO", "NOMBRE DEL PRODUCTO", "STOCK", "UNIDAD"]
    rows = [(str(i+1), p['codigoProducto'], p['nombreProducto'], str(p['stockInicial']), p['nombreUnidad']) 
            for i, p in enumerate(productos)]
    print_tabla(header, rows)
    
    try:
        opcion = input("\nIngrese el número de producto (0 para volver): ").strip()
        if opcion == "0":
            return
        opcion = int(opcion) - 1
        producto = productos[opcion]
    except (ValueError, IndexError):
        print("Selección inválida")
        return
    
    unidades_ids = {producto['idUnidadBase']}
    equivalencias = db.execute_query(
        "SELECT idUnidadSuperior, idUnidadInferior FROM equivalencias WHERE idProducto = %s",
        (producto['idProducto'],)
    )
    for eq in equivalencias:
        unidades_ids.add(eq['idUnidadSuperior'])
        unidades_ids.add(eq['idUnidadInferior'])
    
    unidades = []
    for uid in unidades_ids:
        unidad = db.execute_query(
            "SELECT * FROM unidadesproducto WHERE idUnidad = %s",
            (uid,)
        )
        if unidad:
            unidades.append(unidad[0])
    
    if not unidades:
        print("No hay unidades asociadas al producto")
        return
    
    print("\nUnidades disponibles para este producto:")
    header = ["N°", "NOMBRE DE UNIDAD"]
    rows = [(str(i+1), u['nombreUnidad']) for i, u in enumerate(unidades)]
    print_tabla(header, rows)
    
    try:
        opcion_unidad = int(input("\nIngrese el número de unidad: ")) - 1
        unidad = unidades[opcion_unidad]
    except (ValueError, IndexError):
        print("Selección inválida")
        return
    
    factor = 1
    current_unit = unidad['idUnidad']
    base_unit = producto['idUnidadBase']
    equivalencias = db.execute_query(
        "SELECT * FROM equivalencias WHERE idProducto = %s",
        (producto['idProducto'],)
    )
    
    while current_unit != base_unit:
        encontrado = False
        for eq in equivalencias:
            if eq['idUnidadSuperior'] == current_unit:
                factor *= eq['cantidadEquivalente']
                current_unit = eq['idUnidadInferior']
                encontrado = True
                break
        if not encontrado:
            print("No se puede convertir a la unidad base")
            return
    
    try:
        stock = int(input("\nStock de salida: "))
        if stock <= 0:
            print("El stock debe ser mayor a 0")
            return
        
        stock_base_total = producto['stockInicial'] + sum(
            m['cantidad'] for m in db.execute_query(
                "SELECT cantidad FROM movimientos WHERE idProducto = %s AND tipoMovimiento = 'ENTRADA'",
                (producto['idProducto'],)
            )
        ) - sum(
            m['cantidad'] for m in db.execute_query(
                "SELECT cantidad FROM movimientos WHERE idProducto = %s AND tipoMovimiento = 'SALIDA'",
                (producto['idProducto'],)
            )
        )
        
        if (stock * factor) > stock_base_total:
            print("No hay suficiente stock disponible")
            return
            
    except ValueError:
        print("Valor inválido")
        return
    
    # Seleccionar usuario
    usuarios = db.execute_query(
        "SELECT * FROM entidades WHERE tipoEntidad = 'USUARIO'"
    )
    if not usuarios:
        print("\nNo hay usuarios registrados. Registre uno primero.")
        return
    
    print("\nLISTADO DE USUARIOS REGISTRADOS")
    header = ["N°", "TIPO", "DOCUMENTO", "NOMBRE"]
    rows = [(str(i+1), u['tipoDocumento'], u['numeroDocumento'], u['nomEntidad']) 
            for i, u in enumerate(usuarios)]
    print_tabla(header, rows)
    
    try:
        opcion = int(input("\nSeleccione usuario (0 para cancelar): "))
        if opcion == 0:
            return
        usuario = usuarios[opcion-1]['numeroDocumento']
    except:
        print("Selección inválida")
        return

fecha = input("Ingrese fecha (DD-MM-AA) o 0 para fecha actual: ").strip()
    if fecha == '0':
        fecha_movimiento = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    else:
        try:
            fecha_dt = datetime.strptime(fecha, '%d-%m-%y')
            fecha_movimiento = fecha_dt.strftime('%Y-%m-%d %H:%M:%S')
        except ValueError:
            print("Formato de fecha inválido, usando fecha actual")
            fecha_movimiento = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    
    stock_base = stock * factor
    
    try:
        db.execute_insert(
            """INSERT INTO movimientos 
            (tipoMovimiento, idProducto, cantidad, proveedor, fechaMovimiento)
            VALUES (%s, %s, %s, %s, %s)""",
            ('SALIDA', producto['idProducto'], stock_base, usuario, fecha_movimiento)
        )
        print("\n¡Salida registrada exitosamente!")
    except Exception as e:
        print(f"Error al registrar salida: {str(e)}")

def reporte_movimientos(db):
    productos = Producto(db).listar()
    movimientos = Producto(db).obtener_movimientos()
    
    if not productos:
        print("\nNo hay productos registrados")
        return
    
    header = ["N°", "CÓDIGO", "NOMBRE DEL PRODUCTO", "STOCK BASE", 
              "STOCK INGRESO", "STOCK SALIDA", "STOCK REAL", "UNIDAD"]
    
    rows = []
    for i, p in enumerate(productos, 1):
        mov = next((m for m in movimientos if m['idProducto'] == p['idProducto']), None)
        entradas = mov['entradas'] if mov else 0
        salidas = mov['salidas'] if mov else 0
        stock_real = p['stockInicial'] + entradas - salidas
        
        rows.append((
            f"{i:02d}",
            p['codigoProducto'],
            p['nombreProducto'],
            str(p['stockInicial']),
            str(entradas),
            str(salidas),
            str(stock_real),
            p['nombreUnidad']
        ))
    
    print("\nREPORTE DE MOVIMIENTOS")
    print_tabla(header, rows)

def reporte_ingresos(db, por_producto=False):
    query = """
        SELECT m.*, p.codigoProducto, p.nombreProducto, 
               u.nombreUnidad, e.nomEntidad 
        FROM movimientos m
        JOIN productos p ON m.idProducto = p.idProducto
        JOIN unidadesproducto u ON p.idUnidadBase = u.idUnidad
        LEFT JOIN entidades e ON m.proveedor = e.numeroDocumento
        WHERE m.tipoMovimiento = 'ENTRADA'
    """
    
    if por_producto:
        productos = db.execute_query("SELECT * FROM productos")
        print("\nSeleccione un producto:")
        header = ["N°", "CÓDIGO", "NOMBRE DEL PRODUCTO"]
        rows = [(str(i+1), p['codigoProducto'], p['nombreProducto']) 
                for i, p in enumerate(productos)]
        print_tabla(header, rows)
        
        try:
            opcion = int(input("\nIngrese el número de producto: ")) - 1
            id_producto = productos[opcion]['idProducto']
            query += f" AND m.idProducto = {id_producto}"
        except:
            print("Selección inválida")
            return

movimientos = db.execute_query(query)
    
    if not movimientos:
        print("\nNo hay movimientos registrados")
        return
    
    header = ["N°", "CÓDIGO", "PRODUCTO", "CANTIDAD", "UNIDAD", "PROVEEDOR", "FECHA"]
    rows = []
    for i, m in enumerate(movimientos, 1):
        rows.append((
            f"{i:02d}",
            m['codigoProducto'],
            m['nombreProducto'],
            str(m['cantidad']),
            m['nombreUnidad'],
            m['nomEntidad'] or 'N/A',
            m['fechaMovimiento'].strftime('%d/%m/%Y')
        ))
    
    print("\nREPORTE DE INGRESOS" + (" POR PRODUCTO" if por_producto else ""))
    print_tabla(header, rows)

def reporte_salidas(db, por_producto=False):
    query = """
        SELECT m.*, p.codigoProducto, p.nombreProducto, 
               u.nombreUnidad, e.nomEntidad 
        FROM movimientos m
        JOIN productos p ON m.idProducto = p.idProducto
        JOIN unidadesproducto u ON p.idUnidadBase = u.idUnidad
        LEFT JOIN entidades e ON m.proveedor = e.numeroDocumento
        WHERE m.tipoMovimiento = 'SALIDA'
        ORDER BY m.fechaMovimiento DESC
    """
    
    if por_producto:
        productos = db.execute_query("SELECT * FROM productos")
        print("\nSeleccione un producto:")
        header = ["N°", "CÓDIGO", "NOMBRE DEL PRODUCTO"]
        rows = [(str(i+1), p['codigoProducto'], p['nombreProducto']) 
                for i, p in enumerate(productos)]
        print_tabla(header, rows)
        
        try:
            opcion = int(input("\nIngrese el número de producto: ")) - 1
            id_producto = productos[opcion]['idProducto']
            query += f" AND m.idProducto = {id_producto}"
        except:
            print("Selección inválida")
            return

movimientos = db.execute_query(query)
    
    if not movimientos:
        print("\nNo hay movimientos registrados")
        return
    
    header = ["N°", "CÓDIGO", "PRODUCTO", "CANTIDAD", "UNIDAD", "USUARIO", "FECHA"]
    rows = []
    for i, m in enumerate(movimientos, 1):
        rows.append((
            f"{i:02d}",
            m['codigoProducto'],
            m['nombreProducto'],
            str(m['cantidad']),
            m['nombreUnidad'],
            m['nomEntidad'] or 'N/A',
            m['fechaMovimiento'].strftime('%d/%m/%Y')
        ))
    
    print("\nREPORTE DE SALIDAS" + (" POR PRODUCTO" if por_producto else ""))
    print_tabla(header, rows)

def registrar_entidad(db):
    print("\nREGISTRO DE ENTIDAD (0 para volver)")
    
    while True:
        print("Tipo de entidad:")
        print("1. USUARIO")
        print("2. EMPRESA")
        print("0. Volver")
        opcion_tipo = input("Seleccione una opción: ").strip()
        
        if opcion_tipo == "0":
            return
        if opcion_tipo == '1':
            tipo_entidad = 'USUARIO'
            tipo_doc = 'DNI'
            break
        elif opcion_tipo == '2':
            tipo_entidad = 'EMPRESA'
            tipo_doc = 'RUC'
            break
        else:
            print("Opción inválida")

while True:
        numero_doc = input(f"Ingrese {tipo_doc} (1 para generar DNI especial): ").strip()
        
        if tipo_doc == 'DNI':
            if numero_doc == "1":
                # Se consulta el máximo DNI especial (los que comienzan con '999')
                resultado = db.execute_query(
                    "SELECT MAX(numeroDocumento) AS maxDNI FROM entidades WHERE numeroDocumento LIKE '999%'"
                )
                if resultado and resultado[0]['maxDNI'] is not None:
                    nuevo_dni = int(resultado[0]['maxDNI']) + 1
                else:
                    nuevo_dni = 99900001  # Valor inicial si no existe ningún DNI especial
                numero_doc = str(nuevo_dni)
            elif numero_doc == "0":
                return
        
        # Si el número ingresado NO es un DNI especial (no comienza con "999"),
        # se verifica que no exista ya en la base de datos.
        if not numero_doc.startswith("999"):
            existe = db.execute_query(
                "SELECT idEntidad FROM entidades WHERE numeroDocumento = %s",
                (numero_doc,)
            )
            if existe:
                print(f"¡El {tipo_doc} ya existe en el sistema!")
                continue
       
        if tipo_doc == 'DNI' and len(numero_doc) == 8 and numero_doc.isdigit():
            break
        elif tipo_doc == 'RUC' and len(numero_doc) == 11 and numero_doc.isdigit():
            break
        print(f"{tipo_doc} inválido. Debe tener {8 if tipo_doc == 'DNI' else 11} dígitos")

nombre_entidad = input("Nombre de la entidad: ").strip()

try:
        db.execute_insert(
            """INSERT INTO entidades 
            (tipoEntidad, tipoDocumento, numeroDocumento, nomEntidad) 
            VALUES (%s, %s, %s, %s)""",
            (tipo_entidad, tipo_doc, numero_doc, nombre_entidad)
        )
        print("\n¡Entidad registrada exitosamente!")
        
        entidad = db.execute_query(
            "SELECT * FROM entidades ORDER BY idEntidad DESC LIMIT 1"
        )[0]
        
        header = ["N°", "TIPOENTIDAD", "TIPODOCUMENTO", "NUMERODOCUMENTO", "NOMENTIDAD", "FECHAREGISTRO"]
        rows = [(
            "01",
            entidad['tipoEntidad'],
            entidad['tipoDocumento'],
            entidad['numeroDocumento'],
            entidad['nomEntidad'],
            entidad['fechaRegistro'].strftime('%d/%m/%Y')
        )]
        print_tabla(header, rows)
        
    except mysql.connector.IntegrityError:
        print("\nError: El número de documento ya existe en el sistema")
    except Exception as e:
        print(f"\nError al registrar entidad: {str(e)}")

def listar_entidades(db):
    entidades = db.execute_query("SELECT * FROM entidades")
    if not entidades:
        print("\nNo hay entidades registradas")
        return
    
    header = ["N°", "TIPOENTIDAD", "TIPODOCUMENTO", "NUMERODOCUMENTO", "NOMENTIDAD", "FECHAREGISTRO"]
    rows = []
    for i, entidad in enumerate(entidades, 1):
        rows.append((
            f"{i:02d}",
            entidad['tipoEntidad'],
            entidad['tipoDocumento'],
            entidad['numeroDocumento'],
            entidad['nomEntidad'],
            entidad['fechaRegistro'].strftime('%d/%m/%Y')
        ))
    
    print("\nLISTADO DE ENTIDADES REGISTRADAS")
    print_tabla(header, rows)

def menu_reportes_ingresos(db):
    while True:
        print("\nREPORTES DE INGRESOS")
        print("1. Reporte general de todos los ingresos")
        print("2. Reporte de ingresos por producto")
        print("3. Volver al menú principal")
        
        opcion = input("Seleccione una opción: ").strip()
        
        if opcion == '1':
            reporte_ingresos(db)
        elif opcion == '2':
            reporte_ingresos(db, por_producto=True)
        elif opcion == '3':
            break
        else:
            print("Opción inválida")

def menu_reportes_salidas(db):
    while True:
        print("\nREPORTES DE SALIDAS")
        print("1. Reporte general de todas las salidas")
        print("2. Reporte de salidas por producto")
        print("3. Volver al menú principal")
        
        opcion = input("Seleccione una opción: ").strip()
        
        if opcion == '1':
            reporte_salidas(db)
        elif opcion == '2':
            reporte_salidas(db, por_producto=True)
        elif opcion == '3':
            break
        else:
            print("Opción inválida")

def main():
    db = Database()
    while True:
        print("\n" + "=" * 40)
        print("SISTEMA DE GESTIÓN DE PRODUCTOS")
        print("=" * 40)
        print("1. Registrar unidad de medida")
        print("2. Listar unidades registradas")
        print("3. Registrar nuevo producto")
        print("4. Listar productos registrados")
        print("5. Registrar entidad (proveedor/usuario)")
        print("6. Listar entidades registradas")
        print("7. Registrar entrada de productos")
        print("8. Registrar salida de productos")
        print("9. Reporte general de movimientos")
        print("10. Reportes de ingresos")
        print("11. Reportes de salidas")
        print("12. Salir del sistema")
        
        opcion = input("\nSeleccione una opción: ").strip()
        
        if opcion == '1':
            registrar_unidades(db)
        elif opcion == '2':
            listar_unidades(db)
        elif opcion == '3':
            registrar_producto(db)
        elif opcion == '4':
            listar_productos(db)
        elif opcion == '5':
            registrar_entidad(db)
        elif opcion == '6':
            listar_entidades(db)
        elif opcion == '7':
            registrar_entrada(db)
        elif opcion == '8':
            registrar_salida(db)
        elif opcion == '9':
            reporte_movimientos(db)
        elif opcion == '10':
            menu_reportes_ingresos(db)
        elif opcion == '11':
            menu_reportes_salidas(db)
        elif opcion == '12':
            print("\n¡Gracias por usar el sistema!")
            break
        else:
            print("\nOpción inválida, intente nuevamente")
        
        input("\nPresione Enter para continuar...")

if __name__ == "__main__":
    main()