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"; /// /// 消息类型 /// public enum MsgType { markdown, text, textcard, interactive_taskcard } /// /// 发送消息公共模板方法 /// /// 微信微信好友id,默认@all发给所有关注该应用的用户 /// 标题 /// 内容 /// 消息类型 /// 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 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(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); } /// /// 获取访问token /// /// /// {"errcode":0,"errmsg":"ok","access_token":"iCbcfE1OjfRhV0_io-CzqTNC0lnrudeW3oF5rhJKfmINaxLClLa1FoqAY_wEXtodYh_DTnrtAwZfzeb-NRXvwiOoqUTHx3i6QKLYcfBtF8y-xd5mvaeaf3e9mvTAPhmX0lkm1cLTwRLmoa1IwzgQ-QZEZcuIcntWdEMGseVYok3BwCGpC87bt6nNdgnekZdFVRp1uuaxoctDGlXpoQlQsA","expires_in":7200} /// private static GetTokenResult GetAccessToken() { string getTokenUrl = $"{GetTokenUrl}?corpid={CORPID}&corpsecret={CORPSECRET}"; string getTokenResult = HttpHelper.HttpGet(getTokenUrl); GetTokenResult tokenResult = JsonSerializer.Deserialize(getTokenResult); return tokenResult; } /// /// 发送text /// /// /// /// /// private static Dictionary GetText(string title, string content, string toUser = "") { Dictionary dic = new() { { "msgtype", "text" }, { "touser", toUser }, { "agentid", AGENTID }, { "text", new Dictionary { { "content",$"{title}\n\n{content}" } }} }; return dic; } /// /// 发送markdown /// /// 要发送的标题 /// 发送的内容 /// 指定接收消息的成员,成员ID列表(多个接收者用‘|’分隔,最多支持1000个)。 特殊情况:指定为”@all”,则向该企业应用的全部成员发送 /// private static Dictionary GetMarkdown(string title, string content, string toUser = "") { Dictionary dic = new() { { "touser", toUser }, { "msgtype", "markdown" }, { "agentid", AGENTID }, { "enable_duplicate_check",1} }; dic.Add("markdown", new Dictionary { { "content", $"**{title}**\n\n{content}" } }); return dic; } public class GetTokenResult { /// /// 0、正常 /// public int errcode { get; set; } public string errmsg { get; set; } public string access_token { get; set; } } } }