实现zxtnft购买功能

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

@@ -300,7 +300,7 @@ public class TestZxlnftService {
         //发行个数
         Long publishCount = 1L;
         //开始索引
-        Integer seriesBeginIndex = 14;
+        Integer seriesBeginIndex = 15;
         Long sellCount = 1000L; //积分
         //无限制系列
         String seriesId = "4e40d5f6f65aa8ec9bc33ab424e0167e68783bbe95d4d265086314d749808eef_8a827e181b695fb8d9b081d3855d2895ced1d003ee186622a005cec37ea77e59";
@@ -340,33 +340,39 @@ public class TestZxlnftService {
             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());
+                if(nft035RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_FAIL.getCode())){
+                    log.info("任务执行失败！taskId:{} taskMsg:{}",nft035ReqDto.getTaskId(),nft035RespDto.getData().getTaskMsg());
+                    return;
                 }
 
                 int count  = 1;
                 String nftIdBegin = null;
-                while(StringUtil.isEmpty(nftIdBegin)){
-                    try {
-                        Thread.sleep(1000l);
-                    } catch (InterruptedException e) {
-                        e.printStackTrace();
-                    }
-                    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;
+                if(nft035RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.PROCESSING.getCode())){
+                    log.info(ZxlnftEnum.TaskStatusEnum.PROCESSING.getMessage());
+                    while(StringUtil.isEmpty(nftIdBegin)){
+                        try {
+                            Thread.sleep(1000l);
+                        } catch (InterruptedException e) {
+                            e.printStackTrace();
+                        }
+                        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();
+                        }else if(nft035RespDtoTemp.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_FAIL.getCode())){
+                            log.info("任务执行失败！taskId:{}",nft035ReqDto.getTaskId());
+                            return;
+                        }
+
+                        if(count==6){
+                            log.info("=======查询共6次，跳出循环！taskId:{}",nft035ReqDto.getTaskId());
+                            break;
+                        }
                     }
+                }else if(nft035RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
+                    log.info(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getMessage());
                 }
 
                 log.info("发行NFT后返回给前端nftID:{}",nftIdBegin);