.NET Core实现企业微信消息推送

{ "errcode" : 0, "errmsg" : "ok", "invaliduser" : "userid1|userid2", "invalidparty" : "partyid1|partyid2", "invalidtag": "tagid1|tagid2", "msgid": "xxxx", "response_code": "xyzxyz" }

{ "touser" : "UserID1|UserID2|UserID3", "toparty" : "PartyID1|PartyID2", "totag" : "TagID1 | TagID2", "msgtype" : "text", "agentid" : 1, "text" : { "content" : "你的快递已到，请携带工卡前往邮件中心领取。\n出发前可查看邮件中心视频实况，聪明避开排队。" }, "safe":0, "enable_id_trans": 0, "enable_duplicate_check": 0, "duplicate_check_interval": 1800 }

 "Wx": { "Baseurl": "https://qyapi.weixin.qq.com/cgi-bin/", "TokenUrl": "gettoken?corpid=xx&corpsecret=xx", "PushUrl": "message/send?access_token={0}" },

        public void ConfigureServices(IServiceCollection services) { services.AddHttpClient("WxClient", config => { config.BaseAddress = new Uri(Configuration["Wx:baseurl"]); config.DefaultRequestHeaders.Add("Accept", "application/json"); }); GlobalContext.Configuration = Configuration; } public void Configure(IApplicationBuilder app, IWebHostEnvironment env) { GlobalContext.HttpClientFactory = app.ApplicationServices.GetService(); }

    public class GetTokenResult { /// 
 /// 错误编号 /// 
 public int errcode { get; set; } /// 
 /// 错误信息 /// 
 public string errmsg { get; set; } /// 
 /// Token /// 
 public string access_token { get; set; } /// 
 /// 过期时间 /// 
 public int expires_in { get; set; } }

using Microsoft.Extensions.Configuration; using Newtonsoft.Json; using System; using System.Collections.Generic; using System.Linq; using System.Net.Http; using System.Text; using System.Threading.Tasks; namespace TaskScheduling.Wx { public class GlobalContext { public static IConfiguration Configuration { get; set; } public static IHttpClientFactory HttpClientFactory { get; set; } /// 
 /// 过期时间 /// 
 public static DateTime TimeOutDate { get; set; } /// 
 /// Token /// 
 public static string Token { get; set; } /// 
 /// 获取Token /// 
 /// Item1 Token;Item2 是否成功 public static Tuple GetToken() { //判断Token是否存在 以及Token是否在有效期内 if (string.IsNullOrEmpty(Token) || TimeOutDate > DateTime.Now) { //构造请求链接 var requestBuild = Configuration["Wx:TokenUrl"]; using (var wxClient = HttpClientFactory.CreateClient("WxClient")) { var httpResponse = wxClient.GetAsync(requestBuild).Result; var dynamic = JsonConvert.DeserializeObject( httpResponse.Content.ReadAsStringAsync().Result ); if (dynamic.errcode == 0) { Token = dynamic.access_token; //过期5分钟前刷新Token var expires_in = Convert.ToDouble(dynamic.expires_in - 5 * 60); TimeOutDate = DateTime.Now.AddSeconds(expires_in); return Tuple.Create(Token, true); } else { return Tuple.Create($"获取Token失败，错误：{ dynamic.errmsg}", false); } } } else { return Tuple.Create(Token, true); } } /// 
 /// 推送MES /// 
 /// Item1 Token;Item2 是否成功 public static string WxPush(string content) { //构造请求链接 var requestBuild = Configuration["Wx:PushUrl"]; var (token, issuccess) = GetToken(); if (!issuccess) throw new Exception(token); requestBuild = string.Format(requestBuild, token); //建立HttpClient using (var wxClient = HttpClientFactory.CreateClient("WxClient")) { byte[] data = Encoding.UTF8.GetBytes(content); var bytearray = new ByteArrayContent(data); var httpResponse = wxClient.PostAsync(requestBuild, bytearray).Result; var dynamic = JsonConvert.DeserializeObject( httpResponse.Content.ReadAsStringAsync().Result ); if (dynamic.errcode == 0) return "推送成功！"; else throw new Exception($"推送失败,原因:{JsonConvert.SerializeObject(dynamic) }"); } } /// 
 /// 获取发送内容 /// 
 ///  ///  ///  public static string GetContent(string userId, string msg) { var objText = new { content = msg }; string text = JsonConvert.SerializeObject(objText); var obj = new { touser = userId, toparty = "", totag = "", msgtype = "text", agentid = 1000051,//应用id text = objText, safe = 0, enable_id_trans = 0, enable_duplicate_check = 0, duplicate_check_interval = 1800 }; string strJson = JsonConvert.SerializeObject(obj); return strJson; } } }

string userid = "userid"; var content1 = GlobalContext.GetContent(userid, "推送测试"); return GlobalContext.WxPush(content1);