BrowserData.cs

using sage.ew.db;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Linq;
using System.Text;
using System.Windows.Forms;

namespace Sage.ES.S50.Browser
{
    internal class BrowserData:sage.ew.interficies.IBrowserData
    {
        #region Camps privats

        private string _cSelect = "";
        private string ultimaConsulta;
        long registrosleidos = 0;

        // Objeto para la lectura por lotes
        BatchDataReader batchdatareader = new BatchDataReader();

        #endregion Camps privats



        #region Propietades

        private string _cTabla;
        public string _Tabla
        {
            get { return _cTabla; }
            set
            {
                _cTabla = value;
            }
        }

        private string _cGroupBy = "";
        public string _GroupBy
        {
            get { return _cGroupBy; }
            set { _cGroupBy = value; }
        }

        private string _cOrderBy;
        public string _OrderBy
        {
            get { return _cOrderBy; }
            set { _cOrderBy = value; }
        }

        private string _cCampo_Predet;
        public string _Campo_Predet
        {
            get { return _cCampo_Predet; }
            set { _cCampo_Predet = value; }
        }

        private string _cCampos;
        public string _Campos
        {
            get { return _cCampos; }
            set { _cCampos = value; }
        }
        
        private string _cCondicion;
        public string _Condicion
        {
            get { return _cCondicion; }
            set { _cCondicion = value; }
        }

        private string _cClave;
        public string _Clave
        {
            get { return _cClave; }
            set { _cClave = value; }
        }

        private string _cDataBase;
        public string _DataBase
        {
            get { return _cDataBase; }
            set { _cDataBase = value; }
        }

        private Dictionary<string, object> _cCodigo;
        public Dictionary<string, object> _Codigo
        {
            get { return _cCodigo; }
            set { _cCodigo = value; }
        }

        [Description("Muestra en modo 'Browser' el Datatable"), DefaultValue(null)]
        public DataTable _DatatablePersonalizado
        {
            get { return _dtDatatablePersonalizado; }
            set
            {
                _dtDatatablePersonalizado = value;
            }
        }
        private DataTable _dtDatatablePersonalizado = null;

        private string _cConsultaPersonalizada = "";
        public string _ConsultaPersonalizada
        {
            get { return _cConsultaPersonalizada; }
            set
            {
                _cConsultaPersonalizada = value;
            }
        }

        private DataTable resultado = null;
        public DataTable _Resultado
        {
            get
            {
                return resultado;
            }
            set { resultado = value; }
        }

        private bool _cSeleccion_Multiple = false;
        public bool _Seleccion_Multiple
        {
            get { return _cSeleccion_Multiple; }
            set { _cSeleccion_Multiple = value; }
        }

        #endregion


        #region Mètodes públics

        public void _Execute()
        {
            ExecutaConsulta();
        }

        #endregion Mètodes públics

