StockInicialProcesoMigracion.cs

using sage.ew.db;
using sage.ew.ewbase;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;

namespace sage.ew.serie.Clases
{
    public class StockInicialProcesoMigracion
    {
        #region Variables privadas

        private bool _usarDatosHisserie = true;

        #region Tablas temporales

        private const string TEMPCOMPRAS = @"#TMPCOMPRAS";
        private const string TEMPSTOCKINI = @"#TMPSTOCKINI";
        private const string TEMPINICIALSER = @"#TMPINICIALSER";
        private const string TEMPTRASP = @"#TMPTRASP";

        #endregion Tablas temporales

        #endregion Variables privadas

        #region Propiedades 

        public string EjercicioAnterior
        {
            get { return _Anterior.Ejercicio; }
        }
        PeriodoItem _Anterior = null;

        public string Ejercicio
        {
            get { return _Actual.Ejercicio; }
        }
        PeriodoItem _Actual = null;

        public string Mensaje { get; private set; } = string.Empty;

        public bool Restultado { get; private set; } = false;

        #endregion Propiedades 

        #region Constructores

        private StockInicialProcesoMigracion() { }

        public StockInicialProcesoMigracion(string ejercicio) : this()
        {
            _Actual = Periodos.Instancia.GetPeriodo(ejercicio);
            _Anterior = Periodos.Instancia.GetPeriodoAnteriorAl(ejercicio);
        }

        #endregion Constructores

        #region Métodos públicos

        public void Execute()
        {
            //Sino supera las validaciones previas acabo
            if (!ValidacionesPrevias())
                return;

            var query = string.Empty;

            //Obtiene el query de borrado de tablas temporales (por si acaso)
            query += GetQuery_BorrarTablasTemporales();

            //Obtengo la instrucción de borrado de datos previos en stockini (presuntamente ha de estar vacio para articulos de series)
            query += GetQuery_BorrarArticulosDeSeriesDeStockIni();

            //Obtengo la instrucción de borrado de datos previos en INICIALSER (presuntamente ha de estar vacio)
            query += GetQuery_BorrarArticulosDeSeriesDeInicialser();

            //Obtengo el query que creará los orínenes de datos
            query += GetQuery_CrearOrigenesDeDatos();

            //Obtengo el query para insertar registros 
            query += GetQuery_InsertarRegistros();

            //Obtiene el query de borrado de tablas temporales
            query += GetQuery_BorrarTablasTemporales();

            //Ejecuto todas las operaciones
            Restultado = DB.SQLExec(query);
        }

        #endregion Métodos públicos

        #region Métodos privados

        private string GetQuery_BorrarTablasTemporales()
        {
            var query = string.Empty;

            query += $"IF EXISTS (SELECT * FROM tempdb.dbo.sysobjects WHERE ID = OBJECT_ID(N'tempdb..{TEMPCOMPRAS}')) BEGIN DROP TABLE {TEMPCOMPRAS} END; " + Environment.NewLine;
            query += $"IF EXISTS (SELECT * FROM tempdb.dbo.sysobjects WHERE ID = OBJECT_ID(N'tempdb..{TEMPSTOCKINI}')) BEGIN DROP TABLE {TEMPSTOCKINI} END; " + Environment.NewLine;
            query += $"IF EXISTS (SELECT * FROM tempdb.dbo.sysobjects WHERE ID = OBJECT_ID(N'tempdb..{TEMPINICIALSER}')) BEGIN DROP TABLE {TEMPINICIALSER} END; " + Environment.NewLine;
            query += $"IF EXISTS (SELECT * FROM tempdb.dbo.sysobjects WHERE ID = OBJECT_ID(N'tempdb..{TEMPTRASP}')) BEGIN DROP TABLE {TEMPTRASP} END; " + Environment.NewLine;

            return query;
        }

        private bool ValidacionesPrevias()
        {

            //Ha de tener ejercicio anterior
            if (!Periodos.Instancia.ExisteEjercicioAnteriorAl(_Actual.Ejercicio))
            {
                Restultado = true; //El resultado es true pq no implica error, simplemente el proceso es innecesario
                Mensaje = "No existe ejercicio anterior.";
                return false;
            }

            //Que trabaje con series
            if (!InstalacionConSeries())
            {
                Restultado = true; //El resultado es true pq no implica error, simplemente el proceso es innecesario
                Mensaje = "La instalación no trabaja con series.";
                return false;
            }

            return true;
        }

