lixiaojun
2024-03-26 3e14440cb203d28923ba9cfec39ceff15f2c35e7
Yw.Service.Run.Core/07-service/02-record/RunRealRecord.cs
文件名从 Yw.Service.Run.Core/06-service/2-record/RunRealRecord.cs 修改
@@ -12,8 +12,8 @@
        /// </summary>
        public Model.RunRealRecord GetLastRecord(string ObjectType, long ObjectID)
        {
            var redisCache = new RedisCache.RunRealLastRecordCacheHelper();
            return redisCache.GetLastRecord(ObjectType, ObjectID);
            var lcacheHelper = LCacheCreateHelper.CreateLCache<Yw.LCache.IRunRealLastRecordCacheHelper>();
            return lcacheHelper.GetLastRecord(ObjectType, ObjectID);
        }
        /// <summary>
@@ -25,8 +25,8 @@
            {
                return default;
            }
            var redisCache = new RedisCache.RunRealLastRecordCacheHelper();
            return redisCache.GetLastRecord(ObjectType, ObjectIds);
            var lcacheHelper = LCacheCreateHelper.CreateLCache<Yw.LCache.IRunRealLastRecordCacheHelper>();
            return lcacheHelper.GetLastRecord(ObjectType, ObjectIds);
        }
        /// <summary>
@@ -38,8 +38,8 @@
            {
                return default;
            }
            var redisCache = new RedisCache.RunRealLastRecordCacheHelper();
            return redisCache.GetLastRecord(list);
            var lcacheHelper = LCacheCreateHelper.CreateLCache<Yw.LCache.IRunRealLastRecordCacheHelper>();
            return lcacheHelper.GetLastRecord(list);
        }
        #endregion
@@ -64,7 +64,7 @@
            {
                Number = 1;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetLastList(StartTime, EndTime, Number, Run);
            return Entity2Models(entityList);
        }
@@ -78,7 +78,7 @@
            {
                Number = 1;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetLastListByDay(Day, Number, Run);
            return Entity2Models(entityList);
        }
@@ -96,7 +96,7 @@
            {
                Number = 1;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetLastListByDayRange(StartDay, EndDay, Number, Run);
            return Entity2Models(entityList);
        }
@@ -114,7 +114,7 @@
            {
                Number = 1;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetLastListByTimeRange(StartTime, EndTime, Number, Run);
            return Entity2Models(entityList);
        }
@@ -131,7 +131,7 @@
                    return default;
                }
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.Get(StartTime, EndTime, Run);
            return Entity2Models(entityList);
        }
@@ -141,7 +141,7 @@
        /// </summary>
        public List<Model.RunRealRecord> GetByDay(DateTime Day, bool? Run = null)
        {
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetByDay(Day, Run);
            return Entity2Models(entityList);
        }
@@ -156,7 +156,7 @@
                return default;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetByDayRange(StartDay, EndDay, Run);
            return Entity2Models(entityList);
        }
@@ -170,7 +170,7 @@
            {
                return default;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetByTimeRange(StartTime, EndTime, Run);
            return Entity2Models(entityList);
        }
@@ -187,7 +187,7 @@
                    return default;
                }
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetPageList(StartTime, EndTime, Run, PageIndex, PageSize, ref Total);
            return Entity2Models(entityList);
        }
@@ -205,7 +205,7 @@
            {
                Number = 1;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetLastListByObjectTypeAndObjectID(ObjectType, ObjectID, Number, Run);
            return Entity2Models(entityList);
        }
@@ -222,7 +222,7 @@
                    return default;
                }
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetByObjectTypeAndObjectID(ObjectType, ObjectID, StartTime, EndTime, Run);
            return Entity2Models(entityList);
        }
@@ -232,7 +232,7 @@
        /// </summary>
        public List<Model.RunRealRecord> GetByObjectTypeAndObjectIDOfDay(string ObjectType, long ObjectID, DateTime Day, bool? Run = null)
        {
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetByObjectTypeAndObjectIDOfDay(ObjectType, ObjectID, Day, Run);
            return Entity2Models(entityList);
        }
@@ -246,7 +246,7 @@
            {
                return default;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetByObjectTypeAndObjectIDOfDayRange(ObjectType, ObjectID, StartDay, EndDay, Run);
            return Entity2Models(entityList);
        }
@@ -260,7 +260,7 @@
            {
                return default;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetByObjectTypeAndObjectIDOfTimeRange(ObjectType, ObjectID, StartTime, EndTime, Run);
            return Entity2Models(entityList);
        }
@@ -277,7 +277,7 @@
                    return default;
                }
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entityList = dal.GetPageListByObjectTypeAndObjectID(ObjectType, ObjectID, StartTime, EndTime, Run, PageIndex, PageSize, ref Total);
            return Entity2Models(entityList);
        }
@@ -299,7 +299,7 @@
            {
                return default;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entity = Model2Entity(model);
            return dal.InsertOrUpdate(entity);
        }
@@ -313,7 +313,7 @@
            {
                return default;
            }
            var dal = new DAL.RunRealRecord();
            var dal = DALCreateHelper.CreateDAL<Yw.DAL.IRunRealRecord>();
            var entity_list = Model2Entities(list);
            return dal.InsertOrUpdate(entity_list);
        }
@@ -330,12 +330,12 @@
            var bol = Insert(record);
            if (bol)
            {
                var redisCache = new RedisCache.RunRealLastRecordCacheHelper();
                bol = redisCache.SetLastRecord(record);
                var lcacheHelper = LCacheCreateHelper.CreateLCache<Yw.LCache.IRunRealLastRecordCacheHelper>();
                bol = lcacheHelper.SetLastRecord(record);
                if (bol)
                {
                    var runQueueHelper = new RabbitMqExChangeHelper();
                    bol = runQueueHelper.Push(RunParasHelper.Run.Run.ExchangeName, new List<Model.RunRealRecord>() { record });
                    var exchangeHelper = ExchangeCreateHelper.CreateExchange<Yw.Exchange.IRunRealRecordExchangeHelper>();
                    bol = exchangeHelper.Push(new List<Model.RunRealRecord>() { record });
                }
                return bol;
            }
@@ -354,12 +354,12 @@
            var bol = Inserts(list);
            if (bol)
            {
                var redisCache = new RedisCache.RunRealLastRecordCacheHelper();
                bol = redisCache.SetLastRecord(list);
                var lcacheHelper = LCacheCreateHelper.CreateLCache<Yw.LCache.IRunRealLastRecordCacheHelper>();
                bol = lcacheHelper.SetLastRecord(list);
                if (bol)
                {
                    var runQueueHelper = new RabbitMqExChangeHelper();
                    bol = runQueueHelper.Push(RunParasHelper.Run.Run.ExchangeName, list);
                    var exchangeHelper = ExchangeCreateHelper.CreateExchange<Yw.Exchange.IRunRealRecordExchangeHelper>();
                    bol = exchangeHelper.Push(list);
                }
                return bol;
            }