Merge branch 'Test_IRC_Net8' of http://192.168.3.68:2000/XCKJ/irc-netcore-api into Test_IRC_Net8

IRaCIS.Core.API/Progranm.cs

@@ -25,8 +25,9 @@ using Microsoft.AspNetCore.HttpOverrides;
 using IRaCIS.Application.Services.BackGroundJob;
 using LogDashboard;
 using OfficeOpenXml.Utils;
+using FellowOakDicom.Network;
+using IRaCIS.Core.Application.Service.ImageAndDoc;
 
-Console.WriteLine("这是一个示例文本，示例文本中会出现示例多次。".Replace("示例", "替换"));
 
 #region 获取环境变量
 //以配置文件为准，否则 从url中取环境值(服务以命令行传递参数启动，配置文件配置了就不需要传递环境参数)
@@ -291,6 +292,8 @@ try
     //Log.Logger.Warning($"ContentRootPath——GetParent：{Directory.GetParent(env.ContentRootPath).Parent.FullName}");
     //Log.Logger.Warning($"ContentRootPath——xx：{Path.GetDirectoryName(Path.GetDirectoryName(env.ContentRootPath))}");
 
+    //DicomServerFactory.Create<CStoreSCPService>(11112);
+
     app.Run();
 
 }

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

@@ -101,6 +101,8 @@ namespace IRaCIS.Core.Application.Contracts
 
         public string Name { get; set; } = string.Empty;
 
+        public bool IsSigned { get; set; }
+
 
     }
 
@@ -113,6 +115,21 @@ namespace IRaCIS.Core.Application.Contracts
         public string SortField { get; set; } = "";
     }
 
+    public class TrialDocQuery : PageInput
+    {
+        public Guid? TrialId { get; set; }
+
+        public Guid? FileTypeId { get; set; }
+
+        public string TrialCode { get; set;} = string.Empty;
+
+
+        public string Name { get; set; } = string.Empty;
+
+        public bool IsSigned { get; set; }
+
+    }
+
     public class TrialUserDocUnionQuery: PageInput
     {
         [NotDefault]

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

@@ -183,7 +183,9 @@ namespace IRaCIS.Core.Application.Services
                             UserTypeShortName = user.UserTypeRole.UserTypeShortName
                         };
 
-            return await query.Where(t=>t.ConfirmTime==null).ToPagedListAsync(querySystemDocument.PageIndex, querySystemDocument.PageSize, querySystemDocument.SortField, querySystemDocument.Asc); 
+            return await query.WhereIf(querySystemDocument.IsSigned==true,t=>t.ConfirmTime!=null)
+                              .WhereIf(querySystemDocument.IsSigned == false, t => t.ConfirmTime == null)
+                              .ToPagedListAsync(querySystemDocument.PageIndex, querySystemDocument.PageSize, querySystemDocument.SortField, querySystemDocument.Asc); 
 
 
 

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

@@ -67,6 +67,50 @@ namespace IRaCIS.Core.Application.Services
         }
 
 
+        public async Task<PageOutput<UnionDocumentWithConfirmInfoView>> GetTrialSignDocumentList(TrialDocQuery querySystemDocument)
+        {
+            var trialDocQueryable = from trialDoc in _trialDocumentRepository.AsQueryable(true).Where(t => t.TrialId == querySystemDocument.TrialId)
+            .Where(t => t.NeedConfirmedUserTypeList.Any(t => t.NeedConfirmUserTypeId == _userInfo.UserTypeId))
+            .Where(t => t.IsDeleted == false || (t.IsDeleted == true && t.TrialDocConfirmedUserList.Any(t => t.ConfirmUserId == _userInfo.Id)))
+
+                                    join trialUser in _repository.Where<TrialUser>(t => t.TrialId == querySystemDocument.TrialId && t.UserId == _userInfo.Id) on trialDoc.TrialId equals trialUser.TrialId
+                                    join confirm in _repository.Where<TrialDocConfirmedUser>(t => t.TrialDocument.TrialId == querySystemDocument.TrialId) on
+                                    new { trialUser.UserId, TrialDocumentId = trialDoc.Id } equals new { UserId = confirm.ConfirmUserId, confirm.TrialDocumentId } into cc
+                                    from confirm in cc.DefaultIfEmpty()
+                                    select new UnionDocumentWithConfirmInfoView()
+                                    {
+                                        Id = trialDoc.Id,
+                                        IsSystemDoc = false,
+                                        CreateTime = trialDoc.CreateTime,
+                                        FullFilePath = trialDoc.Path,
+                                        IsDeleted = trialDoc.IsDeleted,
+                                        Name = trialDoc.Name,
+                                        Path = trialDoc.Path,
+                                        FileTypeId = trialDoc.FileTypeId,
+                                        FileType = _userInfo.IsEn_Us ? trialDoc.FileType.Value : trialDoc.FileType.ValueCN,
+                                        UpdateTime = trialDoc.UpdateTime,
+                                        SignViewMinimumMinutes = trialDoc.SignViewMinimumMinutes,
+
+                                        //IsConfirmed = confirm.ConfirmTime != null,
+                                        ConfirmUserId = confirm.ConfirmUserId,
+                                        ConfirmTime = confirm.ConfirmTime,
+                                        RealName = trialUser.User.FullName,
+                                        UserName = trialUser.User.UserName,
+                                        UserTypeId = trialUser.User.UserTypeId,
+                                        UserTypeShortName = trialUser.User.UserTypeRole.UserTypeShortName
+
+                                    };
+
+            trialDocQueryable = trialDocQueryable.WhereIf(!string.IsNullOrEmpty(querySystemDocument.Name), t => t.Name.Contains(querySystemDocument.Name))
+                .WhereIf(querySystemDocument.FileTypeId != null, t => t.FileTypeId == querySystemDocument.FileTypeId)
+               .WhereIf(querySystemDocument.IsSigned == true, t => t.ConfirmTime != null)
+               .WhereIf(querySystemDocument.IsSigned == false, t => t.ConfirmTime == null);
+
+
+             return await trialDocQueryable.ToPagedListAsync(querySystemDocument.PageIndex, querySystemDocument.PageSize, querySystemDocument.SortField, querySystemDocument.Asc);
+
+        }
+
         /// <summary>
         /// 获取下一个未签名的文件
         /// </summary>