        private bool InstalacionConSeries()
        {
            //Lo ideal sería usar EW_GLOBAL => Convert.ToBoolean(EW_GLOBAL._GetVariable("wl_series", false)) pero no esta cargada 
            //por lo que iremos a por los valores en tablas => GESTION.CONTADOR campo SERIES. El uso de series debería ser uniforme por todas las empresas de un grupo
            var sql = $"SELECT TOP (1) * FROM {DB.SQLDatabase(_Actual.Ejercicio, "CONTADOR")} WHERE SERIES = 8758 OR SERIES = 8578 ";
            var datos = new DataTable();
            if (DB.SQLExec(sql, ref datos) && datos.Rows.Count > 0)
            {
                return true;
            }
            return false;
        }

        private string GetQuery_InsertarRegistros()
        {
            var query = string.Empty;

            //STOCKINI
            query += $"INSERT INTO {DB.SQLDatabase(_Actual.Ejercicio, "STOCKINI")} (EMPRESA, ALMACEN, FECHA, ARTICULO, UNIDADES, LINIA, PMCOM, DEPCOM) " + Environment.NewLine +
                    $"(" + Environment.NewLine +
                    $"  SELECT STOCKINI.EMPRESA, STOCKINI.ALMACEN, {DB.SQLString(_Actual.PeriodoIni)} as FECHA, STOCKINI.ARTICULO, STOCKINI.SERIES as UNIDADES, " + Environment.NewLine +
                    "       (SELECT STR(COALESCE(MAX(NUMLINEA.LINIA) + STOCKINI.NUMLIN, STOCKINI.NUMLIN), 5) AS NUMERO " + Environment.NewLine + //Autocalcula el número de línea
                    $"      FROM {DB.SQLDatabase(_Actual.Ejercicio, "STOCKINI")} NUMLINEA " + Environment.NewLine +
                    "       WHERE NUMLINEA.EMPRESA = STOCKINI.EMPRESA " + Environment.NewLine +
                    "         AND NUMLINEA.ALMACEN = STOCKINI.ALMACEN " + Environment.NewLine +
                    $"        AND NUMLINEA.FECHA = {DB.SQLString(_Actual.PeriodoIni)} " + Environment.NewLine +
                    "       ) as LINIA, STOCKINI.COSTE AS PMCOM, STOCKINI.DEPOSITO AS DEPCOM " + Environment.NewLine +
                    $"  FROM {TEMPSTOCKINI} as STOCKINI" + Environment.NewLine +
                    $"); " + Environment.NewLine;

            //Ahora en stockini tenemos números de linea nuevos que hay que usar para informar INICIALSER y HISSERIE, volcamos a temporal
            query += $"SELECT STOCKINI.EMPRESA, STOCKINI.ALMACEN, STOCKINI.FECHA, STOCKINI.LINIA as LINEA, STOCKINI.ARTICULO, COMPRAS.SERIE, " + Environment.NewLine +
                     $"       COMPRAS.LINEA as NUMERO, Cast(0 as bit) as BAJA, Cast(0 as bit) as MODELO, " + Environment.NewLine +
                     $"       (CASE COMPRAS.DEPOSITO WHEN 'D' THEN Cast(1 as bit) ELSE Cast(0 as bit) END) as DEPOSITO " + Environment.NewLine +
                     $"INTO {TEMPINICIALSER} " + Environment.NewLine +
                     $"FROM (" + Environment.NewLine +
                     $"         SELECT STOCKINI.EMPRESA, STOCKINI.ALMACEN, STOCKINI.FECHA, STOCKINI.ARTICULO, STOCKINI.LINIA " + Environment.NewLine +
                     $"         FROM {DB.SQLDatabase(_Actual.Ejercicio, "STOCKINI")} " + Environment.NewLine +
                     $"         INNER JOIN({GetQuery_ArticulosDeSeries(_Anterior.Ejercicio)}) ARTICULO ON STOCKINI.ARTICULO = ARTICULO.ARTICULO " + Environment.NewLine +
                     $"     ) STOCKINI " + Environment.NewLine +
                     $"LEFT JOIN( " + Environment.NewLine +
                     $"             SELECT ARTICULO, ALMACEN, SERIE, DEPOSITO, ROW_NUMBER() OVER(PARTITION BY EMPRESA, ALMACEN, ARTICULO order by EMPRESA, ALMACEN, ARTICULO) as LINEA " + Environment.NewLine +
                     $"             FROM {TEMPCOMPRAS} " + Environment.NewLine +
                     $"         ) COMPRAS ON COMPRAS.ARTICULO = STOCKINI.ARTICULO AND COMPRAS.ALMACEN = STOCKINI.ALMACEN ; " + Environment.NewLine;

            //Insertamos en INICIALSER
            query += $"INSERT {DB.SQLDatabase(_Actual.Ejercicio, "INICIALSER")} (EMPRESA, ALMACEN, FECHA, LINEA, ARTICULO, SERIE, NUMERO, BAJA, MODELO, DEPOSITO) " + Environment.NewLine +
                     $"       (SELECT EMPRESA, ALMACEN, FECHA, LINEA, ARTICULO, SERIE, NUMERO, BAJA, MODELO, DEPOSITO FROM {TEMPINICIALSER}) ;" + Environment.NewLine;

            //Ahora hay que insertar el registro del movimiento en HISSERIE
            query += $"INSERT INTO {DB.SQLDatabase("COMUNES", "HISSERIE")} " +
                        "(SERIE,FECHA,HORA,DOCUMENTO,NUMERO,CUENTA,MOVIMIENTO,USUARIO,COSTE,PRECIO,OBSERVA,ORDENADOR,EMPRESA,ALMACEN,MODELO, IGNORAR, FECHADOC) " + Environment.NewLine +
                        "(SELECT SERIE," +
                                 DB.SQLString(DateTime.Now.ToString("d")) + ", " + //FECHA
                                 DB.SQLString(DateTime.Now.ToString("T")) + ", " + //HORA
                                "'INICIAL', " + //DOCUMENTO
                                "'' , " + //NUMERO
                                "'INICIAL', " + //CUENTA
                                "'A', " + //MOVIMIENTO
                                "'ACTUALIZACION', " + //USUARIO
                                "0, " + //COSTE
                                "0, " + //PRECIO
                                "'', " + //OBSERVA
                                DB.SQLString(Environment.MachineName.Trim().ToUpper()) + ", " + //ORDENADOR
                                "EMPRESA, " + //EMPRESA
                                "ALMACEN, " + //ALMACEN
                                "'', " + //MODELO
                                " CAST(0 as BIT), " +  //CCR 148577
                                DB.SQLString(_Actual.PeriodoIni) + " " +
                         $"FROM {TEMPINICIALSER} ) ;" + Environment.NewLine;

            return query;
        }

