namespace Yw.Service
{
///
/// 运行分析配置
///
public partial class RunAnalyConfigure
{
#region Cache
//获取缓存
private static List GetCache()
{
var all = RunAnalyConfigureCacheHelper.GetSet(() =>
{
var dal = DALCreateHelper.CreateDAL3();
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.CreateDAL3();
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.CreateDAL3();
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 RemoveCacheByObjectTypeAndObjectID(string ObjectType, long ObjectID)
{
var all = GetCache();
all.RemoveAll(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID);
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.CreateDAL3();
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.CreateDAL3();
var entity_list = Model2Entities(list);
var ids = dal.InsertsR(entity_list);
if (ids != null && ids.Count > 0)
{
UpdateCache(ids);
return true;
}
return false;
}
///
/// 插入或更新
///
public long InsertOrUpdate(Model.RunAnalyConfigurePure pure)
{
if (pure == null)
{
return default;
}
var dal = DALCreateHelper.CreateDAL3();
var entity = pure.ToEntity();
var id = dal.InsertOrUpdate(entity);
if (id > 0)
{
UpdateCache(id);
}
return id;
}
#endregion
#region Update
///
/// 更新一条
///
public bool Update(Model.RunAnalyConfigure model)
{
if (model == null)
{
return false;
}
if (model.ID < 1)
{
return false;
}
var dal = DALCreateHelper.CreateDAL3();
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 false;
}
if (list.Exists(x => x.ID < 1))
{
return false;
}
var dal = DALCreateHelper.CreateDAL3();
var entity_list = Model2Entities(list);
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.CreateDAL3();
var bol = dal.DeleteByID(ID);
if (bol)
{
RemoveCache(ID);
}
return bol;
}
///
/// 通过 ObjectType 和 ObjectID 删除
///
public bool DeleteByObjectTypeAndObjectID(string ObjectType, long ObjectID, out string Msg)
{
Msg = string.Empty;
var dal = DALCreateHelper.CreateDAL3();
var bol = dal.DeleteByObjectTypeAndObjectID(ObjectType, ObjectID);
if (bol)
{
RemoveCacheByObjectTypeAndObjectID(ObjectType, ObjectID);
}
return bol;
}
#endregion
#region Set
///
/// 设置
///
public bool Set(List list, out string Msg)
{
Msg = string.Empty;
if (list == null || list.Count < 1)
{
return false;
}
var entityList = list.ToEntityList();
var dal = DALCreateHelper.CreateDAL3();
var bol = dal.Set(entityList);
if (bol)
{
RemoveCache();
}
return bol;
}
#endregion
}
}