@@ -166,7 +210,7 @@ namespace IRaCIS.Core.Application.Services
 
             var trialId = querySystemDocument.TrialId;
 
-            var trialInfo = await (_repository.Where<Trial>(t => t.Id == querySystemDocument.TrialId,ignoreQueryFilters:true).Select(t => new { t.TrialFinishedTime, t.TrialStatusStr }).FirstNotNullAsync());
+            var trialInfo = await (_repository.Where<Trial>(t => t.Id == querySystemDocument.TrialId, ignoreQueryFilters: true).Select(t => new { t.TrialFinishedTime, t.TrialStatusStr }).FirstNotNullAsync());
 
             //系统文档查询
             var systemDocumentQueryable = from needConfirmedUserType in _repository.Where<SystemDocNeedConfirmedUserType>(t => t.NeedConfirmUserTypeId == _userInfo.UserTypeId)

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

@@ -0,0 +1,132 @@
+using FellowOakDicom.Network;
+using FellowOakDicom;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using IRaCIS.Core.Application.Contracts.Dicom;
+
+namespace IRaCIS.Core.Application.Service.ImageAndDoc
+{
+
+    public class CStoreSCPService : DicomService, IDicomServiceProvider, IDicomCStoreProvider, IDicomCEchoProvider
+    {
+        public readonly IDicomArchiveService _dicomArchiveService;
+
+
+        private static readonly DicomTransferSyntax[] _acceptedTransferSyntaxes = new DicomTransferSyntax[]
+        {
+               DicomTransferSyntax.ExplicitVRLittleEndian,
+               DicomTransferSyntax.ExplicitVRBigEndian,
+               DicomTransferSyntax.ImplicitVRLittleEndian
+        };
+
+        private static readonly DicomTransferSyntax[] _acceptedImageTransferSyntaxes = new DicomTransferSyntax[]
+        {
+               // Lossless
+               DicomTransferSyntax.JPEGLSLossless,
+               DicomTransferSyntax.JPEG2000Lossless,
+               DicomTransferSyntax.JPEGProcess14SV1,
+               DicomTransferSyntax.JPEGProcess14,
+               DicomTransferSyntax.RLELossless,
+               // Lossy
+               DicomTransferSyntax.JPEGLSNearLossless,
+               DicomTransferSyntax.JPEG2000Lossy,
+               DicomTransferSyntax.JPEGProcess1,
+               DicomTransferSyntax.JPEGProcess2_4,
+               // Uncompressed
+               DicomTransferSyntax.ExplicitVRLittleEndian,
+               DicomTransferSyntax.ExplicitVRBigEndian,
+               DicomTransferSyntax.ImplicitVRLittleEndian
+        };
+
+
+        public CStoreSCPService(INetworkStream stream, Encoding fallbackEncoding, ILogger log, DicomServiceDependencies dependencies/*, IDicomArchiveService dicomArchiveService*/)
+            : base(stream, fallbackEncoding, log, dependencies)
+        {
+            //_dicomArchiveService = dicomArchiveService;
+        }
+
+
+        public Task OnReceiveAssociationRequestAsync(DicomAssociation association)
+        {
+            if (association.CalledAE != "STORESCP")
+            {
+                return SendAssociationRejectAsync(
+                    DicomRejectResult.Permanent,
+                    DicomRejectSource.ServiceUser,
+                    DicomRejectReason.CalledAENotRecognized);
+            }
+
+            foreach (var pc in association.PresentationContexts)
+            {
+                if (pc.AbstractSyntax == DicomUID.Verification)
+                {
+                    pc.AcceptTransferSyntaxes(_acceptedTransferSyntaxes);
+                }
+                else if (pc.AbstractSyntax.StorageCategory != DicomStorageCategory.None)
+                {
+                    pc.AcceptTransferSyntaxes(_acceptedImageTransferSyntaxes);
+                }
+            }
+
+            return SendAssociationAcceptAsync(association);
+        }
+
+
+        public Task OnReceiveAssociationReleaseRequestAsync()
+        {
+            return SendAssociationReleaseResponseAsync();
+        }
+
+
+        public void OnReceiveAbort(DicomAbortSource source, DicomAbortReason reason)
+        {
+            /* nothing to do here */
+        }
+
+
+        public void OnConnectionClosed(Exception exception)
+        {
+            /* nothing to do here */
+        }
+
+
+        public async Task<DicomCStoreResponse> OnCStoreRequestAsync(DicomCStoreRequest request)
+        {
+            var studyUid = request.Dataset.GetSingleValue<string>(DicomTag.StudyInstanceUID).Trim();
+            var instUid = request.SOPInstanceUID.UID;
+
+            var path = Path.GetFullPath(@".\DICOM-Store");
+
+            path = Path.Combine(path, studyUid);
+
+            if (!Directory.Exists(path))
+            {
+                Directory.CreateDirectory(path);
+            }
+
+            path = Path.Combine(path, instUid) + ".dcm";
+
+            await request.File.SaveAsync(path);
+
+            return new DicomCStoreResponse(request, DicomStatus.Success);
+        }
+
+
+        public Task OnCStoreRequestExceptionAsync(string tempFileName, Exception e)
+        {
+            // let library handle logging and error response
+            return Task.CompletedTask;
+        }
+
+
+        public Task<DicomCEchoResponse> OnCEchoRequestAsync(DicomCEchoRequest request)
+        {
+            return Task.FromResult(new DicomCEchoResponse(request, DicomStatus.Success));
+        }
+
+    }
+}