        private string GetQuery_CrearOrigenesDeDatos()
        {
            #region Datos STOCKINSER

            //Obtener datos de stockinser
            string queryOrigenDatos = GetQuery_ObtenerSeriesDeStockInSer();

            //Incorporo los costes y la marca de deposito a los datos
            queryOrigenDatos = $@"SELECT DATOS.* " + Environment.NewLine +
                               $"INTO {TEMPCOMPRAS} " + Environment.NewLine +
                               $"FROM ({queryOrigenDatos}) AS DATOS; " + Environment.NewLine; 

            #region Corrección eventuales cambios de almacen

            //Creo tabla temporal de cambios de almacen
            queryOrigenDatos += QueryCrearTablaTemporal_TraspasosAlmacen() + "; ";

            //Actualizo los datos de la tabla temporal de compras con los datos de cambio de almacén
            queryOrigenDatos += $"UPDATE A set A.ALMACEN = B.ALMACEN " + Environment.NewLine +
                                $"FROM  {TEMPCOMPRAS}  AS A," + Environment.NewLine +
                                $"(" + Environment.NewLine +
                                $"   SELECT x.SERIE, x.ALMACEN FROM {TEMPTRASP} x " + Environment.NewLine +
                                $") AS B" + Environment.NewLine +
                                $"WHERE A.SERIE = B.SERIE; " + Environment.NewLine;


            #endregion Corrección eventuales cambios de almacen

            #endregion Datos COMPRAS e STOCKINSER

            #region Datos para STOCKINI

            queryOrigenDatos += "SELECT EMPRESA, ALMACEN, ARTICULO, COUNT(*) AS SERIES, " + Environment.NewLine +
                                "       ROUND(SUM(COSTE)/COUNT(*),2) AS COSTE, " + Environment.NewLine +
                                "       SUM(CASE DEPOSITO WHEN 'D' THEN 1 ELSE 0 END) AS DEPOSITO, " + Environment.NewLine +
                                "       ROW_NUMBER() OVER(PARTITION BY EMPRESA, ALMACEN order by EMPRESA, ALMACEN, ARTICULO) as NUMLIN " + Environment.NewLine +
                                $"INTO {TEMPSTOCKINI} FROM {TEMPCOMPRAS} " + Environment.NewLine +
                                "GROUP BY EMPRESA, ALMACEN, ARTICULO ; " + Environment.NewLine + Environment.NewLine;

            #endregion Datos para STOCKINI

            return queryOrigenDatos;
        }

