INSERT INTO `obpm2`.`flink_jobs`(`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES (200, 'CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_organizations-rd_company_summary', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-组织tenant_organizations信息到调度Jdbc汇集数据库-3.0.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_organizations-rd_company_summary\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call dispatch.proc_sync_rd_company_summary_by_company(:after.id)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_organizations-rd_company_summary\\\",\\\"bootstrapServer\\\":\\\"192.168.0.52:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_organizations-rd_company_summary\\\",\\\"topic\\\":\\\"obpm2.binlog-cdc.topic.data.tenant_organizations\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_organizations-rd_company_summary\\\",\\\"description\\\":\\\"简化版本-CheckPoint-组织tenant_organizations信息到调度Jdbc汇集数据库-3.0.\\\",\\\"id\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_organizations-rd_company_summary\\\"}\"}', '简化版本-CheckPoint-组织tenant_organizations信息到调度Jdbc汇集数据库-3.0.', 1, '2023-04-26 17:00:16', '2023-04-26 17:00:15', NULL, NULL, NULL, '简化版本-CheckPoint-组织tenant_organizations信息到调度Jdbc汇集数据库-3.0.', 0);
INSERT INTO `obpm2`.`flink_jobs`(`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES (201, 'CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation-rd_company_summary', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-企业tlk_companyinformation信息到调度Jdbc汇集数据库-3.0.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation-rd_company_summary\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call dispatch.proc_sync_rd_company_summary_by_company(:after.DOMAINID)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation-rd_company_summary\\\",\\\"bootstrapServer\\\":\\\"192.168.0.52:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation-rd_company_summary\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation-rd_company_summary\\\",\\\"description\\\":\\\"简化版本-CheckPoint-企业tlk_companyinformation信息到调度Jdbc汇集数据库-3.0.\\\",\\\"id\\\":\\\"CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation-rd_company_summary\\\"}\"}', '简化版本-CheckPoint-企业tlk_companyinformation信息到调度Jdbc汇集数据库-3.0.', 1, '2023-04-26 17:00:24', '2023-04-26 17:00:24', NULL, NULL, NULL, '简化版本-CheckPoint-企业tlk_companyinformation信息到调度Jdbc汇集数据库-3.0.', 0);
INSERT INTO `obpm2`.`flink_jobs`(`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES (202, 'CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_employees-rd_employee_summary', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集员工tenant_employees到调度指挥人员-3.0.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_employees-rd_employee_summary\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call dispatch.proc_sync_rd_employee_summary_by_employee(:after.id)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_employees-rd_employee_summary\\\",\\\"bootstrapServer\\\":\\\"192.168.0.52:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_employees-rd_employee_summary\\\",\\\"topic\\\":\\\"obpm2.binlog-cdc.topic.data.tenant_employees\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_employees-rd_employee_summary\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集员工tenant_employees到调度指挥人员-3.0.\\\",\\\"id\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_employees-rd_employee_summary\\\"}\"}', '简化版本-CheckPoint-归集员工tenant_employees到调度指挥人员-3.0.', 1, '2023-04-26 17:00:29', '2023-04-26 17:00:29', NULL, NULL, NULL, '简化版本-CheckPoint-归集员工tenant_employees到调度指挥人员-3.0.', 0);
INSERT INTO `obpm2`.`flink_jobs`(`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES (203, 'CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_users-rd_employee_summary', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集人员tenant_users到调度指挥人员-3.0.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_users-rd_employee_summary\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call dispatch.proc_sync_rd_employee_summary_by_tenant_user(:after.id)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_users-rd_employee_summary\\\",\\\"bootstrapServer\\\":\\\"192.168.0.52:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_users-rd_employee_summary\\\",\\\"topic\\\":\\\"obpm2.binlog-cdc.topic.data.tenant_users\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_users-rd_employee_summary\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集人员tenant_users到调度指挥人员-3.0.\\\",\\\"id\\\":\\\"CheckPoint2-consume-obpm2.binlog-cdc.topic.data.tenant_users-rd_employee_summary\\\"}\"}', '简化版本-CheckPoint-归集人员tenant_users到调度指挥人员-3.0.', 1, '2023-04-26 17:00:34', '2023-04-26 17:00:34', NULL, NULL, NULL, '简化版本-CheckPoint-归集人员tenant_users到调度指挥人员-3.0.', 0);
INSERT INTO `obpm2`.`flink_jobs`(`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES (204, 'CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info-rd_security_station_summary', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点tlk_attendance_site_base_info到调度指挥驻勤-3.0.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info-rd_security_station_summary\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call dispatch.proc_sync_rd_security_station_summary_by_station(:after.id)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info-rd_security_station_summary\\\",\\\"bootstrapServer\\\":\\\"192.168.0.52:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info-rd_security_station_summary\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info-rd_security_station_summary\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点tlk_attendance_site_base_info到调度指挥驻勤-3.0.\\\",\\\"id\\\":\\\"CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info-rd_security_station_summary\\\"}\"}', '简化版本-CheckPoint-归集驻勤点tlk_attendance_site_base_info到调度指挥驻勤-3.0.', 1, '2023-04-26 17:00:40', '2023-04-26 17:00:40', NULL, NULL, NULL, '简化版本-CheckPoint-归集驻勤点tlk_attendance_site_base_info到调度指挥驻勤-3.0.', 0);


INSERT INTO `obpm2`.`flink_jobs` (`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES ('367', '捕获dispatch.rdemployee-company-station-tenance-room to kafka', '0', '{\n  \"param1\": \"{\\\"job.name\\\":\\\"捕获dispatch.rdemployee-company-station-tenance-room to kafka\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cdc-binlog-multiple-partition\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"kafka.bootstrap.server\\\":\\\"192.168.0.52:9092\\\",\\\"kafka.cdc.topic.prefix\\\":\\\"[dbName].binlog-cdc.topic.data.[tableName]\\\",\\\"kafka.consumer.group.id\\\":\\\"cdc-binlog-kafka-dispatch-events\\\"}\",\n  \"param2\": \"{\\\"source.name\\\":\\\"mysql-cdc-flink-source\\\",\\\"source.database.host\\\":\\\"192.168.0.7\\\",\\\"source.database.port\\\":\\\"3368\\\",\\\"source.database.username\\\":\\\"v5_binlog\\\",\\\"source.database.password\\\":\\\"Bcxin#6576Log\\\",\\\"source.database.serverTimeZone\\\":\\\"GMT+8\\\",\\\"source.database.serverId\\\":\\\"6001-6200\\\",\\\"source.database.connectTimeout\\\":\\\"60000\\\",\\\"source.database.db.list\\\":\\\"dispatch;\\\",\\\"source.database.table.list\\\":\\\"dispatch.tencent_close_room_events;dispatch.rd_company_summary;dispatch.rd_employee_summary;dispatch.rd_security_station_summary;dispatch.tlk_org_purse_transaction;\\\"}\"\n}', '捕获dispatch.rdemployee-company-station-tenance-room to kafka', '1', '2023-04-27 14:29:24', '2023-03-05 20:21:59', NULL, NULL, NULL, '同步调度指挥功能', '0');

INSERT INTO `obpm2`.`flink_jobs` (
    `id`,
    `name`,
    `job_type`,
    `parameter_json`,
    `description`,
    `is_online`,
    `last_updated_time`,
    `created_time`,
    `flink_job_id`,
    `flink_job_started_time`,
    `flink_job_started_response`,
    `title`,
    `is_deleted`
)
VALUES
    (
        '268',
        '捕获obpm.users-employees-stations-company-organization-person-to-dispatch',
        '0',
        '{\n  \"param1\": \"{\\\"job.name\\\":\\\"捕获obpm.tenant_users-tenant-employees-baibaodunflow-tlkcompanyinformation及驻勤信息到kafka\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cdc-v2-obpm2-baibaodunflow\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"kafka.bootstrap.server\\\":\\\"117.78.39.204:9092\\\",\\\"kafka.cdc.topic.prefix\\\":\\\"[dbName].binlog-cdc.topic.data.[tableName]\\\",\\\"kafka.consumer.group.id\\\":\\\"binlog-cdc-dispatch-flink-platform-events\\\"}\",\n  \"param2\": \"{\\\"source.name\\\":\\\"mysql-cdc-flink-source\\\",\\\"source.database.host\\\":\\\"192.168.0.7\\\",\\\"source.database.port\\\":\\\"3368\\\",\\\"source.database.username\\\":\\\"v5_binlog\\\",\\\"source.database.password\\\":\\\"Bcxin#6576Log\\\",\\\"source.database.serverTimeZone\\\":\\\"GMT+8\\\",\\\"source.database.serverId\\\":\\\"5400-6400\\\",\\\"source.database.connectTimeout\\\":\\\"60000\\\",\\\"source.database.db.list\\\":\\\"obpm2;baibaodunflow;dispatch;\\\",\\\"source.database.table.list\\\":\\\"obpm2.tenant_users;obpm2.tenant_employees;obpm2.tenant_organizations;baibaodunflow.TLK_COMPANYINFORMATION;baibaodunflow.TLK_ATTENDANCE_SITE_BASE_INFO;baibaodunflow.tlk_attendance_site_person_info;\\\"}\"\n}',
        'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka',
        '1',
        '2023-04-27 17:14:13',
        '2023-03-05 20:21:59',
        NULL,
        NULL,
        NULL,
        'CDC 直接到Dispatch',
        '0'
    );



#调度指挥调度订阅数据
INSERT INTO `obpm2`.`flink_jobs`(`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES (370, 'cdc-obpm2-baibaodunflow-v2-dispatch-370', 0, '{\n  \"param1\": \"{\\\"job.name\\\":\\\"捕获cdc-obpm2-baibaodunflow-v2-调度指挥关注-370\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cdc-v2-obpm2-baibaodunflow-dispatch-test\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"kafka.bootstrap.server\\\":\\\"117.78.39.204:9092\\\",\\\"kafka.cdc.topic.prefix\\\":\\\"[dbName].binlog-cdc.topic.v2.[tableName]\\\",\\\"kafka.consumer.group.id\\\":\\\"binlog-cdc-v2-flink-platform-dispatch-events\\\"}\",\n  \"param2\": \"{\\\"source.name\\\":\\\"mysql-cdc-flink-source\\\",\\\"source.database.host\\\":\\\"220.243.148.23\\\",\\\"source.database.port\\\":\\\"2111\\\",\\\"source.database.username\\\":\\\"bcx\\\",\\\"source.database.password\\\":\\\"Wstestv5qy#2022\\\",\\\"source.database.serverTimeZone\\\":\\\"GMT+8\\\",\\\"source.database.serverId\\\":\\\"3000-3800\\\",\\\"source.database.connectTimeout\\\":\\\"60000\\\",\\\"source.database.db.list\\\":\\\"obpm2;baibaodunflow;dispatch;organizationauth;\\\",\\\"source.database.table.list\\\":\\\"obpm2.tenant_users;obpm2.tenant_employees;obpm2.tenant_organizations;baibaodunflow.TLK_ATTENDANCE_SITE_BASE_INFO;baibaodunflow.tlk_companyinformation;baibaodunflow.tlk_attendance_site_person_info;dispatch.tenant_employee_attendance_records;dispatch.tenant_employee_attendance_records;dispatch.tencent_close_room_events;dispatch.police_incidents;\\\"}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-05-31 13:13:40', '2023-03-05 20:21:59', NULL, NULL, NULL, '行业信息数据归集-DEV环境', 0);
