package com.ard.work.device.camera.service;
|
|
import com.ard.common.core.constant.CacheConstants;
|
import com.ard.common.redis.service.RedisService;
|
import com.ard.work.api.domian.ArdCamera;
|
import com.ard.work.device.camera.domain.PtzParamDTO;
|
import com.ard.work.websocket.utils.PTZWebSocketUtils;
|
import jakarta.annotation.Resource;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import java.util.List;
|
import java.util.Set;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
@Slf4j
|
@Component
|
public class PtzTask {
|
|
@Resource
|
private PtzDataCollector ptzDataCollector;
|
|
@Resource
|
private PtzCacheManager ptzCacheManager;
|
|
@Resource
|
private RedisService redisService;
|
|
private final Set<String> runningCamera = ConcurrentHashMap.newKeySet();
|
|
/**
|
* 采集任务（不会堆积）
|
*/
|
@Scheduled(initialDelay = 5000, fixedDelay = 1000)
|
public void startCollectTask() {
|
|
List<Object> cameraList = redisService.getCacheMapValues(CacheConstants.CAMERA_LIST);
|
if (cameraList == null || cameraList.isEmpty()) return;
|
|
for (Object obj : cameraList) {
|
ArdCamera camera = (ArdCamera) obj;
|
String camId = camera.getId();
|
|
// ✅ 防重复执行
|
if (!runningCamera.add(camId)) continue;
|
|
ptzDataCollector.collectCamera(camera, runningCamera);
|
}
|
}
|
|
/**
|
* 推送
|
*/
|
@Scheduled(fixedDelay = 1000)
|
public void pushPTZ() {
|
try {
|
List<PtzParamDTO> list = ptzCacheManager.getAllValidData(5000);
|
if (!list.isEmpty()) {
|
PTZWebSocketUtils.sendMessageAll(list);
|
}
|
} catch (Exception e) {
|
log.error("推送PTZ异常", e);
|
}
|
}
|
}
|
