yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove 停用归档处理

Browse Source
This commit is contained in:
liguoyang
2025-05-09 09:50:16 +08:00
parent 244fd43980
commit 543d2ad9e2
1 changed files with 51 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

102
Src/Dlhis.ScheduledTask/Jobs/ArchiveDeviceUploadLogJob.cs
View File

@@ -1,51 +1,51 @@
using Dlhis.Entity.Device.Entities;
using Dlhis.ScheduledTask.Attributes;
namespace Dlhis.ScheduledTask.Jobs;
/// <summary>
/// 归档设备通行记录
/// </summary>
[RecurringJob(nameof(ArchiveDeviceUploadLogJob), "0 0/5 * * * ?", Name = "归档设备通行记录")]
public class ArchiveDeviceUploadLogJob : BaseJob
{
public ArchiveDeviceUploadLogJob(IServiceProvider serviceProvider) : base(serviceProvider)
{
}
protected override async Task RunAsync(IServiceProvider serviceProvider)
{
var before60Days = DateTime.Today.AddDays(-60).AddSeconds(1);
const int limit = 500;
const string tableName = "deviceuploadlog_20250107";
var data = await DbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, limit);
do
{
if (data.Any())
{
await DbContext.Client.Ado.BeginTranAsync();
try
{
await DbContext.DeleteReallyAsync(data);
foreach (var item in data)
{
item.Id = 0;
}
await DbContext.Client.Insertable(data).AS(tableName).ExecuteCommandAsync();
await DbContext.Client.Ado.CommitTranAsync();
}
catch (Exception)
{
await DbContext.Client.Ado.RollbackTranAsync();
}
data = await DbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, limit);
}
} while (data.Count == limit);
}
}
// using Dlhis.Entity.Device.Entities;
// using Dlhis.ScheduledTask.Attributes;
//
// namespace Dlhis.ScheduledTask.Jobs;
//
// /// <summary>
// /// 归档设备通行记录
// /// </summary>
// [RecurringJob(nameof(ArchiveDeviceUploadLogJob), "0 0/5 * * * ?", Name = "归档设备通行记录")]
// public class ArchiveDeviceUploadLogJob : BaseJob
// {
// public ArchiveDeviceUploadLogJob(IServiceProvider serviceProvider) : base(serviceProvider)
// {
// }
//
// protected override async Task RunAsync(IServiceProvider serviceProvider)
// {
// var before60Days = DateTime.Today.AddDays(-60).AddSeconds(1);
// const int limit = 500;
// const string tableName = "deviceuploadlog_20250107";
//
// var data = await DbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, limit);
//
// do
// {
// if (data.Any())
// {
// await DbContext.Client.Ado.BeginTranAsync();
// try
// {
// await DbContext.DeleteReallyAsync(data);
//
// foreach (var item in data)
// {
// item.Id = 0;
// }
//
// await DbContext.Client.Insertable(data).AS(tableName).ExecuteCommandAsync();
// await DbContext.Client.Ado.CommitTranAsync();
// }
// catch (Exception)
// {
// await DbContext.Client.Ado.RollbackTranAsync();
// }
//
// data = await DbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, limit);
// }
//
// } while (data.Count == limit);
// }
// }