BM报告

IRaCIS.Core.Application/Service/ReadingCalculate/RECIST1Point1_BMCalculateService.cs

@@ -26,6 +26,7 @@ namespace IRaCIS.Core.Application.Service.ReadingCalculate
         IRepository<ReadingTableAnswerRowInfo> _readingTableAnswerRowInfoRepository,
         IRepository<ReadingQuestionTrial> _readingQuestionTrialRepository,
         IRepository<OrganInfo> _organInfoRepository,
+           IRepository<DicomInstance> _dicomInstanceRepository,
         IRepository<ReadingGlobalTaskInfo> _readingGlobalTaskInfoRepository,
         IRepository<SubjectVisit> _subjectVisitRepository,
         IRepository<TumorAssessment_RECIST1Point1BM> _tumorAssessment_RECIST1Point1BM,
@@ -59,7 +60,228 @@ namespace IRaCIS.Core.Application.Service.ReadingCalculate
         /// <returns></returns>
         public async Task<Stream> DownLoadTumorEvaluationStream(DownLoadReadReportInDto inDto)
         {
-            throw new BusinessValidationFailedException(_localizer["ReadingCalculate_DownLoadReadReport"]);
+            var downFile = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, $@"wwwroot/ReadReoprtTemplate/downLoad/{inDto.DownLoadGuid}");
+            Directory.CreateDirectory(downFile);
+
+            var taskinfo = await _visitTaskRepository.Where(x => x.Id == inDto.VisitTaskId && x.ReadingCategory == ReadingCategory.Visit)
+              .Include(x => x.TrialReadingCriterion).FirstNotNullAsync();
+            var visitInfo = await _subjectVisitRepository.Where(x => x.Id == taskinfo.SourceSubjectVisitId).Include(x => x.StudyList).FirstNotNullAsync();
+            var subjectInfo = await _subjectRepository.Where(x => x.Id == taskinfo.SubjectId).Include(x => x.Trial).Include(x => x.SubjectPatientList).FirstNotNullAsync();
+            var subjectPatientList = await _subjectPatientRepository.Where(x => x.SubjectId == subjectInfo.Id).Include(x => x.Patient).ToListAsync();
+            var trialQuestion = await _readingQuestionTrialRepository.Where(x => x.ReadingQuestionCriterionTrialId == taskinfo.TrialReadingCriterionId).ToListAsync();
+            var tableQuestion = await _readingTableQuestionTrialRepository.Where(x => x.ReadingQuestionTrial.ReadingQuestionCriterionTrialId == taskinfo.TrialReadingCriterionId).ToListAsync();
+            var dicotionCode = trialQuestion.Where(x => x.DictionaryCode != string.Empty).Select(x => x.DictionaryCode).Distinct().ToList();
+            dicotionCode.AddRange(tableQuestion.Where(x => x.DictionaryCode != string.Empty).Select(x => x.DictionaryCode).Distinct());
+            var dictionList = await _dictionaryRepository.Where(x => dicotionCode.Contains(x.Code)).Include(x => x.ChildList).ToListAsync();
+            var unitDictionary = await _dictionaryRepository.Where(x => x.Code == "ValueUnit").Include(x => x.ChildList).ToListAsync();
+
+            var relatedVisitTask = await ServiceProvider.GetService<IReadingImageTaskService>().GetRelatedVisitTask(new GetRelatedVisitTaskInDto()
+            {
+                VisitTaskId = inDto.VisitTaskId
+            });
+
+            var relatedTaskIds = relatedVisitTask.Item1.Select(x => x.VisitTaskId).ToList();
+
+            var answerList = await _readingTaskQuestionAnswerRepository.Where(x => relatedTaskIds.Contains(x.VisitTaskId)).Include(x => x.ReadingQuestionTrial).ToListAsync();
+
+            var rowinfoList = await _readingTableAnswerRowInfoRepository.Where(x => relatedTaskIds.Contains(x.VisitTaskId)).Include(x => x.VisitTask).Include(x => x.ReadingQuestionTrial).ToListAsync();
+
+            var instanceIdList = rowinfoList.Select(x => x.InstanceId).ToList();
+            var instanceList = await _dicomInstanceRepository.Where(x => instanceIdList.Contains(x.Id)).Include(x => x.DicomSerie.DicomStudy).ToListAsync();
+
+            var tableAnswerList = await _readingTableQuestionAnswerRepository.Where(x => relatedTaskIds.Contains(x.VisitTaskId)).Include(x => x.ReadingQuestionTrial).Include(x => x.ReadingTableQuestionTrial).ToListAsync();
+            var taskinfoList = await _visitTaskRepository.Where(x => relatedTaskIds.Contains(x.Id))
+                .Include(x => x.SourceSubjectVisit).Include(x => x.SourceSubjectVisit.StudyList)
+                .Include(x => x.DoctorUser).ToListAsync();
+
+            List<ExportVisitData> exportVisitDatas = taskinfoList
+                .Select(x => new ExportVisitData()
+                {
+                    VisitName = x.SourceSubjectVisit.VisitName,
+                    VisitNum = x.VisitTaskNum,
+                    CheckDate = string.Join(",", x.SourceSubjectVisit.StudyList.Where(x => x.StudyTime != null).Select(x => x.StudyTime.Value.ToString("yyyy-MM-dd"))),
+                    CheckInfoList = x.SourceSubjectVisit.StudyList.Select(x => new DicomStudyInfo()
+                    {
+                        BodyPartExamined = x.BodyPartExamined,
+                        Modalities = x.Modalities
+                    }).ToList(),
+                    HaveNewLesion = _generalCalculateService.GetTaskanswer(answerList, dictionList, unitDictionary, x.Id, QuestionType.NewLesions),
+                    TargetResult = _generalCalculateService.GetTaskanswer(answerList, dictionList, unitDictionary, x.Id, QuestionType.TargetLesion),
+                    NoTargetResult = _generalCalculateService.GetTaskanswer(answerList, dictionList, unitDictionary, x.Id, QuestionType.NoTargetLesion),
+                    OverallResult = _generalCalculateService.GetTaskanswer(answerList, dictionList, unitDictionary, x.Id, QuestionType.Tumor),
+                    DoctorName = x.DoctorUser.LastName + x.DoctorUser.FirstName,
+                    SignTime = x.SignTime?.ToString("yyyy-MM-dd HH:mm:ss"),
+                    VisitTargetInfoList = getLesionInfo(LesionType.TargetLesion, x.Id),
+                    VisitNoTargetInfoList = getLesionInfo(LesionType.NonTargetLesions, x.Id),
+                }).OrderBy(x => x.VisitNum).ToList();
+
+
+            #region 两个函数
+            List<VisitLesionInfo> getLesionInfo(LesionType lesionType, Guid Visittaskid)
+            {
+                var targetFocus = rowinfoList.Where(x => x.VisitTaskId == Visittaskid && x.ReadingQuestionTrial.LesionType == lesionType).OrderBy(x => x.RowIndex).ToList();
+
+
+                var targetInfo = new List<VisitLesionInfo>();
+
+                int num = 1;
+                foreach (var item in targetFocus)
+                {
+
+                    VisitLesionInfo target = new VisitLesionInfo
+                    {
+                        RowMark = rowinfoList.Where(x => x.VisitTaskId == Visittaskid && x.RowIndex == item.RowIndex && x.ReadingQuestionTrial.LesionType == lesionType).Select(x => x.RowMark).FirstIsNullReturnEmpty(),
+                        Organ = _generalCalculateService.GetTaskTableAnswer(tableAnswerList, dictionList, unitDictionary, Visittaskid, lesionType, QuestionMark.Organ, item.RowIndex),
+                        Part = _generalCalculateService.GetTaskTableAnswer(tableAnswerList, dictionList, unitDictionary, Visittaskid, lesionType, QuestionMark.Part, item.RowIndex),
+                        Number = num,
+                        StudyCode = instanceList.Where(x => x.Id == item.InstanceId).Select(x => x.DicomSerie.DicomStudy.Code).FirstOrDefault(),
+                        RowId = item.Id,
+                        SeriesNumber = instanceList.Where(x => x.Id == item.InstanceId).Select(x => x.DicomSerie.SeriesNumber).FirstOrDefault(),
+                        InstanceNumber = instanceList.Where(x => x.Id == item.InstanceId).Select(x => x.InstanceNumber).FirstOrDefault(),
+                        VisitLength = getStateInfo(item.VisitTaskId, item.RowIndex, lesionType),
+                    };
+                    targetInfo.Add(target);
+                    num++;
+
+                }
+                if (lesionType == LesionType.TargetLesion)
+                {
+                    for (int i = num; i <= 5; i++)
+                    {
+                        VisitLesionInfo target = new VisitLesionInfo
+                        {
+                            Number = i,
+                        };
+                        targetInfo.Add(target);
+
+                    }
+
+                }
+
+                return targetInfo;
+            }
+
+            decimal getStateInfo(Guid visitTaskid, decimal item, LesionType lesionType)
+            {
+                // 非淋巴结取长径 淋巴结取长短径
+                var state = _generalCalculateService.GetTaskTableAnswer(tableAnswerList, dictionList, unitDictionary, visitTaskid, lesionType, QuestionMark.State, item);
+                var majorAxis = _generalCalculateService.GetTaskTableAnswer(tableAnswerList, dictionList, unitDictionary, visitTaskid, lesionType, QuestionMark.MajorAxis, item, false);
+
+                var isLymph = _generalCalculateService.GetTaskTableAnswer(tableAnswerList, dictionList, unitDictionary, visitTaskid, lesionType, QuestionMark.IsLymph, item);
+                var shortAxis = _generalCalculateService.GetTaskTableAnswer(tableAnswerList, dictionList, unitDictionary, visitTaskid, lesionType, QuestionMark.ShortAxis, item, false);
+
+                var result = string.Empty;
+
+                if (!majorAxis.IsNullOrEmpty())
+                {
+                    result = majorAxis;
+
+                }
+
+                if (isLymph.EqEnum(YesOrNoOrNa.Yes) && !shortAxis.IsNullOrEmpty())
+                {
+                    result = shortAxis;
+                }
+
+                return result.IsNullOrEmptyReturn0();
+
+            }
+            #endregion
+
+            var researchProgramNo = subjectInfo.Trial.ResearchProgramNo;
+            var subjectName = subjectInfo.ShortName;
+            var subjectCode = subjectPatientList.Select(x => x.Patient).OrderByDescending(x => x.CreateTime).Select(x => x.PatientIdStr).FirstIsNullReturnEmpty();
+
+
+
+            List<ExportTumorEvaluationInfo> resultdata = new List<ExportTumorEvaluationInfo>();
+            List<string> times = new List<string>() { "One", "Two", "Three" };
+            List<string> columns = new List<string>() { "VisitName", "CheckDate", "CheckInfoStr", "HaveNewLesion", "TargetResult", "NoTargetResult", "OverallResult", "DoctorSignTime" };
+
+            var forCount = (int)Math.Ceiling((double)exportVisitDatas.Count() / 3);
+            for (int i = 0; i < forCount; i++)
+            {
+                ExportTumorEvaluationInfo export = new ExportTumorEvaluationInfo
+                {
+                    ResearchProgramNo = researchProgramNo,
+                    SubjectName = subjectName,
+                    SubjectCode = subjectCode,
+                    VisitList = exportVisitDatas.Skip(i * 3).Take(3).ToList(),
+                };
+
+                export.Lesion = new ExportData()
+                {
+                    OneTargetSum = export.VisitOne.TargetSum.ToString(),
+                    TwoTargetSum = export.VisitTwo.VisitTargetInfoList.Count() > 0 ? export.VisitTwo.TargetSum.ToString() : string.Empty,
+                    ThreeTargetSum = export.VisitThree.VisitTargetInfoList.Count() > 0 ? export.VisitThree.TargetSum.ToString() : string.Empty,
+
+
+                };
+                foreach (var time in times)
+                {
+                    foreach (var column in columns)
+                    {
+                        _generalCalculateService.SetPropertyDynamically(export.Lesion, column, export, time);
+                    }
+
+                }
+
+                if (i >= forCount - 1)
+                {
+                    export.IsLastPage = true;
+                    // 之后最后一个任务需要签名
+                    var thisVisitListNum = export.VisitList.Count();
+                    switch (thisVisitListNum)
+                    {
+                        case 1:
+                            export.Lesion.OneDoctorSign = "签字：";
+                            break;
+                        case 2:
+                            export.Lesion.TwoDoctorSign = "签字：";
+                            break;
+                        case 3:
+                            export.Lesion.ThreeDoctorSign = "签字：";
+                            break;
+                    }
+
+                }
+                resultdata.Add(export);
+            }
+
+
+
+
+
+            var value = new
+            {
+                VisitTaskList = resultdata,
+                IsLastPage = false,
+            };
+
+
+            var templatePath = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, @"wwwroot/ReadReoprtTemplate/TumorEvaluation_RECIST1.1_CN_V1.docx");
+            var outputFilePath = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, $@"wwwroot/ReadReoprtTemplate/downLoad/{inDto.DownLoadGuid}.docx");
+
+
+            MiniWord.SaveAsByTemplate(outputFilePath, templatePath, value);
+
+
+            //// 获取文件夹中的所有文件路径
+            Directory.Delete(downFile, true);
+
+            if (RuntimeInformation.IsOSPlatform(OSPlatform.Windows))
+            {
+                Stream stream = _generalCalculateService.ReadAndReturnStream(outputFilePath);
+                return stream;
+            }
+            else
+            {
+
+                var pdfurl = System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory, @"wwwroot/ReadReoprtTemplate/downLoad");
+                FileConvertHelper.ConvertWordToPdf(outputFilePath, pdfurl);
+                Stream stream = _generalCalculateService.ReadAndReturnStream(pdfurl + $"/{inDto.DownLoadGuid}.pdf");
+                return stream;
+            }
         }
 
         /// <summary>