通过nft购买查询修复购买状态

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/biz/ZxinTradeBiz.java

@@ -3,6 +3,7 @@ package com.liquidnet.service.galaxy.router.zxin.biz;
 import com.liquidnet.common.exception.LiquidnetServiceException;
 import com.liquidnet.common.third.zxlnft.biz.ZxlnftBiz;
 import com.liquidnet.common.third.zxlnft.config.ZxlnftConfig;
+import com.liquidnet.common.third.zxlnft.constant.ZxlnftEnum;
 import com.liquidnet.common.third.zxlnft.dto.*;
 import com.liquidnet.common.third.zxlnft.util.ZxlnftSdkUtil;
 import com.liquidnet.commons.lang.util.*;
@@ -22,6 +23,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.io.UnsupportedEncodingException;
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -107,15 +109,51 @@ public class ZxinTradeBiz {
         nft044ReqDto.setTaskId(nftOrderBo.getNftBuyTaskId());
         ZxlnftResponseDto<Nft044BuyResultRespDto> nft044RespDto = zxlnftSdkUtil.nft044BuyResult(nft044ReqDto);
 
-
         GalaxyNftBuyResultQueryRespDto resultQueryRespDto = GalaxyNftBuyResultQueryRespDto.getNew();
         if(nft044RespDto.isSuccess()){
-            BeanUtil.copy(nft044RespDto.getData(),resultQueryRespDto);
-            String nowTimeStr = DateUtil.format(new Date(nft044RespDto.getData().getChainTimestamp().longValue()*1000),DateUtil.Formatter.yyyyMMddHHmmss);
-            //转换任务状态
-            Integer taskStatus = Integer.valueOf(GalaxyEnumBiz.getTaskStatusEnum(reqDto.getRouterType(),nft044RespDto.getData().getTaskStatus().toString()).getCode());
-            resultQueryRespDto.setTaskStatus(taskStatus);
-            resultQueryRespDto.setChainTimestamp(nowTimeStr);
+            if(nft044RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_SUCCESS.getCode())){
+                Long nftBuyChainTimestamp = nft044RespDto.getData().getChainTimestamp();
+                Integer nftBuyStatus = nft044RespDto.getData().getTaskStatus();
+                String nftBuyTradeHash = nft044RespDto.getData().getTxHash();;
+                String nftBuyPayTaskId = nft044RespDto.getData().getPayTaskId();
+                //更新订单缓存数据状态
+                if(StringUtil.isNotNull(nftBuyChainTimestamp)&&nftBuyChainTimestamp!=0){
+                    //设置时间
+                    String nftBuyChainTimestampStr = DateUtil.format(new Date(nftBuyChainTimestamp*1000),DateUtil.Formatter.yyyyMMddHHmmss);
+                    nftOrderBo.setNftBuyChainTimestamp(nftBuyChainTimestampStr);
+                }
+                if(StringUtil.isNotNull(nftBuyStatus)){
+                    //转换任务状态
+                    String nftBuyStatusStr = GalaxyEnumBiz.getTaskStatusEnum(nftOrderBo.getRouterType(),nftBuyStatus.toString()).getCode();
+
+                    nftOrderBo.setNftBuyStatus(nftBuyStatusStr);
+                }
+                nftOrderBo.setNftBuyTradeHash(nftBuyTradeHash);
+                nftOrderBo.setNftBuyPayTaskId(nftBuyPayTaskId);
+                nftOrderBo.setUpdatedAt(LocalDateTime.now());
+                //先更新nft购买数据
+                dataUtils.updateNftOrderBuyInfo(nftOrderBo.getRouterType(),nftOrderBo.getNftOrderPayId(),nftOrderBo);
+            }else if(nft044RespDto.getData().getTaskStatus().toString().equals(ZxlnftEnum.TaskStatusEnum.TASK_FAIL.getCode())){
+                Long nftBuyChainTimestamp = nft044RespDto.getData().getChainTimestamp();
+                Integer nftBuyStatus = nft044RespDto.getData().getTaskStatus();
+                //更新订单缓存数据状态
+                if(StringUtil.isNotNull(nftBuyChainTimestamp)&&nftBuyChainTimestamp!=0){
+                    //设置时间
+                    String nftBuyChainTimestampStr = DateUtil.format(new Date(nftBuyChainTimestamp*1000),DateUtil.Formatter.yyyyMMddHHmmss);
+                    nftOrderBo.setNftBuyChainTimestamp(nftBuyChainTimestampStr);
+                }
+                if(StringUtil.isNotNull(nftBuyStatus)){
+                    //转换任务状态
+                    String nftBuyStatusStr = GalaxyEnumBiz.getTaskStatusEnum(nftOrderBo.getRouterType(),nftBuyStatus.toString()).getCode();
+
+                    nftOrderBo.setNftBuyStatus(nftBuyStatusStr);
+                }
+                nftOrderBo.setUpdatedAt(LocalDateTime.now());
+                //先更新nft购买数据
+                dataUtils.updateNftOrderBuyInfo(nftOrderBo.getRouterType(),nftOrderBo.getNftOrderPayId(),nftOrderBo);
+            }
+            resultQueryRespDto.setTaskStatus(Integer.parseInt(nftOrderBo.getNftBuyStatus()));
+            resultQueryRespDto.setChainTimestamp(nftOrderBo.getNftBuyChainTimestamp());
             return ResponseDto.success(resultQueryRespDto);
         }else{
             return ResponseDto.failure(GalaxyErrorEnum.NFT_PUBLISH_AND_BUY_QUERY_FAIL.getCode(), GalaxyErrorEnum.NFT_PUBLISH_AND_BUY_QUERY_FAIL.getMessage());
@@ -174,10 +212,6 @@ public class ZxinTradeBiz {
             nftPublishResultQueryReqDto.setNftOrderPayId(reqDto.getNftOrderPayId());
             nftPublishResultQueryReqDto.setRouterType(reqDto.getRouterType());
             ResponseDto<GalaxyNftPublishResultQueryRespDto> publishResultQueryRespDto = zxinPublishBiz.nftPublishResultQuery(nftPublishResultQueryReqDto);
-            if(publishResultQueryRespDto.isSuccess()){
-                GalaxyNftPublishResultQueryRespDto nftPublishResultQueryRespDtoTemp = publishResultQueryRespDto.getData();
-                BeanUtil.copy(nftPublishResultQueryRespDtoTemp,nftOrderBo);
-            }
         }else if(StringUtil.isNotEmpty(nftOrderBo.getNftBuyStatus())
                 && (GalaxyEnum.TaskStatusEnum.INIT.getCode().equalsIgnoreCase(nftOrderBo.getNftBuyStatus())
                 ||GalaxyEnum.TaskStatusEnum.PROCESSING.getCode().equalsIgnoreCase(nftOrderBo.getNftBuyStatus()))){
@@ -190,10 +224,6 @@ public class ZxinTradeBiz {
             nftBuyResultQueryReqDto.setNftOrderPayId(reqDto.getNftOrderPayId());
             nftBuyResultQueryReqDto.setRouterType(reqDto.getRouterType());
             ResponseDto<GalaxyNftBuyResultQueryRespDto> buyResultQueryRespDto= this.nftBuyResultQuery(nftBuyResultQueryReqDto);
-            if(buyResultQueryRespDto.isSuccess()){
-                GalaxyNftBuyResultQueryRespDto nftBuyResultQueryRespDtoTemp = buyResultQueryRespDto.getData();
-                BeanUtil.copy(nftBuyResultQueryRespDtoTemp,nftOrderBo);
-            }
         }
 
         //判断是否需要二次购买

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/galaxy/router/zxin/service/GalaxyRouterStrategyZxlTradeImpl.java

@@ -38,11 +38,13 @@ public class GalaxyRouterStrategyZxlTradeImpl implements IGalaxyRouterStrategyTr
         return zxinTradeBiz.nftPublishAndBuy(reqDto);
     }
 
+    @Deprecated
     @Override
     public ResponseDto<GalaxyNftBuyResultQueryRespDto> nftBuyResultQuery(GalaxyNftBuyResultQueryReqDto reqDto) {
         return zxinTradeBiz.nftBuyResultQuery(reqDto);
     }
 
+    @Deprecated
     @Override
     public ResponseDto<GalaxyNftBuyPayResultQueryRespDto> nftBuyPayResultQuery(GalaxyNftBuyPayResultQueryReqDto reqDto) {
         return zxinTradeBiz.nftBuyPayResultQuery(reqDto);
@@ -53,11 +55,13 @@ public class GalaxyRouterStrategyZxlTradeImpl implements IGalaxyRouterStrategyTr
         return zxinTradeBiz.nftPublishAndBuyResultQuery(reqDto);
     }
 
+    @Deprecated
     @Override
     public ResponseDto<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyRouterBatchQueryReqDto reqDto) {
         return zxinTradeBiz.nftPublishAndBuyResultBatchQuery(reqDto);
     }
 
