企业微信-内部应用回调服务的应用与实现

-# 企业微信-内部应用回调服务的应用与实现
第一章 域名与ip白名单
第二章 api的调用与实现
第三章 回调服务的应用与实现

---

  

---

前言

哈喽！之前我们聊了api的手动调用这章我们来聊聊回调服务。
起首什么是企业微信的回调服务？还是拿企业成员来聊吧（这个相对简朴）。
比如有成员离职然后咱们内部系统中有资源属于他，是一定要做资源转交或者迁移的。
做迁移时系统需要知道迁移谁的数据，这里逻辑层面上有两种方式：
1、定时任务-每秒访问一次通讯录有成员变动就执行迁移。
2、回调模式-开一个接口让企业微信调用来告诉你成员变得信息。企微回调服务入口
由于企业微信有回调模式因此本人极力不保举定时任务方案，但回调服务也有丢失消息的弊端。
下一章我将介绍怎样利用利用RabiitMQ使其回调消息不丢失，有爱好的朋友可以看一下。
（个人学习利用并不全面，如有错误欢迎指正。绝对听劝！）

---

一、配置回调服务

1.配置回调服务入口：

2.配置前：

上图中第一个空填后端服务中要担当企业微信消息的接口路径。（第二节重点讲解）
Token和EncodingAESKey随机获取即可，不过获取后要和后端的解析代码对应。
注意红框中的消息类型，如果不勾选这一类的消息不会做回调。
3.配置后

这里的回调服务器不一定要域名，用ip加端口也一样能回调乐成，配置乐成页面请看下图：

建议获取Token和EncodingAESKey后就立即配置到后端的配置文件中。
当服务部署到服务器后在复制配置文件中的内容到该页面即可。
想要乐成配置需要完成本章第三节，并且把服务部署到服务器上才行！！！！！！！！！！
二、解密工具

企业微信的回调需要AES加解密
可以看企业微信的官方接口加解密方案阐明，固然不用看懂，会用就行了。
本章主要用java语言做后端服务的开发，因此主要看java的AES加解密，这是企业微信提供的Java版加解密工具 JavaAES加解密工具包
正式在项目中利用可以按我这个目录存放

加解密工具利用实现

主要是看WXBizMsgCrypt的VerifyURL或者DecryptMsg方法。
起首我们需要new一个WXBizMsgCrypt的实例，必须有三个入参：
参数形貌token配置消息服务器时随机生成的TokenencodingAesKey配置消息服务器时随机生成的EncodingAESKeyreceiveid在内部应用开发中这里填corpId就可以了

1.         WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(callBackToken, callBackEncodingAESKey, corpId);

复制代码

当我们有wxcpt 这个实例后可以调用VerifyURL方法或者DecryptMsg来解密
这个两个方法的公共参数如下：
参数形貌msgSignature加密签名由企业微信回调时提供timestamp时间戳同上由企业微信回调时提供nonce随机数戳同上由企业微信回调时提供 VerifyURL方法在上面三个参数的环境下还需要传入echoStr参数，代码如下：

1.         //echoStr加密密文，只有在配置回调服务时企业微信会发一段密文让你解析，这个密文就是放到这个参数里的。
2.         //一般解密成功后就直接将结果return就行了。
3.         wxcpt.VerifyURL(msgSignature, timestamp, nonce, echoStr);

复制代码

DecryptMsg方法将echoStr参数替换为xml解密后得到明文xml，代码如下：

1.         //xml也是企业微信回调时穿过来的密文xml
2.         String plainXml = wxcpt.DecryptMsg(msgSignature, timestamp, nonce, xml);

复制代码

解密工具可以不用研究的很透彻，会用就行。深究伤脑！！！
三、回调接口编写

1.环境版本

   JDK：17.0.12
mavem：3.6.3
spring-boot：3.3.3
  2.引入库

利用lombok来简化实体类的代码
jaxb-api和jaxb-core以及jaxb-runtime用于解析企微回调的名为xml数据

1.         <dependency>
2.             <groupId>org.projectlombok</groupId>
3.             <artifactId>lombok</artifactId>
4.             <optional>true</optional>
5.         </dependency>
6.         <!--xml解析工具-->
7.         <dependency>
8.             <groupId>javax.xml.bind</groupId>
9.             <artifactId>jaxb-api</artifactId>
10.             <version>2.3.1</version>
11.         </dependency>
12.         <dependency>
13.             <groupId>com.sun.xml.bind</groupId>
14.             <artifactId>jaxb-core</artifactId>
15.             <version>2.3.0.1</version>
16.         </dependency>
17.         <!-- 添加 JAXB 运行时实现 -->
18.         <dependency>
19.             <groupId>org.glassfish.jaxb</groupId>
20.             <artifactId>jaxb-runtime</artifactId>
21.             <version>2.3.1</version>
22.         </dependency>

复制代码

3.配置文件

1. qywx:
2.   url: https://qyapi.weixin.qq.com #企业微信api出口根路径
3.   #如果嫌public-path麻烦可以舍弃这个配置url用：https://qyapi.weixin.qq.com/cgi-bin代替
4.   public-path: cgi-bin #接口目录，最终会拼接在url后面，
5.   debug-mode: false #是否开启api的debug-mode模式
6.   corpId: 你的企业ID
7.   secret: 你的应用密钥
8.   call-back:
9.     #最好用自己在企业微信上随机生成的
10.     token: 自己生成
11.     encodingAESKey: 自己生成