        private string QueryCrearTablaTemporal_TraspasosAlmacen()
        {
            //Movimientos entre almacenes para determinar el almacen a fecha de apertura

            var query = "SELECT DATOS.* " +
                        $"INTO {TEMPTRASP} " +
                        "FROM (" + Environment.NewLine +
                                        "SELECT SERIE.SERIE, SERIE.ARTICULO, DOCUMENTO.FECHA, DOCUMENTO.ALMORIG AS ALMACEN, DOCUMENTO.ALMDEST, 'TRASPASO' as TIPOMOV, " + Environment.NewLine +
                                                CamposHisserie() + ", ROW_NUMBER() OVER(PARTITION BY SERIE.SERIE ORDER BY DOCUMENTO.Fecha ASC ) AS fila" + Environment.NewLine +
                                        $"FROM {DB.SQLDatabase(_Actual.Ejercicio, "TRASPSER")} SERIE " + Environment.NewLine +
                                        $"INNER JOIN {DB.SQLDatabase(_Actual.Ejercicio, "C_ALBATR")} DOCUMENTO ON DOCUMENTO.EMPRESA = SERIE.EMPRESA " +
                                                          "AND DOCUMENTO.NUMERO = SERIE.ALBARAN " + Environment.NewLine +
                                        $"INNER JOIN {DB.SQLDatabase(_Actual.Ejercicio, "D_ALBATR")} DETALLE ON DETALLE.EMPRESA = SERIE.EMPRESA " +
                                                       "AND DETALLE.NUMERO = SERIE.ALBARAN " +
                                                       "AND DETALLE.LINIA = SERIE.LINEA " +
                                                       "AND DETALLE.ARTICULO = SERIE.ARTICULO " + Environment.NewLine +
                                        LeftJoinHisserie(documento: "TRASPASO") + " " + Environment.NewLine +
                        ") DATOS WHERE DATOS.FILA = 1 " + Environment.NewLine; //Sólo me interesa el más antiguo

            return query;
        }

        #region Métodos comunes de HISSERIE

        private string CamposHisserie()
        {
            var campos = "";
            if (_usarDatosHisserie)
            {
                campos = "HISSERIE.FECHAMOV, HISSERIE.MOVIMIENTO " + Environment.NewLine;
                //HISSERIE.FECHAMOV => Es un campo construido
                //campos = "       HISSERIE.FECHA + HISSERIE.HORA as FECHAMOV, HISSERIE.MOVIMIENTO " + Environment.NewLine;
            }
            return campos;
        }

        private string LeftJoinHisserie(string documento)
        {
            var query = "";
            if (_usarDatosHisserie)
            {
                var tipoMovimiento = "(MOVIMIENTO = 'A' OR MOVIMIENTO = 'B')";
                var joinClause = "SERIE.SERIE = HISSERIE.SERIE ";
                switch (documento)
                {
                    case "VENTA":
                        joinClause += " AND RTRIM(SERIE.ALBARAN) +LTRIM(RTRIM(SERIE.LETRA)) = RTRIM(HISSERIE.NUMERO) ";
                        break;
                    case "DEPOSITO":
                        joinClause += " AND RTRIM(SERIE.DEPOSITO) +LTRIM(RTRIM(SERIE.LETRA)) = RTRIM(HISSERIE.NUMERO) ";
                        break;

                    case "MODELO":
                    case "REGULARI":
                        joinClause += " AND RTRIM(SERIE.DOCUMENTO) = RTRIM(HISSERIE.NUMERO) ";
                        break;

                    case "PRODUC":      //Consumo en producción
                    case "PRODUCCION":  //Alta por producción
                    case "TRANSFORM":   //Consumo en transformación
                    case "TRANSFORMA":  //Alta por transformación
                    case "ALBAREGU":
                    case "DEPCOM":
                        joinClause += " AND RTRIM(SERIE.ALBARAN) = RTRIM(HISSERIE.NUMERO) ";
                        break;

                    case "TRASPASO":
                        tipoMovimiento = "MOVIMIENTO = 'M' ";
                        joinClause += " AND RTRIM(SERIE.ALBARAN) = RTRIM(HISSERIE.NUMERO) ";
                        break;

                    case "SERVICIO":    //Entragada a técnico o entrada en un servicio
                        joinClause += " AND RTRIM(SERIE.SERVEI) = RTRIM(HISSERIE.NUMERO) ";
                        break;

                    case "ORDENES":    //Entragada a técnico o entrada en un servicio
                        joinClause += " AND RTRIM(SERIE.ORDRE) = RTRIM(HISSERIE.NUMERO) ";
                        break;

                    case "MONTAJE":    //Solo informa la baja, no informa cuenta ni modelo ni nada
                        joinClause += " AND HISSERIE.CUENTA = '' AND HISSERIE.NUMERO = '' ";
                        break;

                    case "COMPRA":
                        joinClause += " AND RTRIM(SERIE.ALBARAN) = RTRIM(HISSERIE.NUMERO) AND SERIE.PROVEEDOR = HISSERIE.CUENTA ";
                        break;

                    case "INICIAL":
                        joinClause += " AND RTRIM(SERIE.EMPRESA) = RTRIM(HISSERIE.DOCUMENTO) ";
                        break;
                    default:
                        //Sin clausula adicional o no contemplada
                        break;
                }

                query = "LEFT JOIN ( " + Environment.NewLine +
                        "   SELECT SERIE, MAX(FECHA +HORA) AS FECHAMOV, NUMERO, MAX(MOVIMIENTO) AS MOVIMIENTO, MAX(DOCUMENTO) AS DOCUMENTO, MAX(CUENTA) AS CUENTA " + Environment.NewLine +
                        $"  FROM { DB.SQLDatabase("COMUNES", "HISSERIE")} " + Environment.NewLine +
                        $"  WHERE DOCUMENTO = '{documento}' AND {tipoMovimiento} AND IGNORAR = 0 " + Environment.NewLine +
                        "   GROUP BY SERIE, NUMERO, FECHA " + Environment.NewLine +
                        ") HISSERIE ON " + joinClause;
            }
            return query;
        }

