diff --git a/IRaCIS.Core.API/HostService/SyncFileRecoveryService.cs b/IRaCIS.Core.API/HostService/SyncFileRecoveryService.cs index eebcab180..da3a7be84 100644 --- a/IRaCIS.Core.API/HostService/SyncFileRecoveryService.cs +++ b/IRaCIS.Core.API/HostService/SyncFileRecoveryService.cs @@ -6,6 +6,7 @@ using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Hosting; using Microsoft.Extensions.Logging; +using Microsoft.Extensions.Options; using System; using System.Linq; using System.Threading; @@ -84,13 +85,22 @@ public class FileSyncWorker(IServiceScopeFactory _scopeFactory, ILogger>(); var _uploadFileSyncRecordRepository = scope.ServiceProvider.GetRequiredService>(); + + var syncConfig = (scope.ServiceProvider.GetRequiredService>()).CurrentValue; + var oss = scope.ServiceProvider.GetRequiredService(); var file = await _fileUploadRecordRepository.FirstOrDefaultAsync(t => t.Id == id); - if (file == null || file.IsNeedSync != true) + if (file == null || file.IsNeedSync != true || syncConfig.IsOpenStoreSync == false) return; + //如果发现系统配置某一边同步进行了关闭,那么就直接返回,不执行任务 + if (syncConfig.SyncConfigList.Any(t => t.UploadRegion == file.UploadRegion && t.IsOpenSync == false)) + { + return; + } + var log = new UploadFileSyncRecord { FileUploadRecordId = id,