重构WxMpXmlMessage,修改fromUserName为fromUser,toUserName为toUser,避免不必要的歧义

This commit is contained in:
BinaryWang 2016-09-30 16:41:50 +08:00
parent 87ab934a1c
commit 5345a6d1f1
10 changed files with 40 additions and 55 deletions

View File

@ -171,7 +171,7 @@ public class WxMpMessageRouter {
} else { } else {
res = rule.service(wxMessage, this.wxMpService, this.sessionManager, this.exceptionHandler); res = rule.service(wxMessage, this.wxMpService, this.sessionManager, this.exceptionHandler);
// 在同步操作结束session访问结束 // 在同步操作结束session访问结束
this.log.debug("End session access: async=false, sessionId={}", wxMessage.getFromUserName()); this.log.debug("End session access: async=false, sessionId={}", wxMessage.getFromUser());
sessionEndAccess(wxMessage); sessionEndAccess(wxMessage);
} }
} }
@ -183,7 +183,7 @@ public class WxMpMessageRouter {
for (Future<?> future : futures) { for (Future<?> future : futures) {
try { try {
future.get(); future.get();
WxMpMessageRouter.this.log.debug("End session access: async=true, sessionId={}", wxMessage.getFromUserName()); WxMpMessageRouter.this.log.debug("End session access: async=true, sessionId={}", wxMessage.getFromUser());
// 异步操作结束session访问结束 // 异步操作结束session访问结束
sessionEndAccess(wxMessage); sessionEndAccess(wxMessage);
} catch (InterruptedException e) { } catch (InterruptedException e) {
@ -203,7 +203,7 @@ public class WxMpMessageRouter {
StringBuffer messageId = new StringBuffer(); StringBuffer messageId = new StringBuffer();
if (wxMessage.getMsgId() == null) { if (wxMessage.getMsgId() == null) {
messageId.append(wxMessage.getCreateTime()) messageId.append(wxMessage.getCreateTime())
.append("-").append(wxMessage.getFromUserName()) .append("-").append(wxMessage.getFromUser())
.append("-").append(wxMessage.getEventKey() == null ? "" : wxMessage.getEventKey()) .append("-").append(wxMessage.getEventKey() == null ? "" : wxMessage.getEventKey())
.append("-").append(wxMessage.getEvent() == null ? "" : wxMessage.getEvent()) .append("-").append(wxMessage.getEvent() == null ? "" : wxMessage.getEvent())
; ;
@ -221,7 +221,7 @@ public class WxMpMessageRouter {
*/ */
protected void sessionEndAccess(WxMpXmlMessage wxMessage) { protected void sessionEndAccess(WxMpXmlMessage wxMessage) {
InternalSession session = ((InternalSessionManager)this.sessionManager).findSession(wxMessage.getFromUserName()); InternalSession session = ((InternalSessionManager)this.sessionManager).findSession(wxMessage.getFromUser());
if (session != null) { if (session != null) {
session.endAccess(); session.endAccess();
} }

View File

@ -168,7 +168,7 @@ public class WxMpMessageRouterRule {
*/ */
protected boolean test(WxMpXmlMessage wxMessage) { protected boolean test(WxMpXmlMessage wxMessage) {
return return
(this.fromUser == null || this.fromUser.equals(wxMessage.getFromUserName())) (this.fromUser == null || this.fromUser.equals(wxMessage.getFromUser()))
&& &&
(this.msgType == null || this.msgType.toLowerCase().equals((wxMessage.getMsgType()==null?null:wxMessage.getMsgType().toLowerCase()))) (this.msgType == null || this.msgType.toLowerCase().equals((wxMessage.getMsgType()==null?null:wxMessage.getMsgType().toLowerCase())))
&& &&

View File

@ -40,11 +40,11 @@ public class WxMpXmlMessage implements Serializable {
@XStreamAlias("ToUserName") @XStreamAlias("ToUserName")
@XStreamConverter(value = XStreamCDataConverter.class) @XStreamConverter(value = XStreamCDataConverter.class)
private String toUserName; private String toUser;
@XStreamAlias("FromUserName") @XStreamAlias("FromUserName")
@XStreamConverter(value = XStreamCDataConverter.class) @XStreamConverter(value = XStreamCDataConverter.class)
private String fromUserName; private String fromUser;
@XStreamAlias("CreateTime") @XStreamAlias("CreateTime")
private Long createTime; private Long createTime;
@ -272,12 +272,12 @@ public class WxMpXmlMessage implements Serializable {
this.msg = msg; this.msg = msg;
} }
public String getToUserName() { public String getToUser() {
return this.toUserName; return this.toUser;
} }
public void setToUserName(String toUserName) { public void setToUser(String toUser) {
this.toUserName = toUserName; this.toUser = toUser;
} }
public Long getCreateTime() { public Long getCreateTime() {
@ -482,12 +482,12 @@ public class WxMpXmlMessage implements Serializable {
this.recognition = recognition; this.recognition = recognition;
} }
public String getFromUserName() { public String getFromUser() {
return this.fromUserName; return this.fromUser;
} }
public void setFromUserName(String fromUserName) { public void setFromUser(String fromUser) {
this.fromUserName = fromUserName; this.fromUser = fromUser;
} }
public static WxMpXmlMessage fromXml(String xml) { public static WxMpXmlMessage fromXml(String xml) {

View File

@ -195,7 +195,7 @@ public class WxMpMessageRouterTest {
.rule().async(false).handler(new WxSessionMessageHandler()).end(); .rule().async(false).handler(new WxSessionMessageHandler()).end();
WxMpXmlMessage msg = new WxMpXmlMessage(); WxMpXmlMessage msg = new WxMpXmlMessage();
msg.setFromUserName("abc"); msg.setFromUser("abc");
router.route(msg); router.route(msg);
Thread.sleep(2000l); Thread.sleep(2000l);
@ -215,7 +215,7 @@ public class WxMpMessageRouterTest {
.rule().async(true).handler(new WxSessionMessageHandler()).end(); .rule().async(true).handler(new WxSessionMessageHandler()).end();
WxMpXmlMessage msg = new WxMpXmlMessage(); WxMpXmlMessage msg = new WxMpXmlMessage();
msg.setFromUserName("abc"); msg.setFromUser("abc");
router.route(msg); router.route(msg);
Thread.sleep(2000l); Thread.sleep(2000l);
@ -229,7 +229,7 @@ public class WxMpMessageRouterTest {
.rule().async(false).handler(new WxSessionMessageHandler()).end(); .rule().async(false).handler(new WxSessionMessageHandler()).end();
WxMpXmlMessage msg = new WxMpXmlMessage(); WxMpXmlMessage msg = new WxMpXmlMessage();
msg.setFromUserName("abc"); msg.setFromUser("abc");
router.route(msg); router.route(msg);
Thread.sleep(2000l); Thread.sleep(2000l);
@ -249,7 +249,7 @@ public class WxMpMessageRouterTest {
.rule().async(true).handler(new WxSessionMessageHandler()).end(); .rule().async(true).handler(new WxSessionMessageHandler()).end();
WxMpXmlMessage msg = new WxMpXmlMessage(); WxMpXmlMessage msg = new WxMpXmlMessage();
msg.setFromUserName("abc"); msg.setFromUser("abc");
router.route(msg); router.route(msg);
Thread.sleep(2000l); Thread.sleep(2000l);
@ -268,7 +268,7 @@ public class WxMpMessageRouterTest {
.rule().async(false).handler(new WxSessionMessageHandler()).end(); .rule().async(false).handler(new WxSessionMessageHandler()).end();
WxMpXmlMessage msg = new WxMpXmlMessage(); WxMpXmlMessage msg = new WxMpXmlMessage();
msg.setFromUserName("abc"); msg.setFromUser("abc");
router.route(msg); router.route(msg);
Thread.sleep(2000l); Thread.sleep(2000l);
@ -282,7 +282,7 @@ public class WxMpMessageRouterTest {
.rule().async(true).handler(new WxSessionMessageHandler()).end(); .rule().async(true).handler(new WxSessionMessageHandler()).end();
WxMpXmlMessage msg = new WxMpXmlMessage(); WxMpXmlMessage msg = new WxMpXmlMessage();
msg.setFromUserName("abc"); msg.setFromUser("abc");
router.route(msg); router.route(msg);
Thread.sleep(2000l); Thread.sleep(2000l);
@ -295,7 +295,7 @@ public class WxMpMessageRouterTest {
@Override @Override
public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService, public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, WxMpService wxMpService,
WxSessionManager sessionManager) { WxSessionManager sessionManager) {
sessionManager.getSession(wxMessage.getFromUserName()); sessionManager.getSession(wxMessage.getFromUser());
return null; return null;
} }

View File

@ -25,21 +25,6 @@ public class WxMpPayServiceImplTest {
@Inject @Inject
protected WxMpServiceImpl wxService; protected WxMpServiceImpl wxService;
@Test
public void testGetPrepayId() throws Exception {
}
@Test
public void testGetJsapiPayInfo() throws Exception {
}
@Test
public void testGetNativePayInfo() throws Exception {
}
@Test @Test
public void testGetPayInfo() throws Exception { public void testGetPayInfo() throws Exception {
@ -79,7 +64,7 @@ public class WxMpPayServiceImplTest {
/** /**
* Test method for {@link me.chanjar.weixin.mp.api.impl.WxMpPayServiceImpl#unifiedOrder(me.chanjar.weixin.mp.bean.pay.WxUnifiedOrderRequest)}. * Test method for {@link me.chanjar.weixin.mp.api.impl.WxMpPayServiceImpl#unifiedOrder(me.chanjar.weixin.mp.bean.pay.WxUnifiedOrderRequest)}.
* @throws WxErrorException * @throws WxErrorException
*/ */
@Test @Test
public void testUnifiedOrder() throws WxErrorException { public void testUnifiedOrder() throws WxErrorException {
@ -89,4 +74,4 @@ public class WxMpPayServiceImplTest {
.tradeType("JSAPI").openid("122").outTradeNo("111111").build()); .tradeType("JSAPI").openid("122").outTradeNo("111111").build());
System.err.println(result); System.err.println(result);
} }
} }

View File

@ -54,8 +54,8 @@ public class WxMpXmlMessageTest {
+ "</SendLocationInfo>" + "</SendLocationInfo>"
+ "</xml>"; + "</xml>";
WxMpXmlMessage wxMessage = WxMpXmlMessage.fromXml(xml); WxMpXmlMessage wxMessage = WxMpXmlMessage.fromXml(xml);
Assert.assertEquals(wxMessage.getToUserName(), "toUser"); Assert.assertEquals(wxMessage.getToUser(), "toUser");
Assert.assertEquals(wxMessage.getFromUserName(), "fromUser"); Assert.assertEquals(wxMessage.getFromUser(), "fromUser");
Assert.assertEquals(wxMessage.getCreateTime(), new Long(1348831860l)); Assert.assertEquals(wxMessage.getCreateTime(), new Long(1348831860l));
Assert.assertEquals(wxMessage.getMsgType(), WxConsts.XML_MSG_TEXT); Assert.assertEquals(wxMessage.getMsgType(), WxConsts.XML_MSG_TEXT);
Assert.assertEquals(wxMessage.getContent(), "this is a test"); Assert.assertEquals(wxMessage.getContent(), "this is a test");
@ -135,8 +135,8 @@ public class WxMpXmlMessageTest {
+ "</SendLocationInfo>" + "</SendLocationInfo>"
+ "</xml>"; + "</xml>";
WxMpXmlMessage wxMessage = WxMpXmlMessage.fromXml(xml); WxMpXmlMessage wxMessage = WxMpXmlMessage.fromXml(xml);
Assert.assertEquals(wxMessage.getToUserName(), "toUser"); Assert.assertEquals(wxMessage.getToUser(), "toUser");
Assert.assertEquals(wxMessage.getFromUserName(), "fromUser"); Assert.assertEquals(wxMessage.getFromUser(), "fromUser");
Assert.assertEquals(wxMessage.getCreateTime(), new Long(1348831860l)); Assert.assertEquals(wxMessage.getCreateTime(), new Long(1348831860l));
Assert.assertEquals(wxMessage.getMsgType(), WxConsts.XML_MSG_TEXT); Assert.assertEquals(wxMessage.getMsgType(), WxConsts.XML_MSG_TEXT);
Assert.assertEquals(wxMessage.getContent(), "this is a test"); Assert.assertEquals(wxMessage.getContent(), "this is a test");

View File

@ -50,18 +50,18 @@ public class DemoGuessNumberHandler implements WxMpMessageHandler, WxMpMessageMa
} }
protected void letsGo(WxMpXmlMessage wxMessage, WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException { protected void letsGo(WxMpXmlMessage wxMessage, WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException {
WxSession session = sessionManager.getSession(wxMessage.getFromUserName()); WxSession session = sessionManager.getSession(wxMessage.getFromUser());
if (session.getAttribute("guessing") == null) { if (session.getAttribute("guessing") == null) {
WxMpCustomMessage m = WxMpCustomMessage WxMpCustomMessage m = WxMpCustomMessage
.TEXT() .TEXT()
.toUser(wxMessage.getFromUserName()) .toUser(wxMessage.getFromUser())
.content("请猜一个100以内的数字") .content("请猜一个100以内的数字")
.build(); .build();
wxMpService.getKefuService().customMessageSend(m); wxMpService.getKefuService().customMessageSend(m);
} else { } else {
WxMpCustomMessage m = WxMpCustomMessage WxMpCustomMessage m = WxMpCustomMessage
.TEXT() .TEXT()
.toUser(wxMessage.getFromUserName()) .toUser(wxMessage.getFromUser())
.content("放弃了吗那请重新猜一个100以内的数字") .content("放弃了吗那请重新猜一个100以内的数字")
.build(); .build();
wxMpService.getKefuService().customMessageSend(m); wxMpService.getKefuService().customMessageSend(m);
@ -74,7 +74,7 @@ public class DemoGuessNumberHandler implements WxMpMessageHandler, WxMpMessageMa
protected void giveHint(WxMpXmlMessage wxMessage, WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException { protected void giveHint(WxMpXmlMessage wxMessage, WxMpService wxMpService, WxSessionManager sessionManager) throws WxErrorException {
WxSession session = sessionManager.getSession(wxMessage.getFromUserName()); WxSession session = sessionManager.getSession(wxMessage.getFromUser());
if (session.getAttribute("guessing") == null) { if (session.getAttribute("guessing") == null) {
return; return;
@ -89,7 +89,7 @@ public class DemoGuessNumberHandler implements WxMpMessageHandler, WxMpMessageMa
if (guessNumber < answer) { if (guessNumber < answer) {
WxMpCustomMessage m = WxMpCustomMessage WxMpCustomMessage m = WxMpCustomMessage
.TEXT() .TEXT()
.toUser(wxMessage.getFromUserName()) .toUser(wxMessage.getFromUser())
.content("小了") .content("小了")
.build(); .build();
wxMpService.getKefuService().customMessageSend(m); wxMpService.getKefuService().customMessageSend(m);
@ -97,14 +97,14 @@ public class DemoGuessNumberHandler implements WxMpMessageHandler, WxMpMessageMa
} else if (guessNumber > answer) { } else if (guessNumber > answer) {
WxMpCustomMessage m = WxMpCustomMessage WxMpCustomMessage m = WxMpCustomMessage
.TEXT() .TEXT()
.toUser(wxMessage.getFromUserName()) .toUser(wxMessage.getFromUser())
.content("大了") .content("大了")
.build(); .build();
wxMpService.getKefuService().customMessageSend(m); wxMpService.getKefuService().customMessageSend(m);
} else { } else {
WxMpCustomMessage m = WxMpCustomMessage WxMpCustomMessage m = WxMpCustomMessage
.TEXT() .TEXT()
.toUser(wxMessage.getFromUserName()) .toUser(wxMessage.getFromUser())
.content("Bingo!") .content("Bingo!")
.build(); .build();
session.removeAttribute("guessing"); session.removeAttribute("guessing");

View File

@ -24,8 +24,8 @@ public class DemoImageHandler implements WxMpMessageHandler {
= WxMpXmlOutMessage = WxMpXmlOutMessage
.IMAGE() .IMAGE()
.mediaId(wxMediaUploadResult.getMediaId()) .mediaId(wxMediaUploadResult.getMediaId())
.fromUser(wxMessage.getToUserName()) .fromUser(wxMessage.getToUser())
.toUser(wxMessage.getFromUserName()) .toUser(wxMessage.getFromUser())
.build(); .build();
return m; return m;
} catch (WxErrorException e) { } catch (WxErrorException e) {

View File

@ -21,7 +21,7 @@ public class DemoOAuth2Handler implements WxMpMessageHandler {
wxMpService.getWxMpConfigStorage().getOauth2redirectUri(), wxMpService.getWxMpConfigStorage().getOauth2redirectUri(),
WxConsts.OAUTH2_SCOPE_USER_INFO, null) + "\">测试oauth2</a>"; WxConsts.OAUTH2_SCOPE_USER_INFO, null) + "\">测试oauth2</a>";
return WxMpXmlOutMessage.TEXT().content(href) return WxMpXmlOutMessage.TEXT().content(href)
.fromUser(wxMessage.getToUserName()).toUser(wxMessage.getFromUserName()) .fromUser(wxMessage.getToUser()).toUser(wxMessage.getFromUser())
.build(); .build();
} }
} }

View File

@ -17,8 +17,8 @@ public class DemoTextHandler implements WxMpMessageHandler {
public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context, public WxMpXmlOutMessage handle(WxMpXmlMessage wxMessage, Map<String, Object> context,
WxMpService wxMpService, WxSessionManager sessionManager) { WxMpService wxMpService, WxSessionManager sessionManager) {
WxMpXmlOutTextMessage m WxMpXmlOutTextMessage m
= WxMpXmlOutMessage.TEXT().content("测试加密消息").fromUser(wxMessage.getToUserName()) = WxMpXmlOutMessage.TEXT().content("测试加密消息").fromUser(wxMessage.getToUser())
.toUser(wxMessage.getFromUserName()).build(); .toUser(wxMessage.getFromUser()).build();
return m; return m;
} }