From 98b1a0affd69bbe63223c21fdd2c404e8bedfccb Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 20 五月 2020 17:25:08 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/div' into 2.1.2
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
index 844dc7d..c739be7 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
@@ -83,7 +83,8 @@
try {// 閭�璇峰鍔�
redPackWinInviteService.inviteSucceedReward(orderMQMsg.getUid());
} catch (Exception e) {
- e.printStackTrace();
+ LogHelper.errorDetailInfo(e);
+ return Action.ReconsumeLater;
}
}
return Action.CommitMessage;
@@ -121,9 +122,10 @@
UserInviteMQMsg.class);
inviteSucceedReward = true;
uid = userInviteMQMsg.getWorkerId();
-
- redPackWinInviteService.initCreateRedPackWin(userInviteMQMsg.getBossId(),userInviteMQMsg.getWorkerId());
-
+
+ redPackWinInviteService.initCreateRedPackWin(userInviteMQMsg.getBossId(),
+ userInviteMQMsg.getWorkerId());
+
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.redPackGiftDrawback.name())) {// 绾㈠寘璧犻��
UserRedPackGiftMQMsg userRedPackGiftMQMsg = new Gson().fromJson(new String(message.getBody()),
UserRedPackGiftMQMsg.class);
--
Gitblit v1.8.0