namespace IStation.Service
{
///
/// 测点组
///
public partial class LogicTree
{
#region Cache
//获取缓存
private static List GetCache()
{
var all = LogicTreeCacheHelper.GetSet(() =>
{
var dal = new DAL.LogicTree();
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 = new DAL.LogicTree();
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);
}
LogicTreeCacheHelper.Trigger();
}
//通过 Ids 更新缓存
private static void UpdateCache(List Ids)
{
if (Ids == null || Ids.Count < 1)
return;
var dal = new DAL.LogicTree();
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);
}
LogicTreeCacheHelper.Trigger();
}
//通过 PolicyID 更新缓存
private static void UpdateCacheByPolicyID(long PolicyID)
{
var dal = new DAL.LogicTree();
var entity_list = dal.GetByPolicyID(PolicyID);
var model_list = Entity2Models(entity_list);
var all = GetCache();
all.RemoveAll(x => x.PolicyID == PolicyID);
if (model_list != null && model_list.Count > 0)
{
all.AddRange(model_list);
}
LogicTreeCacheHelper.Trigger();
}
//移除缓存
private static void RemoveCache(long ID)
{
var all = GetCache();
all.RemoveAll(x => x.ID == ID);
LogicTreeCacheHelper.Trigger();
}
//通过 PolicyID 移除缓存
private static void RemoveCacheByPolicyID(long PolicyID)
{
var all = GetCache();
all.RemoveAll(x => x.PolicyID == PolicyID);
LogicTreeCacheHelper.Trigger();
}
///
/// 发布缓存
///
public static void PublishCache(string key)
{
LogicTreeCacheHelper.Publish(key);
}
#endregion
#region Query
///
/// 通过 CorpID 获取
///
public List GetAll()
{
var all = GetCache();
var list = all.OrderBy(x => x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
return list;
}
///
/// 通过 ID 获取
///
public Model.LogicTree GetByID(long ID)
{
var all = GetAll();
var model = all.Find(x => x.ID == ID);
return model;
}
///
/// 通过 ID 获取
///
public List GetByIds(List Ids)
{
if (Ids == null || Ids.Count < 1)
return default;
var all = GetAll();
var list = all.Where(x => Ids.Contains(x.ID)).OrderBy(x => x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
return list;
}
///
/// 通过 PolicyID 获取
///
public List GetByPolicyID(long PolicyID)
{
var all = GetAll();
return all.Where(x => x.PolicyID == PolicyID).OrderBy(x => x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
}
///
/// 通过 ID 获取子项及自身
///
public List GetChildAndSelfByID(long ID)
{
var all = GetAll();
var list = all.Where(x => x.ID == ID || x.ParentIds.Contains(ID)).OrderBy(x => x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
return list;
}
///
/// 通过 ID 获取子项
///
public List GetChildrenByID(long ID)
{
var all = GetAll();
var list = all.Where(x => x.ParentIds.Contains(ID)).OrderBy(x => x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
return list;
}
///
/// 通过 ID 获取父级
///
public List GetParentByID(long ID)
{
var all = GetAll();
var model = all.Find(x => x.ID == ID);
if (model == null)
return default;
return all.Where(x => model.ParentIds.Contains(x.ID)).OrderBy(x => x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
}
///
/// 通过 ID 获取父级及自身
///
public List GetParentAndSelfByID(long ID)
{
var all = GetAll();
var model = all.Find(x => x.ID == ID);
if (model == null)
return default;
return all.Where(x => model.ParentIds.Contains(x.ID) || x.ID == ID).OrderBy(x => x.ParentIds.Count).ThenBy(x => x.SortCode).ToList();
}
///
/// 通过 ParentID 获取
///
public List GetByParentID(long ParentID)
{
var all = GetAll();
return all.Where(x => x.ParentIds.LastOrDefault() == ParentID).OrderBy(x => x.SortCode).ToList();
}
///
/// 是否包含子项
///
public bool HasChildren(long ID)
{
var all = GetAll();
return all.Exists(x => x.ParentIds.Contains(ID));
}
///
/// 通过 ParentID 获取最大排序码
///
public int GetMaxSortCodeByParentID(long ParentID)
{
var all = GetByParentID(ParentID);
if (all == null || all.Count < 1)
return 0;
return all.Max(x => x.SortCode);
}
///
/// 获取所有拓展列表
///
public List GetExList()
{
var all = GetAll();
return ToExList(all);
}
///
/// 通过 PolicyID 获取拓展列表
///
public List GetExByPolicyID(long PolicyID)
{
var all = GetByPolicyID(PolicyID);
return ToExList(all);
}
///
/// 通过 ID 获取子项拓展列表
///
public List GetExChildrenByID(long ID)
{
var all = GetChildrenByID(ID);
return ToExList(all);
}
///
/// 通过 ID 获取子项及自身拓展列表
///
public List GetExChildAndSelfByID(long ID)
{
var all = GetChildAndSelfByID(ID);
return ToExList(all);
}
///
/// 通过 ID 获取拓展
///
public Model.LogicTreeEx GetExByID(long ID)
{
var model = GetByID(ID);
return ToEx(model);
}
///
/// 通过 Ids 获取拓展列表
///
public List GetExByIds(List Ids)
{
if (Ids == null || Ids.Count < 1)
return default;
var list = GetByIds(Ids);
return ToExList(list);
}
//ToExList
private List ToExList(List list)
{
return list?.Select(x =>
{
var name = LogicHelper.GetName(x.LogicType, x.LogicID);
var description = LogicHelper.GetDescription(x.LogicType, x.LogicID);
return new Model.LogicTreeEx(x, name, description);
}).ToList();
}
//to Ex
private Model.LogicTreeEx ToEx(Model.LogicTree model)
{
if (model == null)
return default;
var name = LogicHelper.GetName(model.LogicType, model.LogicID);
var description = LogicHelper.GetDescription(model.LogicType, model.LogicID);
return new Model.LogicTreeEx(model, name, description);
}
#endregion
#region Insert
///
/// 添加一条
///
public long Insert(Model.LogicTree model)
{
if (model == null)
return default;
var entity = Model2Entity(model);
var dal = new DAL.LogicTree();
var id = dal.Insert(entity);
if (id > 0)
{
UpdateCache(id);
}
return id;
}
///
/// 批量插入
///
public bool Inserts(List list)
{
if (list == null || list.Count < 1)
return false;
var dal = new DAL.LogicTree();
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.LogicTree model)
{
if (model == null)
return false;
var entity = Model2Entity(model);
var dal = new DAL.LogicTree();
var bol = dal.Update(entity);
if (bol)
{
UpdateCache(model.ID);
}
return bol;
}
///
/// 批量更新
///
public bool Updates(List list)
{
if (list == null || list.Count < 1)
return false;
var entity_list = Model2Entities(list.ToList());
var dal = new DAL.LogicTree();
var bol = dal.Updates(entity_list);
if (bol)
{
UpdateCache(list.Select(x => x.ID).ToList());
}
return bol;
}
///
/// 更新排序码
///
public bool UpdateSortCode(long ID, int SortCode)
{
if (ID < 1)
return default;
var dal = new DAL.LogicTree();
var bol = dal.UpdateSortCode(ID, SortCode);
if (bol)
{
UpdateCache(ID);
}
return bol;
}
///
/// 更新排序
///
public bool UpdateSorter(List sorters)
{
if (sorters == null || sorters.Count < 1)
return default;
var dal = new DAL.LogicTree();
var bol = dal.UpdateSorter(sorters.ToEntityList());
if (bol)
{
UpdateCache(sorters.Select(x => x.ID).ToList());
}
return bol;
}
///
/// 更新树排序码
///
public bool UpdateTreeSortCode(long ID, List ParentIds, int SortCode)
{
if (ID < 1)
return default;
var dal = new DAL.LogicTree();
var bol = dal.UpdateTreeSortCode(ID, TreeParentIdsHelper.ToString(ParentIds), SortCode);
if (bol)
{
UpdateCache(ID);
}
return bol;
}
///
/// 更新树排序
///
public bool UpdateTreeSorter(List sorters)
{
if (sorters == null || sorters.Count() < 1)
return default;
var dal = new DAL.LogicTree();
var bol = dal.UpdateTreeSorter(sorters.ToEntityList());
if (bol)
{
UpdateCache(sorters.Select(x => x.ID).ToList());
}
return bol;
}
#endregion
#region Exist
///
/// 判断是否存在
///
public bool IsExist(long PolicyID, string LogicType, long LogicID)
{
var all = GetAll();
return all.Exists(x => x.PolicyID == PolicyID && x.LogicType == LogicType && x.LogicID == LogicID);
}
///
/// 通过 PolicyID 判断是否存在
///
public bool IsExistByPolicyID(long PolicyID)
{
var all = GetAll();
return all.Exists(x => x.PolicyID == PolicyID);
}
///
/// 通过 LogicType 和 LogicID 判断是否存在
///
public bool IsExistByLogicTypeAndLogicID(string LogicType, long LogicID)
{
var all = GetAll();
return all.Exists(x => x.LogicType == LogicType && x.LogicID == LogicID);
}
#endregion
#region Delete
///
/// 通过 ID 删除
///
public bool DeleteByID(long ID, out string Msg)
{
Msg = string.Empty;
if (HasChildren(ID))
{
Msg = "存在子级";
return false;
}
var dal = new DAL.LogicTree();
var bol = dal.DeleteByID(ID);
if (bol)
{
RemoveCache(ID);
}
return bol;
}
#endregion
#region Other
///
/// 保存
///
public bool Save(long PolicyID, List treeList)
{
var dal = new DAL.LogicTree();
var bol = dal.Save(PolicyID, treeList?.ToEntityList());
if (bol)
{
UpdateCacheByPolicyID(PolicyID);
}
return bol;
}
#endregion
}
}