微信公众号自动回复及多客服功能实现

目录

• 前期准备
• 1、微信公众平台基本设置
• 2、开发所需参数
• 功能步骤
• 1、填写服务器配置
• 2、验证服务器地址的有效性
• 3、依据接口文档实现业务逻辑
• 具体实现
• 1、微信接入
• 2、自定义回复及多客服接入

默认微信公众平台对公众号的自动回复、多客服等功能都是可以直接使用的。但是由于一些因素（扫码登录）开放了微信公众号接口，导致以上功能需要自己对接，无法直接使用平台提供的功能。以下是我对公众号自动回复和多客服实现的一些心得。

效果：

前期准备

1、微信公众平台基本设置

公众号官网：https://mp.weixin.qq.com

公众号客服系统地址：
https://mpkf.weixin.qq.com/

登录前需公众号管理员设置客服账号：

基本配置：

AppSecret：自动生成

IP白名单：服务器外网ip（调用“获取access_token”接口，返回结果。如非白名单IP调用，将返回错误码：40164）

服务器地址：备案的域名下的某个可访问路径

Token令牌： 自定义

消息加密密钥：自动生成即可

消息加密解密方式：安全模式

2、开发所需参数

开发者ID（AppID）

开发者密码（AppSecret）

服务器令牌（Token）

消息加解密密钥（EncodingAESKey）

功能步骤

1、填写服务器配置

2、验证服务器地址的有效性

开发者提交信息后，微信服务器将发送GET请求到填写的服务器地址URL上，GET请求携带参数如下表所示：

参数描述signature微信加密签名，signature结合了开发者填写的token参数和请求中的timestamp参数、nonce参数。timestamp时间戳nonce随机数echostr随机字符串

开发者通过检验signature对请求进行校验（下面有校验方式）。若确认此次GET请求来自微信服务器，请原样返回echostr参数内容，则接入生效，成为开发者成功，否则接入失败。加密/校验流程如下：

1）将token、timestamp、nonce三个参数进行字典序排序

2）将三个参数字符串拼接成一个字符串进行sha1加密

3）开发者获得加密后的字符串可与signature对比，标识该请求来源于微信

3、依据接口文档实现业务逻辑

具体实现

全局常量：

   //@Value("${DNBX_TOKEN}")
    private String DNBX_TOKEN = 服务器令牌token;

1、微信接入

接入地址需要和配置中的服务器地址匹配

/**
     * 微信接入
     * 必须为get方式获取接口参数并验证
     * @return
     * @throws IOException
     */
    @RequestMapping(value = "/connect", method = RequestMethod.GET)
    public void connectWeixin(HttpServletRequest request, HttpServletResponse response) throws IOException {
        PrintWriter print;
        //获取微信接口参数
        String signature = request.getParameter("signature");
        String timestamp = request.getParameter("timestamp");
        String nonce = request.getParameter("nonce");
        String echostr = request.getParameter("echostr");
        LOGGER.info("\n[signature=" + signature
                + "][timestamp=" + timestamp
                + "][nonce=" + nonce
                + "][echostr=" + echostr
                + "][token=" + DNBX_TOKEN + "]");
        // 通过检验signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败
        if (signature != null && WeChatUtil.checkSignature(signature, DNBX_TOKEN, timestamp, nonce)) {
            try {
                print = response.getWriter();
                print.write(echostr);
                print.flush();
                print.close();
                LOGGER.info("wechat auth success...");
            } catch (IOException e) {
                e.printStackTrace();
            }
        } else {
            LOGGER.info("wechat auth failure...");
        }
    }

