{ "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&connectionTimeZone=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_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_main_o", "topic": "obpm2.binlog-cdc.topic.v2.tenant_users", "refKafkaName": "kafka-collection", "subscriberContents": [ { "uid": "user_tenant_users_topic_s_01", "title": "执行员工信息变更操作v0529-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_topic_s_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_topic_s_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_topic_s_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_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)" } ] } ] }