+    @Deprecated
     @Override
     public ResponseDto<GalaxyNftBuyRespDto> nftBuy(GalaxyNftBuyReqDto reqDto) {
         return zxinTradeBiz.nftBuy(reqDto);

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/galaxy/service/impl/GalaxyTradeServiceImpl.java

@@ -25,7 +25,8 @@ public class GalaxyTradeServiceImpl implements IGalaxyTradeService {
 
     @Override
     public ResponseDto<GalaxyNftBuyRespDto> nftBuy(GalaxyNftBuyReqDto reqDto) {
-        return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftBuy(reqDto);
+//        return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftBuy(reqDto);
+        return null;
     }
 
     @Override
@@ -35,12 +36,14 @@ public class GalaxyTradeServiceImpl implements IGalaxyTradeService {
 
     @Override
     public ResponseDto<GalaxyNftBuyResultQueryRespDto> nftBuyResultQuery(GalaxyNftBuyResultQueryReqDto reqDto) {
-        return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftBuyResultQuery(reqDto);
+//        return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftBuyResultQuery(reqDto);
+        return null;
     }
 
     @Override
     public ResponseDto<GalaxyNftBuyPayResultQueryRespDto> nftBuyPayResultQuery(GalaxyNftBuyPayResultQueryReqDto reqDto) {
-        return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftBuyPayResultQuery(reqDto);
+//        return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftBuyPayResultQuery(reqDto);
+        return null;
     }
 
     @Override
@@ -50,6 +53,7 @@ public class GalaxyTradeServiceImpl implements IGalaxyTradeService {
 
     @Override
     public ResponseDto<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyRouterBatchQueryReqDto reqDto) {
-        return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftPublishAndBuyResultBatchQuery(reqDto);
+//        return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftPublishAndBuyResultBatchQuery(reqDto);
+        return null;
     }
 }