【数据资产】

数据港接口

+package com.csbr.qingcloud.portal.config;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * @program:
+ * @description: 数据港配置
+ * @author: yio
+ * @create: 2024-05-31 14:16
+ **/
+@Component
+@ConfigurationProperties(prefix = "dataport")
+@Data
+public class DataPortConfig {
+    private String username;
+    private String password;
+    private String authKey;
+    private String registerAuthKey;
+    private String requestUri;
+    private String operatorRegisterUri;
+    private String enterpriseRegisterUri;
+}

@@ -2,11 +2,14 @@ package com.csbr.qingcloud.portal.controller;
 
 import com.csbr.cloud.common.entity.CsbrUpdate;
 import com.csbr.cloud.common.response.CommonRes;
+import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO;
 import com.csbr.qingcloud.portal.domain.vo.*;
+import com.csbr.qingcloud.portal.mybatis.entity.MfEnterprise;
+import com.csbr.qingcloud.portal.mybatis.service.MfEnterpriseService;
+import com.csbr.qingcloud.portal.service.DataPortService;
+import com.csbr.qingcloud.portal.service.DemandService;
 import csbr.cloud.entity.annotation.SystemLog;
 import csbr.cloud.entity.domain.base.vo.PageListVO;
-import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO;
-import com.csbr.qingcloud.portal.service.DemandService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -128,6 +131,20 @@ public class DemandController {
         List<ProcessOrderProcessDtlRSVO> pageVO = demandService.listByProcessOrderNo();
         return CommonRes.success(pageVO);
     }
+
+    @Resource
+    private MfEnterpriseService mfEnterpriseService;
+
+    @Resource
+    private DataPortService dataPortService;
+
+    @GetMapping("/test")
+    public CommonRes getToken(@RequestParam String guid) {
+        MfEnterprise entity = mfEnterpriseService.getById(guid);
+        dataPortService.operatorRegister(entity);
+        dataPortService.enterpriseRegister(entity);
+        return CommonRes.success(Boolean.TRUE);
+    }
     
     //endregion
     

+package com.csbr.qingcloud.portal.domain.vo.dataPort;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 15:43
+ **/
+@Data
+@Schema(title = "公共身份附件信息参数")
+public class AttachmentCommonVO {
+
+    @Schema(title = "附件类型")
+    private String attachType;
+
+    @Schema(title = "附件名称")
+    private String attachName;
+
+    @Schema(title = "附件编号")
+    private String attachCode;
+
+    @Schema(title = "附件签发机构")
+    private String issueOrg;
+
+    @Schema(title = "签发日期")
+    private String issueDate;
+
+    @Schema(title = "到期日期")
+    private String expireDate;
+
+    @Schema(title = "附件验证地址或区块链凭证索引")
+    private String verifyUrl;
+
+    @Schema(title = "附件描述信息")
+    private String description;
+
+}
\ No newline at end of file

+package com.csbr.qingcloud.portal.domain.vo.dataPort;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @program:
+ * @description: 数据港返回结果
+ * @author: makejava
+ * @create: 2025-09-05 10:35
+ **/
+@Data
+@Schema(title = "数据港返回结果")
+public class DataPortRes<T> implements Serializable {
+
+    /**
+     * 返回码
+     */
+    @Schema(description = "返回码")
+    private Integer code;
+
+    /**
+     * 返回描述
+     */
+    @Schema(description = "返回描述")
+    private String message;
+
+    /**
+     * 数据
+     */
+    @Schema(description = "数据")
+    private T data;
+
+    public DataPortRes(Integer code, T data){
+        this.code = code;
+        this.data = data;
+    }
+
+    public DataPortRes(Integer code, String message){
+        this.code = code;
+        this.message = message;
+    }
+
+    /**
+     * 返回成功
+     * @param data
+     * @param <T>
+     * @return
+     */
+    public static <T> DataPortRes<T> success(T data) {
+        return new DataPortRes<T>(200, data);
+    }
+
+    /**
+     * 返回失败
+     * @param message
+     * @return
+     */
+    public static DataPortRes fail(String message) {
+        return new DataPortRes(500, message);
+    }
+}

