-- IoT 数据每日凌晨 1:00 增量同步(需在「系统管理-定时任务」中启用) -- 调用目标:iotDataIncrementalSyncTask.syncIncremental -- 若 job_id 冲突请调整主键后执行 INSERT INTO sys_job ( job_id, job_name, job_group, invoke_target, cron_expression, misfire_policy, concurrent, status, create_by, create_time, remark ) VALUES ( 102, 'IoT数据每日增量同步', 'DEFAULT', 'iotDataIncrementalSyncTask.syncIncremental', '0 0 1 * * ?', '3', '1', '0', 'admin', sysdate(), '增量同步牛只称重、耳标温度步数、定位项圈、环境监测(third_party.iot.last_sync_time 水印)' ) ON DUPLICATE KEY UPDATE job_name = VALUES(job_name), invoke_target = VALUES(invoke_target), cron_expression = VALUES(cron_expression), remark = VALUES(remark); -- 上次 IoT 增量同步成功时间(首次为空,任务成功后自动写入) INSERT INTO sys_config ( config_id, config_name, config_key, config_value, config_type, create_by, create_time, remark ) SELECT 200, '第三方 IoT 上次增量同步时间', 'third_party.iot.last_sync_time', '', 'Y', 'admin', sysdate(), 'IoT 增量同步 updatedAfter 水印,由 iotDataIncrementalSyncTask 维护' FROM DUAL WHERE NOT EXISTS ( SELECT 1 FROM sys_config WHERE config_key = 'third_party.iot.last_sync_time' );