{
  "title": "归集行业信息到开发监管环境-优化配置-职员信息变更",
  "groupId": "cdc-gathering-reader-db-employee-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":"employees_tenant_employees_topic",	
      "topic": "obpm2.binlog-cdc.topic.v2.tenant_employees",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
		  "uid":"employees_tenant_employees_01",	
          "title": "执行职员变更操作-proc_sync_employees_info_collect_by_employee",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_employee_v2(:after.id,:after.tenant_user_id,:after.occupation_type,:after.hired_date,:after.leave_time,:before.status,:after.status,:after.insure,:after.created_time,:after.last_updated_time,:after.department_id,:department.name,:organization.id,:organization.supervise_region_code,:organization.name,:organization.institutional_code,:organization.supervise_depart_name,:organization.supervise_depart_id,:organization.approved_information_status,:user.checked_status)"
        },
        {
		  "uid":"employees_tenant_employees_02",
          "title": "执行职员人数变更操作-proc_sync_rd_company_info_collect_by_employee_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_employee_v2(:after.organization_id,:after.last_updated_time,:before.status,:after.status,:before.occupation_type,:after.occupation_type)"
        },
        {
		  "uid":"employees_tenant_employees_03",	
          "title": "执行职员面谈记录变更操作-proc_sync_employed_events_info_collect_by_employee_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_employed_events_info_collect_by_employee_v2(:after.id,:before.interview,:after.interview,:after.last_updated_time)"
        },
        {
		  "uid":"employees_tenant_employees_04",	
          "title": "执行驻勤点人员入职时间、投保状态信息更新-proc_sync_tlk_attendance_site_person_info_by_employees",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_tlk_attendance_site_person_info_by_employees(:after.id)"
        },
        {
          "uid":"employees_tenant_employees_05",
          "title": "职员就职状态变化驻勤点人数变更操作-proc_sync_att_site_update_attPersonNum_by_employees",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_att_site_update_attPersonNum_by_employees(:after.id)"
        }
      ]
    },
    {
	  "uid":"employees_tenant_employee_events_topic",	
      "topic": "obpm2.binlog-cdc.topic.v2.tenant_employee_events",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
		  "uid":"employees_tenant_employee_events_01",	
          "title": "执行职员入离职记录信息更新-proc_sync_employed_events_info_collect_by_employee_events_v2",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_employed_events_info_collect_by_employee_events_v2(:after.id,:after.employee_id,:after.event_type,:after.note,:after.event_time,:after.created_time)"
        }
      ]
    }
  ]
}