Merge branch 'Test_IRC_Net8' of https://gitea.frp.extimaging.com/XCKJ/irc-netcore-api into Test_IRC_Net8

IRaCIS.Core.Application/BusinessFilter/LegacyController/ModelActionFilter .cs

@@ -1,7 +1,11 @@
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.Mvc.Filters;
+using Microsoft.AspNetCore.Mvc.ModelBinding;
+using Microsoft.AspNetCore.Mvc.ModelBinding.Binders;
+using Microsoft.AspNetCore.Mvc.ModelBinding.Metadata;
 using Microsoft.Extensions.Localization;
 using Newtonsoft.Json;
+using System.Reflection;
 
 
 namespace IRaCIS.Core.Application.Filter;
@@ -28,3 +32,7 @@ public class ModelActionFilter(IStringLocalizer _localizer) : ActionFilterAttrib
         }
     }
 }
+
+
+
+

IRaCIS.Core.Application/Helper/DicomDIRHelper.cs

@@ -1,4 +1,5 @@
-using FellowOakDicom;
+using DocumentFormat.OpenXml.Office.CustomUI;
+using FellowOakDicom;
 using FellowOakDicom.Media;
 using System;
 using System.Collections.Generic;
@@ -57,6 +58,7 @@ namespace IRaCIS.Core.Application.Helper
             var mappings = new List<string>();
             int index = 1;
 
+            var studyUid=list.FirstOrDefault()?.StudyInstanceUid;
 
             var dicomDir = new DicomDirectory();
 
@@ -130,7 +132,7 @@ namespace IRaCIS.Core.Application.Helper
 
                    var relativePath= await _oSSService.UploadToOSSAsync(memoryStream, ossFolder, "DICOMDIR", true);
 
-                    dic.Add("DICOMDIR" , relativePath.Split('/').Last());
+                    dic.Add($"{studyUid}_DICOMDIR" , relativePath.Split('/').Last());
                 }
 
                 //清理临时文件

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

