{
  "param1": 
  {"job.name":"简化版本-CheckPoint-实时归集-企业-信息-3.0",
  "checkpoint.mode":"file",
  "checkpoint.hdfs.config":"core-site-default.xml",
  "checkpoint.disk.location":"/tmp/cp-table-task-company-information-collect"
  },
  "param2": {
    "name":"实时归集企业信息",
    "jdbcMeta": {
      "url": "jdbc:mysql://49.4.21.141:3306/companyinfocollect?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8&allowMultiQueries=true&autoReconnect=true",
      "userName": "TL5_enterprise",
      "password": "Bcx#20221024",
      "sqlMetaDefinitions": [
        {
          "tableName": "tlk_companyinfoquery",
          "sql": "create table jdbc_insert_rd_company_info_query_summary(ID STRING,ITEM_company_name STRING, ITEM_company_status INT,ITEM_economic_type INT,ITEM_company_type INT,ITEM_register_address STRING, ITEM_office_address STRING,ITEM_is_sub INT,item_supervise_district STRING,item_supervise_office STRING,item_legal_person STRING,item_document_type INT,item_document_id STRING,ITEM_register_doc_type INT,item_register_id STRING,item_office_type STRING, PRIMARY KEY (ID) NOT ENFORCED)"
        }
      ]
    },
    "kafkaMeta": {
      "autoOffsetRest": "earliest",
      "scanStartupMode": "earliest-offset",
      "enableAutoCommit": "true",
      "bootstrapServer": "117.78.39.204:9092",
      "topicDefinitions": [
        {
          "topic": "baibaodunflow.binlog-cdc.topic.tlk_companyinformation",
          "sql": "create table kafka_company_information(ID STRING,FORMID STRING,ITEM_domain_id STRING,ITEM_companyName STRING,ITEM_companyStatus STRING,ITEM_economicType INT,ITEM_companyType INT, ITEM_registerAddress STRING, ITEM_officeAddress STRING,ITEM_isSub INT, ITEM_legalPerson STRING,ITEM_documentType INT,ITEM_documentID STRING, ITEM_registerDocumentType STRING, ITEM_registerID STRING, ITEM_officeType STRING, PRIMARY KEY (ID) NOT ENFORCED)"
        },
        {
          "topic": "baibaodunflow.binlog-cdc.topic.tlk_setsupervise",
          "sql": "create table kafka_set_supervise(ID STRING,ITEM_DOMAIN_ID STRING,ITEM_OFFICEADDRESS STRING, ITEM_OFFICEADDRESSID STRING, ITEM_OFFICEPOLICEADDRESS STRING,ITEM_OFFICEPOLICEADDRESSID STRING,ITEM_OFFICEPOLICEIDINDEX STRING, PRIMARY KEY (ID) NOT ENFORCED)"
        }
      ]
    },
    "executeSql": [
      "INSERT INTO jdbc_insert_rd_company_info_query_summary (ID,ITEM_company_name,ITEM_company_status,ITEM_economic_type,ITEM_company_type,ITEM_register_address,ITEM_office_address,ITEM_is_sub,item_legal_person,item_document_type,item_document_id,ITEM_register_doc_type,item_register_id,item_office_type,item_supervise_district,item_supervise_office ) SELECT REPLACE( c.ID, c.FORMID, '__2eoK1zvtxNarHlwwQg4' ),c.ITEM_companyName,( CASE c.ITEM_companyStatus WHEN '正常' THEN 1 WHEN '注销' THEN 2 WHEN '撤销' THEN 3 WHEN '吊销' THEN 4 else 1 END ) as cmp_status,c.ITEM_economicType,c.ITEM_companyType,c.ITEM_registerAddress,c.ITEM_officeAddress,c.ITEM_isSub,c.ITEM_legalPerson,c.ITEM_documentType,c.ITEM_documentID,1,c.ITEM_registerID,c.ITEM_officeType,ifnull(s.ITEM_OFFICEADDRESS,''),ifnull(s.ITEM_OFFICEPOLICEADDRESS,'') FROM kafka_company_information c JOIN kafka_set_supervise s ON c.ITEM_domain_id = s.ITEM_DOMAIN_ID"
    ]
  }
  }