实现xuper发行购买功能

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-common/src/main/java/com/liquidnet/service/galaxy/router/xuper/biz/XuperTradeCommonBiz.java

@@ -151,7 +151,7 @@ public class XuperTradeCommonBiz {
 
                 int count  = 0;
                 while(nftBuyPayTaskId == null){
-                    Thread.sleep(500l);
+                    Thread.sleep(1000l);
                     count++;
                     log.info("=======执行nft购买第{}次查询,taskId:{}",count,nft044ReqDto.getTaskId());
                     //执行nft购买结果查询

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

@@ -114,7 +114,7 @@ public abstract class AbstractDataUtils {
         try{
             this.getQueueUtil().sendMySqlRedis(
                     SqlMapping.get("galaxy_series_info.insert"),
-                    new Object[]{seriesInfoBo.getSeriesInfoId(),seriesInfoBo.getSeriesName(),seriesCode,null,seriesInfoBo.getTotalCount()
+                    new Object[]{seriesInfoBo.getSeriesInfoId(),seriesInfoBo.getSeriesName(),seriesCode,seriesInfoBo.getSeriesId(),seriesInfoBo.getTotalCount()
                             ,seriesInfoBo.getCrtCount(),seriesInfoBo.getSeriesClaimTaskId(),seriesInfoBo.getSeriesClaimStatus(),seriesInfoBo.getCoverUrl(),seriesInfoBo.getSeriesDesc()
                             ,nftCount,seriesInfoBo.getTradeHash(),seriesInfoBo.getRouterType(),LocalDateTime.now(),null
                     }

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/galaxy/router/xuper/biz/XuperArtworkBiz.java

@@ -3,6 +3,7 @@ package com.liquidnet.service.galaxy.router.xuper.biz;
 import com.baidu.xasset.auth.Crypto;
 import com.baidu.xasset.client.base.Base;
 import com.baidu.xuper.api.Account;
+import com.liquidnet.common.exception.constant.ErrorCode;
 import com.liquidnet.common.third.xuper.config.XuperConfig;
 import com.liquidnet.common.third.xuper.constant.XuperEnum;
 import com.liquidnet.common.third.xuper.dto.*;
@@ -266,6 +267,11 @@ public class XuperArtworkBiz {
         return ResponseDto.success(seriesClaimRespDto);
     }
 
+    /**
+     * 系列声明结果查询
+     * @param reqDto
+     * @return
+     */
     public ResponseDto<GalaxyArtSeriesClaimResultQueryRespDto> seriesClaimResultQuery(GalaxyArtSeriesClaimResultQueryReqDto reqDto) {
         //根据skuId获取系列nft信息
         GalaxySeriesNftInfoBo seriesNftInfoBo = dataUtils.getSeriesNftInfoBo(reqDto.getRouterType(),reqDto.getSkuId());
@@ -314,14 +320,12 @@ public class XuperArtworkBiz {
             log.error("sys error msg "+e.getMessage(),e);
         }
         log.info("seriesClaimResultQuery resp : "+ JsonUtils.toJson(respDto));
-        if(respDto.getErrNo() == 0){
-            if(respDto.getMeta().getStatus() == Integer.parseInt(XuperEnum.AssetPublishStatusEnum.INIT.getCode())
-            || respDto.getMeta().getStatus() == Integer.parseInt(XuperEnum.AssetPublishStatusEnum.PUBLISH_SUCCESS.getCode())){
+        if(respDto.getErrNo() == Integer.parseInt(ErrorCode.SUCCESS.getCode())){
+            if(respDto.getMeta().getStatus() == Integer.parseInt(XuperEnum.AssetPublishStatusEnum.INIT.getCode())){
                 //设置系列声明状态
                 seriesInfoBo.setSeriesClaimStatus(GalaxyEnum.SeriesClaimStatusEnum.SUCCESS.getCode());
                 String nowTimeStr = DateUtil.getNowTime();
                 seriesInfoBo.setChainTimestamp(nowTimeStr);
-                seriesInfoBo.setTradeHash(respDto.getMeta().getTxId());
                 seriesInfoBo.setSeriesId(String.valueOf(respDto.getMeta().getAssetId()));
                 seriesInfoBo.setUpdatedAt(LocalDateTime.now());
 
@@ -335,8 +339,7 @@ public class XuperArtworkBiz {
                 GalaxyArtSeriesClaimResultQueryRespDto resultQueryRespDto = this.buildGalaxyArtSeriesClaimResultQueryRespDto(reqDto,seriesInfoBo,XuperEnum.AssetPublishStatusEnum.INIT.getCode());
 
                 return ResponseDto.success(resultQueryRespDto);
-            }else if(respDto.getMeta().getStatus() != Integer.parseInt(XuperEnum.AssetPublishStatusEnum.INIT.getCode())
-                    && respDto.getMeta().getStatus() != Integer.parseInt(XuperEnum.AssetPublishStatusEnum.PUBLISH_SUCCESS.getCode())){
+            }else{
                 seriesInfoBo.setSeriesClaimStatus(GalaxyEnum.SeriesClaimStatusEnum.FAIL.getCode());
                 seriesInfoBo.setUpdatedAt(LocalDateTime.now());
 

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/test/java/com/liquidnet/service/goblin/test/xuper/TestXuperSdkUtil.java

@@ -449,9 +449,10 @@ public class TestXuperSdkUtil {
         Xuper010QuerySdsReqDto reqDto = Xuper010QuerySdsReqDto.getNew();
         // 定义返回结果对象
         Xuper010QuerySdsRespDto respDto = null;
-//        long assetId = 171095615845019437l;
-        long assetId = 477060752401870637l;
-        long shardId = 4l;
+        long assetId = 171095615845019437l;
+//        assetId = 477060752401870637l;
+        assetId = 2203931451566698285l;
+        long shardId = 1l;
         try {
             reqDto.setAssetId(assetId);
             reqDto.setShardId(shardId);