Merge branch 'Test_IRC_Net8' of https://gitea.frp.extimaging.com/XCKJ/irc-netcore-api into Test_IRC_Net8

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

@@ -1,14 +1,16 @@
-using System;
-using System.Globalization;
-using System.Threading;
-using System.Threading.Tasks;
+using IRaCIS.Core.Application.Helper.OtherTool;
 using IRaCIS.Core.Domain.BaseModel;
 using IRaCIS.Core.Domain.Share;
 using MassTransit;
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Logging;
-using NPOI.SS.Formula.Functions;
+using Newtonsoft.Json;
+using System;
+using System.Globalization;
+using System.Threading;
+using System.Threading.Tasks;
 
-public class ConsumeExceptionFilter<T>(ILogger<ConsumeExceptionFilter<T>> _logger)  : IFilter<ConsumeContext<T>> where T : DomainEvent
+public class ConsumeExceptionFilter<T>(ILogger<ConsumeExceptionFilter<T>> _logger, IConfiguration _config)  : IFilter<ConsumeContext<T>> where T : DomainEvent
 {
 
     public async Task Send(ConsumeContext<T> context, IPipe<ConsumeContext<T>> next)
@@ -23,6 +25,44 @@ public class ConsumeExceptionFilter<T>(ILogger<ConsumeExceptionFilter<T>> _logge
         {
             var errorInfo = $"Exception: {exception.Message}[{exception.StackTrace}]" + (exception.InnerException != null ? $" InnerException: {exception.InnerException.Message}[{exception.InnerException.StackTrace}]" : "");
             _logger.LogError(errorInfo);
+
+            try
+            {
+                bool isOpenWeComNotice = _config.GetValue<bool>("WeComNoticeConfig:IsOpenWeComNotice");
+
+                if (isOpenWeComNotice)
+                {
+                    string webhook = _config["WeComNoticeConfig:WebhookUrl"] ?? string.Empty;
+
+                    var uri = new Uri(_config["SystemEmailSendConfig:SiteUrl"]);
+                    var baseUrl = uri.GetLeftPart(UriPartial.Authority);
+
+                    var userList = _config.GetSection("WeComNoticeConfig:APINoticeUserList").Get<string[]>();
+
+
+
+                    // 🔔 异步告警（不要阻塞请求）
+                    _ = WeComNotifier.SendAlertAsync(
+                        webhook: webhook,
+                        alert: new WeComAlert
+                        {
+                            Env = baseUrl,
+                            UserName = "MassTransit 自动触发邮件",
+                            Api = "",
+                            Message = $"异常信息:{exception.Message} ",
+                            Stack = exception.StackTrace,
+                            AtUsers = userList ?? []
+                        }
+                    );
+
+                }
+
+
+            }
+            catch (Exception ex)
+            {
+                Log.Logger.Error($"MassTransit里发送企业微信出现错误：{ex.Message}");
+            }
         }
     }
 

IRaCIS.Core.Application/MassTransit/Recurring/IRRecurringConsumer.cs

@@ -37,7 +37,12 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
 
         public async Task Consume(ConsumeContext<UrgentIRUnReadTaskRecurringEvent> context)
         {
-            var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
+            var isEn_US = context.Message.CultureInfoName == StaticData.CultureInfo.en_US;
+
+            //设置当前事件传递过来的语言
+            var culture = context.Message.CultureInfoName;
+            CultureInfo.CurrentCulture = new CultureInfo(culture);
+
             var trialId = context.Message.TrialId;
 
             var trialInfo = await _trialRepository.FirstOrDefaultAsync(t => t.Id == trialId);

IRaCIS.Core.Application/MassTransit/Recurring/QCRecurringEmailConsumer.cs

@@ -7,6 +7,7 @@ using MassTransit.Scheduling;
 using Microsoft.Extensions.Options;
 using System;
 using System.Collections.Generic;
+using System.Globalization;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
@@ -34,7 +35,11 @@ public class QCImageQuestionRecurringEventConsumer(IRepository<Trial> _trialRepo
     {
         var trialId = context.Message.TrialId;
 
-        var isEn_us = false;
+        var isEn_us = context.Message.CultureInfoName == StaticData.CultureInfo.en_US;
+
+        //设置当前事件传递过来的语言
+        var culture = context.Message.CultureInfoName;
+        CultureInfo.CurrentCulture = new CultureInfo(culture);
 
         var trialInfo = await _trialRepository.Where(t => t.Id == trialId).Select(t => new { t.ResearchProgramNo, t.ExperimentName, t.TrialCode, t.TrialStatusStr }).FirstNotNullAsync();
 
@@ -102,7 +107,12 @@ public class CRCImageQuestionRecurringEventConsumer(IRepository<Trial> _trialRep
     {
         var trialId = context.Message.TrialId;
 
-        var isEn_us = false;
+        var isEn_us = context.Message.CultureInfoName == StaticData.CultureInfo.en_US;
+
+        //设置当前事件传递过来的语言
+        var culture = context.Message.CultureInfoName;
+        CultureInfo.CurrentCulture = new CultureInfo(culture);
+
         var trialInfo = await _trialRepository.Where(t => t.Id == trialId).Select(t => new { t.ResearchProgramNo, t.ExperimentName, t.TrialCode, t.TrialStatusStr, t.DeclarationTypeEnumList }).FirstNotNullAsync();
 
         //找到 该项目的IQC 用户Id
@@ -173,7 +183,11 @@ public class ImageQCRecurringEventConsumer(IRepository<Trial> _trialRepository,
     {
         var trialId=context.Message.TrialId;
 
-        var isEn_us = false;
+        var isEn_us = context.Message.CultureInfoName == StaticData.CultureInfo.en_US;
+
+        //设置当前事件传递过来的语言
+        var culture = context.Message.CultureInfoName;
+        CultureInfo.CurrentCulture = new CultureInfo(culture);
 
         var trialInfo = await _trialRepository.Where(t => t.Id == trialId).Select(t => new { t.ResearchProgramNo, t.ExperimentName, t.TrialCode, t.TrialStatusStr }).FirstNotNullAsync();
 

IRaCIS.Core.Application/MassTransit/Recurring/SystemDocumentConsumer.cs

@@ -42,7 +42,12 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
 
             DateTime now = DateTime.Now;
             Console.WriteLine("发送定时过期提醒");
-            var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
+            var isEn_US = context.Message.CultureInfoName == StaticData.CultureInfo.en_US;
+
+            //设置当前事件传递过来的语言
+            var culture = context.Message.CultureInfoName;
+            CultureInfo.CurrentCulture = new CultureInfo(culture);
+
             var systemDocQuery =
             from sysDoc in _systemDocumentRepository.AsQueryable(false)
             from identityUser in _identityUserRepository.AsQueryable(false).Where(t => t.UserRoleList.Where(t => t.IsUserRoleDisabled == false).Any(t => sysDoc.NeedConfirmedUserTypeList.AsQueryable().Any(c => c.NeedConfirmUserTypeId == t.UserTypeId)))
@@ -150,7 +155,11 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
 
         public async Task Consume(ConsumeContext<SystemDocumentPublishEvent> context)
         {
-            var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
+            var isEn_US = context.Message.CultureInfoName == StaticData.CultureInfo.en_US;
+
+            //设置当前事件传递过来的语言
+            var culture = context.Message.CultureInfoName;
+            CultureInfo.CurrentCulture = new CultureInfo(culture);
 
             // 记录是否只发送给新增角色的日志
             if (context.Message.NewUserTypeIds != null && context.Message.NewUserTypeIds.Any())

IRaCIS.Core.Application/MassTransit/Recurring/TrialDocumentConsumer.cs

@@ -53,7 +53,11 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
 
             DateTime now = DateTime.Now;
             Console.WriteLine("发送定时项目过期提醒");
-            var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
+            var isEn_US = context.Message.CultureInfoName == StaticData.CultureInfo.en_US;
+            //设置当前事件传递过来的语言
+            var culture = context.Message.CultureInfoName;
+            CultureInfo.CurrentCulture = new CultureInfo(culture);
+
             var trialDocQuery =
              from trialDoc in _trialDocumentRepository.AsQueryable(true)
  
@@ -177,7 +181,11 @@ namespace IRaCIS.Core.Application.MassTransit.Recurring
 
         public async Task Consume(ConsumeContext<TrialDocumentPublishEvent> context)
         {
-            var isEn_US = CultureInfo.CurrentCulture.Name == StaticData.CultureInfo.en_US;
+            var isEn_US = context.Message.CultureInfoName == StaticData.CultureInfo.en_US;
+
+            //设置当前事件传递过来的语言
+            var culture = context.Message.CultureInfoName;
+            CultureInfo.CurrentCulture = new CultureInfo(culture);
 
             // 记录是否只发送给新增角色的日志
             if (context.Message.NewUserTypeIds != null && context.Message.NewUserTypeIds.Any())