From 76ea7fe2a8097f77cc9436a22324b31a11e6192d Mon Sep 17 00:00:00 2001 From: dany1 Date: Mon, 3 Jan 2022 23:15:31 +0800 Subject: [PATCH] =?UTF-8?q?:art:=20#2477=20=E3=80=90=E5=B0=8F=E7=A8=8B?= =?UTF-8?q?=E5=BA=8F=E3=80=91=E5=A2=9E=E5=8A=A0=E8=AE=A2=E9=98=85=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E9=80=9A=E7=9F=A5=E4=BA=8B=E4=BB=B6=E7=9A=84=E7=9B=B8?= =?UTF-8?q?=E5=85=B3=E5=B1=9E=E6=80=A7=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../wx/miniapp/bean/WxMaMessage.java | 48 ++++- .../miniapp/bean/WxMaSubscribeMsgEvent.java | 118 ++++++++++++ .../wx/miniapp/json/WxMaGsonBuilder.java | 2 + .../WxMaSubscribeMsgEventJsonAdapter.java | 104 ++++++++++ .../wx/miniapp/bean/WxMaMessageTest.java | 179 ++++++++++++++++++ 5 files changed, 450 insertions(+), 1 deletion(-) create mode 100644 weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/bean/WxMaSubscribeMsgEvent.java create mode 100644 weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/json/adaptor/WxMaSubscribeMsgEventJsonAdapter.java diff --git a/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/bean/WxMaMessage.java b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/bean/WxMaMessage.java index 4a8713cad..76017659f 100644 --- a/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/bean/WxMaMessage.java +++ b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/bean/WxMaMessage.java @@ -11,6 +11,7 @@ import lombok.Data; import me.chanjar.weixin.common.error.WxRuntimeException; import me.chanjar.weixin.common.util.xml.XStreamCDataConverter; import org.apache.commons.io.IOUtils; +import org.apache.commons.lang3.StringUtils; import java.io.IOException; import java.io.InputStream; @@ -165,6 +166,39 @@ public class WxMaMessage implements Serializable { @XStreamConverter(value = XStreamCDataConverter.class) private String openPid; + @XStreamAlias("SubscribeMsgPopupEvent") + private WxMaSubscribeMsgEvent.SubscribeMsgPopupEvent subscribeMsgPopupEvent; + + @XStreamAlias("SubscribeMsgChangeEvent") + private WxMaSubscribeMsgEvent.SubscribeMsgChangeEvent subscribeMsgChangeEvent; + + @XStreamAlias("SubscribeMsgSentEvent") + private WxMaSubscribeMsgEvent.SubscribeMsgSentEvent subscribeMsgSentEvent; + + /** + * 不要直接使用这个字段， + * 这个字段只是为了适配 SubscribeMsgPopupEvent SubscribeMsgChangeEvent SubscribeMsgSentEvent + * 在json里面名称都是List并且有时候是对象有时候是数组的问题 + * 当List只有一个对象的时候，微信服务器推送过来的的List是对象而非数组，当有多个对象的时候推送过来的才是数组 + * 当只有一个对象的时候 + * "List": { + * "TemplateId": "hD-ixGOhYmUfjOnI8MCzQMPshzGVeux_2vzyvQu7O68", + * "SubscribeStatusString": "accept", + * "PopupScene": "0" + * } + * 当有多条数据的时候 + * "List": [ { + * "TemplateId": "hD-ixGOhYmUfjOnI8MCzQMPshzGVeux_2vzyvQu7O68", + * "SubscribeStatusString": "accept", + * "PopupScene": "0" + * }, { + * "TemplateId": "hD-ixGOhYmUfjOnI8MCzQMPshzGVeux_2vzyvQu7O68", + * "SubscribeStatusString": "accept", + * "PopupScene": "0" + * }] + */ + @SerializedName("List") + private WxMaSubscribeMsgEvent.WxMaSubscribeMsgEventJson uselessMsg; public static WxMaMessage fromXml(String xml) { return XStreamTransformer.fromXml(WxMaMessage.class, xml); @@ -201,7 +235,19 @@ public class WxMaMessage implements Serializable { } public static WxMaMessage fromJson(String json) { - return WxMaGsonBuilder.create().fromJson(json, WxMaMessage.class); + WxMaMessage message = WxMaGsonBuilder.create().fromJson(json, WxMaMessage.class); + // 在这里处理 event的json格式时候的 list 问题，让json和xml的程序接口可以保持一致， 详见 uselessMsg 字段的注释 + if (message.getUselessMsg() != null) { + if (StringUtils.equals(message.getEvent(), "subscribe_msg_popup_event")) { + message.setSubscribeMsgPopupEvent(message.getUselessMsg().getPopupEvents()); + } else if (StringUtils.equals(message.getEvent(), "subscribe_msg_change_event")) { + message.setSubscribeMsgChangeEvent(message.getUselessMsg().getChangeEvents()); + } else if (StringUtils.equals(message.getEvent(), "subscribe_msg_sent_event")) { + message.setSubscribeMsgSentEvent(message.getUselessMsg().getSentEvent()); + } + message.setUselessMsg(null); + } + return message; } public static WxMaMessage fromEncryptedJson(String encryptedJson, WxMaConfig config) { diff --git a/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/bean/WxMaSubscribeMsgEvent.java b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/bean/WxMaSubscribeMsgEvent.java new file mode 100644 index 000000000..2191dd838 --- /dev/null +++ b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/bean/WxMaSubscribeMsgEvent.java @@ -0,0 +1,118 @@ +package cn.binarywang.wx.miniapp.bean; + +import com.thoughtworks.xstream.annotations.XStreamAlias; +import com.thoughtworks.xstream.annotations.XStreamConverter; +import com.thoughtworks.xstream.annotations.XStreamImplicit; +import lombok.Data; +import me.chanjar.weixin.common.util.xml.XStreamCDataConverter; + +import java.io.Serializable; +import java.util.LinkedList; +import java.util.List; + +/** + * WxMaSubscribeMsgEvent class + * 客户端订阅，服务端收到的通知 + * @author dany + * @date 2021/12/31 + */ +public class WxMaSubscribeMsgEvent { + /** + * https://developers.weixin.qq.com/miniprogram/dev/framework/open-ability/subscribe-message.html + */ + @Data + @XStreamAlias("SubscribeMsgPopupEvent") + public static class SubscribeMsgPopupEvent implements Serializable { + private static final long serialVersionUID = 6319723189257161326L; + @XStreamImplicit(itemFieldName = "List") + private List list = new LinkedList<>(); + } + + @Data + @XStreamAlias("SubscribeMsgChangeEvent") + public static class SubscribeMsgChangeEvent implements Serializable { + private static final long serialVersionUID = 7705686111539437751L; + @XStreamImplicit(itemFieldName = "List") + private List list = new LinkedList<>(); + } + + @Data + @XStreamAlias("SubscribeMsgSentEvent") + public static class SubscribeMsgSentEvent implements Serializable { + private static final long serialVersionUID = 7705686111539437751L; + @XStreamAlias("List") + private SentEvent list; + } + + + @Data + public static class PopupEvent implements Serializable { + private static final long serialVersionUID = 4934029303241387226L; + /** + * 模板id + */ + @XStreamAlias("TemplateId") + @XStreamConverter(value = XStreamCDataConverter.class) + private String templateId; + /** + * 订阅结果（accept接收；reject拒收） + */ + @XStreamAlias("SubscribeStatusString") + @XStreamConverter(value = XStreamCDataConverter.class) + private String subscribeStatusString; + /** + * 弹框场景，0代表在小程序页面内 + */ + @XStreamAlias("PopupScene") + private String popupScene; + } + + @Data + public static class ChangeEvent implements Serializable { + private static final long serialVersionUID = 1523634146232757624L; + /** + * 模板id + */ + @XStreamAlias("TemplateId") + @XStreamConverter(value = XStreamCDataConverter.class) + private String templateId; + /** + * 订阅结果（accept接收；reject拒收） + */ + @XStreamAlias("SubscribeStatusString") + @XStreamConverter(value = XStreamCDataConverter.class) + private String subscribeStatusString; + } + + @Data + public static class SentEvent implements Serializable { + private static final long serialVersionUID = -8734478345463177940L; + /** + * 模板id + */ + @XStreamAlias("TemplateId") + @XStreamConverter(value = XStreamCDataConverter.class) + private String templateId; + + @XStreamAlias("MsgID") + private String msgId; + + @XStreamAlias("ErrorCode") + private String errorCode; + + @XStreamAlias("ErrorStatus") + @XStreamConverter(value = XStreamCDataConverter.class) + private String errorStatus; + } + + @Data + public static class WxMaSubscribeMsgEventJson implements Serializable { + private static final long serialVersionUID = -4820758280837190275L; + + private SubscribeMsgPopupEvent popupEvents; + + private SubscribeMsgChangeEvent changeEvents; + + private SubscribeMsgSentEvent sentEvent; + } +} diff --git a/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/json/WxMaGsonBuilder.java b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/json/WxMaGsonBuilder.java index e6f6842fa..0918935ee 100644 --- a/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/json/WxMaGsonBuilder.java +++ b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/json/WxMaGsonBuilder.java @@ -1,6 +1,7 @@ package cn.binarywang.wx.miniapp.json; import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage; +import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMsgEvent; import cn.binarywang.wx.miniapp.bean.WxMaUniformMessage; import cn.binarywang.wx.miniapp.bean.analysis.WxMaRetainInfo; import cn.binarywang.wx.miniapp.bean.analysis.WxMaUserPortrait; @@ -26,6 +27,7 @@ public class WxMaGsonBuilder { INSTANCE.registerTypeAdapter(WxMaVisitDistribution.class, new WxMaVisitDistributionGsonAdapter()); INSTANCE.registerTypeAdapter(WxMaRetainInfo.class, new WxMaRetainInfoGsonAdapter()); INSTANCE.registerTypeAdapter(WxMaUserPortrait.class, new WxMaUserPortraitGsonAdapter()); + INSTANCE.registerTypeAdapter(WxMaSubscribeMsgEvent.WxMaSubscribeMsgEventJson.class, new WxMaSubscribeMsgEventJsonAdapter()); } public static Gson create() { diff --git a/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/json/adaptor/WxMaSubscribeMsgEventJsonAdapter.java b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/json/adaptor/WxMaSubscribeMsgEventJsonAdapter.java new file mode 100644 index 000000000..d489f14a7 --- /dev/null +++ b/weixin-java-miniapp/src/main/java/cn/binarywang/wx/miniapp/json/adaptor/WxMaSubscribeMsgEventJsonAdapter.java @@ -0,0 +1,104 @@ +package cn.binarywang.wx.miniapp.json.adaptor; + +import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMsgEvent; +import com.google.gson.JsonArray; +import com.google.gson.JsonDeserializationContext; +import com.google.gson.JsonDeserializer; +import com.google.gson.JsonElement; +import com.google.gson.JsonObject; +import com.google.gson.JsonParseException; +import lombok.extern.slf4j.Slf4j; + +import java.lang.reflect.Type; + +/** + * WxMaSubscribeMsgEventJsonAdapter class + * + * @author dany + * @date 2021/12/31 + */ +@Slf4j +public class WxMaSubscribeMsgEventJsonAdapter implements JsonDeserializer { + @Override + public WxMaSubscribeMsgEvent.WxMaSubscribeMsgEventJson deserialize(JsonElement json, Type typeOfT, JsonDeserializationContext context) throws JsonParseException { + WxMaSubscribeMsgEvent.WxMaSubscribeMsgEventJson result = new WxMaSubscribeMsgEvent.WxMaSubscribeMsgEventJson(); + if (json.isJsonArray()) { + JsonArray array = json.getAsJsonArray(); + if (array.size() > 0) { + JsonObject obj = array.get(0).getAsJsonObject(); + MsgEventTypeEnum eventType = detectMsgEventType(obj); + for (int i = 0; i < array.size(); ++i) { + obj = array.get(i).getAsJsonObject(); + setField(result, eventType, obj); + } + } + } else { + JsonObject obj = json.getAsJsonObject(); + MsgEventTypeEnum eventType = detectMsgEventType(obj); + setField(result, eventType, obj); + } + return result; + } + + public enum MsgEventTypeEnum { + EVENT_POPUP,EVENT_CHANGE,EVENT_SENT; + } + private MsgEventTypeEnum detectMsgEventType(JsonObject obj) { + JsonElement popupScene = obj.get("PopupScene"); + if (popupScene != null) { + return MsgEventTypeEnum.EVENT_POPUP; + } + + JsonElement msgId = obj.get("MsgID"); + if (msgId != null) { + return MsgEventTypeEnum.EVENT_SENT; + } + JsonElement errorCode = obj.get("ErrorCode"); + if (errorCode != null) { + return MsgEventTypeEnum.EVENT_SENT; + } + JsonElement errorStatus = obj.get("ErrorStatus"); + if (errorStatus != null) { + return MsgEventTypeEnum.EVENT_SENT; + } + + return MsgEventTypeEnum.EVENT_CHANGE; + } + + private WxMaSubscribeMsgEvent.WxMaSubscribeMsgEventJson setField(WxMaSubscribeMsgEvent.WxMaSubscribeMsgEventJson target, + MsgEventTypeEnum eventType, JsonObject json) { + switch (eventType) { + case EVENT_POPUP: + if (target.getPopupEvents() == null) { + target.setPopupEvents(new WxMaSubscribeMsgEvent.SubscribeMsgPopupEvent()); + } + WxMaSubscribeMsgEvent.PopupEvent popupEvent = new WxMaSubscribeMsgEvent.PopupEvent(); + popupEvent.setTemplateId(json.get("TemplateId").getAsString()); + popupEvent.setSubscribeStatusString(json.get("SubscribeStatusString").getAsString()); + popupEvent.setPopupScene(json.get("PopupScene").getAsString()); + target.getPopupEvents().getList().add(popupEvent); + break; + case EVENT_CHANGE: + if (target.getChangeEvents() == null) { + target.setChangeEvents(new WxMaSubscribeMsgEvent.SubscribeMsgChangeEvent()); + } + WxMaSubscribeMsgEvent.ChangeEvent changeEvent = new WxMaSubscribeMsgEvent.ChangeEvent(); + changeEvent.setTemplateId(json.get("TemplateId").getAsString()); + changeEvent.setSubscribeStatusString(json.get("SubscribeStatusString").getAsString()); + target.getChangeEvents().getList().add(changeEvent); + break; + case EVENT_SENT: + if (target.getSentEvent() == null) { + target.setSentEvent(new WxMaSubscribeMsgEvent.SubscribeMsgSentEvent()); + } + WxMaSubscribeMsgEvent.SentEvent sentEvent = new WxMaSubscribeMsgEvent.SentEvent(); + sentEvent.setTemplateId(json.get("TemplateId").getAsString()); + sentEvent.setMsgId(json.get("MsgID").getAsString()); + sentEvent.setErrorCode(json.get("ErrorCode").getAsString()); + sentEvent.setErrorStatus(json.get("ErrorStatus").getAsString()); + target.getSentEvent().setList(sentEvent); + break; + } + return target; + } +} diff --git a/weixin-java-miniapp/src/test/java/cn/binarywang/wx/miniapp/bean/WxMaMessageTest.java b/weixin-java-miniapp/src/test/java/cn/binarywang/wx/miniapp/bean/WxMaMessageTest.java index 26855b36e..126973484 100644 --- a/weixin-java-miniapp/src/test/java/cn/binarywang/wx/miniapp/bean/WxMaMessageTest.java +++ b/weixin-java-miniapp/src/test/java/cn/binarywang/wx/miniapp/bean/WxMaMessageTest.java @@ -4,6 +4,7 @@ import me.chanjar.weixin.common.api.WxConsts; import org.testng.annotations.Test; import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertNotNull; /** * @author Binary Wang @@ -47,4 +48,182 @@ public class WxMaMessageTest { assertEquals(wxMessage.getSessionFrom(), "sessionFrom"); } + public void testSubscribeMsgPopupEvent() { + // xml 格式 + String xml = "" + + "\n" + + "\n" + + "1610969440\n" + + "\n" + + "\n" + + "\n" + + " \n" + + " \n" + + " \n" + + " 0\n" + + " \n" + + "" + + ""; + + WxMaMessage wxMessage = WxMaMessage.fromXml(xml); + checkSubscribeMsgPopupEvent(wxMessage); + + // 订阅单个模板 json格式 (对象） + String json = "{\n" + + " \"ToUserName\": \"gh_123456789abc\",\n" + + " \"FromUserName\": \"otFpruAK8D-E6EfStSYonYSBZ8_4\",\n" + + " \"CreateTime\": \"1610969440\",\n" + + " \"MsgType\": \"event\",\n" + + " \"Event\": \"subscribe_msg_popup_event\",\n" + + " \"List\": {\n" + + " \"TemplateId\": \"VRR0UEO9VJOLs0MHlU0OilqX6MVFDwH3_3gz3Oc0NIc\",\n" + + " \"SubscribeStatusString\": \"accept\",\n" + + " \"PopupScene\": \"0\"\n" + + " }\n" + + " }"; + wxMessage = WxMaMessage.fromJson(json); + checkSubscribeMsgPopupEvent(wxMessage); + // 订阅多条模板的 json格式（数组） + json = "{\n" + + " \"ToUserName\": \"gh_123456789abc\",\n" + + " \"FromUserName\": \"otFpruAK8D-E6EfStSYonYSBZ8_4\",\n" + + " \"CreateTime\": \"1610969440\",\n" + + " \"MsgType\": \"event\",\n" + + " \"Event\": \"subscribe_msg_popup_event\",\n" + + " \"List\": [{\n" + + " \"TemplateId\": \"VRR0UEO9VJOLs0MHlU0OilqX6MVFDwH3_3gz3Oc0NIc\",\n" + + " \"SubscribeStatusString\": \"accept\",\n" + + " \"PopupScene\": \"0\"\n" + + " }]\n" + + " }"; + wxMessage = WxMaMessage.fromJson(json); + checkSubscribeMsgPopupEvent(wxMessage); + } + + private void checkSubscribeMsgPopupEvent(WxMaMessage wxMessage) { + assertEquals(wxMessage.getToUser(), "gh_123456789abc"); + assertEquals(wxMessage.getFromUser(), "otFpruAK8D-E6EfStSYonYSBZ8_4"); + assertEquals(wxMessage.getCreateTime(),new Integer(1610969440)); + assertEquals(wxMessage.getMsgType(), WxConsts.XmlMsgType.EVENT); + assertEquals(wxMessage.getEvent(), "subscribe_msg_popup_event"); + assertEquals(wxMessage.getSubscribeMsgPopupEvent().getList().size(), 1); + WxMaSubscribeMsgEvent.PopupEvent event = wxMessage.getSubscribeMsgPopupEvent().getList().get(0); + assertEquals(event.getTemplateId(), "VRR0UEO9VJOLs0MHlU0OilqX6MVFDwH3_3gz3Oc0NIc"); + assertEquals(event.getSubscribeStatusString(),"accept"); + assertEquals(event.getPopupScene(), "0"); + } + + public void testSubscribeMsgChangeEvent() { + // xml 格式 + String xml = "\n" + + " \n" + + " \n" + + " 1610968440\n" + + " \n" + + " \n" + + " \n" + + " " + + " \n" + + " \n" + + " \n" + + " \n" + + ""; + + WxMaMessage wxMessage = WxMaMessage.fromXml(xml); + checkSubscribeMsgChangeEvent(wxMessage); + + // json格式 (对象） + String json = "{\n" + + " \"ToUserName\": \"gh_123456789abc\",\n" + + " \"FromUserName\": \"o7esq5OI1Uej6Xixw1lA2H7XDVbc\",\n" + + " \"CreateTime\": \"1610968440\",\n" + + " \"MsgType\": \"event\",\n" + + " \"Event\": \"subscribe_msg_change_event\",\n" + + " \"List\": {\n" + + " \"TemplateId\":\"BEwX0BOT3MqK3Uc5oTU3CGBqzjpndk2jzUf7VfExd8\",\n" + + " \"SubscribeStatusString\": \"reject\"\n" + + " }\n" + + "}\n"; + wxMessage = WxMaMessage.fromJson(json); + checkSubscribeMsgChangeEvent(wxMessage); + // json格式（数组） + json = "{\n" + + " \"ToUserName\": \"gh_123456789abc\",\n" + + " \"FromUserName\": \"o7esq5OI1Uej6Xixw1lA2H7XDVbc\",\n" + + " \"CreateTime\": \"1610968440\",\n" + + " \"MsgType\": \"event\",\n" + + " \"Event\": \"subscribe_msg_change_event\",\n" + + " \"List\": [ {\n" + + " \"TemplateId\":\"BEwX0BOT3MqK3Uc5oTU3CGBqzjpndk2jzUf7VfExd8\",\n" + + " \"SubscribeStatusString\": \"reject\"\n" + + " }]" + + "}"; + wxMessage = WxMaMessage.fromJson(json); + checkSubscribeMsgChangeEvent(wxMessage); + } + + private void checkSubscribeMsgChangeEvent(WxMaMessage wxMessage) { + assertEquals(wxMessage.getToUser(), "gh_123456789abc"); + assertEquals(wxMessage.getFromUser(), "o7esq5OI1Uej6Xixw1lA2H7XDVbc"); + assertEquals(wxMessage.getCreateTime(),new Integer(1610968440)); + assertEquals(wxMessage.getMsgType(), WxConsts.XmlMsgType.EVENT); + assertEquals(wxMessage.getEvent(), "subscribe_msg_change_event"); + assertEquals(wxMessage.getSubscribeMsgChangeEvent().getList().size(), 1); + WxMaSubscribeMsgEvent.ChangeEvent event = wxMessage.getSubscribeMsgChangeEvent().getList().get(0); + assertEquals(event.getTemplateId(), "BEwX0BOT3MqK3Uc5oTU3CGBqzjpndk2jzUf7VfExd8"); + assertEquals(event.getSubscribeStatusString(),"reject"); + } + + public void testSubscribeMsgSentEvent() { + // xml 格式 + String xml = "\n" + + " \n" + + " \n" + + " 1620963428\n" + + " \n" + + " \n" + + " \n" + + " " + + " \n" + + " 1864323726461255680\n" + + " 0\n" + + " \n" + + " \n" + + " \n" + + ""; + + WxMaMessage wxMessage = WxMaMessage.fromXml(xml); + checkSubscribeMsgSentEvent(wxMessage); + + // json格式 (对象） + String json = "{\n" + + " \"ToUserName\": \"gh_123456789abc\",\n" + + " \"FromUserName\": \"o7esq5PHRGBQYmeNyfG064wEFVpQ\",\n" + + " \"CreateTime\": \"1620963428\",\n" + + " \"MsgType\": \"event\",\n" + + " \"Event\": \"subscribe_msg_sent_event\",\n" + + " \"List\": {\n" + + " \"TemplateId\": \"BEwX0BO-T3MqK3Uc5oTU3CGBqzjpndk2jzUf7VfExd8\",\n" + + " \"MsgID\": \"1864323726461255680\",\n" + + " \"ErrorCode\": \"0\",\n" + + " \"ErrorStatus\": \"success\"\n" + + " }\n" + + "}"; + wxMessage = WxMaMessage.fromJson(json); + checkSubscribeMsgSentEvent(wxMessage); + } + private void checkSubscribeMsgSentEvent(WxMaMessage wxMessage) { + assertEquals(wxMessage.getToUser(), "gh_123456789abc"); + assertEquals(wxMessage.getFromUser(), "o7esq5PHRGBQYmeNyfG064wEFVpQ"); + assertEquals(wxMessage.getCreateTime(),new Integer(1620963428)); + assertEquals(wxMessage.getMsgType(), WxConsts.XmlMsgType.EVENT); + assertEquals(wxMessage.getEvent(), "subscribe_msg_sent_event"); + assertNotNull(wxMessage.getSubscribeMsgSentEvent()); + WxMaSubscribeMsgEvent.SentEvent event = wxMessage.getSubscribeMsgSentEvent().getList(); + assertEquals(event.getTemplateId(), "BEwX0BO-T3MqK3Uc5oTU3CGBqzjpndk2jzUf7VfExd8"); + assertEquals(event.getMsgId(),"1864323726461255680"); + assertEquals(event.getErrorCode(),"0"); + assertEquals(event.getErrorStatus(),"success"); + } + }