帮助中心

yujian

2019-12-19 626d711cb15896055c13fe344eb7fcc824589715

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java

@@ -62,8 +62,8 @@


   @Override

   public Action consume(Message message, ConsumeContext context) {

      LogHelper.mqInfo("consumer:InviteOrderSubsidyMessageListener", message.getMsgID(),message.getTopic(), message.getTag(),

            new String(message.getBody()));

      LogHelper.mqInfo("consumer:InviteOrderSubsidyMessageListener", message.getMsgID(), message.getTopic(),

            message.getTag(), new String(message.getBody()));

      String tag = message.getTag();



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

@@ -125,7 +125,9 @@
                  }

               }

            }

         } else if (tag.equalsIgnoreCase(UserTopicTagEnum.useSystemCoupon.name())) {

         }

      } else if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {

         if (tag.equalsIgnoreCase(UserTopicTagEnum.useSystemCoupon.name())) {

            UserSystemCouponUseMQMsg dto = new Gson().fromJson(new String(message.getBody()),

                  UserSystemCouponUseMQMsg.class);

            if (dto != null && dto.getCouponType()

@@ -139,6 +141,7 @@
               return Action.CommitMessage;

            }

         }

         //

      }

      return Action.CommitMessage;

   }

@@ -150,8 +153,7 @@
    */

   private boolean sendOrderSubsidyUpdateLater(OrderMoneyRecievedMQMsg dto, int day) {



      Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiDelay,

            dto);

      Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiDelay, dto);

      msg.setKey(dto.getSourceType() + "_" + dto.getOrderId());

      long delayTime = System.currentTimeMillis() + (Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 60 * 24L * day);

      msg.setStartDeliverTime(delayTime);