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

IRaCIS.Core.Application/BusinessFilter/LegacyController/ModelActionFilter .cs

@@ -1,18 +1,22 @@
-using Microsoft.AspNetCore.Mvc;
+using IRaCIS.Core.Application.Helper.OtherTool;
+using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.Mvc.Filters;
 using Microsoft.AspNetCore.Mvc.ModelBinding;
 using Microsoft.AspNetCore.Mvc.ModelBinding.Binders;
 using Microsoft.AspNetCore.Mvc.ModelBinding.Metadata;
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Localization;
 using Newtonsoft.Json;
+using System;
 using System.Reflection;
+using static System.Runtime.InteropServices.JavaScript.JSType;
 
 
 namespace IRaCIS.Core.Application.Filter;
 
 
 
-public class ModelActionFilter(IStringLocalizer _localizer) : ActionFilterAttribute, IActionFilter
+public class ModelActionFilter(IStringLocalizer _localizer, IConfiguration _config, IUserInfo _userInfo) : ActionFilterAttribute, IActionFilter
 {
 
 
@@ -27,6 +31,49 @@ public class ModelActionFilter(IStringLocalizer _localizer) : ActionFilterAttrib
                                           .Select(e => e.ErrorMessage)
                                           .ToArray();
 
+            var request = context.HttpContext.Request;
+
+            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:VueNoticeUserList").Get<string[]>();
+
+                    var requestBody = context.HttpContext.Items["RequestBody"] as string;
+
+
+                    // 🔔 异步告警（不要阻塞请求）
+                    _ = WeComNotifier.SendAlertAsync(
+                        webhook: webhook,
+                        alert: new WeComAlert
+                        {
+                            Env = baseUrl,
+                            UserName = _userInfo.UserName.IsNotNullOrEmpty()?   $"{_userInfo.UserName}({_userInfo.UserTypeShortName})":  "匿名",
+                            Api = $"{request.Method} {request.Path}",
+                            Message = $"前端传递参数，后端模型验证失败\n 具体信息：{JsonConvert.SerializeObject(validationErrors)}",
+                            JsonData = requestBody,
+                            AtUsers = userList ?? []
+                        }
+                    );
+
+                }
+
+
+            }
+            catch (Exception ex)
+            {
+                Log.Logger.Error($"模型验证过滤器里发送企业微信出现错误：{ex.Message}");
+            }
+
+           
+
             //---提供给接口的参数无效。
             context.Result = new JsonResult(ResponseOutput.NotOk(_localizer["ModelAction_InvalidAPIParameter"] + JsonConvert.SerializeObject(validationErrors)));
         }

IRaCIS.Core.Application/BusinessFilter/LegacyController/ProjectExceptionFilter.cs

@@ -1,13 +1,16 @@
-using IRaCIS.Core.Domain.Share;
+using IRaCIS.Core.Application.Helper.OtherTool;
+using IRaCIS.Core.Domain.Share;
 using IRaCIS.Core.Infrastructure;
+using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.Mvc.Filters;
+using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Localization;
 using Microsoft.Extensions.Logging;
 
 namespace IRaCIS.Core.Application.Filter;
 
-public class ProjectExceptionFilter(ILogger<ProjectExceptionFilter> _logger, IStringLocalizer _localizer) : Attribute, IExceptionFilter
+public class ProjectExceptionFilter(ILogger<ProjectExceptionFilter> _logger, IStringLocalizer _localizer, IConfiguration _config, IUserInfo _userInfo) : Attribute, IExceptionFilter
 {
 
     public void OnException(ExceptionContext context)
@@ -48,6 +51,43 @@ public class ProjectExceptionFilter(ILogger<ProjectExceptionFilter> _logger, ISt
                 context.Result = new JsonResult(ResponseOutput.NotOk(_localizer["Project_ExceptionContactDeveloper"] + (exception.InnerException is null ? (exception.Message)
                     : (exception.Message + "Inner ExceptionMsg:" + exception.InnerException?.Message)), ApiResponseCodeEnum.ProgramException));
 
+                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[]>();
+
+                        var requestBody = context.HttpContext.Items["RequestBody"] as string;
+
+                        var alert = new WeComAlert
+                        {
+                            Env = baseUrl,
+                            UserName = $"{_userInfo.UserName}({_userInfo.UserTypeShortName})",
+                            Api = context.HttpContext.Request.Path,
+                            Message = exception.Message,
+                            JsonData = requestBody,
+                            Stack = exception.StackTrace,
+                            AtUsers = userList ?? []
+                        };
+
+                        _ = WeComNotifier.SendAlertAsync(webhook, alert);
+                    }
+
+                   
+                }
+                catch (Exception ex)
+                {
+
+                    _logger.LogError($"异常过滤器里发送企业微信出现错误：{ex.Message}");
+                }
+
             }
 
             context.ExceptionHandled = true;//标记当前异常已经被处理过了