@@ -1173,7 +1173,7 @@ public class VisitTaskService(IRepository<VisitTask> _visitTaskRepository,
             var visitQuery = _visitTaskRepository.Where(x => x.TrialId == trialId && x.DoctorUserId == _userInfo.UserRoleId && x.TaskState == TaskState.Effect)
                 .WhereIf(inQuery.SubjectId != null, x => x.SubjectId == inQuery.SubjectId)
                 .WhereIf(!string.IsNullOrEmpty(subjectCode), t => (t.Subject.Code.Contains(subjectCode!) && t.IsAnalysisCreate == false) || (t.BlindSubjectCode.Contains(subjectCode!) && t.IsAnalysisCreate))
-                .WhereIf(critrion.CriterionType == CriterionType.OCT, t => t.ReadingCategory == ReadingCategory.Visit ? t.SourceSubjectVisit.NoneDicomStudyList.Where(t=>t.Modality=="OCT").SelectMany(t => t.ImageLabelNoneDicomFileList).Any() : true)
+                .WhereIf(critrion.CriterionType == CriterionType.OCT, t => t.ReadingCategory == ReadingCategory.Visit ? t.SourceSubjectVisit.NoneDicomStudyList.Where(t => t.Modality == "OCT").SelectMany(t => t.ImageLabelNoneDicomFileList).Any() : true)
                 .WhereIf(critrion.CriterionType == CriterionType.IVUS, t => t.ReadingCategory == ReadingCategory.Visit ? t.SourceSubjectVisit.NoneDicomStudyList.Where(t => t.Modality == "IVUS").SelectMany(t => t.ImageLabelNoneDicomFileList).Any() : true);
 
             var visitGroupQuery = visitQuery.GroupBy(x => new { x.SubjectId, x.Subject.Code, x.BlindSubjectCode });
@@ -2293,12 +2293,12 @@ public class VisitTaskService(IRepository<VisitTask> _visitTaskRepository,
 
         foreach (var item in readingTableAnswerRowInfoList)
         {
-            if (item.SplitRowId!=null&&lesionRelationship.ContainsKey(item.SplitRowId.Value))
+            if (item.SplitRowId != null && lesionRelationship.ContainsKey(item.SplitRowId.Value))
             {
                 item.SplitRowId = lesionRelationship[item.SplitRowId.Value];
             }
 
-            if (item.MergeRowId!=null&&lesionRelationship.ContainsKey(item.MergeRowId.Value))
+            if (item.MergeRowId != null && lesionRelationship.ContainsKey(item.MergeRowId.Value))
             {
                 item.MergeRowId = lesionRelationship[item.MergeRowId.Value];
             }
@@ -2403,6 +2403,10 @@ public class VisitTaskService(IRepository<VisitTask> _visitTaskRepository,
                 //另一个阅片人的任务根据任务进度自动进入PM退回或PM申请重阅
                 filterExpression = filterExpression.And(t => t.VisitTaskNum >= task.VisitTaskNum);
 
+                //退回只影响有序的后续所有的，无序的当前访视
+                filterExpression = filterExpression.And(t => (t.TrialReadingCriterion.IsReadingTaskViewInOrder == ReadingOrder.InOrder) ||
+                (t.TrialReadingCriterion.IsReadingTaskViewInOrder != ReadingOrder.InOrder && t.SourceSubjectVisitId == task.SourceSubjectVisitId));
+
 
                 var influenceTaskList = await _visitTaskRepository.Where(filterExpression, true).ToListAsync();
 
@@ -2564,7 +2568,7 @@ public class VisitTaskService(IRepository<VisitTask> _visitTaskRepository,
                     otherVisitIdList = otherVisitIdList.Where(t => t != task.SourceSubjectVisitId.Value).ToList();
                 }
 
-               
+
 
                 //BM后续访视 ，筛选状态不变，任务生成状态重置（实际该访视任务状态 可能是重阅重置了或者失效了，需要后续生成，或者取消分配了，需要后续重新分配）
                 await _subjectCriteriaEvaluationVisitFilterRepository.UpdatePartialFromQueryAsync(t => t.TrialReadingCriterion.CriterionType == CriterionType.RECIST1Pointt1_MB && t.SubjectVisit.SubjectId == task.SubjectId && otherVisitIdList.Contains(t.SubjectVisitId),
@@ -2727,6 +2731,13 @@ public class VisitTaskService(IRepository<VisitTask> _visitTaskRepository,
                 //默认影响的都是该标准的任务
                 filterExpression = filterExpression.And(t => t.TrialReadingCriterionId == filterObj.TrialReadingCriterionId);
             }
+
+            //退回只影响有序的后续所有的，无序的当前访视
+            if (isReReading == false)
+            {
+                filterExpression = filterExpression.And(t => (t.TrialReadingCriterion.IsReadingTaskViewInOrder == ReadingOrder.InOrder) ||
+                (t.TrialReadingCriterion.IsReadingTaskViewInOrder != ReadingOrder.InOrder && t.SourceSubjectVisitId == filterObj.SourceSubjectVisitId));
+            }
         }
 
 

IRaCIS.Core.Application/Service/Common/Export/TumorExportService.cs

@@ -601,9 +601,11 @@ public class Tumor_CDISC_ExportService(IRepository<ReadingQuestionCriterionTrial
 
                 #region tu 表处理部分
 
+                var tu = CreatNewTUExport(task, lesion, visitIndexNoDic, translateDataList, isEn_Us);
+
+
                 if (!tuList.Any(t => t.SubjectCode == task.SubjectCode && t.ARM_TumorNo == $"{task.ArmEnumStr}_{lesion.LessionCode}"))
                 {
-                    var tu = CreatNewTUExport(task, lesion, visitIndexNoDic, translateDataList, isEn_Us);
 
                     if (lesion.OrganInfoId.HasValue)
                     {

IRaCIS.Core.Application/Service/Document/DTO/SystemDocumentViewModel.cs

@@ -92,6 +92,10 @@ namespace IRaCIS.Core.Application.Contracts
 
     public class UnionDocumentWithConfirmInfoView : UnionDocumentView
     {
+        public DocUserSignType SysDocUserSignType { get; set; }
+
+        public bool IsConfirmIdentityUserInner { get; set; }
+
         public Guid TrialId { get; set; }
 
         public bool IsNeedSendEmial { get; set; }

IRaCIS.Core.Application/Service/Document/Interface/ITrialDocumentService.cs

@@ -19,6 +19,8 @@ namespace IRaCIS.Core.Application.Contracts
         Task<IResponseOutput> UserConfirm(UserConfirmCommand userConfirmCommand);
         Task<List<TrialUserDto>> GetTrialUserSelect(Guid trialId);
 
+        Task<IResponseOutput<PageOutput<UnionDocumentWithConfirmInfoView>>> GetSysDocumentConfirmList(SystemDocQuery inQuery);
+
 
         //Task<PageOutput<DocumentUnionWithUserStatView>> GetTrialSystemDocumentList(DocumentTrialUnionQuery querySystemDocument);
         //List<TrialUserUnionDocumentView> GetTrialUserDocumentList(Guid trialId);

IRaCIS.Core.Application/Service/Document/SystemDocumentService.cs

@@ -302,6 +302,7 @@ namespace IRaCIS.Core.Application.Services
                         {
                             AttachmentCount=sysDoc.SystemDocumentAttachmentList.Where(z=>!z.OffLine).Count(),
                             IsSystemDoc = true,
+                            IsPublish=sysDoc.IsPublish,
                             CurrentStaffTrainDays=sysDoc.CurrentStaffTrainDays,
                             NewStaffTrainDays = sysDoc.NewStaffTrainDays,
                             Id = sysDoc.Id,
@@ -327,6 +328,7 @@ namespace IRaCIS.Core.Application.Services
                             //UserTypeShortName = user.UserTypeRole.UserTypeShortName
                         };
 
+
             var list = await query
                               //过滤掉删除的，并且没有签名的
                               .Where(t => !(t.IsDeleted == true && t.ConfirmTime == null))

IRaCIS.Core.Application/Service/Document/TrialDocumentService.cs

@@ -952,10 +952,13 @@ namespace IRaCIS.Core.Application.Services
                 return ResponseOutput.Ok(new PageOutput<UnionDocumentWithConfirmInfoView>());
             }
 
+
             var systemDocQuery =
-               from sysDoc in _systemDocumentRepository.AsQueryable(false)
+               from sysDoc in _systemDocumentRepository.Where(t => t.IsPublish)
                                               .Where(t => inQuery.UserTypeId != null ? t.NeedConfirmedUserTypeList.Any(t => t.NeedConfirmUserTypeId == inQuery.UserTypeId) : true)
-               from identityUser in _identityUserRepository.AsQueryable(false).Where(t => t.Status == UserStateEnum.Enable && t.UserRoleList.Where(t => t.IsUserRoleDisabled == false).Any(t => sysDoc.NeedConfirmedUserTypeList.AsQueryable().Any(c => c.NeedConfirmUserTypeId == t.UserTypeId)))
+               from identityUser in _identityUserRepository.AsQueryable(false)
+
+                  .Where(t => t.Status == UserStateEnum.Enable && t.UserRoleList.Where(t => t.IsUserRoleDisabled == false).Any(t => sysDoc.NeedConfirmedUserTypeList.AsQueryable().Any(c => c.NeedConfirmUserTypeId == t.UserTypeId)))
                   .Where(t => inQuery.UserId != null ? t.Id == inQuery.UserId : true)
                   .Where(t => inQuery.UserTypeId != null ? t.UserRoleList.Any(t => t.UserTypeId == inQuery.UserTypeId && t.IsUserRoleDisabled == false) : true)
                   .Where(t => isEA ? t.IsZhiZhun == true : true) //EA 只能查看内部人员文档
@@ -964,6 +967,9 @@ namespace IRaCIS.Core.Application.Services
                select new UnionDocumentWithConfirmInfoView()
                {
                    IsSystemDoc = true,
+                   SysDocUserSignType = sysDoc.DocUserSignType,
+                   IsConfirmIdentityUserInner = identityUser.IsZhiZhun,
+                   IsPublish=sysDoc.IsPublish,
                    Id = sysDoc.Id,
                    CreateTime = sysDoc.CreateTime,
                    IsDeleted = sysDoc.IsDeleted,
@@ -995,14 +1001,16 @@ namespace IRaCIS.Core.Application.Services
                };
 
             var unionQuery = systemDocQuery.IgnoreQueryFilters().Where(t => !(t.IsDeleted == true && t.ConfirmTime == null))
+                            //外部人员 只签署 外部需要签署的    
+                            .Where(t => t.IsConfirmIdentityUserInner == false ? t.SysDocUserSignType == DocUserSignType.InnerAndOuter : true)
                             .WhereIf(!string.IsNullOrEmpty(inQuery.Name), t => t.Name.Contains(inQuery.Name))
                             .WhereIf(inQuery.FileTypeId != null, t => t.FileTypeId == inQuery.FileTypeId)
                             .WhereIf(inQuery.IsConfirmed == true, t => t.ConfirmTime != null)
                             .WhereIf(inQuery.IsConfirmed == false, t => t.ConfirmTime == null)
                             .WhereIf(inQuery.StartConfirmTime != null, t => t.ConfirmTime >= inQuery.StartConfirmTime.Value)
                             .WhereIf(inQuery.EndConfirmTime != null, t => t.ConfirmTime <= inQuery.EndConfirmTime.Value)
-                             .WhereIf(inQuery.BeginCreateTime != null, t => t.CreateTime >= inQuery.BeginCreateTime)
-                             .WhereIf(inQuery.EndCreateTime != null, t => t.CreateTime <= inQuery.EndCreateTime)
+                            .WhereIf(inQuery.BeginCreateTime != null, t => t.CreateTime >= inQuery.BeginCreateTime)
+                            .WhereIf(inQuery.EndCreateTime != null, t => t.CreateTime <= inQuery.EndCreateTime)
                             .WhereIf(!string.IsNullOrEmpty(inQuery.UserName), t => t.UserName.Contains(inQuery.UserName))
                             .WhereIf(inQuery.IsDeleted != null, t => t.IsDeleted == inQuery.IsDeleted)
                             .WhereIf(isInternal == false, t => t.ConfirmTime != null); //不是内部的人，看有签名时间的

IRaCIS.Core.Application/Service/ImageAndDoc/DownloadAndUploadService.cs

@@ -1185,6 +1185,9 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
 
                 foreach (var item in list.GroupBy(t => new { t.StudyInstanceUid, t.DicomStudyId }))
                 {
+
+                    var studyUid = item.Key.StudyInstanceUid;
+
                     var ossFolder = $"{pathInfo.TrialId}/Image/{pathInfo.SubjectId}/{pathInfo.VisitId}/{item.Key.StudyInstanceUid}";
 
                     var isSucess = await SafeBussinessHelper.RunAsync(async () => await DicomDIRHelper.GenerateStudyDIRAndUploadAsync(item.ToList(), dirDic, ossFolder, _oSSService));
@@ -1192,7 +1195,7 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
 
                     if (isSucess)
                     {
-                        await _dicomStudyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Key.DicomStudyId, u => new DicomStudy() { StudyDIRPath = $"/{ossFolder}/{dirDic["DICOMDIR"]}" });
+                        await _dicomStudyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Key.DicomStudyId, u => new DicomStudy() { StudyDIRPath = $"/{ossFolder}/{dirDic[$"{studyUid}_DICOMDIR"]}" });
                     }
 
                 }
@@ -1625,6 +1628,8 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
 
                     var ossFolder = $"{pathInfo.TrialId}/Image/{pathInfo.SubjectId}/{visitId}/{item.Key.StudyInstanceUid}";
 
+                    var studyUid = item.Key.StudyInstanceUid;
+
                     var isSucess = await SafeBussinessHelper.RunAsync(async () => await DicomDIRHelper.GenerateStudyDIRAndUploadAsync(item.ToList(), dirDic, ossFolder, _oSSService));
 
 
@@ -1632,11 +1637,11 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
                     {
                         if (isTaskStudy)
                         {
-                            await _taskStudyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Key.DicomStudyId, u => new TaskStudy() { StudyDIRPath = $"/{ossFolder}/{dirDic["DICOMDIR"]}" });
+                            await _taskStudyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Key.DicomStudyId, u => new TaskStudy() { StudyDIRPath = $"/{ossFolder}/{dirDic[$"{studyUid}_DICOMDIR"]}" });
                         }
                         else
                         {
-                            await _dicomStudyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Key.DicomStudyId, u => new DicomStudy() { StudyDIRPath = $"/{ossFolder}/{dirDic["DICOMDIR"]}" });
+                            await _dicomStudyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Key.DicomStudyId, u => new DicomStudy() { StudyDIRPath = $"/{ossFolder}/{dirDic[$"{studyUid}_DICOMDIR"]}" });
                         }
 
                     }
@@ -2303,6 +2308,7 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
 
                         var subjectId = item.First().SubjectId;
 
+                        var studyUid = item.Key.StudyInstanceUid;
 
                         var ossFolder = $"{inCommand.TrialId}/Image/{subjectId}/{visitId}/{item.Key.StudyInstanceUid}";
 
@@ -2310,7 +2316,7 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
 
                         if (isSucess)
                         {
-                            await _dicomStudyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Key.DicomStudyId, u => new DicomStudy() { StudyDIRPath = $"/{ossFolder}/{dirDic["DICOMDIR"]}" });
+                            await _dicomStudyRepository.BatchUpdateNoTrackingAsync(t => t.Id == item.Key.DicomStudyId, u => new DicomStudy() { StudyDIRPath = $"/{ossFolder}/{dirDic[$"{studyUid}_DICOMDIR"]}" });
                         }
                     }
                 }

