调度修改

Shuxia Ning

2024-08-28 1a8a81785470302fc7fbd6914a9df5d1094dac2a

 IStation.Service/05-service/01-analysis/AnalysisFactor.cs

ÎļþÃû´Ó Test/IStation.Win.Core/01-service/01-analysis/AnalysisLog.cs ÐÞ¸Ä
@@ -3,20 +3,20 @@
    /// <summary>
    /// 
    /// </summary>
    public partial class AnalysisLog
    public partial class AnalysisFactor
    {
        #region Cache

        private static List<Model.AnalysisLog> GetCache()
        private static List<Model.AnalysisFactor> GetCache()
        {
            return CacheHelper<Model.AnalysisLog>.GetSet(() =>
            return CacheHelper<Model.AnalysisFactor>.GetSet(() =>
            {
                var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisLog>();
                var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
                var entity_list = dal.GetAll();
                var model_list = Entity2Models(entity_list);
                if (model_list == null)
                {
                    model_list = new List<Model.AnalysisLog>();
                    model_list = new List<Model.AnalysisFactor>();
                }
                return model_list;
            }, ConfigHelper.CacheKeepTime, ConfigHelper.CacheRandomTime);
@@ -24,7 +24,7 @@

        private static void UpdateCache(long ID)
        {
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisLog>();
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
            var entity = dal.GetByID(ID);
            var model = Entity2Model(entity);
            var all = GetCache();
@@ -37,14 +37,14 @@
            {
                rhs.Reset(model);
            }
            CacheHelper<Model.AnalysisLog>.Trigger();
            CacheHelper<Model.AnalysisFactor>.Trigger();
        }

        private static void UpdateCache(List<long> Ids)
        {
            if (Ids == null || Ids.Count < 1)
                return;
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisLog>();
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
            var entity_list = dal.GetByIds(Ids);
            var model_list = Entity2Models(entity_list);
            var all = GetCache();
@@ -53,14 +53,14 @@
            {
                all.AddRange(model_list);
            }
            CacheHelper<Model.AnalysisLog>.Trigger();
            CacheHelper<Model.AnalysisFactor>.Trigger();
        }

        private static void RemoveCache(long ID)
        {
            var all = GetCache();
            all.RemoveAll(x => x.ID == ID);
            CacheHelper<Model.AnalysisLog>.Trigger();
            CacheHelper<Model.AnalysisFactor>.Trigger();
        }

        private static void RemoveCache(List<long> Ids)
@@ -69,7 +69,7 @@
                return;
            var all = GetCache();
            all.RemoveAll(x => Ids.Contains(x.ID));
            CacheHelper<Model.AnalysisLog>.Trigger();
            CacheHelper<Model.AnalysisFactor>.Trigger();
        }

        /// <summary>
@@ -77,7 +77,7 @@
        /// </summary>
        public static void PublishCache(string Key)
        {
            CacheHelper<Model.AnalysisLog>.Publish(Key);
            CacheHelper<Model.AnalysisFactor>.Publish(Key);
        }

        #endregion
@@ -87,7 +87,7 @@
        /// <summary>
        /// èŽ·å–所有
        /// </summary>
        public List<Model.AnalysisLog> GetAll()
        public List<Model.AnalysisFactor> GetAll()
        {
            var all = GetCache();
            return all.ToList();
@@ -96,7 +96,7 @@
        /// <summary>
        /// é€šè¿‡ ID èŽ·å–
        /// </summary>
        public Model.AnalysisLog GetByID(long ID)
        public Model.AnalysisFactor GetByID(long ID)
        {
            var all = GetAll();
            return all.Find(x => x.ID == ID);
@@ -105,12 +105,36 @@
        /// <summary>
        /// é€šè¿‡ Ids èŽ·å–
        /// </summary>
        public List<Model.AnalysisLog> GetByIds(List<long> Ids)
        public List<Model.AnalysisFactor> GetByIds(List<long> Ids)
        {
            if (Ids == null || Ids.Count < 1)
                return default;
            var all = GetAll();
            return all.Where(x => Ids.Contains(x.ID)).ToList();
        }

        /// <summary>
        /// é€šè¿‡  Flag èŽ·å–
        /// </summary>
        public List<Model.AnalysisFactor> GetByFlag(int falg)
        {
            if (falg < 1)
                return default;
            var all = GetAll();
            return all.Where(x => x.Flag == falg).ToList();
        }

        /// <summary>
        /// é€šè¿‡  Flag Hz èŽ·å–
        /// </summary>
        public Model.AnalysisFactor GetByFlagAndHz(int falg, double hz)
        {
            if (falg < 1)
                return default;
            if (hz < 1)
                return default;
            var all = GetAll();
            return all.Where(x => x.Flag == falg && x.Hz == hz).FirstOrDefault();
        }

        #endregion
@@ -120,11 +144,11 @@
        /// <summary>
        /// æ’入一条数据
        /// </summary>
        public long Insert(Model.AnalysisLog model)
        public long Insert(Model.AnalysisFactor model)
        {
            if (model == null)
                return default;
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisLog>();
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
            var entity = Model2Entity(model);
            var id = dal.Insert(entity);
            if (id > 0)
@@ -137,11 +161,11 @@
        /// <summary>
        /// æ’入多条
        /// </summary>
        public bool Inserts(List<Model.AnalysisLog> list)
        public bool Inserts(List<Model.AnalysisFactor> list)
        {
            if (list == null || list.Count < 1)
                return default;
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisLog>();
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
            var entity_list = Model2Entities(list);
            var ids = dal.InsertsR(entity_list);
            if (ids != null && ids.Count > 0)
@@ -159,13 +183,13 @@
        /// <summary>
        /// æ›´æ–°ä¸€æ¡
        /// </summary>
        public bool Update(Model.AnalysisLog model)
        public bool Update(Model.AnalysisFactor model)
        {
            if (model == null)
                return default;
            if (model.ID < 1)
                return default;
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisLog>();
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
            var entity_rhs = Model2Entity(model);
            var bol = dal.Update(entity_rhs);
            if (bol)
@@ -178,13 +202,13 @@
        /// <summary>
        /// æ›´æ–°å¤šæ¡
        /// </summary>
        public bool Updates(List<Model.AnalysisLog> list)
        public bool Updates(List<Model.AnalysisFactor> list)
        {
            if (list == null || list.Count < 1)
                return default;
            if (list.ToList().Exists(x => x.ID < 1))
                return default;
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisLog>();
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
            var entity_list = Model2Entities(list.ToList());
            var bol = dal.Updates(entity_list);
            if (bol)
@@ -204,7 +228,7 @@
        public bool DeleteByID(long ID, out string Msg)
        {
            Msg = string.Empty;
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisLog>();
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
            var bol = dal.DeleteByID(ID);
            if (bol)
            {
@@ -213,6 +237,20 @@
            return bol;
        }

        /// <summary>
        /// é€šè¿‡ ID åˆ é™¤
        /// </summary>
        public bool DeleteAll()
        { 
            var dal = DALCreateHelper.CreateDAL<IStation.DAL.IAnalysisFactor>();
            var bol = dal.DeleteAll();
            if (bol)
            {
                CacheHelper<Model.AnalysisFactor>.Remove();
            }
            return bol;
        }

        #endregion 

    }