任务开始前检查配置

performance/Performance.Api/Controllers/ModExtractController.cs

@@ -18,6 +18,7 @@ public class ModExtractController : Controller
     {
         private readonly ClaimService _claim;
         private readonly AllotService _allotService;
+        private readonly CustomExtractService _extractService;
         private readonly IServiceScopeFactory _serviceScopeFactory;
         private readonly IHubNotificationQueue _notificationQueue;
         private readonly IBackgroundTaskQueue _backgroundTaskQueue;
@@ -25,12 +26,14 @@ public class ModExtractController : Controller
         public ModExtractController(
             ClaimService claim,
             AllotService allotService,
+            CustomExtractService extractService,
             IServiceScopeFactory serviceScopeFactory,
             IHubNotificationQueue notificationQueue,
             IBackgroundTaskQueue backgroundTaskQueue)
         {
             _claim = claim;
             _allotService = allotService;
+            _extractService = extractService;
             _serviceScopeFactory = serviceScopeFactory;
             _notificationQueue = notificationQueue;
             _backgroundTaskQueue = backgroundTaskQueue;
@@ -40,6 +43,9 @@ public class ModExtractController : Controller
         public ApiResponse CustomExtract(int allotId)
         {
             var userId = _claim.GetUserId();
+            if (!_extractService.CheckConfigScript(userId, allotId))
+                return new ApiResponse(ResponseType.Fail, "配置信息错误");
+
             _backgroundTaskQueue.QueueBackgroundWorkItem(async token =>
             {
                 using (var scope = _serviceScopeFactory.CreateScope())

performance/Performance.Services/CustomExtractService.cs

@@ -43,6 +43,19 @@ public class CustomExtractService : IAutoInjection
             _perforHospitalconfigRepository = perforHospitalconfigRepository;
             _perforcustscriptRepository = perforcustscriptRepository;
         }
+        public bool CheckConfigScript(int userId, int allotId)
+        {
+            var allot = _perallotRepository.GetEntity(w => w.ID == allotId)
+               ?? throw new PerformanceException("绩效ID无效");
+
+            var scripts = _perforcustscriptRepository.GetEntities(w => w.HospitalId == allot.HospitalId && w.IsEnable == 1);
+
+            scripts = (IsSecondAdmin(userId))
+                ? scripts?.Where(w => w.IsSecondAllot == 1).ToList()
+                : scripts?.Where(w => w.IsOnceAllot == 1).ToList();
+
+            return scripts?.Count() > 0;
+        }
 
         public bool ExtractData(int userId, int allotId, out string resultFilePath)
         {
@@ -59,7 +72,7 @@ public bool ExtractData(int userId, int allotId, out string resultFilePath)
                 ? scripts?.Where(w => w.IsSecondAllot == 1).ToList()
                 : scripts?.Where(w => w.IsOnceAllot == 1).ToList();
 
-            if (scripts == null && scripts.Count > 0)
+            if (scripts == null || scripts.Count == 0)
             {
                 result = false;
                 return result;