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

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

@@ -345,45 +345,55 @@ public class ZxinTradeCommonBiz {
         String nftBuyTradeHash = null;
         String nftBuyPayTaskId = null;
 
-//        3.2.2调用购买NFT接口
-        Nft043BuyReqDto nft043BuyReqDto = Nft043BuyReqDto.getNew();
-        nft043BuyReqDto.setNftId(nftId);
-        nft043BuyReqDto.setApplyScore(seriesNftInfoBo.getSellCount().intValue());
-        try {
-            nft043BuyReqDto.setReceiverPubKey(BASE64Util.decode(userInfoBo.getUserPubKey()));
-        } catch (UnsupportedEncodingException e) {
-            e.printStackTrace();
+        //如果购买任务不为空，则直接进行购买任务查询
+        if(StringUtil.isNotEmpty(nftOrderBo.getNftBuyTaskId())){
+            nftBuyTaskId = nftOrderBo.getNftBuyTaskId();
         }
-        nft043BuyReqDto.setPointReceiverAddr(userInfoBo.getBlockChainAddress());
-        nft043BuyReqDto.setOfferCount(seriesNftInfoBo.getSellCount().longValue());
-        nft043BuyReqDto.setOperateId(IDGenerator.get32UUID());
 
-        /**
-         * 接收人的私钥签名，签名对象是(platformPubKey_receiverPubKey_pointReceiverAddr_applyScore_接口名_nftId_offerCount_operateId)
-         * 接口名：buy_nft
-         */
-        String signMetaData = zxlnftConfig.getNftPlatformPubKey()
-                .concat("_").concat(nft043BuyReqDto.getReceiverPubKey())
-                .concat("_").concat(nft043BuyReqDto.getPointReceiverAddr())
-                .concat("_").concat(nft043BuyReqDto.getApplyScore().toString())
-                .concat("_").concat("buy_nft")
-                .concat("_").concat(nft043BuyReqDto.getNftId())
-                .concat("_").concat(nft043BuyReqDto.getOfferCount().toString())
-                .concat("_").concat(nft043BuyReqDto.getOperateId());
-        String signature = null;
-        try {
-            signature = zxlnftBiz.createSign(BASE64Util.decode(userInfoBo.getUserPriKey()),signMetaData);
-        } catch (UnsupportedEncodingException e) {
-            e.printStackTrace();
-        }
-        nft043BuyReqDto.setSignature(signature);
+        if(StringUtil.isEmpty(nftBuyTaskId)){
+            //        3.2.2调用购买NFT接口
+            Nft043BuyReqDto nft043BuyReqDto = Nft043BuyReqDto.getNew();
+            nft043BuyReqDto.setNftId(nftId);
+            nft043BuyReqDto.setApplyScore(seriesNftInfoBo.getSellCount().intValue());
+            try {
+                nft043BuyReqDto.setReceiverPubKey(BASE64Util.decode(userInfoBo.getUserPubKey()));
+            } catch (UnsupportedEncodingException e) {
+                e.printStackTrace();
+            }
+            nft043BuyReqDto.setPointReceiverAddr(userInfoBo.getBlockChainAddress());
+            nft043BuyReqDto.setOfferCount(seriesNftInfoBo.getSellCount().longValue());
+            nft043BuyReqDto.setOperateId(IDGenerator.get32UUID());
 
-        ZxlnftResponseDto<Nft043BuyRespDto> nft043RespDto = zxlnftSdkUtil.nft043Buy(nft043BuyReqDto);
-        if(nft043RespDto.isSuccess()){
-            try{
+            /**
+             * 接收人的私钥签名，签名对象是(platformPubKey_receiverPubKey_pointReceiverAddr_applyScore_接口名_nftId_offerCount_operateId)
+             * 接口名：buy_nft
+             */
+            String signMetaData = zxlnftConfig.getNftPlatformPubKey()
+                    .concat("_").concat(nft043BuyReqDto.getReceiverPubKey())
+                    .concat("_").concat(nft043BuyReqDto.getPointReceiverAddr())
+                    .concat("_").concat(nft043BuyReqDto.getApplyScore().toString())
+                    .concat("_").concat("buy_nft")
+                    .concat("_").concat(nft043BuyReqDto.getNftId())
+                    .concat("_").concat(nft043BuyReqDto.getOfferCount().toString())
+                    .concat("_").concat(nft043BuyReqDto.getOperateId());
+            String signature = null;
+            try {
+                signature = zxlnftBiz.createSign(BASE64Util.decode(userInfoBo.getUserPriKey()),signMetaData);
+            } catch (UnsupportedEncodingException e) {
+                e.printStackTrace();
+            }
+            nft043BuyReqDto.setSignature(signature);
+
+            ZxlnftResponseDto<Nft043BuyRespDto> nft043RespDto = zxlnftSdkUtil.nft043Buy(nft043BuyReqDto);
+            if(nft043RespDto.isSuccess()){
                 nftBuyTaskId = nft043RespDto.getData().getTaskId();
                 nftOrderBo.setNftBuyTaskId(nftBuyTaskId);
+            }
+        }
 
+        //如果购买任务id不为空
+        if(StringUtil.isNotEmpty(nftBuyTaskId)){
+            try{
                 //3.2.4查询NFT购买结果
                 Nft044BuyResultReqDto nft044ReqDto = Nft044BuyResultReqDto.getNew();
                 nft044ReqDto.setTaskId(nftBuyTaskId);
@@ -445,11 +455,11 @@ public class ZxinTradeCommonBiz {
             nftOrderBo.setNftBuyTradeHash(nftBuyTradeHash);
             nftOrderBo.setNftBuyPayTaskId(nftBuyPayTaskId);
             nftOrderBo.setUpdatedAt(LocalDateTime.now());
-            //先更新nft发行数据
+            //先更新nft购买数据
             dataUtils.updateNftOrderBuyInfo(routerType,nftOrderBo.getNftOrderPayId(),nftOrderBo);
         }else{
             //购买失败
-            throw new GalaxyNftBuyException(GalaxyErrorEnum.NFT_BUY_ERROR.getCode(),"nft043Buy_resp:"+nft043RespDto.getMessage());
+            throw new GalaxyNftBuyException(GalaxyErrorEnum.NFT_BUY_ERROR.getCode(),"nft043Buy_resp: nftBuyTaskId："+nftBuyTaskId);
         }
         GalaxyNftBuyRespDto nftBuyRespDto = GalaxyNftBuyRespDto.getNew();
         nftBuyRespDto.setUserId(userInfoBo.getUserId());