{
  "title": "归集行业信息-优化配置-职员信息变更",
  "groupId": "cdc-gathering-reader-db-employee-12",
  "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":"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,:before.occupation_type,: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,:security_station_id,:security_station_name,:security_supervise_depart_name,:security_supervise_depart_id,:userCredential.zgz_number,:userCredential.dj_level,:user.name,:user.telephone,:user.sex,:user.nation,:user.education,:user.birthdate,:user.politics_status,:user.military_status,:user.authenticated_status,:user.authenticated_time,:user.authenticated_result,:user.background_screening_status,:user.household_type,:user.stature,:user.native_place,:user.marital_status,:user.emergency_contact,:user.emergency_phone,:user.license_level,:user.work_year,:user.diseases_history,:user.place_of_now_address,:user.selected_credential_id,:before.hired_operator_created_time,:after.hired_operator_created_time)"
        },
        {
		  "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,:after.hired_date,:after.insure,:after.status,:department.name)"
        }
      ]
    },
    {
      "uid":"employees_tenant_employee_records_topic",
      "topic": "obpm2.binlog-cdc.topic.v2.tenant_employee_records",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
          "uid":"employees_tenant_employee_records_01",
          "title": "执行职员入离职记录信息更新-proc_sync_employed_events_info_collect_by_employee_events_v3",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_employed_events_info_collect_by_employee_events_v4(:after.id,:after.employee_id,:after.status,:after.action_note,:after.action_time,:after.created_time,:employee.interview,:organization.id,:organization.name,:organization.approved_information_status,:organization.supervise_region_code,:organization.institutional_code,:after.tenant_user_id,:user.name,:after.occupation_type)"
        }
      ]
    },
    {
      "uid":"employees_industry_info_employees_topic",
      "topic": "companyinfocollect.binlog-cdc.topic.v2.employees",
      "refKafkaName": "kafka-collection",
      "subscriberContents": [
        {
          "uid":"company_employees_01",
          "title": "执行公司保安员统计信息更新-proc_sync_rd_company_info_collect_by_employees_v3",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_employees_v3(:after.item_domain_id,:before.employed,:after.employed,:before.occupation_type,:after.occupation_type,:before.certificate_no,:after.certificate_no)",
          "conditionExpress":"#{before.employed}!=#{after.employed}||#{before.occupation_type}!=#{after.occupation_type}||#{before.certificate_no}!=#{after.certificate_no}"
        },
        {
          "uid": "others_tenant_organizations_01",
          "title": "职员入离职后对应驻勤点驻勤人数更新-proc_sync_att_site_update_attPersonNum_by_employees_v3",
          "refJdbcName": "industryInfoCollection-jdbc",
          "type": "JDBC",
          "content": "call companyinfocollect.proc_sync_att_site_update_attPersonNum_by_employees_v3(:before.att_site_id,:after.att_site_id,:before.employed,:after.employed)",
          "conditionExpress": "#{before.employed}!=#{after.employed}||#{before.att_site_id}!=#{after.att_site_id}"
        }
      ]
    }
  ]
}