微信公众平台开发（3）-回复消息

import org.apache.commons.lang.StringUtils;  
import org.apache.log4j.Logger;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Controller;  
import org.springframework.web.bind.annotation.RequestMapping;  
import org.springframework.web.bind.annotation.RequestMethod;  
  
  
import com.company.project.service.WeixinService;  
import com.company.project.util.Util;  
  
  
import javacommon.base.BaseRestSpringController;  
  
  
@Controller  
@RequestMapping("/wxapi")  
public class WeixinApiController extends BaseRestSpringController<Object, java.lang.Long>{  
    public static final Logger log = Logger.getLogger(WeixinApiController.class);  
    public static final String WX_TOKEN = "weixin";  
    @Autowired  
    private WeixinService wxService;  
    /** 
    * 微信回调地址 
    * 
    * @author qincd 
    * @throws IOException  
    * @date Nov 3, 2014 4:01:42 PM 
    */  
    @RequestMapping(method=RequestMethod.GET)  
    public void doGet(HttpServletRequest request,HttpServletResponse response) throws IOException {  
        // 微信会在配置的回调地址上加上signature,nonce,timestamp,echostr4个参数  
        String signature = request.getParameter("signature");  
        String timestamp = request.getParameter("timestamp");  
        String nonce = request.getParameter("nonce");  
        String echostr = request.getParameter("echostr");  
          
        log.info("微信传递的参数：");  
        log.info("signature："+signature);  
        log.info("timestamp："+timestamp);  
        log.info("nonce："+nonce);  
        log.info("echostr："+echostr);  
          
        if (StringUtils.isEmpty(signature)) {  
            return;  
        }  
        // 1).排序  
        String sortString = sort(WX_TOKEN, timestamp, nonce);  
        // 2).加密  
        String mytoken = Util.sha1(sortString);  
        // 3).校验签名  
        if (StringUtils.isNotEmpty(mytoken) && mytoken.equals(signature)) {  
            log.info("签名校验通过。");  
            response.getWriter().println(echostr);  
        }  
        else {  
            log.warn("签名校验失败。");  
        }  
    }  
      
    @RequestMapping(method=RequestMethod.POST)  
    public void doPost(HttpServletRequest request,HttpServletResponse response) throws IOException {  
        // 处理请求、响应  
        request.setCharacterEncoding("utf-8");  
        response.setCharacterEncoding("utf-8");  
        String message = wxService.processRequest(request);  
        response.getWriter().println(message);  
    }  
      
