using Exferia_KairosPRO._1_Modelos.Herencia.Capas; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using Exferia_Aplicacion.General; using Exferia_KairosPRO_EF; using static Exferia_Aplicacion.General.Enumerados; using System.Transactions; using System.Data.SqlClient; using System.Threading; namespace Exferia_KairosPRO._2_Datos { public class KRS_Departamentos_Datos : ABS_Datos { #region Listado public override List Obtener_Listado(List _lst_CamposConRelacionABuscar, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo) { throw new NotImplementedException(); } public override dynamic Obtener_RegistroListado(List _lst_CamposConRelacionABuscar, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo, long _lng_id, List _lst_id) { throw new NotImplementedException(); } protected override void ConsultaRellenar_Listado(KairosProEntities _dbcontext, List _lst_CamposConRelacionABuscar, long _lng_id, List _lst_id, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo) {} #endregion #region Listado Secundario public override List Obtener_Listado_Secundario(List _lst_CamposConRelacionABuscar, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo) { return null; } public override dynamic Obtener_RegistroListado_Secundario(List _lst_CamposConRelacionABuscar, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo, long _lng_id, List _lst_id) { return null; } protected override void ConsultaRellenar_Listado_Secundario(KairosProEntities _dbcontext, List _lst_CamposConRelacionABuscar, long _lng_id, List _lst_id, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo) { } #endregion #region F3 public override dynamic Obtener_F3(string _str_filtro, string _str_CampoBusqueda, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo) { throw new NotImplementedException(); } public override dynamic Obtener_F3_PorId(long _lng_id, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo) { throw new NotImplementedException(); } protected override void ConsultaRellenar_F3(KairosProEntities _dbcontext, string _str_CampoBusqueda, string _str_Filtro, long _lng_id, List _lst_INTERNO_Filtro_OpcionPadre_Modelo, List _lst_INTERNO_Filtro_Modelo) { } #endregion #region Obtener private dynamic g_dnm_Modelo_Obtener = null; public override dynamic Obtener(long _lng_id) { KairosProEntities obj_KairosProEntities = null; try { obj_KairosProEntities = new KairosProEntities(); obj_KairosProEntities.Configuration.LazyLoadingEnabled = false; string str_SQL = " SELECT distinct " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.id) + "," + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.codigoCliente) + "," + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.codigo) + "," + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.descripcion) + "," + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.fechaBorrado) + " FROM " + nameof(KRS_Departamentos) + " WHERE " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.fechaBorrado) + " IS null AND " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.id) + "=@id and " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.codigoCliente) + "=@codigoCliente "; //Parametros object[] arr_Parametros = new object[] { new SqlParameter("@id", _lng_id), new SqlParameter("@codigoCliente", Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO) }; //Rellenar el Modelo g_dnm_Modelo_Obtener = obj_KairosProEntities.Database.SqlQuery(str_SQL, arr_Parametros).FirstOrDefault(); } catch (Control_Errores) { throw; } catch (Exception ex) { throw new Control_Errores("", ex, nameof(KRS_Departamentos_Datos) + "/" + nameof(Obtener),true); } finally { obj_KairosProEntities.Database.Connection.Close(); obj_KairosProEntities.Dispose(); } return g_dnm_Modelo_Obtener; } public override dynamic Obtener_Registro_PorCampo(string _str_CampoBusqueda, string _str_Filtro) { throw new NotImplementedException(); } #endregion #region MODELOS #region Modelo Simple private KRS_Departamentos g_mdl_KRS_Departamentos = null; public KRS_Departamentos Obtener_Modelo_Por_Id(long _lng_id,long _lng_CodigoCliente, bool _bol_Cargar_DepartamentosEmail) { try { string str_SQL = Obtener_Consulta_Modelo() + //WHERE " WHERE " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.id) + "=@id and " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.codigoCliente) + "=@codigoCliente "; //Parametros object[] arr_Parametros = new object[] { new SqlParameter("@id", _lng_id), new SqlParameter("@codigoCliente", _lng_CodigoCliente) }; //Ejecutar y rellenar el modelo Ejecutar_Consulta_Modelo(str_SQL, arr_Parametros, _bol_Cargar_DepartamentosEmail); } catch (Control_Errores) { throw; } catch (Exception ex) { throw new Control_Errores("", ex, nameof(KRS_Departamentos_Datos) + "/" + nameof(Obtener_Modelo_Por_Id), true); } return g_mdl_KRS_Departamentos; } #region Ejecutar_Consulta_Modelo private static int g_int_TotalHilos_Modelo = 1; private bool[] g_bol_Hilos_Terminados_Modelo = new bool[g_int_TotalHilos_Modelo]; private void Ejecutar_Consulta_Modelo(string _str_SQL, object[] _arr_Parametros, bool _bol_Cargar_DepartamentosEmail) { KairosProEntities obj_KairosProEntities = null; try { //Conexion obj_KairosProEntities = new KairosProEntities(); obj_KairosProEntities.Configuration.LazyLoadingEnabled = false; //Rellenar el Modelo g_mdl_KRS_Departamentos = obj_KairosProEntities.Database.SqlQuery(_str_SQL, _arr_Parametros).FirstOrDefault(); #region Rellenar Tablas Relacionadas if (g_mdl_KRS_Departamentos != null) { //reiniciar Valores de los hilos for (int int_Contador = 0; int_Contador < g_int_TotalHilos_Modelo; int_Contador++) { g_bol_Hilos_Terminados_Modelo[int_Contador] = false; } //KRS_DepartamentosEmails ########################################################################################## if (_bol_Cargar_DepartamentosEmail) { ThreadStart obj_ThreadStart_DEPARTAMENTOSEMAIL = new ThreadStart(Obtener_DepartamentosEmails_Modelo); Thread obj_Thread_DEPARTAMENTOSEMAIL = new Thread(obj_ThreadStart_DEPARTAMENTOSEMAIL); obj_Thread_DEPARTAMENTOSEMAIL.Start(); } else { g_bol_Hilos_Terminados_Modelo[0] = true; } //Esperando a que terminen todos los hilos ......................................... bool bol_Termino = false; while (bol_Termino == false) { bol_Termino = true; foreach (bool bol_Termino_Hilo in g_bol_Hilos_Terminados_Modelo) { if (bol_Termino_Hilo == false) { bol_Termino = false; break; } } Thread.Sleep(10); } //................................................................................. } #endregion } catch (Control_Errores) { throw; } catch (Exception ex) { throw new Control_Errores("", ex, nameof(KRS_Departamentos_Datos) + "/" + nameof(Ejecutar_Consulta_Modelo), true); } finally { obj_KairosProEntities.Database.Connection.Close(); obj_KairosProEntities.Dispose(); } } #region Tablas Relacionadas private void Obtener_DepartamentosEmails_Modelo() { try { KRS_DepartamentosEmails_Datos obj_KRS_DepartamentosEmails_Datos = new KRS_DepartamentosEmails_Datos(); g_mdl_KRS_Departamentos.KRS_DepartamentosEmails = obj_KRS_DepartamentosEmails_Datos.Obtener_ModeloListado_Por_IdDepartamento(g_mdl_KRS_Departamentos.id); } catch (Control_Errores) { } finally { g_bol_Hilos_Terminados_Modelo[0] = true; } } #endregion #endregion #endregion #region Modelo Listado private List g_lst_KRS_Departamentos = null; public List Obtener_ModeloListado_Por_Ids(List _lst_Ids) { try { if (_lst_Ids != null && _lst_Ids.Count > 0) { List lst_Parametros = new List(); string str_Filtros_IDS = Funciones.Formar_ContenidoIN_ParaConsultaWhere(nameof(KRS_Departamentos), nameof(KRS_Departamentos.id), G_ENUM_FORMARCONTENIDOIN_CONDICIONANTES.NADA, _lst_Ids); //Consulta string str_SQL = Obtener_Consulta_Modelo() + //WHERE " WHERE " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.codigoCliente) + "=@codigoCliente and " + str_Filtros_IDS; //Parametros lst_Parametros.Add(new SqlParameter("@codigoCliente", Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO)); object[] arr_Parametros = lst_Parametros.ToArray(); //Ejecutar y rellenar el listado Ejecutar_Consulta_Modelo_Listado(str_SQL, arr_Parametros); } } catch (Control_Errores) { throw; } catch (Exception ex) { throw new Control_Errores("", ex, nameof(KRS_Departamentos_Datos) + "/" + nameof(Obtener_ModeloListado_Por_Ids), true); } return g_lst_KRS_Departamentos; } public List Obtener_ModeloListado() { try { //Consulta string str_SQL = Obtener_Consulta_Modelo() + //WHERE " WHERE " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.fechaBorrado) + " is null and " + nameof(KRS_Departamentos) + "." + nameof(KRS_Departamentos.codigoCliente) + "=@codigoCliente "; //Parametros object[] arr_Parametros = new object[] { new SqlParameter("@codigoCliente", Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO) }; //Ejecutar y rellenar el listado Ejecutar_Consulta_Modelo_Listado(str_SQL, arr_Parametros); } catch (Control_Errores) { throw; } catch (Exception ex) { throw new Control_Errores("", ex, nameof(KRS_Departamentos_Datos) + "/" + nameof(Obtener_ModeloListado), true); } return g_lst_KRS_Departamentos; } #region Ejecutar Consulta private void Ejecutar_Consulta_Modelo_Listado(string _str_SQL, object[] _arr_Parametros) { KairosProEntities obj_KairosProEntities = null; try { //Conexion obj_KairosProEntities = new KairosProEntities(); obj_KairosProEntities.Configuration.LazyLoadingEnabled = false; //Rellenar el modelo g_lst_KRS_Departamentos = obj_KairosProEntities.Database.SqlQuery(_str_SQL, _arr_Parametros).ToList(); } catch (Control_Errores) { throw; } catch (Exception ex) { throw new Control_Errores("", ex, nameof(KRS_Departamentos_Datos) + "/" + nameof(Ejecutar_Consulta_Modelo_Listado), true); } finally { obj_KairosProEntities.Database.Connection.Close(); obj_KairosProEntities.Dispose(); } } #endregion #endregion private string Obtener_Consulta_Modelo() { return " SELECT " + nameof(KRS_Departamentos.id) + " , " + nameof(KRS_Departamentos.codigoCliente) + " , " + nameof(KRS_Departamentos.codigo) + " , " + nameof(KRS_Departamentos.descripcion) + " , " + nameof(KRS_Departamentos.fechaBorrado) + " FROM " + nameof(KRS_Departamentos); } #endregion #region Grabar public override INTERNO_ValorDevuelto_Modelo Grabar(object _mdl_obj) { KairosProEntities obj_KairosProEntities = null; INTERNO_ValorDevuelto_Modelo mdl_INTERNO_ValorDevuelto_Modelo = new INTERNO_ValorDevuelto_Modelo(); mdl_INTERNO_ValorDevuelto_Modelo.TodoCorrecto = true; try { obj_KairosProEntities = new KairosProEntities(); obj_KairosProEntities.Configuration.LazyLoadingEnabled = false; KRS_Departamentos mdl_KRS_Departamentos_AGrabar = (KRS_Departamentos)_mdl_obj; KRS_Departamentos mdl_KRS_Departamentos_DatosViejos = new KRS_Departamentos(); KRS_Departamentos mdl_KRS_Departamentos_Final = Obtener_Modelo_Por_Id(mdl_KRS_Departamentos_AGrabar.id, Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO, false); if (mdl_KRS_Departamentos_Final != null) { //Tipo de Accion que se va a realizar mdl_INTERNO_ValorDevuelto_Modelo.TipoAccion = G_ENUM_TIPOACCION.INT_MODIFICAR; //Validado el codigo del cliente, se lo asignamos antes de grabar mdl_KRS_Departamentos_AGrabar.codigoCliente = Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO; //Datos viejos para la trazabilidad Funciones.CopiarPropiedadesObjetos(mdl_KRS_Departamentos_Final, mdl_KRS_Departamentos_DatosViejos, false, false); //Cargar los Datos Nuevos para la trazabilidad Funciones.CopiarPropiedadesObjetos(mdl_KRS_Departamentos_AGrabar, mdl_KRS_Departamentos_Final, false, false); #region Update string str_SQL_Update = " UPDATE " + nameof(KRS_Departamentos) + " SET " + nameof(KRS_Departamentos.codigo) + "=@codigo," + nameof(KRS_Departamentos.descripcion) + "=@descripcion," + nameof(KRS_Departamentos.fechaBorrado) + "=@fechaBorrado" + " WHERE " + nameof(KRS_Departamentos.id) + "=@id and " + nameof(KRS_Departamentos.codigoCliente) + "=@codigoCliente "; //Parametros object[] arr_Parametros_Update = new object[] { new SqlParameter("@codigo", mdl_KRS_Departamentos_Final.codigo), new SqlParameter("@descripcion", mdl_KRS_Departamentos_Final.descripcion), mdl_KRS_Departamentos_Final.fechaBorrado != null ? new SqlParameter("@fechaBorrado", mdl_KRS_Departamentos_Final.fechaBorrado.Value) : new SqlParameter("@fechaBorrado", DBNull.Value), new SqlParameter("@id", mdl_KRS_Departamentos_Final.id), new SqlParameter("@codigoCliente", mdl_KRS_Departamentos_Final.codigoCliente) }; #endregion //Update obj_KairosProEntities.Database.ExecuteSqlCommand(str_SQL_Update, arr_Parametros_Update); //Id de la tabla mdl_INTERNO_ValorDevuelto_Modelo.Id = mdl_KRS_Departamentos_Final.id; } else { mdl_KRS_Departamentos_Final = new KRS_Departamentos(); //Tipo de Accion que se va a realizar mdl_INTERNO_ValorDevuelto_Modelo.TipoAccion = G_ENUM_TIPOACCION.INT_INSERTAR; //Validado el codigo del cliente, se lo asignamos antes de grabar mdl_KRS_Departamentos_AGrabar.codigoCliente = Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO; //Cargar los datos del Modelo Funciones.CopiarPropiedadesObjetos(mdl_KRS_Departamentos_AGrabar, mdl_KRS_Departamentos_Final, false, false); #region INSERT string str_SQL_Insert = " INSERT INTO " + nameof(KRS_Departamentos) + " (" + nameof(KRS_Departamentos.id) + "," + nameof(KRS_Departamentos.codigoCliente) + "," + nameof(KRS_Departamentos.codigo) + "," + nameof(KRS_Departamentos.descripcion) + "," + nameof(KRS_Departamentos.fechaBorrado) + " ) " + " VALUES " + " ( " + "@id," + "@codigoCliente," + "@codigo," + "@descripcion," + "@fechaBorrado" + " ) "; //Parametros object[] arr_Parametros_Insert = new object[] { new SqlParameter("@id", mdl_KRS_Departamentos_Final.id), new SqlParameter("@codigoCliente", mdl_KRS_Departamentos_Final.codigoCliente), new SqlParameter("@codigo", mdl_KRS_Departamentos_Final.codigo), new SqlParameter("@descripcion", mdl_KRS_Departamentos_Final.descripcion), mdl_KRS_Departamentos_Final.fechaBorrado != null ? new SqlParameter("@fechaBorrado", mdl_KRS_Departamentos_Final.fechaBorrado.Value) : new SqlParameter("@fechaBorrado", DBNull.Value) }; #endregion //Update obj_KairosProEntities.Database.ExecuteSqlCommand(str_SQL_Insert, arr_Parametros_Insert); //Id de la tabla mdl_INTERNO_ValorDevuelto_Modelo.Id = mdl_KRS_Departamentos_AGrabar.id; } //Grabar Trazabilidad USR_Trazabilidad_Datos.Grabar_Trazabilidad(typeof(KRS_Departamentos), mdl_KRS_Departamentos_DatosViejos, mdl_KRS_Departamentos_Final, mdl_INTERNO_ValorDevuelto_Modelo.TipoAccion, obj_KairosProEntities); } catch (Exception ex) { throw new Control_Errores("", ex, nameof(KRS_Departamentos_Datos) + "/" + nameof(Grabar), true); } finally { //Cerramos la conexion obj_KairosProEntities.Database.Connection.Close(); obj_KairosProEntities.Dispose(); } return mdl_INTERNO_ValorDevuelto_Modelo; } #endregion #region Borrar public override INTERNO_ValorDevuelto_Modelo Borrar(long _lng_id) { KairosProEntities obj_KairosProEntities = null; INTERNO_ValorDevuelto_Modelo mdl_INTERNO_ValorDevuelto_Modelo = new INTERNO_ValorDevuelto_Modelo(); mdl_INTERNO_ValorDevuelto_Modelo.TodoCorrecto = true; //Tipo de Accion que se va a Realizar mdl_INTERNO_ValorDevuelto_Modelo.TipoAccion = G_ENUM_TIPOACCION.INT_ELIMINAR; bool bol_ActualizarFechaBorrado = false;//Este campo se utiliza por si no se puede borrar, que actualice la fecha de borrado try { obj_KairosProEntities = new KairosProEntities(); obj_KairosProEntities.Configuration.LazyLoadingEnabled = false; // Ver si existe ###################################################################### KRS_Departamentos mdl_KRS_Departamentos = Obtener_Modelo_Por_Id(_lng_id, Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO,false); //###################################################################################### if (mdl_KRS_Departamentos != null) { //Se intenta Borrar, si diera un error porque esta relacionado se graba la fecha de baja try { #region Delete string str_SQL_Delete = " DELETE FROM " + nameof(KRS_Departamentos) + " WHERE " + nameof(KRS_Departamentos.id) + "=@id and " + nameof(KRS_Departamentos.codigoCliente) + "=@codigoCliente "; //Parametros object[] arr_Parametros_Delete = new object[] { new SqlParameter("@id", _lng_id), new SqlParameter("@codigoCliente", Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO) }; #endregion //Delete obj_KairosProEntities.Database.ExecuteSqlCommand(str_SQL_Delete, arr_Parametros_Delete); //Grabar Trazabilidad USR_Trazabilidad_Datos.Grabar_Trazabilidad(typeof(KRS_Departamentos), null, mdl_KRS_Departamentos, mdl_INTERNO_ValorDevuelto_Modelo.TipoAccion, obj_KairosProEntities); } catch (Exception ex) { var sqlException = ex.GetBaseException() as SqlException; if (sqlException != null) { if (sqlException.Errors.Count > 0) { switch (sqlException.Errors[0].Number) { case Control_Errores.G_INT_ERRORCONTROLADO_BORRAR_CONFLICTO_CLAVEFORANEA: // Foreign Key violation bol_ActualizarFechaBorrado = true; break; default: throw; } } } else { throw; } } } //Actualizar la fecha de baja, al no poder borrarlo por tener relaciones if (bol_ActualizarFechaBorrado) { #region Update string str_SQL_Update = " UPDATE " + nameof(KRS_Departamentos) + " SET " + nameof(KRS_Departamentos.fechaBorrado) + "=@fechaBorrado " + " WHERE " + nameof(KRS_Departamentos.id) + "=@id and " + nameof(KRS_Departamentos.codigoCliente) + "=@codigoCliente "; //Parametros object[] arr_Parametros_Update = new object[] { new SqlParameter("@fechaBorrado", DateTime.Now), new SqlParameter("@id", _lng_id), new SqlParameter("@codigoCliente", Variables.G_LNG_IDCLIENTE_LICENCIAVALIDADO) }; #endregion //Update obj_KairosProEntities.Database.ExecuteSqlCommand(str_SQL_Update, arr_Parametros_Update); //Grabar Trazabilidad USR_Trazabilidad_Datos.Grabar_Trazabilidad(typeof(KRS_Departamentos), null, mdl_KRS_Departamentos, mdl_INTERNO_ValorDevuelto_Modelo.TipoAccion, obj_KairosProEntities); } //Devolver tambien el Objeto mdl_INTERNO_ValorDevuelto_Modelo.Id =_lng_id; } catch (Control_Errores) { throw; } catch (Exception ex) { throw new Control_Errores("", ex, nameof(KRS_DepartamentosEmails_Datos) + "/" + nameof(Borrar), true); } finally { obj_KairosProEntities.Database.Connection.Close(); obj_KairosProEntities.Dispose(); } return mdl_INTERNO_ValorDevuelto_Modelo; } public override INTERNO_ValorDevuelto_Modelo Borrar(long _lng_id, long _lng_idAuxiliar) { throw new NotImplementedException(); } public override INTERNO_ValorDevuelto_Modelo Borrar(object _mdl_obj) { throw new NotImplementedException(); } #endregion } }