This commit is contained in:
2025-07-05 14:43:16 +08:00
parent f17481e35b
commit 379d75b251
2 changed files with 4 additions and 4 deletions

View File

@@ -38,7 +38,7 @@ public class CreateGetUploadRecordJob : BaseJob
) )
{ {
var id = deviceTask.Id; var id = deviceTask.Id;
await DbContext.Deleteable<DeviceEntity>().Where(x => x.Id == id).ExecuteCommandAsync(); await DbContext.Deleteable<DeviceTaskEntity>().Where(x => x.Id == id).ExecuteCommandAsync();
deviceTask = null; deviceTask = null;
} }
else if (deviceTask.Status == DeviceTaskStatusEnumType.Wait) else if (deviceTask.Status == DeviceTaskStatusEnumType.Wait)
@@ -47,7 +47,7 @@ public class CreateGetUploadRecordJob : BaseJob
{ {
// 如果任务等待时间超过3天,则删除任务 // 如果任务等待时间超过3天,则删除任务
var id = deviceTask.Id; var id = deviceTask.Id;
await DbContext.Deleteable<DeviceEntity>().Where(x => x.Id == id).ExecuteCommandAsync(); await DbContext.Deleteable<DeviceTaskEntity>().Where(x => x.Id == id).ExecuteCommandAsync();
deviceTask = null; deviceTask = null;
} }
} }

View File

@@ -37,7 +37,7 @@ public class CreateSyncServerDateTimeJob : BaseJob
) )
{ {
var id = deviceTask.Id; var id = deviceTask.Id;
await DbContext.Deleteable<DeviceEntity>().Where(x => x.Id == id).ExecuteCommandAsync(); await DbContext.Deleteable<DeviceTaskEntity>().Where(x => x.Id == id).ExecuteCommandAsync();
deviceTask = null; deviceTask = null;
} }
else if (deviceTask.Status == DeviceTaskStatusEnumType.Wait) else if (deviceTask.Status == DeviceTaskStatusEnumType.Wait)
@@ -46,7 +46,7 @@ public class CreateSyncServerDateTimeJob : BaseJob
{ {
// 如果任务等待时间超过3天,则删除任务 // 如果任务等待时间超过3天,则删除任务
var id = deviceTask.Id; var id = deviceTask.Id;
await DbContext.Deleteable<DeviceEntity>().Where(x => x.Id == id).ExecuteCommandAsync(); await DbContext.Deleteable<DeviceTaskEntity>().Where(x => x.Id == id).ExecuteCommandAsync();
deviceTask = null; deviceTask = null;
} }
} }