+package com.csbr.qingcloud.portal.domain.vo.dataPort;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 15:38
+ **/
+@Data
+@Schema(title = "法人注册参数")
+public class EnterpriseRegisterRQVO {
+
+    @Schema(title = "唯一身份标识")
+    private String identityCode;
+
+    @Schema(title = "法人或其他组织名称")
+    private String enterpriseName;
+
+    @Schema(title = "统一社会信用代码")
+    private String enterpriseCode;
+
+    @Schema(title = "法人或其他组织类型")
+    private String enterpriseType;
+
+    @Schema(title = "经营期限起始")
+    private String operatingPeriodBegin;
+
+    @Schema(title = "经营期限截止")
+    private String operatingPeriodEnd;
+
+    @Schema(title = "实名认证方式")
+    private String authType;
+
+    @Schema(title = "实名认证状态")
+    private String authStatus;
+
+    @Schema(title = "实名认证时间")
+    private String authDate;
+
+    @Schema(title = "法定代表人或负责人姓名")
+    private String legalPerson;
+
+    @Schema(title = "法定代表人或负责人证件号")
+    private String legalPersonCertno;
+
+    @Schema(title = "法定代表人或负责人实名等级")
+    private String legalPersonAuthLevel;
+
+    @Schema(title = "个人实名认证方式")
+    private String legalPersonAuthType;
+
+    @Schema(title = "法人用户状态")
+    private String identityStatus;
+
+    @Schema(title = "法人用户身份附属信息")
+    private EnterpriseSubordinateRQVO extendInfo;
+
+    @Schema(title = "法人用户身份附件信息")
+    private List<AttachmentCommonVO> attachInfo;
+
+}
\ No newline at end of file

+package com.csbr.qingcloud.portal.domain.vo.dataPort;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 15:43
+ **/
+@Data
+@Schema(title = "法人身份附属信息参数")
+public class EnterpriseSubordinateRQVO extends SubordinateCommonVO {
+
+    @Schema(title = "注册地址")
+    private String enterpriseAddress;
+
+    @Schema(title = "注册金额")
+    private String regAmount;
+
+    @Schema(title = "注册日期")
+    private String regDate;
+
+    @Schema(title = "经营范围")
+    private String businessScope;
+
+    @Schema(title = "行业类型")
+    private String industryCategory;
+
+    @Schema(title = "行业小类")
+    private String industryCategory2;
+
+    @Schema(title = "核准机构")
+    private String approvalAuthority;
+
+    @Schema(title = "法定代表人或负责人手机号")
+    private String legalPersonPhone;
+
+    @Schema(title = "法定代表人或负责人邮箱")
+    private String legalPersonEmail;
+
+    @Schema(title = "法定代表人或负责人身份状态")
+    private String legalPersonStatus;
+
+}
\ No newline at end of file

+package com.csbr.qingcloud.portal.domain.vo.dataPort;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 15:38
+ **/
+@Data
+@Schema(title = "经办人注册参数")
+public class OperatorRegisterRQVO {
+
+    @Schema(title = "经办人姓名")
+    private String operator;
+
+    @Schema(title = "经办人身份标识")
+    private String identityCode;
+
+    @Schema(title = "证件类型")
+    private String operatorIdType;
+
+    @Schema(title = "证件号码")
+    private String operatorId;
+
+    @Schema(title = "实名认证等级")
+    private String operatorAuthLevel;
+
+    @Schema(title = "经办人授权方式")
+    private String authorizationType;
+
+    @Schema(title = "实名认证方式")
+    private String operatorAuthType;
+
+    @Schema(title = "认证日期")
+    private String authTime;
+
+    @Schema(title = "身份状态")
+    private String authStatus;
+
+    @Schema(title = "统一社会信用代码")
+    private String enterpriseCode;
+
+    @Schema(title = "经办人用户身份附属信息")
+    private OperatorSubordinateRQVO extendInfo;
+
+    @Schema(title = "经办人用户身份附件信息")
+    private List<AttachmentCommonVO> attachInfo;
+
+}
\ No newline at end of file

+package com.csbr.qingcloud.portal.domain.vo.dataPort;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 15:43
+ **/
+@Data
+@Schema(title = "经办人身份附属信息参数")
+public class OperatorSubordinateRQVO extends SubordinateCommonVO {
+
+    @Schema(title = "法人组织名称")
+    private String enterpriseName;
+
+    @Schema(title = "支付宝账号")
+    private String alipayAccount;
+
+    @Schema(title = "微信账号")
+    private String weixinAccount;
+
+}
\ No newline at end of file

