企业微信第三方服务商运用开发及上架教程 - 职贝云数AI新零售门户

package cn.renkai721.controller;
import cn.renkai721.bean.*;
import cn.renkai721.configuration.QywxProperties;
import cn.renkai721.service.*;
import cn.renkai721.util.HttpUtil;
import cn.renkai721.util.MsgUtil;
import cn.renkai721.util.WxUtil;
import cn.renkai721.wechataes.WXBizMsgCrypt;
import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.Map;
@EnableAsync
@RestController
@RequestMapping("/d3f")
@Slf4j
public class D3f2Controller {
@Resource
private RedissonClient redissonClient;
@Autowired
private RestTemplate restTemplate;
@Autowired
private D3fService d3fService;
@GetMapping(produces = "text/plain;charset=utf-8")
public void d3fGet(@RequestParam(name = "msg_signature", required = false) String signature,
@RequestParam(name = "timestamp", required = false) String timestamp,
@RequestParam(name = "nonce", required = false) String nonce,
@RequestParam(name = "echostr", required = false) String echostr,
HttpServletResponse response) throws Exception {
response.setContentType("text/html;charset=utf-8");
response.setStatus(HttpServletResponse.SC_OK);
WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(
MsgUtil.val("wechat.cp.appConfigs[0].token"),
MsgUtil.val("wechat.cp.appConfigs[0].aesKey"),
MsgUtil.val("wechat.cp.corpId"));
// 需求前往的明文
String sEchoStr = "";
try {
sEchoStr = wxcpt.VerifyURL(signature, timestamp, nonce, echostr);
log.info("resp sEchoStr={}",sEchoStr);
response.getWriter().print(sEchoStr);
return;
} catch (Exception e) {
// 验证URL失败，错误缘由请查看异常
e.printStackTrace();
}
response.getWriter().print("非法央求");
return;
}
@PostMapping(produces = "application/xml; charset=UTF-8")
public void d3fPost(@RequestParam("msg_signature") String signature,
@RequestParam("timestamp") String timestamp,
@RequestParam("nonce") String nonce,
HttpServletResponse response,
HttpServletRequest request) throws Exception {
String success = "success";
String type = request.getParameter("type");
String corpid = request.getParameter("corpid");
log.info("接收d3f post央求：[signature=[{}], timestamp=[{}], nonce=[{}], type=[{}], corpid=[{}] ]",
signature, timestamp, nonce, type, corpid);
try{
response.setContentType("text/html;charset=utf-8");
response.setStatus(HttpServletResponse.SC_OK);
String id = "";
// 访问运用和企业回调传不同的ID
if("data".equals(type)){
// 企微后台设置【数据回调URL】的链接为https://wx.naturobot.com/qywx/d3f?type=data&corpid=$CORPID$
id = corpid;
} else {
id = MsgUtil.val("suite_id");
}
WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(MsgUtil.val(
"wechat.cp.appConfigs[0].token"),
MsgUtil.val("wechat.cp.appConfigs[0].aesKey"),
id);
// 密文，对应POST央求的数据
String postData = "";
// 获取加密的央求音讯：运用输入流获得加密央求音讯postData
ServletInputStream in = request.getInputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
// 作为输入字符串的暂时串，用于判别能否读取终了
String tempStr = "";
while(null != (tempStr=reader.readLine())){
postData += tempStr;
}
String suiteXml = wxcpt.DecryptMsg(signature, timestamp, nonce, postData);
Map suiteMap = WxUtil.transferXmlToMap(suiteXml);
log.info("\n req map={}", suiteMap);
if("suite_ticket".equals(suiteMap.get("InfoType"))){
// https://developer.work.weixin.qq.com/document/10975#%E8%8E%B7%E5%8F%96%E7%AC%AC%E4%B8%89%E6%96%B9%E5%BA%94%E7%94%A8%E5%87%AD%E8%AF%81
// 自动推送SuiteTicket直接写入
// 每非常钟更新一次
//suite_ticket实践有效期为30分钟，
String suite_ticket_value = (String) suiteMap.get("SuiteTicket");
String SuiteId = (String) suiteMap.get("SuiteId");
log.info("suite_ticket={},SuiteId={}",suite_ticket_value,SuiteId);
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.suite_ticket_key);
idBucket.set(suite_ticket_value);
// 调用企业微信接口
d3fService.get_suite_access_token();
}else if("create_auth".equals(suiteMap.get("InfoType"))){
String authCode = (String) suiteMap.get("AuthCode");
// SuiteId代表一个企业，相当于suite_id
String SuiteId = (String) suiteMap.get("SuiteId");
log.info("第三方运用测试上线，AuthCode={},SuiteId={}",authCode,SuiteId);
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.authCode_key+"_"+SuiteId);
idBucket.set(authCode);
// 获取企业永世授权码
idBucket = redissonClient.getBucket(QywxProperties.suite_access_token_key);
String suite_access_token = idBucket.get();
String url1 = "https://qyapi.weixin.qq.com/cgi-bin/service/get_permanent_code?suite_access_token="+suite_access_token;
PermanentReqBean permanentReqBean = new PermanentReqBean();
permanentReqBean.setAuth_code(authCode);
ResponseEntity<PermanentRespBean> postForEntity1 = restTemplate.postForEntity(url1, permanentReqBean, PermanentRespBean.class);
log.info("get_permanent_code={}",postForEntity1.getBody());
if(postForEntity1.getBody().getExpires_in() != null){
String authCorpId = postForEntity1.getBody().getAuth_corp_info().getCorpid();
log.info("永世授权码中获取的第三方运用的authCorpId={}",authCorpId);
String userIdD3f = postForEntity1.getBody().getAuth_user_info().getUserid();
// 直接取第一个
String agentId = postForEntity1.getBody().getAuth_info().getAgent().get(0).getAgentid();
String permanent_code_access_token = postForEntity1.getBody().getAccess_token();
String permanent_code = postForEntity1.getBody().getPermanent_code();
log.info("permanent_code={}",permanent_code);
String open_userid = postForEntity1.getBody().getAuth_user_info().getOpen_userid();
// 可以设置企业的答应自动激活形态
// 这外面的东西需求保存上去，不然后面运用的时分没有了就完蛋了
// 这外面的东西需求保存上去，不然后面运用的时分没有了就完蛋了
// 这外面的东西需求保存上去，不然后面运用的时分没有了就完蛋了
}else{
log.error("get_permanent_code api is error");
}
}else if("cancel_auth".equals(suiteMap.get("InfoType"))){
String AuthCorpId = (String) suiteMap.get("AuthCorpId");
log.info("取消订阅cancel_auth AuthCorpId={}",AuthCorpId);
}
if("unlicensed_notify".equals(suiteMap.get("Event"))){
// 该用户帐号未授权
String AgentID = (String) suiteMap.get("AgentID");
String ToUserName = (String) suiteMap.get("ToUserName");
String FromUserName = (String) suiteMap.get("FromUserName");
log.info("用户帐号没有守旧授权，需求授权");
}else if("change_app_admin".equals(suiteMap.get("Event"))){
String AgentID = (String) suiteMap.get("AgentID");
// ToUserName=corpId
String ToUserName = (String) suiteMap.get("ToUserName");
log.info("第三方运用change_app_admin，ToUserName={},AgentID={}",ToUserName,AgentID);
}else if("subscribe".equals(suiteMap.get("Event"))){
log.info("新用户关注，user={}",suiteMap);
// 回复感激关注
String ToUserName = (String) suiteMap.get("ToUserName");
String FromUserName = (String) suiteMap.get("FromUserName");
String AgentID = (String) suiteMap.get("AgentID");
// 获取暂时授权码
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.suite_access_token_key);
String suite_access_token = idBucket.get();
String url1 = "https://qyapi.weixin.qq.com/cgi-bin/service/get_pre_auth_code?suite_access_token=" + suite_access_token;
String postData1 = HttpUtil.sendGet(url1);
log.info("get_pre_auth_code={}", postData1);
String subscribe_pre_auth_code = JSON.parseObject(postData1).getString("pre_auth_code");
String expires_in = JSON.parseObject(postData1).getString("expires_in");
if(!StringUtils.isEmpty(expires_in)){
// 设置授权配置
url1 = "https://qyapi.weixin.qq.com/cgi-bin/service/set_session_info?suite_access_token=" + suite_access_token;
SessionInfoReqBean sessionInfoReqBean = new SessionInfoReqBean();
sessionInfoReqBean.setPre_auth_code(subscribe_pre_auth_code);
SessionInfoBean sessionInfoBean = new SessionInfoBean();
sessionInfoBean.setAppid(new Integer[0]);
sessionInfoBean.setAuth_type(Integer.parseInt(MsgUtil.val("authType")));
sessionInfoReqBean.setSession_info(sessionInfoBean);
log.info("sessionInfoReqBean={}", JSON.toJSONString(sessionInfoReqBean));
ResponseEntity<SessionInfoRespBean> postForEntity = restTemplate.postForEntity(url1, sessionInfoReqBean, SessionInfoRespBean.class);
log.info("设置授权配置={}", postForEntity.getBody());
}else{
log.error("get_pre_auth_code api is error");
}
// 发送XML音讯给用户
String Title = "谢谢安装该运用";
String Description = "我们的运用很好用，假如有成绩请拨打电话021-12345";
String Url = MsgUtil.val("poster.freeUrl");
String PicUrl = "https://wx.naturobot.com/qywx/image/bg1.png";
log.info("Title={},Description={},Url={},PicUrl={},",Title,Description,Url,PicUrl);
String xmlOutMsg = wxcpt.getXmlNewsMessage(FromUserName,ToUserName,Title,Description,Url,PicUrl);
success = wxcpt.EncryptMsg(xmlOutMsg, timestamp, nonce);
}else if("enter_agent".equals(suiteMap.get("Event"))){
// 用户打开运用的事情
}
if("text".equals(suiteMap.get("MsgType"))){
// 用户发送了文本音讯给运用
String ToUserName = (String) suiteMap.get("ToUserName");
String FromUserName = (String) suiteMap.get("FromUserName");
String AgentID = (String) suiteMap.get("AgentID");
String xmlOutMsg = wxcpt.getXmlTextMessage(FromUserName,ToUserName,"暂未开启聊天功能。");
success = wxcpt.EncryptMsg(xmlOutMsg, timestamp, nonce);
}
} catch (Exception e) {
e.printStackTrace();
}
response.getWriter().print(success);
return;
}
}

