{ "title": "归集行业信息-优化配置-其他信息变更", "groupId": "cdc-gathering-reader-db-others-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": "others_tlk_attendance_site_base_info_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_attendance_site_base_info", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_attendance_site_base_info_01", "title": "执行驻勤点变更操作-proc_sync_employees_info_collect_by_attendance_site", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_attendance_site_v2(:after.id,:after.ITEM_attendanceSiteName,:after.ITEM_officePoliceAddress,:after.ITEM_officePoliceAddressID,:after.LASTMODIFIED)" }, { "uid": "others_tlk_attendance_site_base_info_02", "title": "执行驻勤点状态变更操作-proc_sync_company_info_by_attendance_site", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_attendance_site(:before.DOMAINID,:after.DOMAINID,:after.LASTMODIFIED)" }, { "uid": "others_tlk_attendance_site_base_info_03", "title": "执行驻勤点变更操作-proc_sync_rd_attendance_site_base_info_collect_by_id", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_attendance_site_base_info_collect_by_id(:after.id,:before.ITEM_CONTRACTIDS,:after.ITEM_CONTRACTIDS,:before.ITEM_principal,:after.ITEM_principal,:before.ITEM_USERID,:after.ITEM_USERID,:user.id,:organization.supervise_region_code,:organization.supervise_depart_name,:organization.supervise_depart_id,:organization.institutional_code,:after.ITEM_CONCURRENTSTAFFNUMBER)" } ] }, { "uid": "others_tlk_attendance_site_person_info_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_attendance_site_person_info", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_attendance_site_person_info_01", "title": "执行驻勤点人员变更操作-proc_sync_employees_info_by_attendance_site_person", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_att_site_person(:before.ITEM_securityId,:after.ITEM_securityId)" }, { "uid": "others_tlk_attendance_site_person_info_02", "title": "执行驻勤点人员信息变更操作-proc_sync_tlk_attendance_site_person_info_by_id_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_tlk_attendance_site_person_info_by_id_v2(:before.ID,:after.ID,:organization.after.supervise_region_code,:user.id,:employee.insure,:employee.hired_date,:user.authenticated_status,:user.checked_status,:employee.status,:after.FORMNAME,:after.AUTHOR,:after.AUTHORDEPTID,:after.AUTHOR_DEPT_INDEX,:after.AUTHOR_USER_INDEX,:after.SUBFORMIDS,:after.INITIATOR,:after.ISTMP,:after.VERSIONS,:after.LASTMODIFIER,:after.ITEM_SECURITYNAME,:after.ITEM_SECURITYID,:after.ITEM_ATTENDANCESITEID,:after.ITEM_DOCUMENTTYPE,:after.ITEM_DOCUMENTID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_JOBTYPE,:after.ITEM_CREATEDUSER,:after.ITEM_DOMAIN_ID,:after.CREATED,:certificate.zsbh,:organization.supervise_depart_id)" }, { "uid": "others_tlk_attendance_site_person_info_03", "title": "执行驻勤点表驻勤人数更新操作-proc_sync_att_site_update_attPersonNum_by_att_site_person_info", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_att_site_update_attPersonNum_by_att_site_person_info(:before.id,:after.id,:before.ITEM_attendanceSiteId,:after.ITEM_attendanceSiteId)" } ] }, { "uid": "others_tlk_goodperson_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_goodperson", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_goodperson_01", "title": "执行好人好事变更操作-proc_sync_good_deeds_detail_by_tlk_goodperson_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_good_deeds_detail_by_tlk_goodperson_v2(:after.id,:before.id,:organization.after.supervise_region_code,:organization.supervise_depart_id)" } ] }, { "uid": "others_tlk_punish_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_punish", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_punish_01", "title": "执行惩罚变更操作-proc_sync_punishment_detail_by_tlk_punish_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_punishment_detail_by_tlk_punish_v2(:after.id,:before.id,:organization.after.supervise_region_code,:organization.supervise_depart_id)" } ] }, { "uid": "others_tlk_awardk_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_awardk", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_awardk_01", "title": "执行表彰变更操作-proc_sync_commendation_detail_by_tlk_awardk_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_commendation_detail_by_tlk_awardk_v2(:after.id,:before.id,:organization.after.supervise_region_code,:organization.supervise_depart_id)" } ] }, { "uid": "others_tlk_jfdevice_2_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_jfdevice_2", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_jfdevice_2_01", "title": "执行设备变更操作-proc_sync_rd_device_info_collect_by_device_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_device_info_collect_by_device_v3(:after.id,:before.id,:organization.after.name,:organization.after.supervise_depart_name,:organization.after.supervise_depart_id,:organization.supervise_region_code)" } ] }, { "uid": "others_tlk_vehicle_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_vehicle", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_vehicle_01", "title": "执行车辆变更操作-proc_sync_rd_vehicle_info_collect_by_vehicle_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_vehicle_info_collect_by_vehicle_v3(:after.id,:before.id,:organization.after.supervise_depart_name,:organization.after.supervise_depart_id,:organization.supervise_region_code)" } ] }, { "uid": "others_tenant_contracts_topic", "topic": "obpm2.binlog-cdc.topic.v2.tenant_contracts", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tenant_contracts_01", "title": "执行合同信息变更操作-proc_sync_employee_contracts_info_collect_by_contract_id_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_employee_contracts_info_collect_by_contract_id_v2(:before.id,:after.id,:organization.after.supervise_region_code,:user.id,:user.telephone,:organization.supervise_depart_name,:organization.supervise_depart_id,:organization.telephone,:after.employee_id,:after.name,:after.b_name,:after.a_name,:after.begin_date,:after.end_date,:after.attachment,:after.note,:after.status,:after.creator_created_time,:organization.id)" } ] }, { "uid": "others_tlk_contracttoenterprise_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_contracttoenterprise", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_contracttoenterprise_01", "title": "执行保安服务合同变更操作-proc_sync_tlk_contract_to_enterprise_by_tlk_ContractToEnterprise", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_tlk_contract_to_enterprise_by_tlk_ContractToEnterprise(:before.id,:after.id,:organization.supervise_region_code,:organization.supervise_depart_name,:organization.supervise_depart_id)" }, { "uid": "others_tlk_contracttoenterprise_02", "title": "执行驻勤点中合同信息变更操作-proc_sync_attendance_site_base_update_by_ContractToEnterprise", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_attendance_site_base_update_by_ContractToEnterprise(:after.id)" } ] }, { "uid": "others_tlk_customerfollow", "topic": "mcs.binlog-cdc.topic.v2.tlk_customerfollow", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "others_tlk_customerfollow_01", "title": "执行客户管理跟进人变更数据操作-sync_customerfollow_to_member_service", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call mcs.sync_customerfollow_to_member_service(:before.id,:after.id,:before.item_belongerId,:after.item_belongerId,:before.item_customerId,:after.item_customerId,:after.created,:after.lastmodified)" } ] }, { "uid": "company_tenant_organizations_topic", "topic": "obpm2.binlog-cdc.topic.v2.tenant_organizations", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "company_tenant_organizations_01", "title": "执行公司名变更操作-proc_sync_rd_employee_info_collect_by_organization_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_organization_v2(:after.id,:before.name,:after.name,:after.supervise_region_code,:after.supervise_depart_name,:before.supervise_depart_id,:after.supervise_depart_id,:after.institutional_code,:after.last_updated_time,:before.approved_information_status,:after.approved_information_status,:before.supervise_region_code,:before.supervise_depart_name)" }, { "uid": "company_tenant_organizations_02", "title": "执行公司信息变更操作-proc_sync_rd_company_info_collect_by_organization_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_organization_v2(:after.id,:after.name,:after.status,:after.telephone,:after.fax,:after.place_of_register_province_name,:after.place_of_register_city_name,:after.place_of_register_district_name,:after.place_of_register_address,:after.place_of_business_province_name,:after.place_of_business_city_name,:after.place_of_business_district_name,:after.place_of_business_address,:after.place_of_register_province_code,:after.place_of_register_city_code,:after.place_of_register_district_code,:after.place_of_business_province_code,:after.place_of_business_city_code,:after.place_of_business_district_code,:after.type,:after.institutional_code,:after.industry_detail_type,:after.supervise_region_code,:after.supervise_depart_name,:after.supervise_depart_id,:after.created_time,:after.last_updated_time,:after.approved_information_status,:after.latitude,:after.longitude)" }, { "uid": "company_tenant_organizations_03", "title": "执行股东公司名变更操作-proc_sync_rd_shareholder_info_collect_by_company_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_shareholder_info_collect_by_company_v2(:after.id,:after.place_of_business_address,:after.name,:after.supervise_depart_id,:after.supervise_region_code)" }, { "uid": "company_tenant_organizations_04", "title": "执行管理层公司名变更操作-proc_sync_rd_management_info_collect_by_company_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_management_info_collect_by_company_v2(:after.id,:after.name,:after.supervise_depart_id,:after.supervise_region_code)" }, { "uid": "company_tenant_organizations_05", "title": "执行外地总公司名变更操作-proc_sync_rd_subcompany_info_collect_by_company_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_subcompany_info_collect_by_company_v2(:after.id,:after.place_of_business_address,:after.name,:after.place_of_register_province_name,:after.place_of_register_address,:after.place_of_business_province_name,:after.telephone,:after.supervise_depart_id,:after.supervise_region_code)" }, { "uid": "company_tenant_organizations_06", "title": "执行设备公司变更操作-proc_sync_rd_device_info_collect_by_company_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_device_info_collect_by_company_v2(:after.id,:after.name,:after.supervise_depart_name,:after.supervise_depart_id,:after.supervise_region_code)" }, { "uid": "company_tenant_organizations_07", "title": "执行车辆公司变更操作-proc_sync_rd_vehicle_info_collect_by_company_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_vehicle_info_collect_by_company_v2(:after.id,:after.name,:after.supervise_depart_name,:after.supervise_depart_id,:after.supervise_region_code)" }, { "uid": "company_tenant_organizations_08", "title": "执行公司审核状态变更改变入离职记录操作-proc_sync_employed_events_info_collect_by_organization_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_employed_events_info_collect_by_organization_v2(:after.id,:before.name,:after.name,:after.last_updated_time,:before.approved_information_status,:after.approved_information_status,:after.supervise_region_code,:after.supervise_depart_id,:before.supervise_depart_id)" }, { "uid": "company_tenant_organizations_10", "title": "执行驻勤点表公司名及其监管机构变更操作-proc_sync_attendance_site_base_info_by_tenant_organizations", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_attendance_site_base_info_by_tenant_organizations(:after.id,:before.name,:after.name,:before.supervise_depart_name,:after.supervise_depart_name,:before.supervise_depart_id,:after.supervise_depart_id,:before.supervise_region_code,:after.supervise_region_code)" }, { "uid": "company_tenant_organizations_11", "title": "执行保安服务合同公司名及其监管机构变更操作-proc_sync_attendance_site_base_info_by_tenant_organizations", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_contract_to_enterprise_info_by_organization(:after.id,:before.name,:after.name,:before.supervise_depart_name,:after.supervise_depart_name,:before.supervise_depart_id,:after.supervise_depart_id,:before.supervise_region_code,:after.supervise_region_code)" }, { "uid": "company_tenant_organizations_12", "title": "执行保安员合同监管机构名称变更信息更新-proc_sync_employee_contracts_info_collect_by_organization", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_employee_contracts_info_collect_by_organization(:before.id,:after.id,:before.supervise_depart_name,:after.supervise_depart_name,:before.supervise_depart_id,:after.supervise_depart_id,:before.supervise_region_code,:after.supervise_region_code,:before.telephone,:after.telephone)" }, { "uid": "company_tenant_organizations_121", "title": "薪酬管理执行公司名归集操作-proc_sync_rd_company_info_collect_by_organization_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call personnel_oa.proc_sync_rd_company_info_collect_by_organization_v2(:after.id)" }, { "uid": "supervise_tenant_organizations_13", "title": "执行公司监管归属变更其他归集表的操作-proc_sync_company_supervise_update_by_organization", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_company_supervise_update_by_organization(:before.id,:after.id,:before.supervise_region_code,:after.supervise_region_code,:before.supervise_depart_id,:after.supervise_depart_id,:before.approved_information_status,:after.approved_information_status)" } ] }, { "uid": "company_tenant_companies_topic", "topic": "obpm2.binlog-cdc.topic.v2.tenant_companies", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "company_tenant_companies_01", "title": "执行公司信息变更操作-proc_sync_rd_company_info_collect_by_companies", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_company_info_collect_by_companies(:after.id,:organization.approved_information_last_updated_time,:organization.approved_information_note,:organization.approved_information_status,:organization.code,:organization.created_time,:organization.industry_code,:organization.institutional_code,:organization.last_updated_time,:organization.logo_path,:organization.name,:organization.place_of_business_address,:organization.place_of_business_city_code,:organization.place_of_business_city_name,:organization.place_of_business_district_code,:organization.place_of_business_district_name,:organization.place_of_business_province_code,:organization.place_of_business_province_name,:organization.place_of_register_address,:organization.place_of_register_city_code,:organization.place_of_register_city_name,:organization.place_of_register_district_code,:organization.place_of_register_district_name,:organization.place_of_register_province_code,:organization.place_of_register_province_name,:organization.tenant_user_id,:organization.description,:organization.latitude,:organization.longitude,:organization.sys_name,:organization.lon_lat_json,:organization.status,:organization.fax,:organization.telephone,:organization.type,:organization.industry_detail_type,:organization.supervise_region_code,:organization.supervise_depart_id,:organization.supervise_depart_name,:after.unify_social_credit_code,:after.unify_social_credit_code_file,:after.parent_name,:after.parent_certificate_type,:after.parent_certificate_number,:after.parent_legal_person_name,:after.parent_legal_person_telephone,:after.economic_type,:after.nature,:after.service_scope,:after.service_scope_description,:after.registered_capital,:after.fixed_capital,:after.annual_profit_tax,:after.annual_sales_volume,:after.certificate_type,:after.service_permit_number,:after.security_approval_number,:after.name_of_issuing_authority,:after.first_issue_service_permit,:after.service_permit_attachment,:after.train_content,:after.security_preparedness_rating,:after.security_armed_rating,:after.security_safety_defense_rating,:after.is_risk_assessment,:after.number_of_security_guards,:after.is_public_security_security,:after.is_property_enterprise,:after.nature_of_self_recruited_units,:after.legal_person_name,:after.legal_person_telephone,:after.legal_person_credential_type,:after.legal_person_credential_number,:after.legal_person_nationality,:after.security_person_name,:after.security_person_telephone,:after.security_person_credential_type,:after.security_person_credential_number)" }, { "uid": "company_tenant_companies_02", "title": "执行总公司变更操作-proc_sync_rd_subcompany_info_collect_by_companytel", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_subcompany_info_collect_by_companytel(:after.id,:after.legal_person_name)" } ] }, { "uid": "company_tenant_departments_topic", "topic": "obpm2.binlog-cdc.topic.v2.tenant_departments", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "company_tenant_departments_01", "title": "执行部门名称变更操作-proc_sync_rd_employee_info_collect_by_department_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_employee_info_collect_by_department_v2(:after.id,:after.name,:after.last_updated_time)", "conditionExpress": "#{after.name}!=#{before.name}" } ] }, { "uid": "company_tlk_subcompanyinformation_topic", "topic": "baibaodunflow.binlog-cdc.topic.v2.tlk_subcompanyinformation", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "company_tlk_subcompanyinformation_01", "title": "执行分子公司变更操作-proc_sync_rd_subcompany_info_collect_by_subcompany_v2", "refJdbcName": "industryInfoCollection-jdbc", "type": "JDBC", "content": "call companyinfocollect.proc_sync_rd_subcompany_info_collect_by_subcompany_v2(:after.id,:organization.after.supervise_region_code,:organization.after.place_of_business_address,:organization.after.name,:organization.after.place_of_register_province_name,:organization.after.place_of_register_address,:organization.after.place_of_business_province_name,:organization.after.telephone,:organization.supervise_depart_id)" } ] } ] }