~生成藏品:冗余记录我的藏品列表+返回创作者字段;

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

@@ -10,6 +10,7 @@ import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.goblin.constant.GoblinRedisConst;
 import com.liquidnet.service.goblin.dto.GoblinQueueBizArtworkGenDto;
+import com.liquidnet.service.goblin.dto.vo.GoblinGoodsInfoVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinUserDigitalArtworkVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinGoodsSkuInfoVo;
 import lombok.extern.slf4j.Slf4j;
@@ -97,6 +98,8 @@ public class ConsumerGoblinBizArtworkGenRdsReceiver extends AbstractBizRedisRece
 //                return true;
 //            }
 
+        GoblinGoodsInfoVo goodsInfoVo = this.getGoodsInfoVoFromRdb(goodsSkuInfoVo.getSpuId());
+
         LocalDateTime now = LocalDateTime.now();
 
         GoblinUserDigitalArtworkVo digitalArtworkVo = GoblinUserDigitalArtworkVo.getNew();
@@ -109,6 +112,8 @@ public class ConsumerGoblinBizArtworkGenRdsReceiver extends AbstractBizRedisRece
         digitalArtworkVo.setState(0);
         digitalArtworkVo.setDelFlg("0");
         digitalArtworkVo.setCreatedAt(now);
+        digitalArtworkVo.setAuthor(goodsInfoVo.getAuthor());
+        digitalArtworkVo.setPublisher(goodsInfoVo.getPublisher());
 
         // Mongo记录VO
         mongoTemplate.insert(digitalArtworkVo, GoblinUserDigitalArtworkVo.class.getSimpleName());
@@ -201,6 +206,15 @@ public class ConsumerGoblinBizArtworkGenRdsReceiver extends AbstractBizRedisRece
         return vo;
     }
 
+    public GoblinGoodsInfoVo getGoodsInfoVoFromRdb(String spuId) {
+        String rk = GoblinRedisConst.BASIC_GOODS.concat(spuId);
+        GoblinGoodsInfoVo vo = (GoblinGoodsInfoVo) redisUtil.get(rk);
+        if (null == vo && null != (vo = this.getGoodsInfoVoFromMdb(spuId))) {
+            redisUtil.set(rk, vo);
+        }
+        return vo;
+    }
+
     public GoblinUserDigitalArtworkVo getUserDigitalArtworkVoFromRdb(String artworkId) {
         return (GoblinUserDigitalArtworkVo) redisUtil.get(GoblinRedisConst.USER_DIGITAL_ARTWORK.concat(artworkId));
     }
@@ -216,6 +230,11 @@ public class ConsumerGoblinBizArtworkGenRdsReceiver extends AbstractBizRedisRece
                 GoblinGoodsSkuInfoVo.class, GoblinGoodsSkuInfoVo.class.getSimpleName());
     }
 
+    public GoblinGoodsInfoVo getGoodsInfoVoFromMdb(String spuId) {
+        return mongoTemplate.findOne(Query.query(Criteria.where("spuId").is(spuId)),
+                GoblinGoodsInfoVo.class, GoblinGoodsInfoVo.class.getSimpleName());
+    }
+
 //    public GoblinDigitalArtworkVo getDigitalArtworkVoFromMdb(String uid, String skuId, String orderId) {
 //        return mongoTemplate.findOne(Query.query(Criteria.where("uid").is(uid).and("skuId").is(skuId).and("orderId").is(orderId)),
 //                GoblinDigitalArtworkVo.class, GoblinDigitalArtworkVo.class.getSimpleName());