#region << 版 本 注 释 >>
/*----------------------------------------------------------------
 * 命名空间：WIDESEAWCS_TaskInfoService
 * 创建者：系统自动生成
 * 创建时间：2024/11/14
 * 版本：V1.0.0
 * 描述：任务历史服务实现
 *
 * ----------------------------------------------------------------
 * 修改人：
 * 修改时间：
 * 版本：V1.0.1
 * 修改说明：
 * 
 *----------------------------------------------------------------*/
#endregion << 版 本 注 释 >>

using AutoMapper;
using WIDESEAWCS_Core.BaseRepository;
using WIDESEAWCS_Core.BaseServices;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;
using SqlSugar;
using System.Linq;

namespace WIDESEAWCS_TaskInfoService
{
    /// <summary>
    /// 任务历史服务实现
    /// </summary>
    public class TaskHtyService : ServiceBase<Dt_Task_Hty, IRepository<Dt_Task_Hty>>, ITaskHtyService
    {
        private readonly IMapper _mapper;

        public TaskHtyService(IRepository<Dt_Task_Hty> repository, IMapper mapper) : base(repository)
        {
            _mapper = mapper;
        }

        /// <summary>
        /// 添加任务历史记录
        /// </summary>
        /// <param name="task">原任务对象</param>
        /// <param name="operateType">操作类型</param>
        /// <returns>是否添加成功</returns>
        public bool AddTaskHistory(Dt_Task task, string operateType = "自动完成")
        {
            try
            {
                if (task == null)
                {
                    return false;
                }

                var task_hty = new Dt_Task_Hty
                {
                    // 主键TaskId在历史表中是自增的，所以不需要赋值
                    TaskNum = task.TaskNum,
                    PalletCode = task.PalletCode,
                    PalletType = task.PalletType,
                    DeviceCode = task.Roadway,
                    Roadway = task.Roadway,
                    TaskType = task.TaskType,
                    TaskState = task.TaskState,
                    SourceAddress = task.SourceAddress,
                    TargetAddress = task.TargetAddress,
                    CurrentAddress = task.CurrentAddress,
                    NextAddress = task.NextAddress,
                    ExceptionMessage = task.ExceptionMessage,
                    Grade = task.Grade,
                    WMSId = task.WMSId,
                    Dispatchertime = task.Dispatchertime,
                    Remark = task.Remark,
                    Depth = task.Depth,

                    // 源记录ID设置为原任务的TaskId
                    SourceId = task.TaskId,

                    // 操作类型使用传入的参数
                    OperateType = operateType,

                    // 基础实体字段（如果有的话）
                    CreateDate = DateTime.Now,
                    Creater = task.Creater,

                };

                // 插入历史记录
                int result = BaseDal.AddData(task_hty);
                return result > 0;
            }
            catch (Exception ex)
            {
                // 记录异常日志
                //Console.WriteLine($"添加任务历史记录失败: {ex.Message}");
                return false;
            }
        }

        /// <summary>
        /// 根据原任务ID查询历史记录
        /// </summary>
        /// <param name="sourceId">原任务ID</param>
        /// <returns>历史记录列表</returns>
        public List<Dt_Task_Hty> GetHistoryBySourceId(int sourceId)
        {
            return BaseDal.QueryData(x => x.SourceId == sourceId).OrderByDescending(x => x.CreateDate).ToList();
        }

        /// <summary>
        /// 根据任务号查询历史记录
        /// </summary>
        /// <param name="taskNum">任务号</param>
        /// <returns>历史记录列表</returns>
        public List<Dt_Task_Hty> GetHistoryByTaskNum(int taskNum)
        {
            return BaseDal.QueryData(x => x.TaskNum == taskNum).OrderByDescending(x => x.CreateDate).ToList();
        }

        /// <summary>
        /// 删除指定日期之前的历史任务数据
        /// </summary>
        /// <param name="keepMonths">保留的月数，默认为3个月（本月+后两个月）</param>
        /// <returns>删除的记录数</returns>
        public int DeleteOldTaskHistory(int keepMonths = 3)
        {
            try
            {
                // 计算保留日期：当前日期减去keepMonths个月
                DateTime keepDate = DateTime.Now.AddMonths(-keepMonths);
                
                // 先查询出要删除的数据
                List<Dt_Task_Hty> tasksToDelete = BaseDal.QueryData().Where(x => x.CreateDate < keepDate).ToList();
                
                // 如果没有要删除的数据，直接返回0
                if (tasksToDelete.Count == 0)
                {
                    return 0;
                }
                
                // 删除查询出的历史记录
                bool result = BaseDal.DeleteData(tasksToDelete);
                return result ? tasksToDelete.Count : 0;
            }
            catch (Exception ex)
            {
                // 记录异常日志
                //Console.WriteLine($"删除历史任务记录失败: {ex.Message}");
                return 0;
            }
        }

        /// <summary>
        /// 定时任务调用的历史任务删除方法
        /// </summary>
        public void Task_Hty_Job()
        {
            // 删除3个月之前的历史任务数据，保留本月和后两个月的数据
            DeleteOldTaskHistory(3);
        }
    }
}