fix 优化查询数据范围
This commit is contained in:
@@ -23,14 +23,17 @@ public class SyncOriginCardInfoJob : BaseJob
|
|||||||
|
|
||||||
protected override async Task RunAsync(IServiceProvider serviceProvider)
|
protected override async Task RunAsync(IServiceProvider serviceProvider)
|
||||||
{
|
{
|
||||||
|
var start = DateTime.Now.AddDays(-7);
|
||||||
|
|
||||||
var requests = await DbContext.Queryable<DeviceUploadLogEntity>()
|
var requests = await DbContext.Queryable<DeviceUploadLogEntity>()
|
||||||
.LeftJoin<DeviceEntity>((x, device) => x.DeviceUniqueNo == device.UniqueNo)
|
.LeftJoin<DeviceEntity>((x, device) => x.DeviceUniqueNo == device.UniqueNo)
|
||||||
.Where(x => !string.IsNullOrEmpty(x.UserUniqueNo))
|
.Where(x => !string.IsNullOrEmpty(x.UserUniqueNo))
|
||||||
.Where(x => x.Sync == false)
|
.Where(x => x.Sync == false)
|
||||||
//.Where(x => x.Status) todo
|
|
||||||
.Where(x => SqlFunc.Subqueryable<OutsourceEntity>().Where(p => p.Code == x.UserUniqueNo).NotAny())
|
.Where(x => SqlFunc.Subqueryable<OutsourceEntity>().Where(p => p.Code == x.UserUniqueNo).NotAny())
|
||||||
.Where(x => SqlFunc.Subqueryable<DeviceEntity>().Where(p => p.UniqueNo == x.DeviceUniqueNo)
|
.Where(x => SqlFunc.Subqueryable<DeviceEntity>()
|
||||||
|
.Where(p => p.UniqueNo == x.DeviceUniqueNo)
|
||||||
.Where(p => p.Type == DeviceTypeEnumType.Attendance || (p.Type == DeviceTypeEnumType.Door && p.AsAttendance)).Any())
|
.Where(p => p.Type == DeviceTypeEnumType.Attendance || (p.Type == DeviceTypeEnumType.Door && p.AsAttendance)).Any())
|
||||||
|
.Where(x => x.RaiseDateTime > start)
|
||||||
.Select((x, device) => new UploadAttendanceRequest
|
.Select((x, device) => new UploadAttendanceRequest
|
||||||
{
|
{
|
||||||
Id = x.Id,
|
Id = x.Id,
|
||||||
|
|||||||
Reference in New Issue
Block a user