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.DataProcess_BZ21_FinishTask, "移除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.DataProcess_BZ21_FinishTask, "移除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.DataProcess_BZ21_FinishTask, "移除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.DataProcess_BZ21_FinishTask, "移除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.DataProcess_BZ21_FinishTask, "移除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.DataProcess_BZ21_FinishTask, "移除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.DataProcess_BZ21_FinishTask, "移除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.DataProcess_BZ21_FinishTask, "移除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);
        //    }
        //}



    }
}