From 0e33247236d4ac46f1a75802f53dd6c612301cff Mon Sep 17 00:00:00 2001 From: duheng <2784771470@qq.com> Date: 星期二, 24 十二月 2024 14:52:06 +0800 Subject: [PATCH] 注册泵曲线事件 --- Service/HStation.Service.Assets.Core/05-service/04-FourLink/02-FourlinkMain/FourLinkManage.cs | 185 +++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 173 insertions(+), 12 deletions(-) diff --git a/Service/HStation.Service.Assets.Core/05-service/04-FourLink/02-FourlinkMain/FourLinkManage.cs b/Service/HStation.Service.Assets.Core/05-service/04-FourLink/02-FourlinkMain/FourLinkManage.cs index 7c1dfb0..3d17054 100644 --- a/Service/HStation.Service.Assets.Core/05-service/04-FourLink/02-FourlinkMain/FourLinkManage.cs +++ b/Service/HStation.Service.Assets.Core/05-service/04-FourLink/02-FourlinkMain/FourLinkManage.cs @@ -40,7 +40,7 @@ { model.Reset(model_ds); } - AssetsPumpSeriesCacheHelper.Trigger(); + AssetsFourlinkMainCacheHelper.Trigger(); } //閫氳繃 Ids 鏇存柊缂撳瓨 @@ -59,7 +59,7 @@ { all.AddRange(model_list); } - AssetsPumpSeriesCacheHelper.Trigger(); + AssetsFourlinkMainCacheHelper.Trigger(); } //绉婚櫎缂撳瓨 @@ -67,7 +67,7 @@ { var all = GetCache(); all.RemoveAll(x => x.ID == ID); - AssetsPumpSeriesCacheHelper.Trigger(); + AssetsFourlinkMainCacheHelper.Trigger(); } /// <summary> @@ -75,10 +75,12 @@ /// </summary> public static void PublishCache(string key) { - AssetsPumpSeriesCacheHelper.Publish(key); + AssetsFourlinkMainCacheHelper.Publish(key); } #endregion Cache + + #region Query @@ -88,7 +90,7 @@ public List<Model.AssetsFourlinkMain> GetAll() { var all = GetCache(); - return all; + return all.OrderBy(x => x.SortCode).ToList(); } /// <summary> @@ -110,28 +112,46 @@ return default; } var all = GetAll(); - return all.Where(x => Ids.Contains(x.ID)).ToList(); + return all.Where(x => Ids.Contains(x.ID)).OrderBy(x => x.SortCode).ToList(); } /// <summary> - /// 閫氳繃 绯诲垪ID 鑾峰彇 + /// 鑾峰彇鏁伴噺 /// </summary> - public List<Model.AssetsFourlinkMain> GetBySeriesID(long id) + public int GetCount() { - if (id < 1) + var all = GetAll(); + return all.Count; + } + + /// <summary> + /// 閫氳繃 SeriesID 鑾峰彇 + /// </summary> + public List<Model.AssetsFourlinkMain> GetBySeriesID(long SeriesID) + { + var all = GetAll(); + return all.Where(x => x.SeriesID == SeriesID).OrderBy(x => x.SortCode).ToList(); + } + + /// <summary> + /// 閫氳繃 SeriesIds 鑾峰彇 + /// </summary> + public List<Model.AssetsFourlinkMain> GetBySeriesIds(List<long> SeriesIds) + { + if (SeriesIds == null || SeriesIds.Count < 1) { return default; } var all = GetAll(); - return all.Where(x => x.SeriesID == id).ToList(); + return all.Where(x => SeriesIds.Contains(x.SeriesID)).OrderBy(x => x.SortCode).ToList(); } /// <summary> /// 鑾峰彇鏈�澶ф帓搴忕爜 /// </summary> - public int GetMaxSortCode() + public int GetMaxSortCode(long SeriesID) { - var all = GetAll(); + var all = GetBySeriesID(SeriesID); if (all == null || all.Count < 1) { return 0; @@ -140,6 +160,8 @@ } #endregion Query + + #region Insert @@ -183,6 +205,8 @@ } #endregion Insert + + #region Update @@ -228,8 +252,145 @@ return bol; } + /// <summary> + /// 鏇存柊鎺掑簭鐮� + /// </summary> + public bool UpdateSortCode(long ID, int SortCode) + { + if (ID < 1) + { + return false; + } + var dal = DALCreateHelper.CreateDAL<HStation.DAL.IAssetsFourlinkMain>(); + var bol = dal.UpdateSortCode(ID, SortCode); + if (bol) + { + UpdateCache(ID); + } + return bol; + } + + /// <summary> + /// 鏇存柊鎺掑簭 + /// </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<HStation.DAL.IAssetsFourlinkMain>(); + var bol = dal.UpdateSorter(sorters.ToEntityList()); + if (bol) + { + UpdateCache(sorters.Select(x => x.ID).ToList()); + } + return bol; + } + + /// <summary> + /// 鏇存柊 Paras + /// </summary> + public bool UpdateParas(long ID, Dictionary<string, string> Paras) + { + if (ID < 1) + { + return false; + } + var dal = DALCreateHelper.CreateDAL<HStation.DAL.IAssetsFourlinkMain>(); + var bol = dal.UpdateParas(ID, ParasHelper.ToString(Paras)); + if (bol) + { + UpdateCache(ID); + } + return bol; + } + + /// <summary> + /// 鏇存柊 Flags + /// </summary> + public bool UpdateFlags(long ID, List<string> Flags) + { + if (ID < 1) + { + return false; + } + var dal = DALCreateHelper.CreateDAL<HStation.DAL.IAssetsFourlinkMain>(); + var bol = dal.UpdateFlags(ID, FlagsHelper.ToString(Flags)); + if (bol) + { + UpdateCache(ID); + } + return bol; + } + + /// <summary> + /// 鏇存柊 TagName + /// </summary> + public bool UpdateTagName(long ID, string TagName) + { + if (ID < 1) + { + return false; + } + var dal = DALCreateHelper.CreateDAL<HStation.DAL.IAssetsFourlinkMain>(); + var bol = dal.UpdateTagName(ID, TagName); + if (bol) + { + UpdateCache(ID); + } + return bol; + } + #endregion Update + + + #region Exist + + /// <summary> + /// 鍒ゆ柇 TagName 鏄惁瀛樺湪 + /// </summary> + public bool IsExistTagName(string TagName) + { + if (string.IsNullOrEmpty(TagName)) + { + return false; + } + var all = GetAll(); + return all.Exists(x => x.TagName == TagName); + } + + /// <summary> + /// 鍒ゆ柇 TagName 鏄惁瀛樺湪 ExceptID + /// </summary> + public bool IsExistTagNameExceptID(string TagName, long ExceptID) + { + if (string.IsNullOrEmpty(TagName)) + { + return false; + } + var all = GetAll(); + return all.Exists(x => x.TagName == TagName && x.ID != ExceptID); + } + + /// <summary> + /// 閫氳繃 SeriesID 鍒ゆ柇鏄惁瀛樺湪 + /// </summary> + public bool IsExistBySeriesID(long SeriesID) + { + var all = GetAll(); + return all.Exists(x => x.SeriesID == SeriesID); + } + + #endregion Exist + + + #region Delete /// <summary> -- Gitblit v1.9.3