实现zxtnft购买功能

liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-zxlnft/src/main/java/com/liquidnet/common/third/zxlnft/constant/ZxlnftEnum.java

@@ -170,7 +170,7 @@ public class ZxlnftEnum {
      */
     public enum TaskStatusEnum{
         PROCESSING("2","任务执行中"),
-        TASK_SECCESS("7","任务成功"),
+        TASK_SUCCESS("7","任务成功"),
         TASK_FAIL("10","任务失败");
 
 

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/test/java/com/liquidnet/service/galaxy/TestZxlnftService.java

@@ -255,7 +255,7 @@ public class TestZxlnftService {
             ZxlnftResponseDto<Nft031SeriesClaimResultRespDto> nft031RespDto = zxlnftSdkUtil.nft031SeriesClaimResult(nft031ReqDto);
             if(nft031RespDto.isSuccess()){
                 log.info("系列声明结果查询 ：{}",nft031RespDto.toJson());
-                if(nft031RespDto.getData().getTaskStatus().equals(ZxlnftEnum.TaskStatusEnum.TASK_SECCESS.getCode())){
+                if(nft031RespDto.getData().getTaskStatus().equals(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
                     seriesId = nft031RespDto.getData().getSeriesId();
                 }
 //                {
@@ -332,30 +332,55 @@ public class TestZxlnftService {
         ZxlnftResponseDto<Nft034PublishRespDto> nft034RespDto = zxlnftSdkUtil.nft034Publish(nft034ReqDto);
 
         if(nft034RespDto.isSuccess()){
+            //3.1.4查询 NFT发行结果
+            Nft035PublishResultReqDto nft035ReqDto = Nft035PublishResultReqDto.getNew();
+            nft035ReqDto.setTaskId(nft034RespDto.getData().getTaskId());
+            long timeStart = System.currentTimeMillis();
+            log.info("=======执行第{}次查询,taskId:{}",1,nft035ReqDto.getTaskId());
+            ZxlnftResponseDto<Nft035PublishResultRespDto> nft035RespDto = zxlnftSdkUtil.nft035PublishResult(nft035ReqDto);
+
+            if(nft035RespDto.isSuccess()){
+                if(nft035RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.PROCESSING.getCode())){
+                    log.info(ZxlnftEnum.TaskStatusEnum.PROCESSING.getMessage());
+                }else if(nft035RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
+                    log.info(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getMessage());
+                }else if(nft035RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_FAIL.getCode())){
+                    log.info("任务执行失败！taskId:{}",nft035ReqDto.getTaskId());
+                }
+
+                int count  = 1;
+                String nftIdBegin = null;
+                while(StringUtil.isEmpty(nftIdBegin)){
                     try {
                         Thread.sleep(1000l);
                     } catch (InterruptedException e) {
                         e.printStackTrace();
                     }
-            //3.1.4查询 NFT发行结果
-            Nft035PublishResultReqDto nft035ReqDto = Nft035PublishResultReqDto.getNew();
-            nft035ReqDto.setTaskId(nft034RespDto.getData().getTaskId());
-            ZxlnftResponseDto<Nft035PublishResultRespDto> resp = zxlnftSdkUtil.nft035PublishResult(nft035ReqDto);
-            if(resp.isSuccess()){
-                if(resp.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.PROCESSING.getCode())){
-                    log.info(ZxlnftEnum.TaskStatusEnum.PROCESSING.getMessage());
-                }else if(resp.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SECCESS.getCode())){
-                    log.info(ZxlnftEnum.TaskStatusEnum.TASK_SECCESS.getMessage());
-                }else if(resp.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_FAIL.getCode())){
-                    log.info(ZxlnftEnum.TaskStatusEnum.TASK_FAIL.getMessage());
+                    count++;
+                    log.info("=======执行第{}次查询,taskId:{}",count,nft035ReqDto.getTaskId());
+                    ZxlnftResponseDto<Nft035PublishResultRespDto> nft035RespDtoTemp = zxlnftSdkUtil.nft035PublishResult(nft035ReqDto);
+                    if(nft035RespDtoTemp.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
+                        nftIdBegin = nft035RespDtoTemp.getData().getNftIdBegin();
                     }
+
+                    if(count==6){
+                        log.info("=======查询共6次，跳出循环！taskId:{}",nft035ReqDto.getTaskId());
+                        break;
                     }
                 }
-//        3.1.3调用NFT查询接口
+
+                log.info("发行NFT后返回给前端nftID:{}",nftIdBegin);
+                log.info("总共执行了{}次查询 总耗时:{} MS",count,(System.currentTimeMillis() - timeStart));
+
+                if(StringUtil.isNotEmpty(nftIdBegin)){
+                    //3.1.3调用NFT查询接口
                     Nft036InfoReqDto nft036ReqDto = Nft036InfoReqDto.getNew();
-        nft036ReqDto.setNftId("43c169ae33d2ca5390a49d2319c14223ed5e7447c4b40c0422ef81691ddfee89_16");
-        ZxlnftResponseDto<Nft036InfoRespDto> resp = zxlnftSdkUtil.nft036Info(nft036ReqDto);
-        log.info("调用NFT查询接口 : {}",resp.toJson());
+                    nft036ReqDto.setNftId(nftIdBegin);
+                    ZxlnftResponseDto<Nft036InfoRespDto> nft036RespDto = zxlnftSdkUtil.nft036Info(nft036ReqDto);
+                    log.info("调用NFT查询接口 : {}",nft036RespDto.toJson());
+                }
+            }
+        }
     }
 
     /**
@@ -408,7 +433,7 @@ public class TestZxlnftService {
                     }
                     count++;
                     ZxlnftResponseDto<Nft044BuyResultRespDto> nft044RespDtoTemp = zxlnftSdkUtil.nft044BuyResult(nft044ReqDto);
-                    if(nft044RespDtoTemp.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SECCESS.getCode())){
+                    if(nft044RespDtoTemp.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
                         payTaskId = nft044RespDtoTemp.getData().getPayTaskId();
                     }
                 }