OfflineDownloader.cs

using sage.addons.offline.DataAccess.Dto;


using sage.addons.offline.DataAccess.Repository;
using sage.addons.offline.DataAccess.UnitOfWork;
using sage.addons.offline.Negocio.Interficies;
using sage.addons.offline.Negocio.Listados;
using sage.addons.offline.Negocio.Mantes;
using sage.ew.db;
using sage.ew.ewbase;
using sage.ew.ewbase.Clases;
using sage.ew.functions;
using sage.ew.functions.Clases.DiccionariosLoader;
using sage.ew.global;
using sage.ew.global.DependencyInjection;
using sage.ew.listados.Clases;
using System;
using System.Collections.Generic;
using System.Data;

using System.IO;
using System.Linq;
using System.Threading.Tasks;
using System.Windows.Forms;


namespace sage.addons.offline.Negocio.Clases
{
    internal class OfflineDownloader : OfflineUpAndDown
    {
        internal static string _tablaOld { get; set; } = string.Empty;
        internal static string _ejercicioActual { get; set; } = string.Empty;
        internal static string _ejercicioNew { get; set; } = string.Empty;

        internal static DataTable _dtStockLotesOffline = new DataTable();
        internal static OfflineInfoConfig ficheroInfoConfig = null;

        internal static bool conCargaInicial = false;
        internal static bool conDatosStock = false;
        
        internal static bool Download_Control_Files(int idConf, string tcSucursal)
        {
            _cIdLog = _offlineConfig.GenerarRandomId();

            return true;
        }

        internal static DataTable Download_Control_Files_And_Get_Sucursales(int tnIdConf, string tcSucursal)
        {
            IOfflineUnitOfWork offlineUnitOfWork = DependencyInjector.Instance.Retrieve<IOfflineUnitOfWork>();
            ILog_comoffRepository logRepository = offlineUnitOfWork.Log_comoffRepository;

            OfflineDatosComunicaciones datos = new OfflineDatosComunicaciones();

            _Mostrar_Progreso_Async -= OfflineDownloader__Mostrar_Progreso_Async;
            _Porcen_Progreso_Async -= OfflineDownloader__Porcen_Progreso_Async;

            _Mostrar_Progreso_Async += OfflineDownloader__Mostrar_Progreso_Async;
            _Porcen_Progreso_Async += OfflineDownloader__Porcen_Progreso_Async;

            if (string.IsNullOrWhiteSpace(_cIdLog))
            {
                _cIdLog = _offlineConfig.GenerarRandomId();
            }

            ComprobacionesPrevias(tnIdConf);

            datos._Log_ComoffID = _cIdLog;
            datos._IdConf = tnIdConf;
            datos._MultConf = DB.SQLValor("MULTCONF", "IDCONF", tnIdConf.ToString(), "CODIGO", "OFFLINE").ToString();
            datos._Usuario = EW_GLOBAL._GetVariable("wc_usuario").ToString();
            datos._BdOffline = clsOfflineUtils.ObtenerNombreBdReal("OFFLINE");
            datos._Sucursal = tcSucursal;
            datos._PathFolderInicial = TempFolderName;
            datos._IniServidor = DB._GetVariable("wc_iniservidor").ToString().ToLower();
            datos._EnvioArticulos = _offlineConfig.GetValorVariable(EnumVariables.ENVIOARTICULOS) == ".T.";

            InicializarBarraProgreso();

            _TextStepDetalle = "Recibiendo fichero sucuralm.xml";
            _TextStepProgreso = _TextStepDetalle;
            _PorcenProgreso = IncrementarBarraProgreso();

            DataTable tableDatos = GetTablaOffline("OFFLINE", "SUCURALM", _formatoExportacionPredeterminado, datos, logRepository);
            InsertarTablaBaseDatosBulk(tableDatos, "OFFLINE", "SUCURALM", false, true);

            _TextStepDetalle = "Recibiendo fichero sucurlet.xml";
            _TextStepProgreso = _TextStepDetalle;
            _PorcenProgreso = IncrementarBarraProgreso();
            tableDatos = GetTablaOffline("OFFLINE", "SUCURLET", _formatoExportacionPredeterminado, datos, logRepository);
            InsertarTablaBaseDatosBulk(tableDatos, "OFFLINE", "SUCURLET", false, true);

            _TextStepDetalle = "Recibiendo fichero sucurcaja.xml";
            _TextStepProgreso = _TextStepDetalle;
            _PorcenProgreso = IncrementarBarraProgreso();
            tableDatos = GetTablaOffline("OFFLINE", "SUCURCAJA", _formatoExportacionPredeterminado, datos, logRepository);
            InsertarTablaBaseDatosBulk(tableDatos, "OFFLINE", "SUCURCAJA", false, true);

            _TextStepDetalle = "Recibiendo fichero sucursales.xml";
            _TextStepProgreso = _TextStepDetalle;
            _PorcenProgreso = IncrementarBarraProgreso();
            tableDatos = GetTablaOffline("OFFLINE", "SUCURSALES", _formatoExportacionPredeterminado, datos, logRepository);
            InsertarTablaBaseDatosBulk(tableDatos, "OFFLINE", "SUCURSALES", false, true);

            RecibirOfflineVariables(datos, logRepository);

            offlineUnitOfWork.SaveChanges();
            offlineUnitOfWork.Dispose();

            _Mostrar_Progreso_Async -= OfflineDownloader__Mostrar_Progreso_Async;
            _Porcen_Progreso_Async -= OfflineDownloader__Porcen_Progreso_Async;

            return tableDatos;
        }

        private static void RecibirOfflineVariables(OfflineDatosComunicaciones datos, ILog_comoffRepository logRepository)
        {
            DataTable tableDatos = new DataTable();
            _TextStepDetalle = "Recibiendo fichero variables.xml";
            _TextStepProgreso = _TextStepDetalle;
            _PorcenProgreso = IncrementarBarraProgreso();

            tableDatos = GetTablaOffline("OFFLINE", "VARIABLES", _formatoExportacionPredeterminado, datos, logRepository);

            if (tableDatos != null & tableDatos.Rows.Count > 0)
            {
                foreach (DataRow item in tableDatos.Rows)
                {
                    switch (item.Field<string>("VARIABLE").Trim())
                    {
                        case "ULTIMOLOG":

                            _offlineConfig.InsertOrUpdateVariable(EnumVariables.ULTIMOLOG, item.Field<string>("VALOR").Trim(), "C");

                            try
                            {
                                datos._UltimoLog = Convert.ToInt32(item.Field<string>("VALOR").Trim());
                            }
                            catch 
                            {
                                datos._UltimoLog = 6;
                            }
                            

                            break;
                    }
                }
            }
        }

        private static void OfflineDownloader__Mostrar_Progreso_Async(string message)
        {
            try
            {
                _offBase._TextStepDetalle = message;
            }
            catch (Exception) { }
        }

        private static void OfflineDownloader__Porcen_Progreso_Async(decimal porcen, string message)
        {
            try
            {
                if (_offBase != null)
                {
                    _offBase._TextStepProgreso = message;
                    _offBase._PorcenProgreso = porcen;
                }
            }
            catch (Exception) { }
        }

        internal static bool Download_Offline_Files(clsOfflineUtils.ReportProgress progressReporter, DateTime tdFechaMin, DateTime tdFechaMax, string tcSucursal, bool tlImagenes, bool tlAnterior, bool isCentral, int idConf, bool tlInicial = false, Dictionary<int, bool> prioridades = null)
        {
            _Mostrar_Progreso_Async -= OfflineDownloader__Mostrar_Progreso_Async;
            _Porcen_Progreso_Async -= OfflineDownloader__Porcen_Progreso_Async;

            _Mostrar_Progreso_Async += OfflineDownloader__Mostrar_Progreso_Async;
            _Porcen_Progreso_Async += OfflineDownloader__Porcen_Progreso_Async;

            _cTempFolderName = string.Empty;

            if (!Directory.Exists(TempFolderName))
            {
                Directory.CreateDirectory(TempFolderName);
            }

            bool llOk = Recibir_Datos(tcSucursal, tlImagenes, tdFechaMin, tdFechaMax, isCentral, idConf, prioridades);

            _Mostrar_Progreso_Async -= OfflineDownloader__Mostrar_Progreso_Async;
            _Porcen_Progreso_Async -= OfflineDownloader__Porcen_Progreso_Async;

            return llOk;
        }


        private static bool Recibir_Datos(string tcSucursal, bool tlImagenes, DateTime tdFechaMin, DateTime tdFechaMax, bool isCentral, int idConf, Dictionary<int, bool> prioridades = null)
        {
            IOfflineUnitOfWork offlineUnitOfWork = DependencyInjector.Instance.Retrieve<IOfflineUnitOfWork>();
            ILog_comoffRepository logRepository = offlineUnitOfWork.Log_comoffRepository;

            _tablaOld = string.Empty;
            ReestablecerInfoConfig();

            bool llOk = true;
            int lnValor = 0;
            string lcTipoRecepcion = string.Empty;

            OfflineDatosComunicaciones datos = EstablecerConfiguracion(tcSucursal, tdFechaMin, tdFechaMax, isCentral, idConf, logRepository);

            List<string> laFiles = DescargarListaFicheros(tcSucursal, isCentral, idConf);

            if (laFiles.Count == 0)
            {
                Log_comoffDto logDto = logRepository.GetDto(datos);
                logDto.TipoDato = "01";
                logDto.Resultado = 2;
                logDto.Detalle = "No existen ficheros de datos en la carpeta de FTP o OneDrive de la sucursal " + tcSucursal +
                                " - " + DB.SQLValor("SUCURSALES", "CODIGO", tcSucursal, "NOMBRE", "OFFLINE").ToString().TrimEnd() + ", por lo que no se realizará ninguna recepción de datos de dicha sucursal.";
                logRepository.Insert(logDto);

                _TextStepDetalle = "No existen ficheros de datos en la carpeta de FTP o OneDrive de la sucursal " + tcSucursal;

                offlineUnitOfWork.SaveChanges();

                // Email de notificación de recepción
                EnvioEmailNotificacion("", datos, logRepository);

                offlineUnitOfWork.SaveChanges();
                offlineUnitOfWork.Dispose();

                //No existen ficheros de datos en la carpeta de FTP o OneDrive de las sucursales XXXX-XXXXXXXXXXXX, XXXX - XXXXXXXXXXXX, XXXX - XXXXXXXXXXXX, por lo que no se realizará ninguna recepción de datos
                if (!isCentral)
                {
                    return true;
                }
            }

            foreach (string item in laFiles)
            {
                lcTipoRecepcion = clsOfflineUtils.ObtenerTipoFichero(Path.GetFileNameWithoutExtension(item));

                datos._TipoCom = 3;

                conCargaInicial = conCargaInicial || lcTipoRecepcion == "i";

                if (GetFicheroZip(item, datos))
                {
                    Log_comoffDto logDto = logRepository.GetDto(datos);
                    logDto.TipoDato = "01";
                    logDto.Resultado = 1;
                    logDto.Detalle = "Iniciando proceso de rececepción del fichero de " +
                                    (lcTipoRecepcion == "i" ? "Carga inicial" : "Envío de datos") +
                                    ", con fecha " + clsOfflineUtils.ObtenerFechaFicheroDatos(item) + ", fichero " + item + ".";
                    logRepository.Insert(logDto);

                    // Validaciones previas
                    lnValor = Validaciones_Previas(datos, logRepository);

                    if (lnValor != 0)
                    {
                        offlineUnitOfWork.SaveChanges();

                        // Email de notificación de recepción
                        EnvioEmailNotificacion(item, datos, logRepository);

                        offlineUnitOfWork.SaveChanges();

                        if (lnValor < 0)
                        {
                            // Valor negativo, error excluyente, no se puede continuar
                            offlineUnitOfWork.Dispose();
                            return false;
                        }
                        else
                        {
                            // Valor positivo, advertencia, si se puede continuar
                            continue;
                        }
                    }

                    // Guardar cópia de seguridad
                    SaveBackup(item, datos, logRepository);

                    if (lcTipoRecepcion == "i")
                    {
                        RecibirOfflineVariables(datos, logRepository);
                    }

                    // Vaciar log de comunicaciones
                    VaciarUltimoLog(datos, logRepository);

                    if (_ejercicioNew != _ejercicioActual)
                    {
                        // Cambiar al ejercicio 
                        FUNCTIONS.CambiarEjercicio(_ejercicioActual, _ejercicioNew);
                    }

                    // Tratamiento de deletes
                    Tratamiento_Deletenet(datos, logRepository);

                    // Actualización de datos en la Sucursal
                    if (datos._IsCentral)
                    {
                        Actualizar_Datos_Servidor(datos, logRepository);
                    }
                    else
                    {
                        Actualizar_Datos_Sucursales(datos, logRepository);
                    }

                    // Recepción de datos de la carga inicial
                    EjecutarProcesoRecepcion(datos, lcTipoRecepcion, logRepository);

                    if (_ejercicioNew != _ejercicioActual)
                    {
                        // Restaurar al ejercicio 
                        FUNCTIONS.CambiarEjercicio(_ejercicioNew, _ejercicioActual);
                    }

                    // Actualizar valor de campo ULTFECREC de tabla MULTCONF del registro correspondiente a la configuración de comunicaciones utilizada para la recepción con la fecha y hora de finalización del proceso.
                    Actualizar_Fecha_Recepcion_Multiconf(datos);

                    // Actualizar valor de campo ULTFECREC y CARGAINI de tabla SUCURSALES del registro correspondiente a la sucursal que ha recibido los datos con la fecha y hora de finalización del proceso.
                    Actualizar_Fecha_Recepcion_Sucursales(datos, lcTipoRecepcion, logRepository);

                    // Actualizar campo VALOR de variable HORA_CARGAINI en la tabla VARIABLES del registro correspondiente a IDCONF = 0 con la fecha y hora de finalización del proceso.
                    if (lcTipoRecepcion == "i")
                    {
                        _offlineConfig.InsertOrUpdateVariable(EnumVariables.HORA_CARGAINI, Convert.ToString(DateTime.Now), "D");
                    }

                    offlineUnitOfWork.SaveChanges();

                    // Email de notificación de recepción
                    EnvioEmailNotificacion(item, datos, logRepository);

                    // Eliminar el fichero ZIP recibido.
                    DeleteFicheroZip(item, datos);

                    // Eliminar todos los datos recibidos en la carpeta temporal
                    Eliminar_Carpetas_Temporales(datos, logRepository);

                    // Eliminar base de datos temporal
                    EliminarDataBaseTemporal();
                    offlineUnitOfWork.SaveChanges();
                }
            }

            EjecutarRecalculoRiesgoCliente(datos);

            offlineUnitOfWork.Dispose();

            EW_GLOBAL._Empresa = null;
            if (string.IsNullOrWhiteSpace(_cCaja))
            {
                DiccionariosLoader.CargarDiccionarios(_cEmpresa);
            }
            else
            {
                DiccionariosLoader.CargarDiccionarios(_cEmpresa, _cCaja);
            }

            EW_GLOBAL._Empresa = new sage.ew.empresa.Empresa(_cEmpresa);
            DiccionariosLoader.ReCargarDiccionarios();

            return llOk;
        }

        private static void EjecutarRecalculoRiesgoCliente(OfflineDatosComunicaciones datos)
        {
            // Recalcular el riesgo a partir de la tabla OFFLINE!ACTRIESGO
            if (!datos._IsCentral)
            {
                return;
            }

            DataTable ldtActRiesgo = new DataTable();
            DB.SQLExec("SELECT DISTINCT EMPRESA, CODIGO FROM " + DB.SQLDatabase("OFFLINE", "ACTRIESGO"), ref ldtActRiesgo);

            if (ldtActRiesgo != null && ldtActRiesgo.Rows.Count > 0)
            {
                _TextStepDetalle = "Recalculando riesgo de clientes";
                _TextStepProgreso = _TextStepDetalle;
                _PorcenProgreso = IncrementarBarraProgreso();

                ew.cliente.Clases.clsLimiteCredito clsLimite = new ew.cliente.Clases.clsLimiteCredito();

                foreach (DataRow item in ldtActRiesgo.Rows)
                {
                    clsLimite._RecalcularRiesgoClienteOffline(item["empresa"].ToString(), item["codigo"].ToString());
                }

                clsLimite.Dispose();
            }

            // Vaciamos la tabla OFFLINE!ACTRIESGO para las pròximas recepciones
            DB.SQLExec("DELETE FROM " + DB.SQLDatabase("OFFLINE", "ACTRIESGO"));
        }

        private static List<string> DescargarListaFicheros(string tcSucursal, bool isCentral, int tnIdConf)
        {
            List<string> laFilesFolder = UploadManager.GetListFiles("SUCURNET" + tcSucursal, tnIdConf);
            List<string> laFiles = new List<string>();

            string lcTipoRecepcion = string.Empty;

            // Quitar los ficheros que no son ZIP
            for (int i = 0; i < laFilesFolder.Count; i++)
            {
                if (laFilesFolder[i].Contains(".zip"))
                {
                    lcTipoRecepcion = clsOfflineUtils.ObtenerTipoFichero(Path.GetFileNameWithoutExtension(laFilesFolder[i]));

                    // Comprobar si es un fichero correcto
                    if (isCentral && (lcTipoRecepcion == "c" || lcTipoRecepcion == "i"))
                    {
                        continue;
                    }

                    if (!isCentral && lcTipoRecepcion == "s")
                    {
                        continue;
                    }

                    laFiles.Add(laFilesFolder[i]);
                }
            }

            return laFiles;
        }

        private static OfflineDatosComunicaciones EstablecerConfiguracion(string tcSucursal, DateTime tdFechaMin, DateTime tdFechaMax, bool isCentral, int idConf, ILog_comoffRepository logRepository)
        {
            OfflineDatosComunicaciones datos = new OfflineDatosComunicaciones();
            _offlineConfig = DependencyInjector.Instance.Retrieve<OfflineConfig>();

            datos._Log_ComoffID = _cIdLog;
            datos._IdConf = idConf;
            datos._MultConf = DB.SQLValor("MULTCONF", "IDCONF", idConf.ToString(), "CODIGO", "OFFLINE").ToString();
            datos._Usuario = EW_GLOBAL._GetVariable("wc_usuario").ToString();
            datos._BdOffline = clsOfflineUtils.ObtenerNombreBdReal("OFFLINE");
            datos._Sucursal = tcSucursal;
            datos._PathFolderInicial = TempFolderName;
            datos._IniServidor = DB._GetVariable("wc_iniservidor").ToString().ToLower();
            datos._EnvioArticulos = _offlineConfig.GetValorVariable(EnumVariables.ENVIOARTICULOS) == ".T.";
            datos._FechaInicial = tdFechaMin;
            datos._FechaFinal = tdFechaMax;
            datos._IsCentral = isCentral;
            datos._TipoCom = 3;

            datos._NotificacionEnvio = Convert.ToBoolean(DB.SQLValor("MULTCONF", "IDCONF", idConf.ToString(), "NOTIFICAEN", "OFFLINE"));
            datos._EmailNotificacionEnvio = Convert.ToString(DB.SQLValor("MULTCONF", "IDCONF", idConf.ToString(), "EMAILNOTEN", "OFFLINE"));

            datos._NotificacionRecepcion = Convert.ToBoolean(DB.SQLValor("MULTCONF", "IDCONF", idConf.ToString(), "NOTIFICARE", "OFFLINE"));
            datos._EmailNotificacionRecepcion = Convert.ToString(DB.SQLValor("MULTCONF", "IDCONF", idConf.ToString(), "EMAILNOTRE", "OFFLINE"));

            try
            {
                datos._UltimoLog = Convert.ToInt32(_offlineConfig.GetValorVariable(EnumVariables.ULTIMOLOG));
            }
            catch 
            {
                datos._UltimoLog = 6;
            }
            

            string[] loClaveBackup = _offlineConfig.GetValorVariable(EnumVariables.BACKUP_RECEP).Split('|');

            try
            {
                if (loClaveBackup.Length == 3)
                {
                    datos._Backup = (loClaveBackup[0].ToUpper() == ".T." ? true : false);
                    datos._BackupPath = loClaveBackup[1].TrimEnd();
                    datos._BackupNumArchivos = Convert.ToInt32(loClaveBackup[2]);
                }
            }
            catch
            {
                Log_comoffDto logDto = logRepository.GetDto(datos);
                logDto.TipoDato = "01";
                logDto.Resultado = 2;
                logDto.Detalle = "Error al leer la configuración de la variable " + EnumVariables.BACKUP_RECEP.ToString();
                logRepository.Insert(logDto);
            }

            return datos;
        }

        private static void EjecutarProcesoRecepcion(OfflineDatosComunicaciones datos, string tcTipoRecepcion, ILog_comoffRepository logRepository)
        {
            DataTable TabTmp = ObtenerDatosRecepcion(datos._IdConf);
            string lcTablaControl = string.Empty;

            Log_comoffDto logDto = logRepository.GetDto(datos);
            logDto.TipoDato = "01";
            logDto.Resultado = 1;
            logDto.Detalle = "Obtener configuración de " + (tcTipoRecepcion == "i" ? "la carga inicial" : "datos") + " para la sucursal " + datos._Sucursal + ".";
            logRepository.Insert(logDto);
            CrearDataBaseTemporal(datos._Sucursal);


            decimal nCociente = (TabTmp != null ? TabTmp.Rows.Count : 99.0M);

            nCociente = (nCociente == 0 ? 100 : nCociente);
            InicializarBarraProgreso(Convert.ToInt32(nCociente));

            // Compruebo los ficheros created
            foreach (DataRow itemRow in TabTmp.Rows)
            {
                // comprovo si tinc el módul INSTAL·LAT
                if (!clsOfflineUtils.EvaluarCondicion(itemRow.Field<string>("visicond").TrimEnd().ToLower()))
                {
                    continue;
                }

                RegistroTabRel registro = ComprobarFicheros(itemRow, "_CREATED");
                lcTablaControl = TratarTablasRecepcion(datos, registro, logRepository);

                if (!string.IsNullOrWhiteSpace(lcTablaControl))
                {
                    RegistroTabRel registroControl = new RegistroTabRel();

                    registroControl._DBSecundaria = "OFFLINE";
                    registroControl._TablaSecundaria = lcTablaControl;
                    registroControl._Sufijo = registro._Sufijo;
                    registroControl._Clave = registro._Clave;
                    registroControl._Nombre = registro._Nombre;
                    registroControl._Prioridad = registro._Prioridad;

                    TratarTablasRecepcion(datos, registroControl, logRepository);
                }

                if (!string.IsNullOrWhiteSpace(registro._DBPrincipal) && !string.IsNullOrWhiteSpace(registro._DBSecundaria))
                {
                    lcTablaControl = _offlineConfig.ObtenerTablaControlRelacionada(registro._DBSecundaria + "!" + registro._TablaSecundaria);

                    if (!string.IsNullOrWhiteSpace(lcTablaControl))
                    {
                        RegistroTabRel registroControl = new RegistroTabRel();

                        registroControl._DBSecundaria = "OFFLINE";
                        registroControl._TablaSecundaria = lcTablaControl;
                        registroControl._Sufijo = registro._Sufijo;
                        registroControl._Clave = registro._Clave;
                        registroControl._Nombre = registro._Nombre;
                        registroControl._Prioridad = registro._Prioridad;

                        TratarTablasRecepcion(datos, registroControl, logRepository);
                    }
                }
            }

            // Compruebo los ficheros modified
            foreach (DataRow itemRow in TabTmp.Rows)
            {
                // comprovo si tinc el módul INSTAL·LAT
                if (!clsOfflineUtils.EvaluarCondicion(itemRow.Field<string>("visicond").TrimEnd().ToLower()))
                {
                    continue;
                }

                RegistroTabRel registro = ComprobarFicheros(itemRow, "_MODIFIED");
                lcTablaControl = TratarTablasRecepcion(datos, registro, logRepository);
            }

            InicializarBarraProgreso();

            //Faig el tractament dels partes de costes
            TratarRegistrosPartesCostes();

            if (!datos._IsCentral)
            {
                TratarRegistrosRiesgoCliente();
            }

            //S'han de rebre les imatges, en el cas que estigui marcat
            ProcesarImagenesRecibidas(datos, logRepository);
        }

        private static void ProcesarImagenesRecibidas(OfflineDatosComunicaciones datos, ILog_comoffRepository logRepository)
        {
            // Actualitzem la taula IMAGENES del mòdul OFFLINE
            string lcFile = Path.Combine(TempFolderName, "IMAGENES", "IMAGENES.xml");

            if (!File.Exists(lcFile))
            {
                return;
            }

            _TextStepDetalle = "Procesando imagenes recibidas";
            _TextStepProgreso = _TextStepDetalle;
            _PorcenProgreso = IncrementarBarraProgreso();

            DataTable table = ConvertFileToDatatable(lcFile, FormatoExportacion.XML);
            string lcSql = string.Empty;

            foreach (DataRow item in table.Rows)
            {
                string lcFichero = item["nombre"].ToString().TrimEnd();
                string lcOrigen = Path.Combine(TempFolderName, "IMAGENES", lcFichero);
                string lcDestino = Path.Combine(datos._IniServidor, "COMUNES", "FOTOS", lcFichero);
                string lcRuta = item["ruta"].ToString();
                int lnTipo = Convert.ToInt32(item["tipo"]);

                Log_comoffDto logDto = logRepository.GetDto(datos);

                // Definir tipo de datos en función del tipo de la imagen
                switch (lnTipo)
                {
                    case 1:
                    case 2:
                    case 3:
                    case 4:
                    case 7:
                    case 9:

                        logDto.TipoDato = clsOfflineUtils.ObtenerTipoDato("ARTICULO");
                        break;

                    case 5:

                        logDto.TipoDato = clsOfflineUtils.ObtenerTipoDato("_DATOSEMP");
                        break;

                    case 6:

                        logDto.TipoDato = clsOfflineUtils.ObtenerTipoDato("USUARIO");
                        break;


                    case 8:
                        logDto.TipoDato = clsOfflineUtils.ObtenerTipoDato("MANTENIMIENTOS");
                        break;

                    default:

                        logDto.TipoDato = "01";
                        break;
                }
                


                logDto.Detalle = "La imagen " + lcFichero + " se ha copiado en la carpeta " + Path.Combine(datos._IniServidor, "COMUNES", "FOTOS");

                if (!File.Exists(lcOrigen))
                {
                    logDto.Resultado = 3;
                    logDto.Detalle = "La imagen " + lcFichero + " no se ha recibido en el fichero de comunicaciones.";

                }
                else
                {
                    // Copiar els fitxers de les imatges a les rutes especificades
                    try
                    {
                        File.Copy(lcOrigen, lcDestino, true);
                    }
                    catch (Exception)
                    {
                        logDto.Resultado = 2;
                        logDto.Detalle = "No se ha podido realizar la copia de la imagen " + lcFichero + ", revise si existe la ruta indicada en la configuración " +
                                        "o si el usuario de Windows tiene permisos para acceder a dicha carpeta " + Path.Combine(datos._IniServidor, "COMUNES", "FOTOS");
                    }
                }

                logRepository.Insert(logDto);

                switch (lnTipo)
                {
                    case 4: // Colores

                        if (!lcRuta.Contains("COMUNES\\FOTOS\\"))
                        {
                            lcRuta = Path.Combine(lcRuta, lcFichero);

                            lcSql = "UPDATE " + DB.SQLDatabase("COMUNES", "COLORES") + " SET IMAGEN = " + DB.SQLString(lcDestino) + " WHERE IMAGEN = " + DB.SQLString(lcRuta);
                            DB.SQLExec(lcSql);
                        }
                        break;

                    case 8: // Vendedor

                        if (!lcRuta.Contains("COMUNES\\FOTOS\\"))
                        {
                            lcRuta = Path.Combine(lcRuta, lcFichero);

                            lcSql = "UPDATE " + DB.SQLDatabase("GESTION", "VENDEDOR") + " SET FOTO = " + DB.SQLString(lcDestino) + " WHERE FOTO = " + DB.SQLString(lcRuta);
                            DB.SQLExec(lcSql);
                        }
                        break;
                }
            }
        }

