{ "title": "归集行业信息-优化配置-人员相关信息变更", "groupId": "cdc-gathering-reader-db-employee-user-1", "batchSize": 500, "batchIntervalMs": 2000, "kafkaConnections": [ { "name": "kafka-collection", "bootstrapServer": "192.168.0.243:9092,192.168.0.12:9092,192.168.0.126:9092" } ], "jdbcConnections": [ { "name": "industryInfoCollection-jdbc", "url": "jdbc:mysql://192.168.0.7:3368/companyinfocollect?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8&useSSL=false&allowPublicKeyRetrieval=true&zeroDateTimeBehavior=CONVERT_TO_NULL&allowMultiQueries=true&autoReconnect=true", "userName": "v5_enterprise2021", "password": "Prod_v5#202109", "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": "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)" }, { "uid":"user_tenant_user_credential_details_05", "title": "证书详情同步签章证书表操作-proc_sync_security_flow_tlk_certificate_by_details", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "INSERT INTO security_flow.`tlk_certificate` (`id`, `APPLICATIONID`, `FORMNAME`, `CREATED`, `FORMID`, `DOMAINID`, `ITEM_domain_id`, `ITEM_companyName`, `item_securityname`, `ITEM_DOCUMENTTYPE`, `item_documentid`, `ITEM_headphoto`, `item_certificateno`, `item_certificatedate`, `item_status`, `item_certificatetype`, `item_regionalorigin`, `item_region`, `ITEM_MARK`, `item_isInMyCompany`, `item_level`, `ITEM_IDADDRESS`, `item_certificatefrom`, `ITEM_attachment`, `ITEM_isCertified`, `ITEM_EXAMDATE`) SELECT replace(:after.id,'__jlNfVcjppSliMYH6FkJ','__TTeElnX8IULbf7iTxsM') ,'__zG1ZQsueGwri0O6cXww' , '证书管理/旧证管理/Certificate', :after.create_time, '__TTeElnX8IULbf7iTxsM','' ,k.`company_id` ,k.`company_name` ,:after.xm ,'1' ,:after.idnum ,k.`id_person_photo` ,:after.zsbh ,:after.fzrq ,:after.state ,:after.certificateType ,'610000' ,:after.areacode ,:after.mark ,IF(k.`employed`=0,1,0) ,:after.appraisalGrade ,IF(:after.populationAddress is not null and :after.populationAddress!='',:after.populationAddress,k.`id_address`) ,:after.fzjgmc ,:after.electronCerUrl ,k.`check_status` ,if(:after.examDate='',null,:after.examDate) FROM companyinfocollect.`employees` k WHERE (:after.electronCerUrl='' OR :after.electronCerUrl is null) AND (INSTR(:after.fzjgmc,'西安市') OR INSTR(:after.fzjgmc,'汉中市')) AND :after.state=1 AND k.user_id=:after.tenant_user_id ON DUPLICATE KEY UPDATE ITEM_domain_id = VALUES(ITEM_domain_id), ITEM_companyName = VALUES(ITEM_companyName), item_securityname = VALUES(item_securityname), ITEM_DOCUMENTTYPE = VALUES(ITEM_DOCUMENTTYPE), item_documentid = VALUES(item_documentid), ITEM_headphoto = VALUES(ITEM_headphoto), item_certificateno = VALUES(item_certificateno), item_certificatedate = VALUES(item_certificatedate), item_status = VALUES(item_status), item_certificatetype = VALUES(item_certificatetype), item_region = VALUES(item_region), item_isInMyCompany = VALUES(item_isInMyCompany), ITEM_IDADDRESS = VALUES(ITEM_IDADDRESS), item_certificatefrom = VALUES(item_certificatefrom), ITEM_attachment = VALUES(ITEM_attachment), ITEM_EXAMDATE = VALUES(ITEM_EXAMDATE), ITEM_isCertified = VALUES(ITEM_isCertified)" } ] }, { "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)" } ] } ] }