微信开发源码讲解

微信开发请求Servlet

package com.weixin.servlet;

import java.io.IOException;
import java.io.PrintWriter;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.jeecg.util.SignUtil;

import com.weixin.service.CoreService;

/**
 * 核心请求处理类
 * 
 * @author liufeng
 * @date 2013-05-18
 */
public class CoreServlet extends HttpServlet {
	private static final long serialVersionUID = 4440739483644821986L;

	/**
	 * 确认请求来自微信服务器
	 */
	public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// 微信加密签名
		String signature = request.getParameter("signature");
		// 时间戳
		String timestamp = request.getParameter("timestamp");
		// 随机数
		String nonce = request.getParameter("nonce");
		// 随机字符串
		String echostr = request.getParameter("echostr");

		PrintWriter out = response.getWriter();
		// 通过检验signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败
		if (SignUtil.checkSignature(signature, timestamp, nonce)) {
			out.print(echostr);
		}
		out.close();
		out = null;
	}

	/**
	 * 处理微信服务器发来的消息
	 */
	public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
		// 将请求、响应的编码均设置为UTF-8（防止中文乱码）
		request.setCharacterEncoding("UTF-8");
		response.setCharacterEncoding("UTF-8");

		// 调用核心业务类接收消息、处理消息
		//String respMessage = MingXingService.processRequest(request);
		String respMessage =CoreService.processRequest(request);
		// 响应消息
		PrintWriter out = response.getWriter();
		out.print(respMessage);
		out.close();
	}

}

针对用户事件具体逻辑处理代码：

package com.weixin.service;


import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;


import javax.servlet.http.HttpServletRequest;


import org.apache.log4j.Logger;
import org.jeecg.message.resp.Article;
import org.jeecg.message.resp.NewsMessage;
import org.jeecg.message.resp.TextMessage;
import org.jeecg.util.FreemarkerHelper;
import org.jeecg.util.MessageUtil;
import org.jeecg.util.weather.Weather;




/**
* 核心服务类
*
* @author liufeng
* @date 2013-05-20
*/
public class CoreService {
private static Logger log = Logger.getLogger(CoreService.class);


/**
* 处理微信发来的请求
*
* @param request
* @return
*/
public static String processRequest(HttpServletRequest request) {
String respMessage = null;
try {
// 默认返回的文本消息内容
String respContent = "请求处理异常，请稍候尝试！";
// xml请求解析
Map<String, String> requestMap = MessageUtil.parseXml(request);
// Map<String, String> requestMap = new HashMap<String, String>();
// // 发送方帐号（open_id）
String fromUserName = requestMap.get("FromUserName");
// 公众帐号
String toUserName = requestMap.get("ToUserName");
// 消息类型
String msgType = requestMap.get("MsgType");
// 默认回复此文本消息
TextMessage textMessage = new TextMessage();
textMessage.setToUserName(fromUserName);
textMessage.setFromUserName(toUserName);
textMessage.setCreateTime(new Date().getTime());
textMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_TEXT);
textMessage.setFuncFlag(0);
// 由于href属性值必须用双引号引起，这与字符串本身的双引号冲突，所以要转义
textMessage.setContent(getMainMenu());
// 将文本消息对象转换成xml字符串
respMessage = MessageUtil.textMessageToXml(textMessage);
// 文本消息
if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_TEXT)) {
String content = requestMap.get("Content");
if ("?".equals(content)) {
respContent = getMainMenu();
textMessage.setContent(respContent);
respMessage = MessageUtil.textMessageToXml(textMessage);
} else if ("1".equals(content)) {
respContent = "作者：张代浩 (scott) \n邮箱：[e-mail] \n ：129190229";
textMessage.setContent(respContent);
respMessage = MessageUtil.textMessageToXml(textMessage);
} else if ("2".equals(content)) {
respContent = "<a href=\"www.jeecg.org\">www.jeecg.org</a>";
textMessage.setContent(respContent);
respMessage = MessageUtil.textMessageToXml(textMessage);
} else if ("3".equals(content)) {
// 创建图文消息
NewsMessage newsMessage = new NewsMessage();
newsMessage.setToUserName(fromUserName);
newsMessage.setFromUserName(toUserName);
newsMessage.setCreateTime(new Date().getTime());
newsMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_NEWS);
newsMessage.setFuncFlag(0);


List<Article> articleList = new ArrayList<Article>();
Article article1 = new Article();
article1.setTitle("JEECG专题介绍");
article1.setDescription("JEECG 微云快速开发平台");
article1.setPicUrl("http://avatar.csdn.net/3/D/E/1_zhangdaiscott.jpg");
article1.setUrl("http://zhangdaiscott.github.io/jeecg/");


Article article4 = new Article();
article4.setTitle("第2篇\n MiniDao专题介绍");
article4.setDescription("");
article4.setPicUrl("http://www.jeecg.org/data/attachment/forum/201308/18/224051ey14ehqe000iegja.jpg");
article4.setUrl("http://zhangdaiscott.github.io/MiniDao/");


Article article2 = new Article();
article2.setTitle("第3篇\n JEECG CSDN专家访谈");
article2.setDescription("");
article2.setPicUrl("http://img.my.csdn.net/uploads/201301/23/1358930662_6750.jpg");
article2.setUrl("http://blog.csdn.net/blogdevteam/article/details/8534797");


Article article3 = new Article();
article3.setTitle("第4篇\n 参与开源");
article3.setDescription("");
article3.setPicUrl("http://avatar.csdn.net/3/D/E/1_zhangdaiscott.jpg");
article3.setUrl("http://blog.csdn.net/zhangdaiscott/article/details/14160383");




articleList.add(article1);
articleList.add(article4);
articleList.add(article2);
articleList.add(article3);
newsMessage.setArticleCount(articleList.size());
newsMessage.setArticles(articleList);
respMessage = MessageUtil.newsMessageToXml(newsMessage);
}else if ("4".equals(content)) {
respContent = "<a href=\"http://jeecgdemo.duapp.com/html5Servlet\">微应用演示 -- 用力点我</a>";
textMessage.setContent(respContent);
respMessage = MessageUtil.textMessageToXml(textMessage);
}else if ("5".equals(content)||"翻译".equals(content)) {
respContent = getTranslateUsage();
textMessage.setContent(respContent);
respMessage = MessageUtil.textMessageToXml(textMessage);
}else if ("6".equals(content)||"大转盘".equals(content)) {
NewsMessage newsMessage = new NewsMessage();
newsMessage.setToUserName(fromUserName);
newsMessage.setFromUserName(toUserName);
newsMessage.setCreateTime(new Date().getTime());
newsMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_NEWS);
newsMessage.setFuncFlag(0);

