修改下载代码
continuous-integration/drone/push Build is running Details

Test_IRC_Net8
hang 2026-06-01 15:37:01 +08:00
parent 41efcbfdf1
commit 45db942f66
1 changed files with 11 additions and 7 deletions

View File

@ -276,13 +276,17 @@ namespace IRaCIS.Core.Application.Service
Log.Logger.Warning($"download_log.csv访视数量{existVisits.Count}"); Log.Logger.Warning($"download_log.csv访视数量{existVisits.Count}");
Log.Logger.Warning($"csv排除前需要下载数量{acturalDownList.Count}");
acturalDownList = acturalDownList.Where(t => !existVisits.Any(old => old.VisitNum == t.VisitNum && old.SubjectCode == t.SubjectCode && acturalDownList = acturalDownList.Where(t => !existVisits.Any(old => old.VisitNum == t.VisitNum && old.SubjectCode == t.SubjectCode &&
old.VisitName.Trim().ToLower() == t.VisitName.Trim().ToLower())).ToList(); old.VisitName.Trim().ToLower() == t.VisitName.Trim().ToLower())).ToList();
Log.Logger.Warning($"csv排除后需要下载数量{acturalDownList.Count}");
} }
acturalDownList = acturalDownList.Skip(startIndex - 1).Take(endIndex).ToList(); acturalDownList = acturalDownList.Skip(startIndex - 1).Take(endIndex - startIndex + 1).ToList();
Log.Logger.Warning($"该区{startIndex}-{endIndex} 实际需要下载访视数量:{acturalDownList.Count}"); Log.Logger.Warning($"该区{startIndex}-{endIndex} 实际需要下载访视数量:{acturalDownList.Count}");
@ -319,7 +323,7 @@ namespace IRaCIS.Core.Application.Service
// 遍历 Series // 遍历 Series
foreach (var seriesInfo in studyInfo.SeriesList) foreach (var seriesInfo in studyInfo.SeriesList)
{ {
string studyDicomFolderPath = Path.Combine(trialFolderPath, $"{visitItem.SubjectCode}_{visitItem.VisitName}", $"{studyInfo.StudyCode}_{studyInfo.StudyTime?.ToString("yyyy-MM-dd")}_{seriesInfo.Modality}"); string studyDicomFolderPath = Path.Combine(trialFolderPath, $"{visitItem.SubjectCode}_{visitItem.VisitName.Trim()}", $"{studyInfo.StudyCode}_{studyInfo.StudyTime?.ToString("yyyy-MM-dd")}_{seriesInfo.Modality}");
// 创建 影像 文件夹 // 创建 影像 文件夹
Directory.CreateDirectory(studyDicomFolderPath); Directory.CreateDirectory(studyDicomFolderPath);
@ -333,7 +337,7 @@ namespace IRaCIS.Core.Application.Service
downloadJobs.Add(new DownloadJob() downloadJobs.Add(new DownloadJob()
{ {
Name = $"{visitItem.SubjectCode}_{visitItem.VisitNum}_{visitItem.VisitName}_DICOM_{destinationPath}", Name = $"{visitItem.SubjectCode}_{visitItem.VisitNum}_{visitItem.VisitName.Trim()}_DICOM_{destinationPath}",
Action = async () => Action = async () =>
{ {
@ -381,11 +385,11 @@ namespace IRaCIS.Core.Application.Service
//建立压缩包 //建立压缩包
string visitFolderPath = Path.Combine(trialFolderPath, $"{visitItem.SubjectCode}_{visitItem.VisitName}"); string visitFolderPath = Path.Combine(trialFolderPath, $"{visitItem.SubjectCode}_{visitItem.VisitName.Trim()}");
downloadJobs.Add(new DownloadJob() downloadJobs.Add(new DownloadJob()
{ {
Name = $"{visitItem.SubjectCode}_{visitItem.VisitName}_Zip", Name = $"{visitItem.SubjectCode}_{visitItem.VisitName.Trim()}_Zip",
Action = async () => Action = async () =>
{ {
@ -411,14 +415,14 @@ namespace IRaCIS.Core.Application.Service
//记录日志 //记录日志
downloadJobs.Add(new DownloadJob() downloadJobs.Add(new DownloadJob()
{ {
Name = $"{visitItem.SubjectCode}_{visitItem.VisitNum}_{visitItem.VisitName}_Finished", Name = $"{visitItem.SubjectCode}_{visitItem.VisitNum}_{visitItem.VisitName.Trim()}_Finished",
Action = () => Action = () =>
{ {
DownloadLogger.Write( DownloadLogger.Write(
logFilePath: logFilePath, logFilePath: logFilePath,
subjectCode: visitItem.SubjectCode, subjectCode: visitItem.SubjectCode,
visitNum: visitItem.VisitNum, visitNum: visitItem.VisitNum,
visitName: visitItem.VisitName, visitName: visitItem.VisitName.Trim(),
message: "Success"); message: "Success");
return Task.CompletedTask; return Task.CompletedTask;