using WIDESEA_Core.BaseRepository;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_ITaskInfoService;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_TaskInfoService;
|
|
public class Task_HtyService : ServiceBase<Dt_Task_Hty, IRepository<Dt_Task_Hty>>, ITask_HtyService
|
{
|
public Task_HtyService(IRepository<Dt_Task_Hty> BaseDal) : base(BaseDal)
|
{
|
}
|
|
/// <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);
|
}
|
}
|
