调用生成藏品修改

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

@@ -671,7 +671,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
 //                artworkGenDto.setSkuId(orderVo.getSkuId());
 //                artworkGenDto.setSource(1);
 //                queueUtils.sendMsgByRedis(MQConst.GoblinQueue.BIZ_ARTWORK_GEN.getKey(), artworkGenDto.toJson());
-                this.generateUserArtwork(orderVo);
+                this.generateUserArtwork(orderVo, 1);
                 // 增加销量
                 goblinRedisUtils.incrSkuSaleCount(orderVo.getSpuId(), orderVo.getSkuId(), orderVo.getNum());
                 // TODO: jxl 2022/4/24  判断技术部NFT记录Redis setBuyNftTec
@@ -825,7 +825,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
                 // 加积分
                 goblinOrderUtils.integral(uid, orderVo.getPriceActual(), "购买数字藏品", 1);
                 // 生产藏品列表
-                this.generateUserArtwork(orderVo);
+                this.generateUserArtwork(orderVo, orderType == 4 ? 31 : 2);
                 // 增加销量
                 goblinRedisUtils.incrSkuSaleCount(orderVo.getSpuId(), orderVo.getSkuId(), orderVo.getNum());
                 // 写入用户订单列表 因取消的订单不展示 所以放在这里
@@ -850,9 +850,8 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
      *
      * @param orderVo
      */
-    private void generateUserArtwork(GoblinNftOrderVo orderVo) {
+    private void generateUserArtwork(GoblinNftOrderVo orderVo, Integer source) {
         String uid = orderVo.getUserId(), skuId = orderVo.getSkuId(), orderId = orderVo.getOrderId(), spuId = orderVo.getSpuId();
-        Integer source = 1;
         if (goblinRedisUtils.hasGenUserDigitalArtwork(uid, skuId, orderId)) {// 已生成
             log.warn("#GEN_ARTWORK EXIST_ART[uid={},skuId={},orderId={},source={}]", uid, skuId, orderId, source);
             return;
@@ -867,7 +866,7 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
         digitalArtworkVo.setUid(uid);
         digitalArtworkVo.setOrderId(orderId);
         digitalArtworkVo.setSource(source);
-        digitalArtworkVo.setState(0);
+        digitalArtworkVo.setState(source == 31 ? 5 : 0);
         digitalArtworkVo.setDelFlg("0");
         digitalArtworkVo.setCreatedAt(now);
         digitalArtworkVo.setAuthor(goodsInfoVo.getAuthor());
@@ -884,11 +883,13 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
         // Redis生成标记（缓存三天），用于上面的生成检查
         goblinRedisUtils.markGenUserDigitalArtwork(uid, skuId, orderId);
 
-        GoblinGoodsSkuInfoVo goodsSkuInfoVo = goblinRedisUtils.getGoodsSkuInfoVo(skuId);
-        if ("0".equals(goodsSkuInfoVo.getUnbox())) {// 非盲盒，NFT发行购买
-            ObjectNode bizNftBuyNode = JsonUtils.OM().createObjectNode().put("nftOrderPayId", orderId).put("routerType", goodsSkuInfoVo.getRouteType())
-                    .put("skuId", skuId).put("userId", uid).put("buyTimestamp", DateUtil.Formatter.yyyyMMddHHmmss.format(now));
-            queueUtils.sendMsgByRedis(MQConst.GalaxyQueue.JSON_NFT_PUBLISH_AND_BUY.getKey(), bizNftBuyNode.toString());
+        if (source != 31) {// 空头需要领取再发行
+            GoblinGoodsSkuInfoVo goodsSkuInfoVo = goblinRedisUtils.getGoodsSkuInfoVo(skuId);
+            if ("0".equals(goodsSkuInfoVo.getUnbox())) {// 非盲盒，NFT发行购买
+                ObjectNode bizNftBuyNode = JsonUtils.OM().createObjectNode().put("nftOrderPayId", orderId).put("routerType", goodsSkuInfoVo.getRouteType())
+                        .put("skuId", skuId).put("userId", uid).put("buyTimestamp", DateUtil.Formatter.yyyyMMddHHmmss.format(now));
+                queueUtils.sendMsgByRedis(MQConst.GalaxyQueue.JSON_NFT_PUBLISH_AND_BUY.getKey(), bizNftBuyNode.toString());
+            }
         }
 
         // Mysql持久化