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

fix 注释归档任务

Browse Source
This commit is contained in:
liguoyang
2025-05-24 15:15:20 +08:00
parent 55eee61e02
commit 55f68d2009
1 changed files with 61 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,61 +1,61 @@
using Dlhis.Entity.Device.Entities; // using Dlhis.Entity.Device.Entities;
using Dlhis.ScheduledTask.Attributes; // using Dlhis.ScheduledTask.Attributes;
//
namespace Dlhis.ScheduledTask.Jobs; // namespace Dlhis.ScheduledTask.Jobs;
//
/// <summary> // /// <summary>
/// 归档设备通行记录 // /// 归档设备通行记录
/// </summary> // /// </summary>
[RecurringJob(nameof(ArchiveDeviceUploadLogJob), "0 0 3 * * ? ", Name = "归档设备通行记录")] // [RecurringJob(nameof(ArchiveDeviceUploadLogJob), "0 0 3 * * ? ", Name = "归档设备通行记录")]
public class ArchiveDeviceUploadLogJob : BaseJob // public class ArchiveDeviceUploadLogJob : BaseJob
{ // {
public ArchiveDeviceUploadLogJob(IServiceProvider serviceProvider) : base(serviceProvider) // public ArchiveDeviceUploadLogJob(IServiceProvider serviceProvider) : base(serviceProvider)
{ // {
} // }
//
protected override async Task RunAsync(IServiceProvider serviceProvider) // protected override async Task RunAsync(IServiceProvider serviceProvider)
{ // {
//设置60天前的数据需要归档 // //设置60天前的数据需要归档
var before60Days = DateTime.Today.AddDays(-60).AddSeconds(1); // var before60Days = DateTime.Today.AddDays(-60).AddSeconds(1);
//每次查询500条数据 // //每次查询500条数据
const int limit = 500; // const int limit = 500;
//归档表 // //归档表
const string tableName = "deviceuploadlog_20250107"; // const string tableName = "deviceuploadlog_20250107";
//
//正序获取数据 // //正序获取数据
var data = await DbContext.Queryable<DeviceUploadLogEntity>() // var data = await DbContext.Queryable<DeviceUploadLogEntity>()
.Where(x => x.RaiseDateTime < before60Days) // .Where(x => x.RaiseDateTime < before60Days)
.OrderBy(x => x.Id) // .OrderBy(x => x.Id)
.ToPageListAsync(1, limit); // .ToPageListAsync(1, limit);
//
do // do
{ // {
if (data.Any()) // if (data.Any())
{ // {
await DbContext.Client.Ado.BeginTranAsync(); // await DbContext.Client.Ado.BeginTranAsync();
try // try
{ // {
//删除数据 // //删除数据
await DbContext.DeleteReallyAsync(data); // await DbContext.DeleteReallyAsync(data);
foreach (var item in data) // foreach (var item in data)
{ // {
item.Id = 0; // item.Id = 0;
} // }
//
//插入到归档表 // //插入到归档表
await DbContext.Client.Insertable(data).AS(tableName).ExecuteCommandAsync(); // await DbContext.Client.Insertable(data).AS(tableName).ExecuteCommandAsync();
await DbContext.Client.Ado.CommitTranAsync(); // await DbContext.Client.Ado.CommitTranAsync();
} // }
catch (Exception) // catch (Exception)
{ // {
await DbContext.Client.Ado.RollbackTranAsync(); // await DbContext.Client.Ado.RollbackTranAsync();
} // }
//
await Task.Delay(200); // await Task.Delay(200);
//
//再次获取数据 // //再次获取数据
data = await DbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, limit); // data = await DbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, limit);
} // }
} while (data.Count == limit); // } while (data.Count == limit);
} // }
} // }