    /** 
    * 将token,timestamp,nonce按字典序排序，并返回拼接的字符串 
    * 
    * @author qincd 
    * @date Nov 3, 2014 4:09:43 PM 
    */  
    public static String sort(String token,String timestamp,String nonce) {  
        String[] strArray = {token,timestamp,nonce};  
        Arrays.sort(strArray);  
          
        StringBuilder sbuilder = new StringBuilder();  
        for (String str : strArray) {  
            sbuilder.append(str);  
        }  
      
        return sbuilder.toString();  
    }  
      
      
    }  
      
      
    import java.util.ArrayList;  
    import java.util.List;  
    import java.util.Map;  
      
      
    import javax.servlet.http.HttpServletRequest;  
      
      
    import org.apache.log4j.Logger;  
    import org.springframework.stereotype.Service;  
      
      
    import com.company.project.model.resp.Articles;  
    import com.company.project.model.resp.Music;  
    import com.company.project.model.resp.MusicMessage;  
    import com.company.project.model.resp.NewsMessage;  
    import com.company.project.model.resp.TextMessage;  
    import com.company.project.util.MessageUtil;  
      
      
    @Service  
    public class WeixinService {  
    public static Logger log = Logger.getLogger(WeixinService.class);  
      
    public String processRequest(HttpServletRequest req) {  
    // 解析微信传递的参数  
    String str = null;  
    try {  
        Map<String,String> xmlMap = MessageUtil.parseXml(req);  
        str = "请求处理异常，请稍后再试！";  
          
        String ToUserName = xmlMap.get("ToUserName");  
        String FromUserName = xmlMap.get("FromUserName");  
        String MsgType = xmlMap.get("MsgType");  
          
        if (MsgType.equals(MessageUtil.MESSAGG_TYPE_TEXT)) {  
            // 用户发送的文本消息  
            String content = xmlMap.get("Content");  
            log.info("用户：[" + FromUserName + "]发送的文本消息：" + content);  
              
            // 链接  
            if (content.contains("csdn")) {  
                TextMessage tm = new TextMessage();  
                tm.setToUserName(FromUserName);  
                tm.setFromUserName(ToUserName);  
                tm.setMsgType(MessageUtil.MESSAGG_TYPE_TEXT);  
                tm.setCreateTime(System.currentTimeMillis());  
                tm.setContent("我的CSDN博客：<a href=\"http://my.csdn.net/qincidong\">我的CSDN博客</a>\n");  
                return MessageUtil.textMessageToXml(tm);  
            }  
          
            if (content.contains("图文")) {  
                NewsMessage nm = new NewsMessage();  
                nm.setFromUserName(ToUserName);  
                nm.setToUserName(FromUserName);  
                nm.setCreateTime(System.currentTimeMillis());  
                nm.setMsgType(MessageUtil.MESSAGG_TYPE_NEWS);  
                List<Articles> articles = new ArrayList<Articles>();  
                Articles e1 = new Articles();  
                e1.setTitle("马云接受外媒专访：中国的五大银行想杀了“我”");  
                e1.setDescription("阿里巴巴集团上市大获成功，《华尔街日报》日前就阿里巴巴集团、支付宝等话题采访了马云，马云也谈到了与苹果Apple Pay建立电子支付联盟的可能性。本文摘编自《华尔街日报》，原文标题：马云谈阿里巴巴将如何帮助美国出口商，虎嗅略有删节。");  
                e1.setPicUrl("http://img1.gtimg.com/finance/pics/hv1/29/53/1739/113092019.jpg");  
                e1.setUrl("http://finance.qq.com/a/20141105/010616.htm?pgv_ref=aio2012&ptlang=2052");  
                  
                Articles e2 = new Articles();  
                e2.setTitle("史上最牛登机牌：姓名竟是微博名 涉事航空公司公开致歉");  
                e2.setDescription("世上最遥远的距离是飞机在等你登机，你却过不了安检。");  
                e2.setPicUrl("http://p9.qhimg.com/dmfd/328_164_100/t011946ff676981792d.png");  
                e2.setUrl("http://www.techweb.com.cn/column/2014-11-05/2093128.shtml");  
                articles.add(e1);  
                articles.add(e2);  
                  
                nm.setArticles(articles);  
                nm.setArticleCount(articles.size());  
                  
                String newsXml = MessageUtil.NewsMessageToXml(nm);  
                log.info("\n"+newsXml);  
                return newsXml;  
            }  
            if (content.contains("音乐")) {  
                MusicMessage mm =  new MusicMessage();  
                mm.setFromUserName(ToUserName);  
                mm.setToUserName(FromUserName);  
                mm.setMsgType(MessageUtil.MESSAGG_TYPE_MUSIC);  
                mm.setCreateTime(System.currentTimeMillis());  
                Music music = new Music();  
                music.setTitle("Maid with the Flaxen Hair");  
                music.setDescription("测试音乐");  
                music.setMusicUrl("http://yinyueshiting.baidu.com/data2/music/123297915/1201250291415073661128.mp3?xcode=e2edf18bbe9e452655284217cdb920a7a6a03c85c06f4409");  
                music.setHQMusicUrl("http://yinyueshiting.baidu.com/data2/music/123297915/1201250291415073661128.mp3?xcode=e2edf18bbe9e452655284217cdb920a7a6a03c85c06f4409");  
                mm.setMusic(music);  
                  
                String musicXml = MessageUtil.MusicMessageToXml(mm);  
                log.info("musicXml:\n" + musicXml);  
                return musicXml;  
            }  
          
            // 响应  
            TextMessage tm = new TextMessage();  
            tm.setToUserName(FromUserName);  
            tm.setFromUserName(ToUserName);  
            tm.setMsgType(MessageUtil.MESSAGG_TYPE_TEXT);  
            tm.setCreateTime(System.currentTimeMillis());  
            tm.setContent("你好，你发送的内容是：\n" + content);  
              
            String xml = MessageUtil.textMessageToXml(tm);  
            log.info("xml:" + xml);  
            return xml;  
        }  
        else if (MsgType.equals(MessageUtil.MESSAGG_TYPE_EVENT)) {  
            String event = xmlMap.get("Event");  
            if (event.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {  
                // 订阅  
                TextMessage tm = new TextMessage();  
                tm.setToUserName(FromUserName);  
                tm.setFromUserName(ToUserName);  
                tm.setMsgType(MessageUtil.MESSAGG_TYPE_TEXT);  
                tm.setCreateTime(System.currentTimeMillis());  
                tm.setContent("你好，欢迎关注[程序员的生活]公众号！[愉快]/呲牙/玫瑰\n目前可以回复文本消息");  
                return MessageUtil.textMessageToXml(tm);  
            }  
            else if (event.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {  
                // 取消订阅  
                log.info("用户【" + FromUserName + "]取消关注了。");  
            }  
        }  
    } catch (Exception e) {  
        e.printStackTrace();  
        log.error("处理微信请求时发生异常：");  
    }  
      
    return str;  
    }  
}