From 3faafb9bd6721860330b960aad9c1a4274c6c38a Mon Sep 17 00:00:00 2001 From: 15683799673 Date: Sun, 7 Sep 2025 07:40:12 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E5=A2=9E?= =?UTF-8?q?=E5=8A=A0SaTokenContextMockUtil=20=E6=93=8D=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../job/snailjob/sis/HikDeviceCheckStateTask.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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(); } /**