using IRaCIS.Application.Interfaces; using IRaCIS.Application.Contracts; using IRaCIS.Core.Domain.Share; using EasyCaching.Core; using IRaCIS.Core.Application.Filter; using Microsoft.AspNetCore.Mvc; using Panda.DynamicWebApi.Attributes; using IRaCIS.Core.Infrastructure; using Microsoft.Extensions.Options; namespace IRaCIS.Application.Services { [ApiExplorerSettings(GroupName = "Trial")] public class TrialService : BaseService, ITrialService { private readonly IEasyCachingProvider _provider; private readonly IRepository _trialRepository; private readonly IRepository _trialUserRepository; private readonly IOptionsMonitor _verifyConfig; public bool TrialExpeditedChange { get; set; } = false; public TrialService(IEasyCachingProvider provider, IRepository trialRepository, IRepository trialUserRepository, IOptionsMonitor verifyConfig ) { _verifyConfig = verifyConfig; _provider = provider; _trialRepository = trialRepository; this._trialUserRepository = trialUserRepository; } /// /// 分页获取临床项目列表 默认后台加急状态为3 查所有的 /// /// /// [HttpPost] public async Task> GetTrialList(TrialQueryDTO searchParam) { var multiModalityIdSelectCount = searchParam.ModalityIds.Count; var multiCriteriaSelectCount = searchParam.CriterionIds.Count; var multiReviewTypeSelectCount = searchParam.ReviewTypeIds.Count; var query = _trialRepository.AsQueryable().IgnoreQueryFilters() .WhereIf(!string.IsNullOrEmpty(searchParam.TrialStatusStr), o => o.TrialStatusStr.Contains(searchParam.TrialStatusStr)) .WhereIf(searchParam.SponsorId != null, o => o.SponsorId == searchParam.SponsorId) .WhereIf(searchParam.Expedited != null, o => o.Expedited == searchParam.Expedited) .WhereIf(!string.IsNullOrEmpty(searchParam.Code), o => o.TrialCode.Contains(searchParam.Code)) .WhereIf(!string.IsNullOrWhiteSpace(searchParam.Indication), o => o.Indication.Contains(searchParam.Indication)) .WhereIf(!string.IsNullOrEmpty(searchParam.ResearchProgramNo), o => o.ResearchProgramNo.Contains(searchParam.ResearchProgramNo)) .WhereIf(!string.IsNullOrWhiteSpace(searchParam.ExperimentName), o => o.ExperimentName.Contains(searchParam.ExperimentName)) .WhereIf(searchParam.PhaseId != null, o => o.PhaseId == searchParam.PhaseId) .WhereIf(searchParam.DeclarationTypeId != null, o => o.DeclarationTypeId == searchParam.DeclarationTypeId) .WhereIf(searchParam.IndicationTypeId != null, o => o.IndicationTypeId == searchParam.IndicationTypeId) .WhereIf(searchParam.CROId != null, o => o.CROId == searchParam.CROId) .WhereIf(searchParam.BeginDate != null, o => o.CreateTime >= searchParam.BeginDate) .WhereIf(searchParam.EndDate != null, o => o.CreateTime <= searchParam.EndDate) .WhereIf(searchParam.AttendedReviewerType != null, o => o.AttendedReviewerType == searchParam.AttendedReviewerType) .WhereIf(multiModalityIdSelectCount > 0, t => t.TrialDicList.Count(t => t.KeyName == StaticData.Modality) == multiModalityIdSelectCount) .WhereIf(multiCriteriaSelectCount > 0, t => t.TrialDicList.Count(t => t.KeyName == StaticData.Criterion) == multiCriteriaSelectCount) .WhereIf(multiReviewTypeSelectCount > 0, t => t.TrialDicList.Count(t => t.KeyName == StaticData.ReviewType) == multiReviewTypeSelectCount) .WhereIf(_userInfo.UserTypeEnumInt != (int)UserTypeEnum.SuperAdmin, t => t.TrialUserList.Any(t => t.UserId == _userInfo.Id) && t.IsDeleted == false) .ProjectTo(_mapper.ConfigurationProvider, new { userTypeEnumInt = _userInfo.UserTypeEnumInt, userId = _userInfo.Id }); return await query.ToPagedListAsync(searchParam.PageIndex, searchParam.PageSize, string.IsNullOrWhiteSpace(searchParam.SortField) ? "CreateTime" : searchParam.SortField, searchParam.Asc); } //过滤废除的项目 public async Task> GetTrialSelect() { return await _trialRepository.AsQueryable().IgnoreQueryFilters() .WhereIf(_userInfo.UserTypeEnumInt != (int)UserTypeEnum.SuperAdmin, t => t.TrialUserList.Any(t => t.UserId == _userInfo.Id) && t.IsDeleted == false) .ProjectTo(_mapper.ConfigurationProvider).ToListAsync(); } /// /// 获取项目基本信息 /// /// /// [HttpGet("{projectId:guid}")] public async Task GetTrialInfoAndLockState(Guid projectId) { return (await _trialRepository.Where(o => o.Id == projectId).IgnoreQueryFilters().ProjectTo(_mapper.ConfigurationProvider).FirstOrDefaultAsync()).IfNullThrowException(); } [NonDynamicMethod] public async Task GetTrialMaxState(Guid trialId) { return await _repository.Where(t => t.TrialId == trialId).MaxAsync(u => (int?)u.EnrollStatus) ?? 0; } [HttpGet("{trialId:guid}")] public async Task GetTrialInfoAndMaxTrialState(Guid trialId) { return new TrialAndTrialStateVieModel() { TrialView = await GetTrialInfoAndLockState(trialId), TrialMaxState = await GetTrialMaxState(trialId) }; } [HttpGet("{trialId:guid}")] public async Task GetTrialExpeditedState(Guid trialId) { var trial = (await _trialRepository.FirstOrDefaultAsync(u => u.Id == trialId)).IfNullThrowException(); return trial.Expedited; } /// /// 添加项目 /// /// /// [NonDynamicMethod] public virtual async Task> AddOrUpdateTrial(TrialCommand trialAddModel) { // 到时候 策略授权 统一改 归类 if (!(_userInfo.UserTypeEnumInt == (int)UserTypeEnum.APM || _userInfo.UserTypeEnumInt == (int)UserTypeEnum.ProjectManager || _userInfo.UserTypeEnumInt == (int)UserTypeEnum.SuperAdmin)) { throw new BusinessValidationFailedException("只有PM/APM拥有操作权限!"); } if (trialAddModel.Id == Guid.Empty || trialAddModel.Id == null) { if (await _trialRepository.AnyAsync(u => u.TrialCode == trialAddModel.TrialCode)) { throw new BusinessValidationFailedException("已经存在相同的项目编号。"); } var dbMaxCode = await _trialRepository.Where(t => t.CreateTime.Year == DateTime.Now.Year && t.TrialType == trialAddModel.TrialType).Select(t => t.Code).DefaultIfEmpty().MaxAsync(); var currentYearMaxCodeNext = dbMaxCode + 1; //var test = _trialRepository.Where(t => t.CreateTime.Year == DateTime.Now.Year + 1).Select(t => t.Code).DefaultIfEmpty(1).ToList(); var trial = _mapper.Map(trialAddModel); //trial.Id = NewId.NextGuid(); var yearStr = DateTime.Now.Year.ToString(); trial.Code = currentYearMaxCodeNext; trial.TrialCode = (trial.TrialType == TrialType.NoneOfficial ? yearStr.Substring(yearStr.Length - 2) : "T0") + trial.TrialCode + currentYearMaxCodeNext.ToString("D3"); //多选信息 trialAddModel.ModalityIds.ForEach(modalityId => trial.TrialDicList.Add(new TrialDictionary() { DictionaryId = modalityId, KeyName = StaticData.Modality, TrialId = trial.Id })); trialAddModel.CriterionIds.ForEach(criterionId => trial.TrialDicList.Add(new TrialDictionary() { DictionaryId = criterionId, KeyName = StaticData.Criterion, TrialId = trial.Id })); trialAddModel.ReviewTypeIds.ForEach(ReviewTypeId => trial.TrialDicList.Add(new TrialDictionary() { DictionaryId = ReviewTypeId, KeyName = StaticData.ReviewType, TrialId = trial.Id })); //添加项目后 项目状态变更为申请下载简历 trial.TrialEnrollStatus = (int)TrialEnrollStatus.ChooseDoctor; //trial.TrialStatusStr = StaticData.TrialInitializing; //状态变更详细表 trial.ClinicalTrialProjectDetails.Add(new TrialStatusDetail() { TrialId = trial.Id, TrialStatus = (int)TrialEnrollStatus.ChooseDoctor }); trial = await _trialRepository.AddAsync(trial); //如果是PM， 则需要将该人员添加到 运维人员表 //添加运维人员PM await _repository.AddAsync(new TrialUser() { TrialId = trial.Id, UserId = _userInfo.Id, JoinTime = DateTime.Now }); // 添加扩展信息表记录 await _repository.AddAsync(new TrialPaymentPrice() { TrialId = trial.Id }); //添加访视 await _repository.AddAsync(new VisitStage { TrialId = trial.Id, VisitNum = 0, BlindName = "B" + 0.ToString("D3"), VisitDay = 0, VisitName = "Baseline", IsBaseLine = true }); await _repository.AddAsync(new VisitStage { TrialId = trial.Id, VisitNum = 1, BlindName = "B" + 10.ToString("D3"), VisitDay = 30, VisitName = "Visit 1" }); var success = await _repository.SaveChangesAsync(); _provider.Set(trial.Id.ToString(), StaticData.TrialState.TrialInitializing, TimeSpan.FromDays(7)); return ResponseOutput.Ok(trial); } else { var updateModel = trialAddModel; if (!await _repository.AnyAsync(u => u.Id == trialAddModel.Id && (u.TrialStatusStr == StaticData.TrialState.TrialInitializing || u.TrialStatusStr == StaticData.TrialState.TrialOngoing))) { throw new BusinessValidationFailedException("项目状态只有处于：初始化或者进行中时，才允许操作。"); } // 判断项目Id 是否已经存在 if (await _repository.AnyAsync(u => u.TrialCode == updateModel.TrialCode && u.Id != updateModel.Id)) { throw new BusinessValidationFailedException("已经存在相同的项目编号。"); } var trial = await _repository.FirstOrDefaultAsync(t => t.Id == updateModel.Id); //删除中间表 Title对应的记录 await _repository.BatchDeleteAsync(t => t.TrialId == updateModel.Id); //重新插入新的 Title记录 updateModel.ModalityIds.ForEach(modalityId => trial.TrialDicList.Add(new TrialDictionary() { DictionaryId = modalityId, KeyName = StaticData.Modality, TrialId = trial.Id })); updateModel.CriterionIds.ForEach(criterionId => trial.TrialDicList.Add(new TrialDictionary() { DictionaryId = criterionId, KeyName = StaticData.Criterion, TrialId = trial.Id })); updateModel.ReviewTypeIds.ForEach(ReviewTypeId => trial.TrialDicList.Add(new TrialDictionary() { DictionaryId = ReviewTypeId, KeyName = StaticData.ReviewType, TrialId = trial.Id })); if (updateModel.Expedited != trial.Expedited && updateModel.Expedited != null) { TrialExpeditedChange = true; await TrialExpeditedStatusChange(trial.Id, trial.Expedited, (int)updateModel.Expedited); } _mapper.Map(updateModel, trial); var success = await _repository.SaveChangesAsync(); return ResponseOutput.Ok(trial); } } // TODO: 需要优化，嵌套两层 switch case ？ [NonDynamicMethod] private async Task TrialExpeditedStatusChange(Guid trialId, int oldState, int newState) { switch (oldState) { case (int)TrialExpedited.None: switch (newState) { case (int)TrialExpedited.ExpeditedIn24H: await _repository.BatchUpdateAsync(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() { TimepointIn24H = u.Timepoint, AdjudicationIn24H = u.Adjudication, Timepoint = 0, Adjudication = 0 }); break; case (int)TrialExpedited.ExpeditedIn48H: await _repository.BatchUpdateAsync(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() { TimepointIn48H = u.Timepoint, AdjudicationIn48H = u.Adjudication, Timepoint = 0, Adjudication = 0 }); break; } //_workloadRepository.Update(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() //{ // Timepoint = 0, // Adjudication = 0 //}); break; case (int)TrialExpedited.ExpeditedIn24H: switch (newState) { case (int)TrialExpedited.None: await _repository.BatchUpdateAsync(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() { Timepoint = u.TimepointIn24H, Adjudication = u.AdjudicationIn24H, TimepointIn24H = 0, AdjudicationIn24H = 0 }); break; case (int)TrialExpedited.ExpeditedIn48H: await _repository.BatchUpdateAsync(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() { TimepointIn48H = u.TimepointIn24H, AdjudicationIn48H = u.AdjudicationIn24H, TimepointIn24H = 0, AdjudicationIn24H = 0 }); break; } //_workloadRepository.Update(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() //{ // TimepointIn24H = 0, // AdjudicationIn24H = 0 //}); break; case (int)TrialExpedited.ExpeditedIn48H: switch (newState) { case (int)TrialExpedited.None: await _repository.BatchUpdateAsync(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() { Timepoint = u.TimepointIn48H, Adjudication = u.AdjudicationIn48H, TimepointIn48H = 0, AdjudicationIn48H = 0 }); break; case (int)TrialExpedited.ExpeditedIn24H: await _repository.BatchUpdateAsync(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() { TimepointIn24H = u.TimepointIn48H, AdjudicationIn24H = u.AdjudicationIn48H, TimepointIn48H = 0, AdjudicationIn48H = 0 }); break; } //_workloadRepository.Update(t => t.IsLock == false && t.TrialId == trialId, u => new Workload() //{ // TimepointIn48H = 0, // AdjudicationIn48H = 0 //}); break; } } /// 真删除项目 方便清理测试数据 /// 临床试验项目Id [HttpDelete, Route("{trialId:guid}")] public async Task DeleteTrial(Guid trialId) { var trial = (await _trialRepository.FirstOrDefaultAsync(u => u.Id == trialId,true)).IfNullThrowException(); if (_verifyConfig.CurrentValue.OpenTrialRelationDelete ) { #region 项目真删除废弃 //if (trial.VisitPlanConfirmed) //{ // return ResponseOutput.NotOk("Trial访视计划已经确认，无法删除"); //} //if (await _repository.AnyAsync(u => u.TrialId == trialId)) //{ // return ResponseOutput.NotOk("该Trial有医生入组或在入组流程中，无法删除"); //} //if (await _repository.AnyAsync(u => u.TrialId == trialId)) //{ // return ResponseOutput.NotOk("该Trial下面有Site，无法删除"); //} ////PM 可以删除项目 仅仅在没有site 参与者只有他自己的时候 //if (_userInfo.UserTypeEnumInt == (int)UserTypeEnum.ProjectManager) //{ // //参与者仅有他自己时，可以删除 // if (await _trialUserRepository.CountAsync(t => t.TrialId == trialId) == 1) // { // var success1 = await _repository.BatchDeleteAsync(o => o.Id == trialId) || // await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || // await _repository.BatchDeleteAsync(t => t.TrialId == trialId); // return ResponseOutput.Result(success1); // } //} //if (await _repository.AnyAsync(u => u.TrialId == trialId)) //{ // return ResponseOutput.NotOk("该Trial下面有参与者，无法删除"); //} #endregion var success = await _repository.BatchDeleteAsync(o => o.Id == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialDocument.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialDocument.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialSiteSurvey.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialSiteSurvey.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.SubjectVisit.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.SubjectVisit.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.SubjectVisit.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.NoneDicomStudy.TrialId == trialId) || await _repository.BatchDeleteAsync(t => t.TrialId == trialId) ; return ResponseOutput.Result(success); } else { return ResponseOutput.NotOk("当前运行环境下，不允许删除项目数据。"); } } [HttpPost] public async Task> GetReviewerTrialListByEnrollmentStatus(TrialByStatusQueryDTO param) { var query = _trialRepository.AsQueryable() .WhereIf(param.Status == 5, t => t.EnrollList.Any(u => u.EnrollStatus == EnrollStatus.HasCommittedToCRO)) .WhereIf(param.Status == 8, t => t.EnrollList.Any(u => u.EnrollStatus == EnrollStatus.InviteIntoGroup)) .WhereIf(param.Status == 10, t => t.EnrollList.Any(u => u.EnrollStatus == EnrollStatus.DoctorReading)) .WhereIf(param.Status == 14, t => t.EnrollList.Any(u => u.EnrollStatus == EnrollStatus.Finished)) .ProjectTo(_mapper.ConfigurationProvider, new { userTypeEnumInt = _userInfo.UserTypeEnumInt, userId = _userInfo.Id }); return await query.ToPagedListAsync(param.PageIndex, param.PageSize, string.IsNullOrWhiteSpace(param.SortField) ? "CreateTime" : param.SortField, param.Asc); } /// /// 根据项目Id 获取医生Id，用于触发计算费用 /// public async Task> GetTrialEnrollmentReviewerIds(Guid trialId) { return await _repository.Where(u => u.TrialId == trialId && u.EnrollStatus >= EnrollStatus.DoctorReading).Select(u => u.DoctorId).Distinct().ToListAsync(); } #region 医生用户接口 /// 分页获取医生参与的临床实验项目列表（查询条件） /// [HttpPost] public async Task> GetTrialListByReviewer(ReviewerTrialQueryDTO searchModel) { var query = _trialRepository .WhereIf(searchModel.EnrollStatus != null, o => (int)searchModel.EnrollStatus! == 10 ? o.EnrollList.Any(o => o.EnrollStatus >= EnrollStatus.ConfirmIntoGroup && o.EnrollStatus <= EnrollStatus.DoctorReading && o.DoctorId == _userInfo.Id) : o.EnrollList.Any(o => o.EnrollStatus == searchModel.EnrollStatus && o.DoctorId == _userInfo.Id)) .WhereIf(searchModel.Expedited != null, o => o.Expedited == searchModel.Expedited) .WhereIf(!string.IsNullOrEmpty(searchModel.Code), o => o.TrialCode.Contains(searchModel.Code)) .WhereIf(!string.IsNullOrWhiteSpace(searchModel.Indication), o => o.Indication.Contains(searchModel.Indication)) .WhereIf(_userInfo.UserTypeEnumInt != (int)UserTypeEnum.SuperAdmin, t => t.TrialUserList.Any(t => t.UserId == _userInfo.Id)) .ProjectTo(_mapper.ConfigurationProvider, new { userTypeEnumInt = _userInfo.UserTypeEnumInt, userId = _userInfo.Id }); return await query.ToPagedListAsync(searchModel.PageIndex, searchModel.PageSize, string.IsNullOrWhiteSpace(searchModel.SortField) ? "CreateTime" : searchModel.SortField, searchModel.Asc); } /// /// 医生确认入组或拒绝入组 /// /// 项目Id /// 9-拒绝入组，10-确认入组 /// [HttpPost("{trialId:guid}/{status:int}")] [TypeFilter(typeof(TrialResourceFilter))] public async Task UpdateEnrollStatus(Guid trialId, EnrollStatus status) { await _repository.AddAsync(new EnrollDetail() { DoctorId = _userInfo.Id, TrialId = trialId, EnrollStatus = status, OptUserType = (int)SystemUserType.DoctorUser, }); return ResponseOutput.Result(await _repository.BatchUpdateAsync(u => u.TrialId == trialId && u.DoctorId == _userInfo.Id, e => new Enroll { EnrollStatus = status })); } #endregion } }