取消支付冲正mq只发一次

call-back-service/src/main/java/cn/freemud/amp/service/OrderCallBackMQService.java

@@ -99,10 +99,16 @@ public class OrderCallBackMQService {
      * @param body
      */
     public void revert(OrderCallBackRequestVo body){
-        ApiLog.infoMessage("activityReverse start orderCode:{}", body.getOrderCode());
         if (ObjectUtils.notEqual(body.getDelayMsgEventType(),2)){
             return;
         }
+        String redisKey = "kgd:cancel_payment_oid:" + body.getOrderCode() ;
+        //取消支付订单缓存,
+        Object value = redisCache.getValue(redisKey);
+        if(value != null){
+            return;
+        }
+        ApiLog.infoMessage("activityReverse start orderCode:{}", body.getOrderCode());
         String orderCode=body.getOrderCode();
         OrderStatusChangeRequestDto requestDto = new OrderStatusChangeRequestDto();
         requestDto.setOid(orderCode);

order-application-service/src/main/java/cn/freemud/constant/RedisKeyConstant.java

@@ -100,6 +100,10 @@ public class RedisKeyConstant {
     public final static String USER_BUY_PRODUCT_ONCE = "user_buy_product_once:";
 
 
+    /**
+     * 取消支付冲正mq在redis的key前缀
+     */
+    public final static String KGD_PAYMENT_CANCEL_OID = "kgd:cancel_payment_oid:";
 
     /**
      * cocoNotMadeGoods:商户号:门店号:yyyy-MM-dd

order-application-service/src/main/java/cn/freemud/service/impl/OrderQueueService.java

@@ -5,8 +5,10 @@ import cn.freemud.amqp.Header;
 import cn.freemud.amqp.MQAction;
 import cn.freemud.amqp.MQMessage;
 import cn.freemud.amqp.MQService;
+import cn.freemud.constant.RedisKeyConstant;
 import cn.freemud.entities.dto.OrderPrintDto;
 import cn.freemud.entities.dto.pay.PaymentMqMessageDto;
+import cn.freemud.redis.RedisCache;
 import cn.freemud.utils.AppLogUtil;
 import com.alibaba.fastjson.JSON;
 import com.freemud.application.sdk.api.config.TopicExchangeConfig;
@@ -18,11 +20,16 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
+import java.util.concurrent.TimeUnit;
+
 @Component
 public class OrderQueueService {
 
     @Autowired
     private MQService mqService;
+    @Autowired
+    private RedisCache redisCache;
+
 
 
     // TODO: 21-9-17 定义常量
@@ -75,6 +82,10 @@ public class OrderQueueService {
         } catch (Exception e) {
             AppLogUtil.errorLog("ActivityReverse", JSON.toJSONString(requestDto), "", e);
         }
+
+        String redisKey = RedisKeyConstant.KGD_PAYMENT_CANCEL_OID + oid ;
+        //取消支付订单缓存
+        redisCache.save(redisKey, true, 180L, TimeUnit.MINUTES);
     }