{
  "title": "归集行业信息-优化配置-人员相关信息变更",
  "groupId": "cdc-gathering-reader-db-employee-user-1",
  "batchSize": 500,
  "batchIntervalMs": 2000,
  "kafkaConnections": [
    {
      "name": "kafka-collection",
      "bootstrapServer": "117.78.39.204:9092"
    }
  ],
  "jdbcConnections": [
    {
      "name": "industryInfoCollection-jdbc",
      "url": "jdbc:mysql://49.4.21.141:45611/companyinfocollect?characterEncoding=UTF-8&connectionTimeZone=GMT&allowMultiQueries=true&autoReconnect=true",
      "userName": "bcx",
      "password": "Wstestv5qy#2022",
      "driverClassName": "com.mysql.cj.jdbc.Driver"
    }
  ],
  "topicSubscribers": [
    {
	  "uid":"user_tenant_users_topic",
      "topic": "obpm2.binlog-cdc.topic.v2.tenant_users",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
		  "uid":"user_tenant_users_01",
          "title": "执行员工信息变更操作-proc_sync_rd_employee_info_collect_by_user_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_user_v2(:after.id,:after.name,:after.telephone,:after.sex,:after.nation,:after.education,:after.birthdate,:after.politics_status,:after.military_status,:after.checked_status,:after.authenticated_status,:after.authenticated_time,:after.authenticated_result,:after.background_screening_status,:after.last_updated_time,:after.household_type,:after.stature,:after.native_place,:after.marital_status,:after.emergency_contact,:after.emergency_phone,:after.license_level,:after.work_year,:after.diseases_history,:after.place_of_now_address,:before.id,:before.name,:before.telephone,:before.sex,:before.nation,:before.education,:before.birthdate,:before.politics_status,:before.military_status,:before.checked_status,:before.authenticated_status,:before.authenticated_time,:before.authenticated_result,:before.background_screening_status,:before.household_type,:before.stature,:before.native_place,:before.marital_status,:before.emergency_contact,:before.emergency_phone,:before.license_level,:before.work_year,:before.diseases_history,:before.place_of_now_address)"
        },
        {
          "uid":"user_tenant_users_02",
          "title": "执行驻勤点表负责人姓名相关信息更新-proc_sync_attendance_PRINCIPAL_by_tenant_users_credentials",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_attendance_PRINCIPAL_update_by_tenant_users(:after.id,:after.name,:after.telephone,:after.checked_status)"
        },
        {
          "uid":"user_tenant_users_03",
          "title": "执行驻勤点表挂靠人姓名相关信息更新-proc_sync_attendance_site_base_info_by_tenant_users_credentials",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_attendance_REALITY_update_by_tenant_users(:after.id,:before.name,:after.name,:before.telephone,:after.telephone)"
        },
        {
		  "uid":"user_tenant_users_05",
          "title": "执行驻勤点人员实名认证、证件核验信息更新-proc_sync_tlk_attendance_site_person_info_by_users",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_tlk_attendance_site_person_info_by_users(:after.id,:after.checked_status,:after.authenticated_status,:after.telephone,:before.checked_status,:before.authenticated_status,:before.telephone)"
        }
      ]
    }
  ]
}