mongo换成队列

liquidnet-bus-api/liquidnet-service-goblin-api/src/main/java/com/liquidnet/service/goblin/dto/GoblinQueueBizMongoDto.java

+package com.liquidnet.service.goblin.dto;
+
+import com.liquidnet.commons.lang.util.JsonUtils;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * mongo队列消息体
+ *
+ * @author jiangxiulong
+ */
+@Data
+public class GoblinQueueBizMongoDto implements Serializable, Cloneable {
+
+    private static final long serialVersionUID = -5850588358672254766L;
+
+    /**
+     * mongo操作入队列
+     *
+     * @param bizId 业务id 例如orderId
+     * @param bizType 业务类型 1NFT订单 2...
+     * @param opType 操作类型 1创建 2修改
+     * @param listType 队列类型 1即时性要求高队列 2即时性要求不高队列
+     */
+    private String bizId;
+    private int bizType;
+    private int opType;
+    private int listType;
+
+    private static final GoblinQueueBizMongoDto obj = new GoblinQueueBizMongoDto();
+
+    public static GoblinQueueBizMongoDto getNew() {
+        try {
+            return (GoblinQueueBizMongoDto) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new GoblinQueueBizMongoDto();
+        }
+    }
+
+    public String toJson() {
+        return JsonUtils.toJson(this);
+    }
+}

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

@@ -293,6 +293,7 @@ public class MQConst {
 
         GOBLIN_NFT_ORDER("goblin:stream:nftOrder:create", "group.nftOrder:create", "NFT订单处理"),
         BIZ_INTEGRAL("goblin:stream:biz_integral", "group.biz.integral", "增减积分操作"),
+        BIZ_NFT_MONGO("goblin:stream:biz:mongo:nft", "group.biz.mongo.nft", "NFT的mongo操作"),
 
         ;
 

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

@@ -11,6 +11,7 @@ import com.liquidnet.service.candy.param.BackCouponParam;
 import com.liquidnet.service.candy.vo.CandyUseResultVo;
 import com.liquidnet.service.goblin.constant.GoblinStatusConst;
 import com.liquidnet.service.goblin.dto.GoblinQueueBizIntegralDto;
+import com.liquidnet.service.goblin.dto.GoblinQueueBizMongoDto;
 import com.liquidnet.service.goblin.dto.vo.*;
 import com.liquidnet.service.goblin.entity.GoblinBackOrder;
 import com.liquidnet.service.goblin.entity.GoblinBackOrderLog;
@@ -220,6 +221,22 @@ public class GoblinOrderUtils {
         }
     }
 
+    /**
+     * mongo操作入队列
+     * @param bizId 业务id 例如orderId
+     * @param bizType 业务类型 1NFT订单 2...
+     * @param opType 操作类型 1创建 2修改
+     * @param listType 队列类型 1即时性要求高队列 2即时性要求不高队列
+     */
+    public void setMongoList(String bizId, int bizType, int opType, int listType) {
+        GoblinQueueBizMongoDto goblinQueueBizMongoDto = GoblinQueueBizMongoDto.getNew();
+            goblinQueueBizMongoDto.setBizId(bizId);
+            goblinQueueBizMongoDto.setBizType(bizType);
+            goblinQueueBizMongoDto.setOpType(opType);
+            goblinQueueBizMongoDto.setListType(listType);
+            queueUtils.sendMsgByRedis(MQConst.GoblinQueue.BIZ_NFT_MONGO.getKey(), goblinQueueBizMongoDto.toJson());
+    }
+
     public GoblinUseResultVo useStoreCoupon(String ucouponId, String content, BigDecimal totalPrice, List<GoblinOrderSku> goblinOrderSkuList, String uid) {
         try {
             List<GoblinUserCouponVo> voList = redisUtils.getUserCouponVos(uid);