企业微信回调验证

桃扇骨 2022-09-10 08:16 382阅读 0赞

参考博文1：[企业微信回调验证、消息交互、审批状态回调及审批查询][Link 1]  
参考博文2:[企业微信通讯录回调模板-XML转JSON-让回调不再难！][-XML_JSON-]//主要参考实现XML转JSON

[企业微信设置接收事件服务器url][url]  
![设置事件接收器图片][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP5peL6aOOX-S6ruWuhw_size_20_color_FFFFFF_t_70_g_se_x_16]  
微信官方提供的示例代码（工具）包：[下载地址][Link 2]  
![示例代码包下载地址][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP5peL6aOOX-S6ruWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 1]  
其中的异常及：  
1、**java.security.InvalidKeyException:illegal Key Size**  
![demo包中报错提示][demo]  
官方网站下载JCE无限制权限策略文件，[oracle下载地址][oracle]

如果安装了JRE，将两个jar文件放到%JRE_HOME%\lib\security目录下覆盖原来的文件
    如果安装了JDK，将两个jar文件放到%JDK_HOME%\jre\lib\security目录下覆盖原来文件

2、**java.lang.OutOfMemoryError:Java heap space**  
可略，设置默认vm参数：-Xms800m -Xmx800m  
3、**com.qq.weixin.mp.aes.AesException: 解密后得到的buffer非法**  
[参考博文][Link 3]  
解决方案：检查微信后台随机获取的Token和EncodingAESKey是否一致。

实现步骤：  
1、验证url的有效性（必须GET方法）  
controller层写个方法：

@Value("${corpId}")
    private String corpId;//企业Id
    
    //微信后台，随机获取的Token和EncodingAESKey，写死在配置文件中。
    //注意：一定要跟微信后台配置的一样，否则会报解密后得到的buffer非法
    @Value("${token}")
    private String token;
    @Value("${EncodingAESKey}")
    private String encodingAESKey;
    
     //企业微信回调验证
    @RequestMapping(value = "callback",method = RequestMethod.GET)
      public void connect(HttpServletRequest request, HttpServletResponse response){ 
          // 微信加密签名
    	 String msgSignature = request.getParameter("msg_signature");
    	  // 时间戳
    	  String timestamp = request.getParameter("timestamp");
    	  // 随机数
    	  String nonce = request.getParameter("nonce");
    	  // 随机字符串
    	  String echoStr = request.getParameter("echostr");
    	  WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(token,encodingAESKey,corpId);
    
          //回调key值
          String sEchoStr = null;
          try { 
               PrintWriter out = response.getWriter();
               sEchoStr = wxcpt.VerifyURL(msgSignature,timestamp,nonce,echoStr);
    
               if(StringUtils.isBlank(sEchoStr)){ 
                   logger.error("URL验证失败");
               }
               out.write(sEchoStr);
               out.flush();
    
           }catch (Exception e){ 
               logger.error("企业微信回调url验证错误",e);
           }
      }

微信后台点保存，提示设置成功，即完成。

2、验证url的有效性通过后，注释掉验证url的有效性代码，把method = RequestMethod.GET的Get方法改POST（不要改变接口路径）。

@Value("${corpId}")
    private String corpId;//企业Id
    
    //微信后台，随机获取的Token和EncodingAESKey，写死在配置文件中。
    //注意：一定要跟微信后台配置的一样，否则会报解密后得到的buffer非法
    @Value("${token}")
    private String token;
    @Value("${EncodingAESKey}")
    private String EncodingAESKey;
     
    @RequestMapping(value = "callback",method = RequestMethod.POST)
     public void connect(HttpServletRequest request, HttpServletResponse response){ 
     // 微信加密签名
     String msgSignature = request.getParameter("msg_signature");
      // 时间戳
      String timestamp = request.getParameter("timestamp");
      // 随机数
      String nonce = request.getParameter("nonce");
      // 随机字符串
      String echoStr = request.getParameter("echostr");
      WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(token,encodingAESKey,corpId);
      
    //校验url代码
     // try { 
    // PrintWriter out = response.getWriter();
    // WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(contacts_token,contacts_encodingaeskey,corpId);
    // sEchoStr = wxcpt.VerifyURL(msg_signature,timestamp,nonce,echoStr);
    //
    // if(StringUtils.isBlank(sEchoStr)){ 
    // logger.error("URL验证失败");
    // }
    // out.write(sEchoStr);
    // out.flush();
    //
    // }catch (Exception e){ 
    // logger.error("企业微信回调url验证错误",e);
    // }
      try{ 
     	  PrintWriter out = response.getWriter();
          InputStream inputStream = request.getInputStream();
          String postData= IOUtils.toString(inputStream,"UTF-8");
          String result = wxcpt.DecryptMsg(msgSignature, timestamp, nonce, postData);
          //微信示例代码包，xml转换不生效。自己写XML转json转工具XmlTool.java
          //如果需要返回实体或某个字段，解析转换Json即可
    	  JSONObject json = XmlTool.documentToJSONObject(text);
    	  out.write(json);
    	  out.flush();
      }catch (Exception e){ 
           logger.error("企业微信消息交互错误",e);
      }
     }

