2、微信订阅号之消息自动回复

灰太狼 2022-05-23 09:36 280阅读 0赞

## 前言 ##

这个功能就是，当微信公众号用户输入内容的时候，我们的服务器可以监听到消息，并且可以根据消息内容做一个匹配，然后回复给他不同的消息内容。

### [开发文档][Link 1] ###

## 1、 服务端接收消息Controllr ##

微信会将发往公众账号的消息发到我们配置的URL中，以POST的方式  
当普通微信用户向公众账号发消息时，微信服务器将POST消息的XML数据包到开发者填写的

###  ###

import com.duodian.youhui.admin.moudle.chat.service.impl.ChatServiceImpl;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import javax.annotation.Resource;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    /**
     * @Desc:环境配置好之后就可以开发了
        微信会将发往公众账号的消息发到我们配置的URL中，以POST的方式
        当普通微信用户向公众账号发消息时，微信服务器将POST消息的XML数据包到开发者填写的URL上。
     * @Author HealerJean
     * @Date 2018/5/23  下午3:24.
     */
    @Controller
    @RequestMapping(value ="duodian/youhui")
    @Slf4j
    public class ChatController {
    
        @Resource
        private ChatServiceImpl chatService;
    
        /**
         * 接收来自微信发来的消息
         *
         * @param request
         * @param response
         */
        @ResponseBody
        @RequestMapping(value = "", method = RequestMethod.POST)
        public String wechatServicePost(HttpServletRequest request, HttpServletResponse response) {
            return  chatService.processRequest(request);
        }
    
    }

## 2、服务端服务端service层 ##

/**
     * @Desc: 接收来自服务器认证的消息
     * @Date:  2018/5/23 下午3:43.
     */
    public String processRequest(HttpServletRequest request) {
        //将Request消息转化为Map
        Map<String, String> map = WeChatMessageUtil.xmlToMap(request);
        log.info(map.toString());
    
        Object object =  judgeMessageByMsgType(map);
        if(object!=null) {
            String responseMessage = WeChatMessageUtil.textMessageToXml(object);
            log.info("返回给用户的消息内容\n"+responseMessage);
            return responseMessage;
        }
        return null;
    }

## 3、service层判断消息类型 ##

> 有可能是点击时间，取消订阅事件，订阅公众号事件，文本消息事件，图片消息事件

/**
     * @Desc:  通过map判断消息类型，并选择回复消息的种类
     * @Date:  2018/5/25 上午10:59.
     */
    
    public Object judgeMessageByMsgType(Map<String, String> map){
    
        // 消息类型
        String msgType = map.get("MsgType");
    
        String openId = map.get("FromUserName");
        AccessCallPerson(openId); //接入客服
    
        if (WeChatMessageParams.MESSAGE_TEXT.equals(msgType)) {// 文本消息
            return  getTestMessage(map,true);
         // 接收消息推送
        }else if(WeChatMessageParams.MESSAGE_EVENT.equals(msgType)) {
            //来自点击事件的event值
            String event = map.get("Event");
            //如果是点击事件，判断key的值
            if(StringUtils.equals(WeChatMessageParams.MESSAGE_EVENT_CLICK,event)){//点击事件
                if(StringUtils.equals(map.get("EventKey"),"shikeErWeiMa")){
                    return getImageMessage(map);
                }
            //用户关注微信公众号事件
            }else if(StringUtils.equals(WeChatMessageParams.MESSAGE_EVENT_SUBSCRIBE,event)){
                return getSubscribe(map);
             //用户取关微信订阅号
            }else if(StringUtils.equals(WeChatMessageParams.MESSAGE_EVENT_UNSUBSCRIBE,event)){
                 unSubScribe(map);
            }
            else {
                return  null;
            }
        }
        else { //目前只支持文本消息
            return getTestMessage(map,false);
        }
        return  null;
    }

## 4、发送文本消息 ##

/**
         * @Desc:  发送文本消息
         * @Date:  2018/5/24 上午11:30.
         * flag true表示正常回复，false表示用户发来的格式不正确的回复
         */
    
        public Object getTestMessage(Map<String,String> map,boolean flag){
    
    
            // 发送方帐号（一个OpenID）
            String fromUserName = map.get("FromUserName");
            // 开发者微信号
            String toUserName = map.get("ToUserName");
    
    
            TextMessage textMessage = new TextMessage();
            textMessage.setMsgType(WeChatMessageParams.MESSAGE_TEXT);
            textMessage.setToUserName(fromUserName);
            textMessage.setFromUserName(toUserName);
            textMessage.setCreateTime(System.currentTimeMillis());
            if(flag==false){
                textMessage.setContent("暂时不支持文字输入以外的查询。");
            }else {
    
                String filterContent = filterContent(map.get("Content"));
                textMessage.setContent("hello world");
            }
            return  textMessage;
    
        }

## 5、本微信公众号是是绝密， ##

![ContactAuthor][]

[Link 1]: https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140543
[ContactAuthor]: /images/20220523/089312caa22a448aa66a6d8d117d8c8d.png