nft修改购买逻辑

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-common/src/main/java/com/liquidnet/service/galaxy/utils/AbstractDataUtils.java

@@ -16,7 +16,6 @@ import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.data.mongodb.core.query.Update;
 
-import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Date;
@@ -494,7 +493,7 @@ public abstract class AbstractDataUtils {
 
         Query query = Query.query(Criteria.where("skuId").is(skuId));
         Update update = Update.fromDocument(Document.parse(JsonUtils.toJson(seriesNftInfoBo)));
-        String nowTimeStr = DateUtil.Formatter.yyyyMMddHHmmss.format(LocalDate.now());
+        String nowTimeStr = DateUtil.Formatter.yyyyMMddHHmmss.format(LocalDateTime.now());
         update.set("nftCrtCount",seriesNftInfoBo.getNftCrtCount()+1);
         update.set("updatedAt",nowTimeStr);
         UpdateResult result = this.getMongoTemplate().updateFirst(query,update, GalaxySeriesNftInfoBo.class,GalaxySeriesNftInfoBo.class.getSimpleName());

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

@@ -226,21 +226,21 @@ public class ZxinTradeBiz {
             nftId = nftIdBegin;
             log.info("发行NFT后返回给前端nftID:{}", nftIdBegin);
             log.info("总共执行了{}次查询 总耗时:{} MS", count, (System.currentTimeMillis() - timeStart));
-        }
 
-        //更新订单缓存数据状态
-        nftOrderBo.setNftId(nftId);
-        nftOrderBo.setNftPublishTaskId(publishTaskId);
-        //设置时间
-        String nftPublishChainTimestampStr = DateUtil.format(new Date(nftPublishChainTimestamp*1000),DateUtil.Formatter.yyyyMMddHHmmss);
-        //转换任务状态
-        String nftPublishStatusStr = GalaxyEnumBiz.getTaskStatusEnum(reqDto.getRouterType(),nftPublishStatus.toString()).getCode();
-        nftOrderBo.setNftPublishChainTimestamp(nftPublishChainTimestampStr);
-        nftOrderBo.setNftPublishStatus(nftPublishStatusStr);
-        nftOrderBo.setNftPublishTradeHash(nftPublishTradeHash);
-        nftOrderBo.setUpdatedAt(LocalDateTime.now());
-        //先更新nft发行数据
-        dataUtils.updateNftOrderPublishInfo(reqDto.getRouterType(),reqDto.getNftOrderPayId(),nftOrderBo);
+            //更新订单缓存数据状态
+            nftOrderBo.setNftId(nftId);
+            nftOrderBo.setNftPublishTaskId(publishTaskId);
+            //设置时间
+            String nftPublishChainTimestampStr = DateUtil.format(new Date(nftPublishChainTimestamp*1000),DateUtil.Formatter.yyyyMMddHHmmss);
+            //转换任务状态
+            String nftPublishStatusStr = GalaxyEnumBiz.getTaskStatusEnum(reqDto.getRouterType(),nftPublishStatus.toString()).getCode();
+            nftOrderBo.setNftPublishChainTimestamp(nftPublishChainTimestampStr);
+            nftOrderBo.setNftPublishStatus(nftPublishStatusStr);
+            nftOrderBo.setNftPublishTradeHash(nftPublishTradeHash);
+            nftOrderBo.setUpdatedAt(LocalDateTime.now());
+            //先更新nft发行数据
+            dataUtils.updateNftOrderPublishInfo(reqDto.getRouterType(),reqDto.getNftOrderPayId(),nftOrderBo);
+        }
 
         if(StringUtil.isNotEmpty(nftId)){
             //执行购买逻辑
@@ -248,9 +248,8 @@ public class ZxinTradeBiz {
             GalaxyNftBuyRespDto nftBuyRespDto = this.nftBuyBusinessSync(reqDto.getRouterType(),nftId,userInfoBo,seriesNftInfoBo,nftOrderBo);
             BeanUtil.copy(nftBuyRespDto,nftPublishAndBuyRespDto);
             return ResponseDto.success(nftPublishAndBuyRespDto);
-        }else{
-            return ResponseDto.failure(GalaxyErrorEnum.PUBLISH_FAIL.getCode(), GalaxyErrorEnum.PUBLISH_FAIL.getMessage());
         }
+        return ResponseDto.failure(GalaxyErrorEnum.PUBLISH_FAIL.getCode(), GalaxyErrorEnum.PUBLISH_FAIL.getMessage());
     }
 
     public ResponseDto<GalaxyNftBuyResultQueryRespDto> nftBuyResultQuery(GalaxyNftBuyResultQueryReqDto reqDto) {