| | |
|---|
| | |
|
|---|
| | | 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;
|
|---|
