订单补贴消息修改

admin

2019-12-12 d46dea27b6ec3e0fb32ec7d137699e9fc7d609b0

订单补贴消息修改

 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()

@@ -150,8 +152,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);