记得上下班打卡 | git大法好,push需谨慎

Commit 8a6e806d authored by anjiabin's avatar anjiabin

nft修改购买异常逻辑

parent 4bff4260
...@@ -45,6 +45,13 @@ public class GalaxyNftPublishAndBuyReqDto extends GalaxyBaseReqDto implements Se ...@@ -45,6 +45,13 @@ public class GalaxyNftPublishAndBuyReqDto extends GalaxyBaseReqDto implements Se
@Size(min = 2, max = 30, message = "nft订单支付id限制2-30位且不能包含特殊字符") @Size(min = 2, max = 30, message = "nft订单支付id限制2-30位且不能包含特殊字符")
private String nftOrderPayId; private String nftOrderPayId;
/**
* buyTimestamp
*/
@ApiModelProperty(position = 3, required = true, value = "购买时间戳(格式为:2022-04-07 12:12:12)")
@NotBlank(message = "购买时间戳")
private String buyTimestamp;
@Override @Override
public String toString(){ public String toString(){
return JsonUtils.toJson(this); return JsonUtils.toJson(this);
......
...@@ -21,10 +21,6 @@ import java.util.List; ...@@ -21,10 +21,6 @@ import java.util.List;
@ApiModel(value = "GalaxyNftPublishAndBuyRouterBatchQueryRespDto", description = "NFT发行结果查询") @ApiModel(value = "GalaxyNftPublishAndBuyRouterBatchQueryRespDto", description = "NFT发行结果查询")
@Data @Data
public class GalaxyNftPublishAndBuyRouterBatchQueryRespDto implements Serializable,Cloneable { public class GalaxyNftPublishAndBuyRouterBatchQueryRespDto implements Serializable,Cloneable {
@ApiModelProperty(position = 1, required = true, value = "用户ID[30]")
private String userId;
/** /**
* 路由类型(至信链zxinchain、以太坊eth) * 路由类型(至信链zxinchain、以太坊eth)
*/ */
......
...@@ -213,7 +213,6 @@ public class ZxinTradeBiz { ...@@ -213,7 +213,6 @@ public class ZxinTradeBiz {
} }
} }
GalaxyNftPublishAndBuyRouterBatchQueryRespDto routerBatchQueryRespDto = GalaxyNftPublishAndBuyRouterBatchQueryRespDto.getNew(); GalaxyNftPublishAndBuyRouterBatchQueryRespDto routerBatchQueryRespDto = GalaxyNftPublishAndBuyRouterBatchQueryRespDto.getNew();
routerBatchQueryRespDto.setUserId(reqDto.getUserId());
routerBatchQueryRespDto.setRouterType(reqDto.getRouterType()); routerBatchQueryRespDto.setRouterType(reqDto.getRouterType());
routerBatchQueryRespDto.setBuyInfoList(buyInfoList); routerBatchQueryRespDto.setBuyInfoList(buyInfoList);
return ResponseDto.success(routerBatchQueryRespDto); return ResponseDto.success(routerBatchQueryRespDto);
......
package com.liquidnet.service.galaxy.router.zxin.service; package com.liquidnet.service.galaxy.router.zxin.service;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.base.ResponseDto; import com.liquidnet.service.base.ResponseDto;
import com.liquidnet.service.base.constant.MQConst;
import com.liquidnet.service.galaxy.constant.GalaxyEnum; import com.liquidnet.service.galaxy.constant.GalaxyEnum;
import com.liquidnet.service.galaxy.dto.param.*; import com.liquidnet.service.galaxy.dto.param.*;
import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategyTrade; import com.liquidnet.service.galaxy.router.strategy.IGalaxyRouterStrategyTrade;
...@@ -35,7 +33,7 @@ public class GalaxyRouterStrategyZxlTradeImpl implements IGalaxyRouterStrategyTr ...@@ -35,7 +33,7 @@ public class GalaxyRouterStrategyZxlTradeImpl implements IGalaxyRouterStrategyTr
@Override @Override
public ResponseDto<GalaxyNftPublishAndBuyRespDto> nftPublishAndBuy(GalaxyNftPublishAndBuyReqDto reqDto) { public ResponseDto<GalaxyNftPublishAndBuyRespDto> nftPublishAndBuy(GalaxyNftPublishAndBuyReqDto reqDto) {
//测试发送队列 //测试发送队列
queueUtil.sendMsgByRedis(MQConst.GalaxyQueue.JSON_NFT_PUBLISH_AND_BUY.getKey(), JsonUtils.toJson(reqDto)); // queueUtil.sendMsgByRedis(MQConst.GalaxyQueue.JSON_NFT_PUBLISH_AND_BUY.getKey(), JsonUtils.toJson(reqDto));
// return ResponseDto.success(); // return ResponseDto.success();
return zxinTradeBiz.nftPublishAndBuy(reqDto); return zxinTradeBiz.nftPublishAndBuy(reqDto);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment