diff --git a/ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/sis/HikDeviceCheckStateTask.java b/ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/sis/HikDeviceCheckStateTask.java index 4c9b57ec..3d111d2e 100644 --- a/ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/sis/HikDeviceCheckStateTask.java +++ b/ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/sis/HikDeviceCheckStateTask.java @@ -1,5 +1,6 @@ package org.dromara.job.snailjob.sis; +import cn.dev33.satoken.context.mock.SaTokenContextMockUtil; import cn.hutool.core.collection.CollUtil; import com.aizuda.snailjob.client.job.core.annotation.JobExecutor; import com.aizuda.snailjob.client.job.core.dto.JobArgs; @@ -44,10 +45,15 @@ public class HikDeviceCheckStateTask { * @throws InterruptedException */ public ExecuteResult jobExecute(JobArgs jobArgs) throws InterruptedException { + SaTokenContextMockUtil.setMockContext(this::exec); + return ExecuteResult.success(); + } + + public void exec() { List device = remoteDeviceService.queryHikDevices(); if (CollUtil.isEmpty(device)) { SnailJobLog.REMOTE.info("需要同步的hik设备数量为0,任务执行结束"); - return ExecuteResult.success(); + return; } SnailJobLog.REMOTE.info("需要同步状态的设备数量", device.size()); device.forEach(item -> { @@ -58,7 +64,6 @@ public class HikDeviceCheckStateTask { updateDeviceChannelStatus(item); } }); - return ExecuteResult.success(); } /**