        private static void TratarRegistrosRiesgoCliente()
        {
            string lcSql = string.Empty;
            DataTable ldtRiesgoCliente = new DataTable();

            if (DB._SQLExisteTablaBBDD(_cRaizDataBaseTemporal + "GESTION", "RIESGO"))
            {
                lcSql = " SELECT EMPRESA,CODIGO,PED_PEND,ALB_PEND,FAC_PEND,FAC_NEG,FAC_REMPAG,NUM_IMPAGO,IMPAGOS,IMPAG4315,TOT_PEND,MED_DIAS,FAC_NOCONT," +
                        " PED_PENDIV,ALB_PENDIV,FAC_PENDIV,FAC_NEGDIV,FAC_REMDIV,IMPAGOSDIV,IMP4315DIV,TOT_PENDIV,FAC_NOCDIV " +
                        " FROM [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[RIESGO] " +
                        " UNION ALL " +
                        " SELECT EMPRESA,CODIGO,PED_PEND*(-1) AS PED_PEND,ALB_PEND*(-1) AS ALB_PEND,FAC_PEND*(-1) AS FAC_PEND,FAC_NEG*(-1) AS FAC_NEG,FAC_REMPAG*(-1) AS FAC_REMPAG," +
                        " NUM_IMPAGO*(-1) AS NUM_IMPAGO,IMPAGOS*(-1) AS IMPAGOS,IMPAG4315*(-1) AS IMPAG4315,TOT_PEND*(-1) AS TOT_PEND,MED_DIAS*(-1) AS MED_DIAS,FAC_NOCONT*(-1) AS FAC_NOCONT," +
                        " PED_PENDIV*(-1) AS PED_PENDIV,ALB_PENDIV*(-1) AS ALB_PENDIV,FAC_PENDIV*(-1) AS FAC_PENDIV,FAC_NEGDIV*(-1) AS FAC_NEGDIV," +
                        " FAC_REMDIV*(-1) AS FAC_REMDIV,IMPAGOSDIV*(-1) AS IMPAGOSDIV,IMP4315DIV*(-1) AS IMP4315DIV,TOT_PENDIV*(-1) AS TOT_PENDIV,FAC_NOCDIV *(-1) AS FACNOCDIV " +
                        " FROM [" + clsOfflineUtils.ObtenerNombreBdReal("GESTION") + "].dbo.[RIESGO]";

                DB.SQLExec(lcSql, ref ldtRiesgoCliente);

                if (ldtRiesgoCliente.Rows.Count > 0)
                {
                    // Agrupar lineas 
                    var ldtAgrupado = (from item in ldtRiesgoCliente.AsEnumerable()
                                       group item by new
                                       {
                                           empresa = item.Field<string>("empresa"),
                                           codigo = item.Field<string>("codigo")
                                       }
                                       into g
                                       select new
                                       {
                                           g.Key.empresa,
                                           g.Key.codigo,
                                           ped_pend = g.Sum(y => y.Field<decimal>("ped_pend")),
                                           alb_pend = g.Sum(y => y.Field<decimal>("alb_pend")),
                                           fac_pend = g.Sum(y => y.Field<decimal>("fac_pend")),
                                           fac_neg = g.Sum(y => y.Field<decimal>("fac_neg")),
                                           fac_rempag = g.Sum(y => y.Field<decimal>("fac_rempag")),
                                           num_impago = g.Sum(y => y.Field<int>("num_impago")),
                                           impagos = g.Sum(y => y.Field<decimal>("impagos")),
                                           impag4315 = g.Sum(y => y.Field<decimal>("impag4315")),
                                           tot_pend = g.Sum(y => y.Field<decimal>("tot_pend")),
                                           med_dias = g.Sum(y => y.Field<decimal>("med_dias")),
                                           fac_nocont = g.Sum(y => y.Field<decimal>("fac_nocont")),
                                           ped_pendiv = g.Sum(y => y.Field<decimal>("ped_pendiv")),
                                           alb_pendiv = g.Sum(y => y.Field<decimal>("alb_pendiv")),
                                           fac_pendiv = g.Sum(y => y.Field<decimal>("fac_pendiv")),
                                           fac_negdiv = g.Sum(y => y.Field<decimal>("fac_negdiv")),
                                           fac_remdiv = g.Sum(y => y.Field<decimal>("fac_remdiv")),
                                           impagosdiv = g.Sum(y => y.Field<decimal>("impagosdiv")),
                                           imp4315div = g.Sum(y => y.Field<decimal>("imp4315div")),
                                           tot_pendiv = g.Sum(y => y.Field<decimal>("tot_pendiv")),
                                           fac_nocdiv = g.Sum(y => y.Field<decimal>("fac_nocdiv"))
                                       }).__CopyToDataTable();

                    string lcWhere = string.Empty;
                    foreach (DataRow item in ldtAgrupado.Rows)
                    {
                        lcWhere = " WHERE EMPRESA = " + DB.SQLString(item["EMPRESA"]) + " AND CODIGO = " + DB.SQLString(item["CODIGO"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + DB.SQLDatabase("OFFLINE", "RIESGOCEN") + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + DB.SQLDatabase("OFFLINE", "RIESGOCEN") +
                                        " Set PED_PEND = " + DB.SQLString(item["PED_PEND"]) + ", " +
                                            " ALB_PEND = " + DB.SQLString(item["ALB_PEND"]) + ", " +
                                            " FAC_PEND = " + DB.SQLString(item["FAC_PEND"]) + ", " +
                                            " FAC_NEG = " + DB.SQLString(item["FAC_NEG"]) + ", " +
                                            " FAC_REMPAG = " + DB.SQLString(item["FAC_REMPAG"]) + ", " +
                                            " NUM_IMPAGO = " + DB.SQLString(item["NUM_IMPAGO"]) + ", " +
                                            " IMPAGOS = " + DB.SQLString(item["IMPAGOS"]) + ", " +
                                            " IMPAG4315 = " + DB.SQLString(item["IMPAG4315"]) + ", " +
                                            " TOT_PEND = " + DB.SQLString(item["TOT_PEND"]) + ", " +
                                            " MED_DIAS = " + DB.SQLString(item["MED_DIAS"]) + ", " +
                                            " FAC_NOCONT = " + DB.SQLString(item["FAC_NOCONT"]) + ", " +
                                            " PED_PENDIV = " + DB.SQLString(item["PED_PENDIV"]) + ", " +
                                            " ALB_PENDIV = " + DB.SQLString(item["ALB_PENDIV"]) + ", " +
                                            " FAC_PENDIV = " + DB.SQLString(item["FAC_PENDIV"]) + ", " +
                                            " FAC_NEGDIV = " + DB.SQLString(item["FAC_NEGDIV"]) + ", " +
                                            " FAC_REMDIV = " + DB.SQLString(item["FAC_REMDIV"]) + ", " +
                                            " IMPAGOSDIV = " + DB.SQLString(item["IMPAGOSDIV"]) + ", " +
                                            " IMP4315DIV = " + DB.SQLString(item["IMP4315DIV"]) + ", " +
                                            " TOT_PENDIV = " + DB.SQLString(item["TOT_PENDIV"]) + ", " +
                                            " FAC_NOCDIV = " + DB.SQLString(item["FAC_NOCDIV"]) +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + DB.SQLDatabase("OFFLINE", "RIESGOCEN") + " " +
                                        " (EMPRESA,CODIGO,PED_PEND,ALB_PEND,FAC_PEND,FAC_NEG,FAC_REMPAG,NUM_IMPAGO,IMPAGOS,IMPAG4315,TOT_PEND,MED_DIAS,FAC_NOCONT," +
                                        " PED_PENDIV,ALB_PENDIV,FAC_PENDIV,FAC_NEGDIV,FAC_REMDIV,IMPAGOSDIV,IMP4315DIV,TOT_PENDIV,FAC_NOCDIV) " +
                                        " VALUES (" +
                                            DB.SQLString(item["EMPRESA"]) + ", " +
                                            DB.SQLString(item["CODIGO"]) + ", " +
                                            DB.SQLString(item["PED_PEND"]) + ", " +
                                            DB.SQLString(item["ALB_PEND"]) + ", " +
                                            DB.SQLString(item["FAC_PEND"]) + ", " +
                                            DB.SQLString(item["FAC_NEG"]) + ", " +
                                            DB.SQLString(item["FAC_REMPAG"]) + ", " +
                                            DB.SQLString(item["NUM_IMPAGO"]) + ", " +
                                            DB.SQLString(item["IMPAGOS"]) + ", " +
                                            DB.SQLString(item["IMPAG4315"]) + ", " +
                                            DB.SQLString(item["TOT_PEND"]) + ", " +
                                            DB.SQLString(item["MED_DIAS"]) + ", " +
                                            DB.SQLString(item["FAC_NOCONT"]) + ", " +
                                            DB.SQLString(item["PED_PENDIV"]) + ", " +
                                            DB.SQLString(item["ALB_PENDIV"]) + ", " +
                                            DB.SQLString(item["FAC_PENDIV"]) + ", " +
                                            DB.SQLString(item["FAC_NEGDIV"]) + ", " +
                                            DB.SQLString(item["FAC_REMDIV"]) + ", " +
                                            DB.SQLString(item["IMPAGOSDIV"]) + ", " +
                                            DB.SQLString(item["IMP4315DIV"]) + ", " +
                                            DB.SQLString(item["TOT_PENDIV"]) + ", " +
                                            DB.SQLString(item["FAC_NOCDIV"]) + ") " +
                                " END ";

                        DB.SQLExec(lcSql);
                    }
                }
            }
        }

        private static void TratarRegistrosPartesCostes()
        {
            TratarRegistrosEspeciales("GESTION", "C_PARTES", "_CREATED");
            TratarRegistrosEspeciales("GESTION", "D_PARTES", "_CREATED");
            TratarRegistrosEspeciales("OFFLINE", "CTRL_PARCO", "_CREATED");

            TratarRegistrosEspeciales("GESTION", "C_PARTES", "_MODIFIED");
            TratarRegistrosEspeciales("GESTION", "D_PARTES", "_MODIFIED");
            TratarRegistrosEspeciales("OFFLINE", "CTRL_PARCO", "_MODIFIED");
        }

        private static void TratarRegistrosEspeciales(string tcDatabase, string tcTabla, string tcSufijo)
        {
            string lcCadenaCamps = string.Empty;
            string lcSetCampos = string.Empty;
            string lcIndice = string.Empty;
            string lcCondicion = string.Empty;
            string lcRutaOtrasien = string.Empty;
            string lcSql = string.Empty;

            // BUSQUEM A LA RUTA TEMPORAL SI S'HAN REBUT ELS FITXERS
            lcRutaOtrasien = Path.Combine(TempFolderName, tcDatabase, tcTabla + tcSufijo) + ".xml";

            if (!File.Exists(lcRutaOtrasien))
            {
                return;
            }

            _TextStepDetalle = "Procesando registros " + tcTabla;
            _TextStepProgreso = _TextStepDetalle;
            _PorcenProgreso = IncrementarBarraProgreso();

            // Index de la taula a tractar
            lcCadenaCamps = ObtenerCamposSelect(tcDatabase, tcTabla + tcSufijo);
            lcSetCampos = ObtenerCamposSet(tcDatabase, tcTabla + tcSufijo);
            lcIndice = ObtenerCamposIndices(tcDatabase, tcTabla);

            lcSql = " UPDATE [" + clsOfflineUtils.ObtenerNombreBdReal(tcDatabase) + "].dbo.[" + tcTabla + "] " +
                        " SET " + lcSetCampos +
                        " FROM  [" + clsOfflineUtils.ObtenerNombreBdReal(tcDatabase) + "].dbo.[" + tcTabla + "] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + tcDatabase +"].dbo.[" + tcTabla + tcSufijo + "] b " +
                        " ON " + lcIndice;
            DB.SQLExec(lcSql);

            lcSql = "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + tcDatabase + "].dbo.[_Especial] ";
            DB.SQLExec(lcSql);

            // la condicion només l'aplicarem sobre el primer camp
            lcCondicion = lcIndice.Trim();
            lcCondicion = lcCondicion.Substring(0, lcCondicion.IndexOf('='));

            // farem el FULL JOIN, per trobar els nous registres
            lcSql = "SELECT b.* into [" + _cRaizDataBaseTemporal + tcDatabase + "].dbo.[_Especial] " +
                        " FROM [" + clsOfflineUtils.ObtenerNombreBdReal(tcDatabase) + "].dbo.[" + tcTabla + "] a " +
                        " RIGHT JOIN [" + _cRaizDataBaseTemporal + tcDatabase + "].dbo.[" + tcTabla + tcSufijo + "] b " +
                        " ON " + lcIndice +
                        " WHERE " + lcCondicion + " is null ";
            DB.SQLExec(lcSql);


            // farem el insert
            lcSql = "INSERT INTO [" + clsOfflineUtils.ObtenerNombreBdReal(tcDatabase) + "].dbo.[" + tcTabla + "] (" + lcCadenaCamps + ") " +
                    "SELECT " + lcCadenaCamps + " FROM [" + _cRaizDataBaseTemporal + tcDatabase + "].dbo.[_Especial] ";
            DB.SQLExec(lcSql);
        }

        private static RegistroTabRel ComprobarFicheros(DataRow item, string tcSufijo)
        {
            RegistroTabRel registro = new RegistroTabRel();

            registro._DBPrincipal = string.Empty;
            registro._TablaPrincipal = string.Empty;

            registro._DBSecundaria = string.Empty;
            registro._TablaSecundaria = string.Empty;

            registro._Empresa = item.Field<string>("empresa").TrimEnd();
            registro._EmpresaSecundaria = item.Field<string>("empresecun").TrimEnd();
            registro._Sufijo = string.Empty;
            registro._Prioridad = 0;
            registro._ID = item.Field<int>("ID");
            registro._Clave = item.Field<string>("clave").TrimEnd();
            registro._Nombre = item.Field<string>("nombre").TrimEnd();
            registro._Visible = item.Field<bool>("visible");

            if (!string.IsNullOrWhiteSpace(item.Field<string>("principal")))
            {
                string[] subPos = item.Field<string>("principal").TrimEnd().Split('!');
                if (subPos.Length == 2)
                {
                    registro._DBPrincipal = subPos[0].TrimEnd();
                    registro._TablaPrincipal = subPos[1].TrimEnd();
                    registro._Sufijo = tcSufijo;
                }

                // S'HA DE BUSCAR EL FITXER FISIC, AMB EL NOM ALTERNATIU, SI ES QUE EN TE
                // BUSQUEM A LA RUTA TEMPORAL SI S'HAN REBUT ELS FITXERS
                string lcRutaPrin = Path.Combine(TempFolderName, registro._DBPrincipal, registro._TablaPrincipal + registro._Sufijo) + ".xml";

                if (!File.Exists(lcRutaPrin))
                {
                    registro._DBPrincipal = string.Empty;
                    registro._TablaPrincipal = string.Empty;
                }
            }

            // taula secundaria
            if (!string.IsNullOrWhiteSpace(item.Field<string>("secundaria")))
            {
                string[] subPos = item.Field<string>("secundaria").TrimEnd().Split('!');
                if (subPos.Length == 2)
                {
                    registro._DBSecundaria = subPos[0].TrimEnd();
                    registro._TablaSecundaria = subPos[1].TrimEnd();
                    registro._Sufijo = tcSufijo;
                }

                registro._Relacion = item.Field<string>("relacion");

                // S'HA DE BUSCAR EL FITXER FISIC, AMB EL NOM ALTERNATIU, SI ES QUE EN TE
                // BUSQUEM A LA RUTA TEMPORAL SI S'HAN REBUT ELS FITXERS
                string lcRutaSecun = Path.Combine(TempFolderName, registro._DBSecundaria, registro._TablaSecundaria + registro._Sufijo) + ".xml";

                if (!File.Exists(lcRutaSecun))
                {
                    registro._DBSecundaria = string.Empty;
                    registro._TablaSecundaria = string.Empty;
                    registro._Relacion = string.Empty;
                }
            }

            registro._Prioridad = item.Field<int>("prioridad");

            registro._Otrasien = item.Field<string>("otrasien").TrimEnd();
            registro._Asientos = item.Field<string>("asientos").TrimEnd();
            registro._Ivareper = item.Field<string>("ivareper").TrimEnd();
            registro._Ivasopor = item.Field<string>("ivasopor").TrimEnd();
            registro._Iva_exen = item.Field<string>("iva_exen").TrimEnd();
            registro._Retreper = item.Field<string>("retreper").TrimEnd();
            registro._Retsopor = item.Field<string>("retsopor").TrimEnd();
            registro._Eos = item.Field<string>("eos").TrimEnd();
            registro._Compras = item.Field<string>("compras").TrimEnd();

            return registro;
        }

        private static string TratarTablasRecepcion(OfflineDatosComunicaciones datos, RegistroTabRel registro, ILog_comoffRepository logRepository)
        {
            bool llDiferente = true;
            string lcTablaControl = string.Empty;

            TratamientoEspecialRecepcion(datos, ref registro, logRepository);
            registro._Sobreescribir = (datos._IsCentral ? registro._Prioridad == 2 : registro._Prioridad == 1);

            //TRACTAR PRINCIPAL
            if (!string.IsNullOrWhiteSpace(registro._DBPrincipal) && !string.IsNullOrWhiteSpace(registro._TablaPrincipal))
            {
                if (!registro._TablaPrincipal.Contains("CTRL_"))
                {
                    llDiferente = _tablaOld != registro._Clave + registro._DBPrincipal + registro._TablaPrincipal + registro._Sufijo + (registro._Sobreescribir ? "S" : "N");
                    _tablaOld = registro._Clave + registro._DBPrincipal + registro._TablaPrincipal + registro._Sufijo + (registro._Sobreescribir ? "S" : "N");
                }

                // La principal només cal fer-la la primera vegada
                if (llDiferente)
                {
                    //Si al recuperar la tabla viene "sobreescribir" no tendremos la tabla "_InsertPrin" por esos su cambia el valor de la propiedad deberá de pasar por el método actualziar_datos
                    registro._Actualizado = ActualizarDatosRecepcion(datos, registro, logRepository);

                    lcTablaControl = _offlineConfig.ObtenerTablaControlRelacionada(registro._DBPrincipal + "!" + registro._TablaPrincipal);
                }
            }

            // TRACTAR SECUNDARIA
            if (!string.IsNullOrWhiteSpace(registro._DBSecundaria) && !string.IsNullOrWhiteSpace(registro._TablaSecundaria))
            {
                ActualizarDatosRecepcion(datos, registro, logRepository, true);
            }

            // Tratamiento especial para la tabla COMPRAS
            if (!string.IsNullOrWhiteSpace(registro._Compras))
            {
                TratamientoEspecial_Compras(registro);
            }

            return lcTablaControl;
        }

        private static bool CrearTablaTemporal(string tcDB, string tcTabla, string tcSufijo, string tcEmpresa, bool tlPrincipal)
        {
            string lcTaulaTemp = string.Empty;
            string lcFiltre = string.Empty;
            string lcOr = string.Empty;
            string lcSql = string.Empty;

            lcTaulaTemp = (tlPrincipal ? "_Principal" : "_Secundaria");

            if (!DB._SQLExisteBBDD(_cRaizDataBaseTemporal + tcDB))
            {
                return false;
            }

            // Eliminem la taula de la base de dades
            lcSql = "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + tcDB + "].dbo.[" + lcTaulaTemp + "] ";
            DB.SQLExec(lcSql);

            // S'ha de comprovar si tenim el camp EMPRESA ple, i filtrar només per les empreses existents
            if (!string.IsNullOrWhiteSpace(tcEmpresa))
            {
                lcOr = "";
                string lcCampoEmpresa = tcEmpresa;
                clsOfflineUtils.RevisarTablasCampoEmpresa(tcTabla, ref lcCampoEmpresa);

                if (!string.IsNullOrWhiteSpace(lcCampoEmpresa))
                {
                    DataTable ldtEmpresa = new DataTable();
                    DB.SQLExec("SELECT CODIGO as EMPRESA FROM " + DB.SQLDatabase("GESTION", "EMPRESA"), ref ldtEmpresa);

                    // Montem el filtre
                    foreach (DataRow item in ldtEmpresa.Rows)
                    {
                        lcFiltre = lcFiltre + lcOr + lcCampoEmpresa + " = " + DB.SQLString(item.Field<string>("empresa")) + " ";
                        lcOr = " Or ";
                    }

                    // Pueden existir registros metidos a mano sin empresa asignada
                    if (tcTabla.ToUpper() == "REFERPRO")
                    {
                        lcFiltre = lcFiltre + lcOr + lcCampoEmpresa + " = " + DB.SQLString("") + " ";
                    }
                }
            }

            lcFiltre = (!string.IsNullOrWhiteSpace(lcFiltre) ? " Where " : "") + lcFiltre;

            // Fem una copia de la taula a tractar
            if (!DB._SQLExisteTablaBBDD(_cRaizDataBaseTemporal + tcDB, tcTabla + tcSufijo))
            {
                lcSql = "SELECT * INTO [" + _cRaizDataBaseTemporal + tcDB + "].dbo.[" + tcTabla + tcSufijo + "] " +
                            " FROM " + DB.SQLDatabase(tcDB, tcTabla) + " WHERE 1=2 ";

                DB.SQLExec(lcSql);
            }

            lcSql = "SELECT * INTO [" + _cRaizDataBaseTemporal + tcDB + "].dbo.[" + lcTaulaTemp + "] " +
                            " FROM [" + _cRaizDataBaseTemporal + tcDB + "].dbo.[" + tcTabla + tcSufijo + "] " + lcFiltre;

            DB.SQLExec(lcSql);

            return true;
        }

        private static bool ImportarAsientos(OfflineDatosComunicaciones datos, RegistroTabRel registro, ILog_comoffRepository logRepository, string tcTabla = "_Secundaria")
        {
            int lnAsiento = 0;
            int lnNumAntic = 0;

            string lcSql = string.Empty;
            DataTable ldtAsi = new DataTable();

            lcSql = "SELECT DISTINCT empresa, numero FROM [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + tcTabla + "] ";
            DB.SQLExec(lcSql, ref ldtAsi);

