lixiaojun
2024-10-12 f2333318a31e92f6cbc3a572d8eb9fae9da0f892
Service/HStation.Service.Assets.Core/05-service/03-ValveManage/04-PumpGroupAndMainMap/PumpMaping.cs
@@ -40,7 +40,7 @@
            {
                model.Reset(model_ds);
            }
            ValveSeriesCacheHelper.Trigger();
            AssetsValveSeriesCacheHelper.Trigger();
        }
        //通过型号ID更新缓存
@@ -48,12 +48,12 @@
        {
            var dal = DALCreateHelper.CreateDAL<HStation.DAL.IValveGroupAndMainMap>();
            var alllist = dal.GetAll();
            var entity_ds = alllist.Find(x => x.ValveMainID == ID);
            var entity_ds = alllist.Find(x => x.AssetsValveMainID == ID);
            if (entity_ds != null)
            {
                var model_ds = Entity2Model(entity_ds);
                var all = GetCache();
                var model = all.Find(x => x.ValveMainID == ID);
                var model = all.Find(x => x.AssetsValveMainID == ID);
                if (model == null)
                {
                    all.Add(model_ds);
@@ -62,7 +62,7 @@
                {
                    model.Reset(model_ds);
                }
                ValveSeriesCacheHelper.Trigger();
                AssetsValveSeriesCacheHelper.Trigger();
            }
        }
@@ -82,7 +82,7 @@
            {
                all.AddRange(model_list);
            }
            ValveSeriesCacheHelper.Trigger();
            AssetsValveSeriesCacheHelper.Trigger();
        }
        //移除缓存
@@ -90,15 +90,15 @@
        {
            var all = GetCache();
            all.RemoveAll(x => x.ID == ID);
            ValveSeriesCacheHelper.Trigger();
            AssetsValveSeriesCacheHelper.Trigger();
        }
        //根据MainID移除缓存
        public static void RemoveCacheByMainID(long ID)
        {
            var all = GetCache();
            all.RemoveAll(x => x.ValveMainID == ID);
            ValveSeriesCacheHelper.Trigger();
            all.RemoveAll(x => x.AssetsValveMainID == ID);
            AssetsValveSeriesCacheHelper.Trigger();
        }
        /// <summary>
@@ -106,7 +106,7 @@
        /// </summary>
        public static void PublishCache(string key)
        {
            ValveSeriesCacheHelper.Publish(key);
            AssetsValveSeriesCacheHelper.Publish(key);
        }
        #endregion Cache
@@ -146,7 +146,7 @@
        public static List<long> GetMainIDByGroupID(long ID)
        {
            var all = GetCache();
            return all.Where(x => x.ValveGroupID == ID).Select(x => x.ValveMainID).ToList();
            return all.Where(x => x.ValveGroupID == ID).Select(x => x.AssetsValveMainID).ToList();
        }
        /// <summary>