fix tenantId null 问题
This commit is contained in:
@@ -11,16 +11,19 @@ public class CreateGetUploadRecordJob
|
||||
{
|
||||
private readonly IDbContext _dbContext;
|
||||
private readonly ILogger<CreateGetUploadRecordJob> _logger;
|
||||
private readonly ISqlSugarOptionsService _sqlSugarOptionsService;
|
||||
|
||||
public CreateGetUploadRecordJob(IDbContext dbContext, ILogger<CreateGetUploadRecordJob> logger)
|
||||
public CreateGetUploadRecordJob(IDbContext dbContext, ILogger<CreateGetUploadRecordJob> logger, ISqlSugarOptionsService sqlSugarOptionsService)
|
||||
{
|
||||
_logger = logger;
|
||||
_sqlSugarOptionsService = sqlSugarOptionsService;
|
||||
_dbContext = dbContext;
|
||||
}
|
||||
|
||||
public async Task RunAsync()
|
||||
{
|
||||
_dbContext.Client.QueryFilter.ClearAndBackup<ITenantId>();
|
||||
_sqlSugarOptionsService.IgnoreTenant = true;
|
||||
try
|
||||
{
|
||||
var devices = await _dbContext.Queryable<DeviceEntity>()
|
||||
@@ -60,6 +63,7 @@ public class CreateGetUploadRecordJob
|
||||
}
|
||||
finally
|
||||
{
|
||||
_sqlSugarOptionsService.IgnoreTenant = false;
|
||||
_dbContext.Client.QueryFilter.Restore();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -10,17 +10,20 @@ namespace Dlhis.ScheduledTask.TaskAssignment.Job
|
||||
{
|
||||
private readonly IDbContext _dbContext;
|
||||
private readonly ILogger<CreateSyncServerDateTimeJob> _logger;
|
||||
private readonly ISqlSugarOptionsService _sqlSugarOptionsService;
|
||||
|
||||
public CreateSyncServerDateTimeJob(IDbContext dbContext, ILogger<CreateSyncServerDateTimeJob> logger)
|
||||
public CreateSyncServerDateTimeJob(IDbContext dbContext, ILogger<CreateSyncServerDateTimeJob> logger, ISqlSugarOptionsService sqlSugarOptionsService)
|
||||
{
|
||||
_dbContext = dbContext;
|
||||
_logger = logger;
|
||||
_sqlSugarOptionsService = sqlSugarOptionsService;
|
||||
}
|
||||
|
||||
|
||||
public async Task RunAsync()
|
||||
{
|
||||
_dbContext.Client.QueryFilter.ClearAndBackup<ITenantId>();
|
||||
_sqlSugarOptionsService.IgnoreTenant = true;
|
||||
try
|
||||
{
|
||||
var deviceUniqueNos = await _dbContext.Queryable<DeviceTaskEntity>()
|
||||
@@ -60,6 +63,7 @@ namespace Dlhis.ScheduledTask.TaskAssignment.Job
|
||||
}
|
||||
finally
|
||||
{
|
||||
_sqlSugarOptionsService.IgnoreTenant = false;
|
||||
_dbContext.Client.QueryFilter.Restore();
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user