diff --git a/Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateGetUploadRecordJob.cs b/Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateGetUploadRecordJob.cs index f8835e35..d11caa4c 100644 --- a/Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateGetUploadRecordJob.cs +++ b/Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateGetUploadRecordJob.cs @@ -11,16 +11,19 @@ public class CreateGetUploadRecordJob { private readonly IDbContext _dbContext; private readonly ILogger _logger; + private readonly ISqlSugarOptionsService _sqlSugarOptionsService; - public CreateGetUploadRecordJob(IDbContext dbContext, ILogger logger) + public CreateGetUploadRecordJob(IDbContext dbContext, ILogger logger, ISqlSugarOptionsService sqlSugarOptionsService) { _logger = logger; + _sqlSugarOptionsService = sqlSugarOptionsService; _dbContext = dbContext; } public async Task RunAsync() { _dbContext.Client.QueryFilter.ClearAndBackup(); + _sqlSugarOptionsService.IgnoreTenant = true; try { var devices = await _dbContext.Queryable() @@ -60,6 +63,7 @@ public class CreateGetUploadRecordJob } finally { + _sqlSugarOptionsService.IgnoreTenant = false; _dbContext.Client.QueryFilter.Restore(); } } diff --git a/Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateSyncServerDateTimeJob.cs b/Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateSyncServerDateTimeJob.cs index 789d6722..a8efb1c1 100644 --- a/Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateSyncServerDateTimeJob.cs +++ b/Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateSyncServerDateTimeJob.cs @@ -10,17 +10,20 @@ namespace Dlhis.ScheduledTask.TaskAssignment.Job { private readonly IDbContext _dbContext; private readonly ILogger _logger; + private readonly ISqlSugarOptionsService _sqlSugarOptionsService; - public CreateSyncServerDateTimeJob(IDbContext dbContext, ILogger logger) + public CreateSyncServerDateTimeJob(IDbContext dbContext, ILogger logger, ISqlSugarOptionsService sqlSugarOptionsService) { _dbContext = dbContext; _logger = logger; + _sqlSugarOptionsService = sqlSugarOptionsService; } public async Task RunAsync() { _dbContext.Client.QueryFilter.ClearAndBackup(); + _sqlSugarOptionsService.IgnoreTenant = true; try { var deviceUniqueNos = await _dbContext.Queryable() @@ -60,6 +63,7 @@ namespace Dlhis.ScheduledTask.TaskAssignment.Job } finally { + _sqlSugarOptionsService.IgnoreTenant = false; _dbContext.Client.QueryFilter.Restore(); } }