Article article3 = new Article();
List<Article> articleList = new ArrayList<Article>();
article3.setTitle("大转盘");
article3.setDescription("");
article3.setPicUrl("http://www.jeecg.org/data/attachment/forum/201312/17/165432nuqktzqq305hkr06.jpg");
article3.setUrl("http://jeecgdemo.duapp.com/zhuanpan.htm");
articleList.add(article3);
newsMessage.setArticleCount(articleList.size());
newsMessage.setArticles(articleList);
respMessage = MessageUtil.newsMessageToXml(newsMessage);
}else if (content.startsWith("翻译")) {
String keyWord = content.replaceAll("^翻译", "").trim();
if ("".equals(keyWord)) {
textMessage.setContent(getTranslateUsage());
} else {
textMessage.setContent(BaiduTranslateService.translate(keyWord));
}
respMessage = MessageUtil.textMessageToXml(textMessage);
}else if (content.startsWith("天气")||content.startsWith("7")) {
String keyWord = content.replaceAll("天气", "").trim();
if ("".equals(keyWord)||"7".equals(keyWord)) {
StringBuffer buffer = new StringBuffer();
// 接收用户发送的文本消息内容
buffer.append("发送天气+城市，例如'天气广州'").append("\n");
textMessage.setContent(buffer.toString());
respMessage = MessageUtil.textMessageToXml(textMessage);
} else {
Map<String, Object> map = new HashMap<String, Object>();
Map<String, Object> map2 = new HashMap<String, Object>();
try{
String filepach = request.getRealPath("/");
Weather util = new Weather();
map = util.report(keyWord,filepach);
map2 = util.report2(keyWord,filepach);
}catch (Exception e) {
e.printStackTrace();
StringBuffer buffer = new StringBuffer();
// 接收用户发送的文本消息内容
buffer.append("发送天气+城市，例如'天气广州'").append("\n");
textMessage.setContent(buffer.toString());
respMessage = MessageUtil.textMessageToXml(textMessage);
return respMessage;
}

List<Article> articleList = new ArrayList<Article>();
// 创建图文消息
NewsMessage newsMessage = new NewsMessage();
newsMessage.setToUserName(fromUserName);
newsMessage.setFromUserName(toUserName);
newsMessage.setCreateTime(new Date().getTime());
newsMessage.setMsgType(MessageUtil.RESP_MESSAGE_TYPE_NEWS);
newsMessage.setFuncFlag(0);

// Properties prop = new Properties();
// InputStream inStream = CoreService.class
// .getResourceAsStream("/messages.properties");
// try {
// prop.load(inStream);
// inStream.close();
// } catch (IOException e) {
// e.printStackTrace();
// }
// String picurl = prop.getProperty("picurl");

Article article1 = new Article();
article1.setTitle("【"+content.substring(2)+"】天气实况 气温:"+map2.get("temp")+"度 风速:"+map2.get("WD")+" "+map2.get("WS")+" 湿度:"+map2.get("SD") );
article1.setDescription("");
// article1.setPicUrl(picurl+"/image/khdxz2.jpg");
article1.setPicUrl("");
article1.setUrl("");


Article article2 = new Article();
article2.setTitle("建议："+map.get("index_d"));
article2.setDescription("");
article2.setPicUrl("");
article2.setUrl("");

Article article3 = new Article();
article3.setTitle(map.get("mydate1")+" "+map.get("myweek1")+" "+map.get("temp1")+" "+map.get("weather1")+" "+map.get("wind1")+" "+map.get("fl1"));
article3.setDescription("");
article3.setPicUrl("http://m.weather.com.cn/img/b"+map.get("img1")+".gif");
article3.setUrl("");


Article article4 = new Article();
article4.setTitle(map.get("mydate2")+" "+map.get("myweek2")+" "+map.get("temp2")+" "+map.get("weather2")+" "+map.get("wind2")+" "+map.get("fl2"));
article4.setDescription("");
article4.setPicUrl("http://m.weather.com.cn/img/b"+map.get("img2")+".gif");
article4.setUrl("");

Article article5 = new Article();
article5.setTitle(map.get("mydate3")+" "+map.get("myweek3")+" "+map.get("temp3")+" "+map.get("weather3")+" "+map.get("wind3")+" "+map.get("fl3"));
article5.setDescription("");
article5.setPicUrl("http://m.weather.com.cn/img/b"+map.get("img3")+".gif");
article5.setUrl("");


articleList.add(article1);
articleList.add(article2);
articleList.add(article3);
articleList.add(article4);
articleList.add(article5);
newsMessage.setArticleCount(articleList.size());
newsMessage.setArticles(articleList);
respMessage = MessageUtil.newsMessageToXml(newsMessage);
}

}
}
// 图片消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_IMAGE)) {
respContent = "您发送的是图片消息！";
}
// 地理位置消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LOCATION)) {
respContent = "您发送的是地理位置消息！";
}
// 链接消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_LINK)) {
respContent = "您发送的是链接消息！";
}
// 音频消息
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_VOICE)) {
respContent = "您发送的是音频消息！";
}
// 事件推送
else if (msgType.equals(MessageUtil.REQ_MESSAGE_TYPE_EVENT)) {
// 事件类型
String eventType = requestMap.get("Event");
// 订阅
if (eventType.equals(MessageUtil.EVENT_TYPE_SUBSCRIBE)) {
respContent = "谢谢您的关注！回复\"?\"进入主菜单。";
textMessage.setContent(respContent);
respMessage = MessageUtil.textMessageToXml(textMessage);
}
// 取消订阅
else if (eventType.equals(MessageUtil.EVENT_TYPE_UNSUBSCRIBE)) {
// TODO 取消订阅后用户再收不到公众号发送的消息，因此不需要回复消息
}
// 自定义菜单点击事件
else if (eventType.equals(MessageUtil.EVENT_TYPE_CLICK)) {
// TODO 自定义菜单权没有开放，暂不处理该类消息
String EventKey = requestMap.get("EventKey");
if("jeecg.name".equals(EventKey)){
respContent = "作者：张代浩 (scott)\n 邮箱：[e-mail] \n ：129190229";
textMessage.setContent(respContent);
respMessage = MessageUtil.textMessageToXml(textMessage);
}
if("翻译".equals(EventKey)){
respContent = getTranslateUsage();
textMessage.setContent(respContent);
respMessage = MessageUtil.textMessageToXml(textMessage);
}

}
}


} catch (Exception e) {
e.printStackTrace();
}


return respMessage;
}


/**
* 欢迎语
* @return
*/
public static String getMainMenu() {

// 复杂字符串文本读取，采用文件方式存储
String html = new FreemarkerHelper().parseTemplate("/text/welcome.ftl", null);
return html;
}



/**
* Q译通使用指南
*
* @return
*/
public static String getTranslateUsage() {
StringBuffer buffer = new StringBuffer();
buffer.append("微译使用指南").append("\n\n");
buffer.append("微译为用户提供专业的多语言翻译服务，目前支持以下翻译方向：").append("\n");
buffer.append(" 中 -> 英").append("\n");
buffer.append(" 英 -> 中").append("\n");
buffer.append(" 日 -> 中").append("\n\n");
buffer.append("使用示例：").append("\n");
buffer.append(" 翻译我是中国人").append("\n");
buffer.append(" 翻译dream").append("\n");
buffer.append(" 翻译さようなら").append("\n\n");
buffer.append("回复“?”显示主菜单");
return buffer.toString();
}

}

去123123