            if (ldtAsi.Rows.Count == 0)
            {
                return true;
            }
            else
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "OFFLINE" + "].dbo.[_ControlAsientos] ");

                // Fem una copia de la taula a tractar
                if (DB._SQLExisteTablaBBDD(_cRaizDataBaseTemporal + "OFFLINE", "CTRL_ASIEN" + registro._Sufijo))
                {
                    string lcAny = EW_GLOBAL._GetVariable("wc_any").ToString();
                    lcSql = "SELECT a.* INTO [" + _cRaizDataBaseTemporal + "OFFLINE" + "].dbo.[_ControlAsientos] " +
                                " FROM [" + _cRaizDataBaseTemporal + "OFFLINE" + "].dbo.[" + "CTRL_ASIEN" + registro._Sufijo + "] a " +
                                " INNER JOIN [" + _cRaizDataBaseTemporal + "GESTION].dbo.[" + tcTabla + "] b " +
                                        " ON A.EMPRESA = b.EMPRESA AND a.NUMERO = b.NUMERO and a.LINEA = b.LINEA AND a.EJERCICIO = " + DB.SQLString(lcAny);
                }
                else
                {
                    lcSql = "SELECT * INTO [" + _cRaizDataBaseTemporal + "OFFLINE" + "].dbo.[_ControlAsientos] " +
                                " FROM " + DB.SQLDatabase("OFFLINE", "CTRL_ASIEN") +
                                " WHERE 1=2 ";
                }

                DB.SQLExec(lcSql);

                DB.SQLBegin();

                // he de passar el valor del numero d'asiento a negatiu per evitar problemes
                lcSql = "UPDATE [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + tcTabla + "] SET NUMERO = NUMERO * (-1) ";
                DB.SQLExec(lcSql);

                // he de passar el valor del numero d'asiento a negatiu per evitar problemes
                lcSql = "UPDATE [" + _cRaizDataBaseTemporal + "OFFLINE" + "].dbo.[_ControlAsientos] SET NUMERO = NUMERO * (-1) ";
                DB.SQLExec(lcSql);

                foreach (DataRow item in ldtAsi.Rows)
                {
                    lnNumAntic = item.Field<int>("numero") * (-1);

                    // busco el contador d'asientos de l'empresa actual.
                    lnAsiento = Convert.ToInt32(FUNCTIONS._SumaNumero(item.Field<string>("empresa"), "ASIENTO", "EMPRESA", "GESTION", "CODIGO"));

                    while (!string.IsNullOrWhiteSpace(DB.SQLValor("ASIENTOS","EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) + " AND NUMERO",lnAsiento.ToString(),"EMPRESA","GESTION").ToString()))
                    {
                        lnAsiento = Convert.ToInt32(FUNCTIONS._SumaNumero(item.Field<string>("empresa"), "ASIENTO", "EMPRESA", "GESTION", "CODIGO"));
                    }

                    lcSql = "UPDATE [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + tcTabla + "] " +
                            " SET NUMERO = " + DB.SQLString(lnAsiento) +
                            " WHERE NUMERO = " + DB.SQLString(lnNumAntic) + " AND EMPRESA = " + DB.SQLString(item.Field<string>("empresa"));
                    DB.SQLExec(lcSql);

                    lcSql = "UPDATE [" + _cRaizDataBaseTemporal + "OFFLINE" + "].dbo.[_ControlAsientos] " +
                            " SET NUMERO = " + DB.SQLString(lnAsiento) +
                            " WHERE NUMERO = " + DB.SQLString(lnNumAntic) + " AND EMPRESA = " + DB.SQLString(item.Field<string>("empresa"));
                    DB.SQLExec(lcSql);
                }

                DB.SQLCommit();

                lcSql = "SELECT DISTINCT empresa, asi FROM [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + tcTabla + "] ";
                DB.SQLExec(lcSql, ref ldtAsi);

                string lcInnerOn = string.Empty;

                switch (registro._TablaSecundaria)
                {
                    case "ASIENTOS":

                        if (!string.IsNullOrWhiteSpace(registro._TablaPrincipal))
                        {
                            lcInnerOn = " INNER JOIN " + DB.SQLDatabase(registro._DBPrincipal, registro._TablaPrincipal) + " b ON " + ObtenerInnerOn(registro._DBSecundaria, registro._DBPrincipal, registro._TablaSecundaria, registro._TablaPrincipal, registro._Relacion, registro._Clave, datos, logRepository);
                        }
                        break;

                    case "IVACJREPER":
                    case "IVACJSOPOR":

                        lcInnerOn = " INNER JOIN " + DB.SQLDatabase(registro._DBSecundaria, registro._TablaSecundaria) + " b ON " + " a.empresa = b.empresa AND a.asi = b.asirecc ";
                        break;

                    default:

                        lcInnerOn = " INNER JOIN " + DB.SQLDatabase(registro._DBSecundaria, registro._TablaSecundaria) + " b ON " + " a.empresa = b.empresa AND a.asi = b.asi ";
                        break;

                }

                foreach (DataRow item in ldtAsi.Rows)
                {
                    lcSql = " DELETE FROM " + DB.SQLDatabase("OFFLINE", "CTRL_ASIEN") +
                            " WHERE EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) +
                            " AND EJERCICIO = " + DB.SQLString(_cAny) +
                            " AND NUMERO IN ( SELECT a.NUMERO FROM " + DB.SQLDatabase("GESTION", "ASIENTOS") + " a " +
                                              lcInnerOn +
                                            " WHERE a.EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) +
                                            " AND a.ASI = " + DB.SQLString(item.Field<string>("asi")) + " ) ";
                    DB.SQLExec(lcSql);

                    lcSql = " DELETE FROM " + DB.SQLDatabase("GESTION", "ASIENTOS") +
                            " WHERE EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) +
                            " AND NUMERO IN ( SELECT a.NUMERO FROM " + DB.SQLDatabase("GESTION", "ASIENTOS") + " a " +
                                              lcInnerOn +
                                            " WHERE a.EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) +
                                            " AND a.ASI = " + DB.SQLString(item.Field<string>("asi")) + " ) ";
                    DB.SQLExec(lcSql);
                }
            }

            return true;
        }

        private static bool ImportarEntidad(RegistroTabRel registro)
        {
            // tractar els diferents casos on esta la taula cajas
            string lcDbReal = clsOfflineUtils.ObtenerNombreBdReal(registro._DBPrincipal);

            // Actualitzem la temporal amb les dades de la BD real abans de volcar-la a la real
            string lcSql = "Update [" + _cRaizDataBaseTemporal + registro._DBPrincipal + "].dbo.[_Principal] " +
                            "Set CARTAPAG = COALESCE(B.CARTAPAG, '') " +
                            "From [" + _cRaizDataBaseTemporal + registro._DBPrincipal + "].dbo.[_Principal]  A " +
                            "Left Join [" + lcDbReal + "].dbo.[" + registro._TablaPrincipal + "] B On A.CODIGO = B.CODIGO ";

            return DB.SQLExec(lcSql);
        }

        private static bool ImportarCajas(RegistroTabRel registro)
        {
            // tractar els diferents casos on esta la taula cajas
            string lcDbReal = clsOfflineUtils.ObtenerNombreBdReal(registro._DBPrincipal);

            // Actualitzem la temporal amb les dades de la BD real abans de volcar-la a la real
            string lcSql = "Update [" + _cRaizDataBaseTemporal + registro._DBPrincipal + "].dbo.[_Principal] " +
                            "Set PTICKETS = COALESCE(B.PTICKETS, ''), " +
                                "PDISPLAY = COALESCE(B.PDISPLAY, ''), " +
                                "PCAJA = COALESCE(B.PCAJA, ''), " +
                                "NOMPCAJA = COALESCE(B.NOMPCAJA, ''), " +
                                "NOMPDISP = COALESCE(B.NOMPDISP, ''), " +
                                "IMPRESORA2 = COALESCE(B.IMPRESORA2, ''), " +
                                "IMPRESORA = COALESCE(B.IMPRESORA, ''), " +
                                "IMP_COCI = COALESCE(B.IMP_COCI, ''), " +
                                "IMP_RESUM = COALESCE(B.IMP_RESUM, '') " +
                            "From [" + _cRaizDataBaseTemporal + registro._DBPrincipal + "].dbo.[_Principal]  A " +
                            "Left Join [" + lcDbReal + "].dbo.[" + registro._TablaPrincipal + "] B On A.CODIGO = B.CODIGO ";

            return DB.SQLExec(lcSql);
        }

        private static bool ImportarUniUsers(RegistroTabRel registro)
        {
            string lcIdSage50 = DB.SQLValor("GRUPOSEMP", "CODIGO", GrupoEmpresa._CodigoGrupoActual().ToString().Trim(), "IDSAGE50", "EUROWINSYS").ToString();

            // Actualitzem la temporal amb les dades de la BD real abans de volcar-la a la real
            string lcSql = "Update [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Secundaria] " +
                            "Set IDSAGE50 = " + DB.SQLString(lcIdSage50);

            DB.SQLExec(lcSql);

            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Especial]");

            lcSql = " SELECT DISTINCT " + ObtenerCamposSelect(registro._DBSecundaria, registro._TablaSecundaria + registro._Sufijo, "a.") + 
                    " INTO [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Especial] " +
                    " FROM [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Secundaria] a ";
            DB.SQLExec(lcSql);

            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Secundaria]");

            lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Secundaria] " +
                    " FROM [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Especial] ";
            DB.SQLExec(lcSql);

            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Especial]");

            return true;
        }

        private static bool ImportarAccesoGrup(RegistroTabRel registro)
        {
            string lcGrupo = GrupoEmpresa._CodigoGrupoActual().ToString().Trim();
            string lcIdSage50 = DB.SQLValor("GRUPOSEMP", "CODIGO", lcGrupo, "IDSAGE50", "EUROWINSYS").ToString();

            // Actualitzem la temporal amb les dades de la BD real abans de volcar-la a la real
            string lcSql = "Update [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Secundaria] " +
                            "Set IDSAGE50 = " + DB.SQLString(lcIdSage50) + ", GRUPO = " + DB.SQLString(lcGrupo); 
                            
            return DB.SQLExec(lcSql);
        }

        private static bool ImportarAccesos(RegistroTabRel registro)
        {
            string lcDbReal = clsOfflineUtils.ObtenerNombreBdReal(registro._DBPrincipal);

            string lcSql = "DELETE FROM [" + lcDbReal + "].dbo.[" + registro._TablaPrincipal + "] ";

            return DB.SQLExec(lcSql);
        }

        private static bool ImportarConfTick(RegistroTabRel registro)
        {
            string lcDbReal = clsOfflineUtils.ObtenerNombreBdReal(registro._DBPrincipal);

            // Actualitzem la temporal amb les dades de la BD real abans de volcar-la a la real
            string lcSql = "Update [" + _cRaizDataBaseTemporal + registro._DBPrincipal + "].dbo.[_Principal] " +
                                "Set TICKETS = B.TICKETS, " +
                                    "ARQUEO = B.ARQUEO, " +
                                    "FACTICK = B.FACTICK, " +
                                    "PEDINT = B.PEDINT " +
                            "From [" + _cRaizDataBaseTemporal + registro._DBPrincipal + "].dbo.[_Principal]  A " +
                            "Inner Join [" + lcDbReal + "].dbo.[" + registro._TablaPrincipal + "] B On A.EMPRESA = B.EMPRESA ";


            return DB.SQLExec(lcSql);
        }

        private static bool ImportarAlbaranesFacturas(RegistroTabRel registro)
        {
            string lcSql = " DELETE FROM [" + _cRaizDataBaseTemporal + registro._DBPrincipal + "].dbo.[_Principal] ";

            switch (registro._Clave)
            {
                case "C_ALBVEN":
                case "C_ALBCOM":

                    lcSql += " WHERE FACTURA != '' ";
                    break;

                case "FACTURAS":
                case "FACTURAC":

                    lcSql += " WHERE FACTURA = '' ";
                    break;

                default:

                    lcSql = "";
                    break;
            }

            if (string.IsNullOrWhiteSpace(lcSql))
            {
                return true;
            }
            else
            {
                return DB.SQLExec(lcSql);
            }
        }

        private static bool ImportarStocklotes(RegistroTabRel registro)
        {
            string lcDbReal = clsOfflineUtils.ObtenerNombreBdReal(registro._DBPrincipal);
            string lcDbReal2 = clsOfflineUtils.ObtenerNombreBdReal(registro._DBSecundaria);

            switch (registro._TablaPrincipal)
            {
                case "STOCKS2":

                    // preparo la taula secundaria
                    DataTable ldtStockLotes = new DataTable();
                    string lcSql = "SELECT * " +
                                    " FROM [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Secundaria] " +
                                    " ORDER BY EMPRESA, ALMACEN, ARTICULO, TALLA, COLOR ";

                    DB.SQLExec(lcSql, ref ldtStockLotes);

                    if (ldtStockLotes.Rows.Count == 0)
                    {
                        return true;
                    }

                    // faig una regularització al dia anterior, ja que ha de ser l'últim moviment del dia 
                    DateTime FechaMaxima = DateTime.Today.AddDays(-1);

                    // Eliminar els possibles registres de la data que anem a afegir

                    DataTable ldtRevisar = new DataTable();
                    lcSql = "SELECT DISTINCT empresa, almacen " +
                            " FROM [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Secundaria] " +
                            " ORDER BY EMPRESA, ALMACEN ";
                    DB.SQLExec(lcSql, ref ldtRevisar);

                    string lcCondicion = string.Empty;

                    foreach (DataRow item in ldtRevisar.Rows)
                    {
                        lcCondicion = " EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) + " AND ALMACEN = " + DB.SQLString(item.Field<string>("almacen"));

                        lcSql = "DELETE FROM " + DB.SQLDatabase("GESTION", "REGULARI") +
                                    " WHERE (DOCUMENTO='SINCRONIZACION' OR DOCUMENTO='STOCKSOFFLINE') " +
                                    " AND " + lcCondicion + " AND FECHA = " + DB.SQLString(FechaMaxima);
                        DB.SQLExec(lcSql);

                        lcSql = "DELETE FROM " + DB.SQLDatabase("LOTES", "LTREGUL") +
                                    " WHERE (DOCUMENTO='SINCRONIZACION' OR DOCUMENTO='STOCKSOFFLINE') " +
                                    " AND " + lcCondicion + " AND FECHA = " + DB.SQLString(FechaMaxima);
                        DB.SQLExec(lcSql);
                    }

                    DataTable ldtRegulari = new DataTable();
                    lcSql = " SELECT * FROM " + DB.SQLDatabase("GESTION", "REGULARI") + " WHERE 1=2 ";
                    DB.SQLExec(lcSql, ref ldtRegulari);

                    DataTable ldtLtregul = new DataTable();
                    lcSql = " SELECT * FROM " + DB.SQLDatabase("LOTES", "LTREGUL") + " WHERE 1=2 ";
                    DB.SQLExec(lcSql, ref ldtLtregul);

                    string lcOldCodi = "##@@";
                    string lcOldArticulo = "%&/(";
                    string lcDocumento = "STOCKSOFFLINE";
                    int lnLinia = 0;

                    foreach (DataRow item in ldtStockLotes.Rows)
                    {
                        // si canvia l'empresa o el magatzem, fem un inventari nou

                        if (lcOldCodi != item.Field<string>("EMPRESA") + item.Field<string>("ALMACEN"))
                        {
                            if (lcOldCodi != "##@@")
                            {
                                foreach (DataRow row in ldtRegulari.Rows)
                                {
                                    ImportarStocklotesRegulari(row);
                                }
                            }

                            lcSql = " SELECT * FROM " + DB.SQLDatabase("GESTION", "REGULARI") +
                                    " WHERE EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) +
                                    " AND ALMACEN = " + DB.SQLString(item.Field<string>("almacen")) +
                                    " AND FECHA = " + DB.SQLString(FechaMaxima) +
                                    " AND DOCUMENTO = " + DB.SQLString(lcDocumento);
                            DB.SQLExec(lcSql, ref ldtRegulari);

                            if (ldtRegulari.Rows.Count == 0)
                            {
                                lnLinia = 0;
                            }
                            else
                            {
                                lnLinia = Convert.ToInt32(ldtRegulari.Compute("MAX(LINIA)", ""));
                            }

                            lcOldCodi = item.Field<string>("empresa") + item.Field<string>("almacen");
                            lcOldArticulo = "%&/(";
                        }


                        if (lcOldArticulo != item.Field<string>("ARTICULO") + item.Field<string>("TALLA") + item.Field<string>("COLOR"))
                        {
                            lnLinia = lnLinia + 1;

                            DataRow newRowRegulari = ldtRegulari.NewRow();

                            newRowRegulari["EMPRESA"] = item.Field<string>("empresa");
                            newRowRegulari["ALMACEN"] = item.Field<string>("ALMACEN");
                            newRowRegulari["FECHA"] = FechaMaxima;
                            newRowRegulari["FECHASTOCK"] = FechaMaxima;
                            newRowRegulari["ARTICULO"] = item.Field<string>("ARTICULO");
                            newRowRegulari["UNIDADES"] = item.Field<decimal>("UNIDADES");
                            newRowRegulari["PESO"] = item.Field<decimal>("PESO");
                            newRowRegulari["LINIA"] = lnLinia;
                            newRowRegulari["TALLA"] = item.Field<string>("TALLA");
                            newRowRegulari["COLOR"] = item.Field<string>("COLOR");
                            newRowRegulari["PMCOM"] = 0M;
                            newRowRegulari["PMSTOCK"] = 0M;
                            newRowRegulari["DOCUMENTO"] = lcDocumento;

                            ldtRegulari.Rows.Add(newRowRegulari);

                            lcOldArticulo = item.Field<string>("ARTICULO") + item.Field<string>("TALLA") + item.Field<string>("COLOR");


                            if (lcOldArticulo != "%&/(")
                            {
                                foreach (DataRow row in ldtLtregul.Rows)
                                {
                                    ImportarStocklotesLtregul(row);
                                }
                            }


                            lcSql = " SELECT * FROM " + DB.SQLDatabase("LOTES", "LTREGUL") +
                                    " WHERE EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) +
                                    " AND ALMACEN = " + DB.SQLString(item.Field<string>("almacen")) +
                                    " AND FECHA = " + DB.SQLString(FechaMaxima) +
                                    " AND DOCUMENTO = " + DB.SQLString(lcDocumento) +
                                    " AND LINIA = " + DB.SQLString(lnLinia);
                            DB.SQLExec(lcSql, ref ldtLtregul);
                        }
                        else
                        {
                            DataRow[] rows = ldtRegulari.Select("articulo = '" + item.Field<string>("ARTICULO") + "' and talla ='" + item.Field<string>("TALLA") + "' and color = '" + item.Field<string>("COLOR") + "'");

                            if (rows.Length == 1)
                            {
                                rows[0]["UNIDADES"] = Convert.ToDecimal(rows[0]["UNIDADES"]) + item.Field<decimal>("UNIDADES");
                                rows[0]["PESO"] = Convert.ToDecimal(rows[0]["PESO"]) + item.Field<decimal>("PESO");
                            }
                        }

                        DataRow newRowLtregul = ldtLtregul.NewRow();


                        newRowLtregul["EMPRESA"] = item.Field<string>("EMPRESA");
                        newRowLtregul["ALMACEN"] = item.Field<string>("ALMACEN");
                        newRowLtregul["FECHA"] = FechaMaxima;
                        newRowLtregul["LINIA"] = lnLinia;
                        newRowLtregul["DOCUMENTO"] = lcDocumento;
                        newRowLtregul["ARTICULO"] = item.Field<string>("ARTICULO");
                        newRowLtregul["LOTE"] = item.Field<string>("LOTE");
                        newRowLtregul["UNIDADES"] = item.Field<decimal>("UNIDADES");

                        if (item.Field<DateTime?>("CADUCIDAD") != null)
                        {
                            newRowLtregul["CADUCIDAD"] = item.Field<DateTime?>("CADUCIDAD");
                        }
                        newRowLtregul["FECHA2"] = FechaMaxima;
                        newRowLtregul["PESO"] = item.Field<decimal>("PESO");
                        newRowLtregul["TALLA"] = item.Field<string>("TALLA");
                        newRowLtregul["COLOR"] = item.Field<string>("COLOR");

                        ldtLtregul.Rows.Add(newRowLtregul);

                    }

                    foreach (DataRow row in ldtRegulari.Rows)
                    {
                        ImportarStocklotesRegulari(row);
                    }

                    foreach (DataRow row in ldtLtregul.Rows)
                    {
                        ImportarStocklotesLtregul(row);
                    }

                    ImportarStocklotesRevisarRegularizacion(FechaMaxima);


                    //Una vegada acabat el proces correctament, s'han d'eliminar els inventaris de SINCRONIZACION de dies anteriors
                    foreach (DataRow item in ldtRevisar.Rows)
                    {
                        lcCondicion = " EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) + " AND ALMACEN = " + DB.SQLString(item.Field<string>("almacen"));

                        // Primer buido la taula STOCKLOTES, ja la recalcularem al final
                        lcSql = "DELETE FROM " + DB.SQLDatabase("LOTES", "STOCKLOTES") +
                                    " WHERE " + lcCondicion;
                        DB.SQLExec(lcSql);

                        // Desprem elimino les regularitzacions de dies anteriors
                        lcSql = "DELETE FROM " + DB.SQLDatabase("GESTION", "REGULARI") +
                                        " WHERE (DOCUMENTO='SINCRONIZACION' OR DOCUMENTO='STOCKSOFFLINE') " +
                                        " AND " + lcCondicion + " AND FECHA < " + DB.SQLString(FechaMaxima);
                        DB.SQLExec(lcSql);

                        lcSql = "DELETE FROM " + DB.SQLDatabase("LOTES", "LTREGUL") +
                                    " WHERE (DOCUMENTO='SINCRONIZACION' OR DOCUMENTO='STOCKSOFFLINE') " +
                                    " AND " + lcCondicion + " AND FECHA < " + DB.SQLString(FechaMaxima);
                        DB.SQLExec(lcSql);
                    }
                    break;

            }

            return true;

        }

        private static void ImportarStocklotesRevisarRegularizacion(DateTime tdFechaMaxima)
        {
            bool llTrobat = false;
            int lnLinia = 0;
                 
            string lcOldCodi = string.Empty;
            string lcOldArticulo = string.Empty;
            string lcDocumento = string.Empty;
            string _regula = string.Empty;
            string _ltregul = string.Empty;

            string lcSql = string.Empty;

            string lcFiltroArticulo = string.Empty;
            string lcFiltroLotes = string.Empty;

            DataTable ldtRegulari = new DataTable();
            DataTable ldtLtregul = new DataTable();

            // S'ha de revisar si hi ha documents del dia actual, que s'han traspasat via OFFLINE
            // he de revisar el moviments del inventari de regularització que acabo de crear
            if (_dtStockLotesOffline != null && _dtStockLotesOffline.Rows.Count > 0)
            {
                lcOldCodi = "##@@";
                lcOldArticulo = "%&/(";
                lcDocumento = "STOCKSOFFLINE";


                _dtStockLotesOffline.DefaultView.Sort = "EMPRESA, ALMACEN, ARTICULO, TALLA, COLOR";
                _dtStockLotesOffline = _dtStockLotesOffline.DefaultView.ToTable();

                foreach (DataRow item in _dtStockLotesOffline.Rows)
                {
                    //si canvia l'empresa o el magatzem, fem un inventari nou
                    if (lcOldCodi != item.Field<string>("EMPRESA") + item.Field<string>("ALMACEN"))
                    {
                        if (lcOldCodi != "##@@")
                        {
                            // Actualizar datos
                            foreach (DataRow row in ldtRegulari.Rows)
                            {
                                lcSql = " UPDATE " + DB.SQLDatabase("GESTION","REGULARI") +
                                        " SET UNIDADES = " + DB.SQLString(row.Field<decimal>("UNIDADES")) +
                                            " , PESO = " + DB.SQLString(row.Field<decimal>("PESO")) +
                                        " WHERE EMPRESA = " + DB.SQLString(row.Field<string>("EMPRESA")) +
                                            " AND ALMACEN = " + DB.SQLString(row.Field<string>("ALMACEN")) +
                                            " AND FECHA = " + DB.SQLString(tdFechaMaxima) +
                                            " AND DOCUMENTO = " + DB.SQLString(lcDocumento);

                                DB.SQLExec(lcSql);
                            }

                            // Actualizar datos
                            foreach (DataRow row in ldtLtregul.Rows)
                            {
                                lcSql = " UPDATE " + DB.SQLDatabase("LOTES", "LTREGUL") +
                                        " SET UNIDADES = " + DB.SQLString(row.Field<decimal>("UNIDADES")) +
                                            " , PESO = " + DB.SQLString(row.Field<decimal>("PESO")) +
                                        " WHERE EMPRESA = " + DB.SQLString(row.Field<string>("EMPRESA")) +
                                            " AND ALMACEN = " + DB.SQLString(row.Field<string>("ALMACEN")) +
                                            " AND FECHA = " + DB.SQLString(tdFechaMaxima) +
                                            " AND DOCUMENTO = " + DB.SQLString(lcDocumento) +
                                            " AND LINIA = " + DB.SQLString(lnLinia);

                                DB.SQLExec(lcSql);
                            }
                        }

                        lcSql = " SELECT * FROM " + DB.SQLDatabase("GESTION", "REGULARI") +
                                " WHERE EMPRESA = " + DB.SQLString(item.Field<string>("EMPRESA")) +
                                " AND ALMACEN = " + DB.SQLString(item.Field<string>("ALMACEN")) +
                                " AND FECHA = " + DB.SQLString(tdFechaMaxima) +
                                " AND DOCUMENTO = " + DB.SQLString(lcDocumento);
                        DB.SQLExec(lcSql, ref ldtRegulari);

                        lcSql = " SELECT * FROM " + DB.SQLDatabase("LOTES", "LTREGUL") +
                                " WHERE EMPRESA = " + DB.SQLString(item.Field<string>("EMPRESA")) +
                                " AND ALMACEN = " + DB.SQLString(item.Field<string>("ALMACEN")) +
                                " AND FECHA = " + DB.SQLString(tdFechaMaxima) +
                                " AND DOCUMENTO = " + DB.SQLString(lcDocumento);

                        DB.SQLExec(lcSql, ref ldtLtregul);

                        lcOldCodi = item.Field<string>("EMPRESA") + item.Field<string>("ALMACEN");
                    }


                    lcFiltroArticulo = "ARTICULO = '" + item.Field<string>("ARTICULO").Trim() + "' and TALLA = '" + item.Field<string>("TALLA").Trim() + "' and COLOR = '" + item.Field<string>("COLOR").Trim() + "'";
                    lcFiltroLotes = " and LOTE = '" + item.Field<string>("LOTE").Trim() + "'";

                    llTrobat = false;

                    DataRow[] rowstr = ldtRegulari.Select(lcFiltroArticulo);

                    if (rowstr.Length == 1)
                    {
                        rowstr[0]["UNIDADES"] = Convert.ToDecimal(rowstr[0]["UNIDADES"]) - item.Field<decimal>("UNIDADES");
                        rowstr[0]["PESO"] = Convert.ToDecimal(rowstr[0]["PESO"]) - item.Field<decimal>("PESO");

                        lnLinia = Convert.ToInt32(rowstr[0]["LINIA"]);
                        llTrobat = true;
                    }

                    if (llTrobat)
                    {
                        lcFiltroArticulo = lcFiltroArticulo + lcFiltroLotes + " AND LINIA = " + DB.SQLString(lnLinia);

                        DataRow[] rowstrLotes = ldtLtregul.Select(lcFiltroArticulo);

                        if (rowstrLotes.Length == 1)
                        {
                            rowstrLotes[0]["UNIDADES"] = Convert.ToDecimal(rowstrLotes[0]["UNIDADES"]) - item.Field<decimal>("UNIDADES");
                            rowstrLotes[0]["PESO"] = Convert.ToDecimal(rowstrLotes[0]["PESO"]) - item.Field<decimal>("PESO");

                        }
                    }
                }

                // Actualizar datos
                foreach (DataRow row in ldtRegulari.Rows)
                {
                    lcSql = " UPDATE " + DB.SQLDatabase("GESTION", "REGULARI") +
                            " SET UNIDADES = " + DB.SQLString(row.Field<decimal>("UNIDADES")) +
                                " , PESO = " + DB.SQLString(row.Field<decimal>("PESO")) +
                            " WHERE EMPRESA = " + DB.SQLString(row.Field<string>("EMPRESA")) +
                                " AND ALMACEN = " + DB.SQLString(row.Field<string>("ALMACEN")) +
                                " AND FECHA = " + DB.SQLString(tdFechaMaxima) +
                                " AND DOCUMENTO = " + DB.SQLString(lcDocumento);

                    DB.SQLExec(lcSql);
                }

                // Actualizar datos
                foreach (DataRow row in ldtLtregul.Rows)
                {
                    lcSql = " UPDATE " + DB.SQLDatabase("LOTES", "LTREGUL") +
                            " SET UNIDADES = " + DB.SQLString(row.Field<decimal>("UNIDADES")) +
                                " , PESO = " + DB.SQLString(row.Field<decimal>("PESO")) +
                            " WHERE EMPRESA = " + DB.SQLString(row.Field<string>("EMPRESA")) +
                                " AND ALMACEN = " + DB.SQLString(row.Field<string>("ALMACEN")) +
                                " AND FECHA = " + DB.SQLString(tdFechaMaxima) +
                                " AND DOCUMENTO = " + DB.SQLString(lcDocumento) +
                                " AND LOTE = " + DB.SQLString(row.Field<string>("LOTE")) +
                                " AND LINIA = " + DB.SQLString(row.Field<int>("LINIA"));

                    DB.SQLExec(lcSql);
                }
            }
        }

        private static void ImportarStocklotesRegulari(DataRow row)
        {
            string lcSql = " Insert Into " + DB.SQLDatabase("GESTION", "REGULARI") + Environment.NewLine +
                                                        " (EMPRESA, ALMACEN, DOCUMENTO, FECHA, FECHASTOCK, OBSERVACIONES, ARTICULO, UNIDADES, LINIA, PMSTOCK, PMCOM, TALLA, COLOR, PESO) " + Environment.NewLine +
                                                        " Values(" +
                                                                DB.SQLString(row.Field<string>("empresa")) + ", " +
                                                                DB.SQLString(row.Field<string>("almacen")) + ", " +
                                                                DB.SQLString(row.Field<string>("documento")) + ", " +
                                                                DB.SQLString(row.Field<DateTime>("fecha")) + ", " +
                                                                DB.SQLString(row.Field<DateTime>("fechastock")) + ", " +
                                                                DB.SQLString(row.Field<string>("observaciones")) + ", " +
                                                                DB.SQLString(row.Field<string>("articulo")) + ", " +
                                                                DB.SQLString(row.Field<decimal>("unidades")) + ", " +
                                                                DB.SQLString(row.Field<int>("linia")) + ", " +
                                                                DB.SQLString(row.Field<decimal>("pmstock")) + ", " +
                                                                DB.SQLString(row.Field<decimal>("pmcom")) + ", " +
                                                                DB.SQLString(row.Field<string>("talla")) + ", " +
                                                                DB.SQLString(row.Field<string>("color")) + ", " +
                                                                DB.SQLString(row.Field<decimal>("peso")) + ")" + Environment.NewLine;
            DB.SQLExec(lcSql);
        }

        private static void ImportarStocklotesLtregul(DataRow row)
        {
            string lcSql = " Insert Into " + DB.SQLDatabase("LOTES", "LTREGUL") + Environment.NewLine +
                                                        "(EMPRESA,ALMACEN,FECHA,LINIA,DOCUMENTO,ARTICULO,LOTE,UNIDADES,CADUCIDAD,FECHA2,PESO,TALLA,COLOR) " + Environment.NewLine +
                                                        " Values(" +
                                                                DB.SQLString(row.Field<string>("empresa")) + ", " +
                                                                DB.SQLString(row.Field<string>("almacen")) + ", " +
                                                                DB.SQLString(row.Field<DateTime>("fecha")) + ", " +
                                                                DB.SQLString(row.Field<int>("linia")) + ", " +
                                                                DB.SQLString(row.Field<string>("documento")) + ", " +
                                                                DB.SQLString(row.Field<string>("articulo")) + ", " +
                                                                DB.SQLString(row.Field<string>("lote")) + ", " +
                                                                DB.SQLString(row.Field<decimal>("unidades")) + ", " +
                                                                DB.SQLString(row.Field<DateTime?>("caducidad")) + ", " +
                                                                DB.SQLString(row.Field<DateTime>("fecha")) + ", " +
                                                                DB.SQLString(row.Field<decimal>("peso")) + ", " +
                                                                DB.SQLString(row.Field<string>("talla")) + ", " +
                                                                DB.SQLString(row.Field<string>("color")) + ")" + Environment.NewLine;
            DB.SQLExec(lcSql);
        }

        private static bool ImportarLotesDocumentos(RegistroTabRel registro)
        {
            bool llNoFerRes = false;

            string lcAlmacen = string.Empty;
            decimal lnUnidades = 0M;
            decimal lnPeso = 0M;

            string lcDbReal = clsOfflineUtils.ObtenerNombreBdReal(registro._DBPrincipal);
            string lcDbReal2 = clsOfflineUtils.ObtenerNombreBdReal(registro._DBSecundaria);

            // Primer creem la taula si no existeix
            DB.SQLExec("SELECT * FROM " + DB.SQLDatabase("LOTES", "STOCKLOTES") + " WHERE 1 = 2 ", ref _dtStockLotesOffline);

            DataTable ldtDatos = new DataTable();
            DB.SQLExec("SELECT * FROM [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo.[_Secundaria] ", ref ldtDatos);

            foreach (DataRow item in ldtDatos.Rows)
            {
                if (item.Field<DateTime>("fecha") == DateTime.Today)
                {
                    llNoFerRes = false;


                    //**********************************
                    //** Lotes de los documentos *******
                    //**********************************
                    switch (registro._TablaSecundaria)
                    {
                        case "LTALBTR":

                            // Faig el cas especial, per la part del magatzem desti
                            DataRow[] rowstr = _dtStockLotesOffline.Select("empresa = '" + item.Field<string>("EMPRESA") + "' " +
                                                                        " and articulo = '" + item.Field<string>("ARTICULO") + "' " +
                                                                        " and talla = '" + item.Field<string>("TALLA") + "' " +
                                                                        " and color = '" + item.Field<string>("COLOR") + "' " +
                                                                        " and lote = '" + item.Field<string>("LOTE") + "' " +
                                                                        " and almacen = '" + item.Field<string>("ALMDEST") + "' ");

                            if (rowstr.Length == 0)
                            {
                                DataRow newRow = _dtStockLotesOffline.NewRow();

                                newRow["EMPRESA"] = item.Field<string>("EMPRESA");
                                newRow["ALMACEN"] = item.Field<string>("almdest");
                                newRow["FECHA"] = DateTime.Today;
                                newRow["ARTICULO"] = item.Field<string>("articulo");

                                newRow["UNIDADES"] = item.Field<decimal>("unidades");
                                newRow["PESO"] = item.Field<decimal>("peso");

                                newRow["TALLA"] = item.Field<string>("TALLA");
                                newRow["COLOR"] = item.Field<string>("COLOR");

                                newRow["LOTE"] = item.Field<string>("lote");

                                if (item.Field<DateTime?>("caducidad") != null)
                                {
                                    newRow["CADUCIDAD"] = item.Field<DateTime?>("caducidad");
                                }

                            }
                            else
                            {
                                rowstr[0]["UNIDADES"] = Convert.ToDecimal(rowstr[0]["UNIDADES"]) + item.Field<decimal>("UNIDADES");
                                rowstr[0]["PESO"] = Convert.ToDecimal(rowstr[0]["PESO"]) + item.Field<decimal>("PESO");
                            }

                            lcAlmacen = item.Field<string>("ALMORIG");
                            lnUnidades = (-1) * item.Field<decimal>("UNIDADES");
                            lnPeso = (-1) * item.Field<decimal>("PESO");

                            break;


                        case "LTALBCO":
                        case "LTPEDCO":
                        case "LTCPROD":
                        case "LTDTRAN":
                        case "LTDEPCO":

                            lcAlmacen = item.Field<string>("ALMACEN");
                            lnUnidades = item.Field<decimal>("UNIDADES");
                            lnPeso = item.Field<decimal>("PESO");
                            break;


                        case "LTALBRE":
                        case "LTDEPVE":
                        case "LTALBVE":
                        case "LTPEDVE":
                        case "LTDPROD":
                        case "LTCTRAN":

                            // Els documents de sortida d'stock, resten

                            lcAlmacen = item.Field<string>("ALMACEN");
                            lnUnidades = (-1) * item.Field<decimal>("UNIDADES");
                            lnPeso = (-1) * item.Field<decimal>("PESO");

                            break;


                        case "LTREGUL":
                        case "LTSTINI":

                            // Amb els inventaris, no s'hauria de fer res
                            llNoFerRes = true;
                            lnUnidades = 0M;
                            lnPeso = 0M;
                            break;

                    }

                    if (!llNoFerRes)
                    {
                        DataRow[] rows = _dtStockLotesOffline.Select("empresa = '" + item.Field<string>("EMPRESA") + "' " +
                                                                        " and articulo = '" + item.Field<string>("ARTICULO") + "' " +
                                                                        " and talla = '" + item.Field<string>("TALLA") + "' " +
                                                                        " and color = '" + item.Field<string>("COLOR") + "' " +
                                                                        " and lote = '" + item.Field<string>("LOTE") + "' " +
                                                                        " and almacen = '" + lcAlmacen + "' ");

                        if (rows.Length == 0)
                        {
                            DataRow newRow = _dtStockLotesOffline.NewRow();

                            newRow["EMPRESA"] = item.Field<string>("EMPRESA");
                            newRow["ALMACEN"] = lcAlmacen;
                            newRow["FECHA"] = DateTime.Today;
                            newRow["ARTICULO"] = item.Field<string>("articulo");

                            newRow["UNIDADES"] = lnUnidades;
                            newRow["PESO"] = lnPeso;

                            newRow["TALLA"] = item.Field<string>("TALLA");
                            newRow["COLOR"] = item.Field<string>("COLOR");

                            newRow["LOTE"] = item.Field<string>("lote");

                            if (item.Field<DateTime?>("caducidad") != null)
                            {
                                newRow["CADUCIDAD"] = item.Field<DateTime?>("caducidad");
                            }

                            _dtStockLotesOffline.Rows.Add(newRow);
                        }
                        else
                        {
                            rows[0]["UNIDADES"] = Convert.ToDecimal(rows[0]["UNIDADES"]) + lnUnidades;
                            rows[0]["PESO"] = Convert.ToDecimal(rows[0]["PESO"]) + lnPeso;
                        }
                    }
                }
            }

            return true;
        }


        private static bool TratamientoEspecialRecepcion(OfflineDatosComunicaciones datos, ref RegistroTabRel registro, ILog_comoffRepository logRepository)
        {
            bool llRetorn = false;

            // Genero les taules temporals per poder fer els DELETEs/ INSERTs
            if (!string.IsNullOrWhiteSpace(registro._DBPrincipal))
            {
                llRetorn = CrearTablaTemporal(registro._DBPrincipal, registro._TablaPrincipal, registro._Sufijo, registro._Empresa, true);

                if (!llRetorn)
                {
                    Log_comoffDto logDto = logRepository.GetDto(datos);
                    logDto.TipoDato = clsOfflineUtils.ObtenerTipoDato(registro._Clave);
                    logDto.Resultado = 3;
                    logDto.Detalle = "No existe la tabla " + registro._DBPrincipal + "!" + registro._TablaPrincipal + " en el fichero recibido.";
                    logRepository.Insert(logDto);

                    registro._DBPrincipal = "";
                    registro._TablaPrincipal = "";


                }
            }

            // Genero les taules temporals per poder fer els DELETEs/ INSERTs
            if (!string.IsNullOrWhiteSpace(registro._DBSecundaria))
            {
                llRetorn = CrearTablaTemporal(registro._DBSecundaria, registro._TablaSecundaria, registro._Sufijo, registro._EmpresaSecundaria, false);

                if (!llRetorn)
                {
                    Log_comoffDto logDto = logRepository.GetDto(datos);
                    logDto.TipoDato = clsOfflineUtils.ObtenerTipoDato(registro._Clave);
                    logDto.Resultado = 3;
                    logDto.Detalle = "No existe la tabla " + registro._DBSecundaria + "!" + registro._TablaSecundaria + " en el fichero recibido.";
                    logRepository.Insert(logDto);

                    registro._DBSecundaria = "";
                    registro._TablaSecundaria = "";
                }
            }

            //** tot això no ho tinc molt clar, de moment
            switch (registro._TablaPrincipal)
            {
                case "ENTIDAD":

                    // No importar carta pagaré
                    llRetorn = ImportarEntidad(registro);
                    
                    break;

                case "CAJAS":

                    // No importar configuració d'impressores, displays, etc...
                    llRetorn = ImportarCajas(registro);
                    
                    break;

                case "ACCESOS":

                    if (!datos._IsCentral)
                    {
                        // Eliminar tots els accesos i tornar - los a carregar
                        llRetorn = ImportarAccesos(registro);
                    }
                    break;

                case "CONFTICK":

                    // No importar los contadores del TPV, si no se importan los contadores generales
                    //llRetorn = ImportarConfTick(registro);
                    break;

                case "C_ALBVEN":
                case "C_ALBCOM":

                    // Separar los albaranes de las facturas
                    llRetorn = ImportarAlbaranesFacturas(registro);
                    break;

                default:
                    llRetorn = true;
                    break;
            }


            switch (registro._TablaSecundaria)
            {
                case "STOCKLOTES":

                    if (!datos._IsCentral)
                    {
                        llRetorn = ImportarStocklotes(registro);
                    }
                    break;

                case "LTALBRE":
                case "LTALBTR":
                case "LTALBCO":
                case "LTDEPVE":
                case "LTALBVE":
                case "LTPEDCO":
                case "LTPEDVE":
                case "LTREGUL":
                case "LTSTINI":
                case "LTCPROD":
                case "LTDPROD":
                case "LTCTRAN":
                case "LTDTRAN":
                case "LTDEPCO":

                    if (!datos._IsCentral)
                    {
                        llRetorn = ImportarLotesDocumentos(registro);
                    }
                    break;

                case "FCFACTUVEN":
                case "FCTICKETS":
                    //        llRetorn = this.recibir_xml_facturacion_certificada(tcSucursal, lcTbSecun)
                    break;

                case "UNIUSERS":

                    llRetorn = ImportarUniUsers(registro);
                    break;

                case "ACCESOGRUP":

                    llRetorn = ImportarAccesoGrup(registro);
                    break;


                default:

                    llRetorn = true;
                    break;
            }

            return llRetorn;
        }

        

        private static bool ActualizarDatosRecepcion(OfflineDatosComunicaciones datos, RegistroTabRel registro, ILog_comoffRepository logRepository, bool tlAuxiliar = false)
        {
            string lcIndice = string.Empty;
            string lcTaulaTemp = string.Empty;
            string lcTaulaIns = string.Empty;
            string lcTaulaLocal = string.Empty;
            string lcTaulaLocalAux = string.Empty;
            string lcIndiceAux = string.Empty;
            string lcCadenaCamps = string.Empty;
            string lcCadenaOutput = string.Empty;

            string lcSetCampos = string.Empty;

            string lcSql = string.Empty;
            string lcdbReal = string.Empty;
            string lcCondicion = string.Empty;
            string lcCondicionAux = string.Empty;

            string lcDb = string.Empty;
            string lcTaula = string.Empty;
            string lcDbAux = string.Empty;
            string lcTaulaAux = string.Empty;

            bool llOk = false;

            //si som secundaria, s'han de tractar els registres coincidents de la inserció
            //Index de la taula on es s'ha de fer el lligam
            if (tlAuxiliar)
            {
                lcDb = registro._DBSecundaria;
                lcTaula = registro._TablaSecundaria + registro._Sufijo;
                lcTaulaLocal = registro._TablaSecundaria;

                //Index de la taula a tractar
                lcCadenaCamps = ObtenerCamposSelect(lcDb, lcTaula);
                lcCadenaOutput = ObtenerCamposSelect(lcDb, lcTaula, "b.", true);
                lcSetCampos = ObtenerCamposSet(lcDb, lcTaula);
                lcIndice = ObtenerCamposIndices(lcDb, lcTaulaLocal);

                lcTaulaTemp = "_Secundaria";
                lcTaulaIns = "_InsertSecun";

                if (string.IsNullOrWhiteSpace(registro._DBPrincipal))
                {
                    switch (registro._TablaSecundaria)
                    {
                        case "ASIENTOS":

                            // Si es la tabla ASIENTOS, no hacemos nada.
                            return true;

                        case "CTRL_PARCO":

                            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                            lcSql = " SELECT empresa, numero, linia, ejercicio, MAX(origen) AS ORIGEN, MAX(guid_id) AS GUID_ID, MAX(idtabrel) AS IDTABREL, MAX(created) AS CREATED, MAX(modified) AS MODIFIED " +
                                    " into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                    " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                    " GROUP BY empresa, numero, linia, ejercicio ";
                            DB.SQLExec(lcSql);

                            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                            lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                    " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                            DB.SQLExec(lcSql);

                            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
                            break;

                        default:

                            break;
                    }
                }
                else
                {
                    lcDbAux = registro._DBPrincipal;
                    lcTaulaAux = registro._TablaPrincipal + registro._Sufijo;
                    lcTaulaLocalAux = registro._TablaPrincipal;

                    lcIndiceAux = ObtenerInnerOn(lcDbAux, lcDb, lcTaulaLocalAux, lcTaulaLocal, registro._Relacion, registro._Clave, datos, logRepository);

                    if (string.IsNullOrWhiteSpace(lcIndiceAux))
                    {
                        lcIndiceAux = ObtenerCamposIndices(lcDb, lcTaulaLocalAux);
                    }

                    if (!registro._Sobreescribir)
                    {
                        if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDbAux + "].dbo.[_InsertPrin]"))
                        {
                            // la condicion només l'aplicarem sobre el primer camp
                            lcCondicionAux = lcIndiceAux.Trim();
                            lcCondicionAux = lcCondicionAux.Substring(0, lcCondicionAux.IndexOf('='));

                            switch (registro._TablaSecundaria)
                            {
                                case "D_PEDIVE":

                                    TratamientoEspecial_PedidosVenta(lcDb, registro._Sobreescribir);

                                    break;

                                case "D_PEDICO":

                                    TratamientoEspecial_PedidosCompra(lcDb, registro._Sobreescribir);

                                    break;

                                case "D_ALBDEP":

                                    TratamientoEspecial_PedidosVenta(lcDb, registro._Sobreescribir);
                                    TratamientoEspecial_DepositosVenta(lcDb, registro._Sobreescribir);

                                    break;

                                case "D_DEPCOM":

                                    TratamientoEspecial_PedidosCompra(lcDb, registro._Sobreescribir);
                                    TratamientoEspecial_DepositosCompra(lcDb, registro._Sobreescribir);

                                    break;

                                case "D_ALBVEN":

                                    TratamientoEspecial_PedidosVenta(lcDb, registro._Sobreescribir);
                                    TratamientoEspecial_DepositosVenta(lcDb, registro._Sobreescribir);
                                    TratamientoEspecial_AlbaranesVenta(lcDb, registro._Sobreescribir);

                                    if (registro._Clave == "FACTURAS")
                                    {
                                        TratamientoEspecial_FacturasVenta(lcDb, registro._Sobreescribir);
                                    }

                                    break;

                                case "D_ALBCOM":

                                    TratamientoEspecial_PedidosCompra(lcDb, registro._Sobreescribir);
                                    TratamientoEspecial_DepositosCompra(lcDb, registro._Sobreescribir);
                                    TratamientoEspecial_AlbaranesCompra(lcDb, registro._Sobreescribir);

                                    if (registro._Clave == "FACTURAC")
                                    {
                                        TratamientoEspecial_FacturasCompra(lcDb, registro._Sobreescribir);
                                    }

                                    break;


                                case "ASIENTOS":

                                    string lcCampoAsi = "ASI";

                                    switch (registro._ID)
                                    {
                                        case 285:

                                            lcCampoAsi = "ASI_TRANS";
                                            break;

                                        case 286:

                                            lcCampoAsi = "ASI_DUA";
                                            break;
                                    }

                                    if (registro._Clave == "FACTURAS" || registro._Clave == "FACTURAC")
                                    {
                                        lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDbAux);
                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                        lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                                " INNER JOIN ( " +
                                                    " SELECT b.empresa, b.numero " +
                                                    " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                                    " INNER JOIN [" + lcdbReal + "].dbo.[" + lcTaulaLocalAux + "] a ON A.EMPRESA = B.EMPRESA And A.ASI = B.ASI " +
                                                " ) b " +
                                                " ON A.EMPRESA = B.EMPRESA AND A.numero = B.numero ";

                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                                        lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
                                    }
                                    else
                                    {
                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                        lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                                " INNER JOIN ( " +
                                                    " SELECT DISTINCT b.empresa, b.numero " +
                                                    " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                                    " INNER JOIN [" + _cRaizDataBaseTemporal + lcDbAux + "].dbo.[_InsertPrin] a ON A.EMPRESA = B.EMPRESA And A." + lcCampoAsi + " = B.ASI  ) b " +
                                                " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                                        lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
                                    }

                                    ImportarAsientos(datos, registro, logRepository);

                                    break;

                                case "ENTREGAS":
                                
                                    if (registro._Clave == "FACTURAS" || registro._Clave == "FACTURAC")
                                    {
                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                        lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                                " INNER JOIN ( " +
                                                    " SELECT b.empresa, b.albaran, b.letra " +
                                                    " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                                    " INNER JOIN [" + _cRaizDataBaseTemporal + lcDbAux + "].dbo.[_InsertPrin] a ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.ALBARAN " + (registro._Clave == "FACTURAS" ? " AND A.LETRA = B.LETRA " : "") + " ) b " +
                                                " ON A.EMPRESA = B.EMPRESA AND A.ALBARAN = B.ALBARAN " + (registro._Clave == "FACTURAS" ? " AND A.LETRA = B.LETRA " : "");

                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                                        lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
                                    }
                                    else
                                    {
                                        lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDbAux);
                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                        lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                                " INNER JOIN ( " +
                                                    " SELECT b.empresa, b.albaran, b.letra " +
                                                    " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                                    " INNER JOIN [" + lcdbReal + "].dbo.[" + lcTaulaLocalAux + "] a ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.ALBARAN AND A.LETRA = B.LETRA " +
                                                " ) b " +
                                                " ON A.EMPRESA = B.EMPRESA AND A.ALBARAN = B.ALBARAN AND A.LETRA = B.LETRA ";

                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                                        lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
                                    }

                                    break;

                                case "ENTRE_PR":
                                case "ENTRE_PV":

                                    lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDbAux);
                                    DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                    lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                            " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                            " INNER JOIN ( " +
                                                " SELECT b.empresa, b.numero, b.letra " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                                " INNER JOIN [" + lcdbReal + "].dbo.[" + lcTaulaLocalAux + "] a ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO AND A.LETRA = B.LETRA " +
                                            " ) b " +
                                            " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.LETRA ";

                                    DB.SQLExec(lcSql);

                                    DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                                    lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                            " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                                    DB.SQLExec(lcSql);

                                    DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                    break;

                                default:

                                    if (registro._Clave == "FACTURAS" || registro._Clave == "FACTURAC")
                                    {
                                        lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDbAux);
                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                        lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                                " INNER JOIN ( " +
                                                    " SELECT b.* " +
                                                    " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                                    " INNER JOIN [" + lcdbReal + "].dbo.[" + lcTaulaLocalAux + "] a ON " + lcIndiceAux +
                                                " ) b " +
                                                " ON " + lcIndice;

                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                                        lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                                        DB.SQLExec(lcSql);

                                        DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
                                    }
                                    else
                                    {
                                        lcSql = " DELETE FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                            " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                            " LEFT JOIN [" + _cRaizDataBaseTemporal + lcDbAux + "].dbo.[_InsertPrin] a " +
                                            " ON " + lcIndiceAux +
                                            " WHERE " + lcCondicionAux + " is null ";

                                        DB.SQLExec(lcSql);
                                    }

                                    break;
                            }
                        }
                    }
                    else
                    {
                        switch (registro._TablaSecundaria)
                        {
                            case "D_PEDIVE":

                                TratamientoEspecial_PedidosVenta(lcDb, registro._Sobreescribir);

                                break;

                            case "D_PEDICO":

                                TratamientoEspecial_PedidosCompra(lcDb, registro._Sobreescribir);

                                break;

                            case "D_ALBDEP":

                                TratamientoEspecial_PedidosVenta(lcDb, registro._Sobreescribir);
                                TratamientoEspecial_DepositosVenta(lcDb, registro._Sobreescribir);

                                break;

                            case "D_DEPCOM":

                                TratamientoEspecial_PedidosCompra(lcDb, registro._Sobreescribir);
                                TratamientoEspecial_DepositosCompra(lcDb, registro._Sobreescribir);

                                break;

                            case "D_ALBVEN":

                                TratamientoEspecial_PedidosVenta(lcDb, registro._Sobreescribir);
                                TratamientoEspecial_DepositosVenta(lcDb, registro._Sobreescribir);
                                TratamientoEspecial_AlbaranesVenta(lcDb, registro._Sobreescribir);

                                if (registro._Clave == "FACTURAS")
                                {
                                    TratamientoEspecial_FacturasVenta(lcDb, registro._Sobreescribir);
                                }

                                break;

                            case "D_ALBCOM":

                                TratamientoEspecial_PedidosCompra(lcDb, registro._Sobreescribir);
                                TratamientoEspecial_DepositosCompra(lcDb, registro._Sobreescribir);
                                TratamientoEspecial_AlbaranesCompra(lcDb, registro._Sobreescribir);

                                if (registro._Clave == "FACTURAC")
                                {
                                    TratamientoEspecial_FacturasCompra(lcDb, registro._Sobreescribir);
                                }

                                break;

                            

                            case "ASIENTOS":


                                string lcCampoAsi = "ASI";

                                switch (registro._ID)
                                {
                                    case 285:

                                        lcCampoAsi = "ASI_TRANS";
                                        break;

                                    case 286:

                                        lcCampoAsi = "ASI_DUA";
                                        break;
                                }

                                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        " INNER JOIN ( " +
                                            " SELECT DISTINCT b.empresa, b.numero " +
                                            " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                            " INNER JOIN [" + _cRaizDataBaseTemporal + lcDbAux + "].dbo.[_Principal] a ON A.EMPRESA = B.EMPRESA And A." + lcCampoAsi + " = B.ASI  ) b " +
                                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                                DB.SQLExec(lcSql);

                                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                                lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                                DB.SQLExec(lcSql);

                                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                ImportarAsientos(datos, registro, logRepository);

                                break;

                            case "ENTREGAS":

                                if (registro._Clave == "FACTURAS" || registro._Clave == "FACTURAC")
                                {

                                    DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                                    lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                                            " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                            " INNER JOIN ( " +
                                                " SELECT b.empresa, b.albaran, b.letra " +
                                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] b " +
                                                " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Principal] a ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.ALBARAN " + (registro._Clave == "FACTURAS" ? " AND A.LETRA = B.LETRA " : "") + " ) b " +
                                            " ON A.EMPRESA = B.EMPRESA AND A.ALBARAN = B.ALBARAN " + (registro._Clave == "FACTURAS" ? " AND A.LETRA = B.LETRA " : "");

                                    DB.SQLExec(lcSql);

                                    DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria]");

                                    lcSql = " SELECT * INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] " +
                                            " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] ";
                                    DB.SQLExec(lcSql);

                                    DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
                                }
                                break;

                        }
                    }
                }
            }
            else
            {
                lcDb = registro._DBPrincipal;
                lcTaula = registro._TablaPrincipal + registro._Sufijo;
                lcTaulaLocal = registro._TablaPrincipal;

                //Index de la taula a tractar
                lcCadenaCamps = ObtenerCamposSelect(lcDb, lcTaula);
                lcCadenaOutput = ObtenerCamposSelect(lcDb, lcTaula, "b.", true);
                lcSetCampos = ObtenerCamposSet(lcDb, lcTaula);
                lcIndice = ObtenerCamposIndices(lcDb, lcTaulaLocal);

                lcTaulaTemp = "_Principal";
                lcTaulaIns = "_InsertPrin";
            }

            _TextStepDetalle = "Recibiendo datos tabla " + lcDb + "!" + lcTaulaLocal;
            _TextStepProgreso = _TextStepDetalle;
            _PorcenProgreso = IncrementarBarraProgreso();

            //** Busquem el nom de la base de dades real i el propietari
            lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDb);

            
            ActualizarDatosRecepcionEspecial(datos, registro, lcTaulaTemp, lcTaulaLocal, lcDb, lcTaula, logRepository);

            if (registro._TablaSecundaria == "CTRL_ASIEN" && clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_ControlAsientos]"))
            {
                lcTaulaTemp = "_ControlAsientos";
            }

            if (registro._Sobreescribir)
            {
                DataTable ldtUpdate = new DataTable();

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[" + lcTaulaLocal + "] " +
                        " SET " + lcSetCampos +
                        " OUTPUT " + lcCadenaOutput +
                        " FROM  [" + lcdbReal + "].dbo.[" + lcTaulaLocal + "] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaTemp + "] b " +
                        " ON " + lcIndice;

                DB.SQLExec(lcSql, ref ldtUpdate);

                if (ldtUpdate != null && ldtUpdate.Rows.Count > 0)
                {
                    RegistroDatosRecepcion(datos, registro, ldtUpdate, lcTaulaLocal, lcDb, false, logRepository);

                    llOk = true;

                    conDatosStock = conDatosStock || clsOfflineUtils.EsTipoDatoDocumento(registro._Clave);

                    if (tlAuxiliar)
                    {
                        TratamientoEspecialTablas(datos, registro, ldtUpdate, logRepository);
                    }
                }
            }

            // S'ha tenir en compte si NO tenim prioritat, ja que només s'han d'insertar el registres que no hi són
            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaIns + "]");

            // la condicion només l'aplicarem sobre el primer camp
            lcCondicion = lcIndice.Trim();
            lcCondicion = lcCondicion.Substring(0, lcCondicion.IndexOf('='));


            // farem el FULL JOIN, per trobar els nous registres
            lcSql = "SELECT b.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaIns + "] " +
                        " FROM [" + lcdbReal + "].dbo.[" + lcTaulaLocal + "] a " +
                        " RIGHT JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaTemp + "] b " +
                        " ON " + lcIndice +
                        " WHERE " + lcCondicion + " is null ";
            DB.SQLExec(lcSql);


            // he de comprovar, que els registres estiguin dins de la cursor de dades Auxiliar

            if (tlAuxiliar && !string.IsNullOrWhiteSpace(lcDbAux))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Control]");


                // la condicion només l'aplicarem sobre el primer camp
                lcCondicionAux = lcIndiceAux.Trim();
                lcCondicionAux = lcCondicionAux.Substring(0, lcCondicionAux.IndexOf('='));


                //  Faig dos casos especials pels arquejos, més endavant s'haurà de repensar una mica
                switch (lcTaulaLocal)
                {
                    case "ASIENTOS":

                        string lcCampoAsi = "ASI";

                        switch (registro._ID)
                        {
                            case 285:

                                lcCampoAsi = "ASI_TRANS";
                                break;

                            case 286:

                                lcCampoAsi = "ASI_DUA";
                                break;
                        }

                        lcSql = " SELECT c.* INTO [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Control] " +
                                            " From [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaIns + "] as c " +
                                            " inner join ( " +
                                                        " Select A.* " +
                                                        " From [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaIns + "] as A " +
                                                        " Where Exists ( " +
                                                                        " Select B.* " +
                                                                        " From [" + _cRaizDataBaseTemporal + lcDbAux + "].dbo.[_Principal] as B " +
                                                                        " Where A.EMPRESA = B.EMPRESA And A.ASI = B." + lcCampoAsi + " ) " +
                                                        " ) d ON c.EMPRESA = d.EMPRESA AND c.NUMERO = d.NUMERO ";

                        break;

                    default:

                        lcSql = string.Empty;
                        break;
                }

                if (!string.IsNullOrWhiteSpace(lcSql))
                {
                    DB.SQLExec(lcSql);

                    lcTaulaIns = "_Control";
                }
            }

            //    ******************************************************************************************************************************************

            // farem el insert
            DataTable ldtInsert = new DataTable();
            lcSql = "SELECT " + lcCadenaCamps + " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaIns + "] ";
            DB.SQLExec(lcSql, ref ldtInsert);

            if (ldtInsert != null && ldtInsert.Rows.Count > 0)
            {
                lcSql = "INSERT INTO [" + lcdbReal + "].dbo.[" + lcTaulaLocal + "] (" + lcCadenaCamps + ") " +
                        "SELECT " + lcCadenaCamps + " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaIns + "] ";
                DB.SQLExec(lcSql);

                RegistroDatosRecepcion(datos, registro, ldtInsert, lcTaulaLocal, lcDb, true, logRepository);

                llOk = true;

                conDatosStock = conDatosStock || clsOfflineUtils.EsTipoDatoDocumento(registro._Clave);

                if (tlAuxiliar)
                {
                    TratamientoEspecialTablas(datos, registro, ldtInsert, logRepository);
                }
            }


            // Eliminem la taula de la base de dades, en cas que sigui la principal
            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertSecun]");
            DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Control]");

            return llOk;
        }

        private static void TratamientoEspecial_PedidosVenta(string lcDb, bool tlSobreescribir)
        {
            //** Busquem el nom de la base de dades real i el propietari
            string lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDb);
            string lcSql = string.Empty;

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PRESUV_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PRESUV_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, SUBSTRING(a.DOC_NUM, 1, 10) as numero, SUBSTRING(a.doc_num, 11, 2) as letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.LETRA = B.LETRA " : "") +
                                        " WHERE a.DOC = 3) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_PRESUV] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_PRESUV_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_PRESUV] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PRESUV_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PRESUV_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, SUBSTRING(a.DOC_NUM, 1, 10) as numero, SUBSTRING(a.doc_num, 11, 2) as letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.LETRA = B.LETRA " : "") +
                                        " WHERE a.DOC = 3) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[D_PRESUV] " +
                        " SET " + ObtenerCamposSet(lcDb, "D_PRESUV_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[D_PRESUV] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra AND A.LINIA = B.LINIA ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }
        }

        private static void TratamientoEspecial_PedidosCompra(string lcDb, bool tlSobreescribir)
        {
            // No hay nada que hacer

        }

        private static void TratamientoEspecial_DepositosVenta(string lcDb, bool tlSobreescribir)
        {
            //** Busquem el nom de la base de dades real i el propietari
            string lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDb);
            string lcSql = string.Empty;

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PEDIVE_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PEDIVE_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, SUBSTRING(a.DOC_NUM, 1, 10) as numero, SUBSTRING(a.doc_num, 11, 2) as letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.LETRA = B.LETRA " : "") +
                                        " WHERE a.DOC = 1) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_PEDIVE] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_PEDIVE_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_PEDIVE] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PEDIVE_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PEDIVE_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, SUBSTRING(a.DOC_NUM, 1, 10) as numero, SUBSTRING(a.doc_num, 11, 2) as letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.LETRA = B.LETRA " : "") +
                                        " WHERE a.DOC = 1) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[D_PEDIVE] " +
                        " SET " + ObtenerCamposSet(lcDb, "D_PEDIVE_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[D_PEDIVE] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra AND A.LINIA = B.LINIA ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_ALBDEP_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_ALBDEP_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, SUBSTRING(a.DOC_NUM, 1, 10) as numero, SUBSTRING(a.doc_num, 11, 2) as letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.LETRA = B.LETRA " : "") +
                                        " WHERE a.DOC = 2) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_ALBDEP] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_ALBDEP_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_ALBDEP] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_ALBDEP_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_ALBDEP_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, SUBSTRING(a.DOC_NUM, 1, 10) as numero, SUBSTRING(a.doc_num, 11, 2) as letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.LETRA = B.LETRA " : "") +
                                        " WHERE a.DOC = 2) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[D_ALBDEP] " +
                        " SET " + ObtenerCamposSet(lcDb, "D_ALBDEP_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[D_ALBDEP] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra AND A.LINIA = B.LINIA ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }
        }

        private static void TratamientoEspecial_DepositosCompra(string lcDb, bool tlSobreescribir)
        {
            //** Busquem el nom de la base de dades real i el propietari
            string lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDb);
            string lcSql = string.Empty;

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PEDICO_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PEDICO_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, a.DOC_NUM as numero " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO AND A.PROVEEDOR = B.PROVEEDOR " : "") +
                                        " WHERE a.DOC = 1) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_PEDICO] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_PEDICO_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_PEDICO] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PEDICO_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PEDICO_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, a.DOC_NUM as numero " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.PROVEEDOR = B.PROVEEDOR " : "") +
                                        " WHERE a.DOC = 1) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[D_PEDICO] " +
                        " SET " + ObtenerCamposSet(lcDb, "D_PEDICO_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[D_PEDICO] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LINIA = B.LINIA ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_DEPCOM_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_DEPCOM_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, a.DOC_NUM as numero " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO AND A.PROVEEDOR = B.PROVEEDOR " : "") +
                                        " WHERE a.DOC = 3) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_DEPCOM] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_DEPCOM_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_DEPCOM] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_DEPCOM_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_DEPCOM_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, a.DOC_NUM as numero " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.PROVEEDOR = B.PROVEEDOR " : "") +
                                        " WHERE a.DOC = 3) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[D_DEPCOM] " +
                        " SET " + ObtenerCamposSet(lcDb, "D_DEPCOM_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[D_DEPCOM] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LINIA = B.LINIA ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }
        }

        private static void TratamientoEspecial_AlbaranesVenta(string lcDb, bool tlSobreescribir)
        {
            //** Busquem el nom de la base de dades real i el propietari
            string lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDb);
            string lcSql = string.Empty;

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PEDIVE_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PEDIVE_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, SUBSTRING(a.DOC_NUM, 1, 10) as numero, SUBSTRING(a.doc_num, 11, 2) as letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.LETRA = B.LETRA " : "") +
                                        " WHERE a.DOC = 1) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_PEDIVE] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_PEDIVE_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_PEDIVE] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PEDIVE_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PEDIVE_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, SUBSTRING(a.DOC_NUM, 1, 10) as numero, SUBSTRING(a.doc_num, 11, 2) as letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.LETRA = B.LETRA " : "") +
                                        " WHERE a.DOC = 1) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[D_PEDIVE] " +
                        " SET " + ObtenerCamposSet(lcDb, "D_PEDIVE_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[D_PEDIVE] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra AND A.LINIA = B.LINIA ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }
        }

        private static void TratamientoEspecial_AlbaranesCompra(string lcDb, bool tlSobreescribir)
        {
            //** Busquem el nom de la base de dades real i el propietari
            string lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDb);
            string lcSql = string.Empty;

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PEDICO_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_PEDICO_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, a.DOC_NUM as numero " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO AND A.PROVEEDOR = B.PROVEEDOR " : "") +
                                        " WHERE a.DOC = 1) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_PEDICO] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_PEDICO_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_PEDICO] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PEDICO_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.D_PEDICO_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, a.DOC_NUM as numero " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        (!tlSobreescribir ? " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_InsertPrin] b ON A.EMPRESA = B.EMPRESA And A.NUMERO = B.NUMERO And A.PROVEEDOR = B.PROVEEDOR " : "") +
                                        " WHERE a.DOC = 1) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[D_PEDICO] " +
                        " SET " + ObtenerCamposSet(lcDb, "D_PEDICO_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[D_PEDICO] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LINIA = B.LINIA ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }
        }

        private static void TratamientoEspecial_FacturasVenta(string lcDb, bool tlSobreescribir)
        {
            //** Busquem el nom de la base de dades real i el propietari
            string lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDb);
            string lcSql = string.Empty;

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_ALBVEN_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_ALBVEN_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, a.numero, a.letra " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        " ) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.LETRA ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_ALBVEN] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_ALBVEN_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_ALBVEN] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.LETRA = B.letra ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }
        }

        private static void TratamientoEspecial_FacturasCompra(string lcDb, bool tlSobreescribir)
        {
            //** Busquem el nom de la base de dades real i el propietari
            string lcdbReal = clsOfflineUtils.ObtenerNombreBdReal(lcDb);
            string lcSql = string.Empty;

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_ALBCOM_ESPECIAL"))
            {
                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] " +
                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.C_ALBCOM_ESPECIAL a " +
                        " INNER JOIN ( " +
                                        " SELECT DISTINCT a.empresa, a.numero, a.proveedor " +
                                        " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Secundaria] a " +
                                        " ) b ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.PROVEEDOR = B.PROVEEDOR ";

                DB.SQLExec(lcSql);

                lcSql = " UPDATE [" + lcdbReal + "].dbo.[C_ALBCOM] " +
                        " SET " + ObtenerCamposSet(lcDb, "C_ALBCOM_ESPECIAL") +
                        " FROM  [" + lcdbReal + "].dbo.[C_ALBCOM] a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial] b " +
                        " ON A.EMPRESA = B.EMPRESA AND A.NUMERO = B.NUMERO AND A.PROVEEDOR = B.PROVEEDOR ";

                DB.SQLExec(lcSql);

                DB.SQLExec("DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[_Especial]");
            }
        }

        private static void TratamientoEspecial_Compras(RegistroTabRel registro)
        {
            string lcSql = string.Empty;
            DataTable table = new DataTable();

            if (clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + "COMUNES].dbo.COMPRAS" + registro._Sufijo))
            {
                lcSql = " SELECT DISTINCT " + registro._Compras + " AS Serie FROM [" + _cRaizDataBaseTemporal + "COMUNES].dbo.COMPRAS" + registro._Sufijo;
                DB.SQLExec(lcSql, ref table);

                if (table.Rows.Count > 0)
                {
                    // Index de la taula a tractar
                    string lcCadenaCamps = ObtenerCamposSelect("COMUNES", "COMPRAS" + registro._Sufijo);
                    string lcSetCampos = ObtenerCamposSet("COMUNES", "COMPRAS" + registro._Sufijo);
                    string lcIndice = ObtenerCamposIndices("COMUNES", "COMPRAS");

                    if (registro._Sobreescribir)
                    {
                        lcSql = " UPDATE [" + clsOfflineUtils.ObtenerNombreBdReal("COMUNES") + "].dbo.[" + "COMPRAS" + "] " +
                                    " SET " + lcSetCampos +
                                    " FROM  [" + clsOfflineUtils.ObtenerNombreBdReal("COMUNES") + "].dbo.[" + "COMPRAS" + "] a " +
                                    " INNER JOIN [" + _cRaizDataBaseTemporal + "COMUNES" + "].dbo.[" + "COMPRAS" + registro._Sufijo + "] b " +
                                    " ON " + lcIndice;
                        DB.SQLExec(lcSql);
                    }

                    lcSql = "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "COMUNES" + "].dbo.[_Especial] ";
                    DB.SQLExec(lcSql);

                    // la condicion només l'aplicarem sobre el primer camp
                    string lcCondicion = lcIndice.Trim();
                    lcCondicion = lcCondicion.Substring(0, lcCondicion.IndexOf('='));

                    // farem el FULL JOIN, per trobar els nous registres
                    lcSql = "SELECT b.* into [" + _cRaizDataBaseTemporal + "COMUNES" + "].dbo.[_Especial] " +
                                " FROM [" + clsOfflineUtils.ObtenerNombreBdReal("COMUNES") + "].dbo.[" + "COMPRAS" + "] a " +
                                " RIGHT JOIN [" + _cRaizDataBaseTemporal + "COMUNES" + "].dbo.[" + "COMPRAS" + registro._Sufijo + "] b " +
                                " ON " + lcIndice +
                                " WHERE " + lcCondicion + " is null ";
                    DB.SQLExec(lcSql);


                    // farem el insert
                    lcSql = "INSERT INTO [" + clsOfflineUtils.ObtenerNombreBdReal("COMUNES") + "].dbo.[" + "COMPRAS" + "] (" + lcCadenaCamps + ") " +
                            "SELECT " + lcCadenaCamps + " FROM [" + _cRaizDataBaseTemporal + "COMUNES" + "].dbo.[_Especial] ";
                    DB.SQLExec(lcSql);

                    lcSql = "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "COMUNES" + "].dbo.[_Especial] ";
                    DB.SQLExec(lcSql);
                }
            }
        }

        private static void TratamientoEspecial_CriterioCaja(OfflineDatosComunicaciones datos, RegistroTabRel registro, string lcCampo, ILog_comoffRepository logRepository)
        {
            string lcSql = string.Empty;
            DataTable table = new DataTable();

            lcSql = " SELECT empresa, " + lcCampo + " AS asi FROM [" + _cRaizDataBaseTemporal + registro._DBSecundaria + "].dbo." + registro._TablaSecundaria + registro._Sufijo;
            DB.SQLExec(lcSql, ref table);

            if (table.Rows.Count > 0)
            {
                TratamientoEspecial_Asientos(datos, registro, table, logRepository);
            }
        }

        private static void TratamientoEspecialTablas(OfflineDatosComunicaciones datos, RegistroTabRel registro, DataTable ldtData, ILog_comoffRepository logRepository)
        {
            switch (registro._TablaSecundaria)
            {
                case "ASIENTOS":

                    // buscar ASI en las tablas relacionadas
                    if (!string.IsNullOrWhiteSpace(registro._Otrasien))
                    {
                        TratamientoEspecial_ASI(registro, "OTRASIEN", registro._Otrasien, ldtData);
                    }

                    if (!string.IsNullOrWhiteSpace(registro._Ivareper))
                    {
                        TratamientoEspecial_ASI(registro, "IVAREPER", registro._Ivareper, ldtData);
                    }

                    if (!string.IsNullOrWhiteSpace(registro._Ivasopor))
                    {
                        TratamientoEspecial_ASI(registro, "IVASOPOR", registro._Ivasopor, ldtData);
                    }

                    if (!string.IsNullOrWhiteSpace(registro._Iva_exen))
                    {
                        TratamientoEspecial_ASI(registro, "IVA_EXEN", registro._Iva_exen, ldtData);
                    }

                    if (!string.IsNullOrWhiteSpace(registro._Retreper))
                    {
                        TratamientoEspecial_ASI(registro, "RETREPER", registro._Retreper, ldtData);
                    }

                    if (!string.IsNullOrWhiteSpace(registro._Retsopor))
                    {
                        TratamientoEspecial_ASI(registro, "RETSOPOR", registro._Retsopor, ldtData);
                    }

                    if (!string.IsNullOrWhiteSpace(registro._Eos))
                    {
                        TratamientoEspecial_ASI(registro, "EOS", registro._Eos, ldtData);
                    }

                    break;

                default:

                    if (!string.IsNullOrWhiteSpace(registro._Asientos))
                    {
                        switch (registro._TablaSecundaria)
                        {
                            case "IVACJREPER":
                            case "IVACJSOPOR":

                                TratamientoEspecial_CriterioCaja(datos, registro, "ASIRECC", logRepository);
                                break;

                            default:

                                TratamientoEspecial_Asientos(datos, registro, ldtData, logRepository);
                                break;
                        }
                    }

                    break;
            }
        }

        private static void TratamientoEspecial_Asientos(OfflineDatosComunicaciones datos, RegistroTabRel registro, DataTable tdtData, ILog_comoffRepository logRepository)
        {
            DataTable ldtDatosASI = new DataTable();
            DataTable ldtDatosCTRL = new DataTable();
            string lcSql = string.Empty;
            string lcSelect = string.Empty;
            string lcWhere = string.Empty;

            if (!DB._SQLExisteTablaBBDD(_cRaizDataBaseTemporal + "GESTION", "ASIENTOS" + registro._Sufijo))
            {
                return;
            }

            lcSql = "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIORIGEN] ";
            lcSql += ";";
            lcSql += "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASITEMPORAL] ";
            lcSql += ";";
            lcSql += "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIINSERT] ";
            DB.SQLExec(lcSql);


            // quitar las columnas que no sean EMPRESA y ASI
            int lnColumns = tdtData.Columns.Count;
            for (int i = lnColumns - 1; i >= 0; i--)
            {
                if (tdtData.Columns[i].ColumnName.ToLower() != "empresa" && tdtData.Columns[i].ColumnName.ToLower() != "asi")
                {
                    tdtData.Columns.RemoveAt(i);
                }
                else
                {
                    if (string.IsNullOrWhiteSpace(lcSelect))
                    {
                        if (tdtData.Columns[i].ColumnName.ToLower() == "empresa")
                        {
                            lcSelect = " asi, empresa ";
                        }
                        else
                        {
                            lcSelect = " empresa, asi ";
                        }
                    }
                }
            }

            if (!clsOfflineUtils.ExisteDatabaseOffline(_cRaizDataBaseTemporal + "GESTION"))
            {
                CrearDataTable("GESTION", _cRaizDataBaseTemporal);
            }

            if (!clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + "GESTION].dbo.[_ASIORIGEN]"))
            {
                lcSql = " Select " + lcSelect + " INTO [" + _cRaizDataBaseTemporal + "GESTION].dbo.[_ASIORIGEN]" +
                        " From " + DB.SQLDatabase("GESTION", "ASIENTOS") + " as A Where 1 = 2 ";

                // Executem la consulta
                DB.SQLExec(lcSql);
            }

            InsertarDatosBulkMode(tdtData, "[" + _cRaizDataBaseTemporal + "GESTION].dbo.[_ASIORIGEN]");

            lcSql = " From [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + "ASIENTOS" + registro._Sufijo + "] as c " +
                    " inner join ( " +
                                " Select A.* " +
                                " From [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + "ASIENTOS" + registro._Sufijo + "] as A " +
                                " Where Exists ( " +
                                            " Select B.* " +
                                            " From [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIORIGEN] as B " +
                                            " Where A.EMPRESA=B.EMPRESA And A.ASI = B.ASI ) " +
                                " ) d ON c.EMPRESA = d.EMPRESA AND c.NUMERO = d.NUMERO ";

            // Executem la consulta
            DB.SQLExec(" Select c.* " + lcSql, ref ldtDatosASI);

            string lcDbReal = clsOfflineUtils.ObtenerNombreBdReal("GESTION");
            string lcCondicion = string.Empty;
            string lcIndice = " A.EMPRESA = B.EMPRESA And A.ASI = B.ASI ";
            string lcInnerOn = ObtenerCamposIndices("GESTION", "ASIENTOS");

            if (ldtDatosASI != null && ldtDatosASI.Rows.Count > 0)
            {
                DB.SQLExec(" Select c.* " + " INTO [" + _cRaizDataBaseTemporal + "GESTION].dbo.[_ASITEMPORAL] " + lcSql);
                
                ImportarAsientos(datos, registro, logRepository, "_ASITEMPORAL");

                // la condicion només l'aplicarem sobre el primer camp
                lcCondicion = lcIndice.Trim();
                lcCondicion = lcCondicion.Substring(0, lcCondicion.IndexOf('='));

                lcSql = "SELECT a.* into [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIINSERT] " +
                            " FROM  [" + lcDbReal + "].dbo.[ASIENTOS] a " +
                            " INNER JOIN [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + "ASIENTOS" + registro._Sufijo + "] b ON " + lcInnerOn +
                            " INNER JOIN [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIORIGEN] c ON b.EMPRESA = c.EMPRESA And b.ASI = c.ASI ";
                DB.SQLExec(lcSql);

                string lcCadenaCamps = ObtenerCamposSelect("GESTION", "ASIENTOS" + registro._Sufijo);
                string lcCadenaCampsAlias = ObtenerCamposSelect("GESTION", "ASIENTOS" + registro._Sufijo, "a.");

                lcSql = " INSERT INTO [" + lcDbReal + "].dbo.[" + "ASIENTOS" + "] (" + lcCadenaCamps + ") " +
                        " SELECT " + lcCadenaCampsAlias + " FROM [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASITEMPORAL] a " +
                        " LEFT JOIN [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIINSERT] b ON " + lcInnerOn +
                        " where B.asi is null ";
                DB.SQLExec(lcSql);

                TratamientoEspecial_ASI(registro, "OTRASIEN", "ASI", ldtDatosASI);

                lcSql = " Select a.*, c.NUMERO as NUEVO_NUMERO " +
                        " from [" + _cRaizDataBaseTemporal + "OFFLINE" + "].dbo.CTRL_ASIEN" + registro._Sufijo + " a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[ASIENTOS" + registro._Sufijo + "] b ON a.EMPRESA = b.EMPRESA and a.NUMERO = b.NUMERO and a.LINEA = b.LINEA and a.EJERCICIO = " + DB.SQLString(_cAny) +
                        " INNER JOIN (SELECT a.empresa, a.asi, a.numero " +
                                    " FROM [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASITEMPORAL] a " +
                                    " LEFT JOIN [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIINSERT] b ON a.empresa = b.empresa AND a.asi = b.asi " +
                                    " WHERE B.asi is null ) c ON b.EMPRESA = c.empresa and b.asi = c.asi ";

                DB.SQLExec(lcSql, ref ldtDatosCTRL);

                foreach (DataRow item in ldtDatosCTRL.Rows)
                {
                    lcWhere = " WHERE EMPRESA = " + DB.SQLString(item.Field<string>("empresa")) +
                              " AND LINEA = " + DB.SQLString(item.Field<int>("linea")) +
                              " AND EJERCICIO = " + DB.SQLString(_cAny);

                    lcSql = " DELETE FROM " + DB.SQLDatabase("OFFLINE", "CTRL_ASIEN") + lcWhere + " AND NUMERO = " + DB.SQLString(item.Field<int>("nuevo_numero")) + "; " +
                            " INSERT INTO " + DB.SQLDatabase("OFFLINE", "CTRL_ASIEN") +
                                    " (empresa, numero, linea, ejercicio, origen, idtabrel) " +
                                    " Values ( " +
                                                DB.SQLString(item.Field<string>("empresa")) + ", " + DB.SQLString(item.Field<int>("nuevo_numero")) + ", " +
                                                DB.SQLString(item.Field<int>("linea")) + ", " + DB.SQLString(_cAny) + ", " +
                                                DB.SQLString(item.Field<string>("origen")) + ", " + DB.SQLString(item.Field<int>("idtabrel")) + ")";
                    DB.SQLExec(lcSql);
                }
            }

            lcSql = "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIORIGEN] ";
            lcSql += ";";
            lcSql += "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASITEMPORAL] ";
            lcSql += ";";
            lcSql += "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIINSERT] ";
            DB.SQLExec(lcSql);
            
        }

        private static void TratamientoEspecial_ASI(RegistroTabRel registro, string tcTabla, string tcCampo, DataTable tdtData)
        {
            DataTable ldtDatosASI = new DataTable();
            string lcSql = string.Empty;

            if (!DB._SQLExisteTablaBBDD(_cRaizDataBaseTemporal + "GESTION", tcTabla + registro._Sufijo))
            {
                return;
            }

            lcSql = "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASI] ";
            lcSql += ";";
            lcSql += "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASINUEVO] ";
            lcSql += ";";
            lcSql += "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIESPECIAL] ";
            DB.SQLExec(lcSql);


            if (!clsOfflineUtils.ExisteDatabaseOffline(_cRaizDataBaseTemporal + "GESTION"))
            {
                CrearDataTable("GESTION", _cRaizDataBaseTemporal);
            }

            if (!clsOfflineUtils.ExisteTablaOffline("[" + _cRaizDataBaseTemporal + "GESTION].dbo.[_ASI]"))
            {
                lcSql = " Select empresa, asi INTO [" + _cRaizDataBaseTemporal + "GESTION].dbo.[_ASI]" +
                        " From " + DB.SQLDatabase("GESTION", "ASIENTOS") + " as A Where 1 = 2 ";

                // Executem la consulta
                DB.SQLExec(lcSql);
            }

            // quitar las columnas que no sean EMPRESA y ASI
            int lnColumns = tdtData.Columns.Count;
            for (int i = lnColumns - 1; i >= 0; i--)
            {
                if (tdtData.Columns[i].ColumnName.ToLower() != "empresa" && tdtData.Columns[i].ColumnName.ToLower() != tcCampo.ToLower())
                {
                    tdtData.Columns.RemoveAt(i);
                }
            }

            InsertarDatosBulkMode(tdtData, "[" + _cRaizDataBaseTemporal + "GESTION].dbo.[_ASI]");


            lcSql = " Select A.* " +
                    " From [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + tcTabla + registro._Sufijo + "] as A " +
                    " Where Exists ( " +
                                    " Select B.* " +
                                    " From [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASI] as B " +
                                    " Where A.EMPRESA=B.EMPRESA And A." + tcCampo + " = B.ASI )";

            //Executem la consulta
            DB.SQLExec(lcSql, ref ldtDatosASI);

            string lcDbReal = clsOfflineUtils.ObtenerNombreBdReal(registro._DBSecundaria);
            string lcCondicion = string.Empty;
            string lcIndice = " A.EMPRESA = B.EMPRESA And A.ASI = B." + tcCampo + " ";
            string lcInnerOn = ObtenerCamposIndices("GESTION", tcTabla);

            if (ldtDatosASI != null && ldtDatosASI.Rows.Count > 0)
            {
                if (registro._Sobreescribir)
                {
                    string lcSetCampos = ObtenerCamposSet("GESTION", tcTabla + registro._Sufijo);

                    lcSql = " UPDATE " + DB.SQLDatabase("GESTION", tcTabla) +
                        " SET " + lcSetCampos +
                        " FROM " + DB.SQLDatabase("GESTION", tcTabla) + " a " +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + tcTabla + registro._Sufijo + "] b ON " + lcInnerOn +
                        " INNER JOIN [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASI] c ON b.EMPRESA = c.EMPRESA And b." + tcCampo + " = c.ASI ";

                    DB.SQLExec(lcSql);
                }

                // la condicion només l'aplicarem sobre el primer camp
                lcCondicion = lcIndice.Trim();
                lcCondicion = lcCondicion.Substring(0, lcCondicion.IndexOf('='));

                lcSql = " SELECT a.* into [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASINUEVO] " +
                        " From [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + tcTabla + registro._Sufijo + "] as a " +
                        " inner join ( " +
                                    " Select c.* " +
                                    " From [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[" + tcTabla + registro._Sufijo + "] as c " +
                                    " Where Exists ( " +
                                                    " Select d.* " +
                                                    " From [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASI] as d " +
                                                    " Where c.EMPRESA = d.EMPRESA And c.ASI = d.ASI ) " +
                        " ) b ON " + lcInnerOn;

                DB.SQLExec(lcSql);

                string lcCadenaCamps = ObtenerCamposSelect("GESTION", tcTabla + registro._Sufijo);

                // farem el FULL JOIN, per trobar els nous registres
                lcSql = "SELECT b.* into [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIESPECIAL] " +
                            " FROM " + DB.SQLDatabase("GESTION", tcTabla) + " a " +
                            " RIGHT JOIN [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASINUEVO] b " +
                            " ON " + lcIndice +
                            " WHERE " + lcCondicion + " is null ";
                DB.SQLExec(lcSql);

                lcSql = " INSERT INTO " + DB.SQLDatabase("GESTION", tcTabla) + " (" + lcCadenaCamps + ") " +
                        " SELECT " + lcCadenaCamps + " FROM [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIESPECIAL] ";
                DB.SQLExec(lcSql);
            }

            lcSql = "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASI] ";
            lcSql += ";";
            lcSql += "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASINUEVO] ";
            lcSql += ";";
            lcSql += "DROP TABLE IF EXISTS [" + _cRaizDataBaseTemporal + "GESTION" + "].dbo.[_ASIESPECIAL] ";
            DB.SQLExec(lcSql);
        }

        private static void ActualizarDatosRecepcionEspecial(OfflineDatosComunicaciones datos, RegistroTabRel registro, string lcTaulaTemp, string lcTaulaLocal, string lcDb, string lcTaula, ILog_comoffRepository logRepository)
        {
            if (lcTaulaLocal == "EMPRESA")
            {
                DataTable ldtEmpresa = new DataTable();

                // buscamos si se han recibido empresas que no estan dadas de alta
                string lcSql = " SELECT a.CODIGO, a.NOMBRE " +
                                " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaula + "] a " +
                                " WHERE a.codigo NOT IN ( " +
                                                    " SELECT b.codigo " +
                                                    " FROM [" + _cRaizDataBaseTemporal + lcDb + "].dbo.[" + lcTaulaTemp + "] b ) ";
                DB.SQLExec(lcSql, ref ldtEmpresa);

                if (ldtEmpresa != null && ldtEmpresa.Rows.Count > 0)
                {
                    string lcDetalle = "Se han detectado en el fichero datos de empresas que no existen en el grupo de empresa que recibe los datos." + Environment.NewLine +
                                        "Para poder recibir datos de dichas empresas, deberá crearlas en el grupo de empresa en el que desee recibir los datos." + Environment.NewLine +
                                        "Las empresas incluidas en fichero que no existen en el grupo de empresa son las siguientes: " + Environment.NewLine + Environment.NewLine;

                    lcDetalle += ConstruirTextoDetalleEspecial(ldtEmpresa, "codigo", "nombre");

                    Log_comoffDto logDto = logRepository.GetDto(datos);
                    logDto.TipoDato = clsOfflineUtils.ObtenerTipoDato(registro._Clave);
                    logDto.Resultado = 3;
                    logDto.Detalle = lcDetalle;
                    logRepository.Insert(logDto);
                }
            }
        }

        private static void RegistroDatosRecepcion(OfflineDatosComunicaciones datos, RegistroTabRel registro, DataTable tdtDatos, string tcTaulaLocal, string tcDb, bool tlInsert, ILog_comoffRepository logRepository)
        {
            List<string> lista = new List<string>();

            string lcDetalle = string.Empty;
            string lcCampo = string.Empty;
            int lnResultado = 0;

            if (registro._Visible && registro._Actualizado && registro._TablaSecundaria == tcTaulaLocal)
            {
                return;
            }

            if (registro._Sufijo == "_CREATED")
            {
                if (tlInsert)
                {
                    lcDetalle = "Se ha dado de alta la siguiente información." + Environment.NewLine;
                    lnResultado = 1;
                }
                else
                {
                    lcDetalle = "Se ha actualizado la siguiente información a partir datos nuevos en el grupo de empresa origen." + Environment.NewLine +
                                "Revise que la información es correcta en el grupo de empresa que ha recibido los datos:" + Environment.NewLine;
                    lnResultado = 2;
                }
            }
            else
            {
                if (tlInsert)
                {
                    lcDetalle = "Se ha dado de alta la siguiente información a partir de datos modificados en el grupo de empresa origen." + Environment.NewLine +
                                "Revise que la información es correcta en el grupo de empresa que ha recibido los datos:" + Environment.NewLine;
                    lnResultado = 2;
                }
                else
                {
                    lcDetalle = "Se ha actualizado la siguiente información." + Environment.NewLine;
                    lnResultado = 1;
                }
            }

            lcDetalle += "Dato: " + (tcTaulaLocal.Contains("CTRL_") ? "Información extendida de " : "") + registro._Nombre.ToUpper() + Environment.NewLine + Environment.NewLine;


            switch (tcTaulaLocal)
            {
                case "BARRAS":
                case "IDI_ART":
                case "OFERTAS":
                case "PVP":
                case "REFERPRO":
                case "PVPCOL":
                case "ART_COLO":
                case "ART_TALL":
                case "ESCANDAL":
                case "FACTORPTOS":
                case "ART_FOTO":
                case "ARTLOT":
                case "BAREAN":
                case "COSTELOT":
                case "STOALMMM":
                case "EAN_PESO":
                case "ART_REST":
                case "ART_REG":
                case "CMBPVP":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "articulo", "ARTICULO", "GESTION");
                    break;

                case "DESC_FAM":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "familia", "ARTICULO", "GESTION");
                    break;

                case "MULTICAM":
                case "VALMULTI":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "codigo", "MCAMPOS", "GESTION");
                    break;

                case "DESC_SUB":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "subfam", "SUBFAM", "GESTION");
                    break;

                case "TALLGRUP":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "talla", "TALLAS", "COMUNES");
                    break;

                case "COLOGRUP":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "color", "COLORES", "COMUNES");
                    break;

                case "COMPRAS":
                case "STOCKS2":
                case "STOCKLOTES":
                case "STOCKS":
                case "STOCKINI":
                case "ALMA_ANALI":

                case "INICIALSER":
                case "LTSTINI":
                case "CTRL_STINI":

                case "REGULARI":
                case "LTREGUL":
                case "REGULARISER":
                case "CTRL_REGUL":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "almacen", "ALMACEN", "GESTION");
                    break;

                case "HISSERIE":

                    switch (registro._Clave)
                    {
                        case "STOCKINI":

                            lcDetalle += ConstruirTextoDetalle(tdtDatos, "almacen", "ALMACEN", "GESTION");
                            break;

                        case "C_ALBARE":
                        case "C_ALBATR":
                        case "PEDINT_C":
                        case "C_ALBCOM":
                        case "C_DEPCOM":
                        case "C_PROD":
                        case "C_TRANS":
                        case "C_ALBVEN":
                        case "C_ALBDEP":

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "numero", "", "numero");
                            break;

                        case "REGULARI":

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "documento", "", "documento");
                            break;
                    }
                    break;

                case "C_FORMUL":
                case "D_FORMUL":
                case "CTRL_FORMU":

                    lcCampo = (tcTaulaLocal == "D_FORMUL" ? "formula" : "articulo");
                    lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "C_FORMUL", "LOTES", "ARTICULO");
                    break;

                case "ART_CLASIF":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "clasif", "CLASIF", "COMUNES");
                    break;

                case "DESCUEN":
                case "ACTI_CLI":
                case "BANC_CLI":
                case "CONT_CLI":
                case "ENV_CLI":
                case "GIRO_CLI":
                case "TELF_CLI":
                case "VACA_CLI":
                case "CLITARJFID":
                case "MANDATOS":
                //case "MANDEMP":
                case "CONTLF_CLI":
                case "RIESGO":
                case "CUOTAS":
                case "CUO_MES":
                case "CCAACLI":

                    lcCampo = (tcTaulaLocal == "RIESGO" ? "codigo" : "cliente");
                    lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                    break;

                case "TCPS":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "tcp", "TCP", "COMUNES");
                    break;

                case "OTRAS":
                case "GIRO_CUE":
                case "BANC_CUE":
                case "MODIDFIS":
                case "RET_EMP":

                    lcCampo = (tcTaulaLocal == "OTRAS" ? "codigo" : "cuenta");
                    lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CUENTAS", "GESTION");
                    break;

                case "TELF_PRO":
                case "GIRO_PRO":
                case "CONT_PRO":
                case "ACTI_PRO":
                case "ENV_PRO":
                case "VACA_PRO":
                case "BANC_PRO":
                case "CONTLF_PRO":
                case "DESC_PRO":

                    lcCampo = (tcTaulaLocal == "DESC_PRO" ? "proveed" : "proveedor");
                    lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "PROVEED", "GESTION");
                    break;

                case "ENTRE_CL":

                    switch (registro._ID)
                    {
                        case 113:
                            // Entregas a cuenta de cliente
                            lcCampo = (tcTaulaLocal == "ENTRE_CL" || tcTaulaLocal == "PREVI_CL" ? "cliente" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                            break;

                        case 318:
                            // Entregas a cuenta de proveedor
                            lcCampo = (tcTaulaLocal == "ENTRE_CL" ? "cliente" : (tcTaulaLocal == "PREVIS" ? "proveedor" : "cuenta"));
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "PROVEED", "GESTION");
                            break;
                    }
                    break;

                case "EOS":

                    switch (registro._ID)
                    {
                        case 68: // Facturas de venta
                        case 301: // TPV con arqueo
                        case 326: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "factura");
                            break;

                        case 113:
                            // Entregas a cuenta de cliente
                            lcCampo = (tcTaulaLocal == "ENTRE_CL" || tcTaulaLocal == "PREVI_CL" ? "cliente" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                            break;

                        case 318:
                            // Entregas a cuenta de proveedor
                            lcCampo = (tcTaulaLocal == "ENTRE_CL" ? "cliente" : (tcTaulaLocal == "PREVIS" ? "proveedor" : "cuenta"));
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "PROVEED", "GESTION");
                            break;

                        case 216:
                            // Facturas de compra

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "cuenta", "factura");
                            break;
                    }

                    break;

                case "IVAREPER":

                    switch (registro._ID)
                    {
                        case 69: // Facturas de venta
                        case 302: // TPV con arqueo
                        case 327: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "numfra");
                            break;

                        case 113:
                            // Entregas a cuenta de cliente
                            lcCampo = (tcTaulaLocal == "ENTRE_CL" || tcTaulaLocal == "PREVI_CL" ? "cliente" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                            break;

                        case 318:
                            // Entregas a cuenta de proveedor
                            lcCampo = (tcTaulaLocal == "ENTRE_CL" ? "cliente" : (tcTaulaLocal == "PREVIS" ? "proveedor" : "cuenta"));
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "PROVEED", "GESTION");
                            break;

                        case 344:
                            // Facturas de compra
                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "cuenta", "numfra");
                            break;
                    }

                    break;

                case "IVASOPOR":

                    switch (registro._ID)
                    {
                        case 318:
                            // Entregas a cuenta de proveedor
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, "cuenta", "PROVEED", "GESTION");
                            break;

                        case 217:
                            // Facturas de compra

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "cuenta", "numfra");
                            break;
                    }

                    break;

                case "IVA_EXEN":

                    switch (registro._ID)
                    {
                        case 276: // Facturas de venta
                        case 308: // TPV con arqueo
                        case 333: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "factura");
                            break;

                        case 113:
                            // Entregas a cuenta de cliente
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, "cuenta", "CLIENTES", "GESTION");
                            break;

                        case 318:
                            // Entregas a cuenta de proveedor
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, "cuenta", "PROVEED", "GESTION");
                            break;

                        case 277:
                            // Facturas de compra

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "cuenta", "factura");
                            break;
                    }

                    break;

                case "RETREPER":

                    // Facturas de compra
                    lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "numfra");
                    break;

                case "RETSOPOR":

                    switch (registro._ID)
                    {
                        case 393: // Facturas de venta
                        case 395: // TPV con arqueo
                        case 396: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "numfra");
                            break;
                    }

                    break;

                case "PREVI_CL":
                case "CTRL_PREVV":

                    switch (registro._ID)
                    {
                        case 67: // Facturas de venta
                        case 300: // TPV con arqueo
                        case 325: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "factura");
                            break;

                        case 360:
                            // Entregas a cuenta de cliente
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, "cliente", "CLIENTES", "GESTION");
                            break;
                    }

                    break;

                case "PREVIS":
                case "CTRL_PREVC":

                    switch (registro._ID)
                    {
                        case 361:
                            // Entregas a cuenta de proveedor
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, "proveedor", "PROVEED", "GESTION");
                            break;

                        case 245:
                            // Facturas de compra

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "proveedor", "factura");
                            break;
                    }

                    break;

                case "CTRL_ASIEN":

                    lcDetalle += tdtDatos.Rows.Count.ToString() + " registros.";
                    break;

                case "ASIENTOS":
                case "OTRASIEN":
                //case "CTRL_ASIEN":

                    switch (registro._ID)
                    {
                        case 336:
                            // Presupuestos de venta
                            lcCampo = (tcTaulaLocal == "OTRASIEN" ? "codcuen" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                            break;

                        case 72:
                            // Pedidos de venta
                            lcCampo = (tcTaulaLocal == "OTRASIEN" ? "codcuen" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                            break;

                        case 5:
                            // Albaranes de venta
                            lcCampo = (tcTaulaLocal == "OTRASIEN" ? "codcuen" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                            break;

                        case 67:
                        case 68:
                        case 222:
                        case 348:
                            // Facturas de venta
                            lcCampo = (tcTaulaLocal == "OTRASIEN" ? "codcuen" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                            break;

                        case 216:
                        case 245:
                        case 221:
                            // Facturas de compra
                            lcCampo = (tcTaulaLocal == "OTRASIEN" ? "codcuen" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "PROVEED", "GESTION");
                            break;


                        case 360:
                            // Clientes
                            lcCampo = (tcTaulaLocal == "OTRASIEN" ? "codcuen" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "CLIENTES", "GESTION");
                            break;

                        case 361:
                            // Proveedores
                            lcCampo = (tcTaulaLocal == "OTRASIEN" ? "codcuen" : "cuenta");
                            lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo, "PROVEED", "GESTION");
                            break;
                    }
                    break;

                case "C_FACTUVEN":

                    switch (registro._ID)
                    {
                        case 288: // Facturas de venta
                        case 310: // TPV con arqueo
                        case 335: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "numero");

                            break;
                    }
                    break;

                case "C_FACTUCOM":

                    switch (registro._ID)
                    {
                        case 289: // Facturas de compra

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "proveedor", "numero");

                            break;
                    }
                    break;

                case "FINTECHFAC":

                    switch (registro._ID)
                    {
                        case 293: // Facturas de venta
                        case 311: // TPV con arqueo
                        case 252: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "numfra");

                            break;
                    }
                    break;

                case "FCFACTUVEN":

                    switch (registro._ID)
                    {
                        case 400: // Facturas de venta
                        case 408: // TPV con arqueo
                        case 407: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "borrador");

                            break;
                    }
                    break;

                case "FCREGCERT":

                    switch (registro._ID)
                    {
                        case 403: // Facturas de venta
                        case 405: // TPV con arqueo
                        case 404: // TPV sin arqueo

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "borrador");

                            break;
                    }
                    break;

                case "FPAG_GIR":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "fpag", "FPAG", "GESTION");
                    break;

                case "LIN_DESC":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "codigo", "LINEAS", "GESTION");
                    break;

                case "ZONAS":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "ruta", "RUTAS", "GESTION");
                    break;

                case "ART_COMI":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "vendedor", "VENDEDOR", "GESTION");
                    break;

                case "CONIRPF":

                    lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "conirpf", "nombre");

                    break;

                case "FCLETRAS":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "letra", "LETRAS", "COMUNES");
                    break;

                case "CAJ_FCOB":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "caja", "CAJAS", "TPV");
                    break;

                case "PLAN_D":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "plancont", "PLANS", "GESTION");
                    break;

                case "MODCONFI":
                case "CFGFACT":
                case "CODIGOS":
                case "FACTUCNF":
                case "FLAGS":
                case "OPCEMP":
                case "CONTACNF":
                case "ESCALADO":
                case "CONTADOR":
                case "SERIES":
                case "ACCESOS":
                case "MENUS":
                case "CONFIGURA":
                case "CONFTPV":
                case "CONFVAL":
                case "CONFTICK":
                case "MODCCAN":
                case "OTROSCFG":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "empresa", "EMPRESA", "GESTION");
                    break;

                case "OPC_USER":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "operario", "OPERARIO", "COMUNES");
                    break;

                case "ACCE_MON":
                case "OPCESPUS":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "usuario", "USUARIOS", "COMUNES");
                    break;


                case "OPCFLAG":
                case "CASH":
                case "PERFILES":

                    foreach (DataRow item in tdtDatos.Rows)
                    {
                        if (!lista.Contains(item.Field<int>("codigo").ToString().TrimEnd()))
                        {
                            lcDetalle += item.Field<int>("codigo").ToString().TrimEnd() + " - " + item.Field<string>("nombre").TrimEnd() + Environment.NewLine;
                            lista.Add(item.Field<int>("codigo").ToString().TrimEnd());
                        }
                    }

                    break;

                case "ARQUEOS":
                case "D_ARQUEO":
                case "CTRL_ARQUE":

                    lcCampo = (tcTaulaLocal == "D_ARQUEO" ? "arqueo" : "numero");

                    foreach (DataRow item in tdtDatos.Rows)
                    {
                        if (!lista.Contains(item.Field<string>("empresa").ToString().TrimEnd() + " - " + item.Field<int>(lcCampo).ToString().TrimEnd()))
                        {
                            lcDetalle += item.Field<string>("empresa").ToString().TrimEnd() + " - " + item.Field<int>(lcCampo).ToString().TrimEnd() + Environment.NewLine;
                            lista.Add(item.Field<string>("empresa").ToString().TrimEnd() + " - " + item.Field<int>(lcCampo).ToString().TrimEnd());
                        }
                    }
                    //lcDetalle += ConstruirTextoDetalleEspecial(ldtDatos, "empresa", lcCampo);

                    break;

                case "C_ALBATR":
                case "D_ALBATR":
                case "LTALBTR":
                case "TRASPSER":
                case "CTRL_ALBTR":

                case "C_ALBARE":
                case "D_ALBARE":
                case "LTALBRE":
                case "REGUSER":
                case "CTRL_ALBRE":

                case "PEDINT_C":
                case "PEDINT_D":
                case "PEDINT_LIN":
                case "PEDINT_REG":
                case "CTRL_PEDIN":

                case "CTRL_FACV":

                    lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "numero");
                    break;

                case "CCAAFAC":

                    lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "factura");
                    break;

                case "MULTICA2":

                    switch (registro._Clave)
                    {
                        case "C_PRESUV":
                        case "C_PEDIVE":
                        case "C_ALBDEP":
                        case "C_ALBVEN":
                        case "FACTURAS":
                        case "TPVCONARQUEO":
                        case "TPVSINARQUEO":

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "letra", "numero" );

                            break;
                    }
                    break;

                case "MULTICA3":

                    switch (registro._Clave)
                    {
                        case "C_PEDICO":
                        case "C_DEPCOM":
                        case "C_ALBCOM":
                        case "FACTURAC":

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "proveedor", "numero");
                            break;
                    }
                    break;

                case "CONTADO":

                    switch (registro._Clave)
                    {
                        case "C_PEDIVE":
                        case "C_ALBDEP":
                        case "C_ALBVEN":
                        case "CONTADO":

                            lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "letra", "numero");
                            break;
                    }
                    break;

                case "C_PRESUV":
                case "D_PRESUV":
                case "PORTES_PRV":
                case "ENTRE_PR":
                case "PRES_ADI":

                case "C_PEDIVE":
                case "D_PEDIVE":
                case "D_PEDIVEES":
                case "PORTES_PDV":
                case "ENTRE_PV":
                case "PEDV_ADI":

                case "C_ALBDEP":
                case "D_ALBDEP":
                case "LTDEPVE":
                case "DEPSER":
                case "PORTES_DPV":
                case "DEPV_ADI":

                case "C_ALBVEN":
                case "D_ALBVEN":
                case "LTALBVE":
                case "VENSER":
                case "PORTES":
                case "ENTREGAS":
                case "ALBV_ADI":
                case "REFALBCLI":
                case "CAB_AV":
                case "LIN_AV":
                case "ALB_FPAG":
                case "VALES":

                case "CTRL_PRESV":
                case "CTRL_PEDV":
                case "CTRL_DEPV":
                case "CTRL_ALBV":

                    lcCampo = (tcTaulaLocal == "PORTES" || tcTaulaLocal == "ENTREGAS" ? "albaran" : (tcTaulaLocal == "VALES" ? "ticket" : "numero"));
                    if (registro._Clave == "FACTURAS")
                    {
                        lcCampo = (tcTaulaLocal == "C_ALBVEN" && tcDb == "GESTION" ? "factura" : lcCampo);
                    }

                    lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "letra", lcCampo);
                    break;


                case "C_PEDICO":
                case "D_PEDICO":
                case "D_PEDICOES":

                case "C_DEPCOM":
                case "D_DEPCOM":
                case "LTDEPCO":
                case "DEPCSER":

                case "C_PROD":
                case "D_PROD":
                case "LTCPROD":
                case "LTDPROD":
                case "PRODUSER":
                case "PRODUSERC":

                case "C_TRANS":
                case "D_TRANS":
                case "LTCTRAN":
                case "LTDTRAN":
                case "TRANSER":
                case "TRANSSER":

                case "C_PARTES":

                case "CTRL_PEDC":
                case "CTRL_DEPC":
                case "CTRL_PROD":
                case "CTRL_TRANS":

                    lcCampo = (tcTaulaLocal == "PRODUSER" || tcTaulaLocal == "PRODUSERC" || tcTaulaLocal == "TRANSER" || tcTaulaLocal == "TRANSSER" ? "albaran" : "numero");

                    lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", lcCampo);
                    break;

                case "C_ALBCOM":
                case "D_ALBCOM":
                case "LTALBCO":
                case "COMSER":
                case "PORTESC":
                case "ALB_FPA2":
                case "C_TRANSDUA":
                case "D_TRANSDUA":

                case "CTRL_ALBC":
                case "CTRL_FACC":

                    lcCampo = (tcTaulaLocal == "PORTESC" ? "albaran" : "numero");
                    if (registro._Clave == "FACTURAC")
                    {
                        lcCampo = (tcTaulaLocal == "C_ALBCOM" ? "factura" : lcCampo);
                    }

                    lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "empresa", "proveedor", lcCampo);
                    break;

                case "TIKETS":
                case "REPOSI":
                case "COB_PAGO":
                case "CTRL_REPOS":
                case "CODPOS":

                    lcDetalle += tdtDatos.Rows.Count.ToString() + " registros.";
                    break;

                case "ESTILOS":
                case "PERF_OBLIG":
                case "PERF_USERS":
                case "UNIUSERS":

                    // No hacer nada, de momento
                    break;

                case "PLEFACT_D":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "codigo", "PLEFACT_C", "COMUNES");
                    break;

                case "COTIZA":

                    lcDetalle += ConstruirTextoDetalle(tdtDatos, "codigo", "MONEDA", "GESTION");
                    break;

                default:

                    if (tcTaulaLocal.Contains("CTRL_"))
                    {
                        string[] loDatos = _offlineConfig.ObtenerTablaOriginalRelacionada(tcTaulaLocal).Split('!');

                        if (loDatos.Length == 2)
                        {
                            switch (tcTaulaLocal)
                            {
                                case "CTRL_FORMU":

                                    lcCampo = "ARTICULO";
                                    break;

                                case "CTRL_STINI":

                                    lcCampo = "ALMACEN";
                                    break;

                                case "CTRL_CIRPF":

                                    lcCampo = "CONIRPF";
                                    break;

                                case "CTRL_OFER":

                                    lcCampo = "CODIGO";
                                    loDatos[1] = "ARTICULO";
                                    break;

                                default:

                                    lcCampo = "CODIGO";
                                    break;

                            }

                            if (tcTaulaLocal == "CTRL_PRCLI")
                            {
                                lcDetalle += ConstruirTextoDetalleEntero(tdtDatos, lcCampo.ToLower(), "PRCLIENT", "GESTION", lcCampo);
                            }
                            else
                            {
                                lcDetalle += ConstruirTextoDetalle(tdtDatos, lcCampo.ToLower(), loDatos[1], loDatos[0], lcCampo);
                            }
                        }
                    }
                    else
                    {
                        if (tcTaulaLocal == "PRCLIENT")
                        {
                            lcDetalle += ConstruirTextoDetalleEntero(tdtDatos, lcCampo.ToLower(), "PRCLIENT", "GESTION", lcCampo);
                        }
                        else
                        {
                            if (tdtDatos.Columns.Contains("codigo") && tdtDatos.Columns.Contains("nombre"))
                            {
                                lcDetalle += ConstruirTextoDetalleEspecial(tdtDatos, "codigo", "nombre");
                            }
                            else
                            {
                                ;
                            }
                        }
                    }
                    break;
            }

            Log_comoffDto logDto = logRepository.GetDto(datos);
            logDto.TipoDato = clsOfflineUtils.ObtenerTipoDato(registro._Clave);
            logDto.Resultado = lnResultado;
            logDto.Detalle = lcDetalle;
            logRepository.Insert(logDto);

        }

        private static string ObtenerCamposSelect(string tcDBLocal, string tcTablaLocal, string tcAlias = "", bool tlForzar = false)
        {
            // tcDBLocal->Nombre de la base de datos a la cual pertenece la tabla tcTablaLocal
            // tcTablaLocal->nombre de la tabla de la cual se debe comparar

            string lcSelect = string.Empty;
            string lcComa = string.Empty;
            int lnContador = 0;
            DataTable ldtCampos = new DataTable();

            DB.SQLExec("SELECT column_name, data_type FROM " + _cRaizDataBaseTemporal + tcDBLocal + ".INFORMATION_SCHEMA.COLUMNS WHERE table_name = '" + tcTablaLocal + "' ", ref ldtCampos);

            //Creamos estructura vacia
            foreach (DataRow item in ldtCampos.Rows)
            {
                lnContador++; 
                if (tlForzar && !string.IsNullOrWhiteSpace(tcAlias) && lnContador > 40)
                {
                    continue;
                }


                switch (item["column_name"].ToString().ToLower())
                {
                    case "com_estado":
                    case "com_fecha":
                    case "com_ini":
                    case "sucursal":
                    case "created":
                    case "modified":
                    case "vista":

                        break;

                    default:

                        switch (item["data_type"].ToString().ToLower())
                        {
                            case "text":
                            case "ntext":

                                if (!string.IsNullOrWhiteSpace(tcAlias))
                                {
                                    lcSelect += lcComa + "cast(" + tcAlias + "[" + item["column_name"].ToString().ToLower() + "] as varchar(8000)) as [" + item["column_name"].ToString().ToLower() + "] ";
                                }
                                else
                                {
                                    //lcSelect += lcComa + "CONVERT(VARCHAR(8000), [" + item["column_name"].ToString().ToLower() + "]) as [" + item["column_name"].ToString().ToLower() + "] ";
                                    lcSelect += lcComa + tcAlias + "[" + item["column_name"].ToString().ToLower() + "]";
                                }
                                break;

                            default:

                                lcSelect += lcComa + tcAlias + "[" + item["column_name"].ToString().ToLower() + "]";

                                break;
                        }

                        lcComa = ", ";

                        break;
                }
            }

            return lcSelect;
        }

        private static string ObtenerCamposSet(string tcDBLocal, string tcTablaLocal)
        {
            // tcDBLocal->Nombre de la base de datos a la cual pertenece la tabla tcTablaLocal
            // tcTablaLocal->nombre de la tabla de la cual se debe comparar

            string lcSet = string.Empty;
            string lcComa = string.Empty;
            DataTable ldtCampos = new DataTable();

            DB.SQLExec("SELECT * FROM " + _cRaizDataBaseTemporal + tcDBLocal + ".dbo." + tcTablaLocal + " WHERE 1 = 2", ref ldtCampos);

            //Creamos estructura vacia
            for (int i = 0; i < ldtCampos.Columns.Count; i++)
            {
                switch (ldtCampos.Columns[i].ColumnName.ToLower())
                {
                    case "com_estado":
                    case "com_fecha":
                    case "com_ini":
                    case "sucursal":
                    case "created":

                        break;
                    
                    case "modified":

                        lcSet += lcComa + " [" + ldtCampos.Columns[i].ColumnName.ToLower() + "] = " + DB.SQLString(DateTime.Now);

                        lcComa = ", ";
                        break;

                    default:

                        lcSet += lcComa + " [" + ldtCampos.Columns[i].ColumnName.ToLower() + "] = b.[" + ldtCampos.Columns[i].ColumnName.ToLower() + "] ";

                        lcComa = ", ";
                        break;
                }
            }

            return lcSet;
        }

        private static void CrearDataBaseTemporal(string tcSucursal)
        {
            _cRaizDataBaseTemporal = ObtenerDataBaseName(tcSucursal);

            // Carregar les dades de la gestió a una base de dades temporal dins del SQLSERVER
            CrearDataTable("COMUNES", _cRaizDataBaseTemporal);

            CrearDataTable("GESTION", _cRaizDataBaseTemporal);

            //* *Faig un recorregut per tots els móduls que tinc
            foreach (KeyValuePair<string, DB._ModuloSchema> entry in DB._dicCacheModulos)
            {
                CrearDataTable(entry.Value._Nombre, _cRaizDataBaseTemporal);
            }

            CrearDataTable("EUROWINSYS", _cRaizDataBaseTemporal);
        }



        private static void CrearDataTable(string tcDB, string tcArrelDB)
        {
            string lcDataBaseTemp = tcArrelDB + tcDB;
            string lcRutaTemp = Path.Combine(TempFolderName, tcDB);

            // tinc que comprovar si existeix
            if (Directory.Exists(lcRutaTemp))
            {
                // Recorrer todos los ficheros de la carpeta
                string[] files = Directory.GetFiles(lcRutaTemp, "*.xml");


                if (files.Length > 0)
                {
                    DB._DBCreate(lcDataBaseTemp);
                }

                foreach (var file in files)
                {
                    DataTable table = ConvertFileToDatatable(file, FormatoExportacion.XML);
                    string lcTabla = Path.GetFileNameWithoutExtension(file);

                    InsertarTablaBaseDatosBulk(table, tcDB, lcTabla, lcDataBaseTemp);
                }

                // Caso especial para el riesgo
                if (tcDB == "GESTION")
                {
                    string fichero = Path.Combine(TempFolderName, "RIESGO.XML");

                    // Tenemos que leer el fichero
                    if (File.Exists(fichero))
                    {
                        DataTable table = ConvertFileToDatatable(fichero, FormatoExportacion.XML);
                        string lcTabla = Path.GetFileNameWithoutExtension(fichero);

                        InsertarTablaBaseDatosBulk(table, tcDB, lcTabla, lcDataBaseTemp);
                    }
                }
            }
        }

        private static DataTable ObtenerDatosRecepcion(int tnIdConf)
        {
            string lcSql = string.Empty;
            string lcWhereCentral = string.Empty;
            string lcWhereSucur = string.Empty;
            string lcOrCentral = string.Empty;
            string lcOrSucur = string.Empty;
            string lcComa = string.Empty;

            DataTable TabTmp = new DataTable();

            // Reviso quines son les dades que he de rebre


            if (ficheroInfoConfig != null)
            {
                lcSql = " Select A.CLAVE, A.NOMBRE, cast(1 as bit) as SELRECIBIR, " +
                        " A.VISIBLE, A.ID, A.PRINCIPAL, A.SECUNDARIA, A.IDGRUPO, A.VISICOND, A.RELACION, A.EMPRESA, A.EMPRESECUN, A.TIPOTABLA, 1 as PRIORIDAD, " +
                        " A.asientos, A.otrasien, A.eos, A.iva_exen, A.ivasopor, A.ivareper, A.retsopor, A.retreper, A.compras " +
                        " From " + DB.SQLDatabase("OFFLINE", "TABRELNET") + " a ";

                if (ficheroInfoConfig._PrioridadesCentral.Count == 0)
                {
                    lcSql += " Where 1 = 2 ";
                }
                else
                {
                    lcComa = "";
                    lcSql += " Where A.ID IN (";
                    foreach (int item in ficheroInfoConfig._PrioridadesCentral)
                    {
                        lcSql += lcComa + DB.SQLString(item);
                        lcComa = ", ";
                    }

                    lcSql += ")";
                }

                lcSql += " UNION ALL ";

                lcSql += " Select A.CLAVE, A.NOMBRE, cast(1 as bit) as SELRECIBIR, " +
                        " A.VISIBLE, A.ID, A.PRINCIPAL, A.SECUNDARIA, A.IDGRUPO, A.VISICOND, A.RELACION, A.EMPRESA, A.EMPRESECUN, A.TIPOTABLA, 2 as PRIORIDAD, " +
                        " A.asientos, A.otrasien, A.eos, A.iva_exen, A.ivasopor, A.ivareper, A.retsopor, A.retreper, A.compras " +
                        " From " + DB.SQLDatabase("OFFLINE", "TABRELNET") + " a ";

                if (ficheroInfoConfig._PrioridadesSucursal.Count == 0)
                {
                    lcSql += " Where 1 = 2 ";
                }
                else
                {
                    lcComa = "";
                    lcSql += " Where A.ID IN (";
                    foreach (int item in ficheroInfoConfig._PrioridadesSucursal)
                    {
                        lcSql += lcComa + DB.SQLString(item);
                        lcComa = ", ";
                    }

                    lcSql += ")";
                }
            }
            else
            {
                // Si no encontramos el fichero de prioridades, vamos a obtener todas las tablas relacionadas
                lcSql = " Select A.CLAVE, A.NOMBRE, cast(1 as bit) as SELRECIBIR, " +
                        " A.VISIBLE, A.ID, A.PRINCIPAL, A.SECUNDARIA, A.IDGRUPO, A.VISICOND, A.RELACION, A.EMPRESA, A.EMPRESECUN, A.TIPOTABLA, 1 as PRIORIDAD, " +
                        " A.asientos, A.otrasien, A.eos, A.iva_exen, A.ivasopor, A.ivareper, A.retsopor, A.retreper, A.compras " +
                        " From " + DB.SQLDatabase("OFFLINE", "TABRELNET") + " a " +
                        " Where 1 = 1 ";
            }


            DB.SQLExec(lcSql, ref TabTmp);

            TabTmp.DefaultView.Sort = " CLAVE ASC, PRINCIPAL ASC, VISIBLE DESC, SECUNDARIA ASC ";
            TabTmp = TabTmp.DefaultView.ToTable();

            return TabTmp;
        }

        private static int Validaciones_Previas(OfflineDatosComunicaciones datos, ILog_comoffRepository logRepository)
        {
            string ficheroConfiguracion = Path.Combine(TempFolderName, "InfoConfig.xml");
            int lnValor = 0;
            string lcError = string.Empty;

            // Tenemos que leer el fichero
            if (!File.Exists(ficheroConfiguracion))
                return -1;

            string lcAllText = string.Empty;

            try
            {
                lcAllText = File.ReadAllText(ficheroConfiguracion);
                ficheroInfoConfig = _DeserializeOfflineInfoConfig(lcAllText);
            }
            catch
            {
                ficheroInfoConfig = new OfflineInfoConfig();
            }

            // Versión de Sage 50: Se revisará la versión de Sage 50 destino de los datos y se comparará con la versión incluida en el fichero de configuración de comunicaciones que se ha recibido.
            string[] lcVersionActual = InfoConfig._Version.Split('.');
            string[] lcVersionFichero = ficheroInfoConfig._Version.Split('.');

            if (lcVersionActual.Length > 2 && lcVersionFichero.Length > 2)
            {
                lnValor = 0;

                for (int i = 0; i < 3; i++)
                {
                    if (lnValor == 0 && lcVersionActual[i] != lcVersionFichero[i])
                    {
                        lnValor = -1;
                    }
                }
            }

            if (lnValor < 0)
            {
                lcError = "Los datos recibidos de la central son de la versión " + ficheroInfoConfig._Version + " de Sage 50, " +
                                        "la versión de su instalación es " + InfoConfig._Version + " ." + Environment.NewLine +
                                        "Para poder realizar la recepción de los datos es necesario que la versión de Sage 50 sea la misma.";

                Log_comoffDto logDto = logRepository.GetDto(datos);
                logDto.TipoDato = "01";
                logDto.Resultado = 3;
                logDto.Detalle = lcError;

                logRepository.Insert(logDto);

                FUNCTIONS._MessageBox(lcError, "Validaciones previas", MessageBoxButtons.OK, MessageBoxIcon.Error, MessageBoxDefaultButton.Button1);
                return lnValor;
            }

            // Año y Fecha inicial y final de ejercicio desde el cual se ejecuta envío: 
            // Se comprobará que la fecha inicial y final del ejercicio en el cual se reciben datos son las mismas que las incluidas en el fichero de configuración de comunicaciones.
            _ejercicioActual = _ejercicioNew = InfoConfig._Ejercicio;
            if (InfoConfig._FechaInicial != ficheroInfoConfig._FechaInicial || InfoConfig._FechaFinal != ficheroInfoConfig._FechaFinal || InfoConfig._Ejercicio != ficheroInfoConfig._Ejercicio)
            {
                if (!DB._oAliasDBEjer.ContainsKey(ficheroInfoConfig._Ejercicio.Trim()))
                {
                    lcError = "Se ha incluido información en el fichero de datos para el ejercicio " + ficheroInfoConfig._Ejercicio + ", pero dicho ejercicio no existe en el grupo de empresa en el cual está recibiendo los datos." + Environment.NewLine + Environment.NewLine +
                                "Debe crear el ejercicio y volver a ejecutar una recepción de datos.";

                    Actualizar_Tabla(datos, "OFFLINE", "EJERCICIOS", "EJERCICIOS.XML", logRepository);

                    Log_comoffDto logDto = logRepository.GetDto(datos);
                    logDto.TipoDato = "01";
                    logDto.Resultado = 3;
                    logDto.Detalle = lcError;
                    logRepository.Insert(logDto);

                    return 1;
                }

                _ejercicioNew = ficheroInfoConfig._Ejercicio;
            }

            // Tamaño de campos en la instalación que recibe los datos
            // Comprobar que la longitud de los campos de la instalación que recibe los datos es la misma que vendrá informada en el fichero de configuración de comunicaciones.
            if (!datos._IsCentral)
            {
                string ficheroAmplitud = Path.Combine(TempFolderName, "Config.xml");

                // Tenemos que leer el fichero
                if (!File.Exists(ficheroAmplitud))
                {
                    lcError = "No existe la configuración de la longitud de campos en del fichero recibido.";

                    Log_comoffDto logDto = logRepository.GetDto(datos);
                    logDto.TipoDato = "01";
                    logDto.Resultado = 3;
                    logDto.Detalle = lcError;
                    logRepository.Insert(logDto);

                    FUNCTIONS._MessageBox(lcError, "Validaciones previas", MessageBoxButtons.OK, MessageBoxIcon.Error, MessageBoxDefaultButton.Button1);
                    return -1;
                }

                //Crear fichero CONFIG.DBF
                DataTable configActual = clsOfflineUtils.AmplitudCampos();

                DataTable ldtConfigFichero = new DataTable();
                FUNCTIONS._Xml2Datatable(ficheroAmplitud, ref ldtConfigFichero);

                foreach (DataRow item in configActual.Rows)
                {
                    DataRow[] rows = ldtConfigFichero.Select("clave = '" + item["clave"].ToString() + "' and db = '" + item["db"].ToString() + "'");

                    if (rows.Length > 0)
                    {
                        if (Convert.ToInt32(item["ancho"]) != Convert.ToInt32(rows[0]["ancho"]))
                        {
                            lcError += item["clave"].ToString() + " Longitud en el fichero: " + Convert.ToInt32(rows[0]["ancho"]) + " , Longitud en la instalación: " + Convert.ToInt32(item["ancho"]) + Environment.NewLine;
                        }
                    }
                }

                if (!string.IsNullOrWhiteSpace(lcError))
                {
                    lcError = "Existen diferencias en la longitud de algunos campos en la instalación en la que está recibiendo los datos, respecto a longitud de campos en la instalación que ha enviado los datos." +
                                Environment.NewLine + Environment.NewLine + lcError;

                    Log_comoffDto logDto = logRepository.GetDto(datos);
                    logDto.TipoDato = "01";
                    logDto.Resultado = 3;
                    logDto.Detalle = lcError;
                    logRepository.Insert(logDto);

                    FUNCTIONS._MessageBox(lcError, "Validaciones previas. Recepción de datos Offline", MessageBoxButtons.OK, MessageBoxIcon.Error, MessageBoxDefaultButton.Button1);
                    return -1;
                }
            }

            return lnValor;
        }

        private static int ObtenerResultadoComunicacion(string tdIdLog)
        {
            DataTable table = new DataTable();
            string lcSql = "Select MAX(resultado) AS resultado " +
                            " From " + DB.SQLDatabase("OFFLINE", "LOG_COMOFF") +
                            " WHERE idlog = " + DB.SQLString(tdIdLog);

            DB.SQLExec(lcSql, ref table);

            if (table != null && table.Rows.Count > 0)
            {
                return Convert.ToInt32(table.Rows[0]["resultado"]);
            }

            return 1;
        }
        
        private static void EnvioEmailNotificacion(string tcFicheroZip, OfflineDatosComunicaciones datos, ILog_comoffRepository logRepository)
        {
            if (datos._NotificacionRecepcion && !string.IsNullOrEmpty(datos._EmailNotificacionRecepcion))
            {                
                _TextStepDetalle = "Enviado email de notificación";
                _TextStepProgreso = _TextStepDetalle;
                _PorcenProgreso = IncrementarBarraProgreso();

                SendMail loSendMail = new SendMail("SUPERVISOR");

                int lnResultadoComunicacion = ObtenerResultadoComunicacion(datos._Log_ComoffID);

                if (string.IsNullOrWhiteSpace(tcFicheroZip))
                {
                    loSendMail._Subject = "Sage 50 – Error en la recepción de datos";
                    loSendMail._Body = " Grupo de empresa: " + GrupoEmpresa._CodigoGrupoActual() + " - " + DB.SQLValor("gruposemp", "codigo", GrupoEmpresa._CodigoGrupoActual(), "nombre", "eurowinsys").ToString() + "<br>" +
                            " Sucursal Origen: " + datos._Sucursal + " - " + DB.SQLValor("SUCURSALES", "CODIGO", datos._Sucursal, "NOMBRE", "OFFLINE").ToString() + "<br><br>" +
                            " No existen ficheros de datos en la carpeta de FTP o OneDrive de la sucursal." + "<br><br>" +
                            " Revise el documento adjunto donde se incluye detalle del registro de comunicaciones, en el cual podrá ver los errores que se han producido durante el proceso de recepción de datos. ";
                }
                else
                {
                    switch (lnResultadoComunicacion)
                    {
                        case 3:
                            loSendMail._Subject = "Sage 50 – Error en la recepción de datos";
                            loSendMail._Body = " Grupo de empresa: " + GrupoEmpresa._CodigoGrupoActual() + " - " + DB.SQLValor("gruposemp", "codigo", GrupoEmpresa._CodigoGrupoActual(), "nombre", "eurowinsys").ToString() + "<br>" +
                                    " Sucursal Origen: " + datos._Sucursal + " - " + DB.SQLValor("SUCURSALES", "CODIGO", datos._Sucursal, "NOMBRE", "OFFLINE").ToString() + "<br><br>" +
                                    " Se han producido errores en el proceso de recepción de datos de fecha " + clsOfflineUtils.ObtenerFechaFicheroDatos(tcFicheroZip) + ", fichero " + tcFicheroZip + ". " + "<br><br>" +
                                    " Revise el documento adjunto donde se incluye detalle del registro de comunicaciones, en el cual podrá ver los errores que se han producido durante el proceso de recepción de datos. ";
                            break;

                        case 2:
                            loSendMail._Subject = "Sage 50 – Incidencias en la recepción de datos";
                            loSendMail._Body = " Grupo de empresa: " + GrupoEmpresa._CodigoGrupoActual() + " - " + DB.SQLValor("gruposemp", "codigo", GrupoEmpresa._CodigoGrupoActual(), "nombre", "eurowinsys").ToString() + "<br>" +
                                    " Sucursal Origen: " + datos._Sucursal + " - " + DB.SQLValor("SUCURSALES", "CODIGO", datos._Sucursal, "NOMBRE", "OFFLINE").ToString() + "<br><br>" +
                                    " Ha finalizado la recepción de datos de fecha " + clsOfflineUtils.ObtenerFechaFicheroDatos(tcFicheroZip) + ", fichero " + tcFicheroZip + " con incidencias." + "<br><br>" +
                                    " Revise el documento adjunto donde se incluye detalle del registro de comunicaciones, en el cual podrá ver las incidencias detectadas durante el proceso de recepción de datos.";

                            break;

                        default:

                            loSendMail._Subject = "Sage 50 – Recepción de datos";
                            loSendMail._Body = " Grupo de empresa: " + GrupoEmpresa._CodigoGrupoActual() + " - " + DB.SQLValor("gruposemp", "codigo", GrupoEmpresa._CodigoGrupoActual(), "nombre", "eurowinsys").ToString() + "<br>" +
                                    " Sucursal Origen: " + datos._Sucursal + " - " + DB.SQLValor("SUCURSALES", "CODIGO", datos._Sucursal, "NOMBRE", "OFFLINE").ToString() + "<br><br>" +
                                    " Ha finalizado la recepción de datos de fecha " + clsOfflineUtils.ObtenerFechaFicheroDatos(tcFicheroZip) + ", fichero " + tcFicheroZip + " correctamente." + "<br><br>" +
                                    " Revise documento adjunto donde se incluye detalle del registro de comunicaciones en el cual podrá ver los datos recibidos.";
                            break;
                    }
                }

                loSendMail._Emails = datos._EmailNotificacionRecepcion.Split(';').ToList();
                loSendMail._EnvioDirecto = true;
                loSendMail._ShowEmailForm = false;
                loSendMail._CCOUsuarioActivo = false;

                _ObtenerConfiguracionEmail(loSendMail); //Task 202603

                // Adjuntar fichero Comunicaciones
                string cRuta = TempFolderName;

                Log_comoffDto logDto = logRepository.GetDto(datos);
                logDto.TipoDato = "01";

                try
                {
                    using (RegistroComunicaciones loLogCom = new RegistroComunicaciones(datos._Log_ComoffID))
                    {

                        cRuta = Path.Combine(cRuta, loLogCom._NombreFicheroExportar);

                        loLogCom._Exportar(ew.listados.Clases.Listados.ExportType.pdf, cRuta, false, "REG_COMU");

                        loSendMail._AddAttachment(cRuta + ".pdf");
                    }
                }
                catch (Exception)
                {
                    logDto.Resultado = 2;
                    logDto.Detalle = "No se ha podido adjuntar el fichero PDF.";
                    logRepository.Insert(logDto);
                }

                if (!loSendMail._Send() && !string.IsNullOrWhiteSpace(loSendMail._Error_Message))
                {
                    //En caso de que haya dado un error en el envío del email y estemos en modo de tarea programada, guardamos una notificación de Sage 50
                    //FUNCTIONS._Notificacion("Sage 50 – Recepción de datos", "Incidencia en envío de email de la recepción de datos.",
                    //"No se ha enviado correctamente el email de la recepción de datos. del grupo " + GrupoEmpresa._CodigoGrupoActual(), tcIcono: "warning");
                    logDto.Resultado = 3;
                    logDto.Detalle = "Fallo al realizar envío de mail de notificación de recepción de datos. Revise en el mantenimiento de grupos de empresa, los datos de configuración en pestaña Configuración notificaciones del Add-on Comunicaciones offline.";
                }
                else
                {
                    logDto.Resultado = 1;
                    logDto.Detalle = "Enviado email de notificación de recepción correctamente.";
                }
                logRepository.Insert(logDto);

                if (loSendMail._EnvioDirecto && File.Exists(cRuta + ".pdf"))
                {
                    File.Delete(cRuta + ".pdf");
                }

                loSendMail = null;                
            }
        }

        private static void Actualizar_Fecha_Recepcion_Multiconf(OfflineDatosComunicaciones datos)
        {
            string lcCampo = "ULTFECREC";

            DB.SQLExec("UPDATE " + DB.SQLDatabase("OFFLINE", "MULTCONF") +
                        " SET " + lcCampo + " = " + DB.SQLString(DateTime.Now) + ", MODIFIED = MODIFIED " +
                        " WHERE IDCONF = " + DB.SQLString(datos._IdConf));
        }

        private static void Actualizar_Fecha_Recepcion_Sucursales(OfflineDatosComunicaciones datos, string cTipoRecepcion, ILog_comoffRepository logRepository)
        {
            // i -> Carga Inicial    
            // e -> Envío de datos
            string lcCampo = (cTipoRecepcion == "i" ? ", CARGAINI = " + DB.SQLString(DateTime.Now) : "");
            string lcTipoRecepcion = (cTipoRecepcion == "i" ? "la carga inicial" : "datos");

            DB.SQLExec("UPDATE " + DB.SQLDatabase("OFFLINE", "SUCURSALES") +
                        " SET ULTFECREC = " + DB.SQLString(DateTime.Now) +
                        lcCampo + ", MODIFIED = MODIFIED " +
                        " WHERE CODIGO = " + DB.SQLString(datos._Sucursal));


            Log_comoffDto logDto = logRepository.GetDto(datos);
            logDto.TipoDato = "01";
            logDto.Resultado = 1;
            logDto.Detalle = "Recepción de " + lcTipoRecepcion + " finalizado correctamente.";
            logRepository.Insert(logDto);
        }

        private static bool Actualizar_Datos_Sucursales(OfflineDatosComunicaciones datos, ILog_comoffRepository logRepository)
        {
            // Actualizar configuraciones de sucursales:
            Actualizar_Tabla(datos, "OFFLINE", "SUCURSALES", "SUCURSALES.XML", logRepository);
            Actualizar_Tabla(datos, "OFFLINE", "SUCURALM", "SUCURALM.XML", logRepository);
            Actualizar_Tabla(datos, "OFFLINE", "SUCURLET", "SUCURLET.XML", logRepository);
            Actualizar_Tabla(datos, "OFFLINE", "SUCURCAJA", "SUCURCAJA.XML", logRepository);
            Actualizar_Tabla(datos, "OFFLINE", "PRIORIDAD", "PRIORIDAD.XML", logRepository);

            // Actualizar variables del grupo de empresa(configuración de grupo de empresa Sucursal):
            if (!string.IsNullOrWhiteSpace(datos._Sucursal))
            {
                bool llValor = Convert.ToBoolean(DB.SQLValor("SUCURSALES", "CODIGO", datos._Sucursal, "ENV_FOTO", "OFFLINE"));
                _offlineConfig.InsertOrUpdateVariable(EnumVariables.ENVIARIMAGENES, (llValor ? ".T." : ".F."), "L");

                llValor = Convert.ToBoolean(DB.SQLValor("SUCURSALES", "CODIGO", datos._Sucursal, "DELMANTES", "OFFLINE"));
                _offlineConfig.InsertOrUpdateVariable(EnumVariables.DELETE_SUC_MANT, (llValor ? ".T." : ".F."), "L");

                llValor = Convert.ToBoolean(DB.SQLValor("SUCURSALES", "CODIGO", datos._Sucursal, "DELDOCS", "OFFLINE"));
                _offlineConfig.InsertOrUpdateVariable(EnumVariables.DELETE_SUC_DOC, (llValor ? ".T." : ".F."), "L");
            }

            Log_comoffDto logDto = logRepository.GetDto(datos);
            logDto.TipoDato = "01";
            logDto.Resultado = 1;
            logDto.Detalle = "Actualizada configuración de sucursales y grupos de empresa.";
            logRepository.Insert(logDto);

            // Se deberán actualizar o crear las configuraciones modificando o añadiendo registros en tablas MULTCONF, TABNETCONF, SUCURCONF según datos recibidos en ficheros XML con el mismo nombre.
            Actualizar_Tabla(datos, "OFFLINE", "MULTCONF", "MULTCONF.XML", logRepository);
            Actualizar_Tabla(datos, "OFFLINE", "TABNETCONF", "TABNETCONF.XML", logRepository);
            Actualizar_Tabla(datos, "OFFLINE", "SUCURCONF", "SUCURCONF.XML", logRepository);

            Actualizar_Tabla(datos, "OFFLINE", "EJERCICIOS", "EJERCICIOS.XML", logRepository);

            return true;
        }

        private static bool Actualizar_Datos_Servidor(OfflineDatosComunicaciones datos, ILog_comoffRepository logRepository)
        {
            Log_comoffDto logDto = logRepository.GetDto(datos);

            bool lbExiste = true;

            lbExiste = Actualizar_Tabla(datos, "OFFLINE", "SUCURSALES", "SUCURSALES.XML", logRepository);
            if (lbExiste)
            {
                logDto.TipoDato = "01";
                logDto.Resultado = 1;
                logDto.Detalle = "Actualizada configuración de la sucursal " + datos._Sucursal + ". Revise mantenimiento de sucursales para ver los cambios realizados.";
                logRepository.Insert(logDto);
            }

            // Actualizar configuraciones de sucursales:
            lbExiste = Actualizar_Tabla(datos, "GESTION", "SERIES", "SERIES.XML", logRepository);
            if (lbExiste)
            {
                logDto.TipoDato = "01";
                logDto.Resultado = 1;
                logDto.Detalle = "Actualizados contadores de series de documentos de la sucursal " + datos._Sucursal;
                logRepository.Insert(logDto);
            }

            Actualizar_Tabla(datos, "OFFLINE", "EJERCICIOS", "EJERCICIOS.XML", logRepository);

            Actualizar_Tabla(datos, "OFFLINE", "ACTRIESGO", "ACTRIESGO.XML", logRepository);

            return true;
        }

        private static bool Actualizar_Tabla(OfflineDatosComunicaciones datos, string tcNombreBD, string tcNombreTabla, string tcFicheroXML, ILog_comoffRepository logRepository)
        {
            string lcSql = string.Empty;
            string lcWhere = string.Empty;
            string lcTablaSql = string.Empty;

            string fichero = Path.Combine(TempFolderName, tcFicheroXML);

            // Tenemos que leer el fichero
            if (!File.Exists(fichero))
                return false;

            DataTable ldtFichero = new DataTable();
            FUNCTIONS._Xml2Datatable(fichero, ref ldtFichero);

            tcNombreTabla = tcNombreTabla.Trim();
            lcTablaSql = DB.SQLDatabase(tcNombreBD, tcNombreTabla);

            Log_comoffDto logDto = logRepository.GetDto(datos);

            switch (tcNombreTabla)
            {
                case "SUCURSALES":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE codigo = " + DB.SQLString(item["CODIGO"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + lcTablaSql +
                                        " Set NOMBRE = " + DB.SQLString(item["NOMBRE"]) +
                                        " , LICENCIA = " + DB.SQLString(item["NOMBRE"]) +
                                        " , ACTIVA = " + DB.SQLString(item["ACTIVA"]) +
                                        " , DELDOCS = " + DB.SQLString(item["DELDOCS"]) +
                                        " , ENV_FOTO = " + DB.SQLString(item["ENV_FOTO"]) +
                                        " , DELMANTES = " + DB.SQLString(item["DELMANTES"]) +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + lcTablaSql + " " +
                                        " (CODIGO,NOMBRE,LICENCIA,ACTIVA,DELDOCS,ENV_FOTO,DELMANTES) " +
                                         "VALUES (" +
                                            DB.SQLString(item["CODIGO"]) + ", " +
                                            DB.SQLString(item["NOMBRE"]) + ", " +
                                            DB.SQLString(item["LICENCIA"]) + ", " +
                                            DB.SQLString(item["ACTIVA"]) + ", " +
                                            DB.SQLString(item["DELDOCS"]) + ", " +
                                            DB.SQLString(item["ENV_FOTO"]) + ", " +
                                            DB.SQLString(item["DELMANTES"]) + ") " +
                                " END ";


                        DB.SQLExec(lcSql);
                    }

                    break;

                case "SUCURALM":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE SUCURSAL = " + DB.SQLString(item["SUCURSAL"]) + " AND LINIA = " + DB.SQLString(item["LINIA"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + lcTablaSql +
                                        " Set ALMACEN = " + DB.SQLString(item["ALMACEN"]) +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + lcTablaSql + " " +
                                        " (LINIA,SUCURSAL,ALMACEN) " +
                                        " VALUES (" +
                                            DB.SQLString(item["LINIA"]) + ", " +
                                            DB.SQLString(item["SUCURSAL"]) + ", " +
                                            DB.SQLString(item["ALMACEN"]) + ") " +
                                " END ";

                        DB.SQLExec(lcSql);
                    }

                    break;

                case "SUCURLET":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE SUCURSAL = " + DB.SQLString(item["SUCURSAL"]) + " AND LINIA = " + DB.SQLString(item["LINIA"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + lcTablaSql +
                                        " Set LETRA = " + DB.SQLString(item["LETRA"]) +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + lcTablaSql + " " +
                                        " (LINIA,SUCURSAL,LETRA) " +
                                        " VALUES (" +
                                            DB.SQLString(item["LINIA"]) + ", " +
                                            DB.SQLString(item["SUCURSAL"]) + ", " +
                                            DB.SQLString(item["LETRA"]) + ") " +
                                " END ";

                        DB.SQLExec(lcSql);
                    }

                    break;

                case "SUCURCAJA":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE SUCURSAL = " + DB.SQLString(item["SUCURSAL"]) + " AND LINIA = " + DB.SQLString(item["LINIA"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + lcTablaSql +
                                        " Set CAJA = " + DB.SQLString(item["CAJA"]) +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + lcTablaSql + " " +
                                        " (LINIA,SUCURSAL,CAJA) " +
                                        " VALUES (" +
                                            DB.SQLString(item["LINIA"]) + ", " +
                                            DB.SQLString(item["SUCURSAL"]) + ", " +
                                            DB.SQLString(item["CAJA"]) + ") " +
                                " END ";

                        DB.SQLExec(lcSql);
                    }

                    break;

                case "SUCURCONF":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE SUCURSAL = " + DB.SQLString(item["SUCURSAL"]) + " AND IDCONF = " + DB.SQLString(item["IDCONF"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + lcTablaSql +
                                        " Set VALOR = " + DB.SQLString(item["VALOR"]) +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + lcTablaSql + " " +
                                        " (SUCURSAL,IDCONF,VALOR) " +
                                        " VALUES (" +
                                            DB.SQLString(item["SUCURSAL"]) + ", " +
                                            DB.SQLString(item["IDCONF"]) + ", " +
                                            DB.SQLString(item["VALOR"]) + ") " +
                                " END ";

                        DB.SQLExec(lcSql);
                    }

                    break;

                case "PRIORIDAD":

                    bool lbMsj = false;
                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        // Comprobamos si existe el registro con los mismos valores en campos prioridad y control para mostrar mensaje
                        if (!lbMsj)
                        {
                            lcWhere = " WHERE IDTABREL = " + DB.SQLString(item["IDTABREL"]) + " AND PRIO_DATOS = " + DB.SQLString(item["PRIO_DATOS"]) + " AND CTRL_DATOS = " + DB.SQLString(item["CTRL_DATOS"]);

                            DataTable dt = new DataTable();
                            DB.SQLExec("SELECT * FROM " + lcTablaSql + lcWhere, ref dt);
                            if (dt != null && dt.Rows.Count == 0)
                            {
                                logDto.TipoDato = "01";
                                logDto.Resultado = 1;
                                logDto.Detalle = "Actualizada configuración de control de datos. Revise el mantenimiento de grupos de empresa para comprobar los cambios realizados.";
                                logRepository.Insert(logDto);
                                lbMsj = true;
                            }
                        }
                    

                        lcWhere = " WHERE IDTABREL = " + DB.SQLString(item["IDTABREL"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                            " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                            " BEGIN " + Environment.NewLine +
                                    " Update " + lcTablaSql +
                                    " Set PRIO_DATOS = " + DB.SQLString(item["PRIO_DATOS"]) +
                                    " , CTRL_DATOS = " + DB.SQLString(item["CTRL_DATOS"]) +
                                    lcWhere + Environment.NewLine +
                            " END " + Environment.NewLine +
                            " ELSE " + Environment.NewLine +
                            " BEGIN" + Environment.NewLine +
                                    " INSERT INTO " + lcTablaSql + " " +
                                    " (IDTABREL,PRIO_DATOS,CTRL_DATOS) " +
                                    " VALUES (" +
                                        DB.SQLString(item["IDTABREL"]) + ", " +
                                        DB.SQLString(item["PRIO_DATOS"]) + ", " +
                                        DB.SQLString(item["CTRL_DATOS"]) + ") " +
                            " END ";

                        DB.SQLExec(lcSql);

                        try
                        {

                        }
                        catch (Exception)
                        {
                            logDto.TipoDato = "01";
                            logDto.Resultado = 2;
                            logDto.Detalle = "Se ha producido un error que ha impedido realizar actualización de configuración de control de datos. Revise la configuración de control de datos en el mantenimiento de grupos de empresa por si fuera necesario realizar algún cambio de forma manual.";
                            logRepository.Insert(logDto);

                            break;
                        }
                    }

                    break;

                case "MULTCONF":
                    List<string> lstInsert = new List<string>();
                    List<string> lstUpdate = new List<string>();

                    string lcCodigo = "";
                    bool llHayCambios = false;
                    ConfComOffline configura = new ConfComOffline();

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        // Elimino todas las tareas programas que tenemos creada de esta configuración si existe para después crear de nuevo con valores actualizados
                        lcCodigo = item["CODIGO"].ToString();

                        configura = new ConfComOffline(lcCodigo);
                        configura._Load();
                        llHayCambios = false;

                        lcWhere = " WHERE CODIGO = " + DB.SQLString(item["CODIGO"]);

                        string lcHora_Rec = FUNCTIONS.Modificar_Hora(item["HORA_REC"].ToString(), -15);
                        string lcHora_Env = FUNCTIONS.Modificar_Hora(item["HORA_ENV"].ToString(), 15);

                        var tipo = Convert.ToInt16(item["TIPO"]);

                        lcSql = " Update " + lcTablaSql +
                                        " Set IDCONF = " + DB.SQLString(item["IDCONF"]) +
                                        " , NOMBRE = " + DB.SQLString(item["NOMBRE"]) +
                                        " , TIPO = " + DB.SQLString((tipo == 0 ? 0 : Convert.ToInt16(item["TIPO"]) == 1 ? 2 : 1)) +
                                        (tipo == 1 ? (tipo == 0 ? "" : ", FREC_ENV = ''") : " , FREC_ENV = " + DB.SQLString(item["FREC_REC"])) + // Se giran los valores
                                        (tipo == 2 ? (tipo == 0 ? "" : ", FREC_REC = ''") : " , FREC_REC = " + DB.SQLString(item["FREC_ENV"])) + // Se giran los valores
                                        (tipo == 1 ? (tipo == 0 ? "" : ", HORA_ENV = ''") : " , HORA_ENV = " + DB.SQLString(lcHora_Rec)) + // Se giran los valores
                                        (tipo == 2 ? (tipo == 0 ? "" : ", HORA_REC = ''") : " , HORA_REC = " + DB.SQLString(lcHora_Env)) + // Se giran los valores
                                        " , REC_STOCK = " + DB.SQLString(item["REC_STOCK"]) +
                                        lcWhere + Environment.NewLine;

                        DB.SQLExec(lcSql, out int lnFilasAfectadas);

                        if (lnFilasAfectadas == 0)
                        {
                            DB.SQLExec("DELETE FROM " + lcTablaSql + " WHERE IDCONF = " + DB.SQLString(item["IDCONF"]));

                            lcSql = " INSERT INTO " + lcTablaSql + " " +
                                    " (IDCONF,NOMBRE,CODIGO,TIPO,FREC_ENV,FREC_REC,HORA_ENV,HORA_REC,REC_STOCK,CONEXION,CFG_FTP,ONEDRVUSER,ONEDRVFOLD,REFRESHTOKEN,RESOURCEIDS,CLIENTID) " +
                                    " VALUES (" +
                                                DB.SQLString(item["IDCONF"]) + ", " +
                                                DB.SQLString(item["NOMBRE"]) + ", " +
                                                DB.SQLString(item["CODIGO"]) + ", " +
                                                DB.SQLString((Convert.ToInt16(item["TIPO"]) == 0 ? 0 : Convert.ToInt16(item["TIPO"]) == 1 ? 2 : 1)) + ", " +
                                                (Convert.ToInt16(item["TIPO"]) == 1 ? DB.SQLString(0) : DB.SQLString(item["FREC_REC"])) + ", " + // Se giran los valores
                                                (Convert.ToInt16(item["TIPO"]) == 2 ? DB.SQLString(0) : DB.SQLString(item["FREC_ENV"])) + ", " + // Se giran los valores
                                                (Convert.ToInt16(item["TIPO"]) == 1 ? DB.SQLString("") : DB.SQLString(lcHora_Rec)) + ", " + // Se giran los valores
                                                (Convert.ToInt16(item["TIPO"]) == 2 ? DB.SQLString("") : DB.SQLString(lcHora_Env)) + ", " + // Se giran los valores
                                                DB.SQLString(item["REC_STOCK"]) + ", " +
                                                DB.SQLString(item["CONEXION"]) + ", " +
                                                DB.SQLString(item["CFG_FTP"]) + ", " +
                                                DB.SQLString(item["ONEDRVUSER"]) + ", " +
                                                DB.SQLString(item["ONEDRVFOLD"]) + ", " +
                                                DB.SQLString(item["REFRESHTOKEN"]) + ", " +
                                                DB.SQLString(item["RESOURCEIDS"]) + ", " +
                                                DB.SQLString(item["CLIENTID"]) +
                                            ") ";

                            DB.SQLExec(lcSql);

                            lstInsert.Add(Convert.ToString(item["CODIGO"]) + " - " + Convert.ToString(item["NOMBRE"]));

                            llHayCambios = true;
                        }
                        else
                        {
                            lstUpdate.Add(Convert.ToString(item["CODIGO"]) + " - " + Convert.ToString(item["NOMBRE"]));
                        }

                        configura._Codigo = Convert.ToString(item["CODIGO"]);
                        configura._IdConf = Convert.ToInt32(item["IDCONF"]);
                        configura._Conexion = Convert.ToInt32(item["CONEXION"]);
                        configura._ConfiguracionFtp = Convert.ToString(item["CFG_FTP"]);
                        configura._OneDriveUser = Convert.ToString(item["ONEDRVUSER"]);
                        configura._OneDriveFolder = Convert.ToString(item["ONEDRVFOLD"]);
                        configura._RefreshToken = Convert.ToString(item["REFRESHTOKEN"]);
                        configura._ResourceIds = Convert.ToString(item["RESOURCEIDS"]);
                        configura._ClientId = Convert.ToString(item["CLIENTID"]);
                        configura._Nombre = Convert.ToString(item["NOMBRE"]);

                        // Comprobamos si hay cambio de tipo (envío, recepción o ambas) o  si se ha modificado la hora de envío o recepción
                        switch (Convert.ToInt16(item["TIPO"]))
                        {
                            case 0: // Envío/Recepción
                                llHayCambios = llHayCambios || (configura.Envio != true);
                                llHayCambios = llHayCambios || (configura.Recepcion != true);
                                break;
                            case 1:  // Envío   
                                llHayCambios = llHayCambios || (configura.Envio != false);
                                llHayCambios = llHayCambios || (configura.Recepcion != true);
                                break;
                            case 2:   // Recepción
                                llHayCambios = llHayCambios || (configura.Envio != true);
                                llHayCambios = llHayCambios || (configura.Recepcion != false);
                                break;
                        }
                        llHayCambios = llHayCambios || (configura._HoraEnvio != (Convert.ToInt16(item["TIPO"]) == 1 ? "" : Convert.ToString(lcHora_Rec)));
                        llHayCambios = llHayCambios || (configura._HoraRecepcion != (Convert.ToInt16(item["TIPO"]) == 2 ? "" : Convert.ToString(lcHora_Env)));

                        if (llHayCambios)
                        {
                            TareasProgramadasOffline tareap = new TareasProgramadasOffline(configura);
                            tareap.Delete();
                        }

                        // ---------------- IMPORTANTE ----------------
                        // Estas propiedades hay que cambiar después de la posible eliminación de tareas programadas si hay cambio en la configuración, 
                        // porque si cambiamos antes de eliminar las posibles tareas, no encuentra las tareas programadas de esta configuración que ya existen
                        // ---------------- IMPORTANTE ----------------

                        // Debemos de cambiar los valores y si la configuración que viene es envío debemos marcar recepción o viceversa
                        // la propiedad _Tipo le asignamos valor con las propiedades Envío y Recepción
                        switch (Convert.ToInt16(item["TIPO"]))
                        {
                            case 0: // Envío/Recepción
                                configura.Envio = true;
                                configura.Recepcion = true;
                                break;
                            case 1:  // Envío   
                                configura.Envio = false;
                                configura.Recepcion = true;
                                break;
                            case 2:   // Recepción
                                configura.Envio = true;
                                configura.Recepcion = false;
                                break;
                        }

                        configura._FrecuenciaEnvio = Convert.ToInt16(item["TIPO"]) == 1 ? 0 : Convert.ToInt16(item["FREC_REC"]);
                        configura._FrecuenciaRecepcion = Convert.ToInt16(item["TIPO"]) == 2 ? 0 : Convert.ToInt16(item["FREC_ENV"]);
                        configura._HoraEnvio = Convert.ToInt16(item["TIPO"]) == 1 ? "" : Convert.ToString(lcHora_Rec);
                        configura._HoraRecepcion = Convert.ToInt16(item["TIPO"]) == 2 ? "" : Convert.ToString(lcHora_Env);
                        configura._RecalcularStock = Convert.ToBoolean(item["REC_STOCK"]);

                        if (llHayCambios)
                        {
                            TareasProgramadasOffline tareap = new TareasProgramadasOffline(configura);
                            tareap.Save();
                        }
                    }

                    logDto.TipoDato = "01";
                    logDto.Resultado = 1;
                    if (lstInsert.Count > 0)
                    {
                        List<string> lstMsjInsert = new List<string>();
                        lstMsjInsert.Add("Creadas las siguientes configuraciones de comunicaciones: ");
                        lstMsjInsert.Add("Creadas las siguientes tareas programadas de configuraciones de comunicaciones: ");
                        foreach (string valorMsj in lstMsjInsert)
                        {
                            logDto.Detalle = valorMsj;
                            foreach (string valor in lstInsert)
                            {
                                logDto.Detalle += Environment.NewLine + valor;
                            }
                            logRepository.Insert(logDto);
                        }
                    }


                    if (lstUpdate.Count > 0)
                    {
                        List<string> lstMsjUpdate = new List<string>();
                        lstMsjUpdate.Add("Actualizadas las siguientes configuraciones de comunicaciones: ");
                        lstMsjUpdate.Add("Actualizadas las siguientes tareas programadas de configuraciones de comunicaciones: ");

                        foreach (string valorMsj in lstMsjUpdate)
                        {
                            logDto.Detalle = valorMsj;
                            foreach (string valor in lstUpdate)
                            {
                                logDto.Detalle += Environment.NewLine + valor;
                            }
                            logRepository.Insert(logDto);
                        }
                    }

                    break;

                case "TABNETCONF":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE CODIGO = " + DB.SQLString(item["CODIGO"]) + " AND IDTABREL = " + DB.SQLString(item["IDTABREL"]);

                        lcSql = " Update " + lcTablaSql +
                                " Set IDCONF = " + DB.SQLString(item["IDCONF"]) +
                                " , SELENVIAR = " + DB.SQLString(item["SELRECIBIR"]) +
                                " , SELRECIBIR = " + DB.SQLString(item["SELENVIAR"]) +
                                lcWhere;

                        DB.SQLExec(lcSql, out int lnFilasAfectadas);

                        if (lnFilasAfectadas == 0)
                        {
                            DB.SQLExec("DELETE FROM " + lcTablaSql + " WHERE IDCONF = " + DB.SQLString(item["IDCONF"]) + " AND IDTABREL = " + DB.SQLString(item["IDTABREL"]));

                            lcSql = " INSERT INTO " + lcTablaSql + " " +
                                        " (CODIGO,IDCONF,IDTABREL,SELENVIAR,SELRECIBIR) " +
                                        " VALUES (" +
                                                        DB.SQLString(item["CODIGO"]) + ", " +
                                                        DB.SQLString(item["IDCONF"]) + ", " +
                                                        DB.SQLString(item["IDTABREL"]) + ", " +
                                                        DB.SQLString(item["SELRECIBIR"]) + ", " +
                                                        DB.SQLString(item["SELENVIAR"]) + ") ";

                            DB.SQLExec(lcSql);
                        }
                    }

                    break;

                case "SERIES":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE EMPRESA = " + DB.SQLString(item["EMPRESA"]) + " AND SERIE = " + DB.SQLString(item["SERIE"]) + " AND TIPODOC = " + DB.SQLString(item["TIPODOC"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + lcTablaSql +
                                        " Set CONTADOR = " + DB.SQLString(item["CONTADOR"]) +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + lcTablaSql + " " +
                                        " (EMPRESA, SERIE, TIPODOC, CONTADOR) " +
                                        " VALUES (" +
                                            DB.SQLString(item["EMPRESA"]) + ", " +
                                            DB.SQLString(item["SERIE"]) + ", " +
                                            DB.SQLString(item["TIPODOC"]) + ", " +
                                            DB.SQLString(item["CONTADOR"]) + ") " +
                                " END ";

                        DB.SQLExec(lcSql);
                    }

                    break;

                case "EJERCICIOS":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE TIPOOFF = " + DB.SQLString(item["TIPOOFF"]) + " AND EJERCICIO = " + DB.SQLString(item["EJERCICIO"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + lcTablaSql +
                                        " Set TRASPEJER = " + DB.SQLString(item["TRASPEJER"]) +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + lcTablaSql + " " +
                                        " (TIPOOFF,EJERCICIO,TRASPEJER) " +
                                        " VALUES (" +
                                            DB.SQLString(item["TIPOOFF"]) + ", " +
                                            DB.SQLString(item["EJERCICIO"]) + ", " +
                                            DB.SQLString(item["TRASPEJER"]) + ") " +
                                " END ";

                        DB.SQLExec(lcSql);
                    }

                    break;

                case "ACTRIESGO":

                    foreach (DataRow item in ldtFichero.Rows)
                    {
                        lcWhere = " WHERE EMPRESA = " + DB.SQLString(item["EMPRESA"]) + " AND CODIGO = " + DB.SQLString(item["CODIGO"]);

                        lcSql = " IF EXISTS " + Environment.NewLine +
                                " ( SELECT * FROM " + lcTablaSql + lcWhere + " ) " + Environment.NewLine +
                                " BEGIN " + Environment.NewLine +
                                        " Update " + lcTablaSql +
                                        " Set MODIFIED = GETDATE() " +
                                        lcWhere + Environment.NewLine +
                                " END " + Environment.NewLine +
                                " ELSE " + Environment.NewLine +
                                " BEGIN" + Environment.NewLine +
                                        " INSERT INTO " + lcTablaSql + " " +
                                        " (EMPRESA,CODIGO) " +
                                        " VALUES (" +
                                            DB.SQLString(item["EMPRESA"]) + ", " +
                                            DB.SQLString(item["CODIGO"]) + ") " +
                                " END ";

                        DB.SQLExec(lcSql);
                    }

                    break;
            }

            return true;
        }

        private static string Tratamiento_Deletenet_Tabla_Control(string tcTabla, string tcWhere, string tcEjercicio, string tcId, string tcChecksum)
        {
            //Task 190035: Control de que el checksum de deletenet no esté modificado o manipulado desde la tabla en el campo sql
            if (tcChecksum != _offlineConfig.GenerarChecksumDeleteNet(tcId, tcWhere, tcTabla))
            {
                throw new ChecksumDeleteNetException("Error en la comprobación del checksum de la tabla Deletenet");
            }

            string lcSql = string.Empty;
            string lcTablaControl = _offlineConfig.ObtenerTablaControlRelacionada(tcTabla);

            if (string.IsNullOrWhiteSpace(lcTablaControl))
            {
                return "";
            }

            switch (lcTablaControl)
            {
                case "CTRL_CLI":
                case "CTRL_CUE":
                case "CTRL_FPAG":
                case "CTRL_LINEA":
                case "CTRL_RUTAS":
                case "CTRL_VEN":
                case "CTRL_AGEN":
                case "CTRL_TPFAC":
                case "CTRL_ACTI":
                case "CTRL_PRO":
                case "CTRL_ART":
                case "CTRL_FAM":
                case "CTRL_SUBFA":
                case "CTRL_MARCA":
                case "CTRL_CARAC":
                case "CTRL_MCAM":
                case "CTRL_TARIF":
                case "CTRL_MON":
                case "CTRL_TPIVA":
                case "CTRL_ALM":
                case "CTRL_BANC":
                case "CTRL_ENTI":
                case "CTRL_IDIOM":
                case "CTRL_TPRET":
                case "CTRL_NIV1":
                case "CTRL_NIV2":
                case "CTRL_NIV3":
                case "CTRL_NIV4":
                case "CTRL_PLAN":
                case "CTRL_SECUN":
                case "CTRL_CONGA":
                case "CTRL_CIRPF":
                case "CTRL_SEC":
                case "CTRL_TPCOS":
                case "CTRL_TPOPE":
                case "CTRL_OPERA":
                case "CTRL_CONC":
                case "CTRL_COLO":
                case "CTRL_TALL":
                case "CTRL_GTALL":
                case "CTRL_GCOLO":
                case "CTRL_TCP":
                case "CTRL_CLASI":
                case "CTRL_EMPL":
                case "CTRL_LET":
                case "CTRL_OBRA":
                case "CTRL_SUPLI":
                case "CTRL_MCONC":
                case "CTRL_FCOB":
                case "CTRL_CAJAS":
                case "CTRL_DEFVA":
                case "CTRL_CAN":
                case "CTRL_REPOS":
                case "CTRL_RETIR":
                case "CTRL_FORMU":
                case "CTRL_MCAML":
                case "CTRL_TPREG":
                case "CTRL_ARQUE":
                case "CTRL_PEDIN":
                case "CTRL_FPTOS":

                    lcSql = " DELETE FROM " + DB.SQLDatabase("OFFLINE", lcTablaControl) + tcWhere + "; ";
                    break;

                case "CTRL_PARCO":

                    tcWhere = tcWhere.Replace("linea", "linia");
                    lcSql = " DELETE FROM " + DB.SQLDatabase("OFFLINE", lcTablaControl) + tcWhere + " AND EJERCICIO = " + DB.SQLString(tcEjercicio) + "; ";

                    break;

                case "CTRL_ASIEN":

                    lcSql = " DELETE FROM " + DB.SQLDatabase("OFFLINE", lcTablaControl) +
                            " FROM " + DB.SQLDatabase("OFFLINE", lcTablaControl) + " a " +
                            " INNER JOIN (SELECT empresa, numero, linea FROM " + DB.SQLDatabase("GESTION","ASIENTOS") + tcWhere + " ) b " +
                                " ON a.empresa = b.EMPRESA and a.NUMERO = b.NUMERO and a.LINEA = b.LINEA " +
                            " WHERE a.EJERCICIO = " + DB.SQLString(tcEjercicio) + "; ";
                    
                    break;

                case "CTRL_PREVV":

                    lcSql = " DELETE FROM " + DB.SQLDatabase("OFFLINE", lcTablaControl) + tcWhere + " AND PERIODO = " + DB.SQLString(tcEjercicio) + "; ";
                    break;

                case "CTRL_PREVC":

                    lcSql = " DELETE FROM " + DB.SQLDatabase("OFFLINE", lcTablaControl) + tcWhere + " AND YEAR(EMISION) = " + DB.SQLString(tcEjercicio) + "; ";
                    break;

                default:

                    lcSql = " DELETE FROM " + DB.SQLDatabase("OFFLINE", lcTablaControl) + tcWhere + " AND EJERCICIO = " + DB.SQLString(tcEjercicio) + "; ";
                    break;
            }

            return lcSql;
        }



        private static bool Tratamiento_Deletenet(OfflineDatosComunicaciones datos, ILog_comoffRepository logRepository)
        {
            string lcFile = Path.Combine(TempFolderName, "DELETENET.xml");
            if (!File.Exists(lcFile))
            {
                return false;
            }

            DataTable table = ConvertFileToDatatable(lcFile, FormatoExportacion.XML);

            string lcDb = string.Empty;
            string lcTabla = string.Empty;
            string lcEjercicio = string.Empty;
            string lcWhere = string.Empty;
            string lcTipoDato = string.Empty;
            string lcChecksum = string.Empty;
            string lcId = string.Empty;

            string lcSql = string.Empty;
            DataTable tablaConsulta = new DataTable();

            List<string> lstTareasProg = new List<string>();
            ConfComOffline configura = new ConfComOffline();

            foreach (DataRow item in table.Rows)
            {
                string lcCodigo = "";
            
                lcTipoDato = clsOfflineUtils.ObtenerTipoDato(item.Field<string>("clavetab").TrimEnd());

                lcDb = item.Field<string>("db").TrimEnd();
                lcTabla = item.Field<string>("tabla").TrimEnd();
                lcEjercicio = item.Field<string>("ejercicio").TrimEnd();
                lcWhere = item.Field<string>("sql").TrimEnd();
                lcId = item.Field<string>("id").TrimEnd();
                lcChecksum = item.Field<string>("checksum").TrimEnd();

                try
                {
                    lcSql = Tratamiento_Deletenet_Tabla_Control(lcDb + "!" + lcTabla, lcWhere, lcEjercicio, lcId, lcChecksum);
                    lcSql += " DELETE FROM " + DB.SQLDatabase(lcDb, lcTabla) + lcWhere + ";";
                    

                    switch (lcTabla)
                    {
                        case "C_PLANT":
                            
                            lcWhere = lcWhere.Replace("codigo", "plantilla");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "D_PLANTCLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "D_PLANTLIN") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "D_PLANTPLA") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PLANTHDOC") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PLANCLIART") + lcWhere + ";";

                            break;

                        case "ARTICULO":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICAM") + lcWhere + " AND FICHERO = 'ARTICULO' ;";

                            lcWhere = lcWhere.Replace("codigo", "articulo");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PVPCOL") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PVP") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "OFERTAS") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "BARRAS") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "EAN_PESO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ESCANDAL") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "REFERPRO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "IDI_ART") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ART_FOTO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "STOALMMM") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CMBPVP") + lcWhere + ";";

                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "ART_CLASIF") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "ART_COLO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "ART_TALL") + lcWhere + ";";
                        
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ART_ULTCOS") + lcWhere + ";";
                        

                            if (EW_GLOBAL._ModuloActivo("TPV"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("TPV", "ART_REST") + lcWhere + ";";
                            }

                            if (EW_GLOBAL._ModuloActivo("TUEFID"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("TUEFID", "ART_REG") + lcWhere + ";";
                                lcSql += " DELETE FROM " + DB.SQLDatabase("TUEFID", "FACTORPTOS") + lcWhere + ";";
                            }
                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "ARTLOT") + lcWhere + ";";
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "BAREAN") + lcWhere + ";";
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "COSTELOT") + lcWhere + " AND EJERCICIO = '" + lcEjercicio + "' ;";

                                lcWhere = item.Field<string>("sql").TrimEnd();
                                lcWhere = lcWhere.Replace("codigo", "LEFT(codigo," + EW_GLOBAL._GetLenCampo(ew.global.Diccionarios.KeyDiccionarioLenCampos.wn_articulo) + ")");
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "MULTICAM") + lcWhere + " AND FICHERO = 'ARTLOTES' ;";
                            }

                            break;

                        case "PROVEED":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICAM") + lcWhere + " AND FICHERO = 'PROVEEDO' ;";

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "OTRAS") + lcWhere + ";";

                            lcWhere = lcWhere.Replace("codigo", "proveed");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "DESC_PRO") + lcWhere + ";";

                            lcWhere = item.Field<string>("sql").TrimEnd();
                            lcWhere = lcWhere.Replace("codigo", "proveedor");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ACTI_PRO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "BANC_PRO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONT_PRO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ENV_PRO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "GIRO_PRO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "TELF_PRO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONTLF_PRO") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "VACA_PRO") + lcWhere + ";";

                            lcWhere = item.Field<string>("sql").TrimEnd();
                            lcWhere = lcWhere.Replace("codigo", "cliente");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ENTRE_CL") + lcWhere + ";";

                            break;

                        case "CLIENTES":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICAM") + lcWhere + " AND FICHERO = 'CLIENTES' ;";

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "OTRAS") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "RIESGO") + lcWhere + ";";

                            lcWhere = lcWhere.Replace("codigo", "cliente");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "DESCUEN") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ACTI_CLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "BANC_CLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONT_CLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ENV_CLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "GIRO_CLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "TELF_CLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONTLF_CLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "VACA_CLI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ENTRE_CL") + lcWhere + ";";

                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "CUOTAS") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "CUO_MES") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "MANDATOS") + lcWhere + ";";

                            if (EW_GLOBAL._ModuloActivo("TUEFID"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("TUEFID", "CLITARJFID") + lcWhere + ";";
                            }

                            break;

                        case "ASIENTOS":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "OTRASIEN") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "EOS") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "RETREPER") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "RETSOPOR") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "IVAREPER") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "IVASOPOR") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "IVA_EXEN") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MOD347I") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "IVACJREPER") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "IVACJSOPOR") + lcWhere + ";";

                            string lcWhereObserasi = " where " + lcWhere.Substring(lcWhere.IndexOf("asi"));
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "OBSERASI") + lcWhereObserasi + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONCILIA") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONCIASI") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ASIMEM") + lcWhere + ";";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "FACTURAE") + lcWhere + ";";

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MOD347M") + lcWhere + " AND EJERCICIO = '" + lcEjercicio + "' ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MOD349R") + lcWhere + " AND EJERCICIOA = '" + lcEjercicio + "' ;";

                            break;

                        case "ENTREGAS":
                        case "ENTRE_PV":
                        case "ENTRE_PR":

                            //Obtener primero número del asiento de la entrega para localizar el resto de ASIs del asiento 
                            var query = $"SELECT ASIENTOS.EMPRESA, ASIENTOS.NUMERO, ASIENTOS.ASI FROM {DB.SQLDatabase("GESTION", "ASIENTOS")} ASIENTOS " +
                                        $"INNER JOIN " +
                                        $"   (SELECT EMPRESA, NUMERO FROM {DB.SQLDatabase("GESTION", "ASIENTOS")} {lcWhere}) AS DATOS " +
                                        $"ON ASIENTOS.EMPRESA = DATOS.EMPRESA and ASIENTOS.NUMERO = DATOS.NUMERO ";
                            var datosAsiento = new DataTable();

                            if(DB.SQLExec(query, ref datosAsiento))
                            {
                                foreach (DataRow row in datosAsiento.Rows)
                                {
                                    var empresa = Convert.ToString(row["EMPRESA"]).TrimEnd();
                                    var asi = Convert.ToString(row["ASI"]).TrimEnd();
                                    var whereLineaAsientoEntrega = $" WHERE empresa = '{empresa}' and asi = '{asi}' ";

                                    lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "OTRASIEN") + whereLineaAsientoEntrega + ";";
                                    lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ASIENTOS") + whereLineaAsientoEntrega + ";";

                                    var numero = Convert.ToString(row["numero"]).TrimEnd();
                                    var whereControlAsientoEntrega = $" WHERE empresa = '{empresa}' and numero = '{numero}' ";
                                    lcSql += " DELETE FROM " + DB.SQLDatabase("OFFLINE", "CTRL_ASIEN") + whereControlAsientoEntrega + ";";
                                }
                            }
                            

                            break;

                        case "MONEDA":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "COTIZA") + lcWhere + ";";

                            break;

                        case "ENTIDAD":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "OFICINAS") + lcWhere + ";";

                            break;

                        case "FAMILIAS":

                            lcWhere = lcWhere.Replace("codigo", "familia");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "DESC_FAM") + lcWhere + ";";

                            break;

                        case "F_PAG":

                            lcWhere = lcWhere.Replace("codigo", "fpag");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "FPAG_GIR") + lcWhere + ";";

                            break;

                        case "GRUPCOLO":

                            lcWhere = lcWhere.Replace("codigo", "grupo");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "COLOGRUP") + lcWhere + ";";

                            break;

                        case "GRUPTALL":

                            lcWhere = lcWhere.Replace("codigo", "grupo");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "TALLGRUP") + lcWhere + ";";

                            break;

                        case "LINEAS":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "LIN_DESC") + lcWhere + ";";

                            break;

                        case "PLANS":

                            lcWhere = lcWhere.Replace("codigo", "plancont");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PLAN_D") + lcWhere + ";";

                            break;

                        case "RUTAS":

                            lcWhere = lcWhere.Replace("codigo", "ruta");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "ZONAS") + lcWhere + ";";

                            break;

                        case "VENDEDOR":

                            lcWhere = lcWhere.Replace("codigo", "vendedor");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "ART_COMI") + lcWhere + ";";

                            break;

                        case "ALMACEN":

                            lcWhere = lcWhere.Replace("codigo", "almacen");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ART_ULTCOS") + lcWhere + ";";
                            break;

                        case "TALLAS":

                            lcWhere = lcWhere.Replace("codigo", "talla");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ART_ULTCOS") + lcWhere + ";";
                            break;

                        case "COLORES":

                            lcWhere = lcWhere.Replace("codigo", "color");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ART_ULTCOS") + lcWhere + ";";
                            break;

                        case "C_PRESUV":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICA2") + lcWhere + " AND FICHERO = 4 ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ENTRE_PR") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PRES_ADI") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PORTES_PRV") + lcWhere + " ;"; //Bug 195879

                            break;

                        case "C_PEDIVE":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICA2") + lcWhere + " AND FICHERO = 2 ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONTADO") + lcWhere + " AND TIPO = 2 ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ENTRE_PV") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PEDV_ADI") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PORTES_PDV") + lcWhere + " ;"; //Bug 195879

                            if (EW_GLOBAL._ModuloActivo("GAPED"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("GAPED", "D_PEDIVEES") + lcWhere + " AND EJERCICI = '" + lcEjercicio + "' ;";
                            }

                            break;

                        case "D_PEDIVE":

                            if (EW_GLOBAL._ModuloActivo("GAPED"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("GAPED", "D_PEDIVEES") + lcWhere + " AND EJERCICI = '" + lcEjercicio + "' ;";
                            }
                            break;

                        case "C_ALBVEN":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICA2") + lcWhere + " AND FICHERO = 1 ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONTADO") + lcWhere + " AND TIPO = 1 ;";

                            //Bug 195567 => Borrado por empresa+numero+letra
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "REFALBCLI") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ALB_FPAG") + lcWhere + " ;";

                            //Borrado por empresa+albaran+letra
                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ENTREGAS") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PORTES") + lcWhere + " ;"; //Bug 195879

                            lcWhere = lcWhere.Replace("albaran", "numero");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "ALBV_ADI") + lcWhere + " ;";

                            if (EW_GLOBAL._ModuloActivo("TPV"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("TPV", "TIKETS") + lcWhere + " AND EJERCICIO = '" + lcEjercicio + "' ;";
                                lcSql += " DELETE FROM " + DB.SQLDatabase("TPV", "C_ALBVEN") + lcWhere + " AND EJERCICIO = '" + lcEjercicio + "' ;";
                            }

                            break;

                        case "D_ALBVEN":

                            if (EW_GLOBAL._ModuloActivo("TUEFID"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("TUEFID", "LIN_AV") + lcWhere + " AND EJERCICIO = '" + lcEjercicio + "' ;";
                            }

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTALBVE") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            if (EW_GLOBAL._ModuloActivo("TPV"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("TPV", "D_ALBVEN") + lcWhere + " AND EJERCICIO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "VENSER") + lcWhere + " ;";

                            DB.SQLExec(" SELECT SERIE FROM " + DB.SQLDatabase("GESTION", "VENSER") + lcWhere, ref tablaConsulta);
                            foreach (DataRow itemSerie in tablaConsulta.Rows)
                            {
                                lcSql += " UPDATE " + DB.SQLDatabase("COMUNES", "COMPRAS") + " SET BAJA = '', CODEMP = '', FBAJA = NULL " +
                                         " WHERE SERIE = " + DB.SQLString(itemSerie["SERIE"]) + " AND [ANY] = '" + lcEjercicio + "' ";
                            }

                            break;

                        case "C_ALBDEP":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICA2") + lcWhere + " AND FICHERO = 5 ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "CONTADO") + lcWhere + " AND TIPO = 4 ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "DEPV_ADI") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PORTES_DPV") + lcWhere + " ;"; //Bug 195879

                            break;

                        case "D_ALBDEP":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTDEPVE") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            lcWhere = lcWhere.Replace("numero", "deposito");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "DEPSER") + lcWhere + " ;";

                            DB.SQLExec(" SELECT SERIE FROM " + DB.SQLDatabase("GESTION", "DEPSER") + lcWhere, ref tablaConsulta);
                            foreach (DataRow itemSerie in tablaConsulta.Rows)
                            {
                                lcSql += " UPDATE " + DB.SQLDatabase("COMUNES", "COMPRAS") + " SET BAJA = '', CODEMP = '', FBAJA = NULL " +
                                         " WHERE SERIE = " + DB.SQLString(itemSerie["SERIE"]) + " AND [ANY] = '" + lcEjercicio + "' ";
                            }

                            break;

                        case "C_PRECOM":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICA3") + lcWhere + " AND FICHERO = 3 ;";

                            break;

                        case "C_PEDICO":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICA3") + lcWhere + " AND FICHERO = 2 ;";
                            if (EW_GLOBAL._ModuloActivo("GAPED"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("GAPED", "D_PEDICOES") + lcWhere + " AND EJERCICI = '" + lcEjercicio + "' ;";
                            }

                            break;

                        case "D_PEDICO":

                            if (EW_GLOBAL._ModuloActivo("GAPED"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("GAPED", "D_PEDICOES") + lcWhere + " AND EJERCICI = '" + lcEjercicio + "' ;";
                            }
                            break;

                        case "C_ALBCOM":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICA3") + lcWhere + " AND FICHERO = 1 ;";

                            break;

                        case "D_ALBCOM":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTALBCO") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "COMSER") + lcWhere + " ;";

                            lcWhere = lcWhere.Replace("empresa", "codempcom");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "COMPRAS") + lcWhere + " AND [ANY] = '" + lcEjercicio + "' ";

                            break;

                        case "C_DEPCOM":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "MULTICA3") + lcWhere + " AND FICHERO = 4 ;";

                            break;

                        case "D_DEPCOM":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTDEPCO") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "DEPCSER") + lcWhere + " ;";

                            lcWhere = lcWhere.Replace("empresa", "codempcom");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "COMPRAS") + lcWhere + " AND [ANY] = '" + lcEjercicio + "' ";

                            break;

                        case "C_ALBARE":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTALBRE") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "REGUSER") + lcWhere + " ;";

                            break;

                        case "D_ALBARE":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTALBRE") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "REGUSER") + lcWhere + " ;";

                            DB.SQLExec(" SELECT SERIE FROM " + DB.SQLDatabase("GESTION", "REGUSER") + lcWhere, ref tablaConsulta);
                            foreach (DataRow itemSerie in tablaConsulta.Rows)
                            {
                                lcSql += " UPDATE " + DB.SQLDatabase("COMUNES", "COMPRAS") + " SET BAJA = '', CODEMP = '', FBAJA = NULL " +
                                         " WHERE SERIE = " + DB.SQLString(itemSerie["SERIE"]) + " AND [ANY] = '" + lcEjercicio + "' ";
                            }

                            break;

                        case "C_ALBATR":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTALBTR") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "TRASPSER") + lcWhere + " ;";

                            break;

                        case "D_ALBATR":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTALBTR") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "TRASPSER") + lcWhere + " ;";

                            DB.SQLExec(" SELECT SERIE FROM " + DB.SQLDatabase("GESTION", "TRASPSER") + lcWhere, ref tablaConsulta);
                            foreach (DataRow itemSerie in tablaConsulta.Rows)
                            {
                                lcSql += " UPDATE " + DB.SQLDatabase("COMUNES", "COMPRAS") + " SET BAJA = '', CODEMP = '', FBAJA = NULL " +
                                         " WHERE SERIE = " + DB.SQLString(itemSerie["SERIE"]) + " AND [ANY] = '" + lcEjercicio + "' ";
                            }

                            break;

                        case "STOCKINI":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTSTINI") + lcWhere + " ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "INICIALSER") + lcWhere + " ;";

                            DB.SQLExec(" SELECT SERIE FROM " + DB.SQLDatabase("GESTION", "INICIALSER") + lcWhere, ref tablaConsulta);
                            foreach (DataRow itemSerie in tablaConsulta.Rows)
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "COMPRAS") +
                                         " WHERE SERIE = " + DB.SQLString(itemSerie["SERIE"]) + " AND [ANY] = '" + lcEjercicio + "' ";
                            }

                            break;

                        case "REGULARI":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTREGUL") + lcWhere + " ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "REGULARISER") + lcWhere + " ;";

                            DB.SQLExec(" SELECT SERIE FROM " + DB.SQLDatabase("GESTION", "REGULARISER") + lcWhere, ref tablaConsulta);
                            foreach (DataRow itemSerie in tablaConsulta.Rows)
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "COMPRAS") + 
                                         " WHERE SERIE = " + DB.SQLString(itemSerie["SERIE"]) + " AND [ANY] = '" + lcEjercicio + "' ";
                            }

                            break;

                        case "C_PROD":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTCPROD") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PRODUSERC") + lcWhere + " ;";

                            lcWhere = lcWhere.Replace("empresa", "codempcom");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "COMPRAS") + lcWhere + " AND [ANY] = '" + lcEjercicio + "' ";

                            break;

                        case "D_PROD":

                            if (EW_GLOBAL._ModuloActivo("LOTES"))
                            {
                                lcWhere = lcWhere.Replace("linea", "linia");
                                lcSql += " DELETE FROM " + DB.SQLDatabase("LOTES", "LTDPROD") + lcWhere + " AND PERIODO = '" + lcEjercicio + "' ;";
                            }

                            lcWhere = lcWhere.Replace("linia", "linea");
                            lcWhere = lcWhere.Replace("numero", "albaran");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("GESTION", "PRODUSER") + lcWhere + " ;";

                            DB.SQLExec(" SELECT SERIE FROM " + DB.SQLDatabase("GESTION", "PRODUSER") + lcWhere, ref tablaConsulta);
                            foreach (DataRow itemSerie in tablaConsulta.Rows)
                            {
                                lcSql += " UPDATE " + DB.SQLDatabase("COMUNES", "COMPRAS") + " SET BAJA = '', CODEMP = '', FBAJA = NULL " + 
                                         " WHERE SERIE = " + DB.SQLString(itemSerie["SERIE"]) + " AND [ANY] = '" + lcEjercicio + "' ";
                            }

                            break;

                        case "MULTCONF":

                            string[] subPos = lcWhere.Split('=');
                            if (subPos.Length == 2)
                                lcCodigo = subPos[1].TrimEnd();

                            DB.SQLExec(" SELECT codigo FROM " + DB.SQLDatabase("OFFLINE", "MULTCONF") + lcWhere, ref tablaConsulta);
                            if (tablaConsulta != null && tablaConsulta.Rows.Count > 0)
                                lcCodigo = tablaConsulta.Rows[0]["codigo"].ToString();

                            configura = new ConfComOffline(lcCodigo);
                            configura._Load();

                            lcSql += " DELETE FROM " + DB.SQLDatabase("OFFLINE", "TABNETCONF") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("OFFLINE", "SUCURCONF") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("OFFLINE", "USERCONF") + lcWhere + " ;";
                          
                            break;

                        case "ARQUEOS":

                            lcWhere = lcWhere.Replace("numero", "arqueo");
                            lcSql += " DELETE FROM " + DB.SQLDatabase("TPV", "D_ARQUEO") + lcWhere + " ;";
                            
                            lcSql += " UPDATE " + DB.SQLDatabase("TPV", "C_ALBVEN") + " SET ARQUEO = 0 " + lcWhere + " ;";
                            lcSql += " UPDATE " + DB.SQLDatabase("TPV", "TIKETS") + " SET ARQUEO = 0 " + lcWhere + " ;";

                            lcSql += " UPDATE " + DB.SQLDatabase("TPV", "REPOSI") + " SET ARQUEO = 0 " + lcWhere + " ;";
                            lcSql += " UPDATE " + DB.SQLDatabase("TPV", "COB_PAGO") + " SET ARQUEO = 0 " + lcWhere + " ;";

                            int lnPosInicio = lcWhere.IndexOf("and ejercicio");
                            int lnPosFinal = lcWhere.IndexOf("and arqueo");
                            lcWhere = lcWhere.Substring(0, lnPosInicio - 1) + " " + lcWhere.Substring(lnPosFinal);

                            lcSql += " UPDATE " + DB.SQLDatabase("OFFLINE", "CTRL_REPOS") + " SET ARQUEO = 0 " + lcWhere + " ;";
                            lcSql += " UPDATE " + DB.SQLDatabase("OFFLINE", "CTRL_REPOS") + " SET ARQUEO = 0 " + lcWhere + " ;";

                            break;

                        case "PEDINT_C":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "PEDINT_D") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "PEDINT_LIN") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "PEDINT_REG") + lcWhere + " ;";

                            break;

                        case "PEDINT_D":

                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "PEDINT_LIN") + lcWhere + " ;";
                            lcSql += " DELETE FROM " + DB.SQLDatabase("COMUNES", "PEDINT_REG") + lcWhere + " ;";

                            break;
                    }

                    try
                    {
                        DB.SQLExec(lcSql, out int lnFilasAfectadas);
                        Log_comoffDto logDto = logRepository.GetDto(datos);
                        logDto.TipoDato = lcTipoDato;
                        if (lnFilasAfectadas > 0)
                        {
                            logDto.Resultado = 1;
                            logDto.Detalle = "Se han eliminado " + lnFilasAfectadas + " registros en la tabla " + lcTabla + " en el grupo destino. " + Environment.NewLine +
                                             "Dichas eliminaciones se corresponden con datos eliminados en el grupo de empresa origen de los datos recibidos.";
                            logRepository.Insert(logDto);
                        }
                        else
                        {
                            logDto.Resultado = 3;
                            logDto.Detalle = "No se han podido eliminar registros en la tabla " + lcTabla + " porque no existían los datos a eliminar en el grupo de empresa destino de la recepción de datos. " + Environment.NewLine +
                                            "Dichas eliminaciones se corresponden con datos eliminados en el grupo de empresa origen de los datos recibidos.";
                            logRepository.Insert(logDto);
                        }
                    }
                    catch (Exception e)
                    {
                        Log_comoffDto logDto = logRepository.GetDto(datos);
                        logDto.TipoDato = lcTipoDato;
                        logDto.Resultado = 2;
                        logDto.Detalle = "Se ha producido un error en la gestión de la tabla Deletenet. Se descartará este registro. Excepción: " + e.Message;
                        logRepository.Insert(logDto);
                    }

                    if (lcTabla == "MULTCONF")
                    {
                        TareasProgramadasOffline tareap = new TareasProgramadasOffline(configura);
                        tareap.Delete();

                        lstTareasProg.Add(configura._Codigo + " - " + configura._Nombre);
                    }


                }
                catch (ChecksumDeleteNetException e)
                {
                    Log_comoffDto logDto = logRepository.GetDto(datos);
                    logDto.TipoDato = lcTipoDato;
                    logDto.Resultado = 2;
                    logDto.Detalle = "Se ha producido un error de validación de checksum de seguridad en la tabla Deletenet. Se descartará este registro. Excepción: " + e.Message;
                    logRepository.Insert(logDto);
                }
            }


            if (lstTareasProg.Count > 0)
            {
                Log_comoffDto logDto = logRepository.GetDto(datos);
                logDto.TipoDato = lcTipoDato;
                logDto.Resultado = 1;
                logDto.Detalle = "Eliminadas las siguientes tareas programadas de configuraciones de comunicaciones: ";

                foreach (string valor in lstTareasProg)
                {
                    logDto.Detalle += Environment.NewLine + valor;
                }

                logRepository.Insert(logDto);
            }

            return true;
        }

        internal static bool Download_UnZip_File(clsOfflineUtils.ReportProgress progressReporter, Action<string> callback)
        {
            bool llOk = true;

            _Mostrar_Progreso_Async -= OfflineDownloader__Mostrar_Progreso_Async;
            _Mostrar_Progreso_Async += OfflineDownloader__Mostrar_Progreso_Async;

            _cTempFolderName = string.Empty;

            if (!Directory.Exists(TempFolderName))
            {
                Directory.CreateDirectory(TempFolderName);
            }

            string cFile = "configura_offline.zip";

            llOk = UnZip_File(cFile);

            if (!ExistsFile(TempFolderName, cFile, callback))
            {
                return false;
            }
                

            _Mostrar_Progreso_Async -= OfflineDownloader__Mostrar_Progreso_Async;

            return llOk;

        }

        private static bool UnZip_File(string cFile)
        {
            IOfflineUnitOfWork offlineUnitOfWork = DependencyInjector.Instance.Retrieve<IOfflineUnitOfWork>();
            ILog_comoffRepository logRepository = offlineUnitOfWork.Log_comoffRepository;

            if (!UploadManager.Descargar_Fichero(TempFolderName, cFile, "", 0, false))
                return false;

            return true;
        }

        private static bool ExistsFile(string path, string fileName, Action<string> callback)
        {
            string lcFileFtp = Path.Combine(path, fileName);

            if (!File.Exists(lcFileFtp))
            {
                callback?.Invoke("No se ha encontrado el fichero de configuración en el FTP o OneDrive configurado.Revise que haya configurado correctamente los datos de conexión o bien asegurese que se ha realizado una Carga inicial o Envío de datos desde la Central.");

                //_TextStepDetalle = "ERROR: ######################################################## ";
                //_TextStepDetalle = "ERROR: No se puede continuar con la configuración del grupo de empresa porque no se ha encontrado fichero de configuración inicial en la carpeta FTP o OneDrive configurada, seleccione otra carpeta o realice una carga inicial o envío de datos desde la Central’.";
                //_TextStepDetalle = "ERROR: ######################################################## ";

                return false;
            }

            return true;
        }

    }
}