+package com.csbr.qingcloud.portal.domain.vo.dataPort;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 15:43
+ **/
+@Data
+@Schema(title = "公共身份附属信息参数")
+public class SubordinateCommonVO {
+
+    @Schema(title = "电子营业执照")
+    private String businessLicense;
+
+    @Schema(title = "社保卡卡号")
+    private String socialSecurityCard;
+
+    @Schema(title = "社保卡发放地")
+    private String socialSecurityCardSite;
+
+}
\ No newline at end of file

+package com.csbr.qingcloud.portal.service;
+
+import com.csbr.qingcloud.portal.mybatis.entity.MfEnterprise;
+import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseChangeApprove;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 15:13
+ **/
+public interface DataPortService {
+
+    /**
+     * 经办人用户注册
+     * @param entity
+     */
+    void operatorRegister(MfEnterprise entity);
+
+    /**
+     * 经办人用户更新
+     * @param entity
+     */
+    void operatorUpdate(MfEnterpriseChangeApprove entity);
+
+    /**
+     * 法人用户注册
+     * @param entity
+     */
+    void enterpriseRegister(MfEnterprise entity);
+
+    /**
+     * 法人用户更新
+     * @param entity
+     */
+    void enterpriseUpdate(MfEnterpriseChangeApprove entity);
+}
\ No newline at end of file

