定时任务增加SaTokenContextMockUtil 操作
This commit is contained in:
@@ -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<RemoteSisDeviceManage> 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();
|
||||
}
|
||||
|
||||
/**
|
||||
|
Reference in New Issue
Block a user