~queue.tomdb;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractMdbRedisReceiver.java

@@ -5,9 +5,13 @@ import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.goblin.dto.GoblinQueueBizMongoDto;
+import com.mongodb.BasicDBObject;
+import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.data.redis.connection.stream.MapRecord;
 import org.springframework.data.redis.connection.stream.StreamRecords;
 import org.springframework.data.redis.core.StringRedisTemplate;
@@ -30,6 +34,8 @@ public abstract class AbstractMdbRedisReceiver implements StreamListener<String,
     @Autowired
     private RedisUtil redisUtil;
 
+    private static final BasicDBObject BASIC_DB_OBJECT = new BasicDBObject();
+
     @Override
     public void onMessage(MapRecord<String, String, String> message) {
         String redisStreamKey = this.getRedisStreamKey();
@@ -56,17 +62,21 @@ public abstract class AbstractMdbRedisReceiver implements StreamListener<String,
             if (null == queueBizMongoDto) {
                 aBoolean = true;
             } else {
-                String bizId = queueBizMongoDto.getBizId();
-                int opType = queueBizMongoDto.getOpType();
+                String collectName = queueBizMongoDto.getCollect(), columnName = queueBizMongoDto.getColumn();
+                String prefix = queueBizMongoDto.getBizId(), bizId = queueBizMongoDto.getBizId();
 
-                Object o = redisUtil.get(bizId);
-                switch (opType) {
+                switch (queueBizMongoDto.getOpType()) {
                     case 1:// insert
-                        mongoTemplate.insert("");
+                        mongoTemplate.insert(redisUtil.get(prefix.concat(bizId)), collectName);
+                        aBoolean = true;
                         break;
                     case 2:// update
-                        mongoTemplate.getCollection("");
-                        break;
+                        BasicDBObject basicDBObject = (BasicDBObject) AbstractMdbRedisReceiver.BASIC_DB_OBJECT.clone();
+                        UpdateResult updateResult = mongoTemplate.getCollection(collectName).updateOne(
+                                Query.query(Criteria.where(columnName).is(bizId)).getQueryObject(),
+                                basicDBObject.append("$set", mongoTemplate.getConverter().convertToMongoType(redisUtil.get(prefix.concat(bizId))))
+                        );
+                        aBoolean = updateResult.getModifiedCount() > 0;
                 }
             }
         } catch (Exception e) {
@@ -74,7 +84,7 @@ public abstract class AbstractMdbRedisReceiver implements StreamListener<String,
         } finally {
             if (!aBoolean) {
                 HashMap<String, String> map = CollectionUtil.mapStringString();
-                map.put("message", msg);
+                map.put(MQConst.QUEUE_MESSAGE_KEY, msg);
                 stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(this.getRedisStreamKey()));
             }
         }

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

@@ -7,6 +7,7 @@ import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.UserPathDto;
 import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.constant.GoblinStatusConst;
 import com.liquidnet.service.goblin.dto.vo.*;
 import com.liquidnet.service.goblin.entity.GoblinNftOrder;
@@ -780,8 +781,8 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
         digitalArtworkVo.setPublisher(goodsInfoVo.getPublisher());
 
         // Mongo记录VO
-//        goblinOrderUtils.setMongoList("GoblinUserDigitalArtworkVo", "artworkId", digitalArtworkVo.getArtworkId(), "goblin:u_d_art:", 1);
-        goblinMongoUtils.insertGoblinUserDigitalArtworkVo(digitalArtworkVo);
+        goblinOrderUtils.setMongoList(GoblinUserDigitalArtworkVo.class.getSimpleName(), "artworkId", digitalArtworkVo.getArtworkId(), GoblinRedisConst.USER_DIGITAL_ARTWORK, 1);
+//        goblinMongoUtils.insertGoblinUserDigitalArtworkVo(digitalArtworkVo);
         // Redis记录VO
         goblinRedisUtils.setGoblinUserDigitalArtworkVo(digitalArtworkVo);
         // Redis更新藏品ID列表