IRaCIS.Core.Application/TestService.cs

@@ -39,6 +39,7 @@ using SixLabors.ImageSharp;
 using SixLabors.ImageSharp.Formats.Jpeg;
 using SixLabors.ImageSharp.Processing;
 using System.Collections.Concurrent;
+using System.ComponentModel.DataAnnotations;
 using System.Diagnostics;
 using System.Globalization;
 using System.IO;
@@ -77,6 +78,46 @@ namespace IRaCIS.Core.Application.Service
         public static int IntValue = 100;
 
 
+        public class ModelVerifyCommand
+        {
+            public int? IntNUllValue { get; set; }
+            public int IntValue { get; set; }
+
+            public string StringValue { get; set; }
+
+            public string? StringNUllValue { get; set; }
+
+            public string StringBackDefaultValue { get; set; } = string.Empty;
+
+            public Guid GuidValue { get; set; } = NewId.NextSequentialGuid();
+
+            public Guid? GuidNUllValue { get; set; }
+
+            [NotDefault]
+            public Guid GuidValueNotDefault { get; set; }
+
+
+            public bool BoolValue { get; set; }
+
+            public bool? BoolNUllValue { get; set; }
+
+            public DateTime DateTimeValue { get; set; }
+
+            public DateTime? DateTimeNUllValue { get; set; }
+        }
+
+
+        //创建一个模型验证的方法
+        [AllowAnonymous]
+        [HttpPost]
+        public async Task<IResponseOutput> PostModelVerify(ModelVerifyCommand modelVerify)
+        {
+
+            return ResponseOutput.Ok(modelVerify);
+
+        }
+
+
         [AllowAnonymous]
 
         public async Task<IResponseOutput> CreatNewDBStruct()
@@ -99,10 +140,10 @@ namespace IRaCIS.Core.Application.Service
 
         public async Task<IResponseOutput> DeleteCacheDIR()
         {
-           var list= _dicomStudyRepository.Where(t => t.StudyDIRPath!="").Select(t => t.StudyDIRPath).ToList();
+            var list = _dicomStudyRepository.Where(t => t.StudyDIRPath != "").Select(t => t.StudyDIRPath).ToList();
 
 
-            await _IOSSService.DeleteObjects(list.Select(t => t.TrimStart('/')).ToList(),true);
+            await _IOSSService.DeleteObjects(list.Select(t => t.TrimStart('/')).ToList(), true);
 
             return ResponseOutput.Ok();
         }