net core WebApi——尝试企业微信内部应用
程序员文章站
2023-11-24 18:43:28
@[toc] 前言 这几天忙活着别的东西，耽误了很长时间，从文件操作完了之后就在考虑着下一步鼓捣点儿啥，因为最开始的业务开发就是企业微信相关的，这刚好来做个内部应用的小例子玩玩。 企业微信 前身是企业号，当时微信主推的还是公众号与服务号，后续战略考虑到企业的OA了（当然还是跟某个抢市场），企业号应该 ......
目录
@
前言
这几天忙活着别的东西，耽误了很长时间，从文件操作完了之后就在考虑着下一步鼓捣点儿啥，因为最开始的业务开发就是企业微信相关的，这刚好来做个内部应用的小例子玩玩。
企业微信
前身是企业号，当时微信主推的还是公众号与服务号，后续战略考虑到企业的oa了（当然还是跟某个抢市场），企业号应该是在16年还是具体啥时候出的，刚出的时候也是问题不断一直在修复更新，最近这两年基本上没咋关注企业微信了，也都是偶尔上去看看有没有新东西啊什么的，不过不得不说，在这几年的成长中已经修复逐渐成为一个不错的产品了（大厂的效率还是有的），相对于公众号的开发，为什么我选这个作为例子呢，因为企业微信我可以通过个人来使用（注册的早，现在不清楚注册流程，主要看是否需要企业认证），个人开发者在不论啥时候啥平台都或多或少有些不友好（当然，认证了说明你是个好人，为了信息安全，都懂）。
开始
注册企业微信的流程我就不多说了，直接说注册完成之后，我们来看下这个界面，标注的就是我们需要的关键参数。
记好这个东西之后，我们转到应用管理。
这个创建就是你添张图片打个名字而已，不多说，创建完成之后我们来看下图的标记。
记好这两个参数，ok，下来我们就来看api吧，这里我只是介绍下消息推送。
微信等相关的第三方开发大致流程都类似，如下：
- 注册账号（这不废话么）
- 账号认证（为了权限，当然企业微信内部应用不需要）
- 服务域名确定好
- appid、secret等等的配置（为了accesstoken）
- 几乎所有的接口都是先获取accesstoken，相当于你在微信的登录
- 根据接口文档来传参啊获取回调啊获取事件等等
- 根据返回值来看看错误信息
我这里不做服务端，只是写个示例，需要服务端什么的开发之类的可以给我联系，互相学习。
首先，在我们的util新建一个类qythirdutil（名字感觉起的好没水平，玩游戏止于起名字，别人都10级了，我还在想名字），先把我们需要的配置信息搞了。
private static string _corpid = string.empty;
private static string _secret = string.empty;
private static string _agentid = string.empty;
/// <summary>
/// 企业微信id
/// </summary>
public static string corpid
{
get
{
if (string.isnullorempty(_corpid))
{
_corpid = aprilconfig.configuration["qythird:corpid"];
}
return _corpid;
}
}
/// <summary>
/// 企业微信应用秘钥
/// </summary>
public static string secret
{
get
{
if (string.isnullorempty(_secret))
{
_secret = aprilconfig.configuration["qythird:secret"];
}
return _secret;
}
}
/// <summary>
/// 企业微信应用id
/// </summary>
public static string agentid
{
get
{
if (string.isnullorempty(_secret))
{
_agentid = aprilconfig.configuration["qythird:agentid"];
}
return _agentid;
}
}
然后我们来划分下方法，我们需要获取accesstoken，需要执行发送消息的方法。
/// <summary>
/// 获取accesstoken
/// </summary>
/// <returns></returns>
public static string getaccesstoken()
{
qyaccesstoken accesstoken = null;
bool isget = false;
if (cacheutil.exists("qyaccesstoken"))
{
accesstoken = cacheutil.get<qyaccesstoken>("qyaccesstoken");
if (accesstoken.expire_time >= datetime.now.addminutes(1))
{
isget = true;
}
}
if (!isget)
{
string url = $"https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={corpid}&corpsecret={secret}";
//请求获取
string res = requestutil.httpget(url);
accesstoken = jsonconvert.deserializeobject<qyaccesstoken>(res);
if (accesstoken != null && accesstoken.errcode == 0)
{
accesstoken.expire_time = datetime.now.addseconds(accesstoken.expires_in);
cacheutil.set("qyaccesstoken", accesstoken, new timespan(2, 0, 0));
}
else
{
logutil.error($"获取accesstoken失败——{accesstoken.errcode},{accesstoken.errmsg}");
}
}
return accesstoken.access_token;
}
这里用到了两个地方，一个是微信端回调的对象实例qyaccesstoken，需要的朋友可以在源码里cv，我这里就不贴出来了。
另一个是httpclient的简单封装请求方法requestutil，看了有些博客说httpclient的生命周期之类的，有推荐直接实例化一个私有静态的，也有做工厂模式创建的，没细究，这块儿要多注意下。
public class requestutil
{
/// <summary>
/// 发起post同步请求
/// </summary>
/// <param name="url">请求地址</param>
/// <param name="postdata">请求数据</param>
/// <param name="contenttype">数据类型</param>
/// <param name="timeout">超时时间</param>
/// <returns></returns>
public static string httppost(string url, string postdata = null, string contenttype = null, int timeout = 30)
{
if (string.isnullorempty(postdata))
{
postdata = "";
}
using (httpclient client = new httpclient())
{
client.timeout = new timespan(0, 0, timeout);
using (httpcontent httpcontent = new stringcontent(postdata, encoding.utf8))
{
if (contenttype != null)
httpcontent.headers.contenttype = new system.net.http.headers.mediatypeheadervalue(contenttype);
httpresponsemessage response = client.postasync(url, httpcontent).result;
return response.content.readasstringasync().result;
}
}
}
/// <summary>
/// 发起post异步请求
/// </summary>
/// <param name="url">请求地址</param>
/// <param name="postdata">请求数据</param>
/// <param name="contenttype">数据类型</param>
/// <param name="timeout">超时时间</param>
/// <returns></returns>
public static async task<string> httppostasync(string url, string postdata = null, string contenttype = null, int timeout = 30)
{
if (string.isnullorempty(postdata))
{
postdata = "";
}
using (httpclient client = new httpclient())
{
client.timeout = new timespan(0, 0, timeout);
using (httpcontent httpcontent = new stringcontent(postdata, encoding.utf8))
{
if (contenttype != null)
httpcontent.headers.contenttype = new system.net.http.headers.mediatypeheadervalue(contenttype);
httpresponsemessage response = await client.postasync(url, httpcontent);
return await response.content.readasstringasync();
}
}
}
/// <summary>
/// 发起get同步请求
/// </summary>
/// <param name="url">请求地址</param>
/// <returns></returns>
public static string httpget(string url)
{
using (httpclient client = new httpclient())
{
return client.getstringasync(url).result;
}
}
/// <summary>
/// 发起get异步请求
/// </summary>
/// <param name="url">请求地址</param>
/// <returns></returns>
public static async task<string> httpgetasync(string url)
{
using (httpclient client = new httpclient())
{
httpresponsemessage response = await client.getasync(url);
return await response.content.readasstringasync();
}
}
}
然后我们来写个发送消息的方法sendmessage，这里我只写了下普通文本推送。
/// <summary>
/// 消息推送
/// </summary>
/// <param name="content">文本内容</param>
/// <param name="range">推送范围</param>
/// <param name="messagetype">消息类型</param>
/// <returns></returns>
public static bool sendmessage(string content, messagerange range, aprilenums.messagetype messagetype)
{
bool issend = false;
if (string.isnullorempty(content) || content.length > 2048 || range==null)
{
return false;
}
string accesstoken = getaccesstoken();
if (string.isnullorempty(accesstoken))
{
return false;
}
string url = $"https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={accesstoken}";
stringbuilder data = new stringbuilder();
bool isvaildrange = false;
if (range.isall)
{
data.append($"\"touser\":\"@all\"");
isvaildrange = true;
}
else
{
if (range.users != null && range.users.count > 0)
{
data.appendformat("\"touser\" : {0}", getrangevalue(range.users));
isvaildrange = true;
}
if (range.tags != null && range.tags.count > 0)
{
if (data.length > 0)
{
data.append(",");
}
data.appendformat("\"totag\" : {0}", getrangevalue(range.tags));
isvaildrange = true;
}
if (range.departments != null && range.departments.count > 0)
{
if (data.length > 0)
{
data.append(",");
}
data.appendformat("\"totag\" : {0}", getrangevalue(range.departments));
isvaildrange = true;
}
}
if (!isvaildrange)
{
//没有发送范围
return false;
}
data.appendformat(",\"msgtype\":\"{0}\"", getmessagetype(messagetype));
data.appendformat(",\"agentid\":\"{0}\"", agentid);
data.append(",\"text\": {");
data.appendformat("\"content\":\"{0}\"", content);
data.insert(0, "{");
data.append("}}");
logutil.debug($"获取到发送消息请求：{data.tostring()}");
string res = requestutil.httppost(url, data.tostring(), "application/json");
logutil.debug($"获取到发送消息回调：{res}");
return false;
}
简单说下消息推送，第一个就是你的推送类型，是普通文本还是啥（文档都有，我这净扯淡），然后就是你的范围，再然后就是你的推送内容了，当然根据不同的推送类型你的内容参数也不同，需要进一步封装的朋友可以去看下api。
测试
我们在控制器中（不再说values了）加上消息推送的测试，这里的范围可以在你自己的通讯录中查看。
[httpget]
public actionresult<ienumerable<string>> get()
{
//…
messagerange range = new messagerange();
range.users = new list<string>();
range.users.add("10001");
qythridutil.sendmessage("我就是来测试", range, aprilenums.messagetype.text);
//…
}
小结
写到这里基本上都结束了，为什么我特意拿出来企业微信的内部应用来写这篇呢，其实是做下这个消息推送，以后的自己的工程就可以写个这个然后做异常警告之类的东西，这样想想这篇就不是废话了，编程的奇淫技巧（咳咳，乐趣，乐趣）就在于此，代码自己敲，东西自己组，全在于你自己怎么玩了。