        private void ExecutaConsulta()           
        {
            bool tbSoloEstructura = false;
            string tcFiltro = "";
            bool force = false;
            string sortcolumn = "";
            bool consultalistado = false;
            bool canviarordre = true;




            DataTable ldtResultado = new DataTable();

            
            string sqlresultados = string.Empty;
            string sqloriginal = string.Empty;
            string lcFrom = string.Empty;
            string lcWhere = string.Empty;
            string lcOrderBy = string.Empty;
            string lcGroupBy = string.Empty;


            //Console.WriteLine(String.Format("{0:00}:{1:00}:{2:00}.{3:00}", DateTime.Now.Hour, DateTime.Now.Minute, DateTime.Now.Second, DateTime.Now.Millisecond / 10) + " - Browser.ExecutaConsulta (inici)");
            //Stopwatch stopWatch = new Stopwatch();
            //stopWatch.Start();

            if (_DatatablePersonalizado == null)
            {
                // PE-95408. Si se ha pasada consulta personalizada, la utilizamos
                if (!string.IsNullOrWhiteSpace(_ConsultaPersonalizada))
                {
                    sqloriginal = AnalizeSql(_ConsultaPersonalizada);
                }
                else
                {
                    sqloriginal = MountSql();
                }


                //if (_dtGrid == null || _dtGrid.Rows.Count == 0 || tcFiltro != _cFiltro || force)
                //{
                //    lcWhere = "";
                //    _cFiltro = tcFiltro;

                //    if (tbSoloEstructura)
                //        lcWhere = " Where 1 = 0";
                //    else
                //    {
                if (!string.IsNullOrWhiteSpace(tcFiltro))
                {
                    //if (!string.IsNullOrWhiteSpace(lcWhere))
                    //    lcWhere = lcWhere + " And ";
                    lcWhere = lcWhere + " Where " + tcFiltro;
                }
                //    }

                // Montem la consulta del resultat
                sqlresultados = "Select ";//Top " + maxregistros.ToString() + " ";
                if (_Seleccion_Multiple)
                {
                    sqlresultados += DB.SQLFalse() + " as selected, ";
                }
                sqlresultados += "* From (";
                sqlresultados += sqloriginal;
                sqlresultados += ") as sqlresult ";
                sqlresultados += lcWhere;

                // Sólo ordenamos el resultado con datos
                if (!tbSoloEstructura)
                {
                    //if (!String.IsNullOrEmpty(_CondicionAutomatica))
                    //{
                    //    canviarordre = false;
                    //    sortedcolumn = sortcolumn = !this._Clave.Contains(",") ? this._Clave : (this._Clave.Contains(",") && this._Clave.Split(',').Where(f => f.ToLower() == "codigo").Count() > 0) ? "CODIGO" : "";
                    //}

                    if (string.IsNullOrWhiteSpace(sortcolumn))
                    {
                        //if (timerexecutaconsulta._Selcol > 0)
                        //{
                        //    sortcolumn = timerexecutaconsulta._Selcol.ToString();
                        //    canviarordre = false;
                        //}
                    }

                    // Si no hay que ordenar por columna
                    if (string.IsNullOrWhiteSpace(sortcolumn))
                    {
                        //sortedcolumn = "";

                        // Order by
                        if (!string.IsNullOrWhiteSpace(lcOrderBy))
                        {
                            string orderby = "";
                            string coma = "";

                            // Agafem els camps per saber la posició dels camps de l'order by
                            string[] aliascamps = _cSelect.Split(',');

                            // Treure els alias
                            string[] orderbycamps = lcOrderBy.Split(',');
                            foreach (string orderbycamp in orderbycamps)
                            {
                                string lowercamp = orderbycamp.ToLower().Trim();
                                string orderbyascdesc = "";

                                if (lowercamp.Contains(" desc"))
                                {
                                    orderbyascdesc = " desc ";
                                    lowercamp = lowercamp.Replace(" desc", "");
                                }

                                if (lowercamp.Contains(" asc"))
                                {
                                    orderbyascdesc = " asc ";
                                    lowercamp = lowercamp.Replace(" asc", "");
                                }

                                // Busco la posició del camp order dins del select
                                int poscamporderby = -1;
                                for (int i = 0; i < aliascamps.Length; i++)
                                {
                                    string loweralias = aliascamps[i].ToLower().Trim();

                                    if (loweralias.Contains(lowercamp))
                                    {
                                        poscamporderby = i + 1;
                                        break;
                                    }
                                }

                                if (poscamporderby > -1)
                                {
                                    orderby += coma + poscamporderby.ToString() + orderbyascdesc;

                                    coma = ", ";
                                }
                                else
                                {
                                    // Bug 132053. Si el campo del order by no está en el resultado de la consulta, no lo usamos.
                                    //int pospunt = orderbycamp.IndexOf('.');
                                    //if (pospunt != -1)
                                    //{
                                    //    orderby += coma + orderbycamp.Substring(pospunt + 1);
                                    //}
                                    //else
                                    //{
                                    //    orderby += coma + orderbycamp;
                                    //}

                                    //coma = ", ";
                                }

                            }

                            sortcolumn = orderby;
                            //sqlresultados += " Order by " + orderby;
                        }
                    }

                    if (!string.IsNullOrWhiteSpace(sortcolumn))
                    {
                        // Forzamos el orden del encabezado de columna
                        if (canviarordre)
                        {
                            //if (sortedcolumn == sortcolumn && (!sortcolumn.Contains(" Desc ") || sortcolumn.Length > 6 && sortcolumn.Trim().ToLower().Substring(sortcolumn.Trim().Length - 4) != "desc") && !consultalistado)
                            //{
                            //    sortcolumn += " Desc ";
                            //}
                            //else
                            //{
                            //    if (sortcolumn.Length > 6 && sortcolumn.Trim().ToLower().Substring(sortcolumn.Trim().Length - 4) == "desc")
                            //    {
                            //        sortcolumn = sortcolumn.Substring(0, sortcolumn.Length - 6);
                            //    }
                            //}
                        }
                        else
                        {
                            //sortcolumn = sortedcolumn;
                        }

                        // CCR 154358. Si no hay sortcolumn, no añadir Order by
                        if (!string.IsNullOrWhiteSpace(sortcolumn))
                        {
                            sqlresultados += " Order by " + sortcolumn;
                        }
                    }

                    //sortedcolumn = sortcolumn;
                }

                canviarordre = true;

                // CCR 137276. Si s'ha de mostrar llistat, excel... agafem tots els registres tenint en compte els filtres
                if (consultalistado)
                {
                    // Executem
                    DB.SQLExec(sqlresultados, ref ldtResultado);
                }
                else
                {
                    //Procesar_Resultados_Seleccion_Multiple();

                    ultimaConsulta = sqlresultados;

                    batchdatareader._MaxResults = 100;
                    batchdatareader._Sqlquery = sqlresultados;
                    batchdatareader._Read();

                    if (!string.IsNullOrWhiteSpace(batchdatareader._Error_Message))
                    {
                       sage.ew.functions.FUNCTIONS._MessageBox("Se han producido incidencias en la ejecución de la consulta SQL." + Environment.NewLine +
                                    "Se mostrarán los datos de la configuración original." + Environment.NewLine + Environment.NewLine +
                                    "Incidencias:" + Environment.NewLine + batchdatareader._Error_Message, MessageBoxButtons.OK, MessageBoxIcon.Error, MessageBoxDefaultButton.Button1, DialogResult.OK);

                        // Si hay consulta personalizada, la sacamos para que muestre el resultado original
                        if (!string.IsNullOrWhiteSpace(_ConsultaPersonalizada))
                        {
                            _ConsultaPersonalizada = "";
                            _cSelect = "";
                            ExecutaConsulta();
                        }
                    }

                    ldtResultado = batchdatareader._Resultados;
                    registrosleidos = batchdatareader._RowsRead;

                    // Si se ha incluido la columna selected, hay que sacarle el readonly
                    if (_Seleccion_Multiple)
                    {
                        ldtResultado.Columns["selected"].ReadOnly = false;
                    }

                    //Marcar_Seleccion_Multiple();
                }
                //}
                //else
                //{
                //    // Si no ha cambiado nada en la consulta, devolvemos el mismo datatable
                //    return _dtGrid;
                //}
            }
            else
            {
                // Si hay un DataTable personalizado, devolvemos el mismo datatable
                ldtResultado = _DatatablePersonalizado;
            }

            //stopWatch.Stop();
            //TimeSpan ts = stopWatch.Elapsed;
            //Console.WriteLine(String.Format("{0:00}:{1:00}:{2:00}.{3:00}", DateTime.Now.Hour, DateTime.Now.Minute, DateTime.Now.Second, DateTime.Now.Millisecond / 10) + " - Browser.ExecutaConsulta (final) " + String.Format("{0:00}:{1:00}:{2:00}.{3:00}", ts.Hours, ts.Minutes, ts.Seconds, ts.Milliseconds / 10));

            //this.ewcheckboxSelTodosCap.Checked = false;

            _Resultado = ldtResultado;
        }

