RgpdFileExportManager.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using sage.ew.interficies;
using sage.ew.db;
using sage.ew.global;
using System.IO;
using System.Windows.Forms;
using sage.ew.functions.Clases;
using Sage.ES.S50.Addons;

namespace sage.addons.rgpd
{
    internal static class RgpdFileExportManager
    {
        internal static IRgpdFileExportOperations _GeneradorFicherosExportacion
        {
            get 
            { 
                if(_oGeneradorFicherosExportacion == null)
                    _oGeneradorFicherosExportacion = new RgpdFileExportToCSV();
                return _oGeneradorFicherosExportacion; 
            }
            set { _oGeneradorFicherosExportacion = value; }
        }
        private static IRgpdFileExportOperations _oGeneradorFicherosExportacion = null;

        public static string _RutaFicheroGenerado
        {
            get { return _cRutaFicheroGenerado; }
            private set { _cRutaFicheroGenerado = value; }
        }
        private static string _cRutaFicheroGenerado = string.Empty;

        public static bool _Exportar(IRgpdInstanciaEntidad toOrigen, bool tlSolicitarRuta = true)
        {
            bool llResultadoExportacion = false;
            _cRutaFicheroGenerado = "";

            DataTable ldtDatos = obtenerDatosExportacion(toOrigen);

            if (_GeneradorFicherosExportacion != null && _GeneradorFicherosExportacion._Exportar(ldtDatos, tlSolicitarRuta))
            {
                llResultadoExportacion = true;
                _cRutaFicheroGenerado = _GeneradorFicherosExportacion._RutaFicheroGenerado;
            }

            return llResultadoExportacion;
        }

        private static DataTable obtenerDatosExportacion(IRgpdInstanciaEntidad toOrigen)
        {
            //string lcSql = "SELECT * FROM ";
            DataTable ldtResultados = new DataTable();

            //Obtener los campos de entidad_d asociados al origen
            var camposSensibles = obtenerCamposSensiblesDeLaEntidad(toOrigen._CodigoEntidad);

            //Por cada campo recuperado realizar un query filtrado por instancia 
            if (camposSensibles.Any())
            {
                StringBuilder sbSql = new StringBuilder();
                //Bug 131627 => Se modifica el query para que use un UNION ALL en vez de UNION para no suprimir resultados
                camposSensibles.ToList().ForEach(loCampo => sbSql.Append(queryCampoSensible(loCampo, toOrigen._CodigoInstancia) + (camposSensibles.Last() == loCampo ? "" : " UNION ALL ")));
                string lcQuerysConcatenados = sbSql.ToString();

                DB.SQLExec(lcQuerysConcatenados, ref ldtResultados);
            }
            return ldtResultados;
        }

        private static string queryCampoSensible(IRgpdCampoSensible toCampo, string tcCodigoInstania)
        {
            string lcSql = String.Empty;

            lcSql = "SELECT '" + toCampo._Nombre + "' AS DESCRIPCIONCAMPO, CAST(" + toCampo._Campo + " as nvarchar) COLLATE " + DB._ServerColation() + " AS VALORCAMPO " +
                    " FROM " + DB.SQLDatabase(toCampo._BaseDeDatos, toCampo._Tabla) +
                    " WHERE " + toCampo._CampoInstancia + " = " + DB.SQLString(tcCodigoInstania.TrimEnd());

            return lcSql;
        }

        private static IEnumerable<IRgpdCampoSensible> obtenerCamposSensiblesDeLaEntidad(string tcCodigoEntidad)
        {
            string lcSql = "SELECT CODENT, BBDD, TABLA, CAMPO, NOMBRE, CODTRATA, CODCATEG, PORTABLE, CAMPOINS FROM " + DB.SQLDatabase("RGPD", "ENTIDAD_D") +
                           " WHERE CODENT = " + DB.SQLString(tcCodigoEntidad.TrimEnd()) +
                           " AND PORTABLE = 1 " +
                           " AND CAMPOINS != '' "; 
            DataTable ldtResultados = new DataTable();
            List<IRgpdCampoSensible> listaCampos = new List<IRgpdCampoSensible>();

            //Recupero los datos de ENTIDAD_D
            if (DB.SQLExec(lcSql, ref ldtResultados) && ldtResultados.Rows.Count > 0)
            {
                ldtResultados.AsEnumerable().Cast<DataRow>().ToList().ForEach(loEle => listaCampos.Add(new CampoSensible(loEle)));
            }

            //TODO: Mejorar control excepción para Mayoristas que tiene registros pero puede no estar instalado
            object loObjeto = AddonsController.Instance.AddonsManager.GetAddon("MAYORIST");

            if (loObjeto == null)
                listaCampos = listaCampos
                    .Where(loEle => loEle._BaseDeDatos != "MAYORIST")
                    .ToList();

            return listaCampos;
        }
    }
}