{ "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": "{\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/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_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 \"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.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 \"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}" }