fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
@@ -72,7 +72,6 @@ msg.setStartDeliverTime(System.currentTimeMillis() + 1000 * 60); producer.send(msg); return Action.CommitMessage; } } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatisticDelay.name())) {// 订单统计 OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class); int hour = 24; @@ -104,6 +103,7 @@ } } return Action.CommitMessage; } } else if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) { boolean inviteSucceedReward = false; Long uid = null;