333

schangxiang@126.com

2024-12-23 71f890c1c7f40d2605f9eabfe787e5ac287162fc

 CC/iWareSql/DataAccess/ClearDataHandler.cs

@@ -19,28 +19,28 @@
    public class ClearDataHandler
    {
        /// <summary>
        /// 移除XX天前的 异常表 数据
        /// 移除XX天前的 wms_record_print 数据
        /// </summary>
        /// <param name="edm"></param>
        public static void Delete_Base_SysExceptionInfo(int days)
        public static void Delete_wms_record_print(int days)
        {
            try
            {
                using (DbModel edm = new DbModel())
                using (WmsDBModel.WmsDBModel edm = new WmsDBModel.WmsDBModel())
                {
                    var queryTime = DateTime.Now.AddDays(-days);

                    var removeList = edm.Base_SysExceptionInfo.Where(x => x.createTime <= queryTime).ToList();
                    var removeList = edm.wms_record_print.Where(x => x.CreateTime <= queryTime).ToList();
                    if (removeList != null && removeList.Count > 0)
                    {
                        edm.Base_SysExceptionInfo.RemoveRange(removeList);
                        edm.wms_record_print.RemoveRange(removeList);
                    }
                    edm.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 异常表 数据 出现异常", ex);
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 异常表 数据 出现异常", ex);
            }
        }

@@ -66,33 +66,33 @@
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 请求日志 数据 出现异常", ex);
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 请求日志 数据 出现异常", ex);
            }
        }

        /// <summary>
        /// 移除XX天前的 请求日志 数据
        /// 移除XX天前的 mes_push_papercut 数据
        /// </summary>
        /// <param name="edm"></param>
        public static void Delete_Task_RequestLog(int days)
        public static void Delete_mes_push_papercut(int days)
        {
            try
            {
                using (DbModel edm = new DbModel())
                using (WmsDBModel.WmsDBModel edm = new WmsDBModel.WmsDBModel())
                {
                    var queryTime = DateTime.Now.AddDays(-days);

                    var removeList = edm.Task_RequestLog.Where(x => x.CreateTime <= queryTime).ToList();
                    var removeList = edm.mes_push_papercut.Where(x => x.CreateTime <= queryTime).ToList();
                    if (removeList != null && removeList.Count > 0)
                    {
                        edm.Task_RequestLog.RemoveRange(removeList);
                        edm.mes_push_papercut.RemoveRange(removeList);
                    }
                    edm.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 请求日志 数据 出现异常", ex);
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 请求日志 数据 出现异常", ex);
            }
        }

@@ -118,7 +118,7 @@
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 请求日志 数据 出现异常", ex);
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 请求日志 数据 出现异常", ex);
            }
        }

@@ -145,7 +145,7 @@
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 MES_BTJReceiveReq 数据 出现异常", ex);
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 MES_BTJReceiveReq 数据 出现异常", ex);
            }
        }
        /// <summary>
@@ -170,7 +170,7 @@
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 MES_OnLineReq 数据 出现异常", ex);
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 MES_OnLineReq 数据 出现异常", ex);
            }
        }

@@ -179,30 +179,55 @@
        /// 移除XX天前的 设备任务表 数据
        /// </summary>
        /// <param name="edm"></param>
        public static void Delete_Task_Part(int days)
        public static void Delete_mes_push_packagecode(int days)
        {
            try
            {
                using (DbModel edm = new DbModel())
                using (WmsDBModel.WmsDBModel edm = new WmsDBModel.WmsDBModel())
                {
                    var queryTime = DateTime.Now.AddDays(-days);

                    var queryTaskState1 = (int)DeviceTaskStatusEnum.已取消;
                    var queryTaskState2 = (int)DeviceTaskStatusEnum.已完成;

                    var removeList = edm.Task_Part.Where(x => x.CreateTime <= queryTime
                        && (x.TaskState == queryTaskState1 || x.TaskState == queryTaskState2)
                 
                    var removeList = edm.mes_push_packagecode.Where(x => x.CreateTime <= queryTime
                        ).ToList();
                    if (removeList != null && removeList.Count > 0)
                    {
                        edm.Task_Part.RemoveRange(removeList);
                        edm.mes_push_packagecode.RemoveRange(removeList);
                    }
                    edm.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 请求日志 数据 出现异常", ex);
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 请求日志 数据 出现异常", ex);
            }
        }

        /// <summary>
        /// 移除XX天前的 设备任务表 数据
        /// </summary>
        /// <param name="edm"></param>
        public static void Delete_wms_rbline_task(int days)
        {
            try
            {
                using (WmsDBModel.WmsDBModel edm = new WmsDBModel.WmsDBModel())
                {
                    var queryTime = DateTime.Now.AddDays(-days);


                    var removeList = edm.wms_rbline_task.Where(x => x.CreateTime <= queryTime
                        ).ToList();
                    if (removeList != null && removeList.Count > 0)
                    {
                        edm.wms_rbline_task.RemoveRange(removeList);
                    }
                    edm.SaveChanges();
                }
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 请求日志 数据 出现异常", ex);
            }
        }

@@ -229,7 +254,7 @@
            }
            catch (Exception ex)
            {
                Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 设备报警 数据 出现异常", ex);
                Log4NetHelper.WriteErrorLog(LogType.DataProcess_BZ21_FinishTask, "移除XX天前的 设备报警 数据 出现异常", ex);
            }
        }