package com.ruoyi.device.camera.service.impl;
|
|
import com.ruoyi.common.annotation.SdkOperate;
|
import com.ruoyi.common.constant.CacheConstants;
|
import com.ruoyi.common.core.redis.RedisCache;
|
import com.ruoyi.device.camera.domain.ArdCameras;
|
import com.ruoyi.device.camera.domain.CameraCmd;
|
import com.ruoyi.device.camera.service.IArdCamerasService;
|
import com.ruoyi.device.camera.service.ICameraSdkService;
|
import com.ruoyi.device.camera.strategy.SdkStrategy;
|
import com.ruoyi.device.camera.strategy.SdkStrategyFactory;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.boot.ApplicationArguments;
|
import org.springframework.boot.ApplicationRunner;
|
import org.springframework.stereotype.Service;
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
|
/**
|
* @Description: 相机sdk业务
|
* @ClassName: CameraSdkServiceImpl
|
* @Author: 刘苏义
|
* @Date: 2023年10月16日15:21:01
|
**/
|
@Service
|
@Slf4j(topic = "SDK")
|
public class CameraSdkServiceImpl implements ICameraSdkService, ApplicationRunner {
|
@Resource
|
private IArdCamerasService ardCamerasService;
|
@Resource
|
private RedisCache redisCache;
|
@Resource
|
private SdkStrategyFactory sdkStrategyFactory;
|
|
/**
|
* 启动线程方法，用于执行初始化登录相机的逻辑
|
*
|
* @param args 命令行参数
|
*/
|
@Override
|
public void run(ApplicationArguments args) {
|
|
try {
|
// 从ardCamerasService中获取ArdCameras列表
|
List<ArdCameras> ardCameras = ardCamerasService.selectArdCamerasListNoDataScope(new ArdCameras());
|
for (ArdCameras camera : ardCameras) {
|
login(camera);
|
}
|
} catch (Exception ex) {
|
// 初始化登录相机异常，记录错误日志
|
log.error("初始化登录相机异常：" + ex.getMessage());
|
}
|
}
|
|
|
//登录
|
@Override
|
public Boolean login(ArdCameras ardCamera) {
|
boolean result = false;
|
try {
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
//sdkStrategy.login(ardCamera);//同步登录
|
sdkStrategy.asyncLogin(ardCamera);//异步登录
|
result=true;
|
}
|
} catch (Exception ex) {
|
log.error("登录异常：" + ex.getMessage());
|
return false;
|
}
|
return result;
|
}
|
|
//注销
|
@Override
|
public boolean logout(String cameraId) {
|
boolean result = false;
|
try {
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.logout(cameraId);
|
}
|
} catch (Exception ex) {
|
log.error("注销异常：" + ex.getMessage());
|
return false;
|
}
|
return result;
|
}
|
|
//在线检测
|
@Override
|
public boolean isOnLine(CameraCmd cmd) {
|
try {
|
boolean onLine = false;
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
onLine = sdkStrategy.isOnLine(cmd);
|
}
|
return onLine;
|
} catch (Exception ex) {
|
log.error("检测在线异常：" + ex.getMessage());
|
return false;
|
}
|
}
|
|
//云台控制
|
@SdkOperate
|
@Override
|
public boolean pTZControl(CameraCmd cmd) {
|
try {
|
boolean result = false;
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.pTZControl(cmd);
|
}
|
return result;
|
} catch (Exception ex) {
|
log.error("ptz控制异常：" + ex.getMessage());
|
return false;
|
}
|
}
|
|
//设置聚焦值
|
@Override
|
public boolean setFocusPos(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.setFocusPos(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("设置聚焦值异常：" + ex.getMessage());
|
|
}
|
return result;
|
}
|
|
//获取聚焦值
|
@Override
|
public int getFocusPos(CameraCmd cmd) {
|
int result = 0;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.getFocusPos(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("获取聚焦值异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//设置预置位
|
@Override
|
@SdkOperate
|
public boolean setPreset(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.setPreset(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("设置预置位异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//调用预置位
|
@Override
|
@SdkOperate
|
public boolean gotoPreset(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.gotoPreset(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("调用预置位异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//获取码流压缩参数
|
@Override
|
public Map<String, Object> getVideoCompressionCfg(CameraCmd cmd) {
|
Map<String, Object> map = new HashMap<>();
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
map = sdkStrategy.getVideoCompressionCfg(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("获取码流压缩参数异常：" + ex.getMessage());
|
}
|
return map;
|
}
|
|
//透雾开关
|
@Override
|
public boolean controlDefogcfg(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.controlDefogcfg(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("操控透雾异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//红外开关
|
@Override
|
public boolean controlInfrarecfg(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.controlInfrarecfg(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("操控红外异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//手动/自动聚焦
|
@Override
|
public boolean controlFocusMode(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.controlFocusMode(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("操控聚焦模式异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//获取聚焦模式
|
@Override
|
public String getFocusMode(CameraCmd cmd) {
|
String result = "";
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.getFocusMode(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("获取聚焦模式异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//云台加热
|
@Override
|
public boolean controlPTHeateRpwron(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.controlPTHeateRpwron(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("操控云台加热异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//镜头加热
|
@Override
|
public boolean controlCameraDeicing(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.controlCameraDeicing(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("操控云台加热异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//获取云台锁定信息
|
@Override
|
public int getPTZLockInfo(CameraCmd cmd) {
|
int result = 99;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.getPTZLockInfo(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("获取云台锁定信息异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
@Override
|
public String captureJPEGPicture(CameraCmd cmd) {
|
return null;
|
}
|
|
//抓图
|
@SdkOperate
|
@Override
|
public String picCutCate(CameraCmd cmd) {
|
String url = "";
|
try {
|
//获取摄像头ID
|
String cameraId = cmd.getCameraId();
|
//从redis中获取摄像头信息
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
//获取摄像头工厂
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
url = sdkStrategy.picCutCate(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("抓图异常：" + ex.getMessage());
|
}
|
return url;
|
}
|
|
//获取ptz
|
@Override
|
public Map<String, Object> getPtz(CameraCmd cmd) {
|
Map<String, Object> map = new HashMap<>();
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
map = sdkStrategy.getPtz(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("获取ptz异常：" + ex.getMessage());
|
}
|
return map;
|
}
|
|
//获取ptz范围
|
@Override
|
public Map<String, Object> getPtzScope(CameraCmd cmd) {
|
Map<String, Object> map = new HashMap<>();
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
map = sdkStrategy.getPtzScope(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("获取ptz范围异常：" + ex.getMessage());
|
}
|
return map;
|
}
|
|
//设置ptz
|
@SdkOperate
|
@Override
|
public boolean setPtz(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.setPtz(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("设置ptz异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//设置零方位角
|
@SdkOperate
|
@Override
|
public boolean setZeroPtz(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.setZeroPtz(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("设置零方位角异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//引导指向目标
|
@SdkOperate
|
@Override
|
public boolean guideTargetPosition(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.guideTargetPosition(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("引导指向目标异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
/**
|
* @描述 操控锁定
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/1/17 16:36
|
* @修改人和其它信息 0-解锁 1-锁定
|
*/
|
@Override
|
@SdkOperate
|
public boolean controlLock(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();//申请锁的相机
|
ArdCameras ardCameras = ardCamerasService.selectArdCamerasById(cameraId);
|
Date now = new Date();
|
now.setTime(now.getTime() + cmd.getExpired() * 1000);
|
ardCameras.setOperatorExpired(now);//设置当前过期时间
|
ardCamerasService.updateArdCameras(ardCameras);
|
return true;
|
}
|
|
/**
|
* @描述 操控解锁
|
* @参数 [userId, channelNum]
|
* @返回值 boolean
|
* @创建人 刘苏义
|
* @创建时间 2023/6/30 15:36
|
* @修改人和其它信息
|
*/
|
@Override
|
public boolean controlUnLock(CameraCmd cmd) {
|
String cameraId = cmd.getCameraId();//申请解锁的相机
|
String operator = cmd.getOperator();//申请者
|
ArdCameras ardCameras = ardCamerasService.selectArdCamerasById(cameraId);
|
if (ardCameras.getOperatorId().equals(operator)) {
|
//如果解锁相机的当前用户是申请者，则清空该相机的过期时间
|
ardCameras.setOperatorExpired(null);
|
int i = ardCamerasService.updateArdCameras(ardCameras);
|
if (i > 0) {
|
log.debug(cameraId + "--解锁成功");
|
}
|
}
|
return true;
|
}
|
|
|
//录像
|
@SdkOperate
|
@Override
|
public String record(CameraCmd cmd) {
|
String url = "";
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
url = sdkStrategy.record(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("录像异常：" + ex.getMessage());
|
}
|
return url;
|
}
|
|
//开始录像
|
@Override
|
public boolean recordStart(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.recordStart(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("开始录像异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//停止录像并存入minio
|
@Override
|
public String recordStopToMinio(CameraCmd cmd) {
|
String url = "";
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
url = sdkStrategy.recordStopToMinio(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("停止录像异常：" + ex.getMessage());
|
}
|
return url;
|
}
|
|
//停止录像并不存入minio
|
@Override
|
public boolean recordStopNotToMinio(CameraCmd cmd) {
|
boolean result = false;
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
result = sdkStrategy.recordStopNotToMinio(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("停止录像异常：" + ex.getMessage());
|
}
|
return result;
|
}
|
|
//获取相机架设参数
|
@Override
|
public Map<String, Object> getGisInfo(CameraCmd cmd) {
|
Map<String, Object> map = new HashMap<>();
|
try {
|
String cameraId = cmd.getCameraId();
|
ArdCameras ardCamera = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId);
|
if (ardCamera != null) {
|
String factory = ardCamera.getFactory();
|
SdkStrategy sdkStrategy = sdkStrategyFactory.getSdkStrategy(factory);
|
map = sdkStrategy.getGisInfo(cmd);
|
}
|
} catch (Exception ex) {
|
log.error("获取相机架设参数异常：" + ex.getMessage());
|
}
|
return map;
|
}
|
|
|
}
|
