From 851e43f3d0a79154cb4dc3a55738a83a97797c2d Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期三, 13 十一月 2019 10:04:34 +0800
Subject: [PATCH] 红包提现次数限制
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/coupon/SystemCouponMessageListener.java | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/coupon/SystemCouponMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/coupon/SystemCouponMessageListener.java
index 0101484..5945bfe 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/coupon/SystemCouponMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/coupon/SystemCouponMessageListener.java
@@ -43,8 +43,7 @@
if (orderMoneyRecievedMQMsgDTO.getOrderFirst() != null
&& orderMoneyRecievedMQMsgDTO.getOrderFirst() == true) {
// 棣栨鍒拌处杩斿埄
- // TODO 涓氬姟浠ｇ爜娣诲姞
-
+
// 婵�娲诲厤鍗曞埜
userSystemCouponService.triggerFreeCouponActivate(orderMoneyRecievedMQMsgDTO.getUid());
@@ -57,8 +56,11 @@
if (UserTopicTagEnum.systemCouponDrawback.name().equalsIgnoreCase(tag)) {// 鍒搁��鍥�
UserSystemCouponUseMQMsg userSystemCouponUseMQMsg = new Gson().fromJson(new String(message.getBody()),
UserSystemCouponUseMQMsg.class);
- //TODO澶勭悊鍒搁��鍥�
+ //澶勭悊鍒搁��鍥�
+ userSystemCouponService.sendBackByGiveId(userSystemCouponUseMQMsg.getUserSystemCouponId());
+ // 涓氬姟浠ｇ爜鎵ц鎴愬姛鍚庤繑鍥�
+ return Action.CommitMessage;
}
}
return Action.CommitMessage;
--
Gitblit v1.8.0