        private string AnalizeSql(string consultapersonalizada)
        { 
            string sqloriginal = consultapersonalizada;
            string lcFrom = string.Empty;
            string lcWhere = string.Empty;
            string lcOrderBy = string.Empty;
            string lcGroupBy = string.Empty;

            // N'agafem les diferents parts
            int lnPosSelect = consultapersonalizada.ToLower().IndexOf("select", StringComparison.OrdinalIgnoreCase);
            int lnPosFrom = consultapersonalizada.ToLower().IndexOf("from", StringComparison.OrdinalIgnoreCase);
            int lnPosWhere = consultapersonalizada.ToLower().LastIndexOf("where", StringComparison.OrdinalIgnoreCase);
            int lnPosGroupBy = consultapersonalizada.ToLower().LastIndexOf("group by", StringComparison.OrdinalIgnoreCase);
            int lnPosOrderBy = consultapersonalizada.ToLower().LastIndexOf("order by", StringComparison.OrdinalIgnoreCase);


            // El select només lo montem una vegada
            if (string.IsNullOrWhiteSpace(_cSelect))
            {
                // Select fins al From
                _cSelect = consultapersonalizada.Substring(lnPosSelect + 6, lnPosFrom - (lnPosSelect + 6));

                // Busco els noms del camps per utilitzarlos als filtres
                int lnPosAs = 0;
                //int lnPosComa = 0;
                int lnLenAs = 0;
                int lnPosPunt = 0;

                string lcSelect = _cSelect;
                string lcamp = "";
                string lcAlias = "";

                do
                {
                    // Pot ser que el camp no tingui alias
                    lnPosAs = lcSelect.ToLower().IndexOf(" as ");
                    //lnPosComa = lcSelect.IndexOf(",");

                    //if (lnPosAs == -1 || (lnPosComa > 0 && lnPosAs > lnPosComa))
                    //{
                    //    lnPosAs = lnPosComa;
                    //    lnLenAs = 2;
                    //}
                    //else
                    //{
                    lnLenAs = 3;
                    //}

                    if (lnPosAs != -1)
                    {
                        // la part esquerra és el camp o l'expressió
                        lcAlias = lcSelect.Substring(0, lnPosAs).Trim();

                        if (lnLenAs != 2)
                        {
                            lcSelect = lcSelect.Substring(lnPosAs + lnLenAs).Trim();
                        }

                        // busquem la coma per al 
                        lnPosAs = lcSelect.IndexOf(",");
                        if (lnPosAs == -1)
                            lcamp = lcSelect.Substring(0).Trim();
                        else
                        {
                            lcamp = lcSelect.Substring(0, lnPosAs).Trim();
                            lcSelect = lcSelect.Substring(lnPosAs + 1).Trim();
                        }

                        // És possible que al lcCamp li hagi quedat el alias de la taula
                        lnPosPunt = lcamp.IndexOf(".");
                        if (lnPosPunt != -1)
                        {
                            lcamp = lcamp.Substring(lnPosPunt + 1).Trim();
                        }

                        //_cAliasCamps.Add(lcamp, lcAlias);
                    }

                } while (lnPosAs != -1);
            }

            // El From arribarà fins la primera clausula que tingui la consulta
            if (lnPosWhere != -1)
                lcFrom = consultapersonalizada.Substring(lnPosFrom + 4, lnPosWhere - (lnPosFrom + 4));
            else if (lnPosGroupBy != -1)
                lcFrom = consultapersonalizada.Substring(lnPosFrom + 4, lnPosGroupBy - (lnPosFrom + 4));
            else if (lnPosOrderBy != -1)
                lcFrom = consultapersonalizada.Substring(lnPosFrom + 4, lnPosOrderBy - (lnPosFrom + 4));
            else
                lcFrom = consultapersonalizada.Substring(lnPosFrom + 4);

            // El Where. Que també fins la propera clausula que tingui la consulta
            if (lnPosWhere != -1)
            {
                if (lnPosGroupBy != -1)
                    lcWhere = consultapersonalizada.Substring(lnPosWhere + 6, lnPosGroupBy - (lnPosWhere + 6));
                else if (lnPosOrderBy != -1)
                    lcWhere = consultapersonalizada.Substring(lnPosWhere + 6, lnPosOrderBy - (lnPosWhere + 6));
                else
                    lcWhere = consultapersonalizada.Substring(lnPosWhere + 6);

                // PE-104293. Si hay where ponemos parentesis por si hay algun Or
                if (!string.IsNullOrWhiteSpace(lcWhere))
                {
                    lcWhere = "(" + lcWhere + ")";
                }
            }

            // El Group By. Que també fins la propera clausula que tingui la consulta
            if (lnPosGroupBy != -1)
            {
                if (lnPosOrderBy != -1)
                    lcGroupBy = consultapersonalizada.Substring(lnPosGroupBy + 8, lnPosOrderBy - (lnPosGroupBy + 8));
                else
                    lcGroupBy = consultapersonalizada.Substring(lnPosGroupBy + 8);
            }

            // El Order By sempres ha de ser l'últim
            if (lnPosOrderBy != -1)
            {
                lcOrderBy = consultapersonalizada.Substring(lnPosOrderBy + 8);
                sqloriginal = sqloriginal.Substring(0, lnPosOrderBy - 1);
            }

            return sqloriginal;
        }

