{ "title": "归集行业信息-优化配置-公司相关信息", "groupId": "cdc-gathering-reader-db-employee-user-1", "batchSize": 500, "batchIntervalMs": 2000, "kafkaConnections": [ { "name": "kafka-collection", "bootstrapServer": "10.100.146.2:9092" } ], "jdbcConnections": [ { "name": "industryInfoCollection-jdbc", "url": "jdbc:mysql://10.100.146.2:3368/companyinfocollect?characterEncoding=UTF-8&serverTimezone=GMT%2B8&useSSL=false&allowPublicKeyRetrieval=true&zeroDateTimeBehavior=CONVERT_TO_NULL&allowMultiQueries=true&autoReconnect=true", "userName": "jinzhongin", "password": "YVPQRhwUQhhz", "driverClassName": "com.mysql.cj.jdbc.Driver" } ], "topicSubscribers": [ { "uid": "user_tlk_managementlayer_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_managementlayer", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "user_tlk_managementlayer_01", "title": "执行管理层信息增删变更操作-proc_sync_company_info_collect_by_management", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_management(:before.DOMAINID,:after.DOMAINID,:after.LASTMODIFIED)" }, { "uid": "user_tlk_managementlayer_02", "title": "执行管理层变更操作-proc_sync_rd_management_info_collect_by_management", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_management_info_collect_by_management_v2(:after.id,:organization.after.supervise_region_code,:organization.after.name,:organization.after.supervise_depart_id)" } ] }, { "uid": "user_tlk_shareholderinformation_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_shareholderinformation", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "user_tlk_shareholderinformation_01", "title": "执行股东公司信息变更操作-proc_sync_company_info_collect_by_shareholder", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_shareholder(:before.DOMAINID,:after.DOMAINID,:after.LASTMODIFIED)" }, { "uid": "user_tlk_shareholderinformation_02", "title": "执行股东变更操作-proc_sync_rd_shareholder_info_collect_by_shareholder", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_shareholder_info_collect_by_shareholder_v2(:after.id,:organization.after.supervise_region_code,:organization.after.place_of_business_address,:organization.after.name,:organization.after.supervise_depart_id)" } ] }, { "uid": "user_tlk_securitymastermanagement_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_securitymastermanagement", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "user_tlk_securitymastermanagement_01", "title": "执行保安师变更操作-proc_sync_rd_employee_info_collect_by_securitymastermanagement", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_securitymastermanagement(:before.ITEM_DOCUMENTID,:after.ITEM_DOCUMENTID,:after.LASTMODIFIED,:after.DOMAINID,:before.ITEM_DEGREE,:after.ITEM_DEGREE)" } ] }, { "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,:after.salary)" }, { "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_employees_05", "title": "离职人员移除出驻勤点操作", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "DELETE FROM baibaodunflow.tlk_attendance_site_person_info where ITEM_SECURITYID = :after.id and :before.status = 0 and :after.status = 1; UPDATE baibaodunflow.tlk_attendance_site_arrange_info set ITEM_LEAVE_ATT_TIME = NOW(),ITEM_LEAVE_ATT_OPERATOR= :after.leave_operator_name,LASTMODIFIED = NOW() where ITEM_SECURITYID = :after.id and ITEM_LEAVE_ATT_TIME is null and :before.status = 0 and :after.status = 1" }, { "uid": "employees_tenant_employees_02221", "title": "执行管理层在职状态变更操作-proc_sync_rd_management_info_collect_by_employee", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_management_info_collect_by_employee(:after.id,:after.status)" } ] }, { "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,:organization.supervise_depart_id)" } ] }, { "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)" }, { "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)" } ] } ] }