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 (67, '捕获obpm.tenant_users-tenant-employees-baibaodunflow-tlkcompanyinformation及驻勤信息 kafka', 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-v2-mu-p-flink-platform-events\\\"}\",\n  \"param2\": \"{\\\"source.name\\\":\\\"mysql-cdc-flink-source\\\",\\\"source.database.host\\\":\\\"49.4.21.141\\\",\\\"source.database.port\\\":\\\"2111\\\",\\\"source.database.username\\\":\\\"bcx\\\",\\\"source.database.password\\\":\\\"Wstestv5qy#2022\\\",\\\"source.database.connectionTimeZone\\\":\\\"GMT+8\\\",\\\"source.database.serverId\\\":\\\"5400-6400\\\",\\\"source.database.connectTimeout\\\":\\\"60000\\\",\\\"source.database.db.list\\\":\\\"obpm2;baibaodunflow;dispatch;organizationauth;\\\",\\\"source.database.table.list\\\":\\\"obpm2.tenant_users;obpm2.tenant_user_credentials;obpm2.tenant_employees;obpm2.tenant_organizations;obpm2.tenant_departments;baibaodunflow.TLK_COMPANYINFORMATION;baibaodunflow.TLK_ATTENDANCE_SITE_BASE_INFO;baibaodunflow.tlk_attendance_site_person_info;baibaodunflow.tlk_attendance_site_person_info;organizationauth.tlk_DepartmentLevel;baibaodunflow.tlk_SetSupervise;dispatch.tlk_device_binded_log;dispatch.tencent_close_room_events;dispatch.rd_company_summary;dispatch.rd_employee_summary;dispatch.rd_security_station_summary;dispatch.tlk_org_purse_transaction;dispatch.tlk_org_purse;dispatch.rd_security_station_person_summary;dispatch.tlk_device_comminicated_log;dispatch.tlk_device_comminicated_logs_detail;\\\"}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-26 17:59:12', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 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 (69, '1捕获obpm.tenant_users-tenant-employees-baibaodunflow-tlkcompanyinformation及驻勤信息 kafka', 0, '{\n  \"param1\": \"{\\\"job.name\\\":\\\"捕获obpm.tenant_users-tenant-employees-baibaodunflow-tlkcompanyinformation及驻勤信息到kafka\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cdc-v6-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.single-partition.[tableName]\\\",\\\"kafka.consumer.group.id\\\":\\\"binlog-cdc-v2-flink-platform-events\\\"}\",\n  \"param2\": \"{\\\"source.name\\\":\\\"mysql-cdc-flink-source\\\",\\\"source.database.host\\\":\\\"49.4.21.141\\\",\\\"source.database.port\\\":\\\"2111\\\",\\\"source.database.username\\\":\\\"bcx\\\",\\\"source.database.password\\\":\\\"Wstestv5qy#2022\\\",\\\"source.database.connectionTimeZone\\\":\\\"GMT+8\\\",\\\"source.database.serverId\\\":\\\"5400-6400\\\",\\\"source.database.connectTimeout\\\":\\\"60000\\\",\\\"source.database.db.list\\\":\\\"obpm2;baibaodunflow;dispatch;organizationauth;\\\",\\\"source.database.table.list\\\":\\\"obpm2.tenant_users;\\\"}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-25 10:44:25', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 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 (72, 'cp-consume-tlkcompany-tenant-users-employees-data-72-2023-03-08T09:03:34.204Z', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集人员,职员,企业信息到调度平台-3.0\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cp-consume-tlkcompany-tenant-users-employees-data\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_rd_company_summary存储过程: 归集企业信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call proc_rd_company_summary(:after.DOMAINID,:before.ITEM_companyName,:after.ITEM_companyName,:after.ITEM_legalPerson,:after.ITEM_registerAddress,:after.ITEM_registerAddressDetail,:after.ITEM_officeAddress,:after.ITEM_officeAddressDetail,:after.ITEM_businessScope,:after.ITEM_companyStatus,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_companyinformation\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_rd_employee_summary存储过程: 归集职员人员信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call proc_rd_employee_summary(:after.id,:after.tenant_user_id,:after.status,:after.occupation_type,:after.hired_date,:after.leave_date,:after.organization_id,:after.last_sync_time)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"topic\\\":\\\"obpm2.binlog-cdc.topic.data.tenant_employees\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_refresh_tenant_user存储过程: 更新人的信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call proc_refresh_tenant_user(:after.id)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"topic\\\":\\\"obpm2.binlog-cdc.topic.data.tenant_users\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集人员,职员,企业信息到调度平台-3.0.\\\",\\\"id\\\":\\\"cp-consume-tlkcompany-tenant-users-employees-data\\\"}\"}', '简化版本-CheckPoint-归集人员,职员,企业信息到调度平台-3.0.', 1, '2023-03-08 17:06:38', '2023-03-05 20:45:54', NULL, NULL, NULL, 'dddd', 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 (73, 'CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables-73-2023-03-08T09:04:03.462Z', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_rd_employee_summary存储过程: 归集驻勤信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"name\\\":\\\"执行proc_rd_security_service_station_relation_employee_summary存储过程: 归集驻勤人员信息\\\",\\\"url\\\":\\\"jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\\\",\\\"username\\\":\\\"bcx\\\",\\\"password\\\":\\\"Wstestv5qy#2022\\\",\\\"connectionTimeZone\\\":\\\"GMT-8\\\",\\\"driver\\\":\\\"com.mysql.cj.jdbc.Driver\\\",\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-08 17:06:40', '2023-03-05 20:46:07', NULL, NULL, NULL, 'aaaaa', 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 (74, 'CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136000,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136000,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data tables\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-08 17:01:03', '2023-03-06 18:03:48', NULL, NULL, NULL, 'dddd', 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 (76, 'CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-08 17:01:02', '2023-03-06 18:06:11', NULL, NULL, NULL, 'cccc', 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 (78, 'CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3-78-2023-03-09T06:18:38.681Z', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_3\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-09 14:18:39', '2023-03-07 09:49:24', NULL, NULL, NULL, 'xxxxxx', 1);
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 (79, 'CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5', 1, '{\"param1\":\"{\\\"job.name\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\"}\",\"param2\":\"{\\\"kafka2JdbcDefinitions\\\":[{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}},{\\\"jdbcDefinitions\\\":[{\\\"jdbcId\\\":1632676329051136002,\\\"sqlTemplate\\\":\\\"call securityflow.proc_rd_security_service_station_relation_employee_summary(:after.ID,:after.ITEM_SECURITYID,:after.ITEM_PHONE,:after.ITEM_DEPTNAME,:after.ITEM_ATTENDANCESITEID,:after.DOMAINID,:after.LASTMODIFIED)\\\"}],\\\"kafkaDefinition\\\":{\\\"consumerGroupId\\\":\\\"consume-kafka:CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.data.tlk_attendance_site_person_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\",\\\"description\\\":\\\"简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.\\\",\\\"id\\\":\\\"CheckPoint2-consume-tlk_attendance_site_base_info-tlk_attendance_site_person_info-summary-data2 tables_5\\\"}\"}', '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 1, '2023-03-07 18:02:40', '2023-03-07 18:02:40', NULL, NULL, NULL, '简化版本-CheckPoint-归集驻勤点及驻勤人员到调度Jdbc汇集数据库-2.8.', 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 (189, 'WebHookAPI演示-企业-驻勤-驻勤人员', 2, '{\n  \"param1\": \"{\\\"job.name\\\":\\\"简化版本-CheckPoint-更新企业和驻勤点-驻勤人员信息-3.0\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cp-webhook-company-station-person\\\"}\",\n  \"param2\": \"{\\n  \\\"name\\\": \\\"WebHookAPI演示-企业-驻勤-驻勤人员\\\",\\n  \\\"topicDefinition\\\": {\\n    \\\"name\\\": \\\"cp-dispatch\\\",\\n    \\\"topic\\\": \\\"\\\",\\n    \\\"consumerGroupId\\\": \\\"dispatch.webhook.api\\\",\\n    \\\"enableAutoCommit\\\": true,\\n    \\\"scanStartupMode\\\": \\\"group-offsets\\\",\\n    \\\"primaryKeyName\\\": \\\"ID\\\",\\n    \\\"autoOffsetRest\\\": \\\"earliest\\\",\\n    \\\"bootstrapServer\\\": \\\"117.78.39.204:9092\\\"\\n  },\\n  \\\"webHookConfigs\\\": [\\n    {\\n      \\\"title\\\": \\\"同步企业信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.data.rd_company_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/flush/request\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"contents\\\\\\\":[{\\\\\\\"ids\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"],\\\\\\\"dataType\\\\\\\":\\\\\\\"Company\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    },\\n    {\\n      \\\"title\\\": \\\"同步驻勤点信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_security_station_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/flush/request\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"contents\\\\\\\":[{\\\\\\\"ids\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"],\\\\\\\"dataType\\\\\\\":\\\\\\\"Station\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    },\\n    {\\n      \\\"title\\\": \\\"同步驻勤人员信息\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_security_station_person_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/flush/request\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"contents\\\\\\\":[{\\\\\\\"stationPersonRequest\\\\\\\":{\\\\n          \\\\\\\"stationIds\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"],\\\\\\\"employeeIds\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"]\\\\n        },\\\\\\\"dataType\\\\\\\":\\\\\\\"Station\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    }\\n  ]\\n}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-26 19:07:52', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 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 (190, 'WebHookAPI演示-保安人员', 2, '{\n  \"param1\": \"{\\\"job.name\\\":\\\"简化版本-CheckPoint-更新保安人员-3.0\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cp-webhook-employee\\\"}\",\n  \"param2\": \"{\\n  \\\"name\\\": \\\"WebHookAPI演示-保安人员\\\",\\n  \\\"topicDefinition\\\": {\\n    \\\"name\\\": \\\"cp-dispatch\\\",\\n    \\\"topic\\\": \\\"\\\",\\n    \\\"consumerGroupId\\\": \\\"dispatch.webhook.api\\\",\\n    \\\"enableAutoCommit\\\": true,\\n    \\\"scanStartupMode\\\": \\\"group-offsets\\\",\\n    \\\"primaryKeyName\\\": \\\"ID\\\",\\n    \\\"autoOffsetRest\\\": \\\"earliest\\\",\\n    \\\"bootstrapServer\\\": \\\"117.78.39.204:9092\\\"\\n  },\\n  \\\"webHookConfigs\\\": [\\n    {\\n      \\\"title\\\": \\\"同步职员信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.data.rd_employee_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/flush/request\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"contents\\\\\\\":[{\\\\\\\"ids\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"],\\\\\\\"dataType\\\\\\\":\\\\\\\"Employee\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    }\\n  ]\\n}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-26 18:39:27', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 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 (191, 'WebHookAPI演示-联动值-通讯日志', 2, '{\n  \"param1\": \"{\\\"job.name\\\":\\\"简化版本-CheckPoint-计算联动值-3.0\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cp-webhook-purse-points-logs\\\"}\",\n  \"param2\": \"{\\n  \\\"name\\\": \\\"WebHookAPI演示-联动值-通讯日志\\\",\\n  \\\"topicDefinition\\\": {\\n    \\\"name\\\": \\\"cp-dispatch\\\",\\n    \\\"topic\\\": \\\"\\\",\\n    \\\"consumerGroupId\\\": \\\"dispatch.webhook.api\\\",\\n    \\\"enableAutoCommit\\\": true,\\n    \\\"scanStartupMode\\\": \\\"group-offsets\\\",\\n    \\\"primaryKeyName\\\": \\\"ID\\\",\\n    \\\"autoOffsetRest\\\": \\\"earliest\\\",\\n    \\\"bootstrapServer\\\": \\\"117.78.39.204:9092\\\"\\n  },\\n  \\\"webHookConfigs\\\": [\\n    {\\n      \\\"title\\\": \\\"实时计算通讯日志及联动值\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.data.tencent_close_room_events\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/tencent/callback/calculate\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"ids\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    }\\n  ]\\n}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-26 19:09:08', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 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 (193, 'TableTask-实时归集企业-驻勤-驻勤人员-人员信息', 2, '{\r\n  \"param1\": \"{\\\"job.name\\\":\\\"简化版本-CheckPoint-实时归集企业-驻勤-驻勤人员-人员信息-3.0\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cp-table-task-company-station-person-employee\\\"}\",\r\n  \"param2\": \"{\\n  \\\"name\\\": \\\"实时归集企业-驻勤-驻勤人员-人员信息\\\",\\n  \\\"jdbcMeta\\\": {\\n    \\\"url\\\": \\\"jdbc:mysql://49.4.21.141:45611/dispatch?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8&allowMultiQueries=true&autoReconnect=true\\\",\\n    \\\"userName\\\": \\\"bcx\\\",\\n    \\\"password\\\": \\\"Wstestv5qy#2022\\\",\\n    \\\"sqlMetaDefinitions\\\": [\\n      {\\n        \\\"tableName\\\": \\\"rd_company_summary\\\",\\n        \\\"sql\\\": \\\"create table jdbc_insert_rd_company_summary(id STRING,status INT, name STRING,legal STRING,legal_telephone STRING,institutional STRING,register_address STRING,business_address STRING,service_scope STRING,lon_lat STRING,organization_id STRING,supervise_domain_id STRING,supervise_depart_id STRING, last_sync_time TIMESTAMP(3),last_updated_time TIMESTAMP(3),supervise_region_code STRING,PRIMARY KEY (id) NOT ENFORCED)\\\"\\n      },\\n      {\\n        \\\"tableName\\\": \\\"rd_security_station_summary\\\",\\n        \\\"sql\\\": \\\"create table jdbc_insert_rd_security_station_summary(id STRING,name STRING,station_type STRING,company_name STRING,principal_id STRING,principal_name STRING,principal_contact STRING,service_scope STRING,address STRING,lon_lat STRING,organization_id STRING,supervise_domain_id STRING,supervise_depart_id STRING, last_sync_time TIMESTAMP(3),last_updated_time TIMESTAMP(3),site_state STRING,begin_date TIMESTAMP(3),end_date TIMESTAMP(3),supervise_region_code STRING,PRIMARY KEY (id) NOT ENFORCED)\\\"\\n      },\\n      {\\n        \\\"tableName\\\": \\\"rd_employee_summary\\\",\\n        \\\"sql\\\": \\\"create table jdbc_insert_rd_employee_summary(id STRING,name STRING,head_photo STRING,contact STRING, company_name STRING,status INT,checked_status INT,authenticated_status INT,military_status STRING,security_certificate_no STRING,occupation_type INT,hired_date TIMESTAMP(3),leave_time TIMESTAMP(3),insure INT,organization_id STRING,tenant_user_id STRING,tenant_employee_id STRING,last_sync_time TIMESTAMP(3),last_updated_time TIMESTAMP(3),device_number STRING,tenant_im_user_id STRING,idCard_no STRING,cid STRING,PRIMARY KEY (id) NOT ENFORCED) \\\"\\n      },\\n      {\\n        \\\"tableName\\\": \\\"rd_security_station_person_summary\\\",\\n        \\\"sql\\\": \\\"create table jdbc_insert_rd_security_station_person_summary(id STRING,employee_id STRING,security_station_id STRING,PRIMARY KEY (id) NOT ENFORCED)\\\"\\n      }\\n    ]\\n  },\\n  \\\"kafkaMeta\\\": {\\n    \\\"autoOffsetRest\\\": \\\"earliest\\\",\\n    \\\"scanStartupMode\\\": \\\"earliest-offset\\\",\\n    \\\"enableAutoCommit\\\": \\\"true\\\",\\n    \\\"bootstrapServer\\\": \\\"117.78.39.204:9092\\\",\\n    \\\"topicDefinitions\\\": [\\n      {\\n        \\\"topic\\\": \\\"obpm2.binlog-cdc.topic.tenant_organizations\\\",\\n        \\\"sql\\\": \\\"create table kafka_tenant_organizations(id STRING,name STRING,industry_code STRING,institutional_code STRING,place_of_business_address STRING,place_of_register_address STRING,latitude STRING,longitude STRING,PRIMARY KEY (id) NOT ENFORCED) \\\"\\n      },\\n      {\\n        \\\"topic\\\": \\\"obpm2.binlog-cdc.topic.tenant_user_credentials\\\",\\n        \\\"sql\\\": \\\"create table kafka_tenant_user_credentials(id STRING,created_time BIGINT,address STRING,credential_type INT,front_photo STRING,head_photo STRING,name STRING,number STRING,reverse_photo STRING,selected INT,valid_date_from BIGINT,valid_date_to BIGINT,tenant_user_id STRING,mark STRING,district_code STRING,city_code STRING,province_code STRING, PRIMARY KEY (id) NOT ENFORCED)  \\\"\\n      },\\n      {\\n        \\\"topic\\\": \\\"obpm2.binlog-cdc.topic.tenant_users\\\",\\n        \\\"sql\\\": \\\"create table kafka_tenant_users(id STRING,authenticated_status INT,authenticated_result STRING,authenticated_time BIGINT,checked_status INT,third_party_loginNo STRING,created_time BIGINT ,email STRING,habit_setting STRING,head_photo STRING,im_identity STRING,lon_lat_json STRING,name STRING,sex INT,stature STRING,telephone STRING,user_type INT,selected_credential_id STRING,household_type STRING,one_inch_color_white_photo STRING,two_inch_color_blue_photo STRING,education STRING,marital_status STRING,military_status STRING,nation STRING,native_place STRING,politics_status STRING,cid STRING,wechat STRING,wechat_nicky STRING,last_updated_time BIGINT,background_screening_status INT,last_background_screening_time BIGINT,emergency_contact STRING,emergency_phone STRING,license_level STRING,place_of_now_address STRING,place_of_now_city_code STRING,place_of_now_city_name STRING,place_of_now_district_code STRING,place_of_now_district_name STRING,place_of_now_province_code STRING,place_of_now_province_name STRING,third_party_login_no STRING,last_sync_time BIGINT, PRIMARY KEY (id) NOT ENFORCED)  \\\"\\n      },\\n      {\\n        \\\"topic\\\": \\\"obpm2.binlog-cdc.topic.tenant_employees\\\",\\n        \\\"sql\\\": \\\"create table kafka_tenant_employees(id STRING,created_time BIGINT,email STRING,hired_date BIGINT,job_number STRING,last_updated_time BIGINT,leave_note STRING,leave_operator_created_time BIGINT,leave_operator_id STRING,leave_operator_name STRING,leave_time BIGINT,master_slave_type INT,occupation_type INT,`position` STRING,positive_date BIGINT,salary STRING,salary_bank_number STRING,status INT,work_place STRING,organization_id STRING,superior_id STRING,tenant_user_id STRING,unique_offset STRING,insure INT,is_domain_admin INT,identification STRING,interview STRING,person_status INT,plan_positive_date BIGINT,probation STRING,hired_operator_created_time BIGINT,hired_operator_id STRING,hired_operator_name STRING,last_sync_time BIGINT, PRIMARY KEY (id) NOT ENFORCED)   \\\"\\n      },\\n      {\\n        \\\"topic\\\": \\\"baibaodunflow.binlog-cdc.topic.tlk_companyinformation\\\",\\n        \\\"sql\\\": \\\"create table kafka_tlk_companyinformation(ID STRING,ITEM_companyStatus STRING, DOMAINID STRING, ITEM_legalPerson STRING,ITEM_legalPersonPhone STRING,ITEM_businessScope STRING,LASTMODIFIED BIGINT,PRIMARY KEY (ID) NOT ENFORCED)  \\\"\\n      },\\n      {\\n        \\\"topic\\\": \\\"baibaodunflow.binlog-cdc.topic.tlk_SetSupervise\\\",\\n        \\\"sql\\\": \\\"create table kafka_tlk_SetSupervise(ID STRING,ITEM_REGISTERADDRESS STRING,ITEM_REGISTERADDRESSID STRING,ITEM_REGISTERPOLICEADDRESS STRING,ITEM_OFFICEPOLICEADDRESSID STRING,ITEM_OFFICEPOLICEIDINDEX STRING,ITEM_REGISTERPOLICEADDRESSID STRING,ITEM_REGISTERPOLICEIDINDEX STRING,ITEM_DOMAIN_ID STRING,ITEM_B STRING,ITEM_FLAG INT, PRIMARY KEY (ID) NOT ENFORCED)   \\\"\\n      },\\n      {\\n        \\\"topic\\\": \\\"baibaodunflow.binlog-cdc.topic.tlk_attendance_site_base_info\\\",\\n        \\\"sql\\\": \\\"create table kafka_tlk_attendance_site_base_info(ID STRING,ITEM_OFFICEPOLICEADDRESSID STRING,ITEM_ATTENDANCESITENAME STRING,ITEM_ATTENDANCESITETYPE STRING,DOMAINID STRING,ITEM_PRINCIPAL STRING,ITEM_PRINCIPALNAME STRING,ITEM_PRINCIPALPHONENO STRING,ITEM_SERVEOBJECTNAME STRING,ITEM_ATTENDANCESITEADDRESS STRING,ITEM_ATTENDANCESITEFULLADDRESS STRING, ITEM_ATTENDANCESITELONGITUDE STRING,ITEM_ATTENDANCESITELATITUDE STRING,ITEM_ATTENDANCESTARTDATE BIGINT,ITEM_ATTENDANCEENDDATE BIGINT,ITEM_ATTENDANCESITESTATE STRING, LASTMODIFIED BIGINT,  PRIMARY KEY (ID) NOT ENFORCED) \\\"\\n      },\\n      {\\n        \\\"topic\\\": \\\"baibaodunflow.binlog-cdc.topic.tlk_attendance_site_person_info\\\",\\n        \\\"sql\\\": \\\"create table kafka_tlk_attendance_site_person_info(ID STRING, ITEM_ATTENDANCESITEID STRING,ITEM_SECURITYID STRING,ITEM_SECURITYNAME STRING,PRIMARY KEY (ID) NOT ENFORCED) \\\"\\n      }\\n    ]\\n  },\\n  \\\"executeSql\\\": [\\n    \\\"insert into jdbc_insert_rd_employee_summary(id,name,head_photo,contact, company_name,status,checked_status,authenticated_status,military_status,security_certificate_no,occupation_type,hired_date,leave_time,insure,organization_id,tenant_user_id,tenant_employee_id,last_sync_time,last_updated_time,device_number,tenant_im_user_id,idCard_no,cid)select distinct ee.id,u.`name`,c.head_photo,u.telephone,o.`name` as orgName,ee.`status`,u.checked_status,u.authenticated_status,u.military_status,(select c2.number from kafka_tenant_user_credentials c2 where c2.tenant_user_id=u.id and c2.credential_type=7 limit 1) as securityCredentialNo,ee.occupation_type,IFNULL(TO_TIMESTAMP(FROM_UNIXTIME(ee.hired_date/1000, \'yyyy-MM-dd HH:mm:ss\')),CURRENT_TIMESTAMP) as hired_date,TO_TIMESTAMP(FROM_UNIXTIME(ee.leave_time/1000, \'yyyy-MM-dd HH:mm:ss\')) as leave_time,ifnull(ee.insure,0),ee.organization_id,ee.tenant_user_id,ee.id,TO_TIMESTAMP(FROM_UNIXTIME(ee.last_sync_time/1000, \'yyyy-MM-dd HH:mm:ss\')) as last_sync_time,TO_TIMESTAMP(FROM_UNIXTIME(ee.last_updated_time/1000, \'yyyy-MM-dd HH:mm:ss\')) as last_updated_time,\'\',ifnull(u.im_identity,\'#\'), c.number,u.cid from kafka_tenant_users u  left join kafka_tenant_user_credentials c on u.id=c.tenant_user_id and c.credential_type=0 join kafka_tenant_employees ee on ee.tenant_user_id=u.id join kafka_tenant_organizations o on o.id=ee.organization_id where ee.`status`=0\\\",\\n    \\\"insert into jdbc_insert_rd_company_summary(id,name,status,legal,legal_telephone,institutional,register_address, business_address,service_scope,organization_id,supervise_domain_id,supervise_depart_id,last_sync_time,last_updated_time,supervise_region_code,lon_lat)select o.id,o.`name`,(case when ITEM_companyStatus=\'注销\' then 2 when ITEM_companyStatus=\'撤销\' then 1 else 0 end) as ITEM_companyStatus,ci.ITEM_legalPerson,ci.ITEM_legalPersonPhone,ifnull(o.institutional_code,\'\'),o.place_of_register_address,o.place_of_business_address,ci.ITEM_businessScope,o.id,\'#\',\'#supervise_depart_id\',TO_TIMESTAMP(FROM_UNIXTIME(ci.LASTMODIFIED/1000, \'yyyy-MM-dd HH:mm:ss\')),TO_TIMESTAMP(FROM_UNIXTIME(ci.LASTMODIFIED/1000, \'yyyy-MM-dd HH:mm:ss\')),\'110000\', convert2Point(o.longitude,o.latitude) as lonlat from kafka_tenant_organizations o left join kafka_tlk_companyinformation ci on o.id=ci.DOMAINID\\\",\\n    \\\"insert into jdbc_insert_rd_security_station_summary(id,name,station_type,company_name,principal_id,principal_name, principal_contact,service_scope,address,lon_lat,organization_id,supervise_domain_id,supervise_depart_id,last_sync_time,last_updated_time,site_state,begin_date,end_date,supervise_region_code)select   bi.ID,bi.ITEM_ATTENDANCESITENAME,bi.ITEM_ATTENDANCESITETYPE,o.name,bi.ITEM_PRINCIPAL,bi.ITEM_PRINCIPALNAME,bi.ITEM_PRINCIPALPHONENO,bi.ITEM_SERVEOBJECTNAME,bi.ITEM_ATTENDANCESITEFULLADDRESS,  convert2Point(ITEM_ATTENDANCESITELONGITUDE,ITEM_ATTENDANCESITELATITUDE) as lonlat,  o.id,\'#\',ifnull(bi.ITEM_OFFICEPOLICEADDRESSID,\'#\') as supervise_depart_id,TO_TIMESTAMP(FROM_UNIXTIME(bi.LASTMODIFIED/1000, \'yyyy-MM-dd HH:mm:ss\')),  TO_TIMESTAMP(FROM_UNIXTIME(bi.LASTMODIFIED/1000, \'yyyy-MM-dd HH:mm:ss\')),bi.ITEM_ATTENDANCESITESTATE,TO_TIMESTAMP(FROM_UNIXTIME(bi.ITEM_ATTENDANCESTARTDATE/1000, \'yyyy-MM-dd HH:mm:ss\')),TO_TIMESTAMP(FROM_UNIXTIME(bi.ITEM_ATTENDANCEENDDATE/1000, \'yyyy-MM-dd HH:mm:ss\')),\'110000\' from kafka_tlk_attendance_site_base_info bi  join kafka_tenant_organizations o on o.id=bi.DOMAINID \\\",\\n    \\\"insert into jdbc_insert_rd_security_station_person_summary(id,employee_id,security_station_id)select ID,ITEM_SECURITYID,ITEM_ATTENDANCESITEID from kafka_tlk_attendance_site_person_info \\\"\\n  ]\\n}\"\r\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-24 07:24:55', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 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 (194, '简化版本-CheckPoint-同步企业到子站到调度平台-3.0', 2, '{\n  \"param1\": \"{\\\"job.name\\\":\\\"简化版本-CheckPoint-同步企业到子站到调度平台-3.0\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/zizhan-cp-consume-tlkcompany-tenant-users-employees-data-v2\\\"}\",\n  \"param2\": \"{\\n  \\\"name\\\": \\\"WebHookAPI演示-子站企业-人员-驻勤-驻勤人员\\\",\\n  \\\"topicDefinition\\\": {\\n    \\\"name\\\": \\\"cp-dispatch\\\",\\n    \\\"topic\\\": \\\"\\\",\\n    \\\"consumerGroupId\\\": \\\"dispatch.webhook.api\\\",\\n    \\\"enableAutoCommit\\\": true,\\n    \\\"scanStartupMode\\\": \\\"group-offsets\\\",\\n    \\\"primaryKeyName\\\": \\\"ID\\\",\\n    \\\"autoOffsetRest\\\": \\\"earliest\\\",\\n    \\\"bootstrapServer\\\": \\\"117.78.39.204:9092\\\"\\n  },\\n  \\\"webHookConfigs\\\": [\\n    {\\n      \\\"title\\\": \\\"同步企业信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_company_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/v2/dispatch/sync-slave\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"dataType\\\\\\\":\\\\\\\"RdCompany\\\\\\\",\\\\\\\"content\\\\\\\":\\\\\\\"#{after:json}\\\\\\\"}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    },\\n    {\\n      \\\"title\\\": \\\"同步职员信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_employee_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/v2/dispatch/sync-slave\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"dataType\\\\\\\":\\\\\\\"RdEmployee\\\\\\\",\\\\\\\"content\\\\\\\":\\\\\\\"#{after:json}\\\\\\\"}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    },\\n    {\\n      \\\"title\\\": \\\"同步驻勤点信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_security_station_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/v2/dispatch/sync-slave\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"dataType\\\\\\\":\\\\\\\"RdStation\\\\\\\",\\\\\\\"content\\\\\\\":\\\\\\\"#{after:json}\\\\\\\"}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    },\\n    {\\n      \\\"title\\\": \\\"同步驻勤人员信息\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_security_station_person_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/v2/dispatch/sync-slave\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"dataType\\\\\\\":\\\\\\\"RdStationPerson\\\\\\\",\\\\\\\"content\\\\\\\":\\\\\\\"#{after:json}\\\\\\\"}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    }\\n  ]\\n}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-22 14:50:25', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 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 (195, '捕获rd_employee_summary表的变更', 0, '{\n  \"param1\": \"{\\\"job.name\\\":\\\"捕获rd_employee_summary表的变更\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cdc-dispatch\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"kafka.bootstrap.server\\\":\\\"117.78.39.204:9092\\\",\\\"kafka.cdc.topic.prefix\\\":\\\"[dbName].binlog-partition-cdc.topic.[tableName]\\\",\\\"kafka.consumer.group.id\\\":\\\"binlog-partition-cdc-flink-platform-events\\\"}\",\n  \"param2\": \"{\\\"source.name\\\":\\\"mysql-cdc-flink-source\\\",\\\"source.database.host\\\":\\\"49.4.21.141\\\",\\\"source.database.port\\\":\\\"2111\\\",\\\"source.database.username\\\":\\\"bcx\\\",\\\"source.database.password\\\":\\\"Wstestv5qy#2022\\\",\\\"source.database.connectionTimeZone\\\":\\\"GMT+8\\\",\\\"source.database.serverId\\\":\\\"5400-6400\\\",\\\"source.database.connectTimeout\\\":\\\"60000\\\",\\\"source.database.db.list\\\":\\\"dispatch;\\\",\\\"source.database.table.list\\\":\\\"dispatch.rd_employee_summary;\\\"}\"\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-21 16:37:58', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 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 (199, '简化版本-CheckPoint-实时归集-企业-信息-3.0', 2, '{\n  \"param1\": \n  {\"job.name\":\"简化版本-CheckPoint-实时归集-企业-信息-3.0\",\n  \"checkpoint.mode\":\"file\",\n  \"checkpoint.hdfs.config\":\"core-site-default.xml\",\n  \"checkpoint.disk.location\":\"/tmp/cp-table-task-company-information-collect\"\n  },\n  \"param2\": {\n    \"name\":\"实时归集企业信息\",\n    \"jdbcMeta\": {\n      \"url\": \"jdbc:mysql://49.4.21.141:3306/companyinfocollect?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8&allowMultiQueries=true&autoReconnect=true\",\n      \"userName\": \"TL5_enterprise\",\n      \"password\": \"Bcx#20221024\",\n      \"sqlMetaDefinitions\": [\n        {\n          \"tableName\": \"tlk_companyinfoquery\",\n          \"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)\"\n        }\n      ]\n    },\n    \"kafkaMeta\": {\n      \"autoOffsetRest\": \"earliest\",\n      \"scanStartupMode\": \"earliest-offset\",\n      \"enableAutoCommit\": \"true\",\n      \"bootstrapServer\": \"117.78.39.204:9092\",\n      \"topicDefinitions\": [\n        {\n          \"topic\": \"baibaodunflow.binlog-cdc.topic.tlk_companyinformation\",\n          \"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)\"\n        },\n        {\n          \"topic\": \"baibaodunflow.binlog-cdc.topic.tlk_setsupervise\",\n          \"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)\"\n        }\n      ]\n    },\n    \"executeSql\": [\n      \"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\"\n    ]\n  }\n  }', '实时归集-企业-信息', 1, '2023-04-20 22:54:04', '2023-04-20 19:01:39', 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 (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\\\":\\\"117.78.39.204: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\\\":\\\"117.78.39.204: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\\\":\\\"117.78.39.204: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\\\":\\\"117.78.39.204: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.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.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.tlk_attendance_site_base_info-rd_security_station_summary\\\",\\\"bootstrapServer\\\":\\\"117.78.39.204:9092\\\",\\\"enableAutoCommit\\\":\\\"true\\\",\\\"name\\\":\\\"CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.tlk_attendance_site_base_info-rd_security_station_summary\\\",\\\"topic\\\":\\\"baibaodunflow.binlog-cdc.topic.tlk_attendance_site_base_info\\\",\\\"scanStartupMode\\\":\\\"group-offsets\\\",\\\"primaryKeyName\\\":\\\"ID\\\",\\\"autoOffsetRest\\\":\\\"earliest\\\"}}],\\\"name\\\":\\\"CheckPoint2-consume-baibaodunflow.binlog-cdc.topic.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.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\\\":\\\"117.78.39.204: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\\\":\\\"49.4.21.141\\\",\\\"source.database.port\\\":\\\"2111\\\",\\\"source.database.username\\\":\\\"bcx\\\",\\\"source.database.password\\\":\\\"Wstestv5qy#2022\\\",\\\"source.database.connectionTimeZone\\\":\\\"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);