新增企业微信通知

ZR.Admin.WebApi/Middleware/GlobalExceptionMiddleware.cs

@@ -10,6 +10,7 @@ using System.Text.Encodings.Web;
 using System.Text.Json;
 using System.Threading.Tasks;
 using ZR.Admin.WebApi.Extensions;
+using ZR.Common;
 using ZR.Model.System;
 using ZR.Service.System.IService;
 
@@ -119,7 +120,7 @@ namespace ZR.Admin.WebApi.Middleware
             Logger.Log(ei);
             context.Response.ContentType = "text/json;charset=utf-8";
             await context.Response.WriteAsync(responseResult, System.Text.Encoding.UTF8);
-
+            WxNoticeHelper.SendMsg("系统出错", sysOperLog.errorMsg);
             SysOperLogService.InsertOperlog(sysOperLog);
         }
 

ZR.Admin.WebApi/appsettings.json

@@ -32,6 +32,13 @@
     "bucketName": "bucketName",
     "domainUrl": "http://xxx.xxx.com" //访问资源域名
   },
+  //企业微信通知配置
+  "WxCorp": {
+    "AgentID": "",
+    "CorpID": "",
+    "CorpSecret": "",
+    "SendUser": "@all"
+  },
   "gen": {
     "conn": "Data Source=LAPTOP-STKF2M8H\\SQLEXPRESS;User ID=sa;Password=zradmin123;Initial Catalog=ZrAdmin;Integrated Security=SSPI",
     "dbType": 1, //MySql = 0, SqlServer = 1

ZR.Common/WxNoticeHelper.cs

@@ -0,0 +1,157 @@
+using Infrastructure;
+using System.Collections.Generic;
+using System.Text.Json;
+
+namespace ZR.Common
+{
+    public class WxNoticeHelper
+    {
+        //CorpID  企业ID 
+        //AGENTID 应用的ID
+        //Secret 应用的ID对应的密钥
+        private static readonly string AGENTID = AppSettings.App(new string[] { "WxCorp", "AgentID" });
+        private static readonly string CORPID = AppSettings.App(new string[] { "WxCorp", "CorpID" });
+        private static readonly string CORPSECRET = AppSettings.App(new string[] { "WxCorp", "CorpSecret" });
+        private static readonly string SEND_USER = AppSettings.App(new string[] { "WxCorp", "SendUser" });
+        private static readonly string SendUrl = "https://qyapi.weixin.qq.com/cgi-bin/message/send";
+        private static readonly string GetTokenUrl = "https://qyapi.weixin.qq.com/cgi-bin/gettoken";
+
+        /// <summary>
+        /// 消息类型
+        /// </summary>
+        public enum MsgType { markdown, text, textcard, interactive_taskcard }
+
+        /// <summary>
+        /// 发送消息公共模板方法
+        /// </summary>
+        /// <param name="toUser">微信微信好友id，默认@all发给所有关注该应用的用户</param>
+        /// <param name="title">标题</param>
+        /// <param name="content">内容</param>
+        /// <param name="msgType">消息类型</param>
+        /// <returns></returns>
+        public static (int, string) SendMsg(string title, string content, string toUser = "", MsgType msgType = MsgType.text)
+        {
+            if (string.IsNullOrEmpty(toUser))
+            {
+                toUser = SEND_USER;
+            }
+            if (string.IsNullOrEmpty(title))
+            {
+                return (0, "title不能为空");
+            }
+            if (string.IsNullOrEmpty(CORPID))
+            {
+                return (0, "请完成企业微信通知配置");
+            }
+            GetTokenResult tokenResult = GetAccessToken();
+
+            if (tokenResult == null || tokenResult.errcode != 0)
+            {
+                return (0, tokenResult?.errmsg);
+            }
+
+            Dictionary<string, object> dic = null;
+            switch (msgType)
+            {
+                case MsgType.markdown:
+                    dic = GetMarkdown(title, content, toUser);
+                    break;
+                case MsgType.text:
+                    dic = GetText(title, content, toUser);
+                    break;
+                case MsgType.textcard:
+                    break;
+                case MsgType.interactive_taskcard:
+                    break;
+                default:
+                    dic = GetText(title, content, toUser);
+                    break;
+            }
+            string postData = JsonSerializer.Serialize(dic);
+            string msgUrl = $"{SendUrl}?access_token={tokenResult.access_token}";
+
+            //返回结果
+            //{"errcode":0,"errmsg":"ok","invaliduser":""}
+            string msgResult = HttpHelper.HttpPost(msgUrl, postData, "contentType/json");
+            GetTokenResult getTokenResult = JsonSerializer.Deserialize<GetTokenResult>(msgResult);
+
+            return (getTokenResult?.errcode == 0 ? 100 : 0, getTokenResult?.errmsg);
+        }
+        public static (int, string) SendMsg(string title, string content, string toUser)
+        {
+            return SendMsg(title, content, toUser, MsgType.markdown);
+        }
+
+        /// <summary>
+        /// 获取访问token
+        /// </summary>
+        /// <returns>           
+        /// {"errcode":0,"errmsg":"ok","access_token":"iCbcfE1OjfRhV0_io-CzqTNC0lnrudeW3oF5rhJKfmINaxLClLa1FoqAY_wEXtodYh_DTnrtAwZfzeb-NRXvwiOoqUTHx3i6QKLYcfBtF8y-xd5mvaeaf3e9mvTAPhmX0lkm1cLTwRLmoa1IwzgQ-QZEZcuIcntWdEMGseVYok3BwCGpC87bt6nNdgnekZdFVRp1uuaxoctDGlXpoQlQsA","expires_in":7200}
+        /// </returns>
+        private static GetTokenResult GetAccessToken()
+        {
+            string getTokenUrl = $"{GetTokenUrl}?corpid={CORPID}&corpsecret={CORPSECRET}";
+            string getTokenResult = HttpHelper.HttpGet(getTokenUrl);
+
+            GetTokenResult tokenResult = JsonSerializer.Deserialize<GetTokenResult>(getTokenResult);
+            return tokenResult;
+        }
+
+        /// <summary>
+        /// 发送text
+        /// </summary>
+        /// <param name="title"></param>
+        /// <param name="content"></param>
+        /// <param name="toUser"></param>
+        /// <returns></returns>
+        private static Dictionary<string, object> GetText(string title, string content, string toUser = "")
+        {
+            Dictionary<string, object> dic = new()
+            {
+                    { "msgtype", "text" },
+                    { "touser", toUser },
+                    { "agentid", AGENTID },
+                    { "text", new Dictionary<string, string>
+                    {
+                        { "content",$"{title}\n\n{content}"
+                    }
+                }}
+                };
+            return dic;
+        }
+
+        /// <summary>
+        /// 发送markdown
+        /// </summary>
+        /// <param name="title">要发送的标题</param>
+        /// <param name="content">发送的内容</param>
+        /// <param name="toUser">指定接收消息的成员，成员ID列表（多个接收者用‘|’分隔，最多支持1000个）。 特殊情况：指定为”@all”，则向该企业应用的全部成员发送</param>
+        /// <returns></returns>
+        private static Dictionary<string, object> GetMarkdown(string title, string content, string toUser = "")
+        {
+            Dictionary<string, object> dic = new()
+            {
+                    { "touser", toUser },
+                    { "msgtype", "markdown" },
+                    { "agentid", AGENTID },
+                    { "enable_duplicate_check",1}
+                };
+
+            dic.Add("markdown", new Dictionary<string, string>
+                {
+                    { "content", $"**{title}**\n\n{content}" }
+                });
+            return dic;
+        }
+
+        public class GetTokenResult
+        {
+            /// <summary>
+            /// 0、正常
+            /// </summary>
+            public int errcode { get; set; }
+            public string errmsg { get; set; }
+            public string access_token { get; set; }
+        }
+    }
+}

ZR.Tasks/TaskScheduler/JobBase.cs

@@ -4,6 +4,7 @@ using Quartz;
 using System;
 using System.Diagnostics;
 using System.Threading.Tasks;
+using ZR.Common;
 using ZR.Model.System;
 using ZR.Service.System.IService;
 
@@ -47,6 +48,7 @@ namespace ZR.Tasks
                 };
                 status = 1;
                 logMsg = $"Job Run Fail，Exception：{ex.Message}";
+                WxNoticeHelper.SendMsg("任务执行出错", logMsg);
             }
 
             var logModel = new SysTasksLog()