import cn.hutool.core.util.XmlUtil;

import org.apache.commons.io.IOUtils;

import org.apache.commons.lang3.StringUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.servlet.mvc.support.RedirectAttributes;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.servlet.http.HttpSession;

import java.io.InputStream;

import java.io.PrintWriter;

import java.nio.charset.StandardCharsets;

import java.util.Map;

@RestController

@RequestMapping("/api/wx")

public class WxSampleController {

    private static final Logger logger = LoggerFactory.getLogger(WxSampleController.class);

    /** 企业微信回调验证 */

    @GetMapping("/callback")

    public void connect(HttpServletRequest request, HttpServletResponse response){

        //msg_signature = hash 算法 (token+timestamp+nonce+echostr); 

        // 形象说法就是标记，防止参数传递过程被篡改

        String msg_signature = request.getParameter("msg_signature");// 微信加密签名

        String timestamp = request.getParameter("timestamp");// 时间戳

        String nonce = request.getParameter("nonce");// 随机数

        //echostr = AES 算法使用 EncodingAESKey 密钥加密明文后的值

        String echoStr = request.getParameter("echostr");// 随机字符串

        String token = ""; // 前面获取的 Token

        String encodingaeskey = ""; // 前面获取的 EncodingAESKey

        String secretId = ""; // 企业 ID

        try (PrintWriter out = response.getWriter()) {

            // 微信准备的加解密类

            WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(token,encodingaeskey,secretId);

            String 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);

        }

    }

    /** 企业微信消息交互 */

    @PostMapping( "/callback")

    public void acceptMessage(HttpServletRequest request, RedirectAttributes attributes, HttpSession session){

		//msg_signature = hash 算法 (token+timestamp+nonce+echostr); 

        // 形象说法就是标记，防止参数传递过程被篡改

        String sMsgSignature = request.getParameter("msg_signature");// 微信加密签名

        String sTimestamp = request.getParameter("timestamp");// 时间戳

        String sNonce = request.getParameter("nonce");// 随机数

        String token = ""; // 前面获取的 Token

        String encodingaeskey = ""; // 前面获取的 EncodingAESKey

        String corpId = ""; // 企业 ID

        try{

            InputStream inputStream = request.getInputStream();

            String sPostData = IOUtils.toString(inputStream, StandardCharsets.UTF_8);

            WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(token,encodingaeskey,corpId);

            String sMsg = wxcpt.DecryptMsg(sMsgSignature,sTimestamp,sNonce,sPostData);

            //sMsg 是 xml 格式的字符串，我使用的是 hutool 工具下的插件转 map 的，你也可以用其它的方式

           	Map<String, String> map = new HashMap<String, String>(10);

            Document document = XmlUtil.parseXml(sMsg);

            List<Element> xml = XmlUtil.getElements(document.getDocumentElement(), null);

            for(Element x:xml){

                map.put(x.getTagName(),x.getTextContent());

            }

            // 业务代码 ...

        }catch (Exception e){

            logger.error("企业微信消息交互错误",e);

        }

    }

}

// 报错代码

aesKey = Base64.decodeBase64(encodingAesKey + "=");

// 32 位字符串可以使用 UUID 去掉中间的 - 就剩下 32 位了

Base64.encodeBase64String(UUID.randomUUID().toString().replaceAll("-","").getBytes());