复制代码

/**
* 对企业微信发送给企业后台的音讯加解密示例代码.
*
* @copyright Copyright (c) 1998-2014 Tencent Inc.
*/
// ------------------------------------------------------------------------
/**
* 针对org.apache.commons.codec.binary.Base64，
* 需求导入架包commons-codec-1.9（或commons-codec-1.8等其他版本）
* 官方下载地址：http://commons.apache.org/proper/commons-codec/download_codec.cgi
*/
package cn.renkai721.wechataes;
import org.apache.commons.codec.binary.Base64;
import javax.crypto.Cipher;
import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
import java.nio.charset.Charset;
import java.util.Arrays;
import java.util.Random;
/**
* 提供接收和推送给企业微信音讯的加解密接口(UTF8编码的字符串).
* <ol>
* <li>第三方回复加密音讯给企业微信</li>
* <li>第三方收到企业微信发送的音讯，验证音讯的安全性，并对音讯停止解密。</li>
* </ol>
* 阐明：异常java.security.InvalidKeyException:illegal Key Size的处理方案
* <ol>
* <li>在官方网站下载JCE有限制权限策略文件（JDK7的下载地址：
* http://www.oracle.com/technetwork/java/javase/downloads/jce-7-download-432124.html</li>
* <li>下载后解压，可以看到local_policy.jar和US_export_policy.jar以及readme.txt</li>
* <li>假如安装了JRE，将两个jar文件放到%JRE_HOME%\lib\security目录下覆盖原来的文件</li>
* <li>假如安装了JDK，将两个jar文件放到%JDK_HOME%\jre\lib\security目录下覆盖原来文件</li>
* </ol>
*/
public class WXBizMsgCrypt {
static Charset CHARSET = Charset.forName("utf-8");
Base64 base64 = new Base64();
byte[] aesKey;
String token;
String receiveid;
/**
* 构造函数
* @param token 企业微信后台，开发者设置的token
* @param encodingAesKey 企业微信后台，开发者设置的EncodingAESKey
* @param receiveid, 不同场景含义不同，详见文档
*
* @throws AesException 执行失败，请查看该异常的错误码和详细的错误信息
*/
public WXBizMsgCrypt(String token, String encodingAesKey, String receiveid) throws AesException {
if (encodingAesKey.length() != 43) {
throw new AesException(AesException.IllegalAesKey);
}
this.token = token;
this.receiveid = receiveid;
aesKey = Base64.decodeBase64(encodingAesKey + "=");
}
// 生成4个字节的网络字节序
byte[] getNetworkBytesOrder(int sourceNumber) {
byte[] orderBytes = new byte[4];
orderBytes[3] = (byte) (sourceNumber & 0xFF);
orderBytes[2] = (byte) (sourceNumber >> 8 & 0xFF);
orderBytes[1] = (byte) (sourceNumber >> 16 & 0xFF);
orderBytes[0] = (byte) (sourceNumber >> 24 & 0xFF);
return orderBytes;
}
// 还原4个字节的网络字节序
int recoverNetworkBytesOrder(byte[] orderBytes) {
int sourceNumber = 0;
for (int i = 0; i < 4; i++) {
sourceNumber <<= 8;
sourceNumber |= orderBytes[i] & 0xff;
}
return sourceNumber;
}
// 随机生成16位字符串
String getRandomStr() {
String base = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";
Random random = new Random();
StringBuffer sb = new StringBuffer();
for (int i = 0; i < 16; i++) {
int number = random.nextInt(base.length());
sb.append(base.charAt(number));
}
return sb.toString();
}
/**
* 对明文停止加密.
*
* @param text 需求加密的明文
* @return 加密后base64编码的字符串
* @throws AesException aes加密失败
*/
String encrypt(String randomStr, String text) throws AesException {
ByteGroup byteCollector = new ByteGroup();
byte[] randomStrBytes = randomStr.getBytes(CHARSET);
byte[] textBytes = text.getBytes(CHARSET);
byte[] networkBytesOrder = getNetworkBytesOrder(textBytes.length);
byte[] receiveidBytes = receiveid.getBytes(CHARSET);
// randomStr + networkBytesOrder + text + receiveid
byteCollector.addBytes(randomStrBytes);
byteCollector.addBytes(networkBytesOrder);
byteCollector.addBytes(textBytes);
byteCollector.addBytes(receiveidBytes);
// ... + pad: 运用自定义的填充方式对明文停止补位填充
byte[] padBytes = PKCS7Encoder.encode(byteCollector.size());
byteCollector.addBytes(padBytes);
// 获得最终的字节流, 未加密
byte[] unencrypted = byteCollector.toBytes();
try {
// 设置加密形式为AES的CBC形式
Cipher cipher = Cipher.getInstance("AES/CBC/NoPadding");
SecretKeySpec keySpec = new SecretKeySpec(aesKey, "AES");
IvParameterSpec iv = new IvParameterSpec(aesKey, 0, 16);
cipher.init(Cipher.ENCRYPT_MODE, keySpec, iv);
// 加密
byte[] encrypted = cipher.doFinal(unencrypted);
// 运用BASE64对加密后的字符串停止编码
String base64Encrypted = base64.encodeToString(encrypted);
return base64Encrypted;
} catch (Exception e) {
e.printStackTrace();
throw new AesException(AesException.EncryptAESError);
}
}
/**
* 对密文停止解密.
*
* @param text 需求解密的密文
* @return 解密得到的明文
* @throws AesException aes解密失败
*/
String decrypt(String text) throws AesException {
byte[] original;
try {
// 设置解密形式为AES的CBC形式
Cipher cipher = Cipher.getInstance("AES/CBC/NoPadding");
SecretKeySpec key_spec = new SecretKeySpec(aesKey, "AES");
IvParameterSpec iv = new IvParameterSpec(Arrays.copyOfRange(aesKey, 0, 16));
cipher.init(Cipher.DECRYPT_MODE, key_spec, iv);
// 运用BASE64对密文停止解码
byte[] encrypted = Base64.decodeBase64(text);
// 解密
original = cipher.doFinal(encrypted);
} catch (Exception e) {
e.printStackTrace();
throw new AesException(AesException.DecryptAESError);
}
String xmlContent, from_receiveid;
try {
// 去除补位字符
byte[] bytes = PKCS7Encoder.decode(original);
// 分离16位随机字符串,网络字节序和receiveid
byte[] networkOrder = Arrays.copyOfRange(bytes, 16, 20);
int xmlLength = recoverNetworkBytesOrder(networkOrder);
xmlContent = new String(Arrays.copyOfRange(bytes, 20, 20 + xmlLength), CHARSET);
from_receiveid = new String(Arrays.copyOfRange(bytes, 20 + xmlLength, bytes.length),
CHARSET);
} catch (Exception e) {
e.printStackTrace();
throw new AesException(AesException.IllegalBuffer);
}
// receiveid不相反的状况
System.out.println("------ from_receiveid="+from_receiveid+", receiveid="+receiveid);
if (!from_receiveid.equals(receiveid)) {
throw new AesException(AesException.ValidateCorpidError);
}
return xmlContent;
}
/**
* 将企业微信回复用户的音讯加密打包.
* <ol>
* <li>对要发送的音讯停止AES-CBC加密</li>
* <li>生成安全签名</li>
* <li>将音讯密文和安全签名打包成xml格式</li>
* </ol>
*
* @param replyMsg 企业微信待回复用户的音讯，xml格式的字符串
* @param timeStamp 工夫戳，可以本人生成，也可以用URL参数的timestamp
* @param nonce 随机串，可以本人生成，也可以用URL参数的nonce
*
* @return 加密后的可以直接回复用户的密文，包括msg_signature, timestamp, nonce, encrypt的xml格式的字符串
* @throws AesException 执行失败，请查看该异常的错误码和详细的错误信息
*/
public String EncryptMsg(String replyMsg, String timeStamp, String nonce) throws AesException {
// 加密
String encrypt = encrypt(getRandomStr(), replyMsg);
// 生成安全签名
if (timeStamp == "") {
timeStamp = Long.toString(System.currentTimeMillis());
}
String signature = SHA1.getSHA1(token, timeStamp, nonce, encrypt);
// System.out.println("发送给平台的签名是: " + signature[1].toString());
// 生成发送的xml
String result = XMLParse.generate(encrypt, signature, timeStamp, nonce);
System.out.println("call wechat xml message=["+result+"]");
return result;
}
/**
* 检验音讯的真实性，并且获取解密后的明文.
* <ol>
* <li>应用收到的密文生成安全签名，停止签名验证</li>
* <li>若验证经过，则提取xml中的加密音讯</li>
* <li>对音讯停止解密</li>
* </ol>
*
* @param msgSignature 签名串，对应URL参数的msg_signature
* @param timeStamp 工夫戳，对应URL参数的timestamp
* @param nonce 随机串，对应URL参数的nonce
* @param postData 密文，对应POST央求的数据
*
* @return 解密后的原文
* @throws AesException 执行失败，请查看该异常的错误码和详细的错误信息
*/
public String DecryptMsg(String msgSignature, String timeStamp, String nonce, String postData)
throws AesException {
// 密钥，公众帐号的app secret
// 提取密文
Object[] encrypt = XMLParse.extract(postData);
// 验证安全签名
String signature = SHA1.getSHA1(token, timeStamp, nonce, encrypt[1].toString());
// 和URL中的签名比较能否相等
// System.out.println("第三方收到URL中的签名：" + msg_sign);
// System.out.println("第三方校验签名：" + signature);
if (!signature.equals(msgSignature)) {
throw new AesException(AesException.ValidateSignatureError);
}
// 解密
String result = decrypt(encrypt[1].toString());
return result;
}
/**
* 验证URL
* @param msgSignature 签名串，对应URL参数的msg_signature
* @param timeStamp 工夫戳，对应URL参数的timestamp
* @param nonce 随机串，对应URL参数的nonce
* @param echoStr 随机串，对应URL参数的echostr
*
* @return 解密之后的echostr
* @throws AesException 执行失败，请查看该异常的错误码和详细的错误信息
*/
public String VerifyURL(String msgSignature, String timeStamp, String nonce, String echoStr)
throws AesException {
String signature = SHA1.getSHA1(token, timeStamp, nonce, echoStr);
if (!signature.equals(msgSignature)) {
throw new AesException(AesException.ValidateSignatureError);
}
String result = decrypt(echoStr);
return result;
}
public String getXmlTextMessage(String FromUserName,String ToUserName, String sendMsgText){
// 文本音讯
String timestamp = Long.toString(System.currentTimeMillis()/1000L);
return "<xml>" +
" <ToUserName><![CDATA["+FromUserName+"]]></ToUserName>" +
" <FromUserName><![CDATA["+ToUserName+"]]></FromUserName>" +
" <CreateTime>"+timestamp+"</CreateTime>" +
" <MsgType><![CDATA[text]]></MsgType>" +
" <Content><![CDATA["+sendMsgText+"]]></Content>" +
"</xml>";
}
public String getXmlNewsMessage(String FromUserName,String ToUserName, String Title, String Description, String Url, String PicUrl){
// 图文音讯
String timestamp = Long.toString(System.currentTimeMillis()/1000L);
return "<xml>" +
" <ToUserName><![CDATA["+FromUserName+"]]></ToUserName>" +
" <FromUserName><![CDATA["+ToUserName+"]]></FromUserName>" +
" <CreateTime>"+timestamp+"</CreateTime>" +
" <MsgType><![CDATA[news]]></MsgType>" +
" <Content><![CDATA[]]></Content>" +
" <ArticleCount>1</ArticleCount>" +
" <Articles>" +
" <item>" +
" <Title><![CDATA["+Title+"]]></Title>" +
" <Description><![CDATA["+Description+"]]></Description>" +
" <Url><![CDATA["+Url+"]]></Url>" +
" <PicUrl><![CDATA["+PicUrl+"]]></PicUrl>" +
" </item>" +
" </Articles>" +
" <FuncFlag>0</FuncFlag>" +
"</xml>";
}
}

