From 8ba02b125d2df1a3393efdb276daae2244452d45 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 28 十月 2019 18:06:58 +0800
Subject: [PATCH] 返利奖励券新规则调整，订单统计，返利到账优化
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java | 11 +++++++----
1 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java
index 469a4cf..55610dc 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/order/InviteOrderSubsidyMessageListener.java
@@ -22,6 +22,7 @@
import com.yeshi.fanli.exception.money.OrderMoneySettleException;
import com.yeshi.fanli.exception.mq.MQUnSendInfoException;
import com.yeshi.fanli.exception.order.InviteOrderSubsidyException;
+import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService;
import com.yeshi.fanli.service.inter.order.InviteOrderSubsidyService;
import com.yeshi.fanli.service.inter.order.OrderMoneySettleService;
@@ -59,9 +60,11 @@
@Override
public Action consume(Message message, ConsumeContext context) {
- if (!Constant.IS_TASK) {// 闈炰换鍔℃湇鍔″櫒涓嶈兘娑堣垂娑堟伅
- return Action.ReconsumeLater;
- }
+ // if (!Constant.IS_TASK) {// 闈炰换鍔℃湇鍔″櫒涓嶈兘娑堣垂娑堟伅
+ // return Action.ReconsumeLater;
+ // }
+ LogHelper.mqInfo("consumer:InviteOrderSubsidyMessageListener", message.getTopic(), message.getTag(),
+ new String(message.getBody()));
if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {
// 鏌ヨ涓婄骇绾㈠寘
@@ -148,7 +151,7 @@
Message msg = new Message(MQTopicName.TOPIC_FANLI.name(), "delay", new Gson().toJson(dto).getBytes());
msg.setKey(dto.getSourceType() + "_" + dto.getOrderId());
- long delayTime = System.currentTimeMillis() + 1000 * 60 * 60 * 24L * day;
+ long delayTime = System.currentTimeMillis() + (Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 60 * 24L * day);
msg.setStartDeliverTime(delayTime);
SendResult sendResult = producer.send(msg);
if (sendResult != null) {
--
Gitblit v1.8.0