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
2024-12-01 13:00:27 +08:00
parent f93bd5abca
commit cbbb4b5c1c
1 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Src/Dlhis.ScheduledTask/Jobs/SyncOriginCardInfoJob.cs
View File

@@ -23,17 +23,15 @@ public class SyncOriginCardInfoJob : BaseJob
protected override async Task RunAsync(IServiceProvider serviceProvider)
{
var start = DateTime.Now.AddDays(-2);
var start = DateTime.Now.AddDays(-3);
var requests = await DbContext.Queryable<DeviceUploadLogEntity>()
.LeftJoin<DeviceEntity>((x, device) => x.DeviceUniqueNo == device.UniqueNo)
.Where(x => x.ModifiedTime > start)
.Where(x => !string.IsNullOrEmpty(x.UserUniqueNo))
.Where(x => x.Type == DeviceUploadLogTypeEnumType.Attendance)
.Where(x => x.Sync == false)
.Where(x => !string.IsNullOrEmpty(x.UserUniqueNo))
.Where(x => SqlFunc.Subqueryable<OutsourceEntity>().Where(p => p.Code == x.UserUniqueNo).NotAny())
.Where(x => SqlFunc.Subqueryable<DeviceEntity>()
.Where(p => p.UniqueNo == x.DeviceUniqueNo)
.Where(p => p.Type == DeviceTypeEnumType.Attendance || (p.Type == DeviceTypeEnumType.Door && p.AsAttendance)).Any())
.Select((x, device) => new UploadAttendanceRequestItem
{
Id = x.Id,
@@ -41,7 +39,7 @@ public class SyncOriginCardInfoJob : BaseJob
ZNOTE = device.DeployPlace,
ZWORKCODE = x.UserUniqueNo
})
.ToPageListAsync(1, 500);
.ToPageListAsync(1, 1000);
Logger.LogInformation("获取待上传考勤记录数:{count}", requests.Count);