复制代码

token和encodingAESKey看第一节的第二点随机获取就行了！
4.控制层

参数名称形貌msgSignature企业微信加密签名就是形貌的那样该参数由企业微信回调时提供timestamp时间戳同上nonce随机数同上echoStr加密字符该字符串是由在配置回调服务器时有效，由企微传递xml加密文档全部企微的回调都会有该参数，通过解析它才气获取回调事件内容 该接口必须包罗这五个参数并且是开放的（有安全框架的需忽略权限，其它自界说拦截逻辑请过滤该接口）

1. @RestController
2. public class CallBackController {
4.     private final CallbackService callbackService;
5.     public CallBackController(CallbackService callbackService) {
6.         this.callbackService = callbackService;
7.     }
9.     /**
10.      * 回调接口，由企业微信调用请开放
11.      * 注意：
12.      * echoStr，get
13.      * xml
14.      * @param msgSignature  企业微信加密签名
15.      * @param timestamp     时间戳
16.      * @param nonce         随机数
17.      * @param echoStr       加密字符
18.      * @param xml           加密文档
19.      */
20.     @RequestMapping("/callback")
21.     public String callback(@RequestParam(value = "msg_signature", required = false) String msgSignature,
22.                                 @RequestParam(value = "timestamp", required = false) String timestamp,
23.                                 @RequestParam(value = "nonce", required = false) String nonce,
24.                                 @RequestParam(value = "echostr", required = false) String echoStr,
25.                                 @RequestBody(required = false) String xml)
26.     {
27.         return callbackService.callback(msgSignature,timestamp,nonce,echoStr,xml);
28.     }
30. }

复制代码

5、服务层

1. public class CallbackService {
3.     @Value("${qywx.corpId}")
4.     private String corpId;
6.     @Value("${qywx.call-back.token}")
7.     private String callBackToken;
8.     @Value("${qywx.call-back.encodingAESKey}")
9.     private String callBackEncodingAESKey;
11.     public String callback(String msgSignature, String timestamp, String nonce, String echoStr,String xml) {
12.         if (echoStr==null&&xml==null){
13.             return "解析内容为空，解析失败";
14.         }
15.         if (msgSignature==null||timestamp==null||nonce==null){
16.             return "辅助解析参数为空，解析失败";
17.         }
19.         String result = "成功";
20.         try {
21.             WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(callBackToken, callBackEncodingAESKey, corpId);
22.             //这里注意在配置url时企业微信会调用一次该接口，此时echoStr是有值的
23.             //为了通过企业微信的校验这里需要解密并且将明文返回
24.             if (echoStr!=null&&!echoStr.isBlank()){
25.                 //调用工具包解密
26.                 return wxcpt.VerifyURL(msgSignature, timestamp, nonce, echoStr);
27.             }else {
28.                 //如果echoStr没值，那肯定是企业的业务回调了
29.                 String plainXml = wxcpt.DecryptMsg(msgSignature, timestamp, nonce, xml);
31.                 //企业微信回调的明文是xml,下面我用javax.xml来做一个解析。
32.                 CommonEventData xmlObject = XMLUtil.convertXmlStrToObject(CommonEventData.class, plainXml);
33.                 //因为企业微信有各种各样的回调xml类型，因此需要做抽象类，并以对应子类返回数据
34.                 if ("text".equals(xmlObject.getMsgType())){
35.                     System.out.println("text");
36.                     //文本消息回调的业务逻辑
37.                     TextMsgEventData textMsgEventData = XMLUtil.convertXmlStrToObject(TextMsgEventData.class, xml);
38.                     System.out.println(textMsgEventData);
39.                 }
40.                 //如果你需要加其它业务逻辑需要自己建BaseEventData的子类来对应
41.                 //当然这只是我使用了javax.xml来解析xml的案例，有更好用的xml包可以替换
42.                 if ("event".equals(xmlObject.getMsgType())){
43.                     //事件消息回调的业务逻辑,审批和成员变动都是该类型
44.                     //该类型的消息还有很多不同内容的xml需要特别注意（用我这个方法就需要建很多的子类来对应）
45.                     System.out.println("event");
46.                     //这里我们忽略Event的类型直接用ChangeType来判断使用哪个类进行封装
47.                     switch(xmlObject.getChangeType()){
48.                         case "create_user":
49.                         case "update_user":
50.                         case "delete_user":
51.                             UserEventData userEventData = XMLUtil.convertXmlStrToObject(UserEventData.class, xml);
52.                             System.out.println(userEventData);
53.                     }
54.                 }
55.             }
56.         } catch (AesException e) {
57.             throw new RuntimeException(e);
58.         }
59.         return result;
60.     }
61. }

复制代码

六、项目源码

项目gitee地址

---

总结

本章主要难点是编写正确的回调接口，只要注意配置文件的内容和企业微信上的逐一对应（Token和EncodingAESKey）的，并且解密工具包的入参次序没问题，就能乐成。还有一个贫苦的点在于没办法当地测试只能部署到服务器后调用才气判断接口是否正确。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。