@@ -58,6 +98,7 @@ public class ProjectExceptionFilter(ILogger<ProjectExceptionFilter> _logger, ISt
 
             _logger.LogError(errorInfo);
 
+
             //_logger.LogError(exception, exception.Message);
         }
         else

IRaCIS.Core.Application/Helper/OtherTool/WeComNotifier.cs

@@ -0,0 +1,98 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Newtonsoft.Json;
+using RestSharp;
+using System.Net;
+using System.Threading.Tasks;
+using IdentityModel;
+
+namespace IRaCIS.Core.Application.Helper.OtherTool;
+
+
+public class WeComAlert
+{
+    public string Env { get; set; } = "";
+    public string UserName { get; set; } = "";
+    public string Api { get; set; } = "";
+    public string Message { get; set; } = "";
+    public string? JsonData { get; set; }
+    public string? Stack { get; set; }
+    public bool HasStack => !string.IsNullOrWhiteSpace(Stack);
+    public string[] AtUsers { get; set; } = [];
+}
+
+
+
+public static class WeComNotifier
+{
+
+    public static async Task SendAlertAsync(string webhook, WeComAlert alert)
+    {
+        try
+        {
+            var client = new RestClient();
+            var request = new RestRequest(webhook, Method.Post);
+
+            var time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
+
+            // 处理 @
+            var atText = alert.AtUsers != null && alert.AtUsers.Any()
+                ? string.Join("", alert.AtUsers.Select(u => $" <@{u}>"))
+                : "";
+
+            // 处理堆栈
+            var stack = alert.Stack;
+            if (!string.IsNullOrWhiteSpace(stack))
+            {
+                stack = stack.Replace("\n", "\n> ");
+                if (stack.Length > 1200)
+                    stack = stack[..1200] + "...(已截断)";
+            }
+
+            var markdown = $@"## 🚨 系统告警
+> {atText}
+> **部署环境：** [{alert.Env}]({alert.Env})
+> **发生时间：** {time}
+> **操作人：** {alert.UserName}
+> **接口地址：** {alert.Api}
+### ❗ 告警信息
+<font color=""warning"">{alert.Message}</font>";
+
+            if (!string.IsNullOrWhiteSpace(alert.JsonData))
+            {
+                markdown += $@"
+> **📦 请求数据（JSON 格式）：**
+```json
+{alert.JsonData}
+```";
+            }
+
+            if (!string.IsNullOrWhiteSpace(stack))
+            {
+                markdown += $@"
+### 堆栈信息（部分）
+<font color=""comment"">{stack}</font>";
+            }
+
+            var payload = new
+            {
+                msgtype = "markdown",
+                markdown = new { content = markdown }
+            };
+
+            request.AddHeader("Content-Type", "application/json");
+            request.AddStringBody(JsonConvert.SerializeObject(payload), DataFormat.Json);
+
+            await client.ExecuteAsync(request);
+        }
+        catch (Exception ex)
+        {
+            Log.Logger.Error("企业微信告警发送失败: " + ex.Message);
+        }
+    }
+
+}
+

IRaCIS.Core.Application/TestService.cs

@@ -6,6 +6,7 @@ using IRaCIS.Application.Contracts;
 using IRaCIS.Core.Application.BusinessFilter;
 using IRaCIS.Core.Application.Contracts;
 using IRaCIS.Core.Application.Helper;
+using IRaCIS.Core.Application.Helper.OtherTool;
 using IRaCIS.Core.Application.Service.BusinessFilter;
 using IRaCIS.Core.Application.ViewModel;
 using IRaCIS.Core.Domain;
@@ -109,10 +110,13 @@ namespace IRaCIS.Core.Application.Service
 
         //创建一个模型验证的方法
         [AllowAnonymous]
-        [HttpPost]
+        [HttpPost("{email}")]
         public async Task<IResponseOutput> PostModelVerify(ModelVerifyCommand modelVerify)
         {
+            var webhook = "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=cdd97aab-d256-4f07-9145-a0a2b1555322";
+           //await WeComNotifier.SendErrorAsync(webhook, "http://irc.test.extimaging.com/login", new Exception("测试异常"), new[] { "ZhouHang" });
 
+            //throw new Exception("手动测试异常抛出");
             return ResponseOutput.Ok(modelVerify);
 
         }