nft修改购买逻辑

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyNftPublishAndBuyResultBatchQueryReqDto.java

@@ -22,7 +22,7 @@ import java.util.List;
  */
 @ApiModel(value = "GalaxyNftPublishResultQueryReqDto", description = "NFT发行结果查询")
 @Data
-public class GalaxyNftPublishAndBuyResultBatchQueryReqDto extends GalaxyBaseReqDto  implements Serializable,Cloneable {
+public class GalaxyNftPublishAndBuyResultBatchQueryReqDto implements Serializable,Cloneable {
     @ApiModelProperty(position = 1, required = true, value = "用户ID[30]")
     @NotBlank(message = "用户ID不能为空！")
     @Size(min = 1, max = 30, message = "用户ID限制2-30位且不能包含特殊字符")
@@ -33,7 +33,8 @@ public class GalaxyNftPublishAndBuyResultBatchQueryReqDto extends GalaxyBaseReqD
      */
     @ApiModelProperty(position = 1, required = true, value = "nft订单支付idList不能为空")
     @NotNull(message = "nft订单支付idList不能为空")
-    private List<String> orderInfoList;
+    private List<RouterOrderInfo> routerOrderInfoList;
+
 
     @Override
     public String toString(){
@@ -49,8 +50,21 @@ public class GalaxyNftPublishAndBuyResultBatchQueryReqDto extends GalaxyBaseReqD
             return new GalaxyNftPublishAndBuyResultBatchQueryReqDto();
         }
     }
-    public static class OrderInfo{
+    @Data
+    public static class RouterOrderInfo{
+        @ApiModelProperty(position = 1, required = true, value = "用户ID[30]")
+        @NotBlank(message = "用户ID不能为空！")
+        @Size(min = 1, max = 30, message = "用户ID限制2-30位且不能包含特殊字符")
+        private String userId;
+        /**
+         * 路由类型(至信链zxinchain、以太坊eth)
+         */
+        @ApiModelProperty(position = 1, required = true, value = "路由类型(至信链zxinchain、以太坊eth)")
+        @NotBlank(message = "路由类型不能为空！")
+        private String routerType;
+
         @ApiModelProperty(position = 1, required = true, value = "nft订单支付id")
-        private String nftOrderPayId;
+        private List<String> nftOrderPayIdList;
+
     }
 }

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyNftPublishAndBuyResultBatchQueryRespDto.java

@@ -25,7 +25,7 @@ public class GalaxyNftPublishAndBuyResultBatchQueryRespDto implements Serializab
     private String userId;
 
     @ApiModelProperty(position = 1, required = true, value = "用户购买信息List")
-    private List<BuyInfo> buyInfoList;
+    private List<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> routerBuyInfoList;
 
 
     @Override
@@ -42,31 +42,4 @@ public class GalaxyNftPublishAndBuyResultBatchQueryRespDto implements Serializab
             return new GalaxyNftPublishAndBuyResultBatchQueryRespDto();
         }
     }
-
-    @Data
-    public static class BuyInfo{
-        @ApiModelProperty(position = 2, required = true, value = "nft订单唯一id")
-        private String nftOrderPayId;
-
-        @ApiModelProperty(position = 2, required = true, value = "nftId")
-        private String nftId;
-
-        @ApiModelProperty(position = 3, required = true, value = "nft发行时间")
-        private String nftPublishChainTimestamp;
-
-        @ApiModelProperty(position = 4, required = true, value = "nft发行状态")
-        private String nftPublishStatus;
-
-        @ApiModelProperty(position = 5, required = true, value = "nft发行交易hash")
-        private String nftPublishTxHash;
-
-        @ApiModelProperty(position = 6, required = true, value = "nft购买时间")
-        private String nftBuyChainTimestamp;
-
-        @ApiModelProperty(position = 7, required = true, value = "nft购买状态")
-        private String nftBuyStatus;
-
-        @ApiModelProperty(position = 8, required = true, value = "nft购买交易hash")
-        private String nftBuyTxHash;
-    }
 }

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyNftPublishAndBuyRouterBatchQueryReqDto.java

