修改影像接收设置失败标志

IRC.Core.SCP/Service/CStoreSCPService.cs

@@ -47,8 +47,6 @@ namespace IRaCIS.Core.SCP.Service
 
         private List<Guid> _SCPStudyIdList => _ImageUploadList.Where(t => t.SCPStudyId != Guid.Empty).Select(t => t.SCPStudyId).ToList();
 
-
-
         private List<ImageUploadInfo> _ImageUploadList { get; set; } = new List<ImageUploadInfo>();
 
         private SCPImageUpload _upload { get; set; }
@@ -246,23 +244,25 @@ namespace IRaCIS.Core.SCP.Service
 
         public async void OnConnectionClosed(Exception exception)
         {
+            var _studyRepository = _serviceProvider.GetService<IRepository<SCPStudy>>();
+
             /* nothing to do here */
 
             //奇怪的bug  上传的时候，用王捷修改的影像，会关闭，重新连接，导致检查id 丢失，然后状态不一致
             if (exception == null)
             {
-                var _studyRepository = _serviceProvider.GetService<IRepository<SCPStudy>>();
                 //将检查设置为传输结束
-                await _studyRepository.BatchUpdateNoTrackingAsync(t => _SCPStudyIdList.Contains(t.Id), u => new SCPStudy() { IsUploadFinished = true });
+                await _studyRepository.BatchUpdateNoTrackingAsync(t => _SCPStudyIdList.Contains(t.Id), u => new SCPStudy() { IsUploadFinished = true, IsUploadFaild = false });
 
-                await _studyRepository.SaveChangesAndClearAllTrackingAsync();             
             }
             else
             {
+                await _studyRepository.BatchUpdateNoTrackingAsync(t => _SCPStudyIdList.Contains(t.Id), u => new SCPStudy() { IsUploadFinished = true, IsUploadFaild = true });
                 //记录日志
                 await AddUploadLogAsync();
             }
 
+            await _studyRepository.SaveChangesAndClearAllTrackingAsync();
 
 
             Log.Logger.Warning($"连接关闭 {exception?.Message} {exception?.InnerException?.Message}");
@@ -400,7 +400,7 @@ namespace IRaCIS.Core.SCP.Service
             {
                 try
                 {
-                    var scpStudyId = await dicomArchiveService.ArchiveDicomFileAsync(request.File , storeRelativePath, Association.CallingAE, Association.CalledAE, fileSize);
+                    var scpStudyId = await dicomArchiveService.ArchiveDicomFileAsync(request.File, storeRelativePath, Association.CallingAE, Association.CalledAE, fileSize);
 
                     var series = await _seriesRepository.FirstOrDefaultAsync(t => t.Id == seriesId);
 

IRaCIS.Core.Domain/Image/SCPStudy.cs

@@ -66,7 +66,7 @@ public class SCPStudy : BaseFullDeleteAuditEntity, IEntitySeqId
 
     public bool IsUploadFinished { get; set; }
 
-
+    public bool IsUploadFaild { get; set; }
 
     #region HIR 注释
     //public Guid TrialId { get; set; }

IRaCIS.Core.Infra.EFCore/Migrations/20250919084625_modifyUploadFailed.cs

@@ -0,0 +1,29 @@
+using Microsoft.EntityFrameworkCore.Migrations;
+
+#nullable disable
+
+namespace IRaCIS.Core.Infra.EFCore.Migrations
+{
+    /// <inheritdoc />
+    public partial class modifyUploadFailed : Migration
+    {
+        /// <inheritdoc />
+        protected override void Up(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.AddColumn<bool>(
+                name: "IsUploadFaild",
+                table: "SCPStudy",
+                type: "bit",
+                nullable: false,
+                defaultValue: false);
+        }
+
+        /// <inheritdoc />
+        protected override void Down(MigrationBuilder migrationBuilder)
+        {
+            migrationBuilder.DropColumn(
+                name: "IsUploadFaild",
+                table: "SCPStudy");
+        }
+    }
+}

IRaCIS.Core.Infra.EFCore/Migrations/IRaCISDBContextModelSnapshot.cs

@@ -8190,6 +8190,9 @@ namespace IRaCIS.Core.Infra.EFCore.Migrations
                     b.Property<bool>("IsDeleted")
                         .HasColumnType("bit");
 
+                    b.Property<bool>("IsUploadFaild")
+                        .HasColumnType("bit");
+
                     b.Property<bool>("IsUploadFinished")
                         .HasColumnType("bit");