企业微信-内部应用回调服务的应用与实现 - ToB企服应用市场:ToB评测及商务社交产业平台

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

复制代码

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

复制代码

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

复制代码

<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>javax.xml.bind</groupId>
<artifactId>jaxb-api</artifactId>
<version>2.3.1</version>
</dependency>
<dependency>
<groupId>com.sun.xml.bind</groupId>
<artifactId>jaxb-core</artifactId>
<version>2.3.0.1</version>
</dependency>
<dependency>
<groupId>org.glassfish.jaxb</groupId>
<artifactId>jaxb-runtime</artifactId>
<version>2.3.1</version>
</dependency>

复制代码

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

复制代码

@RestController
public class CallBackController {
private final CallbackService callbackService;
public CallBackController(CallbackService callbackService) {
this.callbackService = callbackService;
}
/**
* 回调接口，由企业微信调用请开放
* 注意：
* echoStr，get
* xml
* @param msgSignature 企业微信加密签名
* @param timestamp 时间戳
* @param nonce 随机数
* @param echoStr 加密字符
* @param xml 加密文档
*/
@RequestMapping("/callback")
public String callback(@RequestParam(value = "msg_signature", required = false) String msgSignature,
@RequestParam(value = "timestamp", required = false) String timestamp,
@RequestParam(value = "nonce", required = false) String nonce,
@RequestParam(value = "echostr", required = false) String echoStr,
@RequestBody(required = false) String xml)
{
return callbackService.callback(msgSignature,timestamp,nonce,echoStr,xml);
}
}

复制代码

public class CallbackService {
@Value("${qywx.corpId}")
private String corpId;
@Value("${qywx.call-back.token}")
private String callBackToken;
@Value("${qywx.call-back.encodingAESKey}")
private String callBackEncodingAESKey;
public String callback(String msgSignature, String timestamp, String nonce, String echoStr,String xml) {
if (echoStr==null&&xml==null){
return "解析内容为空，解析失败";
}
if (msgSignature==null||timestamp==null||nonce==null){
return "辅助解析参数为空，解析失败";
}
String result = "成功";
try {
WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(callBackToken, callBackEncodingAESKey, corpId);
//这里注意在配置url时企业微信会调用一次该接口，此时echoStr是有值的
//为了通过企业微信的校验这里需要解密并且将明文返回
if (echoStr!=null&&!echoStr.isBlank()){
//调用工具包解密
return wxcpt.VerifyURL(msgSignature, timestamp, nonce, echoStr);
}else {
//如果echoStr没值，那肯定是企业的业务回调了
String plainXml = wxcpt.DecryptMsg(msgSignature, timestamp, nonce, xml);
//企业微信回调的明文是xml,下面我用javax.xml来做一个解析。
CommonEventData xmlObject = XMLUtil.convertXmlStrToObject(CommonEventData.class, plainXml);
//因为企业微信有各种各样的回调xml类型，因此需要做抽象类，并以对应子类返回数据
if ("text".equals(xmlObject.getMsgType())){
System.out.println("text");
//文本消息回调的业务逻辑
TextMsgEventData textMsgEventData = XMLUtil.convertXmlStrToObject(TextMsgEventData.class, xml);
System.out.println(textMsgEventData);
}
//如果你需要加其它业务逻辑需要自己建BaseEventData的子类来对应
//当然这只是我使用了javax.xml来解析xml的案例，有更好用的xml包可以替换
if ("event".equals(xmlObject.getMsgType())){
//事件消息回调的业务逻辑,审批和成员变动都是该类型
//该类型的消息还有很多不同内容的xml需要特别注意（用我这个方法就需要建很多的子类来对应）
System.out.println("event");
//这里我们忽略Event的类型直接用ChangeType来判断使用哪个类进行封装
switch(xmlObject.getChangeType()){
case "create_user":
case "update_user":
case "delete_user":
UserEventData userEventData = XMLUtil.convertXmlStrToObject(UserEventData.class, xml);
System.out.println(userEventData);
}
}
}
} catch (AesException e) {
throw new RuntimeException(e);
}
return result;
}
}

复制代码