From aaac84e4ed86d089c01c5b180e4249db73cc78d7 Mon Sep 17 00:00:00 2001 From: lixiaojun <1287241240@qq.com> Date: 星期三, 19 二月 2025 14:08:04 +0800 Subject: [PATCH] 监测分析改造 --- Service/HStation.Service.Assets.Core/05-service/03-Valve/04-ValvePartMain/AssetsValvePartMain.cs | 336 +++++++++++++++++++++++++++---------------------------- 1 files changed, 167 insertions(+), 169 deletions(-) diff --git a/Service/HStation.Service.Assets.Core/05-service/03-Valve/04-ValvePartMain/AssetsValvePartMain.cs b/Service/HStation.Service.Assets.Core/05-service/03-Valve/04-ValvePartMain/AssetsValvePartMain.cs index 2327801..50aa047 100644 --- a/Service/HStation.Service.Assets.Core/05-service/03-Valve/04-ValvePartMain/AssetsValvePartMain.cs +++ b/Service/HStation.Service.Assets.Core/05-service/03-Valve/04-ValvePartMain/AssetsValvePartMain.cs @@ -1,75 +1,73 @@ -锘縰sing Yw.Service; - -namespace HStation.Service +锘縩amespace HStation.Service { /// <summary> /// 闃�闂ㄤ骇鍝� ///</summary> - public partial class AssetsValvePartMain + public partial class AssetsValvePartMain { #region Cache //鑾峰彇缂撳瓨 private static List<Model.AssetsValvePartMain> GetCache() { - var all = AssetsValvePartMainCacheHelper.GetSet(() => - { - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var entity_list = dal.GetAll(); - var model_list = Entity2Models(entity_list); - if (model_list == null) - { - model_list = new List<Model.AssetsValvePartMain>(); - } - return model_list; - }, Yw.Service.ConfigHelper.CacheKeepTime, Yw.Service.ConfigHelper.CacheRandomTime); - return all; + var all = AssetsValvePartMainCacheHelper.GetSet(() => + { + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var entity_list = dal.GetAll(); + var model_list = Entity2Models(entity_list); + if (model_list == null) + { + model_list = new List<Model.AssetsValvePartMain>(); + } + return model_list; + }, Yw.Service.ConfigHelper.CacheKeepTime, Yw.Service.ConfigHelper.CacheRandomTime); + return all; } //閫氳繃 ID 鏇存柊缂撳瓨 private static void UpdateCache(long ID) { - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var entity_ds = dal.GetByID(ID); - var model_ds = Entity2Model(entity_ds); - var all = GetCache(); - var model = all.Find(x => x.ID == ID); - if (model == null) - { - all.Add(model_ds); - } - else - { - model.Reset(model_ds); - } - AssetsValvePartMainCacheHelper.Trigger(); + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var entity_ds = dal.GetByID(ID); + var model_ds = Entity2Model(entity_ds); + var all = GetCache(); + var model = all.Find(x => x.ID == ID); + if (model == null) + { + all.Add(model_ds); + } + else + { + model.Reset(model_ds); + } + AssetsValvePartMainCacheHelper.Trigger(); } //閫氳繃 Ids 鏇存柊缂撳瓨 private static void UpdateCache(List<long> Ids) { - if (Ids == null || Ids.Count < 1) - { - return; - } - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var entity_list = dal.GetByIds(Ids); - var model_list = Entity2Models(entity_list); - var all = GetCache(); - all.RemoveAll(x => Ids.Contains(x.ID)); - if (model_list != null && model_list.Count > 0) - { - all.AddRange(model_list); - } - AssetsValvePartMainCacheHelper.Trigger(); + if (Ids == null || Ids.Count < 1) + { + return; + } + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var entity_list = dal.GetByIds(Ids); + var model_list = Entity2Models(entity_list); + var all = GetCache(); + all.RemoveAll(x => Ids.Contains(x.ID)); + if (model_list != null && model_list.Count > 0) + { + all.AddRange(model_list); + } + AssetsValvePartMainCacheHelper.Trigger(); } //绉婚櫎缂撳瓨 private static void RemoveCache(long ID) { - var all = GetCache(); - all.RemoveAll(x => x.ID == ID); - AssetsValvePartMainCacheHelper.Trigger(); + var all = GetCache(); + all.RemoveAll(x => x.ID == ID); + AssetsValvePartMainCacheHelper.Trigger(); } /// <summary> @@ -77,7 +75,7 @@ /// </summary> public static void PublishCache(string key) { - AssetsValvePartMainCacheHelper.Publish(key); + AssetsValvePartMainCacheHelper.Publish(key); } #endregion @@ -89,8 +87,8 @@ /// </summary> public List<Model.AssetsValvePartMain> GetAll() { - var all = GetCache(); - return all.OrderBy(x => x.SortCode).ToList(); + var all = GetCache(); + return all.OrderBy(x => x.SortCode).ToList(); } /// <summary> @@ -98,8 +96,8 @@ /// </summary> public Model.AssetsValvePartMain GetByID(long ID) { - var all = GetAll(); - return all.Find(x => x.ID == ID); + var all = GetAll(); + return all.Find(x => x.ID == ID); } /// <summary> @@ -107,40 +105,40 @@ /// </summary> public List<Model.AssetsValvePartMain> GetByIds(List<long> Ids) { - if (Ids == null || Ids.Count < 1) - { - return default; - } - var all = GetAll(); - return all.Where(x => Ids.Contains(x.ID)).OrderBy(x => x.SortCode).ToList(); + if (Ids == null || Ids.Count < 1) + { + return default; + } + var all = GetAll(); + return all.Where(x => Ids.Contains(x.ID)).OrderBy(x => x.SortCode).ToList(); } - + /// <summary> /// 鑾峰彇鏈�澶ф帓搴忕爜 /// </summary> public int GetMaxSortCode() { - var list = GetAll(); + var list = GetAll(); if (list == null || list.Count < 1) { return 0; } return list.Max(x => x.SortCode); } - + /// <summary> /// 鍒涘缓缂栧彿 /// </summary> public string CreateNO() { - var all = GetAll(); - var allNoList = all.Select(x => x.NO).Distinct().ToList(); - var prefix = $"PRJ-{DateTime.Now:yyyy-MM-dd}"; - var no = new Yw.Untity.UniqueNameCreater().Create(prefix, allNoList, "-"); - return no; + var all = GetAll(); + var allNoList = all.Select(x => x.NO).Distinct().ToList(); + var prefix = $"PRJ-{DateTime.Now:yyyy-MM-dd}"; + var no = new Yw.Untity.UniqueNameCreater().Create(prefix, allNoList, "-"); + return no; } - - #endregion + + #endregion #region Insert @@ -149,19 +147,19 @@ /// </summary> public long Insert(Model.AssetsValvePartMain model) { - if (model == null) - { - return default; - } - model.NO = CreateNO(); - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var entity = Model2Entity(model); - var id = dal.Insert(entity); - if (id > 0) - { - UpdateCache(id); - } - return id; + if (model == null) + { + return default; + } + model.NO = CreateNO(); + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var entity = Model2Entity(model); + var id = dal.Insert(entity); + if (id > 0) + { + UpdateCache(id); + } + return id; } /// <summary> @@ -169,9 +167,9 @@ /// </summary> public bool Inserts(List<Model.AssetsValvePartMain> list) { - if (list == null || list.Count < 1) - { - return false; + if (list == null || list.Count < 1) + { + return false; } list.ForEach(x => @@ -181,18 +179,18 @@ x.NO = CreateNO(); } }); - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var entity_list = Model2Entities(list); - var ids = dal.InsertsR(entity_list); - if (ids != null && ids.Count > 0) - { - UpdateCache(ids); - return true; - } - return false; + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var entity_list = Model2Entities(list); + var ids = dal.InsertsR(entity_list); + if (ids != null && ids.Count > 0) + { + UpdateCache(ids); + return true; + } + return false; } - - #endregion + + #endregion #region Update @@ -201,18 +199,18 @@ /// </summary> public bool Update(Model.AssetsValvePartMain model) { - if (model == null) - { - return false; - } - var entity = Model2Entity(model); - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var bol = dal.Update(entity); - if (bol) - { - UpdateCache(model.ID); - } - return bol; + if (model == null) + { + return false; + } + var entity = Model2Entity(model); + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var bol = dal.Update(entity); + if (bol) + { + UpdateCache(model.ID); + } + return bol; } /// <summary> @@ -220,41 +218,41 @@ /// </summary> public bool Updates(List<Model.AssetsValvePartMain> list) { - if (list == null || list.Count < 1) - { - return false; - } - if (list.Exists(x => x.ID < 1)) - { - return false; - } - var entity_list = Model2Entities(list); - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var bol = dal.Updates(entity_list); - if (bol) - { - UpdateCache(list.Select(x => x.ID).ToList()); - } - return bol; + if (list == null || list.Count < 1) + { + return false; + } + if (list.Exists(x => x.ID < 1)) + { + return false; + } + var entity_list = Model2Entities(list); + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var bol = dal.Updates(entity_list); + if (bol) + { + UpdateCache(list.Select(x => x.ID).ToList()); + } + return bol; } - + /// <summary> /// 鏇存柊鎺掑簭鐮� /// </summary> public bool UpdateSortCode(long ID, int SortCode) { - if (ID < 1) - { - return false; - } - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var bol = dal.UpdateSortCode(ID, SortCode); - if (bol) - { - UpdateCache(ID); - } - return bol; + if (ID < 1) + { + return false; + } + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var bol = dal.UpdateSortCode(ID, SortCode); + if (bol) + { + UpdateCache(ID); + } + return bol; } /// <summary> @@ -262,24 +260,24 @@ /// </summary> public bool UpdateSorter(List<Yw.Model.Sorter> sorters) { - if (sorters == null || sorters.Count < 1) - { - return false; - } - if (sorters.Exists(x => x.ID < 1)) - { - return false; - } - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var bol = dal.UpdateSorter(sorters.ToEntityList()); - if (bol) - { - UpdateCache(sorters.Select(x => x.ID).ToList()); - } - return bol; + if (sorters == null || sorters.Count < 1) + { + return false; + } + if (sorters.Exists(x => x.ID < 1)) + { + return false; + } + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var bol = dal.UpdateSorter(sorters.ToEntityList()); + if (bol) + { + UpdateCache(sorters.Select(x => x.ID).ToList()); + } + return bol; } - - + + /// <summary> /// 鏇存柊缂栫爜 /// </summary> @@ -296,9 +294,9 @@ UpdateCache(ID); } return bol; - } - #endregion - + } + #endregion + #region Exist /// <summary> @@ -335,8 +333,8 @@ return all.Exists(x => x.Code == Code && x.ID != ExceptID); } - #endregion - + #endregion + #region Delete /// <summary> @@ -344,18 +342,18 @@ /// </summary> public bool DeleteByID(long ID, out string Msg) { - Msg = string.Empty; - var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); - var bol = dal.DeleteByID(ID); - if (bol) - { - RemoveCache(ID); - } - return bol; + Msg = string.Empty; + var dal = DALCreateHelper.CreateDAL<DAL.IAssetsValvePartMain>(); + var bol = dal.DeleteByID(ID); + if (bol) + { + RemoveCache(ID); + } + return bol; } - - #endregion - - + + #endregion + + } } \ No newline at end of file -- Gitblit v1.9.3