订单列表增加活动类型

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/constant/MQConst.java

@@ -248,6 +248,17 @@ public class MQConst {
         GOBLIN_STORE_ORDER_OPERA("goblin:stream:order:store", "group.order:store", "商铺订单操作"),
         GOBLIN_USER_ORDER_OPERA("goblin:stream:order:user", "group.order:user", "用户订单操作"),
         GOBLIN_XLS_OPERA("goblin:stream:xls", "group.xls", "xls文件操作"),
+
+        GOBLIN_UN_PAY_0("goblin:stream:order:back:0", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_1("goblin:stream:order:back:1", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_2("goblin:stream:order:back:2", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_3("goblin:stream:order:back:3", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_4("goblin:stream:order:back:4", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_5("goblin:stream:order:back:5", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_6("goblin:stream:order:back:6", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_7("goblin:stream:order:back:7", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_8("goblin:stream:order:back:8", "group.order:back", "回滚关闭订单库存队列"),
+        GOBLIN_UN_PAY_9("goblin:stream:order:back:9", "group.order:back", "回滚关闭订单库存队列"),
         ;
 
         private final String key;

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/QueueUtils.java

 package com.liquidnet.service.order.utils;
 
+import com.liquidnet.commons.lang.util.RandomUtil;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinIpAreaVo;
@@ -14,7 +15,7 @@ import java.util.HashMap;
 @Component
 public class QueueUtils {
 
-//    @Autowired
+    //    @Autowired
 //    private RabbitTemplate rabbitTemplate;
     @Autowired
     StringRedisTemplate stringRedisTemplate;
@@ -44,6 +45,53 @@ public class QueueUtils {
         stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }
 
+
+    /**
+     * 发送消息 - REDIS Goblin回滚待支付订单库存
+     *
+     * @param createTime      订单创建时间
+     * @param masterOrderCode Goblin主订单号
+     */
+    public void sendMsgByRedisGoblinStock(String masterOrderCode, LocalDateTime createTime) {
+        String streamKey;
+        int key = createTime.getSecond() % 10;
+        switch (key) {
+            case 1:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_1.getKey();
+                break;
+            case 2:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_2.getKey();
+                break;
+            case 3:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_3.getKey();
+                break;
+            case 4:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_4.getKey();
+                break;
+            case 5:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_5.getKey();
+                break;
+            case 6:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_6.getKey();
+                break;
+            case 7:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_7.getKey();
+                break;
+            case 8:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_8.getKey();
+                break;
+            case 9:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_9.getKey();
+                break;
+            default:
+                streamKey = MQConst.GoblinQueue.GOBLIN_UN_PAY_0.getKey();
+                break;
+        }
+        HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
+        map.put("message", masterOrderCode);
+        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+    }
+
     public void pushPvUv(String uid, String accessType, String performanceId, String orderId, String orderCode, String ipAddress) {
         try {
             KylinIpAreaVo vo = dataUtils.getKylinIpAreaVo(ipAddress);