+package com.liquidnet.service.galaxy.dto.param;
+
+import com.liquidnet.commons.lang.util.JsonUtils;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.Size;
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: NFT购买(涉及NFT发行、NFT购买)
+ * @class: GalaxyNftPublishAndBuyReqDto
+ * @Package com.liquidnet.service.galaxy.dto.param
+ * @Copyright: LightNet @ Copyright (c) 2022
+ * @date 2022/3/17 13:51
+ */
+@ApiModel(value = "GalaxyNftPublishAndBuyReqDto", description = "NFT发行购买")
+@Data
+public class GalaxyNftPublishAndBuyRouterBatchQueryReqDto extends GalaxyBaseReqDto implements Serializable,Cloneable {
+    @ApiModelProperty(position = 1, required = true, value = "用户ID[30]")
+    @NotBlank(message = "用户ID不能为空！")
+    @Size(min = 1, max = 30, message = "用户ID限制2-30位且不能包含特殊字符")
+    private String userId;
+
+    @ApiModelProperty(position = 1, required = true, value = "nft订单支付id")
+    private List<String> nftOrderPayIdList;
+
+
+    @Override
+    public String toString(){
+        return JsonUtils.toJson(this);
+    }
+
+    private static final GalaxyNftPublishAndBuyRouterBatchQueryReqDto obj = new GalaxyNftPublishAndBuyRouterBatchQueryReqDto();
+
+    public static GalaxyNftPublishAndBuyRouterBatchQueryReqDto getNew() {
+        try {
+            return (GalaxyNftPublishAndBuyRouterBatchQueryReqDto) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new GalaxyNftPublishAndBuyRouterBatchQueryReqDto();
+        }
+    }
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/dto/param/GalaxyNftPublishAndBuyRouterBatchQueryRespDto.java

+package com.liquidnet.service.galaxy.dto.param;
+
+import com.liquidnet.commons.lang.util.JsonUtils;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: 发行+购买结果查询
+ * @class: GalaxyNftPublishResultQueryRespDto
+ * @Package com.liquidnet.service.galaxy.dto.param
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/3/28 11:22
+ */
+@ApiModel(value = "GalaxyNftPublishResultQueryRespDto", description = "NFT发行结果查询")
+@Data
+public class GalaxyNftPublishAndBuyRouterBatchQueryRespDto implements Serializable,Cloneable {
+
+    @ApiModelProperty(position = 1, required = true, value = "用户ID[30]")
+    private String userId;
+    
+    /**
+     * 路由类型(至信链zxinchain、以太坊eth)
+     */
+    @ApiModelProperty(position = 1, required = true, value = "路由类型(至信链zxinchain、以太坊eth)")
+    @NotBlank(message = "路由类型不能为空！")
+    private String routerType;
+
+    @ApiModelProperty(position = 1, required = true, value = "用户购买信息List")
+    private List<GalaxyNftPublishAndBuyResultQueryRespDto> buyInfoList;
+
+    @Override
+    public String toString() {
+        return JsonUtils.toJson(this);
+    }
+
+    private static final GalaxyNftPublishAndBuyRouterBatchQueryRespDto obj = new GalaxyNftPublishAndBuyRouterBatchQueryRespDto();
+
+    public static GalaxyNftPublishAndBuyRouterBatchQueryRespDto getNew() {
+        try {
+            return (GalaxyNftPublishAndBuyRouterBatchQueryRespDto) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new GalaxyNftPublishAndBuyRouterBatchQueryRespDto();
+        }
+    }
+}

liquidnet-bus-api/liquidnet-service-galaxy-api/src/main/java/com/liquidnet/service/galaxy/service/IGalaxyTradeService.java

@@ -24,5 +24,5 @@ public interface IGalaxyTradeService {
 
     ResponseDto<GalaxyNftPublishAndBuyResultQueryRespDto> nftPublishAndBuyResultQuery(GalaxyNftPublishAndBuyResultQueryReqDto reqDto);
 
-    ResponseDto<GalaxyNftPublishAndBuyResultBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyResultBatchQueryReqDto reqDto);
+    ResponseDto<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyRouterBatchQueryReqDto reqDto);
 }

liquidnet-bus-config/liquidnet-config/application-dev.yml

@@ -78,12 +78,6 @@ liquidnet:
       host: 39.107.71.112
       port: 6379
       password: 3Xa%8p
-    galaxy:
-      dbs: 0,16
-      database: 15
-      host: 39.107.71.112
-      port: 6379
-      password: 3Xa%8p
 #    goblin:
 #      dbs: 0,256
 #      database: 255

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-galaxy-dev.yml

-liquidnet:
-  system:
-    updating:
-      switch: false
-  info:
-    port: 9992
-    context:
-#    context: /service-consumer
-    name: liquidnet-service-consumer-galaxy
-  logfile:
-    path: /data/logs
-    name: service-consumer-galaxy
-    config: classpath:logback-spring.xml
-    level: debug
-  mysql:
-    database-name: dev_ln_scene
-  mongodb:
-    sslEnabled: false
-    database: dev_ln_scene
-
-#以下为spring各环境个性配置
\ No newline at end of file

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-galaxy-test.yml

