可信空间连接器入住接口

@@ -91,6 +91,9 @@ public class TdsConnectorIdentityManagementRQVO extends FlowRQBaseVO {
     @Schema(description = "业务审批状态")
     @Schema(description = "业务审批状态")
     private String bizApproveState;
     private String bizApproveState;
 
 
+    @Schema(title = "节点名称")
+    private String zqName;
+    
     /******** 库表存储属性 需处理 *****/
     /******** 库表存储属性 需处理 *****/
     
     
     /******** 自定义扩展 *****/
     /******** 自定义扩展 *****/

@@ -106,6 +106,9 @@ public class TdsConnectorIdentityManagementRSVO extends BaseVO {
     @Schema(title = "跨平台审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)")
     @Schema(title = "跨平台审批状态(N 初始 A 审批中 Y 已通过 R 驳回 C 已撤销)")
     private String crossPlatformApproveState;
     private String crossPlatformApproveState;
 
 
+    @Schema(title = "节点名称")
+    private String zqName;
+    
     /******** 库表存储属性 需处理 *****/
     /******** 库表存储属性 需处理 *****/
     
     
     /******** 自定义扩展 *****/
     /******** 自定义扩展 *****/

@@ -114,6 +114,9 @@ public class TdsConnectorIdentityRQVO extends FlowRQBaseVO {
 
 
     private String funcCode;
     private String funcCode;
 
 
+    @Schema(title = "节点名称")
+    private String zqName;
+    
     /******** 库表存储属性 需处理 *****/
     /******** 库表存储属性 需处理 *****/
     
     
     /******** 自定义扩展 *****/
     /******** 自定义扩展 *****/

@@ -102,6 +102,9 @@ public class TdsConnectorIdentityRSVO extends BaseVO {
     @Schema(description = "是否变更数据【N 正常数据，Y 变更数据】")
     @Schema(description = "是否变更数据【N 正常数据，Y 变更数据】")
     private String isChangeData;
     private String isChangeData;
 
 
+    @Schema(title = "节点名称")
+    private String zqName;
+
     /******** 库表存储属性 需处理 *****/
     /******** 库表存储属性 需处理 *****/
     
     
     /******** 自定义扩展 *****/
     /******** 自定义扩展 *****/

@@ -105,4 +105,7 @@ public class MfTdsConnectorIdentity extends BaseShardingDO {
      */
      */
     @Name("原始数据Guid")
     @Name("原始数据Guid")
     private String sourceBizGuid;
     private String sourceBizGuid;
+
+    @Name("节点名称")
+    private String zqName;
 }
 }

@@ -96,4 +96,7 @@ public class MfTdsConnectorIdentityManagement extends BaseShardingDO {
     @Name("所属法人或其他组织名称")
     @Name("所属法人或其他组织名称")
     private String legalEntity;
     private String legalEntity;
 
 
+    @Name("节点名称")
+    private String zqName;
+
 }
 }

@@ -356,6 +356,7 @@ public class TdsConnectorIdentityServiceImpl extends FlowAbstractImpl implements
     @Override
     @Override
     public TdsConnectorIdentityRSVO getEffectiveConnector() {
     public TdsConnectorIdentityRSVO getEffectiveConnector() {
         LambdaQueryWrapper<MfTdsConnectorIdentity> queryWrapper = Wrappers.lambdaQuery();
         LambdaQueryWrapper<MfTdsConnectorIdentity> queryWrapper = Wrappers.lambdaQuery();
+        queryWrapper.eq(MfTdsConnectorIdentity::getIsChangeData,"N");
         queryWrapper.eq(MfTdsConnectorIdentity::getBizApproveState,ApprovalStateEnum.PASSED.getValue());
         queryWrapper.eq(MfTdsConnectorIdentity::getBizApproveState,ApprovalStateEnum.PASSED.getValue());
         List<MfTdsConnectorIdentity> list = mfTdsConnectorIdentityService.list(queryWrapper);
         List<MfTdsConnectorIdentity> list = mfTdsConnectorIdentityService.list(queryWrapper);
         if(ObjectUtils.isNotEmpty(list)){
         if(ObjectUtils.isNotEmpty(list)){