~api:我的藏品:开启盲盒、收取藏品改MONGO更新操作为队列实现;

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/goblin/service/impl/GoblinUserDigitalArtworkServiceImpl.java

@@ -12,6 +12,8 @@ import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishAndBuyResultQueryReqDto;
 import com.liquidnet.service.galaxy.dto.param.GalaxyNftPublishAndBuyResultQueryRespDto;
 import com.liquidnet.service.galaxy.service.IGalaxyTradeService;
+import com.liquidnet.service.goblin.constant.GoblinRedisConst;
+import com.liquidnet.service.goblin.dto.GoblinQueueBizMongoDto;
 import com.liquidnet.service.goblin.dto.vo.*;
 import com.liquidnet.service.goblin.service.IGoblinUserDigitalArtworkService;
 import com.liquidnet.service.goblin.util.GoblinMongoUtils;
@@ -178,7 +180,7 @@ public class GoblinUserDigitalArtworkServiceImpl implements IGoblinUserDigitalAr
         userDigitalArtworkBoxVo.setUpdatedAt(now);
         userDigitalArtworkBoxVo.setDeletedAt(now);
 
-        if (goblinMongoUtils.updateUserDigitalArtworkVoByUnboxing(userDigitalArtworkBoxVo)) {
+//        if (goblinMongoUtils.updateUserDigitalArtworkVoByUnboxing(userDigitalArtworkBoxVo)) {
             String artworkId = IDGenerator.nextMilliId2();
 
             String orderId = userDigitalArtworkBoxVo.getOrderId();
@@ -243,9 +245,18 @@ public class GoblinUserDigitalArtworkServiceImpl implements IGoblinUserDigitalAr
             updateBoxArtworkObjs.add(new Object[]{now, now, now, userDigitalArtworkBoxVo.getArtworkId()});
             queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_ARTWORK_GEN.getKey(), SqlMapping.gets(toMqSqls, initUserDigitalArtworkObjs, updateBoxArtworkObjs));
 
+            // Mongo同步更新
+            GoblinQueueBizMongoDto goblinQueueBizMongoDto = GoblinQueueBizMongoDto.getNew();
+            goblinQueueBizMongoDto.setCollect(GoblinUserDigitalArtworkVo.class.getSimpleName());
+            goblinQueueBizMongoDto.setColumn("artworkId");
+            goblinQueueBizMongoDto.setBizId(userDigitalArtworkBoxVo.getArtworkId());
+            goblinQueueBizMongoDto.setPrefix(GoblinRedisConst.USER_DIGITAL_ARTWORK);
+            goblinQueueBizMongoDto.setOpType(2);
+            queueUtils.sendMsgByRedis(MQConst.GoblinQueue.BIZ_NFT_MONGO.getKey(), goblinQueueBizMongoDto.toJson());
+
             return unboxDigitalArtworkListVo;
-        }
-        return null;
+//        }
+//        return null;
     }
 
     @Override
@@ -255,7 +266,7 @@ public class GoblinUserDigitalArtworkServiceImpl implements IGoblinUserDigitalAr
         userDigitalArtworkVo.setOpeningAt(now);
         userDigitalArtworkVo.setUpdatedAt(now);
 
-        if (goblinMongoUtils.updateUserDigitalArtworkVoByAccept(userDigitalArtworkVo)) {
+//        if (goblinMongoUtils.updateUserDigitalArtworkVoByAccept(userDigitalArtworkVo)) {
             // Redis更新VO
             goblinRedisUtils.setUserDigitalArtworkVo(userDigitalArtworkVo);
 
@@ -274,9 +285,18 @@ public class GoblinUserDigitalArtworkServiceImpl implements IGoblinUserDigitalAr
             updateUserArtworkObjs.add(new Object[]{now, now, userDigitalArtworkVo.getArtworkId()});
             queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_ARTWORK_GEN.getKey(), SqlMapping.gets(toMqSqls, updateUserArtworkObjs));
 
+            // Mongo同步更新
+            GoblinQueueBizMongoDto goblinQueueBizMongoDto = GoblinQueueBizMongoDto.getNew();
+            goblinQueueBizMongoDto.setCollect(GoblinUserDigitalArtworkVo.class.getSimpleName());
+            goblinQueueBizMongoDto.setColumn("artworkId");
+            goblinQueueBizMongoDto.setBizId(userDigitalArtworkVo.getArtworkId());
+            goblinQueueBizMongoDto.setPrefix(GoblinRedisConst.USER_DIGITAL_ARTWORK);
+            goblinQueueBizMongoDto.setOpType(2);
+            queueUtils.sendMsgByRedis(MQConst.GoblinQueue.BIZ_NFT_MONGO.getKey(), goblinQueueBizMongoDto.toJson());
+
             return true;
-        }
-        return false;
+//        }
+//        return false;
     }
 
     /* -------------------------------------------------------------------------------------------------------------- */