修改统计bug,

IRaCIS.Core.Application/IRaCIS.Core.Application.xml

@@ -100,12 +100,6 @@
             医学审核生成规则   废弃
             </summary>	
         </member>
-        <member name="M:IRaCIS.Core.Application.Service.TaskMedicalReviewRuleService.GenerateMedicalReviewTask(IRaCIS.Core.Application.ViewModel.GenerateMedicalReviewTaskCommand)">
-            <summary>
-            产生医学审核
-            </summary>
-            <returns></returns>
-        </member>
         <member name="T:IRaCIS.Core.Application.Service.TaskMedicalReviewService">
             <summary>
             任务医学审核

IRaCIS.Core.Application/Service/Allocation/TaskMedicalReviewRuleService.cs

@@ -78,120 +78,7 @@ namespace IRaCIS.Core.Application.Service
             return ResponseOutput.Ok();
         }
 
-        /// <summary>
-        /// 产生医学审核
-        /// </summary>
-        /// <returns></returns>
-        [Obsolete]
-        public async Task<IResponseOutput> GenerateMedicalReviewTask(GenerateMedicalReviewTaskCommand generateCommand)
-        {
-            var trialId = generateCommand.TrialId;
 
-            //var mimUserList = await _trialUserRepository.Where(t => t.User.UserTypeEnum == Domain.Share.UserTypeEnum.MIM && t.TrialId == trialId).Select(t => t.User).ProjectTo<UserSimpleInfo>(_mapper.ConfigurationProvider).ToListAsync();
-
-
-
-            Guid? defalutMIMUserId = null /*mimUserList.FirstOrDefault()?.UserId*/;
-
-            //获取当前医生数据  已经生成的，和配置的数量
-            var taskTaskMedicalReviewRuleList = await _taskMedicalReviewRuleRepository.Where(t => t.TrialId == trialId).ProjectTo<TaskMedicalReviewRuleView>(_mapper.ConfigurationProvider).ToListAsync();
-
-            foreach (var item in taskTaskMedicalReviewRuleList)
-            {
-
-                if (item.IsEnable)
-                {
-
-                    if (item.PlanGlobalCount > item.GeneratedGlobalCount)
-                    {
-                        var needGenerateCount = item.PlanGlobalCount - item.GeneratedGlobalCount;
-
-                        var canGenerateCount = item.ActualGlobalCount - item.GeneratedGlobalCount;
-
-                        var toGenerateCount = canGenerateCount > needGenerateCount ? needGenerateCount : canGenerateCount;
-
-                        //分配给MIM  
-
-                        if (toGenerateCount > 0)
-                        {
-                            var toGenerateTaskList = item.ActualGlobalTaskList.ExceptBy(item.GeneratedGlobalTaskList.Select(t => t.TaskId), t => t.TaskId).Take(toGenerateCount).ToList();
-
-                            foreach (var toGenerateTask in toGenerateTaskList)
-                            {
-                                await _taskMedicalReviewRepository.AddAsync(new TaskMedicalReview() { DoctorUserId = toGenerateTask.DoctorUserId!.Value, TrialId = toGenerateTask.TrialId, VisitTaskId = toGenerateTask.TaskId, MedicalManagerUserId = defalutMIMUserId });
-                            }
-                        }
-
-
-                    }
-                    if (item.PlanJudgeCount > item.GeneratedJudgeCount)
-                    {
-                        var needGenerateCount = item.PlanJudgeCount - item.GeneratedJudgeCount;
-
-                        var canGenerateCount = item.ActualJudgeCount - item.GeneratedGlobalCount;
-
-                        var toGenerateCount = canGenerateCount > needGenerateCount ? needGenerateCount : canGenerateCount;
-
-                        if (toGenerateCount > 0)
-                        {
-                            var toGenerateTaskList = item.ActualJudgeTaskList.ExceptBy(item.GeneratedJudgeTaskList.Select(t => t.TaskId), t => t.TaskId).Take(toGenerateCount).ToList();
-
-                            foreach (var toGenerateTask in toGenerateTaskList)
-                            {
-                                await _taskMedicalReviewRepository.AddAsync(new TaskMedicalReview() { DoctorUserId = toGenerateTask.DoctorUserId!.Value, TrialId = toGenerateTask.TrialId, VisitTaskId = toGenerateTask.TaskId, MedicalManagerUserId = defalutMIMUserId });
-                            }
-                        }
-
-                    }
-                    if (item.PlanTumorCount > item.GeneratedTumorCount)
-                    {
-                        var needGenerateCount = item.PlanTumorCount - item.GeneratedTumorCount;
-
-                        var canGenerateCount = item.ActualTumorCount - item.GeneratedGlobalCount;
-
-                        var toGenerateCount = canGenerateCount > needGenerateCount ? needGenerateCount : canGenerateCount;
-
-                        if (toGenerateCount > 0)
-                        {
-                            var toGenerateTaskList = item.ActualTumorTaskList.ExceptBy(item.GeneratedTumorTaskList.Select(t => t.TaskId), t => t.TaskId).Take(toGenerateCount).ToList();
-
-                            foreach (var toGenerateTask in toGenerateTaskList)
-                            {
-                                await _taskMedicalReviewRepository.AddAsync(new TaskMedicalReview() { DoctorUserId = toGenerateTask.DoctorUserId!.Value, TrialId = toGenerateTask.TrialId, VisitTaskId = toGenerateTask.TaskId, MedicalManagerUserId = defalutMIMUserId });
-                            }
-                        }
-
-                    }
-                    if (item.PlanVisitCount > item.GeneratedVisitCount)
-                    {
-                        var needGenerateCount = item.PlanVisitCount - item.GeneratedVisitCount;
-
-                        var canGenerateCount = item.ActualVisitCount - item.GeneratedGlobalCount;
-
-                        var toGenerateCount = canGenerateCount > needGenerateCount ? needGenerateCount : canGenerateCount;
-
-                        if (toGenerateCount > 0)
-                        {
-
-                            var toGenerateTaskList = item.ActualVisitTaskList.ExceptBy(item.GeneratedVisitTaskList.Select(t => t.TaskId), t => t.TaskId).Take(toGenerateCount).ToList();
-
-                            foreach (var toGenerateTask in toGenerateTaskList)
-                            {
-                                await _taskMedicalReviewRepository.AddAsync(new TaskMedicalReview() { DoctorUserId = toGenerateTask.DoctorUserId!.Value, TrialId = toGenerateTask.TrialId, VisitTaskId = toGenerateTask.TaskId, MedicalManagerUserId = defalutMIMUserId });
-                            }
-                        }
-
-                    }
-
-                }
-
-            }
-
-
-            await _taskMedicalReviewRepository.SaveChangesAsync();
-            return ResponseOutput.Ok();
-
-        }
 
 
     }

