调试绑定状态查询接口

liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-zxlnft/src/main/java/com/liquidnet/common/third/zxlnft/constant/ErrorEnum.java

+package com.liquidnet.common.third.zxlnft.constant;
+
+import java.util.Arrays;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: ErrorEnum
+ * @Package com.liquidnet.common.third.zxlnft.constant
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/2/21 14:00
+ */
+public enum ErrorEnum {
+    NO_INIT_ERROR("000", "没有初始化"),
+    APP_TYPE_ERROR("001", "应用类型错误"),
+    INVALID_PARAM_ERROR("002", "参数错误"),
+    GENERATE_KEYPAIR_ERROR("003", "生成公私钥错误"),
+    SIGN_ERROR("004", "签名错误"),
+    VERIFY_ERROR("005", "验签错误"),
+    ENCRYPT_ERROR("006", "加密数据错误"),
+    DECODE_ERROR("007", "解密数据错误"),
+    CALCULATE_FILE_HASH_ERROR("008", "计算文件hash错误"),
+    BIND_USER_CERT_ERROR("009", "绑定用户证书错误"),
+    UPDATE_USER_CERT_ERROR("010", "更新用户证书错误"),
+    APPLY_EVIDENCE_ERROR("011", "申请存证错误"),
+    SAVE_EVIDENCE_ERROR("012", "存证错误"),
+    QUERY_EVIDENCE_ERROR("013", "查询存证错误"),
+    AUTHOR_LIMIT_ERROR("027", "作者数量超限错误"),
+    CALCULATE_HASH_ERROR("014", "计算字符串hash错误"),
+    EVIDENCE_HASH_IS_NULL("016", "存证hash为空"),
+    ISSUE_TASK_ERROR("017", "下发任务失败"),
+    EVIDENCE_HASH_CAL_SM3("018", "存证hash摘要算法不通过,仅支持SM3"),
+    QUERY_OBTAIN_TASK_ERROR("019", "获取取证任务结果失败"),
+    OBTAIN_TASK_FAIL("020", "取证失败"),
+    QUERY_CERT_FAIL("021", "获取取证证书信息失败"),
+    URL_INVALID("022", "url不合规，请检查"),
+    DATE_INVALID("023", "时间不合规，请检查"),
+    CREATE_TORT_TASK_ERR("024", "创建侵权监控任务失败"),
+    FILE_AND_URL_NOT_MATCH("025", "evHash与url文件的hash不匹配"),
+    URL_OR_NETWORK_ERR("026", "url地址不正确或者网络不佳，文件下载失败"),
+    PARAM_FORMAT_ERROR("461000", "参数格式错误"),
+    INVALID_APP_ERROR("461010", "无效的用户appid"),
+    PACKAGE_CLOSE_ERROR("562012", "用户消费套餐已被关闭"),
+    NO_PACKAGE_ERROR("562013", "没有可用的消费套餐"),
+    SERVER_INNER_ERROR("562014", "内部错误"),
+    ORDER_NOT_FOUND_ERROR("-101", "此编号未查到对应信息"),
+    SERVER_ERROR("3108", "服务不可用,调用后端服务失败"),
+    UPDATE_CONSUME_ERROR("563006", "更新消费流水状态失败"),
+    MID_SERVER_ERROR("022", "中间件服务异常"),
+    TORT_SOURCE_ERROR("6026", "侵权 Source 类型错误");
+    private String code;
+    private String msg;
+    ErrorEnum(String code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+    public String getCode() { return this.code; }
+    public String getMsg() { return this.msg; }
+    public static String errorMsg(String content) {
+        ErrorEnum err = Arrays.<ErrorEnum>asList(values()).stream().filter(errorEnum -> errorEnum.getCode().equals(content)).findFirst().orElse(SERVER_INNER_ERROR);
+        return err.getMsg();
+    }
+}
\ No newline at end of file

liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-zxlnft/src/main/java/com/liquidnet/common/third/zxlnft/dto/ZxlNftResponseDto.java

+package com.liquidnet.common.third.zxlnft.dto;
+
+import com.liquidnet.commons.lang.util.JsonUtils;
+
+import java.io.Serializable;
+
+/**
+ * 
+ * @param <T>
+ */
+public class ZxlNftResponseDto<T> implements Serializable, Cloneable {
+    private static final long serialVersionUID = 8377276776600901982L;
+    private String retCode;
+    private String retMsg;
+    private T data;
+
+    public boolean isSuccess() {
+        return this.retCode.equals("0");
+    }
+
+    private ZxlNftResponseDto() {
+    }
+
+    private ZxlNftResponseDto(String retCode) {
+        this.retCode = retCode;
+    }
+
+    private ZxlNftResponseDto(String retCode, T data) {
+        this.retCode = retCode;
+        this.data = data;
+    }
+
+    private ZxlNftResponseDto(String retCode, String retMsg) {
+        this.retCode = retCode;
+        this.retMsg = retMsg;
+    }
+
+    private ZxlNftResponseDto(String retCode, String retMsg, T data) {
+        this.retCode = retCode;
+        this.retMsg = retMsg;
+        this.data = data;
+    }
+
+    /**
+     * <p>Getter for the field <retCode>data</retCode>.</p>
+     *
+     * @return a T object.
+     */
+    public T getData() {
+        return data;
+    }
+
+    public static <Object> ZxlNftResponseDto<Object> success() {
+        return new ZxlNftResponseDto<>("0");
+    }
+
+    public static <Object> ZxlNftResponseDto<Object> success(Object data) {
+        return new ZxlNftResponseDto<>("0", data);
+    }
+
+    public static <Object> ZxlNftResponseDto<Object> failure() {
+        return new ZxlNftResponseDto<>("1", "系统繁忙，请稍后再试");
+    }
+
+    public static <Object> ZxlNftResponseDto<Object> failure(String retMsg) {
+        return new ZxlNftResponseDto<>("1", retMsg);
+    }
+
+    public static <Object> ZxlNftResponseDto<Object> failure(String retCode, String retMsg) {
+        return new ZxlNftResponseDto<>(retCode, retMsg);
+    }
+
+    public static <Object> ZxlNftResponseDto<Object> failure(String retCode, String retMsg, Object data) {
+        return new ZxlNftResponseDto<>(retCode, retMsg, data);
+    }
+
+    public <T> T getParseData(Class<T> clazz) {
+        try {
+            if (getData() != null) {
+                return JsonUtils.fromJson(JsonUtils.toJson(getData()), clazz);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    public String toJson() {
+        return JsonUtils.toJson(this);
+    }
+}

liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-zxlnft/src/main/java/com/liquidnet/common/third/zxlnft/dto/nft/Nft016IdentityBindQueryResp.java

 package com.liquidnet.common.third.zxlnft.dto.nft;
 
+import com.liquidnet.commons.lang.util.JsonUtils;
 import lombok.Data;
 
+import java.util.List;
+
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
  * @version V1.0
@@ -12,6 +15,25 @@ import lombok.Data;
  * @date 2022/2/18 15:32
  */
 @Data
-public class Nft016IdentityBindQueryResp {
+public class Nft016IdentityBindQueryResp{
+    private List<queryRsData> queryRsDataList;
+    public static class queryRsData{
+        private String address;
+        private String status;
+
+    }
+
+    private static final Nft016IdentityBindQueryResp obj = new Nft016IdentityBindQueryResp();
+    public static Nft016IdentityBindQueryResp getNew() {
+        try {
+            return (Nft016IdentityBindQueryResp) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            return new Nft016IdentityBindQueryResp();
+        }
+    }
 
+    @Override
+    public String toString(){
+        return JsonUtils.toJson(this);
+    }
 }

liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-zxlnft/src/main/java/com/liquidnet/common/third/zxlnft/exception/ZxlNftException.java

+package com.liquidnet.common.third.zxlnft.exception;
+
+import lombok.Data;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: ZxlNftException
+ * @Package com.liquidnet.common.third.zxlnft.exception
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2022/2/21 13:44
+ */
+@Data
+public class ZxlNftException extends RuntimeException{
+       private static final long serialVersionUID = -3916918823313768482L;
+       private String code;
+       private String msg;
+
+       public ZxlNftException(String code, String msg) {
+             super(msg);
+             this.code = code;
+             this.msg = msg;
+       }
+
+       public ZxlNftException(String code, String msg, Throwable t) {
+             super(msg, t);
+             this.code = code;
+             this.msg = msg;
+       }
+}
+

liquidnet-bus-common/liquidnet-common-third/liquidnet-common-third-zxlnft/src/main/java/com/liquidnet/common/third/zxlnft/service/impl/ZxlnftSdkServiceImpl.java

 package com.liquidnet.common.third.zxlnft.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.liquidnet.common.third.zxlnft.biz.ZxlnftBiz;
 import com.liquidnet.common.third.zxlnft.config.ZxlnftConfig;
 import com.liquidnet.common.third.zxlnft.constant.ZxlnftConstant;
 import com.liquidnet.common.third.zxlnft.dto.nft.*;
+import com.liquidnet.common.third.zxlnft.exception.ZxlNftException;
 import com.liquidnet.common.third.zxlnft.service.ZxlnftSdkService;
 import com.liquidnet.commons.lang.util.HttpUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
@@ -131,7 +133,20 @@ public class ZxlnftSdkServiceImpl implements ZxlnftSdkService
         if (StringUtils.isEmpty(response)) {
             return null;
         }
-        Nft016IdentityBindQueryResp resp = JsonUtils.fromJson(response,Nft016IdentityBindQueryResp.class);
+
+        Nft016IdentityBindQueryResp resp = Nft016IdentityBindQueryResp.getNew();
+         JSONObject json = JSONObject.parseObject(response);
+         if (json.containsKey("retCode") && json.containsKey("data") && json.getInteger("retCode").intValue() == 0) {
+             JSONObject data = json.getJSONObject("data");
+             resp = JsonUtils.fromJson(data.toJSONString(),Nft016IdentityBindQueryResp.class);
+         }else {
+             if (json.containsKey("retCode") && json.getInteger("retCode").intValue() != 0) {
+                 throw new ZxlNftException(String.valueOf(json.getInteger("retCode")), json.getString("retMsg") + ", address:" + req.getAddressList());
+             }
+             throw new ZxlNftException(json.getString("retCode"), json.getString("retMsg") + ", address:" + req.getAddressList());
+         }
+
+        log.info("nft016IdentityBindQuery--->>> return result : {} ",resp.toString());
         return resp;
     }