JFinal Weixin 是基于 JFinal 的微信公众号极速开发 SDK

/** * Copyright (c) 2011-2014, James Zhan 詹波 (jfinal@126.com). * * Licensed under the Apache License, Version 2.0 (the "License"); */ package com.jfinal.weixin.sdk.msg; import java.util.ArrayList; import java.util.List; import org.w3c.dom.Node; import org.w3c.dom.NodeList; import com.jfinal.kit.LogKit; import com.jfinal.kit.StrKit; import com.jfinal.weixin.iot.msg.InEquDataMsg; import com.jfinal.weixin.iot.msg.InEqubindEvent; import com.jfinal.weixin.sdk.msg.in.InImageMsg; import com.jfinal.weixin.sdk.msg.in.InLinkMsg; import com.jfinal.weixin.sdk.msg.in.InLocationMsg; import com.jfinal.weixin.sdk.msg.in.InMsg; import com.jfinal.weixin.sdk.msg.in.InNotDefinedMsg; import com.jfinal.weixin.sdk.msg.in.InShortVideoMsg; import com.jfinal.weixin.sdk.msg.in.InTextMsg; import com.jfinal.weixin.sdk.msg.in.InVideoMsg; import com.jfinal.weixin.sdk.msg.in.InVoiceMsg; import com.jfinal.weixin.sdk.msg.in.card.InCardPassCheckEvent; import com.jfinal.weixin.sdk.msg.in.card.InCardPayOrderEvent; import com.jfinal.weixin.sdk.msg.in.card.InCardSkuRemindEvent; import com.jfinal.weixin.sdk.msg.in.card.InMerChantOrderEvent; import com.jfinal.weixin.sdk.msg.in.card.InUpdateMemberCardEvent; import com.jfinal.weixin.sdk.msg.in.card.InUserCardEvent; import com.jfinal.weixin.sdk.msg.in.card.InUserConsumeCardEvent; import com.jfinal.weixin.sdk.msg.in.card.InUserGetCardEvent; import com.jfinal.weixin.sdk.msg.in.card.InUserGiftingCardEvent; import com.jfinal.weixin.sdk.msg.in.card.InUserPayFromCardEvent; import com.jfinal.weixin.sdk.msg.in.event.InCustomEvent; import com.jfinal.weixin.sdk.msg.in.event.InFollowEvent; import com.jfinal.weixin.sdk.msg.in.event.InLocationEvent; import com.jfinal.weixin.sdk.msg.in.event.InMassEvent; import com.jfinal.weixin.sdk.msg.in.event.InMenuEvent; import com.jfinal.weixin.sdk.msg.in.event.InNotDefinedEvent; import com.jfinal.weixin.sdk.msg.in.event.InPoiCheckNotifyEvent; import com.jfinal.weixin.sdk.msg.in.event.InQrCodeEvent; import com.jfinal.weixin.sdk.msg.in.event.InShakearoundUserShakeEvent; import com.jfinal.weixin.sdk.msg.in.event.InShakearoundUserShakeEvent.AroundBeacon; import com.jfinal.weixin.sdk.msg.in.event.InTemplateMsgEvent; import com.jfinal.weixin.sdk.msg.in.event.InVerifyFailEvent; import com.jfinal.weixin.sdk.msg.in.event.InVerifySuccessEvent; import com.jfinal.weixin.sdk.msg.in.event.InWifiEvent; import com.jfinal.weixin.sdk.msg.in.event.ScanCodeInfo; import com.jfinal.weixin.sdk.msg.in.speech_recognition.InSpeechRecognitionResults; import com.jfinal.weixin.sdk.utils.XmlHelper; public class InMsgParser { private InMsgParser() {} /** * 从 xml 中解析出各类消息与事件 * @param xml xml字符串 * @return {InMsg} */ public static InMsg parse(String xml) { XmlHelper xmlHelper = XmlHelper.of(xml); return doParse(xmlHelper); } /** * 消息类型 * 1：text 文本消息 * 2：image 图片消息 * 3：voice 语音消息 * 4：video 视频消息 * shortvideo 小视频消息 * 5：location 地址位置消息 * 6：link 链接消息 * 7：event 事件 */ private static InMsg doParse(XmlHelper xmlHelper) { String toUserName = xmlHelper.getString("//ToUserName"); String fromUserName = xmlHelper.getString("//FromUserName"); Integer createTime = xmlHelper.getNumber("//CreateTime").intValue(); String msgType = xmlHelper.getString("//MsgType"); if ("text".equals(msgType)) return parseInTextMsg(xmlHelper, toUserName, fromUserName, createTime, msgType); if ("image".equals(msgType)) return parseInImageMsg(xmlHelper, toUserName, fromUserName, createTime, msgType); if ("voice".equals(msgType)) return parseInVoiceMsgAndInSpeechRecognitionResults(xmlHelper, toUserName, fromUserName, createTime, msgType); if ("video".equals(msgType)) return parseInVideoMsg(xmlHelper, toUserName, fromUserName, createTime, msgType); if ("shortvideo".equals(msgType)) //支持小视频 return parseInShortVideoMsg(xmlHelper, toUserName, fromUserName, createTime, msgType); if ("location".equals(msgType)) return parseInLocationMsg(xmlHelper, toUserName, fromUserName, createTime, msgType); if ("link".equals(msgType)) return parseInLinkMsg(xmlHelper, toUserName, fromUserName, createTime, msgType); if ("event".equals(msgType)) return parseInEvent(xmlHelper, toUserName, fromUserName, createTime, msgType); if (InEqubindEvent.DEVICE_EVENT.equals(msgType)) //微信硬件 绑定和解绑事件 return parseInDeviceEvent(xmlHelper, toUserName, fromUserName, createTime, msgType); if (InEquDataMsg.DEVICE_TEXT.equals(msgType)) //微信硬件 接收数据 return parseInDeviceData(xmlHelper, toUserName, fromUserName, createTime, msgType); LogKit.error("无法识别的消息类型 " + msgType + "，请查阅微信公众平台开发文档"); return parseInNotDefinedMsg(xmlHelper, toUserName, fromUserName, createTime, msgType); } private static InMsg parseInNotDefinedMsg(XmlHelper xmlHelper, String toUserName, String fromUserName, Integer createTime, String msgType) { InNotDefinedMsg msg = new InNotDefinedMsg(toUserName, fromUserName, createTime, msgType); msg.setXmlHelper(xmlHelper); return msg; } private static InMsg parseInTextMsg(XmlHelper xmlHelper, String toUserName, String fromUserName, Integer createTime, String msgType) { InTextMsg msg = new InTextMsg(toUserName, fromUserName, createTime, msgType); msg.setContent(xmlHelper.getString("//Content")); msg.setMsgId(xmlHelper.getString("//MsgId")); return msg; } private static InMsg parseInImageMsg(XmlHelper xmlHelper, String toUserName, String fromUserName, Integer createTime, String msgType) { InImageMsg msg = new InImageMsg(toUserName, fromUserName, createTime, msgType); msg.setPicUrl(xmlHelper.getString("//PicUrl")); msg.setMediaId(xmlHelper.getString("//MediaId")); msg.setMsgId(xmlHelper.getString("//MsgId")); return msg; } private static InMsg parseInVoiceMsgAndInSpeechRecognitionResults(XmlHelper xmlHelper, String toUserName, String fromUserName, Integer createTime, String msgType) { String recognition = xmlHelper.getString("//Recognition"); String mediaId = xmlHelper.getString("//MediaId"); String format = xmlHelper.getString("//Format"); String msgId = xmlHelper.getString("//MsgId"); if (StrKit.isBlank(recognition)) { InVoiceMsg msg = new InVoiceMsg(toUserName, fromUserName, createTime, msgType); msg.setMediaId(mediaId); msg.setFormat(format); msg.setMsgId(msgId); return msg; } else { InSpeechRecognitionResults msg = new InSpeechRecognitionResults(toUserName, fromUserName, createTime, msgType); msg.setMediaId(mediaId); msg.setFormat(format); msg.setMsgId(msgId); // 与 InVoiceMsg 唯一的不同之处 msg.setRecognition(recognition); return msg; } } private static InMsg parseInVideoMsg(XmlHelper xmlHelper, String toUserName, String fromUserName, Integer createTime, String msgType) { InVideoMsg msg = new InVideoMsg(toUserName, fromUserName, createTime, msgType); msg.setMediaId(xmlHelper.getString("//MediaId")); msg.setThumbMediaId(xmlHelper.getString("//ThumbMediaId")); msg.setMsgId(xmlHelper.getString("//MsgId")); return msg; } private static InMsg parseInShortVideoMsg(XmlHelper xmlHelper, String toUserName, String fromUserName, Integer createTime, String msgType) { InShortVideoMsg msg = new InShortVideoMsg(toUserName, fromUserName, createTi