Compare commits

..

4 Commits

Author SHA1 Message Date
he b7d58e5643 Revert "修改邮件delay 1s 测试"
This reverts commit 7ebd49d4d6.
2026-06-11 10:01:13 +08:00
he 743abd0ce8 Revert "添加日志测试"
This reverts commit f49a9998f2.
2026-06-11 10:01:06 +08:00
he 56e80d4f1a Revert "添加邮件错误日志"
This reverts commit 3776abf5e5.
2026-06-11 10:00:53 +08:00
he be487a346e Revert "日志添加"
This reverts commit 56646d30ba.
2026-06-11 10:00:46 +08:00
4 changed files with 70 additions and 87 deletions

View File

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

View File

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

View File

@ -85,11 +85,6 @@ namespace IRaCIS.Core.Application.Service
IMapper _mapper, IUserInfo _userInfo, IStringLocalizer _localizer, IFusionCache _fusionCache) : BaseService, IReadingImageTaskService 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>
/// 获取报告图表数据 /// 获取报告图表数据
/// </summary> /// </summary>

View File

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