IRaCIS.Core.Application/Service/Reading/MedicalAudit/ReadingMedicalReviewService.cs

@@ -466,8 +466,12 @@ namespace IRaCIS.Core.Application.Service
             {
                 throw new BusinessValidationFailedException(_localizer["MedicalReview_SaveQuestion"]);
             }
+            var medicalReview = await _taskMedicalReviewRepository.Where(x => x.Id == inDto.TaskMedicalReviewId).FirstNotNullAsync();
+
             await _taskMedicalReviewRepository.UpdatePartialFromQueryAsync(inDto.TaskMedicalReviewId, x => new TaskMedicalReview()
             {
+
+                LatestReplyUserId = (inDto.IsSendDialog && !medicalReview.IsSendMessage && inDto.IsHaveQuestion) ? _userInfo.Id : null,
                 IsHaveQuestion = inDto.IsHaveQuestion,
                 Questioning = inDto.Questioning,
                 IsSendMessage = inDto.IsSendDialog && inDto.IsHaveQuestion,
@@ -476,9 +480,8 @@ namespace IRaCIS.Core.Application.Service
                 AuditAdviceEnum = inDto.AuditAdviceEnum,
                 SaveConclusionTime = DateTime.Now,
 
-            }); 
+            }); ; 
 
-            var medicalReview = await _taskMedicalReviewRepository.Where(x => x.Id == inDto.TaskMedicalReviewId).FirstNotNullAsync();
             if (inDto.IsSendDialog&& !medicalReview.IsSendMessage && inDto.IsHaveQuestion)
             {
               
@@ -511,6 +514,7 @@ namespace IRaCIS.Core.Application.Service
         {
             await _taskMedicalReviewRepository.UpdatePartialFromQueryAsync(inDto.TaskMedicalReviewId, x => new TaskMedicalReview()
             {
+                LatestReplyUserId=_userInfo.Id,
                 IsClosedDialog = inDto.IsClosedDialog,
                 MedicalDialogCloseEnum=inDto.MedicalDialogCloseEnum,
                 DialogCloseReason=inDto.DialogCloseReason,
@@ -547,6 +551,11 @@ namespace IRaCIS.Core.Application.Service
                 throw new BusinessValidationFailedException(_localizer["MedicalReview_invalid"]);
             }
 
+            await _taskMedicalReviewRepository.UpdatePartialFromQueryAsync(inDto.TaskMedicalReviewId, x => new TaskMedicalReview()
+            {
+                LatestReplyUserId = _userInfo.Id,
+            });
+
             var visitTaskId = await _taskMedicalReviewRepository.Where(x => x.Id == inDto.TaskMedicalReviewId).Select(x => x.VisitTaskId).FirstOrDefaultAsync();
             ReadingMedicalReviewDialog dialog = new ReadingMedicalReviewDialog()
             {
@@ -600,6 +609,7 @@ namespace IRaCIS.Core.Application.Service
 
                 await _taskMedicalReviewRepository.UpdatePartialFromQueryAsync(x => !x.IsClosedDialog && x.Id == inDto.TaskMedicalReviewId, x => new TaskMedicalReview()
                 {
+                    LatestReplyUserId=_userInfo.Id,
                     IsClosedDialog = true,
                     MedicalDialogCloseEnum = MedicalDialogClose.IRApplyReReading,
 
@@ -613,6 +623,7 @@ namespace IRaCIS.Core.Application.Service
 
             await _taskMedicalReviewRepository.UpdatePartialFromQueryAsync(inDto.TaskMedicalReviewId, x => new TaskMedicalReview()
             {
+                LatestReplyUserId=_userInfo.Id,
                 DoctorUserIdeaEnum = inDto.DoctorUserIdeaEnum,
             });
             ReadingMedicalReviewDialog dialog = new ReadingMedicalReviewDialog()
@@ -740,10 +751,11 @@ namespace IRaCIS.Core.Application.Service
 
             await _taskMedicalReviewRepository.UpdatePartialFromQueryAsync(inDto.TaskMedicalReviewId, x => new TaskMedicalReview()
             {
+                LatestReplyUserId = _userInfo.Id,
                 DoctorUserIdeaEnum = inDto.DoctorUserIdeaEnum,
                 DisagreeReason = inDto.DisagreeReason,
-                IsApplyHeavyReading=inDto.IsApplyHeavyReading,
+                IsApplyHeavyReading = inDto.IsApplyHeavyReading,
-            });
+            }); ;
 
             var visitTaskId = await _taskMedicalReviewRepository.Where(x => x.Id == inDto.TaskMedicalReviewId).Select(x => x.VisitTaskId).FirstOrDefaultAsync();
             await _readingMedicalReviewDialogRepository.AddAsync(new ReadingMedicalReviewDialog()

IRaCIS.Core.Application/Service/TrialSiteUser/PersonalWorkstation.cs

@@ -544,11 +544,11 @@ namespace IRaCIS.Core.Application
                     TrialCode = t.TrialCode,
                     UrgentCount = t.SubjectVisitList
                     .Where(c => c.TrialSite.CRCUserList.Any(u => u.UserId == _userInfo.Id))
-                    .Where(u => u.SubmitState == SubmitStateEnum.ToSubmit && u.IsUrgent && u.IsPMBackOrReReading).Count(),
+                    .Where(u =>  u.IsUrgent && ((u.SubmitState == SubmitStateEnum.ToSubmit && u.IsPMBackOrReReading)||u.IsQCConfirmedReupload)).Count(),
 
                     ToBeReUploadCount = t.SubjectVisitList
                     .Where(c => c.TrialSite.CRCUserList.Any(u => u.UserId == _userInfo.Id))
-                    .Where(u => u.SubmitState == SubmitStateEnum.ToSubmit && u.IsPMBackOrReReading).Count(),
+                    .Where(u => (u.SubmitState == SubmitStateEnum.ToSubmit && u.IsPMBackOrReReading) ||(u.IsQCConfirmedReupload)).Count(),
 
                 }).Where(x => x.ToBeReUploadCount > 0);
 
@@ -556,7 +556,7 @@ namespace IRaCIS.Core.Application
 
             var toBeDealedCount = _subjectVisitRepository
                   .Where(t => t.Trial.TrialUserList.Any(t => t.UserId == _userInfo.Id))
-                  .Where(u => u.SubmitState == SubmitStateEnum.ToSubmit && u.IsPMBackOrReReading).Count();
+                  .Where(u => (u.SubmitState == SubmitStateEnum.ToSubmit && u.IsPMBackOrReReading) || (u.IsQCConfirmedReupload)).Count();
 
             return ResponseOutput.Ok(result, new { TotalToBeReUploadCount = toBeDealedCount });
 
@@ -885,6 +885,14 @@ namespace IRaCIS.Core.Application
                     CriterionName = g.Key.CriterionName,
                     TrialReadingCriterionId = g.Key.TrialReadingCriterionId,
 
+                    #region 不能对包含聚合或子查询的表达式执行聚合函数
+                    
+
+                    UrgentCount = g.Where(u => u.VisitTask.IsUrgent && u.LatestReplyUser.UserTypeEnum== UserTypeEnum.MIM).Count(),
+
+                    ToBeReplyedCount = g.Where(u => u.LatestReplyUser.UserTypeEnum == UserTypeEnum.MIM).Count(),
+
+                    #endregion
                     //UrgentCount = g.Where(u => u.VisitTask.IsUrgent
                     //&& u.ReadingMedicalReviewDialogList.OrderByDescending(l => l.CreateTime).First().UserTypeEnumInt == (int)UserTypeEnum.MIM).Count(),
 
@@ -898,7 +906,9 @@ namespace IRaCIS.Core.Application
             var toBeDealedCount = _taskMedicalReviewRepository
                 .Where(t => t.Trial.TrialUserList.Any(t => t.UserId == _userInfo.Id))
                 .Where(t => t.IsClosedDialog == false && t.VisitTask.DoctorUserId == _userInfo.Id)
-                .Where(u => u.ReadingMedicalReviewDialogList.OrderByDescending(l => l.CreateTime).First().UserTypeEnumInt == (int)UserTypeEnum.MIM).Count();
+                .Where(u => u.LatestReplyUser.UserTypeEnum == UserTypeEnum.MIM)
+                //.Where(u => u.ReadingMedicalReviewDialogList.OrderByDescending(l => l.CreateTime).First().UserTypeEnumInt == (int)UserTypeEnum.MIM)
+                .Count();
 
             return ResponseOutput.Ok(result, new { TotalToBeReplyedCount = toBeDealedCount });
 
@@ -945,6 +955,10 @@ namespace IRaCIS.Core.Application
                        TrialCode = g.Key.TrialCode,
                        CriterionName = g.Key.CriterionName,
 
+                       UrgentCount = g.Where(u => u.VisitTask.IsUrgent).Select(u => u.VisitTask.IsUrgent && u.LatestReplyUser.UserTypeEnum == UserTypeEnum.IndependentReviewer).Count(),
+
+                       ToBeReplyedCount = g.Select(u => u.LatestReplyUser.UserTypeEnum == UserTypeEnum.IndependentReviewer).Count(),
+
                        //UrgentCount = g.Where(u => u.VisitTask.IsUrgent).Select(u => u.ReadingMedicalReviewDialogList.OrderByDescending(l => l.CreateTime).First()).Count(t => t.UserTypeEnumInt == (int)UserTypeEnum.IndependentReviewer),
 
                        //ToBeReplyedCount = g.Select(t => t.ReadingMedicalReviewDialogList.OrderByDescending(l => l.CreateTime).First()).Count(t => t.UserTypeEnumInt == (int)UserTypeEnum.IndependentReviewer),
@@ -962,7 +976,9 @@ namespace IRaCIS.Core.Application
             var toBeReplyedQuery = _taskMedicalReviewRepository
                   .Where(t => t.Trial.TrialUserList.Any(t => t.UserId == _userInfo.Id))
                   .Where(t => t.IsClosedDialog == false)
-                  .Where(u => u.ReadingMedicalReviewDialogList.OrderByDescending(l => l.CreateTime).First().UserTypeEnumInt == (int)UserTypeEnum.IndependentReviewer);
+                  .Where(u => u.LatestReplyUser.UserTypeEnum == UserTypeEnum.IndependentReviewer);
+                 
+                  //.Where(u => u.ReadingMedicalReviewDialogList.OrderByDescending(l => l.CreateTime).First().UserTypeEnumInt == (int)UserTypeEnum.IndependentReviewer);
 
             var toBeReplyedCount = toBeReplyedQuery.Count();
 

IRaCIS.Core.Domain/Allocation/TaskMedicalReview.cs

@@ -19,7 +19,10 @@ namespace IRaCIS.Core.Domain.Models
     [Table("TaskMedicalReview")]
     public class TaskMedicalReview : Entity, IAuditUpdate, IAuditAdd
     {
+        [JsonIgnore]
+        public User LatestReplyUser { get; set; }
 
+        public Guid? LatestReplyUserId { get; set; }
 
         /// <summary>
         /// CreateUserId