mongo换成队列 订单和藏品

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

@@ -453,7 +453,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
             // nftOrderUtils.addNftOrderList(uid, orderVo.getOrderId());
 
             // mongo
-            goblinOrderUtils.setMongoList(nftOrder.getOrderId(), 1, 1);
+            goblinOrderUtils.setMongoList("GoblinNftOrderVo", "orderId", orderVo.getOrderId(), "goblin:nft:order:id:", 1);
 //            goblinMongoUtils.setGoblinNftOrderVo(orderVo);
 
             // 执行sql
@@ -646,7 +646,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
             // redis
             nftOrderUtils.setNftOrder(orderVo);
             // mongo
-            goblinOrderUtils.setMongoList(orderId, 1, 1);
+            goblinOrderUtils.setMongoList("GoblinNftOrderVo", "orderId", orderVo.getOrderId(), "goblin:nft:order:id:", 1);
 //            goblinMongoUtils.updateGoblinNftOrderVo(orderVo);
             // mysql
             LinkedList<String> sqls = CollectionUtil.linkedListString();
@@ -780,7 +780,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
         digitalArtworkVo.setPublisher(goodsInfoVo.getPublisher());
 
         // Mongo记录VO
-//        goblinOrderUtils.setMongoList(nftOrder.getOrderId(), 1, 1, 1);
+//        goblinOrderUtils.setMongoList("GoblinUserDigitalArtworkVo", "artworkId", digitalArtworkVo.getArtworkId(), "goblin:u_d_art:", 1);
         goblinMongoUtils.insertGoblinUserDigitalArtworkVo(digitalArtworkVo);
         // Redis记录VO
         goblinRedisUtils.setGoblinUserDigitalArtworkVo(digitalArtworkVo);

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

@@ -223,17 +223,20 @@ public class GoblinOrderUtils {
 
     /**
      * mongo操作入队列
-     * @param bizId 业务id 例如orderId
-     * @param bizType 业务类型 1NFT订单 2...
-     * @param opType 操作类型 1创建 2修改
+     * @param collect Mongo集合名
+     * @param column Mongo集合中的字段属性名称
+     * @param bizId Mongo集合中的字段属性值
+     * @param prefix Redis缓存中的Key前缀
+     * @param opType 操作类型[1-insert|2-update]
      */
-    public void setMongoList(String bizId, int bizType, int opType) {
+    public void setMongoList(String collect, String column, String bizId, String prefix, int opType) {
         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());
+        goblinQueueBizMongoDto.setCollect(collect);
+        goblinQueueBizMongoDto.setColumn(column);
+        goblinQueueBizMongoDto.setBizId(bizId);
+        goblinQueueBizMongoDto.setPrefix(prefix);
+        goblinQueueBizMongoDto.setOpType(opType);
+        queueUtils.sendMsgByRedis(MQConst.GoblinQueue.BIZ_NFT_MONGO.getKey(), goblinQueueBizMongoDto.toJson());
     }
 
     public GoblinUseResultVo useStoreCoupon(String ucouponId, String content, BigDecimal totalPrice, List<GoblinOrderSku> goblinOrderSkuList, String uid) {