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

test .

Browse Source
This commit is contained in:
liguoyang
2025-05-08 14:47:24 +08:00
parent 9a40b3a6fe
commit ad027c2e3b
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Src/Dlhis.ScheduledTask/DeviceUploadLog/Services/Implements/DeviceUploadLogService.cs
View File

@@ -374,11 +374,15 @@ public class DeviceUploadLogService : IDeviceUploadLogService
public async Task Test() public async Task Test()
{ {
var before60Days = DateTime.Today.AddDays(-60).AddSeconds(1); var before60Days = DateTime.Today.AddDays(-60).AddSeconds(1);
var data = await _dbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).FirstAsync(); var data = await _dbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.RaiseDateTime < before60Days).OrderBy(x => x.Id).ToPageListAsync(1, 1000);
await _dbContext.DeleteReallyAsync(data); await _dbContext.DeleteReallyAsync(data);
const string tableName = "deviceuploadlog_20250107"; const string tableName = "deviceuploadlog_20250107";
data.Id = 0; foreach (var item in data)
{
item.Id = 0;
}
await _dbContext.Client.Insertable(data).AS(tableName).ExecuteCommandAsync(); await _dbContext.Client.Insertable(data).AS(tableName).ExecuteCommandAsync();
} }