-liquidnet:
-  system:
-    updating:
-      switch: false
-  info:
-    port: 9998
-    context:
-#    context: /service-consumer
-    name: liquidnet-service-consumer-galaxy
-  logfile:
-    path: /data/logs
-    name: service-consumer-galaxy
-    config: classpath:logback-spring.xml
-    level: info
-  mysql:
-    database-name: test_ln_scene
-  mongodb:
-    sslEnabled: false
-    database: test_ln_scene
-
-#以下为spring各环境个性配置

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-galaxy.yml

-server:
-  port: ${liquidnet.info.port}
-  tomcat:
-    uri-encoding: UTF-8
-  servlet:
-    context-path: ${liquidnet.info.context}
-# -----------------------------------------------------------
-knife4j:
-  production: ${liquidnet.knife4j.disable}
-  basic:
-    enable: true
-    username: ${liquidnet.security.username}
-    password: ${liquidnet.security.password}
-# -----------------------------------------------------------
-logging:
-#  config: ${liquidnet.logfile.config}
-  file:
-    name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}.log
-    max-size: 200MB
-  pattern:
-    file: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{36}:%line] - %msg%n'
-    console: '%d{yyyy-MM-dd HH:mm:ss.SSS} [ %-5level] %thread [%logger{36}:%line] - %msg%n'
-    rolling-file-name: ${liquidnet.logfile.path}/${liquidnet.logfile.name}-%d{yyyy-MM-dd}.%i.log
-  level:
-    root: error
-    #以下是为指定包设置日志级别
-    com.liquidnet: ${liquidnet.logfile.level}
-# -----------------------------------------------------------
-eureka:
-#  client:
-#    register-with-eureka: true
-#    fetch-registry: true
-#    serviceUrl:
-#      defaultZone: http://${liquidnet.security.username}:${liquidnet.security.password}@${liquidnet.eureka.host}/eureka-server/eureka
-  instance:
-    hostname: ${spring.cloud.client.ip-address}
-    lease-expiration-duration-in-seconds: 15 #服务过期时间配置,超过这个时间没有接收到心跳EurekaServer就会将这个实例剔除
-    lease-renewal-interval-in-seconds: 5 #服务刷新时间配置，每隔这个时间会主动心跳一次
-    prefer-ip-address: true
-    instance-id: ${spring.application.name}:${spring.cloud.client.ip-address}:${spring.application.instance_id:${server.port}}
-# -----------------------------------------------------------
-#actuator/info
-info:
-  app:
-    name: ${liquidnet.info.name}
-  company:
-    name: zhengzai.tv
-  build:
-    groupId: '@project.groupId@'
-    artifactId: '@project.artifactId@'
-    version: '@project.version@'
-# -----------------------------------------------------------
-spring:
-  application:
-    name: ${liquidnet.info.name}
-  profiles:
-    include: common-service #这里加载management相关公共配置
-  redis:
-    database: ${liquidnet.redis.galaxy.database}
-    port: ${liquidnet.redis.galaxy.port}
-    host: ${liquidnet.redis.galaxy.host}
-    password: ${liquidnet.redis.galaxy.password}
-    lettuce:
-      pool:
-        max-active: 8
-        max-wait: -1
-        max-idle: 8
-        min-idle: 0
-  datasource:
-    name: ${liquidnet.mysql.database-name}
-    url: jdbc:mysql://${liquidnet.mysql.urlHostAndPort}/${liquidnet.mysql.database-name}?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&useSSL=false
-    username: ${liquidnet.mysql.username}
-    password: ${liquidnet.mysql.password}
-#    type: org.apache.tomcat.jdbc.pool.DataSource
-    driver-class-name: com.mysql.cj.jdbc.Driver
-    hikari:
-      maximum-pool-size: 45
-      minimum-idle: 8
-      connection-test-query: SELECT 1
-  data:
-    mongodb:
-      uri: mongodb://${liquidnet.mongodb.user}:${liquidnet.mongodb.pwd}@${liquidnet.mongodb.host}/?authSource=admin&maxPoolSize=200&waitQueueMultiple=100
-      sslEnabled: ${liquidnet.mongodb.sslEnabled}
-      database: ${liquidnet.mongodb.database}
-# -----------------------------------------------------------
-
-# -----------------------------------------------------------