复制代码

package cn.renkai721.util;
import org.jdom2.Document;
import org.jdom2.Element;
import org.jdom2.JDOMException;
import org.jdom2.input.SAXBuilder;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.*;
public class WxUtil {
/**
* 将 Map 转化为 XML
*
* @param map
* @return
*/
public static String transferMapToXml(SortedMap<String, Object> map) {
StringBuffer sb = new StringBuffer();
sb.append("<xml>");
for (String key : map.keySet()) {
sb.append("<").append(key).append(">")
.append(map.get(key))
.append("</").append(key).append(">");
}
return sb.append("</xml>").toString();
}
/**
* 将 XML 转化为 map
*
* @param strxml
* @return
* @throws IOException
*/
public static Map transferXmlToMap(String strxml) throws IOException {
strxml = strxml.replaceFirst("encoding=".*"", "encoding="UTF-8"");
if (null == strxml || "".equals(strxml)) {
return null;
}
Map m = new HashMap();
InputStream in = new ByteArrayInputStream(strxml.getBytes("UTF-8"));
SAXBuilder builder = new SAXBuilder();
Document doc = null;
try {
doc = builder.build(in);
} catch (JDOMException e) {
throw new IOException(e.getMessage()); // 一致转化为 IO 异常输入
}
// 解析 DOM
Element root = doc.getRootElement();
List list = root.getChildren();
Iterator it = list.iterator();
while (it.hasNext()) {
Element e = (Element) it.next();
String k = e.getName();
String v = "";
List children = e.getChildren();
if (children.isEmpty()) {
v = e.getTextNormalize();
} else {
v = getChildrenText(children);
}
m.put(k, v);
}
//关闭流
in.close();
return m;
}
// 辅助 transferXmlToMap 方法递归提取子节点数据
private static String getChildrenText(List<Element> children) {
StringBuffer sb = new StringBuffer();
if (!children.isEmpty()) {
Iterator<Element> it = children.iterator();
while (it.hasNext()) {
Element e = (Element) it.next();
String name = e.getName();
String value = e.getTextNormalize();
List<Element> list = e.getChildren();
sb.append("<" + name + ">");
if (!list.isEmpty()) {
sb.append(getChildrenText(list));
}
sb.append(value);
sb.append("</" + name + ">");
}
}
return sb.toString();
}
}