        private string MountSql()
        {
            string sqloriginal = string.Empty;
            string lcFrom = string.Empty;
            string lcWhere = string.Empty;
            string lcOrderBy = string.Empty;
            string lcGroupBy = string.Empty;
            string lcCampos_No_Visibles = string.Empty;

            // Select
            if (string.IsNullOrWhiteSpace(_cSelect))
            {
                // Si tenemos campos no visibles
                //if (string.IsNullOrWhiteSpace(this._cCampos_No_Visibles) == false)
                //{
                //    // solo añadiremos los que no están en _cCampos
                //    string[] campsnovisibles = this._Campos_No_Visibles.ToLower().Split(',');
                //    string[] campos = this._cCampos.ToLower().Split(',');

                //    foreach (string campnovisible in campsnovisibles)
                //    {
                //        if (!campos.Contains(campnovisible))
                //        {
                //            // Agregamos la coma para posteriormente poder añadir el resto de campos
                //            lcCampos_No_Visibles += "," + campnovisible;
                //        }
                //    }
                //}

                _cSelect = this._cCampos + lcCampos_No_Visibles;// + this._cCampsAgregats;
            }

            // From
            lcFrom = DB.SQLDatabase(this._cDataBase, this._cTabla);

            // Where
            if (!string.IsNullOrWhiteSpace(this._cCondicion))
                lcWhere = this._cCondicion;

            // Group by
            if (!string.IsNullOrWhiteSpace(_cGroupBy))
                lcGroupBy = _cGroupBy;

            // Order
            if (!string.IsNullOrWhiteSpace(_cOrderBy))
                lcOrderBy = _cOrderBy;
            else if (!string.IsNullOrWhiteSpace(_cCampo_Predet))
                lcOrderBy = _cCampo_Predet;

            sqloriginal = "Select ";
            sqloriginal += _cSelect;
            sqloriginal += " From " + lcFrom;
            sqloriginal += !string.IsNullOrWhiteSpace(lcWhere) ? " Where " + lcWhere : "";
            sqloriginal += !string.IsNullOrWhiteSpace(lcGroupBy) ? " Group By " + lcGroupBy : "";
            //sqloriginal += !string.IsNullOrWhiteSpace(lcOrderBy) ? " Order By " + lcOrderBy : "";

            return sqloriginal;
        }
    }
}