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