至信链异常处理

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

@@ -2,8 +2,10 @@ package com.liquidnet.service.galaxy.router.zxin.biz;
 
 import com.liquidnet.common.third.zxlnft.biz.ZxlnftBiz;
 import com.liquidnet.common.third.zxlnft.config.ZxlnftConfig;
+import com.liquidnet.common.third.zxlnft.constant.ZxlErrorEnum;
 import com.liquidnet.common.third.zxlnft.constant.ZxlnftEnum;
 import com.liquidnet.common.third.zxlnft.dto.*;
+import com.liquidnet.common.third.zxlnft.exception.ZxlNftException;
 import com.liquidnet.common.third.zxlnft.util.ZxlnftSdkUtil;
 import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.base.ResponseDto;
@@ -233,6 +235,9 @@ public class ZxinTradeCommonBiz {
                         Thread.sleep(500l);
                         count++;
                         ZxlnftResponseDto<Nft035PublishResultRespDto> nft035RespDtoTemp = zxlnftSdkUtil.nft035PublishResult(nft035ReqDto);
+                        if(!nft035RespDtoTemp.isSuccess()){
+                            throw new ZxlNftException(ZxlErrorEnum.SYSTEM_ERROR.getCode(),ZxlErrorEnum.SYSTEM_ERROR.getMsg());
+                        }
                         log.info("=======执行第{}次查询,taskId:{}", count, nft035ReqDto.getTaskId());
                         if (nft035RespDtoTemp.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())) {
                             nftIdBegin = nft035RespDtoTemp.getData().getNftIdBegin();
@@ -414,6 +419,8 @@ public class ZxinTradeCommonBiz {
             if(nft043RespDto.isSuccess()){
                 nftBuyTaskId = nft043RespDto.getData().getTaskId();
                 nftOrderBo.setNftBuyTaskId(nftBuyTaskId);
+                //更新nftBuyTaskId
+                dataUtils.updateNftOrderBuyInfo(routerType,nftOrderBo.getNftOrderPayId(),nftOrderBo);
             }
         }
 
@@ -432,6 +439,9 @@ public class ZxinTradeCommonBiz {
                     count++;
                     log.info("=======执行第{}次查询,taskId:{}",count,nft044ReqDto.getTaskId());
                     ZxlnftResponseDto<Nft044BuyResultRespDto> nft044RespDto = zxlnftSdkUtil.nft044BuyResult(nft044ReqDto);
+                    if(!nft044RespDto.isSuccess()){
+                        throw new ZxlNftException(ZxlErrorEnum.SYSTEM_ERROR.getCode(),ZxlErrorEnum.SYSTEM_ERROR.getMsg());
+                    }
                     if(nft044RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
                         nftBuyPayTaskId = nft044RespDto.getData().getPayTaskId();
                         nftBuyChainTimestamp = nft044RespDto.getData().getChainTimestamp();