| | |
| | | new String(message.getBody()));
|
| | | String tag = message.getTag();
|
| | | if (tag == null)
|
| | | |
| | | tag = "";
|
| | |
|
| | | if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {
|
| | | if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderConfirm.name())) {// 订单确认收货
|
| | | OrderConfirmMQMsg mqMsg = new Gson().fromJson(new String(message.getBody()),
|
| | | OrderConfirmMQMsg.class);
|
| | | redPackWinInviteService.winRedPackByOrder(mqMsg.getSourceUid(), mqMsg.getOrderNo(), mqMsg.getSourceType());
|
| | | return Action.CommitMessage;
|
| | | // 订单确认收货
|
| | | if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderConfirm.name())) { |
| | | OrderConfirmMQMsg mqMsg = new Gson().fromJson(new String(message.getBody()), OrderConfirmMQMsg.class);
|
| | | try {// 邀请奖励
|
| | | redPackWinInviteService.winRedPackByOrder(mqMsg.getSourceUid(), mqMsg.getOrderNo(), mqMsg.getSourceType());
|
| | | } catch (Exception e) {
|
| | | LogHelper.errorDetailInfo(e);
|
| | | }
|
| | | }
|
| | | }
|
| | | return Action.CommitMessage;
|