附XmlTool.java代码：

import java.util.List;
    import org.dom4j.Attribute;
    import org.dom4j.Document;
    import org.dom4j.DocumentException;
    import org.dom4j.DocumentHelper;
    import org.dom4j.Element;
    import com.alibaba.fastjsonfordrm.JSONArray;
    import com.alibaba.fastjsonfordrm.JSONObject;
     
    public class XmlTool { 
        /** * String 转 org.dom4j.Document * @param xml * @return * @throws DocumentException */
        public static Document strToDocument(String xml){ 
            try { 
                //加上xml标签是为了获取最外层的标签，如果不需要可以去掉
                return DocumentHelper.parseText(xml);
            } catch (DocumentException e) { 
                return null;
            }
        }
     
        /** * org.dom4j.Document 转 com.alibaba.fastjson.JSONObject * @param xml * @return * @throws DocumentException */
        public static JSONObject documentToJSONObject(String xml){ 
            return elementToJSONObject(strToDocument(xml).getRootElement());
        }
     
        /** * org.dom4j.Element 转 com.alibaba.fastjson.JSONObject * @param node * @return */
        public static JSONObject elementToJSONObject(Element node) { 
            JSONObject result = new JSONObject();
            // 当前节点的名称、文本内容和属性
            List<Attribute> listAttr = node.attributes();// 当前节点的所有属性的list
            for (Attribute attr : listAttr) { // 遍历当前节点的所有属性
                result.put(attr.getName(), attr.getValue());
            }
            // 递归遍历当前节点所有的子节点
            List<Element> listElement = node.elements();// 所有一级子节点的list
            if (!listElement.isEmpty()) { 
                for (Element e : listElement) { // 遍历所有一级子节点
                    if (e.attributes().isEmpty() && e.elements().isEmpty()) // 判断一级节点是否有属性和子节点
                        result.put(e.getName(), e.getTextTrim());// 沒有则将当前节点作为上级节点的属性对待
                    else { 
                        if (!result.containsKey(e.getName())) // 判断父节点是否存在该一级节点名称的属性
                            result.put(e.getName(), new JSONArray());// 没有则创建
                        ((JSONArray) result.get(e.getName())).add(elementToJSONObject(e));// 将该一级节点放入该节点名称的属性对应的值中
                    }
                }
            }
            return result;
        }
    }

[Link 1]: https://blog.csdn.net/yzhbyssgdbd123/article/details/98171964
[-XML_JSON-]: https://zwz99.blog.csdn.net/article/details/113818974
[url]: https://work.weixin.qq.com/wework_admin/frame#customer/analysis
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP5peL6aOOX-S6ruWuhw_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/0fbb47e64a314b6cb09347a50792a590.png
[Link 2]: https://work.weixin.qq.com/api/doc/90000/90138/90307#java%E5%BA%93
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5bCP5peL6aOOX-S6ruWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220829/7739196a851a445ea89add77bc6e086b.png
[demo]: /images/20220829/b5af69d58454444bb987de9378a3ad86.png
[oracle]: https://commons.apache.org/proper/commons-codec/download_codec.cgi
[Link 3]: https://blog.csdn.net/weixin_34365635/article/details/89664236