{ "title": "归集行业信息-优化配置-人员相关信息变更", "groupId": "cdc-gathering-reader-db-employee-user-1", "batchSize": 500, "batchIntervalMs": 2000, "kafkaConnections": [ { "name": "kafka-collection", "bootstrapServer": "49.4.84.49:9092" } ], "jdbcConnections": [ { "name": "industryInfoCollection-jdbc", "url": "jdbc:mysql://117.78.35.63:3306/companyinfocollect?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8&allowMultiQueries=true&autoReconnect=true", "userName": "pre_prod", "password": "pre-prod#202305", "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_tenant_user_credentials_topic", "topic": "obpm2.binlog-cdc.topic.v2.tenant_user_credentials", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid":"user_tlk_tenant_user_credentials_02", "title": "执行职员证件信息变更操作-proc_sync_rd_employee_info_collect_by_user_credentials_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_user_credentials_v2(:after.selected,:after.tenant_user_id,:after.credential_type,:after.created_time,:after.number,:after.valid_date_from,:after.valid_date_to,:after.address,:after.front_photo,:after.reverse_photo,:after.head_photo)" }, { "uid":"user_tlk_tenant_user_credentials_05", "title": "执行驻勤点表负责人证件相关信息更新-proc_sync_attendance_PRINCIPAL_update_tenant_user_credentialsP", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_attendance_PRINCIPAL_update_tenant_user_credentialsP(:after.tenant_user_id,:after.number,:before.number,:after.credential_type,:before.credential_type)" }, { "uid":"user_tlk_tenant_user_credentials_06", "title": "执行驻勤点表挂靠人证件相关信息更新-proc_sync_attendance_REALITY_update_by_tenant_user_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_attendance_REALITY_update_by_tenant_user_credentials(:after.tenant_user_id,:before.number,:after.number,:before.credential_type)" }, { "uid":"user_tlk_tenant_user_credentials_07", "title": "执行驻勤点人员身份证号信息更新-proc_sync_tlk_attendance_site_person_info_by_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_tlk_attendance_site_person_info_by_credentials(:after.number,:after.tenant_user_id,:after.credential_type)" } ] }, { "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_update_by_tenant_users", "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_REALITY_update_by_tenant_users", "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)" } ] }, { "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_06", "title": "执行分销商管理离职信息更新-proc_bcx_product_rules_by_tenant_employees", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call shoppingrules.proc_bcx_product_rules_by_tenant_employees(:after.organization_id,:after.status,:after.is_domain_admin,:before.is_domain_admin)" }, { "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)" } ] }, { "uid":"user_tenant_user_credential_details_topic", "topic": "obpm2.binlog-cdc.topic.v2.tenant_user_credential_details", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid":"user_tenant_user_credential_details_00", "title": "执行资格证、等级证变更时保安员证件信息更新-proc_sync_rd_employee_info_collect_by_user_credentials_detail_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_user_credentials_detail_v2(:after.tenant_user_id,:after.certificateType,:after.zsbh,:after.active,:after.state,:after.appraisalGrade,:before.zsbh,:before.idnum,:after.idnum,:before.state,:before.tenant_user_id,:before.areaCode,:after.areaCode,:before.appraisalGrade,:before.mark,:after.mark,:after.id,:before.id)" }, { "uid":"user_tenant_user_credential_details_02", "title": "执行驻勤点人员持证状态、证件编号信息信息更新-proc_sync_tlk_attendance_site_person_info_by_details", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_tlk_attendance_site_person_info_by_details(:after.zsbh,:after.tenant_user_id,:user.checked_status,:after.certificateType,:before.zsbh)" }, { "uid":"user_tenant_user_credential_details_03", "title": "执行员工资格证信息变更操作-proc_sync_tlk_qualification_certificate_by_user_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_tlk_qualification_certificate_by_user_credentials(:after.create_time,:after.areaCode,:after.companyId,:after.id,:after.isOldData,:after.xm,:after.idnum,:after.sex,:after.phone,:after.state,:after.cancelReason,:after.zsbh,:after.cancelDate,:after.fzjgmc,:after.fzrq,:after.companyName,:after.trainName,:after.cancelOrgName,:after.certificateType,:after.active,:after.mark)" }, { "uid":"user_tenant_user_credential_details_04", "title": "执行员工等级证信息变更操作-proc_sync_tlk_grade_certificate_by_user_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_tlk_grade_certificate_by_user_credentials(:after.create_time,:after.areaCode,:after.companyId,:after.id,:after.xm,:after.idnum,:after.zsbh,:after.companyName,:after.trainName,:after.trainStartTime,:after.trainEndTime,:after.appraisalTime,:after.appraisalGrade,:after.certificateType,:after.active,:after.mark,:after.state,:after.cancelReason,:after.cancelDate,:after.cancelOrgName,:after.sex,:after.phone)" } ] } ] }