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

增加日志记录发送Cmove
continuous-integration/drone/push Build is passing Details

Test_HIR_Net8
hang 2025-02-07 17:21:29 +08:00
parent 6f8b88422b
commit c69b2569ce
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
IRaCIS.Core.Application/Service/Visit/PatientService.cs
View File

@ -50,6 +50,7 @@ using static Microsoft.EntityFrameworkCore.DbLoggerCategory;
using DocumentFormat.OpenXml.Vml.Office;
using IRaCIS.Core.Infra.EFCore.Migrations;
using System.Dynamic;
using System.Threading.Channels;
namespace IRaCIS.Application.Services
@ -3152,15 +3153,17 @@ namespace IRaCIS.Application.Services
{
DicomCMoveRequest.ResponseDelegate responseDelegate = (req, response) =>
{
if (response.Status.State == DicomState.Failure)
if (response.Status.State == DicomState.Failure || response.Status.State == DicomState.Cancel)
{
_logger.LogError($" Cmove Pacs 状态返回失败： {response.SOPClassUID.ToJsonNotIgnoreNull()}");
_logger.LogError($" Cmove Pacs 返回状态： {response.Status.State} {response.SOPClassUID.ToJsonNotIgnoreNull()}");
_fusionCache.Set<string?>(CacheKeys.CmoveStudyId(req.Dataset.GetString(DicomTag.StudyInstanceUID)), null, TimeSpan.FromSeconds(1));
}
// 判断是否传输完成或中断，执行缓存清理
if (response.Status.State == DicomState.Success && response.Remaining == 0)
{
_fusionCache.Set<string?>(CacheKeys.CmoveStudyId(req.Dataset.GetString(DicomTag.StudyInstanceUID)), null, TimeSpan.FromSeconds(1));
_fusionCache.Set<string?>(CacheKeys.CmoveStudyId(req.Dataset.GetString(DicomTag.StudyInstanceUID)), null, TimeSpan.FromSeconds(1));
}
};
@ -3192,7 +3195,16 @@ namespace IRaCIS.Application.Services
cmoveRequest.OnResponseReceived += responseDelegate;
cmoveRequestList.Add(cmoveRequest);
_logger.LogInformation($"执行 Cmove StudyInstanceUid：{item}");
}
else
{
_logger.LogInformation($"忽略 Cmove StudyInstanceUid：{item}");
}
}
await client.AddRequestsAsync(cmoveRequestList);