liquidnet-bus-config/liquidnet-config/liquidnet-service-galaxy.yml

@@ -70,11 +70,11 @@ spring:
   profiles:
     include: common-service #这里加载management相关公共配置
   redis:
-    database: ${liquidnet.redis.galaxy.database}
-    dbs: ${liquidnet.redis.galaxy.dbs}
-    port: ${liquidnet.redis.galaxy.port}
-    host: ${liquidnet.redis.galaxy.host}
-    password: ${liquidnet.redis.galaxy.password}
+    database: ${liquidnet.redis.kylin.database}
+    dbs: ${liquidnet.redis.kylin.dbs}
+    port: ${liquidnet.redis.kylin.port}
+    host: ${liquidnet.redis.kylin.host}
+    password: ${liquidnet.redis.kylin.password}
     lettuce:
       pool:
         max-active: 8

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/controller/GalaxyTradeController.java

@@ -16,6 +16,8 @@ import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
 import javax.validation.Valid;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -72,7 +74,24 @@ public class GalaxyTradeController {
     @ApiOperation(value = "NFT发行购买结果批量查询")
     @PostMapping(value = {"nftPublishAndBuyResultBatchQuery"})
     public ResponseDto<GalaxyNftPublishAndBuyResultBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(@Valid @RequestBody GalaxyNftPublishAndBuyResultBatchQueryReqDto reqDto){
-        return galaxyTradeService.nftPublishAndBuyResultBatchQuery(reqDto);
+        //定义返回结果
+        List<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> routerBuyInfoList = new ArrayList<>();
+        List<GalaxyNftPublishAndBuyResultBatchQueryReqDto.RouterOrderInfo> routerOrderInfoList = reqDto.getRouterOrderInfoList();
+        routerOrderInfoList.forEach(routerOrderInfo -> {
+            GalaxyNftPublishAndBuyRouterBatchQueryReqDto batchQueryReqDto =  GalaxyNftPublishAndBuyRouterBatchQueryReqDto.getNew();
+            batchQueryReqDto.setUserId(routerOrderInfo.getUserId());
+            batchQueryReqDto.setRouterType(routerOrderInfo.getRouterType());
+            batchQueryReqDto.setNftOrderPayIdList(routerOrderInfo.getNftOrderPayIdList());
+            ResponseDto<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> responseDtoTemp = galaxyTradeService.nftPublishAndBuyResultBatchQuery(batchQueryReqDto);
+            if(responseDtoTemp.isSuccess()){
+                GalaxyNftPublishAndBuyRouterBatchQueryRespDto routerBatchQueryRespDto = GalaxyNftPublishAndBuyRouterBatchQueryRespDto.getNew();
+                routerBuyInfoList.add(routerBatchQueryRespDto);
+            }
+        });
+        GalaxyNftPublishAndBuyResultBatchQueryRespDto respDto = GalaxyNftPublishAndBuyResultBatchQueryRespDto.getNew();
+        respDto.setUserId(reqDto.getUserId());
+        respDto.setRouterBuyInfoList(routerBuyInfoList);
+        return ResponseDto.success(respDto);
     }
 
 //    @ControllerLog(description = "NFT购买支付结果查询")

liquidnet-bus-service/liquidnet-service-galaxy/liquidnet-service-galaxy-impl/src/main/java/com/liquidnet/service/galaxy/router/eth/service/GalaxyRouterStrategyEthTradeImpl.java

@@ -48,7 +48,7 @@ public class GalaxyRouterStrategyEthTradeImpl implements IGalaxyRouterStrategyTr
     }
 
     @Override
-    public ResponseDto<GalaxyNftPublishAndBuyResultBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyResultBatchQueryReqDto reqDto) {
+    public ResponseDto<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyRouterBatchQueryReqDto reqDto) {
         return null;
     }
 }

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