IRaCIS.Core.Application/Service/Management/UserTypeService.cs

@@ -144,7 +144,6 @@ namespace IRaCIS.Core.Application.Contracts
             {
                 userTypeEnums = new List<UserTypeEnum>() { UserTypeEnum.CRA, UserTypeEnum.ClinicalResearchCoordinator };
 
-
             }
 
 

IRaCIS.Core.Application/Service/TrialSiteUser/DTO/PersonalWorkstationViewModel.cs

@@ -382,6 +382,10 @@ namespace IRaCIS.Core.Application.Contracts
         public int? TrialWaitSignDocCount { get; set; }
 
         public int? SysWaitSignDocCount { get; set; }
+
+        public int? TrialSignedDocCount { get; set; }
+        public int? SysSignedDocCount { get; set; }
+
         #region PM/APM
         public int? PM_SiteSurveryCount { get; set; }
         public int? PM_CheckCount { get; set; }

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

@@ -1212,6 +1212,17 @@ namespace IRaCIS.Core.Application
                         .SelectMany(t => t.NeedConfirmedUserTypeList)
                         .CountAsync(t => t.NeedConfirmUserTypeId == _userInfo.UserTypeId);
 
+            var signedTrialCount = await _trialRepository.Where(t => t.TrialStatusStr != StaticData.TrialState.TrialStopped).Where(t => t.TrialUserList.Any(t => t.UserId == _userInfo.Id))
+               .Where(c => c.TrialDocumentList.Where(t => t.IsDeleted == false && t.NeedConfirmedUserTypeList.Any(t => t.NeedConfirmUserTypeId == _userInfo.UserTypeId)
+               && t.TrialDocConfirmedUserList.Any(t => t.ConfirmUserId == _userInfo.Id && t.ConfirmTime != null)).Count() > 0).CountAsync();
+
+            var signedSysDocCont = await _systemDocumentRepository
+                       .Where(t => t.IsDeleted == false && t.SystemDocConfirmedUserList.Any(t => t.ConfirmUserId == _userInfo.Id && t.ConfirmTime != null))
+                       .SelectMany(t => t.NeedConfirmedUserTypeList)
+                       .CountAsync(t => t.NeedConfirmUserTypeId == _userInfo.UserTypeId);
+
+
+
             var siteSurveyCount = await _trialRepository
                     .Where(t => t.TrialUserList.Any(t => t.UserId == _userInfo.Id))
                     .WhereIf(_userInfo.UserTypeEnumInt == (int)UserTypeEnum.ProjectManager || _userInfo.UserTypeEnumInt == (int)UserTypeEnum.APM, c => c.TrialSiteSurveyList.Where(t => t.State == TrialSiteSurveyEnum.SPMApproved).Count() > 0)
@@ -1248,6 +1259,9 @@ namespace IRaCIS.Core.Application
                 SysWaitSignDocCount =  needSignSysDocCont,
                 TrialWaitSignDocCount =  needSignTrialCount ,
 
+                TrialSignedDocCount=signedTrialCount,
+                SysSignedDocCount=signedSysDocCont,
+
                 #region PM
 
                 PM_SiteSurveryCount = isPM ? siteSurveyCount : 0,