|
using iWareCommon;
|
|
using iWareCommon.Utils;
|
using iWareSql.Orm;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Threading;
|
using System.Collections;
|
using Newtonsoft.Json;
|
using System.Threading.Tasks;
|
using iWareCommon.Common.Globle;
|
using iWareSql.DBModel;
|
using XiGang.Core.Model;
|
|
namespace iWareSql.DataAccess
|
{
|
public class ClearDataHandler
|
{
|
/// <summary>
|
/// 移除XX天前的 异常表 数据
|
/// </summary>
|
/// <param name="edm"></param>
|
public static void Delete_Base_SysExceptionInfo(int days)
|
{
|
try
|
{
|
using (DbModel edm = new DbModel())
|
{
|
var queryTime = DateTime.Now.AddDays(-days);
|
|
var removeList = edm.Base_SysExceptionInfo.Where(x => x.createTime <= queryTime).ToList();
|
if (removeList != null && removeList.Count > 0)
|
{
|
edm.Base_SysExceptionInfo.RemoveRange(removeList);
|
}
|
edm.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 异常表 数据 出现异常", ex);
|
}
|
}
|
|
/// <summary>
|
/// 移除XX天前的 请求日志 数据
|
/// </summary>
|
/// <param name="edm"></param>
|
public static void Delete_HttpRequestRecord()
|
{
|
try
|
{
|
using (DbModel edm = new DbModel())
|
{
|
var queryTime = DateTime.Now.AddDays(-2);
|
|
var removeList = edm.HttpRequestRecord.Where(x => x.CreateTime <= queryTime).ToList();
|
if (removeList != null && removeList.Count > 0)
|
{
|
edm.HttpRequestRecord.RemoveRange(removeList);
|
}
|
edm.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 请求日志 数据 出现异常", ex);
|
}
|
}
|
|
/// <summary>
|
/// 移除XX天前的 请求日志 数据
|
/// </summary>
|
/// <param name="edm"></param>
|
public static void Delete_Task_RequestLog(int days)
|
{
|
try
|
{
|
using (DbModel edm = new DbModel())
|
{
|
var queryTime = DateTime.Now.AddDays(-days);
|
|
var removeList = edm.Task_RequestLog.Where(x => x.CreateTime <= queryTime).ToList();
|
if (removeList != null && removeList.Count > 0)
|
{
|
edm.Task_RequestLog.RemoveRange(removeList);
|
}
|
edm.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 请求日志 数据 出现异常", ex);
|
}
|
}
|
|
/// <summary>
|
/// 移除XX天前的 请求日志 数据
|
/// </summary>
|
/// <param name="edm"></param>
|
public static void Delete_HttpRequestRecord(int days)
|
{
|
try
|
{
|
using (DbModel edm = new DbModel())
|
{
|
var queryTime = DateTime.Now.AddDays(-days);
|
|
var removeList = edm.HttpRequestRecord.Where(x => x.CreateTime <= queryTime).ToList();
|
if (removeList != null && removeList.Count > 0)
|
{
|
edm.HttpRequestRecord.RemoveRange(removeList);
|
}
|
edm.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 请求日志 数据 出现异常", ex);
|
}
|
}
|
|
|
/// <summary>
|
/// 移除XX天前的 MES_BTJReceiveReq 数据
|
/// </summary>
|
/// <param name="edm"></param>
|
public static void Delete_MES_BTJReceiveReq(int days)
|
{
|
try
|
{
|
using (DbModel edm = new DbModel())
|
{
|
var queryTime = DateTime.Now.AddDays(-days);
|
|
var removeList = edm.MES_BTJReceiveReq.Where(x => x.CreateTime <= queryTime).ToList();
|
if (removeList != null && removeList.Count > 0)
|
{
|
edm.MES_BTJReceiveReq.RemoveRange(removeList);
|
}
|
edm.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 MES_BTJReceiveReq 数据 出现异常", ex);
|
}
|
}
|
/// <summary>
|
/// 移除XX天前的 MES_OnLineReq 数据
|
/// </summary>
|
/// <param name="edm"></param>
|
public static void Delete_MES_OnLineReq(int days)
|
{
|
try
|
{
|
using (DbModel edm = new DbModel())
|
{
|
var queryTime = DateTime.Now.AddDays(-days);
|
|
var removeList = edm.MES_OnLineReq.Where(x => x.CreateTime <= queryTime).ToList();
|
if (removeList != null && removeList.Count > 0)
|
{
|
edm.MES_OnLineReq.RemoveRange(removeList);
|
}
|
edm.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 MES_OnLineReq 数据 出现异常", ex);
|
}
|
}
|
|
|
/// <summary>
|
/// 移除XX天前的 设备任务表 数据
|
/// </summary>
|
/// <param name="edm"></param>
|
public static void Delete_Task_Part(int days)
|
{
|
try
|
{
|
using (DbModel edm = new DbModel())
|
{
|
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)
|
).ToList();
|
if (removeList != null && removeList.Count > 0)
|
{
|
edm.Task_Part.RemoveRange(removeList);
|
}
|
edm.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 请求日志 数据 出现异常", ex);
|
}
|
}
|
|
|
/// <summary>
|
/// 移除XX天前的 Device_Warning 数据
|
/// </summary>
|
/// <param name="edm"></param>
|
public static void Delete_Device_Warning(int days)
|
{
|
try
|
{
|
using (DbModel edm = new DbModel())
|
{
|
var queryTime = DateTime.Now.AddDays(-days);
|
|
var removeList = edm.Device_Warning.Where(x => x.CreateTime <= queryTime).ToList();
|
if (removeList != null && removeList.Count > 0)
|
{
|
edm.Device_Warning.RemoveRange(removeList);
|
}
|
edm.SaveChanges();
|
}
|
}
|
catch (Exception ex)
|
{
|
Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 设备报警 数据 出现异常", ex);
|
}
|
}
|
|
///// <summary>
|
///// 移除XX天前的 AGV报警 数据
|
///// </summary>
|
///// <param name="edm"></param>
|
//public static void Delete_Les_InOutStockRecord()
|
//{
|
// try
|
// {
|
// using (DbModel edm = new DbModel())
|
// {
|
// var queryTime = DateTime.Now.AddDays(-30);
|
|
// var removeList = edm.Les_InOutStockRecord.Where(x => x.CreateTime <= queryTime).ToList();
|
// if (removeList != null && removeList.Count > 0)
|
// {
|
// edm.Les_InOutStockRecord.RemoveRange(removeList);
|
// }
|
// edm.SaveChanges();
|
// }
|
// }
|
// catch (Exception ex)
|
// {
|
// Log4NetHelper.WriteErrorLog(LogType.SdaService, "移除XX天前的 出入库记录 数据 出现异常", ex);
|
// }
|
//}
|
|
|
|
}
|
}
|
