实现xuper相关艺术品上传

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

@@ -22,12 +22,20 @@ import java.io.Serializable;
 @Data
 public class GalaxyUserBindStatusQueryReqDto extends GalaxyBaseReqDto implements Serializable,Cloneable {
     /**
-     * nftOrderPayId
+     * 用户id
      */
-    @ApiModelProperty(position = 1, required = true, value = "用户区块链地址")
-    @NotBlank(message = "用户区块链地址不能为空！")
-    @Size(min = 2, max = 100, message = "用户区块链地址不能超过100个字符")
-    private String blockChainAddress;
+    @ApiModelProperty(position = 1, required = true, value = "用户ID[30]")
+    @NotBlank(message = "用户ID不能为空！")
+    @Size(min = 1, max = 30, message = "用户ID限制2-30位且不能包含特殊字符")
+    private String userId;
+
+//    /**
+//     * nftOrderPayId
+//     */
+//    @ApiModelProperty(position = 1, required = true, value = "用户区块链地址")
+//    @NotBlank(message = "用户区块链地址不能为空！")
+//    @Size(min = 2, max = 100, message = "用户区块链地址不能超过100个字符")
+//    private String blockChainAddress;
 
     @Override
     public String toString(){

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

@@ -19,6 +19,9 @@ import java.io.Serializable;
 @ApiModel(value = "GalaxyUserBindStatusQueryRespDto", description = "用户绑定状态查询")
 @Data
 public class GalaxyUserBindStatusQueryRespDto  implements Serializable,Cloneable {
+    @ApiModelProperty(position = 1, required = true, value = "用户ID[30]")
+    private String userId;
+
     @ApiModelProperty(position = 3, required = true, value = "用户区块链地址")
     private String blockChainAddress;
 

liquidnet-bus-service/liquidnet-service-goblin/liquidnet-service-goblin-impl/src/main/java/com/liquidnet/service/galaxy/router/xuper/biz/XuperUserBiz.java

 package com.liquidnet.service.galaxy.router.xuper.biz;
 
 import com.liquidnet.common.third.xuper.util.XuperSdkUtil;
-import com.liquidnet.common.third.zxlnft.dto.Nft016IdentityBindQueryReqDto;
+import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.galaxy.constant.GalaxyEnum;
+import com.liquidnet.service.galaxy.constant.GalaxyErrorEnum;
+import com.liquidnet.service.galaxy.dto.bo.GalaxyUserInfoBo;
 import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryReqDto;
 import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryRespDto;
 import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterReqDto;
 import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterRespDto;
+import com.liquidnet.service.galaxy.utils.GalaxyDataUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -29,24 +33,25 @@ public class XuperUserBiz {
     @Autowired
     private XuperUserCommonBiz xuperUserCommonBiz;
 
+    @Autowired
+    private GalaxyDataUtils dataUtils;
+
     public ResponseDto<GalaxyUserRegisterRespDto> userRegister(GalaxyUserRegisterReqDto reqDto) {
         return xuperUserCommonBiz.userRegister(reqDto);
     }
 
     public ResponseDto<GalaxyUserBindStatusQueryRespDto> userBindStatusQuery(GalaxyUserBindStatusQueryReqDto reqDto){
-        Nft016IdentityBindQueryReqDto nft016ReqDto = Nft016IdentityBindQueryReqDto.getNew();
-        nft016ReqDto.setAddressList(reqDto.getBlockChainAddress());
-//        ZxlnftResponseDto<Nft016IdentityBindQueryRespDto> zxlnftResponseDto = zxlnftSdkUtil.nft016IdentityBindQuery(nft016ReqDto);
-//
+        //获取用户信息
+        GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(reqDto.getRouterType(),reqDto.getUserId());
+        if(StringUtil.isNull(userInfoBo)){
+            log.error("开始执行nftPublishAndBuy error msg:{}", GalaxyErrorEnum.NFT_BUY_FAIL_USER_NOT_EXIST.getMessage());
+            return ResponseDto.failure(GalaxyErrorEnum.NFT_BUY_FAIL_USER_NOT_EXIST.getCode(), GalaxyErrorEnum.NFT_BUY_FAIL_USER_NOT_EXIST.getMessage());
+        }
+
         GalaxyUserBindStatusQueryRespDto userBindStatusQueryRespDto = GalaxyUserBindStatusQueryRespDto.getNew();
-//        if(zxlnftResponseDto.isSuccess()){
-//            Nft016QueryRsData nft016QueryRsData = zxlnftResponseDto.getData().getList().get(0);
-//            userBindStatusQueryRespDto.setBlockChainAddress(nft016QueryRsData.getAddress());
-//            Integer userBindStatus = Integer.valueOf(GalaxyEnumBiz.getUserBindStatusEnum(reqDto.getRouterType(),nft016QueryRsData.getStatus()).getCode());
-//            userBindStatusQueryRespDto.setUserBindStatus(userBindStatus);
-//        }else{
-//            return ResponseDto.failure();
-//        }
+            userBindStatusQueryRespDto.setBlockChainAddress(userInfoBo.getBlockChainAddress());
+            Integer userBindStatus = Integer.valueOf(GalaxyEnum.UserBindStatusEnum.BIND_SUCCESS.getCode());
+            userBindStatusQueryRespDto.setUserBindStatus(userBindStatus);
         return ResponseDto.success(userBindStatusQueryRespDto);
     }
 }

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

@@ -7,8 +7,11 @@ import com.liquidnet.common.third.zxlnft.dto.ZxlnftResponseDto;
 import com.liquidnet.common.third.zxlnft.dto.nft.Nft016QueryRsData;
 import com.liquidnet.common.third.zxlnft.util.ZxlWalletSdkUtil;
 import com.liquidnet.common.third.zxlnft.util.ZxlnftSdkUtil;
+import com.liquidnet.commons.lang.util.StringUtil;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.galaxy.biz.GalaxyEnumBiz;
+import com.liquidnet.service.galaxy.constant.GalaxyErrorEnum;
+import com.liquidnet.service.galaxy.dto.bo.GalaxyUserInfoBo;
 import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryReqDto;
 import com.liquidnet.service.galaxy.dto.param.GalaxyUserBindStatusQueryRespDto;
 import com.liquidnet.service.galaxy.dto.param.GalaxyUserRegisterReqDto;
@@ -50,8 +53,15 @@ public class ZxinUserBiz {
     }
 
     public ResponseDto<GalaxyUserBindStatusQueryRespDto> userBindStatusQuery(GalaxyUserBindStatusQueryReqDto reqDto){
+        //获取用户信息
+        GalaxyUserInfoBo userInfoBo = dataUtils.getGalaxyUserInfo(reqDto.getRouterType(),reqDto.getUserId());
+        if(StringUtil.isNull(userInfoBo)){
+            log.error("开始执行nftPublishAndBuy error msg:{}", GalaxyErrorEnum.NFT_BUY_FAIL_USER_NOT_EXIST.getMessage());
+            return ResponseDto.failure(GalaxyErrorEnum.NFT_BUY_FAIL_USER_NOT_EXIST.getCode(), GalaxyErrorEnum.NFT_BUY_FAIL_USER_NOT_EXIST.getMessage());
+        }
+
         Nft016IdentityBindQueryReqDto nft016ReqDto = Nft016IdentityBindQueryReqDto.getNew();
-        nft016ReqDto.setAddressList(reqDto.getBlockChainAddress());
+        nft016ReqDto.setAddressList(userInfoBo.getBlockChainAddress());
         ZxlnftResponseDto<Nft016IdentityBindQueryRespDto> zxlnftResponseDto = zxlnftSdkUtil.nft016IdentityBindQuery(nft016ReqDto);
 
         GalaxyUserBindStatusQueryRespDto userBindStatusQueryRespDto = GalaxyUserBindStatusQueryRespDto.getNew();