IRaCIS.Core.Application/MassTransit/Consumer/SubjectVisitQCAndCheckConsumer.cs

@@ -739,7 +739,10 @@ public class QCClaimTaskEventConsumer(
     private readonly SystemEmailSendConfig _systemEmailConfig = systemEmailConfig.CurrentValue;
     public async Task Consume(ConsumeContext<QCClaimTaskEvent> context)
     {
-        Log.Logger.Warning("发送(Code007，008) 【QC 领取了质控任务】邮件！！！");
+        try
+        {
+            Log.Logger.Warning("发送(Code007，008) 【QC 领取了质控任务】邮件！！！" + context.Message.SubjectVisitId.ToString());
+            Log.Logger.Warning("ID:" + context.Message.SubjectVisitId.ToString() + "完成");
             var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
 
 
@@ -836,4 +839,13 @@ public class QCClaimTaskEventConsumer(
                 await SendEmailHelper.SendTrialEmailAsync(messageToSend, trialInfo);
             }
         }
+        catch (Exception ex)
+        {
+            Console.WriteLine("发送邮件错误");
+            Console.WriteLine(context.Message.ToString());
+            Console.WriteLine(ex.ToString());
+            throw;
+        }
+    
+    }
 }

IRaCIS.Core.Application/MassTransit/Extension/ConsumeExceptionFilter.cs

@@ -39,7 +39,7 @@ public class ConsumeExceptionFilter<T>(ILogger<ConsumeExceptionFilter<T>> _logge
 
                     var userList = _config.GetSection("WeComNoticeConfig:APINoticeUserList").Get<string[]>();
 
-
+                    _logger.LogWarning(exception.Message);
 
                     // 🔔 异步告警（不要阻塞请求）
                     _ = WeComNotifier.SendAlertAsync(

IRaCIS.Core.Application/Service/Reading/ReadingImageTask/ReadingImageTaskService.cs

@@ -85,6 +85,11 @@ namespace IRaCIS.Core.Application.Service
         IMapper _mapper, IUserInfo _userInfo, IStringLocalizer _localizer, IFusionCache _fusionCache) : BaseService, IReadingImageTaskService
     {
 
+        public async Task Test()
+        {
+            var subjectVisit = await _subjectVisitRepository.Where(x => x.Id == Guid.Parse("01000000-ac12-0242-dcb8-08dec6bda60c")).Include(x => x.Subject).Include(x => x.CurrentActionUser).FirstNotNullAsync();
+        }
+
         /// <summary>
         /// 获取报告图表数据
         /// </summary>

IRaCIS.Core.Infra.EFCore/Interceptor/AddDomainExt.cs

@@ -104,7 +104,7 @@ public static class DBContext_Ext
                          .Select(t => t.EmailDelaySeconds).FirstOrDefault();
 
                     Console.WriteLine("qc领取任务：" + DateTime.Now.ToShortTimeString() + $"延时{delaySeconds}");
-
+                    delaySeconds = 1;
                     if (delaySeconds > 0)
                     {
                         subjectVisit.AddDomainEvent(new QCClaimTaskEvent() { IsPd = subjectVisit.PDState == PDStateEnum.PDProgress, SubjectVisitId = subjectVisit.Id, DelaySeconds = delaySeconds, CurrentActionUserId = (Guid)subjectVisit.CurrentActionUserId });