复制代码

package cn.renkai721.util;
import javax.xml.bind.JAXBContext;
import javax.xml.bind.Unmarshaller;
import java.io.StringReader;
public class XmlUtil {
/**
* 解析XMl内容，转换为POJO类
*
* @param clazz 要解析的对象
* @param xml 解析的xml字符串
* @return 解析完成的对象
*/
public static Object xmlStrToObject(Class clazz, String xml) {
Object xmlObject = null;
try {
JAXBContext context = JAXBContext.newInstance(clazz);
// 进即将Xml转成对象的核心接口
Unmarshaller unmarshaller = context.createUnmarshaller();
StringReader sr = new StringReader(xml);
xmlObject = unmarshaller.unmarshal(sr);
} catch (Exception e) {
e.printStackTrace();
}
return xmlObject;
}
}

复制代码

package cn.renkai721.wechataes;
@SuppressWarnings("serial")
public class AesException extends Exception {
public final static int OK = 0;
public final static int ValidateSignatureError = -40001;
public final static int ParseXmlError = -40002;
public final static int ComputeSignatureError = -40003;
public final static int IllegalAesKey = -40004;
public final static int ValidateCorpidError = -40005;
public final static int EncryptAESError = -40006;
public final static int DecryptAESError = -40007;
public final static int IllegalBuffer = -40008;
//public final static int EncodeBase64Error = -40009;
//public final static int DecodeBase64Error = -40010;
//public final static int GenReturnXmlError = -40011;
private int code;
private static String getMessage(int code) {
switch (code) {
case ValidateSignatureError:
return "签名验证错误";
case ParseXmlError:
return "xml解析失败";
case ComputeSignatureError:
return "sha加密生成签名失败";
case IllegalAesKey:
return "SymmetricKey非法";
case ValidateCorpidError:
return "corpid校验失败";
case EncryptAESError:
return "aes加密失败";
case DecryptAESError:
return "aes解密失败";
case IllegalBuffer:
return "解密后得到的buffer非法";
// case EncodeBase64Error:
// return "base64加密错误";
// case DecodeBase64Error:
// return "base64解密错误";
// case GenReturnXmlError:
// return "xml生成失败";
default:
return null; // cannot be
}
}
public int getCode() {
return code;
}
AesException(int code) {
super(getMessage(code));
this.code = code;
}
}

