|
|
|
@ -1,12 +1,14 @@
|
|
|
|
package com.zhehekeji.web.lib;
|
|
|
|
package com.zhehekeji.web.lib;
|
|
|
|
|
|
|
|
|
|
|
|
import com.zhehekeji.common.util.SpringContextUtil;
|
|
|
|
import com.zhehekeji.common.util.SpringContextUtil;
|
|
|
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
|
|
|
|
|
|
|
import java.time.LocalDateTime;
|
|
|
|
import java.time.LocalDateTime;
|
|
|
|
import java.util.concurrent.DelayQueue;
|
|
|
|
import java.util.concurrent.DelayQueue;
|
|
|
|
import java.util.concurrent.ExecutorService;
|
|
|
|
import java.util.concurrent.ExecutorService;
|
|
|
|
import java.util.concurrent.Executors;
|
|
|
|
import java.util.concurrent.Executors;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Slf4j
|
|
|
|
public class TaskDelayExecutor {
|
|
|
|
public class TaskDelayExecutor {
|
|
|
|
|
|
|
|
|
|
|
|
private static ExecutorService exec = Executors.newFixedThreadPool(1);
|
|
|
|
private static ExecutorService exec = Executors.newFixedThreadPool(1);
|
|
|
|
@ -44,6 +46,7 @@ public class TaskDelayExecutor {
|
|
|
|
if(cameraDelayTask != null){
|
|
|
|
if(cameraDelayTask != null){
|
|
|
|
|
|
|
|
|
|
|
|
if(cameraDelayTask.getType() == 0){
|
|
|
|
if(cameraDelayTask.getType() == 0){
|
|
|
|
|
|
|
|
log.info("开始下载视频:{}",cameraDelayTask.getPath());
|
|
|
|
|
|
|
|
|
|
|
|
cameraControlModule.downloadMp4(cameraDelayTask.getCameraId(), cameraDelayTask.getPath(), cameraDelayTask.getStartTime(), cameraDelayTask.getEndTime());
|
|
|
|
cameraControlModule.downloadMp4(cameraDelayTask.getCameraId(), cameraDelayTask.getPath(), cameraDelayTask.getStartTime(), cameraDelayTask.getEndTime());
|
|
|
|
}else if(cameraDelayTask.getType() == 1){
|
|
|
|
}else if(cameraDelayTask.getType() == 1){
|
|
|
|
|