yujian
2019-11-15 dbc8f0b2058d809e6dad0ada92d391109cbb4f57
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
@@ -55,13 +55,14 @@
         if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {// 返利到账
            OrderMoneyRecievedMQMsg orderMoneyRecievedMQMsg = new Gson().fromJson(new String(message.getBody()),
                  OrderMoneyRecievedMQMsg.class);
            // 分享订单奖励
            if (orderMoneyRecievedMQMsg.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {
               try {// 上级分享订单奖励
                  redPackWinInviteService.orderArriveReward(orderMoneyRecievedMQMsg.getUid(),
                        orderMoneyRecievedMQMsg.getSourceType(), orderMoneyRecievedMQMsg.getOrderId());
               } catch (Exception e) {
                  e.printStackTrace();
               }
//               try {
//                  redPackWinInviteService.orderArriveReward(orderMoneyRecievedMQMsg.getUid(),
//                        orderMoneyRecievedMQMsg.getSourceType(), orderMoneyRecievedMQMsg.getOrderId());
//               } catch (Exception e) {
//                  e.printStackTrace();
//               }
            }
         } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatistic.name())) {// 订单统计
            OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);