        #endregion Métodos comunes de HISSERIE

        private string GetQuery_ObtenerSeriesDeStockInSer()
        {
            return $"SELECT COMPRAS.CODEMPCOM AS EMPRESA, COMPRAS.ALMACEN, STOCKINSER.SERIE, STOCKINSER.ARTICULO, ARTICULO.NOMBRE, COMPRAS.COSTE, COMPRAS.DEPOSITO, " + Environment.NewLine +
                   $"       COMPRAS.GARANTIA, COMPRAS.BAJA, COMPRAS.FECHA, COMPRAS.CODEMPCOM, COMPRAS.EMPRESA as CAMPOEMPRESA " + Environment.NewLine +
                   $"FROM ({GetQuery_StockInser(_Actual.Ejercicio)}) STOCKINSER " + Environment.NewLine +
                   $"INNER JOIN " + DB.SQLDatabase("COMUNES", "COMPRAS") + " COMPRAS on STOCKINSER.SERIE = COMPRAS.SERIE " + Environment.NewLine +
                   $"INNER JOIN ({GetQuery_ArticulosDeSeries(_Anterior.Ejercicio)}) AS ARTICULO ON ARTICULO.ARTICULO = COMPRAS.ARTICULO " + Environment.NewLine +
                   $"WHERE (COMPRAS.BAJA = '' OR (COMPRAS.BAJA = 'S' AND COMPRAS.FBAJA >= {DB.SQLString(_Actual.PeriodoIni)} )) " + Environment.NewLine; //Descarto bajas anteriores a fecha inicio
        }

        private string GetQuery_ArticulosDeSeries(string ejercicio)
        {
            string lcSql = $"SELECT CODIGO AS ARTICULO, NOMBRE FROM {DB.SQLDatabase(ejercicio, "ARTICULO")} WHERE VENSERIE = 1 AND MODELO = '' ";
            return lcSql;
        }

        private string GetQuery_StockInser(string ejercicio)
        {
            string lcSql = $"SELECT ARTICULO, SERIE, ALMACEN FROM {DB.SQLDatabase(ejercicio, "STOCKINSER")} ";
            return lcSql;
        }

        private string GetQuery_BorrarArticulosDeSeriesDeStockIni()
        {
            var query = $"DELETE FROM {DB.SQLDatabase(_Actual.Ejercicio, "STOCKINI")} " +
                        $"WHERE ARTICULO IN(SELECT CODIGO AS ARTICULO FROM {DB.SQLDatabase(_Anterior.Ejercicio, "ARTICULO")} WHERE VENSERIE = 1 AND MODELO = ''); " + Environment.NewLine;

            return query;
        }

        private string GetQuery_BorrarArticulosDeSeriesDeInicialser()
        {
            var query = $"DELETE FROM {DB.SQLDatabase(_Actual.Ejercicio, "INICIALSER")}; " + Environment.NewLine;

            return query;
        }

        #endregion Métodos privados
    }
}