+package com.csbr.qingcloud.portal.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.csbr.cloud.common.enums.RedisKeyEnum;
+import com.csbr.cloud.distributelock.util.RedisUtil;
+import com.csbr.qingcloud.portal.config.DataPortConfig;
+import com.csbr.qingcloud.portal.domain.vo.dataPort.EnterpriseRegisterRQVO;
+import com.csbr.qingcloud.portal.domain.vo.dataPort.EnterpriseSubordinateRQVO;
+import com.csbr.qingcloud.portal.domain.vo.dataPort.OperatorRegisterRQVO;
+import com.csbr.qingcloud.portal.domain.vo.dataPort.OperatorSubordinateRQVO;
+import com.csbr.qingcloud.portal.mybatis.entity.MfEnterprise;
+import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseChangeApprove;
+import com.csbr.qingcloud.portal.service.DataPortService;
+import com.csbr.qingcloud.portal.util.DataPortConnectUtil;
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.jetbrains.annotations.NotNull;
+import org.springframework.stereotype.Service;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 15:13
+ **/
+@Slf4j
+@Service
+public class DataPortServiceImpl implements DataPortService {
+
+    @Resource
+    private DataPortConnectUtil dataPortConnectUtil;
+
+    @Resource
+    private DataPortConfig dataPortConfig;
+
+    @Resource
+    private RedisUtil redisUtil;
+
+    @Override
+    public void operatorRegister(MfEnterprise entity) {
+        OperatorRegisterRQVO operatorRegisterRQVO = beforeOperator(entity);
+        dataPortConnectUtil.postByAuthKey(operatorRegisterRQVO, dataPortConfig.getOperatorRegisterUri());
+    }
+
+    @Override
+    public void operatorUpdate(MfEnterpriseChangeApprove entity) {
+
+    }
+
+    @Override
+    public void enterpriseRegister(MfEnterprise entity) {
+        EnterpriseRegisterRQVO enterpriseRegisterRQVO = beforeEnterprise(entity);
+        dataPortConnectUtil.postByAuthKey(enterpriseRegisterRQVO, dataPortConfig.getEnterpriseRegisterUri());
+    }
+
+    @Override
+    public void enterpriseUpdate(MfEnterpriseChangeApprove entity) {
+
+    }
+
+    /**
+     * 经办人注册前置
+     * @param entity
+     * @return
+     */
+    private OperatorRegisterRQVO beforeOperator(MfEnterprise entity) {
+        Map<String, String> documentsDicMap = getSystemParamsMap("证件类型");
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
+        OperatorRegisterRQVO operatorRegisterRQVO = new OperatorRegisterRQVO();
+        operatorRegisterRQVO.setOperator(entity.getContacts());
+//        operatorRegisterRQVO.setIdentityCode(entity.getManagerPersonId());
+        operatorRegisterRQVO.setOperatorIdType(documentsDicMap.get(entity.getHandlePersonIdType()));
+        operatorRegisterRQVO.setOperatorId(entity.getManagerPersonId());
+//        operatorRegisterRQVO.setOperatorAuthLevel(entity.getAuthenticationLevel());
+        operatorRegisterRQVO.setOperatorAuthLevel("1");
+//        operatorRegisterRQVO.setAuthorizationType(entity.getAuthenticationMethod());
+        operatorRegisterRQVO.setAuthorizationType("1");
+//        operatorRegisterRQVO.setAuthTime(simpleDateFormat.format(entity.getAuthenticationTime()));
+        operatorRegisterRQVO.setAuthTime(simpleDateFormat.format(new Date()));
+//        operatorRegisterRQVO.setAuthStatus(entity.getIdentityState());
+        operatorRegisterRQVO.setAuthStatus("1");
+        operatorRegisterRQVO.setOperatorAuthType("1");
+        operatorRegisterRQVO.setEnterpriseCode(entity.getSocialCreditCode());
+        OperatorSubordinateRQVO operatorSubordinateRQVO = new OperatorSubordinateRQVO();
+        operatorSubordinateRQVO.setEnterpriseName(entity.getTenantName());
+        operatorSubordinateRQVO.setBusinessLicense(getUrl(entity.getBusinessLicenseJson()));
+        operatorRegisterRQVO.setExtendInfo(operatorSubordinateRQVO);
+        return operatorRegisterRQVO;
+    }
+
+    /**
+     * 法人注册前置
+     * @param entity
+     * @return
+     */
+    private EnterpriseRegisterRQVO beforeEnterprise(MfEnterprise entity) {
+        Map<String, String> industryDicMap = getSystemParamsMap("行业分类");
+        EnterpriseRegisterRQVO enterpriseRegisterRQVO = new EnterpriseRegisterRQVO();
+        enterpriseRegisterRQVO.setEnterpriseName(entity.getTenantName());
+        enterpriseRegisterRQVO.setIdentityCode(entity.getSocialCreditCode());
+        enterpriseRegisterRQVO.setEnterpriseCode(entity.getSocialCreditCode());
+        enterpriseRegisterRQVO.setEnterpriseType("4");
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
+        enterpriseRegisterRQVO.setOperatingPeriodBegin(simpleDateFormat.format(entity.getBusinessLicenseStartDate()));
+        enterpriseRegisterRQVO.setOperatingPeriodEnd(simpleDateFormat.format(entity.getBusinessLicenseEndDate()));
+//        enterpriseRegisterRQVO.setAuthType(entity.getAuthenticationMethod());
+        enterpriseRegisterRQVO.setAuthType("3");
+//        enterpriseRegisterRQVO.setAuthStatus(entity.getAuthenticationState());
+        enterpriseRegisterRQVO.setAuthStatus("1");
+//        enterpriseRegisterRQVO.setAuthDate(simpleDateFormat.format(entity.getAuthenticationTime()));
+        enterpriseRegisterRQVO.setAuthDate(simpleDateFormat.format(new Date()));
+        enterpriseRegisterRQVO.setLegalPerson(entity.getJuridicalPerson());
+        enterpriseRegisterRQVO.setLegalPersonCertno(entity.getJuridicalPersonId());
+        enterpriseRegisterRQVO.setLegalPersonAuthLevel("1");
+        enterpriseRegisterRQVO.setLegalPersonAuthType("1");
+//        enterpriseRegisterRQVO.setIdentityStatus(entity.getIdentityState());
+        enterpriseRegisterRQVO.setIdentityStatus("1");
+        EnterpriseSubordinateRQVO extendInfo = new EnterpriseSubordinateRQVO();
+        extendInfo.setEnterpriseAddress(entity.getDetailedAddress());
+        extendInfo.setRegAmount(entity.getRegisteredCapital().toString());
+        extendInfo.setRegDate(simpleDateFormat.format(entity.getRegistrationDate()));
+        extendInfo.setBusinessScope(entity.getBusinessLicenseScope());
+        extendInfo.setIndustryCategory(industryDicMap.get(entity.getIndustry()));
+        extendInfo.setIndustryCategory2(industryDicMap.get(entity.getIndustrySmallcode()));
+        extendInfo.setBusinessLicense(getUrl(entity.getBusinessLicenseJson()));
+        enterpriseRegisterRQVO.setExtendInfo(extendInfo);
+        return enterpriseRegisterRQVO;
+    }
+
+    /**
+     * 取数据字典
+     * @param paramCode
+     * @return
+     */
+    private Map<String, String> getSystemParamsMap(String paramCode) {
+        //获取平台字典信息
+        Object dictMapValue= redisUtil.get(String.format(RedisKeyEnum.DICT_ITEM_MAP.getCode(), paramCode));
+        if(ObjectUtils.isEmpty(dictMapValue)){
+            return new HashMap<>();
+        }
+        return (Map<String, String>) dictMapValue;
+    }
+
+    private String getUrl(String businessLicenseJson) {
+        if (StringUtils.isEmpty(businessLicenseJson)) {
+            return null;
+        }
+        if (businessLicenseJson.contains("[")) {
+            return JSON.parseArray(businessLicenseJson).getJSONObject(0).getString("url");
+        }
+        return JSON.parseObject(businessLicenseJson).getString("url");
+    }
+}
\ No newline at end of file

