From ea723f08f097cb99063437413b897720dc1187c0 Mon Sep 17 00:00:00 2001
From: hurui <177768073@qq.com>
Date: Tue, 14 Feb 2023 09:33:11 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../consumer/OrderRefundSuccessConsumer.java  | 30 +++++++++++++++++--
 .../order/service/impl/OrderServiceImpl.java  |  1 -
 2 files changed, 28 insertions(+), 3 deletions(-)

diff --git a/hai-order/src/main/java/com/web/rocketmq/consumer/OrderRefundSuccessConsumer.java b/hai-order/src/main/java/com/web/rocketmq/consumer/OrderRefundSuccessConsumer.java
index 148825c0..460c6dad 100644
--- a/hai-order/src/main/java/com/web/rocketmq/consumer/OrderRefundSuccessConsumer.java
+++ b/hai-order/src/main/java/com/web/rocketmq/consumer/OrderRefundSuccessConsumer.java
@@ -1,5 +1,7 @@
 package com.web.rocketmq.consumer;
 
+import com.hai.entity.HighDiscountAgentCode;
+import com.hai.entity.HighDiscountUserRel;
 import com.hai.entity.HighOrder;
 import com.hai.entity.HighOrderRefund;
 import com.hai.order.service.OrderRefundHandleService;
@@ -9,12 +11,15 @@ import com.hai.order.type.OrderChildGoodsType;
 import com.hai.order.type.OrderProductType;
 import com.hai.order.type.OrderStatus;
 import com.hai.service.BsMsgService;
+import com.hai.service.HighDiscountAgentCodeService;
+import com.hai.service.HighDiscountUserRelService;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.core.RocketMQListener;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.math.BigDecimal;
 
 @Component
 @Slf4j
@@ -26,15 +31,36 @@ public class OrderRefundSuccessConsumer implements RocketMQListener<HighOrderRef
 
     @Resource
     private OrderRefundService orderRefundService;
-
     @Resource
     private OrderRefundHandleService refundHandleService;
 
+    @Resource
+    private HighDiscountUserRelService discountUserRelService;
+    @Resource
+    private HighDiscountAgentCodeService discountAgentCodeService;
     @Resource
     private BsMsgService bsMsgService;
 
     @Override
-    public void onMessage(HighOrderRefund orderRefund){
+    public void onMessage(HighOrderRefund orderRefund) {
+
+        // 交易订单
+        HighOrder order = orderService.getOrderDetailByNo(orderRefund.getOrderNo());
+        if (order != null && order.getMemDiscountId() != null) {
+            // 交易订单可退金额为0，才会退还优惠券
+            if (order.getSurplusRefundIntegral() == 0 && order.getSurplusRefundPrice().compareTo(new BigDecimal("0")) == 0) {
+                HighDiscountUserRel rel = discountUserRelService.getRelById(order.getMemDiscountId());
+                if (rel != null) {
+                    rel.setStatus(1);  // 状态  0:已过期  1：未使用  2：已使用
+                    rel.setUseTime(null);
+                    discountUserRelService.updateDiscountUserRel(rel);
+
+                    HighDiscountAgentCode code = discountAgentCodeService.getCodeById(rel.getDiscountAgentCodeId());
+                    code.setStatus(2);
+                    discountAgentCodeService.updateCode(code);
+                }
+            }
+        }
 
         if (orderRefund.getGoodsType().equals(OrderChildGoodsType.TYPE1.getNumber())) {
             refundHandleService.couponHandle(orderRefund);
diff --git a/hai-service/src/main/java/com/hai/order/service/impl/OrderServiceImpl.java b/hai-service/src/main/java/com/hai/order/service/impl/OrderServiceImpl.java
index 97a54902..0e3895ce 100644
--- a/hai-service/src/main/java/com/hai/order/service/impl/OrderServiceImpl.java
+++ b/hai-service/src/main/java/com/hai/order/service/impl/OrderServiceImpl.java
@@ -581,7 +581,6 @@ public class OrderServiceImpl implements OrderService {
             rocketMQTemplate.syncSend(OrderTopic.ORDER_TOPIC_REFUND_SUCCESS.getTopic(), orderRefund);
         }
 
-
         return updateOrderData(order);
     }