yujian
2020-07-01 ca0e816fe57482b8f43f22f7a0b6fe7c57a53f42
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
@@ -45,15 +45,17 @@
            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;