{
  "title": "归集行业信息-优化配置-证件详情相关信息变更",
  "groupId": "cdc-gathering-reader-db-user-credential-details-122",
  "batchSize": 500,
  "batchIntervalMs": 2000,
  "kafkaConnections": [
    {
      "name": "kafka-collection",
      "bootstrapServer": "117.78.39.204:9092"
    }
  ],
  "jdbcConnections": [
    {
      "name": "industryInfoCollection-jdbc",
      "url": "jdbc:mysql://49.4.21.141:45611/companyinfocollect?characterEncoding=UTF-8&connectionTimeZone=GMT&allowMultiQueries=true&autoReconnect=true",
      "userName": "bcx",
      "password": "Wstestv5qy#2022",
      "driverClassName": "com.mysql.cj.jdbc.Driver"
    }
  ],
  "topicSubscribers": [
    {
      "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)"
        }
      ]
    }
  ]
}