更新购买逻辑修复购买失败记录

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-common/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinTradeCommonBiz.java

@@ -85,7 +85,8 @@ public class ZxinTradeCommonBiz {
                 return ResponseDto.failure(GalaxyErrorEnum.PUBLISH_FAIL_ALREADY_EXIST.getCode(), GalaxyErrorEnum.PUBLISH_FAIL_ALREADY_EXIST.getMessage());
             }
             if(nftOrderBo.getNftPublishStatus().equalsIgnoreCase(GalaxyEnum.TaskStatusEnum.TASK_SUCCESS.getCode())
-                    &&nftOrderBo.getNftBuyStatus().equalsIgnoreCase(GalaxyEnum.TaskStatusEnum.INIT.getCode())){
+                    &&(nftOrderBo.getNftBuyStatus().equalsIgnoreCase(GalaxyEnum.TaskStatusEnum.INIT.getCode())
+                    ||nftOrderBo.getNftBuyStatus().equalsIgnoreCase(GalaxyEnum.TaskStatusEnum.PROCESSING.getCode()))){
                 //再次发起购买
                 GalaxyNftPublishAndBuyRespDto nftPublishAndBuyRespDto = this.executeBuyBusiness(reqDto,userInfoBo,seriesNftInfoBo,nftOrderBo);
                 if(StringUtil.isNotNull(nftPublishAndBuyRespDto)&&StringUtil.isNotEmpty(nftPublishAndBuyRespDto.getNftId())){
@@ -421,6 +422,8 @@ public class ZxinTradeCommonBiz {
                         nftBuyStatus = nft044RespDto.getData().getTaskStatus();
                     }
                     if(count==20){
+                        //查询超过20次，则把nftId设置为空，为后续重新入队
+                        nftId = null;
                         log.info("=======查询共5次，跳出循环！taskId:{}",nft044ReqDto.getTaskId());
                         break;
                     }
@@ -461,6 +464,7 @@ public class ZxinTradeCommonBiz {
             //购买失败
             throw new GalaxyNftBuyException(GalaxyErrorEnum.NFT_BUY_ERROR.getCode(),"nft043Buy_resp: nftBuyTaskId："+nftBuyTaskId);
         }
+
         GalaxyNftBuyRespDto nftBuyRespDto = GalaxyNftBuyRespDto.getNew();
         nftBuyRespDto.setUserId(userInfoBo.getUserId());
         nftBuyRespDto.setNftId(nftId);