@@ -351,23 +351,24 @@ public class ZxinTradeBiz {
      * @param reqDto
      * @return
      */
-    public ResponseDto<GalaxyNftPublishAndBuyResultBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyResultBatchQueryReqDto reqDto) {
-        List<GalaxyNftPublishAndBuyResultBatchQueryRespDto.BuyInfo> buyInfoList = new ArrayList<>();
-        List<String> nftOrderPayIdList = reqDto.getOrderInfoList();
+    public ResponseDto<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyRouterBatchQueryReqDto reqDto) {
+        List<String> nftOrderPayIdList = reqDto.getNftOrderPayIdList();
+        List<GalaxyNftPublishAndBuyResultQueryRespDto> buyInfoList = new ArrayList<>();
         nftOrderPayIdList.stream().forEach(nftOrderPayId -> {
             GalaxyNftPublishAndBuyResultQueryReqDto resultQueryReqDto = GalaxyNftPublishAndBuyResultQueryReqDto.getNew();
             resultQueryReqDto.setUserId(reqDto.getUserId());
             resultQueryReqDto.setNftOrderPayId(nftOrderPayId);
             resultQueryReqDto.setRouterType(reqDto.getRouterType());
             ResponseDto<GalaxyNftPublishAndBuyResultQueryRespDto> resultQueryRespDto = this.nftPublishAndBuyResultQuery(resultQueryReqDto);
-            GalaxyNftPublishAndBuyResultBatchQueryRespDto.BuyInfo buyInfo = new GalaxyNftPublishAndBuyResultBatchQueryRespDto.BuyInfo();
-            BeanUtil.copy(resultQueryRespDto,buyInfo);
-            buyInfoList.add(buyInfo);
+            if(resultQueryRespDto.isSuccess()){
+                buyInfoList.add(resultQueryRespDto.getData());
+            }
         });
-        GalaxyNftPublishAndBuyResultBatchQueryRespDto resultBatchQueryRespDto = GalaxyNftPublishAndBuyResultBatchQueryRespDto.getNew();
-        resultBatchQueryRespDto.setUserId(reqDto.getUserId());
-        resultBatchQueryRespDto.setBuyInfoList(buyInfoList);
-        return ResponseDto.success(resultBatchQueryRespDto);
+        GalaxyNftPublishAndBuyRouterBatchQueryRespDto routerBatchQueryRespDto = GalaxyNftPublishAndBuyRouterBatchQueryRespDto.getNew();
+        routerBatchQueryRespDto.setUserId(reqDto.getUserId());
+        routerBatchQueryRespDto.setRouterType(reqDto.getRouterType());
+        routerBatchQueryRespDto.setBuyInfoList(buyInfoList);
+        return ResponseDto.success(routerBatchQueryRespDto);
     }
 
     private GalaxyNftBuyRespDto nftBuyBusiness(String routerType,String nftId,GalaxyUserInfoBo userInfoBo, GalaxySeriesNftInfoBo seriesNftInfoBo,GalaxyNftOrderBo nftOrderBo){

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

@@ -6,7 +6,6 @@ import com.liquidnet.service.galaxy.dto.param.*;
 import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategyTrade;
 import com.liquidnet.service.galaxy.router.strategy.annotation.StrategyGalaxyRouterTradeHandler;
 import com.liquidnet.service.galaxy.router.zxin.biz.ZxinTradeBiz;
-import com.liquidnet.service.galaxy.utils.QueueUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -27,9 +26,6 @@ public class GalaxyRouterStrategyZxlTradeImpl implements IGalaxyRouterStrategyTr
     @Autowired
     private ZxinTradeBiz zxinTradeBiz;
 
-    @Autowired
-    private QueueUtil queueUtil;
-
     @Override
     public ResponseDto<GalaxyNftPublishAndBuyRespDto> nftPublishAndBuy(GalaxyNftPublishAndBuyReqDto reqDto) {
 //        queueUtil.sendMsgByRedis(MQConst.GalaxyQueue.JSON_NFT_PUBLISH_AND_BUY.getKey(), JsonUtils.toJson(reqDto));
@@ -53,7 +49,7 @@ public class GalaxyRouterStrategyZxlTradeImpl implements IGalaxyRouterStrategyTr
     }
 
     @Override
-    public ResponseDto<GalaxyNftPublishAndBuyResultBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyResultBatchQueryReqDto reqDto) {
+    public ResponseDto<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyRouterBatchQueryReqDto reqDto) {
         return zxinTradeBiz.nftPublishAndBuyResultBatchQuery(reqDto);
     }
 

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

@@ -49,7 +49,7 @@ public class GalaxyTradeServiceImpl implements IGalaxyTradeService {
     }
 
     @Override
-    public ResponseDto<GalaxyNftPublishAndBuyResultBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyResultBatchQueryReqDto reqDto) {
+    public ResponseDto<GalaxyNftPublishAndBuyRouterBatchQueryRespDto> nftPublishAndBuyResultBatchQuery(GalaxyNftPublishAndBuyRouterBatchQueryReqDto reqDto) {
         return galaxyRouterStrategyContext.getTradeStrategy(reqDto.getRouterType()).nftPublishAndBuyResultBatchQuery(reqDto);
     }
 }