admin
2019-11-16 a6f34b99ee20e528b766c8ed5a61bd9c5aa0e7ae
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);
@@ -113,7 +114,7 @@
               {
                  System.out.println(uid);
               }
               redPackWinInviteService.inviteSucceedReward(uid);
//               redPackWinInviteService.inviteSucceedReward(uid);
            } catch (Exception e) {
               e.printStackTrace();
            }