{
  "title": "归集行业信息到开发监管环境-优化配置-公司信息变更",
  "groupId": "cdc-gathering-reader-db-company-1",
  "batchSize": 500,
  "batchIntervalMs": 2000,
  "kafkaConnections": [
    {
      "name": "kafka-collection",
      "bootstrapServer": "192.168.40.4:9092"
    }
  ],
  "jdbcConnections": [
    {
      "name": "industryInfoCollection-jdbc",
      "url": "jdbc:mysql://220.243.148.23:2111/companyinfocollect?characterEncoding=UTF-8&serverTimezone=GMT%2B8&allowMultiQueries=true&autoReconnect=true",
      "userName": "bcx",
      "password": "Wstestv5qy#2022",
      "driverClassName": "com.mysql.cj.jdbc.Driver"
    }
  ],
  "topicSubscribers": [
    {
      "uid": "company_tenant_organizations_topic",
      "topic": "obpm2.binlog-cdc.topic.v2.tenant_organizations",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
          "uid": "company_tenant_organizations_01",
          "title": "执行公司名变更操作-proc_sync_rd_employee_info_collect_by_organization_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_organization_v2(:after.id,:before.name,:after.name,:after.supervise_region_code,:after.supervise_depart_name,:before.supervise_depart_id,:after.supervise_depart_id,:after.institutional_code,:after.last_updated_time,:before.approved_information_status,:after.approved_information_status)"
        },
        {
		  "uid": "company_tenant_organizations_02",
          "title": "执行公司信息变更操作-proc_sync_rd_company_info_collect_by_organization_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_organization_v2(:after.id,:after.name,:after.status,:after.telephone,:after.fax,:after.place_of_register_province_name,:after.place_of_register_city_name,:after.place_of_register_district_name,:after.place_of_register_address,:after.place_of_business_province_name,:after.place_of_business_city_name,:after.place_of_business_district_name,:after.place_of_business_address,:after.place_of_register_province_code,:after.place_of_register_city_code,:after.place_of_register_district_code,:after.place_of_business_province_code,:after.place_of_business_city_code,:after.place_of_business_district_code,:after.type,:after.institutional_code,:after.industry_detail_type,:after.supervise_region_code,:after.supervise_depart_name,:after.supervise_depart_id,:after.created_time,:after.last_updated_time,:after.approved_information_status)"
        },
        {
		  "uid": "company_tenant_organizations_03",
          "title": "执行股东公司名变更操作-proc_sync_rd_shareholder_info_collect_by_company_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_shareholder_info_collect_by_company_v2(:after.id,:after.place_of_business_address,:after.name)"
        },
        {
		  "uid": "company_tenant_organizations_04",
          "title": "执行管理层公司名变更操作-proc_sync_rd_management_info_collect_by_company_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_management_info_collect_by_company_v2(:after.id,:after.name)"
        },
        {
		  "uid": "company_tenant_organizations_05",
          "title": "执行外地总公司名变更操作-proc_sync_rd_subcompany_info_collect_by_company_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_subcompany_info_collect_by_company_v2(:after.id,:after.place_of_business_address,:after.name,:after.place_of_register_province_name,:after.place_of_register_address,:after.place_of_business_province_name)"
        },
        {
		  "uid": "company_tenant_organizations_06",
          "title": "执行设备公司变更操作-proc_sync_rd_device_info_collect_by_company_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_device_info_collect_by_company_v2(:after.id,:after.name,:after.supervise_depart_name,:after.supervise_depart_id)"
        },
        {
		  "uid": "company_tenant_organizations_07",
          "title": "执行车辆公司变更操作-proc_sync_rd_vehicle_info_collect_by_company_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_vehicle_info_collect_by_company_v2(:after.id,:after.supervise_depart_name,:after.supervise_depart_id)"
        },
        {
		  "uid": "company_tenant_organizations_08",
          "title": "执行公司审核状态变更改变入离职记录操作-proc_sync_employed_events_info_collect_by_organization_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_employed_events_info_collect_by_organization_v2(:after.id,:before.name,:after.name,:after.last_updated_time,:before.approved_information_status,:after.approved_information_status,:after.supervise_region_code)"
        },
        {
		  "uid": "company_tenant_organizations_09",
          "title": "执行驻勤点表公司名称及监管机构信息变更操作-proc_sync_attendance_site_base_info_update_company_by_id",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_attendance_site_base_info_update_company_by_id(:after.id,:after.name,:after.supervise_depart_name,:after.supervise_depart_id)"
        },
        {
		  "uid": "company_tenant_organizations_10",
          "title": "执行驻勤点表公司名及其监管机构变更操作-proc_sync_attendance_site_base_info_by_tenant_organizations",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_attendance_site_base_info_by_tenant_organizations(:after.id,:before.name,:after.name,:before.supervise_depart_name,:after.supervise_depart_name,:before.supervise_depart_id,:after.supervise_depart_id)"
        }
      ]
    },
    {
	  "uid": "company_tenant_companies_topic",
      "topic": "obpm2.binlog-cdc.topic.v2.tenant_companies",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
		  "uid": "company_tenant_companies_01",
          "title": "执行公司信息变更操作-proc_sync_rd_company_info_collect_by_companies",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_companies(:after.id)"
        },
        {
		  "uid": "company_tenant_companies_02",
          "title": "执行总公司变更操作-proc_sync_rd_subcompany_info_collect_by_companytel",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_subcompany_info_collect_by_companytel(:after.id)"
        }
      ]
    },
    {
	  "uid": "company_tenant_departments_topic",
      "topic": "obpm2.binlog-cdc.topic.v2.tenant_departments",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
		  "uid": "company_tenant_departments_01",
          "title": "执行部门名称变更操作-proc_sync_rd_employee_info_collect_by_department_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_department_v2(:after.id,:after.name,:after.last_updated_time)",
          "conditionExpress": ":after.name!=:before.name"
        }
      ]
    },
    {
	  "uid": "company_tlk_subcompanyinformation_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_subcompanyinformation",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
          "uid": "company_tlk_subcompanyinformation_01",
          "title": "执行分子公司变更操作-proc_sync_rd_subcompany_info_collect_by_subcompany_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_subcompany_info_collect_by_subcompany_v2(:after.id,:organization.after.supervise_region_code,:organization.after.place_of_business_address,:organization.after.name,:organization.after.place_of_register_province_name,:organization.after.place_of_register_address,:organization.after.place_of_business_province_name)"
        }
      ]
    }
  ]
}