From 5c03e2dd5afd65c483ef5da8346e78abc29dc7e3 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 01 四月 2020 14:39:54 +0800
Subject: [PATCH] 新增淘客接口，订单返利比例计算相关service修改
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java | 19 ++++++++++++-------
1 files changed, 12 insertions(+), 7 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
index 0e5f944..ee0daa5 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
@@ -46,15 +46,20 @@
return Action.CommitMessage;
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 璁㈠崟缁熻
- UserInfoUpdateMQMsg userInfoUpdateMQMsg = new Gson().fromJson(new String(message.getBody()),
- UserInfoUpdateMQMsg.class);
- if (userInfoUpdateMQMsg != null && (userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.portrait
- || userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.inviteCode)) {
- if (userInfoUpdateMQMsg.getUid() != null)
- spreadUserImgService.deleteImgUrl(userInfoUpdateMQMsg.getUid());
+
+ try {
+ UserInfoUpdateMQMsg userInfoUpdateMQMsg = new Gson().fromJson(new String(message.getBody()),
+ UserInfoUpdateMQMsg.class);
+ if (userInfoUpdateMQMsg != null && (userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.portrait
+ || userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.inviteCode)) {
+ if (userInfoUpdateMQMsg.getUid() != null)
+ spreadUserImgService.deleteImgUrl(userInfoUpdateMQMsg.getUid());
+ }
+ return Action.CommitMessage;
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e, "msgId:" + message.getMsgID(), "");
}
- return Action.CommitMessage;
}
}
return Action.CommitMessage;
--
Gitblit v1.8.0