@@ -19,10 +19,7 @@ import com.csbr.qingcloud.portal.mybatis.entity.MfEnterprise;
 import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseChangeApprove;
 import com.csbr.qingcloud.portal.mybatis.service.MfEnterpriseChangeApproveService;
 import com.csbr.qingcloud.portal.mybatis.service.MfEnterpriseService;
-import com.csbr.qingcloud.portal.service.EnterpriseAttachmentService;
-import com.csbr.qingcloud.portal.service.EnterpriseChangeApproveService;
-import com.csbr.qingcloud.portal.service.EnterpriseDomainService;
-import com.csbr.qingcloud.portal.service.EnterpriseService;
+import com.csbr.qingcloud.portal.service.*;
 import com.csbr.qingcloud.portal.util.ChangeInfoUtil;
 import com.csbr.qingcloud.portal.util.InvokeUtil;
 import com.csbr.qingcloud.portal.util.ZQConfig;
@@ -95,6 +92,9 @@ public class EnterpriseChangeApproveServiceImpl implements EnterpriseChangeAppro
     @Resource
     private EnterpriseDomainService enterpriseDomainService;
 
+    @Resource
+    private DataPortService dataPortService;
+
     /** 保存变更数据 */
     @Override
     public void changeSave(ChangeApproveVO vo) {
@@ -248,6 +248,10 @@ public class EnterpriseChangeApproveServiceImpl implements EnterpriseChangeAppro
 
             //同步更新会员表
             enterpriseService.updateTenant(vo);
+
+            // 调用数据港法人和经办人更新接口
+            dataPortService.operatorUpdate(entity);
+            dataPortService.enterpriseUpdate(entity);
         }
     }
 

@@ -34,6 +34,7 @@ import com.csbr.qingcloud.portal.mybatis.entity.MfEnterpriseChangeApprove;
 import com.csbr.qingcloud.portal.mybatis.service.MfDemandService;
 import com.csbr.qingcloud.portal.mybatis.service.MfEnterpriseChangeApproveService;
 import com.csbr.qingcloud.portal.mybatis.service.MfEnterpriseService;
+import com.csbr.qingcloud.portal.service.DataPortService;
 import com.csbr.qingcloud.portal.service.EnterpriseAttachmentService;
 import com.csbr.qingcloud.portal.service.EnterpriseDomainService;
 import com.csbr.qingcloud.portal.service.EnterpriseService;
@@ -124,6 +125,9 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris
     @Resource
     private ValidatorUtil validatorUtil;
 
