using NPOI.HSSF.Record;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEAWCS_Core.BaseServices;
|
using WIDESEAWCS_ISystemRepository;
|
using WIDESEAWCS_ISystemServices;
|
using WIDESEAWCS_Model.Models;
|
|
namespace WIDESEAWCS_SystemServices
|
{
|
public class Sys_LogService : ServiceBase<Sys_Log, ISys_LogRepository>, ISys_LogService
|
{
|
private static DateTime? _lastExecutionDate = null;
|
private readonly object _lock = new object();
|
|
public Sys_LogService(ISys_LogRepository BaseDal) : base(BaseDal)
|
{
|
|
}
|
|
public void DeleteOldLogs()
|
{
|
// 使用锁确保线程安全
|
lock (_lock)
|
{
|
var today = DateTime.Today;
|
|
// 检查今天是否已经执行过
|
if (_lastExecutionDate.HasValue && _lastExecutionDate.Value.Date == today)
|
{
|
return;
|
}
|
try
|
{
|
// 计算3个月前的日期
|
var threeMonthsAgo = DateTime.Now.AddMonths(-3);
|
// 计算3天前的日期
|
var sevenDaysAgo = DateTime.Now.AddDays(-3);
|
// 特定URL
|
var specificUrl = "http://11.2.30.141:10870/interfaces/api/amr/robotQuery";
|
|
// 构建删除条件：3个月前的日志 或 (7天前且URL为特定地址的日志)
|
var result = BaseDal.Db.Deleteable<Sys_Log>()
|
.Where(log => log.EndDate < threeMonthsAgo ||
|
(log.EndDate < sevenDaysAgo && log.Url == specificUrl))
|
.ExecuteCommand();
|
// 更新最后执行日期为今天
|
_lastExecutionDate = today;
|
}
|
catch (Exception ex)
|
{
|
Console.WriteLine($"执行日志清理时发生错误：{ex.Message}");
|
// 发生错误时不更新最后执行日期，以便重试
|
}
|
}
|
}
|
}
|
}
|
