From e4c7f45ed5a06512fa9981ef63d256e950b433c8 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期一, 29 六月 2020 17:54:22 +0800
Subject: [PATCH] 取消新人免单券奖励
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java | 48 ++++++++++++++++++++++++------------------------
1 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
index fb7c0b5..415188d 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java
@@ -58,22 +58,22 @@
LogHelper.errorDetailInfo(e);
}
- // 鍙戦��48灏忔椂寤舵椂娑堟伅
- boolean verifyOrder = redPackWinInviteService.verifyOrder(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());
- if (verifyOrder) {
- int hour = 48;
- if (Constant.IS_TEST) {
- hour = 1;
- }
- mqMsg.setDelayHour(hour);
- Message msg = new Message(message.getTopic(), OrderTopicTagEnum.orderStatisticDelay.name(),
- 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);
- }
+// // 鍙戦��48灏忔椂寤舵椂娑堟伅
+// boolean verifyOrder = redPackWinInviteService.verifyOrder(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());
+// if (verifyOrder) {
+// int hour = 48;
+// if (Constant.IS_TEST) {
+// hour = 1;
+// }
+// mqMsg.setDelayHour(hour);
+// Message msg = new Message(message.getTopic(), OrderTopicTagEnum.orderStatisticDelay.name(),
+// 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);
@@ -82,14 +82,14 @@
hour = 1;
}
- if (mqMsg.getDelayHour() == hour) {
- try {
- redPackWinInviteService.winFreeCoupon(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());
- } catch (Exception e) {
- LogHelper.errorDetailInfo(e);
- return Action.ReconsumeLater;
- }
- }
+// if (mqMsg.getDelayHour() == hour) {
+// try {
+// redPackWinInviteService.winFreeCoupon(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());
+// } catch (Exception e) {
+// LogHelper.errorDetailInfo(e);
+// return Action.ReconsumeLater;
+// }
+// }
return Action.CommitMessage;
}
}
--
Gitblit v1.8.0