{
  "title": "归集行业信息到开发监管环境-优化配置-其他信息变更",
  "groupId": "cdc-gathering-reader-db-others-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": "others_tlk_attendance_site_base_info_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_attendance_site_base_info",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_attendance_site_base_info_01",
          "title": "执行驻勤点变更操作-proc_sync_employees_info_collect_by_attendance_site",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_attendance_site_v2(:after.id,:after.ITEM_attendanceSiteName,:after.ITEM_officePoliceAddress,:after.ITEM_officePoliceAddressID,:after.LASTMODIFIED)",
          "conditionExpress": ":after.id==:before.id"
        },
        {
			"uid": "others_tlk_attendance_site_base_info_02",
          "title": "执行驻勤点状态变更操作-proc_sync_company_info_by_attendance_site",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_attendance_site(:before.DOMAINID,:after.DOMAINID,:after.LASTMODIFIED)"
        },
        {
			"uid": "others_tlk_attendance_site_base_info_03",
          "title": "执行驻勤点变更操作-proc_sync_rd_attendance_site_base_info_collect_by_id",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_attendance_site_base_info_collect_by_id(:after.id)"
        }
      ]
    },
    {
		"uid": "others_tlk_attendance_site_person_info_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_attendance_site_person_info",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_attendance_site_person_info_01",
          "title": "执行驻勤点人员变更操作-proc_sync_employees_info_by_attendance_site_person",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_att_site_person(:before.ITEM_securityId,:after.ITEM_securityId)"
        },
        {
			"uid": "others_tlk_attendance_site_person_info_02",
          "title": "执行驻勤点人员信息变更操作-proc_sync_tlk_attendance_site_person_info_by_id_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_tlk_attendance_site_person_info_by_id_v2(:before.ID,:after.ID,:organization.after.supervise_region_code)"
        },
        {
			"uid": "others_tlk_attendance_site_person_info_03",
          "title": "执行驻勤点表驻勤人数更新操作-proc_sync_att_site_update_attPersonNum_by_att_site_person_info",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_att_site_update_attPersonNum_by_att_site_person_info(:before.id,:after.id,:before.ITEM_attendanceSiteId,:after.ITEM_attendanceSiteId)"
        }
      ]
    },
    {
		"uid": "others_tlk_goodperson_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_goodperson",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_goodperson_01",
          "title": "执行好人好事变更操作-proc_sync_good_deeds_detail_by_tlk_goodperson_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_good_deeds_detail_by_tlk_goodperson_v2(:after.id,:organization.after.supervise_region_code)"
        }
      ]
    },
    {
		"uid": "others_tlk_punish_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_punish",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_punish_01",
          "title": "执行惩罚变更操作-proc_sync_punishment_detail_by_tlk_punish_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_punishment_detail_by_tlk_punish_v2(:after.id,:organization.after.supervise_region_code)"
        }
      ]
    },
    {
		"uid": "others_tlk_awardk_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_awardk",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_awardk_01",
          "title": "执行表彰变更操作-proc_sync_commendation_detail_by_tlk_awardk_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_commendation_detail_by_tlk_awardk_v2(:after.id,:organization.after.supervise_region_code)"
        }
      ]
    },
    {
		"uid": "others_tlk_jfdevice_2_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_jfdevice_2",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_jfdevice_2_01",
          "title": "执行设备变更操作-proc_sync_rd_device_info_collect_by_device_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_device_info_collect_by_device_v3(:after.id,:before.id,:organization.after.name,:organization.after.supervise_depart_name,:organization.after.supervise_depart_id,:organization.supervise_region_code)"
        }
      ]
    },
    {
		"uid": "others_tlk_vehicle_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_vehicle",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_vehicle_01",
          "title": "执行车辆变更操作-proc_sync_rd_vehicle_info_collect_by_vehicle_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_vehicle_info_collect_by_vehicle_v3(:after.id,:before.id,:organization.after.supervise_depart_name,:organization.after.supervise_depart_id,:organization.supervise_region_code)"
        }
      ]
    },
    {
		"uid": "others_tenant_contracts_topic",
      "topic": "obpm2.binlog-cdc.topic.v2.tenant_contracts",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tenant_contracts_01",
          "title": "执行合同信息变更操作-proc_sync_employee_contracts_info_collect_by_contract_id_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_employee_contracts_info_collect_by_contract_id_v2(:after.id,:organization.after.supervise_region_code)"
        }
      ]
    },
    {
		"uid": "others_tlk_contracttoenterprise_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_contracttoenterprise",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_contracttoenterprise_01",
          "title": "执行保安服务合同变更操作-proc_sync_tlk_contract_to_enterprise_by_tlk_ContractToEnterprise",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_tlk_contract_to_enterprise_by_tlk_ContractToEnterprise(:before.id,:after.id,:organization.supervise_region_code,:organization.supervise_depart_name,:organization.supervise_depart_id)"
        },
        {
			"uid": "others_tlk_contracttoenterprise_02",
          "title": "执行驻勤点中合同信息变更操作-proc_sync_attendance_site_base_update_by_ContractToEnterprise",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_attendance_site_base_update_by_ContractToEnterprise(:after.id)"
        }
      ]
    },
    {
      "uid": "others_tlk_setsupervise_topic",
      "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_setsupervise",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
			"uid": "others_tlk_setsupervise_01",
          "title": "执行保安员合同监管机构名称变更信息更新-proc_sync_employee_contracts_info_collect_by_tlk_setsupervise",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_employee_contracts_info_collect_by_tlk_setsupervise(:after.DOMAINID)"
        }
      ]
    }
  ]
}