2、自定义回复及多客服接入

    @RequestMapping(value = "/connect", method = RequestMethod.POST, produces = "application/xml;charset=UTF-8")
    public void wechatPost(HttpServletRequest request, HttpServletResponse response) throws IOException {
        request.setCharacterEncoding("UTF-8");
        response.setCharacterEncoding("UTF-8");
        LOGGER.info("wechat post request start...");
        PrintWriter print = response.getWriter();
        String reqStr = IOUtils.toString(request.getInputStream());
        LOGGER.info("解密请求消息：");

        try {
        	//对消息加密，相关工具类官方已提供
            WXBizMsgCrypt pc = new WXBizMsgCrypt(DNBX_TOKEN, 消息加解密密钥EncodingAESKey, 开发者AppID);
            String timeStamp = String.valueOf(System.currentTimeMillis());    // 时间戳
            String nonce = DateUtil.format(new Date(), "yyyyMMddHHmmss");    // 随机字符串
            print = response.getWriter();
            String msgSignature = request.getParameter("msg_signature");
            System.out.println("msgSignature = " + msgSignature);
            String timestamp = request.getParameter("timestamp");
            String urlnonce = request.getParameter("nonce");
            System.out.println("urlnonce = " + urlnonce);
            String openid = request.getParameter("openid");
            String encrypt_type = request.getParameter("encrypt_type");
            String decryptStr = pc.decryptMsg(msgSignature, timestamp, urlnonce, reqStr);
            System.out.println("decryptStr = " + decryptStr);
            //LOGGER.info("解密后的请求消息：" + decryptStr);
            //XmlAndMap是自己封装的xml转map的工具类，此处是自动解析decryptStr为xml然后转map，如过不爱自己写可以留下邮箱索要
            Map<String, String> req = XmlAndMap.xmlToMap(decryptStr);
            Map<String, String> rsp = new HashMap<String, String>();
            //获取解密后的数据并封装Map
            rsp.put("ToUserName", req.get("FromUserName"));
            rsp.put("FromUserName", req.get("ToUserName"));
            rsp.put("CreateTime", req.get("CreateTime"));
            String replymsg = "";
            //判断返回的数据类型是否是事件
            if (req.get("Event") != null) {
                if (req.get("Event").equals("subscribe")) {//判断当前事件是关注事件
                    rsp.put("MsgType", "Text");
                    rsp.put("Content", "自定义的欢迎语句内容");
                }
            } else {//此处为消息类型
                Map replyMap = new HashMap();
                replyMap.put("人工客服", "正在为您链接到客服人员，请耐心等候……");
                //加载关键词及其回复内容
                List<KeyWordReply> keyWordReplies = keyWordService.selectKeyWords();
                for (KeyWordReply keyword : keyWordReplies) {
                    String[] split = keyword.getKeyWord().split(",");
                    for (String item : split) {
                        replyMap.put(item.trim(), keyword.getText());
                    }
                }
                //用户输入词汇与自定义的关键词匹配
                if (replymsg != null && replyMap.containsKey(req.get("Content").trim())) {
                    if ("人工客服".equals(req.get("Content"))) {
                        LOGGER.info("人工客服===================");
                        //人工客服对接MsgType类型为transfer_customer_service
                        rsp.put("MsgType", "transfer_customer_service");
                        rsp.put("Content", replymsg);
                    } else {
                        LOGGER.info("自动回复===================");
                        replymsg = (String) replyMap.get(req.get("Content"));
                        rsp.put("MsgType", "Text");
                        rsp.put("Content", replymsg);
                    }
                } else {用户输入词汇与自定义的关键词匹配失败自动回复内容
                    replymsg = "您好！如有问题，请输入【人工客服】寻求帮助。";
                    rsp.put("MsgType", "Text");
                    rsp.put("Content", replymsg);
                }
                //LOGGER.info("加密前响应报文:\n" + XmlAndMap.mapToXml2(rsp));
            }
			//回复内容加密并输出
            String miwen = pc.encryptMsg(XmlAndMap.mapToXml2(rsp), timestamp, urlnonce);
            print.write(miwen);
            //LOGGER.info("加密后响应报文:\n" + miwen);
            print.flush();
            print.close();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (AesException e) {
            e.printStackTrace();
        }
    }

1）、代码中提到的消息类型及数据结构参考：官方文档

2）、对消息加密，加密工具类官方提供：官方代码