From aff1f5b599b61f16bee5296669b96cdb6ffdfac2 Mon Sep 17 00:00:00 2001
From: hang <872297557@qq.com>
Date: Mon, 30 Dec 2024 09:01:12 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=B4=E6=8A=A4=E6=95=B0=E6=8D=AE=E6=A0=B9?=
 =?UTF-8?q?=E6=8D=AE=E5=8F=91=E9=80=81=E7=AB=AF=E5=8A=A0=E9=94=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 IRC.Core.SCP/Service/CStoreSCPService.cs | 25 ++++++++++++++++--------
 1 file changed, 17 insertions(+), 8 deletions(-)

diff --git a/IRC.Core.SCP/Service/CStoreSCPService.cs b/IRC.Core.SCP/Service/CStoreSCPService.cs
index b147cacb9..5820bac6d 100644
--- a/IRC.Core.SCP/Service/CStoreSCPService.cs
+++ b/IRC.Core.SCP/Service/CStoreSCPService.cs
@@ -126,16 +126,25 @@ namespace IRaCIS.Core.SCP.Service
 
         public async Task OnReceiveAssociationReleaseRequestAsync()
         {
-            await DataMaintenanceAsaync();
+            var _distributedLockProvider = _serviceProvider.GetService<IDistributedLockProvider>();
 
-            //记录监控
+            var @lock = _distributedLockProvider.CreateLock($"{_upload.CallingAE}");
 
-            var _SCPImageUploadRepository = _serviceProvider.GetService<IRepository<SCPImageUpload>>();
+            using (await @lock.AcquireAsync())
+            {
 
-            _upload.EndTime = DateTime.Now;
-            _upload.StudyCount = _SCPStudyIdList.Count;
+                await DataMaintenanceAsaync();
 
-            await _SCPImageUploadRepository.AddAsync(_upload,true);
+                //记录监控
+
+                var _SCPImageUploadRepository = _serviceProvider.GetService<IRepository<SCPImageUpload>>();
+
+                _upload.EndTime = DateTime.Now;
+                _upload.StudyCount = _SCPStudyIdList.Count;
+
+                await _SCPImageUploadRepository.AddAsync(_upload, true);
+
+            }
 
             await SendAssociationReleaseResponseAsync();
         }
@@ -263,7 +272,7 @@ namespace IRaCIS.Core.SCP.Service
             {
                 try
                 {
-                    var scpStudyId = await dicomArchiveService.ArchiveDicomFileAsync(request.Dataset, storeRelativePath, Association.CallingAE, Association.CalledAE,fileSize);
+                    var scpStudyId = await dicomArchiveService.ArchiveDicomFileAsync(request.Dataset, storeRelativePath, Association.CallingAE, Association.CalledAE, fileSize);
 
                     if (!_SCPStudyIdList.Contains(scpStudyId))
                     {
@@ -315,7 +324,7 @@ namespace IRaCIS.Core.SCP.Service
 
             //监控信息设置
             _upload.FileCount++;
-            _upload.FileSize= _upload.FileSize+ fileSize;
+            _upload.FileSize = _upload.FileSize + fileSize;
             return new DicomCStoreResponse(request, DicomStatus.Success);
         }