from cnxpdo import get_connection

def insertarCampana(data):
    conexionBD = get_connection()
    if conexionBD is None:
        return {"success": 0, "message": "Error de conexión"}

    try:
        cursor = conexionBD.cursor()
        query = """
            INSERT INTO campanas (nombre_campana, mensaje_campana, id_empleado, medio_envio, fecha_creacion)
            VALUES (%s, %s, %s, %s, %s)
        """
        cursor.execute(query, (
            data['nombre_campana'],
            data['mensaje_campana'],
            data['id_empleado'],
            data['medio_envio'],
            data['fecha_creacion']
        ))
        conexionBD.commit()

        id = cursor.lastrowid
        data['id'] = id

        cursor.close()
        conexionBD.close()

        return {
            "success": 1,
            "message": "Campaña insertada",
            "data": data
        }

    except Exception as e:
        conexionBD.close()
        return {
            "success": 0,
            "message": f"Error: {str(e)}"
        }