+    @Resource
+    private DataPortService dataPortService;
+
     /**
      * 企业信息分页查询
      * @author xcq
@@ -472,6 +476,9 @@ public class EnterpriseServiceImpl extends FlowAbstractImpl implements Enterpris
             else{
                 updateTenant(entity);
             }
+            // 调用数据港法人和经办人注册接口
+            dataPortService.operatorRegister(entity);
+            dataPortService.enterpriseRegister(entity);
         }
 
     }

+package com.csbr.qingcloud.portal.util;
+
+import com.alibaba.fastjson.JSONObject;
+import com.csbr.cloud.common.enums.SystemError;
+import com.csbr.cloud.common.exception.CsbrSystemException;
+import com.csbr.qingcloud.portal.config.DataPortConfig;
+import com.csbr.qingcloud.portal.domain.vo.dataPort.DataPortRes;
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+/**
+ * @program: daop-projects
+ * @description:
+ * @author: xiaojie
+ * @create: 2025-10-11 11:01
+ **/
+@Slf4j
+@Component
+public class DataPortConnectUtil {
+
+    @Resource
+    private DataPortConfig dataPortConfig;
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    /**
+     * 获取数据港token
+     * @return
+     */
+    public String getToken() {
+        HttpHeaders headers = new HttpHeaders();
+        headers.set("Content-Type", "application/json");
+        headers.set("authKey", dataPortConfig.getAuthKey());
+
+        JSONObject params = new JSONObject();
+        params.put("username", dataPortConfig.getUsername());
+        params.put("password", dataPortConfig.getPassword());
+        HttpEntity<JSONObject> request = new HttpEntity<>(params, headers);
+        DataPortRes dataPortRes = restTemplate.postForObject(
+                dataPortConfig.getRequestUri() + "/api/user/singleLogin/getThreeUserToken"
+                , request, DataPortRes.class);
+
+        if (ObjectUtils.isEmpty(dataPortRes)) {
+            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, "获取token失败.");
+        }
+        if (200 != dataPortRes.getCode() && 201 != dataPortRes.getCode()) {
+            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, dataPortRes.getMessage());
+        }
+        return (String) dataPortRes.getData();
+    }
+
+    /**
+     * 经办人用户注册
+     * @return
+     */
+    public String operatorRegister(Object obj) {
+        HttpHeaders headers = new HttpHeaders();
+        headers.set("Content-Type", "application/json");
+        headers.set("authKey", dataPortConfig.getAuthKey());
+
+        HttpEntity<Object> request = new HttpEntity<>(obj, headers);
+        DataPortRes dataPortRes = restTemplate.postForObject(
+                dataPortConfig.getRequestUri() + "/api/user/user/operatorRegister"
+                , request, DataPortRes.class);
+
+        if (ObjectUtils.isEmpty(dataPortRes)) {
+            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, "经办人用户注册失败.");
+        }
+        if (200 != dataPortRes.getCode() && 201 != dataPortRes.getCode()) {
+            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, dataPortRes.getMessage());
+        }
+        return (String) dataPortRes.getData();
+    }
+
+    /**
+     * 法人用户注册
+     * @return
+     */
+    public String enterpriseRegister(Object obj) {
+        HttpHeaders headers = new HttpHeaders();
+        headers.set("Content-Type", "application/json");
+        headers.set("authKey", dataPortConfig.getAuthKey());
+
+        HttpEntity<Object> request = new HttpEntity<>(obj, headers);
+        DataPortRes dataPortRes = restTemplate.postForObject(
+                dataPortConfig.getRequestUri() + "/api/user/user/enterpriseRegister"
+                , request, DataPortRes.class);
+
+        if (ObjectUtils.isEmpty(dataPortRes)) {
+            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, "法人用户注册失败.");
+        }
+        if (200 != dataPortRes.getCode() && 201 != dataPortRes.getCode()) {
+            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, dataPortRes.getMessage());
+        }
+        return (String) dataPortRes.getData();
+    }
+
+    /**
+     * 调用数据港接口
+     * @return
+     */
+    public Object postByAuthKey(Object obj, String uri) {
+        HttpHeaders headers = new HttpHeaders();
+        headers.set("Content-Type", "application/json");
+        headers.set("authKey", dataPortConfig.getRegisterAuthKey());
+
+        HttpEntity<Object> request = new HttpEntity<>(obj, headers);
+        DataPortRes dataPortRes = restTemplate.postForObject(
+                dataPortConfig.getRequestUri() + uri
+                , request, DataPortRes.class);
+
+        if (ObjectUtils.isEmpty(dataPortRes)) {
+            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, "调用数据港接口失败.");
+        }
+        if (200 != dataPortRes.getCode() && 201 != dataPortRes.getCode()) {
+            throw new CsbrSystemException(SystemError.DATA_GET_ERROR, dataPortRes.getMessage());
+        }
+        return dataPortRes.getData();
+    }
+
+}
\ No newline at end of file