nft修改购买逻辑

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/constant/GalaxyErrorEnum.java

@@ -20,6 +20,7 @@ public enum GalaxyErrorEnum {
     SERIES_CLAIM_PROCESSING("NFT0010008","系列声明正在处理中,不允许重复声明！"),
     SERIES_CLAIM_SUCCESSED("NFT0010009","系列已声明成功，不允许重复声明！"),
     SERIES_CLAIM_NOT_EXIST("NFT0010010","系列声明初始化信息不存在，请检查是否已上传对应素材！"),
+    SERIES_NFT_INFO_NOT_EXIST("NFT0010015","系列NFT信息查询不存在！"),
     PUBLISH_ORDER_NOT_EXIST("NFT0010011","NFT购买订单不存在!"),
     NFT_BUY_TASK_NOT_EXIST("NFT0010012","NFT购买执行任务不存在"),
     NFT_BUY_TASK_HAVE_EXIST("NFT0010013","NFT购买执行任务已存在，不可以重复购买!"),

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-common/src/main/java/com/liquidnet/service/galaxy/utils/AbstractDataUtils.java

@@ -116,7 +116,7 @@ public abstract class AbstractDataUtils {
 //        insert into galaxy_series_info (mid, series_info_id, series_name, series_code, series_id, total_count
 //                , crt_count,series_claim_task_id, series_claim_status, cover_url, series_desc
 //                , nft_count,router_type, created_at, updated_at)
-        Integer nftCount = 1;//默认为一个系列包含一个NFT
+        Integer nftCount = seriesInfoBo.getNftCount();//默认为一个系列包含一个NFT
 
         //mongo入库
         GalaxySeriesInfoVo seriesInfoVo = GalaxySeriesInfoVo.getNew();

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinArtworkBiz.java

@@ -187,18 +187,11 @@ public class ZxinArtworkBiz {
         //返回参数
         String seriesId = null;
         String taskId = null;
+
+        GalaxyArtSeriesClaimRespDto seriesClaimRespDto = GalaxyArtSeriesClaimRespDto.getNew();
         if(nft30RespDto.isSuccess()){
             //第零个系列 无限制系列
             taskId = nft30RespDto.getData().getTaskId();
-        }
-
-        GalaxyArtSeriesClaimRespDto seriesClaimRespDto = GalaxyArtSeriesClaimRespDto.getNew();
-        seriesClaimRespDto.setSkuId(skuId);
-        seriesClaimRespDto.setNftUrl(seriesNftUploadBo.getNftUrl());
-        seriesClaimRespDto.setDisplayUrl(seriesNftUploadBo.getDisplayUrl());
-        seriesClaimRespDto.setSeriesId(seriesId);
-        seriesClaimRespDto.setSeriesName(seriesName);
-
             //构造缓存数据
             if(StringUtil.isNull(seriesInfoBo)){
                 //
@@ -217,6 +210,15 @@ public class ZxinArtworkBiz {
                 GalaxySeriesNftInfoBo seriesNftInfoBo = this.buildSeriesNftInfoBo(reqDto,seriesInfoBo,seriesNftUploadBo);
                 dataUtils.setSeriesNftInfoBo(reqDto.getRouterType(),reqDto.getSkuId(),seriesInfoBo,seriesNftInfoBo);
             }
+        }else{
+            return ResponseDto.failure(GalaxyErrorEnum.SERIES_CLAIM_ERROR.getCode(),GalaxyErrorEnum.SERIES_CLAIM_ERROR.getMessage());
+        }
+
+        seriesClaimRespDto.setSkuId(skuId);
+        seriesClaimRespDto.setNftUrl(seriesNftUploadBo.getNftUrl());
+        seriesClaimRespDto.setDisplayUrl(seriesNftUploadBo.getDisplayUrl());
+        seriesClaimRespDto.setSeriesId(seriesId);
+        seriesClaimRespDto.setSeriesName(seriesName);
 
         return ResponseDto.success(seriesClaimRespDto);
     }
@@ -328,6 +330,9 @@ public class ZxinArtworkBiz {
         //根据skuId获取系列nft信息
         GalaxySeriesNftInfoBo seriesNftInfoBo = dataUtils.getSeriesNftInfoBo(reqDto.getRouterType(),reqDto.getSkuId());
 
+        if(StringUtil.isNull(seriesNftInfoBo)){
+            return ResponseDto.failure(GalaxyErrorEnum.SERIES_NFT_INFO_NOT_EXIST.getCode(), GalaxyErrorEnum.SERIES_NFT_INFO_NOT_EXIST.getMessage());
+        }
         String seriesCode = seriesNftInfoBo.getSeriesCode();
 
         //获取任务ID

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinPublishBiz.java

@@ -63,6 +63,10 @@ public class ZxinPublishBiz {
 
         //获取sku信息
         GalaxySeriesNftInfoBo seriesNftInfoBo = dataUtils.getSeriesNftInfoBo(reqDto.getRouterType(),reqDto.getSkuId());
+        if(StringUtil.isNull(seriesNftInfoBo)){
+            return ResponseDto.failure(GalaxyErrorEnum.SERIES_NFT_INFO_NOT_EXIST.getCode(), GalaxyErrorEnum.SERIES_NFT_INFO_NOT_EXIST.getMessage());
+        }
+
         /**
          * 获取订单和nft绑定信息
          */

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinTradeBiz.java

@@ -99,6 +99,9 @@ public class ZxinTradeBiz {
 
         //获取sku信息
         GalaxySeriesNftInfoBo seriesNftInfoBo = dataUtils.getSeriesNftInfoBo(reqDto.getRouterType(),reqDto.getSkuId());
+        if(StringUtil.isNull(seriesNftInfoBo)){
+            return ResponseDto.failure(GalaxyErrorEnum.SERIES_NFT_INFO_NOT_EXIST.getCode(), GalaxyErrorEnum.SERIES_NFT_INFO_NOT_EXIST.getMessage());
+        }
 
         //初始化订单数据
         if(nftOrderBo==null){