提交

IRaCIS.Core.Application/Service/Reading/ReadingImageTask/ReadingImageTaskService.cs

@@ -38,6 +38,7 @@ namespace IRaCIS.Application.Services
         private readonly IRepository<ReadingCriterionPage> _readingCriterionPageRepository;
         private readonly IRepository<ReadingJudgeInfo> _readingJudgeInfoRepository;
         private readonly IRepository<ReadModule> _readModuleRepository;
+        private readonly IRepository<DicomInstance> _dicomInstanceRepository;
         private readonly IRepository<ReadingCriterionDictionary> _readingCriterionDictionaryRepository;
         private readonly IRepository<TumorAssessment> _tumorAssessmentRepository;
         private readonly IRepository<ReadingTableAnswerRowInfo> _readingTableAnswerRowInfoRepository;
@@ -71,6 +72,7 @@ namespace IRaCIS.Application.Services
                   IRepository<ReadingCriterionPage> readingCriterionPageRepository,
                   IRepository<ReadingJudgeInfo> readingJudgeInfoRepository,
                   IRepository<ReadModule> readModuleRepository,
+                  IRepository<DicomInstance> dicomInstanceRepository,
                   IMemoryCache cache,
                   IRepository<ReadingCriterionDictionary> readingCriterionDictionaryRepository,
                   IRepository<TumorAssessment> tumorAssessmentRepository,
@@ -102,6 +104,7 @@ namespace IRaCIS.Application.Services
             this._readingCriterionPageRepository = readingCriterionPageRepository;
             this._readingJudgeInfoRepository = readingJudgeInfoRepository;
             this._readModuleRepository = readModuleRepository;
+            this._dicomInstanceRepository = dicomInstanceRepository;
             this._readingCriterionDictionaryRepository = readingCriterionDictionaryRepository;
             this._tumorAssessmentRepository = tumorAssessmentRepository;
             this._readingTableAnswerRowInfoRepository = readingTableAnswerRowInfoRepository;
@@ -1063,6 +1066,14 @@ namespace IRaCIS.Application.Services
             SubmitTableQuestionOutDto result = new SubmitTableQuestionOutDto();
 
             await VerifyTaskIsSign(inDto.VisitTaskId);
+
+            if (inDto.InstanceId != null)
+            {
+                if (!(await _dicomInstanceRepository.AnyAsync(x => x.Id == inDto.InstanceId && x.SeriesId == inDto.SeriesId)))
+                {
+                    throw new BusinessValidationFailedException($"InstanceId和SeriesId不对应！");
+                }
+            }
             var questionInfo = await _readingQuestionTrialRepository.Where(x => x.Id == inDto.QuestionId).FirstNotNullAsync();
             var criterionId = await _visitTaskRepository.Where(x => x.Id == inDto.VisitTaskId).Select(x => x.TrialReadingCriterionId).FirstOrDefaultAsync();
             var criterionInfo = await _readingQuestionCriterionTrialRepository.Where(x => x.Id == criterionId).FirstNotNullAsync();