~api:藏品转赠退回;

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

@@ -20,6 +20,7 @@ import com.liquidnet.service.goblin.util.QueueUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
@@ -496,13 +497,7 @@ public class GoblinUserDigitalArtworkServiceImpl implements IGoblinUserDigitalAr
             goblinRedisUtils.setUserDigitalArtworkVo(userDigitalArtworkVo);
 
             // Mongo藏品数据更新
-            MdbMessage mdbMessage = MdbMessage.getNew();
-            mdbMessage.setCollect(GoblinUserDigitalArtworkVo.class.getSimpleName());
-            mdbMessage.setColumn("artworkId");
-            mdbMessage.setBizId(artworkId);
-            mdbMessage.setPrefix(GoblinRedisConst.USER_DIGITAL_ARTWORK);
-            mdbMessage.setOpType(2);
-            queueUtils.sendMsgByRedis(MQConst.GoblinQueue.BIZ_NFT_MONGO.getKey(), mdbMessage.toJson());
+            goblinMongoUtils.updateUserDigitalArtworkVoByTransReturn(artworkId, currentDateTime);
 
             // Mysql转赠订单更新
             LinkedList<String> toMqSqls = CollectionUtil.linkedListString();

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

@@ -1639,6 +1639,19 @@ public class GoblinMongoUtils {
         return updateResult.getModifiedCount() > 0;
     }
 
+    /**
+     * 转赠退还后，恢复藏品信息
+     */
+    public boolean updateUserDigitalArtworkVoByTransReturn(String artworkId, LocalDateTime currentDateTime) {
+        Query queryMongo = Query.query(
+                Criteria.where("artworkId").is(artworkId).and("transferState").is(GoblinStatusConst.TransferState.WAITING.name())
+        );
+        Update updateMongo = Update.update("updatedAt", currentDateTime).unset("transferOrderId").unset("transferState")
+                .unset("receiverUid").unset("receiverUser").unset("transferAt");
+        UpdateResult updateResult = mongoTemplate.updateMulti(queryMongo, updateMongo, GoblinUserDigitalArtworkVo.class.getSimpleName());
+        return updateResult.getModifiedCount() > 0;
+    }
+
     public List<String> getPageUserDigitalArtworkIds(String uid, Integer pageNum, Integer pageSize) {
         Criteria criteria = Criteria.where("uid").is(uid).and("delFlg").is("0");
         Query query = Query.query(criteria);