拉新

yujian

2020-06-29 ec60e757d358636dcac1589c44a66f3e276fe58c

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java

@@ -50,21 +50,30 @@


      if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {

         if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatistic.name())) {// 订单统

            OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);

            // 发送24小时延时消息

            // 测试时发送

            OrderMQMsg mqMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);

				
            try {// 邀请奖励

               redPackWinInviteService.winRedPackByOrder(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());

            } catch (Exception e) {

               LogHelper.errorDetailInfo(e);

            }

				
            boolean verifyOrder = redPackWinInviteService.verifyOrder(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());

            if (verifyOrder) {

               // 发送48小时延时消息

            int hour = 48;

            if (Constant.IS_TEST) {

               hour = 1;

            }

            orderMQMsg.setDelayHour(hour);

               mqMsg.setDelayHour(hour);

            Message msg = new Message(message.getTopic(), OrderTopicTagEnum.orderStatisticDelay.name(),

                  new Gson().toJson(orderMQMsg).getBytes());

            if (orderMQMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour > System.currentTimeMillis())// 时间是否已经过了

               msg.setStartDeliverTime(orderMQMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour);

                     new Gson().toJson(mqMsg).getBytes());

               if (mqMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour > System.currentTimeMillis())// 时间是否已经过了

                  msg.setStartDeliverTime(mqMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour);

            else

               msg.setStartDeliverTime(System.currentTimeMillis() + 1000 * 60);

            producer.send(msg);

            }

            return Action.CommitMessage;

         } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatisticDelay.name())) {// 订单统计

            OrderMQMsg mqMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);

@@ -74,8 +83,8 @@
            }



            if (mqMsg.getDelayHour() == hour) {

               try {// 邀请奖励

                  redPackWinInviteService.winRedPackByOrder(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType());

               try {

                  redPackWinInviteService.winFreeCoupon(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());

               } catch (Exception e) {

                  LogHelper.errorDetailInfo(e);

                  return Action.ReconsumeLater;