sendMsgByRedisGoblinStock type改为传参

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

@@ -580,7 +580,7 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
             GoblinOrderAttrVo orderAttrVo = GoblinOrderAttrVo.getNew().copy(orderAttr);
 
             //待支付发送队列
-            queueUtils.sendMsgByRedisGoblinStock(orderVo.getMasterOrderCode(), storeOrder.getCreatedAt());
+            queueUtils.sendMsgByRedisGoblinStock(orderVo.getMasterOrderCode(), storeOrder.getCreatedAt(), "GOBLIN");
             //redis 赋值
             orderVo.setOrderAttrVo(orderAttrVo);
             orderVo.setOrderSkuVoIds(goblinOrderSkuIdList);

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

@@ -51,7 +51,7 @@ public class QueueUtils {
      * @param createTime      订单创建时间
      * @param masterOrderCode Goblin主订单号
      */
-    public void sendMsgByRedisGoblinStock(String masterOrderCode, LocalDateTime createTime) {
+    public void sendMsgByRedisGoblinStock(String masterOrderCode, LocalDateTime createTime, String type) {
         String streamKey;
         int key = createTime.getMinute() % 10;
         switch (key) {
@@ -88,7 +88,7 @@ public class QueueUtils {
         }
         HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
         map.put("id", masterOrderCode);
-        map.put("type", "GOBLIN");
+        map.put("type", type);
         map.put("time", createTime.toString());
         stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
     }