复制代码

package cn.renkai721.wechataes;
import java.util.ArrayList;
public class ByteGroup {
ArrayList<Byte> byteContainer = new ArrayList<Byte>();
public byte[] toBytes() {
byte[] bytes = new byte[byteContainer.size()];
for (int i = 0; i < byteContainer.size(); i++) {
bytes[i] = byteContainer.get(i);
}
return bytes;
}
public ByteGroup addBytes(byte[] bytes) {
for (byte b : bytes) {
byteContainer.add(b);
}
return this;
}
public int size() {
return byteContainer.size();
}
}

复制代码

package cn.renkai721.biz;
import cn.renkai721.bean.*;
import cn.renkai721.configuration.QywxProperties;
import cn.renkai721.util.HttpUtil;
import cn.renkai721.util.MsgUtil;
import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
import java.util.*;
import java.util.concurrent.TimeUnit;
@Slf4j
@Component
public class D3fBiz {
@Resource
private RedissonClient redissonClient;
@Resource
private RestTemplate restTemplate;
public String get_suite_ticket(){
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.suite_ticket_key);
String get_suite_ticket = idBucket.get();
return get_suite_ticket;
}
public String get_suite_access_token(){
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.suite_access_token_key);
String suite_access_token = idBucket.get();
log.info("suite_access_token={}",suite_access_token);
if(StringUtils.isEmpty(suite_access_token)){
String suite_ticket = this.get_suite_ticket();
// 假如上线后，没有最新的suite，手动在企微控制台点击刷新ticket
// 经过本接口获取的suite_access_token有效期为2小时，开发者需求停止缓存，不可频繁获取。
// 参考地址=https://work.weixin.qq.com/api/doc/90001/90143/90600
String url1= "https://qyapi.weixin.qq.com/cgi-bin/service/get_suite_token";
Map<String, Object> paramMap1 = new HashMap<>();
paramMap1.put("suite_id", MsgUtil.val(QywxProperties.suite_id_key));
paramMap1.put("suite_secret", MsgUtil.val(QywxProperties.suite_secret_key));
paramMap1.put("suite_ticket", suite_ticket);
String postData1 = HttpUtil.sendPost(url1, JSONObject.toJSONString(paramMap1));
log.info("get_suite_token={}",postData1);
suite_access_token = JSON.parseObject(postData1).getString(QywxProperties.suite_access_token_key);
String expires_in = JSON.parseObject(postData1).getString("expires_in");
if(!StringUtils.isEmpty(expires_in)){
idBucket.set(suite_access_token,Integer.parseInt(expires_in), TimeUnit.SECONDS);
}else{
log.error("get_suite_token api is error");
}
}
return suite_access_token;
}
public String get_access_token(String corpId){
String suite_access_token = this.get_suite_access_token();
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.corpId_suiteId_agentId+"_"+corpId);
String corpIdAndAgentId = idBucket.get();
log.info("corpIdAndAgentId={}",corpIdAndAgentId);
String permanent_code = corpIdAndAgentId.split(";")[3];
Map paramMap1 = new HashMap<>();
// 获取企业access_token
idBucket = redissonClient.getBucket(QywxProperties.access_token_key+"_"+corpId);
String access_token = idBucket.get();
log.info("access_token={}",access_token);
if(StringUtils.isEmpty(access_token)){
String url1 = "https://qyapi.weixin.qq.com/cgi-bin/service/get_corp_token?suite_access_token="+suite_access_token;
paramMap1 = new HashMap<>();
paramMap1.put("auth_corpid", corpId);
paramMap1.put("permanent_code", permanent_code);
String postData1 = HttpUtil.sendPost(url1, JSONObject.toJSONString(paramMap1));
log.info("get_corp_token={}",postData1);
access_token = JSON.parseObject(postData1).getString("access_token");
String expires_in = JSON.parseObject(postData1).getString("expires_in");
if(!StringUtils.isEmpty(expires_in)){
idBucket.set(access_token,Integer.parseInt(expires_in), TimeUnit.SECONDS);
}else{
log.error("get_corp_token is error");
}
}
return access_token;
}
public void sendD3fTextMsg(String corpId, String toUser, String message){
log.info("sendD3fTextMsg corpId={},toUser={},message={}"
,corpId,toUser,message);
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.corpId_suiteId_agentId+"_"+corpId);
String corpIdAndAgentId = idBucket.get();
log.info("corpIdAndAgentId={}",corpIdAndAgentId);
String agentId = corpIdAndAgentId.split(";")[2];
String access_token = this.get_access_token(corpId);
String msgUrl = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token="+access_token;
MsgRequestDTO requestData = new MsgRequestDTO();
requestData.setAgentid(Integer.parseInt(agentId));
requestData.setTouser(toUser);
requestData.setMsgtype("text");
Map<String,String> text = new HashMap<>();
text.put("content", message);
requestData.setText(text);
log.info("sendD3fTextMsg requestData={}",requestData);
ResponseEntity<MsgResult> postForEntity = restTemplate.postForEntity(msgUrl, requestData, MsgResult.class);
log.info("sendD3fTextMsg postForEntity={}",postForEntity);
}
public void sendD3fNewsMsg(String corpId, String toUser, String Title,
String Description, String Url, String PicUrl){
log.info("sendD3fNewsMsg corpId={},toUser={},Title={},Description={},Url={},PicUrl={},"
,corpId,toUser,Title,Description,Url,PicUrl);
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.corpId_suiteId_agentId+"_"+corpId);
String corpIdAndAgentId = idBucket.get();
log.info("corpIdAndAgentId={}",corpIdAndAgentId);
String agentId = corpIdAndAgentId.split(";")[2];
String access_token = this.get_access_token(corpId);
String msgUrl = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token="+access_token;
Map<String, Object> body = new HashMap<>();
body.put("touser",toUser);
body.put("msgtype","news");
body.put("agentid",Integer.parseInt(agentId));
Map<String, Object> news = new HashMap<>();
List articles = new ArrayList();
Map<String, Object> article = new HashMap<>();
article.put("title",Title);
if(!StringUtils.isEmpty(Description)){
article.put("description",Description);
}
if(!StringUtils.isEmpty(Url)){
article.put("url",Url);
}
article.put("picurl",PicUrl);
articles.add(article);
news.put("articles",articles);
body.put("news",news);
JSONObject jsonObject = new JSONObject(body);
log.info("sendNewsMsg body={},",jsonObject);
ResponseEntity<MsgResult> postForEntity = restTemplate.postForEntity(msgUrl, jsonObject, MsgResult.class);
log.info("sendNewsMsg postForEntity={}",postForEntity);
}
public void sendMarkdownMsg(String corpId,String toUser,String message) {
log.info("sendMarkdownMsg corpId={},toUser={},message={}"
,corpId,toUser,message);
RBucket<String> idBucket = redissonClient.getBucket(QywxProperties.corpId_suiteId_agentId+"_"+corpId);
String corpIdAndAgentId = idBucket.get();
log.info("corpIdAndAgentId={}",corpIdAndAgentId);
String agentId = corpIdAndAgentId.split(";")[2];
String access_token = this.get_access_token(corpId);
String msgUrl = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token="+access_token;
Map<String, Object> body = new HashMap<>();
body.put("touser",toUser);
body.put("msgtype","markdown");
body.put("agentid",agentId);
Map<String,String> markdown = new HashMap<>();
markdown.put("content", message);
body.put("markdown",markdown);
JSONObject jsonObject = new JSONObject(body);
log.info("sendMarkdownMsg body={},",jsonObject);
ResponseEntity<MsgResult> postForEntity = restTemplate.postForEntity(msgUrl, jsonObject, MsgResult.class);
log.info("sendMarkdownMsg={}",postForEntity);
}
}

复制代码