using IRaCIS.Core.Application.Service.Reading.Dto; using IRaCIS.Core.Application.ViewModel; using IRaCIS.Core.Domain.Share; using IRaCIS.Core.Infra.EFCore.Common; using IRaCIS.Core.Infrastructure; using MassTransit; using Microsoft.AspNetCore.Mvc; namespace IRaCIS.Core.Application.Service.ReadingCalculate { [ApiExplorerSettings(GroupName = "Reading")] public class PCWG3CalculateService(IRepository _readingTableQuestionAnswerRepository, IRepository _visitTaskRepository, IRepository _readingQuestionCriterionTrialRepository, IRepository _readingTableQuestionTrialRepository, IRepository _readingTableAnswerRowInfoRepository, IRepository _readingQuestionTrialRepository, IRepository _subjectVisitRepository, IRepository _organInfoRepository, IRepository _dicomStudyRepository, IRepository _noneDicomStudyRepository, IRepository _tumorAssessmentRepository, IGeneralCalculateService _generalCalculateService, IRepository _readingTaskQuestionAnswerRepository, IMapper _mapper, IUserInfo _userInfo, IStringLocalizer _localizer) : BaseService, ICriterionCalculateService { private List siteVisitForTumorList; /// /// 阅片导入 /// /// public async Task ReadingImport() { } /// /// 获取阅片的计算数据 /// /// /// public async Task GetReadingCalculationData(GetReadingCalculationDataInDto inDto) { return new { }; } #region 删除病灶获取起始病灶序号 /// /// 删除病灶获取起始病灶序号 /// /// public async Task GetDeleteLesionStatrIndex(DeleteReadingRowAnswerInDto inDto) { var rowInfo = await _readingTableAnswerRowInfoRepository.Where(x => x.Id == inDto.RowId).Include(x => x.ReadingQuestionTrial).FirstNotNullAsync(); if (rowInfo.ReadingQuestionTrial.LesionType == LesionType.NewLesions) { var minIndex = await _readingTableAnswerRowInfoRepository.Where(x => x.QuestionId == rowInfo.QuestionId && x.VisitTaskId == inDto.VisitTaskId).OrderBy(x => x.RowIndex).Select(x => x.RowIndex).FirstOrDefaultAsync(); return (int)minIndex; } else { return 1; } } #endregion #region 获取阅片报告 /// /// 获取阅片报告 /// /// /// [HttpPost] public async Task GetReadingReportEvaluation(GetReadingReportEvaluationInDto indto) { GetReadingReportEvaluationOutDto result = new GetReadingReportEvaluationOutDto(); result.CalculateResult = await this.GetReportVerify(new GetReportVerifyInDto() { VisitTaskId = indto.VisitTaskId }); var visitTaskInfo = await _visitTaskRepository.Where(x => x.Id == indto.VisitTaskId).FirstNotNullAsync(); result.ReadingTaskState = visitTaskInfo.ReadingTaskState; var taskInfoList = await _generalCalculateService.GetReadingReportTaskList(indto.VisitTaskId); taskInfoList = taskInfoList.Where(x => x.VisitTaskNum <= visitTaskInfo.VisitTaskNum).ToList(); result.VisitTaskList = taskInfoList; var visitTaskIds = taskInfoList.Select(x => x.VisitTaskId).ToList(); var criterionId = visitTaskInfo.TrialReadingCriterionId; var questionList = await _readingQuestionTrialRepository.Where(x => x.ReadingQuestionCriterionTrialId == criterionId && x.ShowQuestion != ShowQuestion.Hide) //.Where(x => x.LesionType != LesionType.BaselineLesions) .Where(x => x.QuestionType != QuestionType.TherapeuticEffectEvaluationGroup) .ToListAsync(); // 新病灶 var questionNewLesions = await _readingQuestionTrialRepository.Where(x => x.ReadingQuestionCriterionTrialId == visitTaskInfo.TrialReadingCriterionId && x.LesionType == LesionType.NewLesions).FirstNotNullAsync(); var tableQuestionList = await _readingTableQuestionTrialRepository.Where(x => x.TrialCriterionId == criterionId).OrderBy(x => x.ShowOrder).ToListAsync(); var tableAnsweRowInfos = await _readingTableAnswerRowInfoRepository.Where(x => x.VisitTaskId == indto.VisitTaskId).ProjectTo(_mapper.ConfigurationProvider).ToListAsync(); var answers = await _readingTaskQuestionAnswerRepository.Where(x => visitTaskIds.Contains(x.VisitTaskId)) .Where(x => x.ReadingQuestionTrialId != questionNewLesions.Id || x.VisitTaskId == visitTaskInfo.Id) .ToListAsync(); if (visitTaskInfo.ReadingTaskState != ReadingTaskState.HaveSigned) { foreach (var item in answers) { item.Answer = item.PCWGInterimAnswer == null ? item.Answer : item.PCWGInterimAnswer; } } var tableAnswers = await _readingTableQuestionAnswerRepository.Where(x => visitTaskIds.Contains(x.VisitTaskId)) .Where(x => x.QuestionId != questionNewLesions.Id || x.VisitTaskId == visitTaskInfo.Id) .ToListAsync(); var alltableAnsweRowInfos = await _readingTableAnswerRowInfoRepository.Where(x => visitTaskIds.Contains(x.VisitTaskId)).ToListAsync(); var organIds = alltableAnsweRowInfos.Where(x => x.OrganInfoId != null).Select(x => x.OrganInfoId).Distinct().ToList(); var organInfos = await _organInfoRepository.Where(x => organIds.Contains(x.Id)).ToListAsync(); var needChangeType = new List() { QuestionMark.Organ, QuestionMark.Location, QuestionMark.Part, }; // 第一级 分组 #region 构造问题 List questions = questionList.Where(x => x.Type == ReadingQestionType.Group).OrderBy(x => x.ShowOrder).Select(x => new ReadingReportDto() { QuestionId = x.Id, GroupName = x.GroupName, GroupEnName = x.GroupEnName, IsShowInDicom = x.IsShowInDicom, Type = x.Type, GroupId = x.GroupId, QuestionType = x.QuestionType, LesionType = x.LesionType, QuestionGenre = x.QuestionGenre, DataSource = x.DataSource, DictionaryCode = x.DictionaryCode, TypeValue = x.TypeValue, QuestionName = x.QuestionName.LanguageName(x.QuestionEnName, _userInfo.IsEn_Us), ShowOrder = x.ShowOrder, ValueType = x.ValueType, CustomUnit = x.CustomUnit, Unit = x.Unit, ReportLayType = ReportLayType.Group, HighlightAnswer = x.HighlightAnswer, HighlightAnswerList = x.HighlightAnswerList, }).ToList(); // 分组 foreach (var item in questions) { // 问题 item.Childrens = questionList.Where(x => x.GroupId == item.QuestionId).OrderBy(x => x.ShowOrder).Select(x => new ReadingReportDto() { GroupName = x.GroupName, GroupEnName = x.GroupEnName, QuestionId = x.Id, IsShowInDicom = x.IsShowInDicom, QuestionName = x.QuestionName.LanguageName(x.QuestionEnName, _userInfo.IsEn_Us), LesionType = x.LesionType, QuestionGenre = x.QuestionGenre, DataSource = x.DataSource, DictionaryCode = x.DictionaryCode, Type = x.Type, QuestionType = x.QuestionType, TypeValue = x.TypeValue, ShowOrder = x.ShowOrder, OrderMark = x.OrderMark, ValueType = x.ValueType, Unit = x.Unit, CustomUnit = x.CustomUnit, ReportLayType = ReportLayType.Question, HighlightAnswer = x.HighlightAnswer, HighlightAnswerList = x.HighlightAnswerList, }).ToList(); // 问题 foreach (var question in item.Childrens) { foreach (var task in taskInfoList) { var answer = answers.Where(x => x.VisitTaskId == task.VisitTaskId && x.ReadingQuestionTrialId == question.QuestionId).FirstOrDefault(); question.Answer.Add(new TaskQuestionAnswer() { Answer = answer == null ? string.Empty : answer.Answer, IsGlobalChange = answer == null ? false : answer.IsGlobalChange, GlobalChangeAnswer = answer == null ? string.Empty : answer.GlobalChangeAnswer, TaskName = task.TaskName, VisitTaskId = task.VisitTaskId, }); } // 构造表格行数据 var rowlist = tableAnsweRowInfos.Where(x => x.QuestionId == question.QuestionId).OrderBy(x => x.RowIndex).ToList(); question.Childrens = rowlist.OrderBy(x => x.RowIndex).Select(x => new ReadingReportDto() { QuestionName = question.OrderMark + x.RowIndex.GetLesionMark(), SplitOrMergeLesionName = x.MergeName.IsNullOrEmpty() ? x.SplitName : x.MergeName, SplitOrMergeType = x.SplitOrMergeType, LesionType = question.LesionType, IsCanEditPosition = x.IsCanEditPosition, RowIndex = x.RowIndex, BlindName = x.BlindName, RowId = x.Id, ReportLayType = ReportLayType.Lesions, FristAddTaskNum = x.FristAddTaskNum, }).ToList(); foreach (var row in question.Childrens) { // tableQuestion row.Childrens = tableQuestionList.Where(x => x.ReadingQuestionId == question.QuestionId).Select(x => new ReadingReportDto() { QuestionName = x.QuestionName.LanguageName(x.QuestionEnName, _userInfo.IsEn_Us), QuestionId = x.ReadingQuestionId, TableQuestionId = x.Id, Type = x.Type, LesionType = question.LesionType, TableQuestionType = x.TableQuestionType, DataSource = x.DataSource, DictionaryCode = x.DictionaryCode, QuestionMark = x.QuestionMark, TypeValue = x.TypeValue, RowIndex = row.RowIndex, ShowOrder = x.ShowOrder, ValueType = x.ValueType, RowId = row.RowId, Unit = x.Unit, ReportLayType = ReportLayType.TableQuestion, FristAddTaskNum = row.FristAddTaskNum, }).ToList(); foreach (var tableQuestion in row.Childrens) { foreach (var task in taskInfoList) { var rowinfo = alltableAnsweRowInfos.Where(x => x.VisitTaskId == task.VisitTaskId && x.QuestionId == tableQuestion.QuestionId && x.RowIndex == tableQuestion.RowIndex).FirstOrDefault(); var taskQuestionAnswer = new TaskQuestionAnswer() { Answer = tableAnswers.Where(x => x.VisitTaskId == task.VisitTaskId && x.QuestionId == tableQuestion.QuestionId && x.RowIndex == tableQuestion.RowIndex && x.TableQuestionId == tableQuestion.TableQuestionId).Select(x => x.Answer).FirstIsNullReturnEmpty(), TaskName = task.TaskName, VisitTaskId = task.VisitTaskId, }; if (rowinfo != null && rowinfo.OrganInfoId != null) { var organInfo = organInfos.Where(x => x.Id == rowinfo.OrganInfoId).FirstOrDefault(); if (organInfo != null && needChangeType.Contains(tableQuestion.QuestionMark)) { if (_userInfo.IsEn_Us) { switch (tableQuestion.QuestionMark) { case QuestionMark.Organ: taskQuestionAnswer.Answer = organInfo.TULOCEN; break; case QuestionMark.Location: if (organInfo.IsCanEditPosition) { } else { taskQuestionAnswer.Answer = organInfo.TULATEN; } break; case QuestionMark.Part: taskQuestionAnswer.Answer = organInfo.PartEN; break; } } else { switch (tableQuestion.QuestionMark) { case QuestionMark.Organ: taskQuestionAnswer.Answer = organInfo.TULOC; break; case QuestionMark.Location: if (organInfo.IsCanEditPosition) { } else { taskQuestionAnswer.Answer = organInfo.TULAT; } break; case QuestionMark.Part: taskQuestionAnswer.Answer = organInfo.Part; break; } } } } tableQuestion.Answer.Add(taskQuestionAnswer); } } } }; } #endregion result.TaskQuestions = questions; return result; } #endregion /// /// 将上一次的病灶信息添加到这一次 /// /// /// public async Task AddTaskLesionAnswerFromLastTask(AddTaskLesionAnswerFromLastTaskInDto inDto) { var visitTaskId = inDto.VisitTaskId; var taskinfo = await _visitTaskRepository.Where(x => x.Id == visitTaskId).FirstNotNullAsync(); var baseLineVisitId = await _subjectVisitRepository.Where(x => x.SubjectId == taskinfo.SubjectId && x.IsBaseLine).Select(x => x.Id).FirstOrDefaultAsync(); // 判断当前任务是否是基线 if (taskinfo.SourceSubjectVisitId != baseLineVisitId) { // 判断当前任务是是否有表格问题答案 if (!(await _readingTableQuestionAnswerRepository.AnyAsync(x => x.VisitTaskId == visitTaskId))) { var LastVisitTaskId = await _visitTaskRepository.Where(x => x.ReadingCategory == ReadingCategory.Visit && x.TrialReadingCriterionId == taskinfo.TrialReadingCriterionId && x.IsAnalysisCreate == taskinfo.IsAnalysisCreate && x.DoctorUserId == taskinfo.DoctorUserId && x.IsSelfAnalysis == taskinfo.IsSelfAnalysis && x.SubjectId == taskinfo.SubjectId && x.ReadingTaskState == ReadingTaskState.HaveSigned && x.VisitTaskNum < taskinfo.VisitTaskNum && x.TaskState == TaskState.Effect && x.ArmEnum == taskinfo.ArmEnum ).OrderByDescending(x => x.VisitTaskNum).Select(x => x.Id).FirstOrDefaultAsync(); // 上一次的表格答案 var copyTableAnswers = await _readingTableQuestionAnswerRepository.Where(x => x.VisitTaskId == LastVisitTaskId ).Select(x => new CopyTableAnswerDto() { Answer = x.Answer, QuestionId = x.QuestionId, RowId = x.RowId, QuestionMark = x.ReadingTableQuestionTrial.QuestionMark, TableQuestionId = x.TableQuestionId, RowIndex = x.RowIndex, TrialId = x.TrialId }).ToListAsync(); // 上一次的行信息 var tableRowAnswers = await _readingTableAnswerRowInfoRepository.Where(x => x.VisitTaskId == LastVisitTaskId).ProjectTo(_mapper.ConfigurationProvider).ToListAsync(); tableRowAnswers.ForEach(x => { x.VisitTaskId = visitTaskId; x.IsCurrentTaskAdd = false; x.Id = NewId.NextGuid(); x.SeriesId = null; x.InstanceId = null; x.MeasureData = string.Empty; x.PicturePath = string.Empty; }); tableRowAnswers.ForEach(x => { x.SplitRowId = tableRowAnswers.Where(y => y.OriginalId == x.SplitRowId).Select(y => y.Id).FirstOrDefault(); x.MergeRowId = tableRowAnswers.Where(y => y.OriginalId == x.MergeRowId).Select(y => y.Id).FirstOrDefault(); }); List notNeedCopyMarks = new List() { QuestionMark.State, QuestionMark.LesionNumber, }; var tableAnswers = copyTableAnswers.Select(x => new ReadingTableQuestionAnswer { Id = NewId.NextGuid(), Answer = notNeedCopyMarks.Contains(x.QuestionMark) ? string.Empty : x.Answer, QuestionId = x.QuestionId, RowIndex = x.RowIndex, RowId = tableRowAnswers.Where(y => y.OriginalId == x.RowId).Select(x => x.Id).FirstOrDefault(), TableQuestionId = x.TableQuestionId, TrialId = x.TrialId, VisitTaskId = visitTaskId, }).ToList(); try { // 新病灶外层问题 var newLesionQuestion = await _readingQuestionTrialRepository.Where(x => x.LesionType == LesionType.NewLesions && x.ReadingQuestionCriterionTrialId == taskinfo.TrialReadingCriterionId).FirstNotNullAsync(); // 既往病灶外层问题 var alwaysNewLesionsQuestion = await _readingQuestionTrialRepository.Where(x => x.LesionType == LesionType.AlwaysNewLesions && x.ReadingQuestionCriterionTrialId == taskinfo.TrialReadingCriterionId).FirstNotNullAsync(); // 新病灶表格问题 var newLesionTableQuestions = await _readingTableQuestionTrialRepository.Where(x => x.ReadingQuestionId == newLesionQuestion.Id).ToListAsync(); // 既往病灶表格问题 var alwaysNewLesionsTableQuestions = await _readingTableQuestionTrialRepository.Where(x => x.ReadingQuestionId == alwaysNewLesionsQuestion.Id).ToListAsync(); Dictionary alwaysTableQuestionIdDic = new Dictionary(); newLesionTableQuestions.ForEach(x => { alwaysTableQuestionIdDic.Add( x.Id, alwaysNewLesionsTableQuestions.Where(y => y.QuestionName == x.QuestionName).Select(y => y.Id).FirstOrDefault() ); }); foreach (var item in tableRowAnswers.Where(x => x.QuestionId == newLesionQuestion.Id).OrderBy(x => x.RowIndex)) { item.QuestionId = alwaysNewLesionsQuestion.Id; foreach (var tableAnswer in tableAnswers.Where(y => y.RowId == item.Id)) { tableAnswer.QuestionId = alwaysNewLesionsQuestion.Id; tableAnswer.TableQuestionId = alwaysTableQuestionIdDic[tableAnswer.TableQuestionId]; } } } catch (Exception) { throw new BusinessValidationFailedException(_localizer["ReadingCalculate_Abnormal"]); } var addList = _mapper.Map>(tableRowAnswers); await _readingTableAnswerRowInfoRepository.AddRangeAsync(addList); await _readingTableQuestionAnswerRepository.AddRangeAsync(tableAnswers); await _readingTableQuestionAnswerRepository.SaveChangesAsync(); } } return new AddTaskLesionAnswerFromLastTaskOutDto() { IsBaseLine = taskinfo.SourceSubjectVisitId == baseLineVisitId, }; } /// /// 测试计算 /// /// /// /// [HttpPost] public async Task TestCalculate(Guid visitTaskId, QuestionType type) { ReadingCalculateDto readingData = await _generalCalculateService.GetReadingCalculateDto(visitTaskId); // 只获取当前的 不会获取上一次临时修改的结果 foreach (var item in readingData.QuestionInfo) { if (item.PCWGInterimAnswer != null) { item.Answer = item.PCWGInterimAnswer; } } await ReadingCalculate(readingData, new List() { type }); } /// /// 计算任务 /// /// /// [HttpPost] public async Task CalculateTask(CalculateTaskInDto inDto) { ReadingCalculateDto readingData = await _generalCalculateService.GetReadingCalculateDto(inDto.VisitTaskId); // 只获取当前的 不会获取上一次临时修改的结果 foreach (var item in readingData.QuestionInfo) { if (item.PCWGInterimAnswer != null) { item.Answer = item.PCWGInterimAnswer; } } readingData.IsChangeOtherTask = inDto.IsChangeOtherTask; await ReadingCalculate(readingData); } /// /// 自动计算 /// /// /// /// public async Task ReadingCalculate(ReadingCalculateDto inDto, List? calculateType = null) { #region 计算 这里顺序非常重要 后面计算的值要依赖前面计算的结果 var needAddList = new List(); List calculateList = new List() { // 基线病灶计数 new ReadingCalculateData (){QuestionType=QuestionType.BaseLineLesionsCount,GetIntFun=GetBaseLineLesionsCount}, // 新病灶计数 new ReadingCalculateData (){QuestionType=QuestionType.NewLesionsCount,GetIntFun=GetNewLesionsCount}, // 既往新病灶 new ReadingCalculateData (){QuestionType=QuestionType.AlwaysNewLesionsCount,GetIntFun=GetAlwaysNewLesionsCount}, // 自治疗后第二个访视点以来持续的新骨病变数量 new ReadingCalculateData (){QuestionType=QuestionType.NewBoneLesionsCount,GetIntFun=GetNewBoneLesionCount}, // 间隔天数 new ReadingCalculateData (){QuestionType=QuestionType.DaysBetween,GetIntFun=GetNumberOfDaysBetween}, // 访视点肿瘤评估 new ReadingCalculateData (){QuestionType=QuestionType.SiteVisitForTumorEvaluation,GetStringFun=GetSiteVisitForTumorEvaluation}, }; if (calculateType != null) { calculateList = calculateList.Where(x => calculateType.Contains(x.QuestionType)).ToList(); } foreach (var calculate in calculateList) { var item = inDto.QuestionInfo.FirstOrDefault(x => x.QuestionType == calculate.QuestionType); if (item != null) { //计算答案 if (inDto.IsOnlyChangeAllTask == false) { #region 计算答案 switch (calculate.QuestionType) { case QuestionType.BaseLineLesionsCount: item.Answer = (await calculate.GetIntFun(inDto)).ToString(); break; case QuestionType.NewLesionsCount: if (inDto.VisitTaskNum >= 1) { item.Answer = (await calculate.GetIntFun(inDto)).ToString(); } else { item.Answer = nameof(YesOrNoOrNa.NA); } break; case QuestionType.AlwaysNewLesionsCount: if (inDto.VisitTaskNum > 1) { item.Answer = (await calculate.GetIntFun(inDto)).ToString(); } else { item.Answer = nameof(YesOrNoOrNa.NA); } break; case QuestionType.NewBoneLesionsCount: item.Answer = (await calculate.GetIntFun(inDto)).ToString(); if (item.Answer == "-1") { item.Answer = nameof(YesOrNoOrNa.NA); } break; case QuestionType.DaysBetween: item.Answer = (await calculate.GetIntFun(inDto)).ToString(); break; case QuestionType.SiteVisitForTumorEvaluation: item.Answer = await calculate.GetStringFun(inDto); break; default: item.Answer = string.Empty; break; } #endregion // 修改修约小数位数 try { List valueOfTypes = new List() { ValueOfType.Decimals, ValueOfType.Percentage }; if (valueOfTypes.Contains(item.ValueType)) { item.Answer = decimal.Round(decimal.Parse(item.Answer.IsNullOrEmpty() ? "0" : item.Answer), inDto.DigitPlaces).ToString("F" + inDto.DigitPlaces.ToString()); } } catch (Exception) { } needAddList.Add(new ReadingTaskQuestionAnswer() { Answer = item.Answer, ReadingQuestionTrialId = item.QuestionId, }); } // 修改全局 if (inDto.IsChangeOtherTask && calculate.ChangeAllTaskFun != null) { await calculate.ChangeAllTaskFun(new ChangeAllTaskDto() { calculateDto = inDto, QuestionId = item.QuestionId, }); } } } var questionIds = needAddList.Select(x => x.ReadingQuestionTrialId).ToList(); await _readingTaskQuestionAnswerRepository.BatchDeleteNoTrackingAsync(x => questionIds.Contains(x.ReadingQuestionTrialId) && x.VisitTaskId == inDto.VisitTaskId); needAddList.ForEach(x => { x.SubjectId = inDto.SubjectId; x.ReadingQuestionCriterionTrialId = inDto.CriterionId; x.VisitTaskId = inDto.VisitTaskId; x.TrialId = inDto.TrialId; x.SubjectId = inDto.SubjectId; }); await _readingTaskQuestionAnswerRepository.AddRangeAsync(needAddList); await _readingTaskQuestionAnswerRepository.SaveChangesAsync(); #endregion } #region 基线病灶计数 /// /// 基线病灶计数 /// /// /// public async Task GetBaseLineLesionsCount(ReadingCalculateDto inDto) { try { return (int)(inDto.QuestionInfo.Where(x => x.LesionType == LesionType.BaselineLesions).SelectMany(x => x.TableRowInfoList) .Sum(x => x.TableQuestionList.Where(y => y.QuestionMark == QuestionMark.LesionNumber).Select(x => x.Answer).FirstOrDefault().IsNullOrEmptyReturn0())); } catch { return 0; } } #endregion #region 新病灶计数 /// /// 获取新病灶计数 /// /// /// public async Task GetNewLesionsCount(ReadingCalculateDto inDto) { return inDto.QuestionInfo.Where(x => x.LesionType == LesionType.NewLesions).SelectMany(x => x.TableRowInfoList) .Where(x => x.TableQuestionList.Any(y => y.QuestionMark == QuestionMark.State && y.Answer == EvaluationOfState.Exists.GetEnumInt())) .Count(); } #endregion #region 既往新病灶计数 /// /// 既往新病灶计数 /// /// /// public async Task GetAlwaysNewLesionsCount(ReadingCalculateDto inDto) { return inDto.QuestionInfo.Where(x => x.LesionType == LesionType.AlwaysNewLesions).SelectMany(x => x.TableRowInfoList) .Where(x => x.TableQuestionList.Any(y => y.QuestionMark == QuestionMark.State && y.Answer == EvaluationOfState.Exists.GetEnumInt())) .Count(); } #endregion #region 自治疗后第二个访视点以来持续的新骨病变数量 /// /// 自治疗后第二个访视点以来持续的新骨病变数量 /// /// /// public async Task GetNewBoneLesionCount(ReadingCalculateDto inDto) { var taskList = await GetSiteVisitForTumorList(inDto); var result = 0; var findindex = taskList.OrderBy(x => x.VisitTaskNum).ToList().FindIndex(x => x.VisitTaskId == inDto.VisitTaskId); if (findindex < 3) { return -1; } else { var twoindex = taskList.OrderBy(x => x.VisitTaskNum).ToList()[2]; result = inDto.QuestionInfo.Where(x => x.LesionType == LesionType.AlwaysNewLesions).SelectMany(x => x.TableRowInfoList) .Where(x => x.FristAddTaskNum >= twoindex.VisitTaskNum && x.TableQuestionList.Any(y => y.QuestionMark == QuestionMark.State && y.Answer == EvaluationOfState.Exists.GetEnumInt())).Count(); //+ inDto.QuestionInfo.Where(x => x.LesionType == LesionType.NewLesions).SelectMany(x => x.TableRowInfoList) // .Where(x => x.TableQuestionList.Any(y => y.QuestionMark == QuestionMark.State && y.Answer == EvaluationOfState.Exists.GetEnumInt())) // .Count(); } return result; } #endregion #region 间隔天数 /// /// 获取 /// /// /// public async Task GetNumberOfDaysBetween(ReadingCalculateDto inDto) { if (inDto.IsBaseLine) { return -1; } var taskinfo = await _visitTaskRepository.Where(x => x.Id == inDto.VisitTaskId).FirstNotNullAsync(); var taskList = await GetSiteVisitForTumorList(inDto); var lastTask = taskList.Where(x => x.VisitTaskNum < taskinfo.VisitTaskNum && x.VisitTaskId != inDto.VisitTaskId).OrderByDescending(x => x.VisitTaskNum).FirstOrDefault(); if (lastTask != null) { var thisTask = taskList.FirstOrDefault(); if (thisTask != null && thisTask.StudyTime != null && lastTask.StudyTime != null) { return (int)Math.Floor((thisTask.StudyTime.Value - lastTask.StudyTime.Value).TotalDays); } else { return -1; } } else { return -1; } } #endregion #region 访视点肿瘤评估 /// /// 访视点肿瘤评估 /// /// /// public async Task GetSiteVisitForTumorEvaluation(ReadingCalculateDto inDto) { return (await GetSiteVisitForTumorEvaluationByDay(inDto)).Result; } /// /// 获取肿瘤评估 逻辑抽离 这里还要返回上一次的结果 /// /// /// /// public async Task GetSiteVisitForTumorEvaluationByDay(ReadingCalculateDto inDto, int? daysBetween = null) { SiteVisitForTumorEvaluationByDayOutDto result = new SiteVisitForTumorEvaluationByDayOutDto(); if (inDto.IsBaseLine) { result.Result = VisitTumorEvaluation.NA.GetEnumInt(); return result; } //如果日期未知,不需要计算肿瘤评估结果; if (await GetNumberOfDaysBetween(inDto) == -1) { result.Result = string.Empty; return result; } if (inDto.QuestionInfo.Any(x => x.QuestionType == QuestionType.ImageQualityAssessment && x.Answer == ImageQualityEvaluation.Abnormal.GetEnumInt())) { //影像质量不正常 result.Result = VisitTumorEvaluation.NE.GetEnumInt(); return result; } var pdResult = await ChangeLastTaskSiteVisitForTumorEvaluation(inDto, daysBetween); // 这里为什么要这样写 因为要把上一次的也返回前端去 前端要修改 result.LastTaskResult = pdResult.LastTaskResult; result.LastTaskId = pdResult.LastTaskId; var newLesionsCount = inDto.QuestionInfo.Where(x => x.QuestionType == QuestionType.NewLesionsCount).Select(x => x.Answer).FirstOrDefault().IsNullOrEmptyReturn0(); var baseLineLesionsCount = inDto.QuestionInfo.Where(x => x.QuestionType == QuestionType.BaseLineLesionsCount).Select(x => x.Answer).FirstOrDefault().IsNullOrEmptyReturn0(); var alwaysNewLesionsCount = inDto.QuestionInfo.Where(x => x.QuestionType == QuestionType.AlwaysNewLesionsCount).Select(x => x.Answer).FirstOrDefault().IsNullOrEmptyReturn0(); if (pdResult.IsPD) { result.Result = VisitTumorEvaluation.PD.GetEnumInt(); } else if (newLesionsCount == 0 && baseLineLesionsCount == 0 && alwaysNewLesionsCount == 0) { result.Result = VisitTumorEvaluation.ND.GetEnumInt(); } else { result.Result = VisitTumorEvaluation.NoPD.GetEnumInt(); } return result; } /// /// 前端获取访视点肿瘤评估 /// /// [HttpPost] public async Task FrontGetSiteVisitForTumorEvaluation(FrontGetSiteVisitForTumorEvaluationInDto inDto) { ReadingCalculateDto readingData = await _generalCalculateService.GetReadingCalculateDto(inDto.VisitTaskId); // 只获取当前的 不会获取上一次临时修改的结果 foreach (var item in readingData.QuestionInfo) { if (item.PCWGInterimAnswer != null) { item.Answer = item.PCWGInterimAnswer; } if (item.QuestionType == QuestionType.DaysBetween) { item.Answer = inDto.NumberOfDaysBetween.ToString(); } } FrontGetSiteVisitForTumorEvaluationOutDto result = new FrontGetSiteVisitForTumorEvaluationOutDto(); var tumorEvaluation = await GetSiteVisitForTumorEvaluationByDay(readingData, inDto.NumberOfDaysBetween); result.ResultList = new List() { new FrontGetSiteVisitForTumor(){ VisitTaskId=inDto.VisitTaskId, TumorEvaluationResult=tumorEvaluation.Result, } }; if (tumorEvaluation.LastTaskResult != null && tumorEvaluation.LastTaskId != null) { result.ResultList.Add(new FrontGetSiteVisitForTumor() { VisitTaskId = tumorEvaluation.LastTaskId.Value, TumorEvaluationResult = tumorEvaluation.LastTaskResult, }); } return result; } /// /// 修改上一次访视结果 并且计算是不是PD /// /// /// /// public async Task ChangeLastTaskSiteVisitForTumorEvaluation(ReadingCalculateDto inDto, int? numOfDaysBetween) { PCWGSiteVisitForTumor result = new PCWGSiteVisitForTumor() { IsPD = false, }; var taskinfo = await _visitTaskRepository.Where(x => x.Id == inDto.VisitTaskId).FirstNotNullAsync(); var taskList = await GetSiteVisitForTumorList(inDto); var lastTask = taskList.Where(x => x.VisitTaskNum < taskinfo.VisitTaskNum && x.VisitTaskId != inDto.VisitTaskId).OrderByDescending(x => x.VisitTaskNum).FirstOrDefault(); var baseLineTask = taskList.OrderBy(x => x.VisitTaskNum).FirstOrDefault(); // 先判断有没有上一个任务 if (lastTask != null) { // 查看历史有没有PD var taskIdList = taskList.Select(x => x.VisitTaskId).ToList(); // pd的任务列表 var pdTaskList = await _readingTaskQuestionAnswerRepository.Where(x => x.VisitTaskId != inDto.VisitTaskId && taskIdList.Contains(x.VisitTaskId) && x.ReadingQuestionTrial.QuestionType == QuestionType.SiteVisitForTumorEvaluation && x.Answer == VisitTumorEvaluation.PD.GetEnumInt()).OrderByDescending(x => x.VisitTask.VisitTaskNum).ToListAsync(); // 自治疗后第二个访视点以来持续的新骨变数量 var thisNewBoneLesionsCount = inDto.QuestionInfo.Where(x => x.QuestionType == QuestionType.NewBoneLesionsCount).Select(x => x.Answer).FirstIsNullReturnEmpty().IsNullOrEmptyReturn0(); // 当前任务的BL-BTN var thisBTN = inDto.QuestionInfo.Where(x => x.QuestionType == QuestionType.BaseLineLesionsCount).Select(x => x.Answer).FirstIsNullReturnEmpty().IsNullOrEmptyReturn0(); // 当前访视新病灶数量 var thisNewLesionsCount = inDto.QuestionInfo.Where(x => x.QuestionType == QuestionType.NewLesionsCount).Select(x => x.Answer).FirstIsNullReturnEmpty().IsNullOrEmptyReturn0(); // 其他访视的BTN var otherBTNStrList = await _readingTaskQuestionAnswerRepository.Where(x => x.VisitTaskId != inDto.VisitTaskId && taskIdList.Contains(x.VisitTaskId) && x.ReadingQuestionTrial.QuestionType == QuestionType.BaseLineLesionsCount).Select(x => new { x.VisitTask.VisitTaskNum, x.Answer, }).ToListAsync(); // 最小的BTN 这个时候再转为int 避免查询报错 var otherMinBTNCount = otherBTNStrList.Select(x => x.Answer.IsNullOrEmptyReturn0()).Min(); // [(V3 - BTN - Min(V2 - BTN、V1 - BTN、BL - BTN)] 小于当0计算 var btnValue = thisBTN - otherMinBTNCount; if (btnValue < 0) { btnValue = 0; } // 历史有PD if (pdTaskList.Count() > 0) { // 当前访视:自治疗后第二个访视点以来持续的新骨变数量 + [(V3 - BTN - Min(V2 - BTN、V1 - BTN、BL - BTN)] + 新病灶 >= 2 if (thisNewBoneLesionsCount + btnValue + thisNewLesionsCount >= 2) { result.IsPD = true; } } else { // 间隔天数 var daysBetween = numOfDaysBetween != null ? numOfDaysBetween.Value : await GetNumberOfDaysBetween(inDto); // 上一次访视的新病灶数量 var lastNewLesionsCount = (await _readingTaskQuestionAnswerRepository.Where(x => x.VisitTaskId == lastTask.VisitTaskId && x.ReadingQuestionTrial.QuestionType == QuestionType.NewLesionsCount).Select(x => x.Answer).FirstOrDefaultAsync()).IsNullOrEmptyReturn0(); // 之前不存在pd 又分为两种情况 在访视2 和 访视2以后 if (inDto.VisitTaskNum == 2) { var alwaysNewLesionsCount = inDto.QuestionInfo.Where(x => x.QuestionType == QuestionType.AlwaysNewLesionsCount).Select(x => x.Answer).FirstIsNullReturnEmpty().IsNullOrEmptyReturn0(); // V1:新病灶计数>=2; V2:新病灶计数>=2且既往新病灶计数>=2;; V2与V1的间隔 >= 6周 if (lastNewLesionsCount >= 2 && thisNewLesionsCount >= 2 && alwaysNewLesionsCount >= 2 && daysBetween >= 42) { result.IsPD = true; } } else if (inDto.VisitTaskNum > 2) { // 上一个访视的BTN var lastBTN = (await _readingTaskQuestionAnswerRepository.Where(x => x.VisitTaskId == lastTask.VisitTaskId && x.ReadingQuestionTrial.QuestionType == QuestionType.BaseLineLesionsCount).Select(x => x.Answer).FirstOrDefaultAsync()).IsNullOrEmptyReturn0(); // 上上个访视的 最小BTN var lastTwoBTN = otherBTNStrList.Where(x => x.VisitTaskNum < lastTask.VisitTaskNum).Select(x => x.Answer.IsNullOrEmptyReturn0()).Min(); // V2:新病灶计数+[(V2-BTN- Min(V1-BTN、BL-BTN)]>=2; // V3:自治疗后第二个访视点以来持续的新骨变数量 + [(V3 - BTN - Min(V2 - BTN、V1 - BTN、BL - BTN)] + 新病灶 >= 2 // V3与V2的间隔 >= 6周 // 按上面条件写三个if看着清晰点 var lastBtnSubMin = lastBTN - lastTwoBTN; if (lastBtnSubMin < 0) { lastBtnSubMin = 0; } if (lastNewLesionsCount + lastBtnSubMin >= 2) { if (thisNewBoneLesionsCount + btnValue + thisNewLesionsCount >= 2) { if (daysBetween >= 42) { result.IsPD = true; } } } } if (result.IsPD) { // 为 null 说明不是前端传的 if (numOfDaysBetween == null) { var visitForTumorEvaluationQuestionId = inDto.QuestionInfo.Where(x => x.QuestionType == QuestionType.SiteVisitForTumorEvaluation).Select(x => x.QuestionId).FirstOrDefault(); await _readingTaskQuestionAnswerRepository.BatchUpdateNoTrackingAsync(x => x.VisitTaskId == lastTask.VisitTaskId && x.ReadingQuestionTrialId == visitForTumorEvaluationQuestionId, x => new ReadingTaskQuestionAnswer { PCWGInterimAnswer = VisitTumorEvaluation.PD.GetEnumInt(), }); } result.LastTaskResult = VisitTumorEvaluation.PD.GetEnumInt(); result.LastTaskId = lastTask.VisitTaskId; } else { if (lastTask != null) { if (numOfDaysBetween == null) { // 如果不是PD 需要把上一次的PD改为NoPD 这里去掉临时答案就是原始答案 await _readingTaskQuestionAnswerRepository.BatchUpdateNoTrackingAsync(x => x.VisitTaskId == lastTask.VisitTaskId && x.ReadingQuestionTrial.QuestionType == QuestionType.SiteVisitForTumorEvaluation, x => new ReadingTaskQuestionAnswer { PCWGInterimAnswer = null, }); } var lastTaskResult = await _readingTaskQuestionAnswerRepository.Where(x => x.VisitTaskId == lastTask.VisitTaskId && x.ReadingQuestionTrial.QuestionType == QuestionType.SiteVisitForTumorEvaluation).Select(x => x.Answer).FirstOrDefaultAsync(); result.LastTaskResult = lastTaskResult; result.LastTaskId = lastTask.VisitTaskId; } } } } return result; } #endregion /// /// 获取访视日期信息 /// /// /// public async Task> GetSiteVisitForTumorList(ReadingCalculateDto inDto) { if (siteVisitForTumorList == null) { var taskinfo = await _visitTaskRepository.Where(x => x.Id == inDto.VisitTaskId).FirstNotNullAsync(); siteVisitForTumorList = await _visitTaskRepository.Where(x => (x.ReadingCategory == ReadingCategory.Visit && x.TrialReadingCriterionId == taskinfo.TrialReadingCriterionId && x.DoctorUserId == taskinfo.DoctorUserId && x.IsAnalysisCreate == inDto.IsAnalysisCreate && x.SubjectId == taskinfo.SubjectId && x.ReadingTaskState == ReadingTaskState.HaveSigned && x.VisitTaskNum <= taskinfo.VisitTaskNum && x.TaskState == TaskState.Effect && x.ArmEnum == taskinfo.ArmEnum ) || x.Id == inDto.VisitTaskId).OrderByDescending(x => x.VisitTaskNum).Select(x => new SiteVisitForTumor() { VisitTaskId = x.Id, VisitTaskNum = x.VisitTaskNum, SubjectVisitId = x.SourceSubjectVisitId, }).ToListAsync(); var visitIds = siteVisitForTumorList.Select(x => x.SubjectVisitId).ToList(); // Dicom 用NM 非dicom 用骨扫描 (BoneScan) List visitStudies = await _dicomStudyRepository.Where(x => visitIds.Contains(x.SubjectVisitId) && x.ModalityForEdit == "BoneScan").Select(x => new VisitStudyTime() { SubjectVisitId = x.SubjectVisitId, StudyTime = x.StudyTime }).ToListAsync(); visitStudies.AddRange( await _noneDicomStudyRepository.Where(x => visitIds.Contains(x.SubjectVisitId) && x.Modality == "BoneScan").Select(x => new VisitStudyTime() { SubjectVisitId = x.SubjectVisitId, StudyTime = x.ImageDate }).ToListAsync() ); visitStudies = visitStudies.Where(x => x.StudyTime != null).ToList(); foreach (var item in siteVisitForTumorList) { item.StudyTime = visitStudies.Where(x => x.SubjectVisitId == item.SubjectVisitId).Max(x => x.StudyTime); } } return siteVisitForTumorList; } public async Task GetReportVerify(GetReportVerifyInDto inDto) { return new GetReportVerifyOutDto() { }; } public async Task VerifyVisitTaskQuestions(VerifyVisitTaskQuestionsInDto inDto) { if (await _readingTaskQuestionAnswerRepository.AnyAsync(x => x.ReadingQuestionTrial.QuestionType == QuestionType.ImageQualityAssessment && x.VisitTaskId == inDto.VisitTaskId && x.Answer == ImageQualityEvaluation.Abnormal.GetEnumInt())) { return; } var tableAnswerList = await _readingTableQuestionAnswerRepository.Where(x => x.VisitTaskId == inDto.VisitTaskId && (x.Answer == string.Empty || x.Answer == null) && x.ReadingTableQuestionTrial.QuestionMark == QuestionMark.State ) .Select(x => new { x.ReadingQuestionTrial.OrderMark, x.RowIndex, QuestionMark = x.ReadingTableQuestionTrial.QuestionMark, Answer = x.Answer, }).ToListAsync(); string errorMassage = string.Empty; var rowAnswerList = await _readingTableAnswerRowInfoRepository.Where(x => x.VisitTaskId == inDto.VisitTaskId && x.ReadingQuestionTrial.LesionType != LesionType.BaselineLesions && (x.MeasureData == string.Empty || x.MeasureData == null)) .Select(x => new { x.ReadingQuestionTrial.OrderMark, x.RowIndex, x.Id, }).ToListAsync(); var unableEvaluateRowIds = await _readingTableQuestionAnswerRepository.Where(x => x.VisitTaskId == inDto.VisitTaskId && x.Answer == EvaluationOfState.UnableEvaluate.GetEnumInt() && x.ReadingTableQuestionTrial.QuestionMark == QuestionMark.State ) .Select(x => x.RowId).Distinct().ToListAsync(); List measureDataList = rowAnswerList.Where(x => !unableEvaluateRowIds.Contains(x.Id)).Select(x => x.OrderMark + x.RowIndex.GetLesionMark()).ToList(); List stateIsNullList = tableAnswerList.Select(x => x.OrderMark + x.RowIndex.GetLesionMark()).ToList(); List allExists = measureDataList.Intersect(stateIsNullList).ToList(); measureDataList = measureDataList.Except(allExists).ToList(); stateIsNullList = stateIsNullList.Except(allExists).ToList(); if (measureDataList.Count() > 0) { errorMassage += _localizer["ReadingCalculate_NoMarker", string.Join(',', measureDataList)] + ","; } if (tableAnswerList.Count > 0) { errorMassage += _localizer["ReadingCalculate_StatusIsEmpty", string.Join(',', stateIsNullList)] + ","; } if (allExists.Count > 0) { errorMassage += _localizer["ReadingCalculate_NoMarkerEmpty", string.Join(',', stateIsNullList)] + ","; } if (errorMassage != string.Empty) { errorMassage = _localizer["ReadingCalculate_questionable"] + errorMassage; throw new BusinessValidationFailedException(errorMassage); } } } }