{ "title": "归集行业信息到开发监管环境-优化配置-人员相关信息变更", "groupId": "cdc-gathering-reader-db-employee-user-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":"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)" } ] }, { "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)" } ] }, { "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_01", "title": "执行公司持证保安员数变更操作-proc_sync_company_info_collect_by_user_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_tenant_user_credential(:after.tenant_user_id,:after.credential_type,:after.created_time)" }, { "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_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.id)" }, { "uid":"user_tlk_tenant_user_credentials_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.id)" }, { "uid":"user_tlk_tenant_user_credentials_05", "title": "执行驻勤点表负责人证件相关信息更新-proc_sync_attendance_PRINCIPAL_by_tenant_users_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_attendance_PRINCIPAL_by_tenant_users_credentials(:after.tenant_user_id)" }, { "uid":"user_tlk_tenant_user_credentials_06", "title": "执行驻勤点表挂靠人证件相关信息更新-proc_sync_attendance_site_base_info_by_tenant_users_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_attendance_site_base_info_by_tenant_users_credentials(:after.tenant_user_id)" }, { "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.id)" } ] }, { "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,:before.checked_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)" }, { "uid":"user_tenant_users_02", "title": "执行驻勤点表负责人姓名相关信息更新-proc_sync_attendance_PRINCIPAL_by_tenant_users_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_attendance_PRINCIPAL_by_tenant_users_credentials(:after.id)" }, { "uid":"user_tenant_users_03", "title": "执行驻勤点表挂靠人姓名相关信息更新-proc_sync_attendance_site_base_info_by_tenant_users_credentials", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_attendance_site_base_info_by_tenant_users_credentials(:after.id)" }, { "uid":"user_tenant_users_04", "title": "执行人员核验状态变更公司保安员数信息更新-proc_sync_rd_company_info_collect_by_tenant_users", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_tenant_users(:after.id,:before.checked_status,:after.checked_status,:after.last_updated_time)" }, { "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)" } ] }, { "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)" } ] }, { "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_01", "title": "执行资格证、等级证变报名时就职单位和培训单位信息更新-proc_sync_tlk_qualification_grade_certificate_by_details", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_tlk_qualification_grade_certificate_by_details(:after.id,:after.certificateType)" }, { "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.id)" } ] } ] }