huimv-baqing/sql/biz_sys_job_iot_data_incremental_sync.sql

-- 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'
);