package com.ruoyi.inspect.service.impl;
|
|
import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell;
|
import com.ruoyi.alarmpoints.well.mapper.ArdAlarmpointsWellMapper;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.spring.SpringUtils;
|
import com.ruoyi.device.camera.domain.ArdCameras;
|
import com.ruoyi.device.camera.domain.CameraCmd;
|
import com.ruoyi.device.camera.mapper.ArdCamerasMapper;
|
import com.ruoyi.device.hiksdk.config.MinioClientSingleton;
|
import com.ruoyi.device.hiksdk.service.IHikClientService;
|
import com.ruoyi.inspect.domain.ArdVideoInspectRecord;
|
import com.ruoyi.inspect.domain.ArdVideoInspectTask;
|
import com.ruoyi.inspect.domain.ArdVideoInspectTaskStep;
|
import com.ruoyi.inspect.mapper.ArdVideoInspectRecordMapper;
|
import com.ruoyi.inspect.mapper.ArdVideoInspectTaskMapper;
|
import com.ruoyi.inspect.service.IArdVideoInspectTaskService;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Service;
|
import org.thymeleaf.spring5.context.SpringContextUtils;
|
|
import javax.annotation.Resource;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Optional;
|
import java.util.UUID;
|
|
/**
|
* @Description:
|
* @ClassName: InspectionTaskImpl
|
* @Author: 刘苏义
|
* @Date: 2023年06月01日8:57
|
* @Version: 1.0
|
**/
|
@Slf4j(topic = "PatrolInspectionTask")
|
class InspectionTask implements Runnable {
|
|
private String taskId;
|
private boolean isRunning;
|
|
public InspectionTask(String taskId) {
|
this.taskId = taskId;
|
this.isRunning = false;
|
}
|
|
public void start() {
|
isRunning = true;
|
Thread thread = new Thread(this);
|
thread.start();
|
}
|
|
public void stop() {
|
isRunning = false;
|
}
|
|
@Override
|
public void run() {
|
while (isRunning) {
|
// 巡检任务的具体逻辑
|
log.debug("巡检任务执行中：" + taskId);
|
try {
|
Thread.sleep(5000);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
ArdVideoInspectTaskServiceImpl ardVideoInspectTaskService = SpringUtils.getBean(ArdVideoInspectTaskServiceImpl.class);
|
ardVideoInspectTaskService.manualTaskRun(taskId);
|
}
|
|
}
|
}
|
