修改 下单逻辑 完成需求

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

@@ -913,7 +913,11 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
                 // 加积分
                 goblinOrderUtils.integral(uid, orderVo.getPriceActual(), "购买数字藏品", 1);
                 // 生产藏品列表
-                this.generateUserArtwork(orderVo, orderType == 4 ? 31 : 2);
+                if (code.equals(orderVo.getSkuId())) {
+                    this.generateUserArtwork(orderVo, 5);
+                } else {
+                    this.generateUserArtwork(orderVo, orderType == 4 ? 31 : 2);
+                }
                 // 增加销量
                 goblinRedisUtils.incrSkuSaleCount(orderVo.getSpuId(), orderVo.getSkuId(), orderVo.getNum());
                 // 写入用户订单列表 因取消的订单不展示 所以放在这里
@@ -955,7 +959,11 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
         digitalArtworkVo.setUid(uid);
         digitalArtworkVo.setOrderId(orderId);
         digitalArtworkVo.setSource(source);
-        digitalArtworkVo.setState(source == 31 ? 5 : 0);
+        if (source == 5) {
+            digitalArtworkVo.setState(0);
+        } else {
+            digitalArtworkVo.setState(source == 31 ? 5 : 0);
+        }
         digitalArtworkVo.setDelFlg("0");
         digitalArtworkVo.setCreatedAt(now);
         digitalArtworkVo.setAuthor(goodsInfoVo.getAuthor());
@@ -978,7 +986,9 @@ public class GoblinNftOrderServiceImpl implements IGoblinNftOrderService {
             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 != 5) {
+                    queueUtils.sendMsgByRedis(MQConst.GalaxyQueue.JSON_NFT_PUBLISH_AND_BUY.getKey(), bizNftBuyNode.toString());
+                }
             }
         }