XCKJ
/
irc-netcore-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改锁

Uat_Study
hang 2023-05-05 17:44:00 +08:00
parent 1958dca2be
commit 884e03fab5
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
IRaCIS.Core.Application/Service/ImageAndDoc/StudyService.cs
View File

@ -13,6 +13,8 @@ using IRaCIS.Core.Application.Filter;
using IRaCIS.Core.Application.MediatR.Handlers; using IRaCIS.Core.Application.MediatR.Handlers;
using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Http;
using Newtonsoft.Json; using Newtonsoft.Json;
using System.Threading;
using Nito.AsyncEx;
namespace IRaCIS.Core.Application.Service.ImageAndDoc namespace IRaCIS.Core.Application.Service.ImageAndDoc
{ {
@ -20,6 +22,7 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
public class StudyService : BaseService, IStudyService public class StudyService : BaseService, IStudyService
{ {
private static object lockCodeGenerate = new object(); private static object lockCodeGenerate = new object();
private readonly AsyncLock _mutex = new AsyncLock();
private readonly IEasyCachingProvider _provider; private readonly IEasyCachingProvider _provider;
@ -128,12 +131,13 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
studyMonitor.UploadFinishedTime = DateTime.Now; studyMonitor.UploadFinishedTime = DateTime.Now;
studyMonitor.ArchiveFinishedTime = DateTime.Now; studyMonitor.ArchiveFinishedTime = DateTime.Now;
studyMonitor.IsDicomReUpload = !incommand.IsAdd; studyMonitor.IsDicomReUpload = !incommand.IsAdd;
studyMonitor.IsSuccess = true;
if (incommand.IsAdd) if (incommand.IsAdd)
{ {
var study = _mapper.Map<DicomStudy>(incommand.Study); var study = _mapper.Map<DicomStudy>(incommand.Study);
lock (lockCodeGenerate) using (await _mutex.LockAsync())
{ {
//查询数据库获取最大的Code 没有记录则为0 //查询数据库获取最大的Code 没有记录则为0
@ -277,8 +281,11 @@ namespace IRaCIS.Core.Application.Service.ImageAndDoc
} }
using (await _mutex.LockAsync())
await _dicomstudyRepository.SaveChangesAsync(); {
await _dicomstudyRepository.SaveChangesAsync();
}
return ResponseOutput.Ok(); return ResponseOutput.Ok();
} }