【数据资产】

1、增加企业认证创建会员类型

@@ -121,14 +121,14 @@ public class TdsConnectorIdentityController {
     @GetMapping("/get-effective-connector")
     @SystemLog(value = "连接器身份信息-查询有效的连接器信息")
     public CommonRes<TdsConnectorIdentityRSVO> getEffectiveConnector() {
-        TdsConnectorIdentityRSVO vo = tdsConnectorIdentityService.getEffectiveConnector();
+        TdsConnectorIdentityRSVO vo = tdsConnectorIdentityService.getEffectiveConnector(null);
         return CommonRes.success(vo);
     }
 
     @GetMapping("/get-connector-identity")
     @SystemLog(value = "连接器身份信息-查询有效的连接器信息")
-    public CommonRes<String> getConnector() {
-        TdsConnectorIdentityRSVO vo = tdsConnectorIdentityService.getEffectiveConnector();
+    public CommonRes<String> getConnector(@RequestParam String tenantGuid) {
+        TdsConnectorIdentityRSVO vo = tdsConnectorIdentityService.getEffectiveConnector(tenantGuid);
         if(ObjectUtils.isEmpty(vo)){
             return CommonRes.success("");
         }

@@ -85,7 +85,7 @@ public interface TdsConnectorIdentityService {
      * 查询有效的连接器信息
      * @return
      */
-    TdsConnectorIdentityRSVO getEffectiveConnector();
+    TdsConnectorIdentityRSVO getEffectiveConnector(String tenantGuid);
 
     /**
      * 查询连接器信息

@@ -21,7 +21,6 @@ import com.csbr.qingcloud.portal.domain.vo.*;
 import com.csbr.qingcloud.portal.service.DataPortService;
 import com.csbr.qingcloud.portal.service.TdsConnectorAdditionalService;
 import com.csbr.qingcloud.portal.service.TdsConnectorVerifiableService;
-import com.csbr.qingcloud.portal.util.IdentificationCodeUtil;
 import csbr.cloud.entity.domain.base.vo.PageListVO;
 import com.csbr.qingcloud.portal.mybatis.entity.MfTdsConnectorIdentity;
 import com.csbr.qingcloud.portal.mybatis.service.MfTdsConnectorIdentityService;
@@ -359,10 +358,14 @@ public class TdsConnectorIdentityServiceImpl extends FlowAbstractImpl implements
     }
 
     @Override
-    public TdsConnectorIdentityRSVO getEffectiveConnector() {
+    public TdsConnectorIdentityRSVO getEffectiveConnector(String tenantGuid) {
         LambdaQueryWrapper<MfTdsConnectorIdentity> queryWrapper = Wrappers.lambdaQuery();
         queryWrapper.eq(MfTdsConnectorIdentity::getIsChangeData,"N");
         queryWrapper.eq(MfTdsConnectorIdentity::getBizApproveState,ApprovalStateEnum.PASSED.getValue());
+        if (StringUtils.isNotEmpty(tenantGuid)) {
+            mfTdsConnectorIdentityService.csbrExcludeShardingLambdaQueryWrapper(queryWrapper);
+            queryWrapper.eq(MfTdsConnectorIdentity::getTenantGuid, tenantGuid);
+        }
         List<MfTdsConnectorIdentity> list = mfTdsConnectorIdentityService.list(queryWrapper);
         if(ObjectUtils.isNotEmpty(list)){
             return convertToVO(list.get(0));