namespace Yw.Service { /// /// 运行分析配置 /// public partial class RunAnalyConfigure { #region Cache //获取缓存 private static List GetCache() { var all = RunAnalyConfigureCacheHelper.GetSet(() => { var dal = DALCreateHelper.CreateDAL(); var entity_list = dal.GetAll(); var model_list = Entity2Models(entity_list); if (model_list == null) { model_list = new List(); } return model_list; }, ConfigHelper.CacheKeepTime, ConfigHelper.CacheRandomTime); return all; } //通过 ID 更新缓存 private static void UpdateCache(long ID) { var dal = DALCreateHelper.CreateDAL(); 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); } RunAnalyConfigureCacheHelper.Trigger(); } //通过 Ids 更新缓存 private static void UpdateCache(List Ids) { if (Ids == null || Ids.Count < 1) return; var dal = DALCreateHelper.CreateDAL(); 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); } RunAnalyConfigureCacheHelper.Trigger(); } //移除缓存 private static void RemoveCache(long ID) { var all = GetCache(); all.RemoveAll(x => x.ID == ID); RunAnalyConfigureCacheHelper.Trigger(); } //移除缓存 private static void RemoveCache() { RunAnalyConfigureCacheHelper.Remove(); RunAnalyConfigureCacheHelper.Trigger(); } /// /// 发布缓存 /// public static void PublishCache(string key) { RunAnalyConfigureCacheHelper.Publish(key); } #endregion #region Query /// /// 获取所有 /// public List GetAll() { var all = GetCache(); return all.ToList(); } /// /// 通过 ID 获取 /// public Model.RunAnalyConfigure GetByID(long ID) { var all = GetAll(); return all.Find(x => x.ID == ID); } /// /// 通过 Ids 获取 /// public List GetByIds(List Ids) { if (Ids == null || Ids.Count < 1) return default; var all = GetAll(); return all.Where(x => Ids.Contains(x.ID)).ToList(); } /// /// 通过 ObjectType 和 ObjectID 获取 /// public Model.RunAnalyConfigure GetByObjectTypeAndObjectID(string ObjectType, long ObjectID) { var all = GetAll(); return all.Find(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID); } #endregion #region Insert /// /// 插入一条数据 /// public long Insert(Model.RunAnalyConfigure model) { if (model == null) { return default; } var dal = DALCreateHelper.CreateDAL(); var entity = Model2Entity(model); var id = dal.Insert(entity); if (id > 0) { UpdateCache(id); } return id; } /// /// 插入多条 /// public bool Inserts(List list) { if (list == null || list.Count < 1) { return default; } var dal = DALCreateHelper.CreateDAL(); var entity_list = Model2Entities(list); var ids = dal.InsertsR(entity_list); if (ids != null && ids.Count > 0) { UpdateCache(ids); return true; } return false; } #endregion #region Update /// /// 更新一条 /// public bool Update(Model.RunAnalyConfigure model) { if (model == null) { return default; } if (model.ID < 1) { return default; } var dal = DALCreateHelper.CreateDAL(); var entity = Model2Entity(model); var bol = dal.Update(entity); if (bol) { UpdateCache(model.ID); } return bol; } /// /// 更新多条 /// public bool Updates(List list) { if (list == null || list.Count < 1) { return default; } if (list.ToList().Exists(x => x.ID < 1)) { return default; } var dal = DALCreateHelper.CreateDAL(); var entity_list = Model2Entities(list.ToList()); var bol = dal.Updates(entity_list); if (bol) { UpdateCache(list.Select(x => x.ID).ToList()); } return bol; } #endregion #region Exist /// /// 判断是否存在 /// public bool IsExist(string ObjectType, long ObjectID) { var all = GetAll(); return all.Exists(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID); } #endregion #region Delete /// /// 通过 ID 删除 /// public bool DeleteByID(long ID, out string Msg) { Msg = string.Empty; var dal = DALCreateHelper.CreateDAL(); var bol = dal.DeleteByID(ID); if (bol) { RemoveCache(ID); } return bol; } #endregion #region Set /// /// 设置 /// public bool Set(List list) { var entityList = Model2Entities(list); var dal = DALCreateHelper.CreateDAL(); var bol = dal.Set(entityList); if (bol) { RemoveCache(); } return bol; } #endregion } }