package com.ruoyi.utils;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.TypeReference;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.ruoyi.activeMQ.vo.CameraCon;
|
import com.ruoyi.activeMQ.vo.CameraControlVO;
|
import com.ruoyi.activeMQ.vo.CameraRuleVO;
|
import com.ruoyi.activeMQ.vo.RuleAreaVO;
|
import com.ruoyi.aibrain.domain.AiCamera;
|
import com.ruoyi.aibrain.domain.AiCameraRule;
|
import com.ruoyi.aibrain.domain.Point;
|
import com.ruoyi.aibrain.service.IAiCameraService;
|
import com.ruoyi.common.core.redis.RedisCache;
|
import com.ruoyi.common.utils.Threads;
|
import com.ruoyi.common.utils.spring.SpringUtils;
|
import com.ruoyi.framework.config.ActiveManager;
|
import org.apache.activemq.command.ActiveMQQueue;
|
import org.apache.activemq.command.ActiveMQTopic;
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.cglib.beans.BeanCopier;
|
|
import javax.jms.Destination;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
public class CameraUtils {
|
|
private static final Logger logger = LoggerFactory.getLogger(Threads.class);
|
|
private static BeanCopier copier = BeanCopier.create(AiCamera.class, CameraControlVO.class, false);
|
|
@Autowired
|
private static ActiveManager activeManager;
|
|
@Autowired
|
private static IAiCameraService aiCameraService;
|
|
@Autowired
|
private static RedisCache redisCache;
|
|
|
/**
|
* 启动AI识别设备
|
*/
|
public static void startCamera() {
|
startCameraAll("1");
|
// activeManager = SpringUtils.getBean(ActiveManager.class);
|
// aiCameraService = SpringUtils.getBean(IAiCameraService.class);
|
//
|
// Destination destination = new ActiveMQQueue("cameraControlQueue");//P2P模式单个消费者
|
// List<AiCamera> cameraList = aiCameraService.queryCameraToStart();
|
// for (AiCamera camera : cameraList){
|
// CameraControlVO cameraVO = new CameraControlVO();
|
// copier.copy(camera,cameraVO,null);
|
// cameraVO.setTime(new Date().getTime());
|
//
|
// List<CameraRuleVO> rules = new ArrayList<>();
|
// for (AiCameraRule cameraRule : camera.getRules()){
|
// CameraRuleVO ruleVO = new CameraRuleVO();
|
// ruleVO.setrecordDuration(cameraRule.getrecordDuration());
|
// ruleVO.setisRecord(cameraRule.getisRecord());
|
// ruleVO.setCameraId(cameraRule.getCameraId());
|
// ruleVO.setPeopleNumber(cameraRule.getPeopleNumber());
|
// ruleVO.setRuleId(cameraRule.getRuleId());
|
// ruleVO.setRuleName(cameraRule.getRuleName());
|
// ruleVO.setRuleArea(cameraRule.getAreas());
|
// rules.add(ruleVO);
|
// }
|
// cameraVO.setRules(rules);
|
// camera.setRunStatus("1");
|
// aiCameraService.updateAiCameraStatus(camera);
|
// //传入队列以及值
|
// activeManager.send(destination, JSON.toJSONString(cameraVO));
|
// logger.info("cameraControlQueue队列："+JSON.toJSONString(cameraVO));
|
// }
|
}
|
|
|
|
/**
|
* 启动AI识别设备
|
*/
|
public static void startCamera(long id,String runStatus) {
|
activeManager = SpringUtils.getBean(ActiveManager.class);
|
aiCameraService = SpringUtils.getBean(IAiCameraService.class);
|
redisCache = SpringUtils.getBean(RedisCache.class);
|
|
|
Destination destination = new ActiveMQQueue("cameraControlQueue");//P2P模式单个消费者
|
AiCamera camera = aiCameraService.selectAiCameraById(id);
|
CameraCon cameraCon=new CameraCon();
|
cameraCon.setState(Integer.valueOf(runStatus));
|
|
|
List<CameraControlVO> cameraControlVOS=new ArrayList<>();
|
|
CameraControlVO cameraVO = new CameraControlVO();
|
cameraVO.setId(String.valueOf(camera.getId()));
|
cameraVO.setRtspUrl(camera.getRtspUrl());
|
cameraVO.setIp(camera.getCameraIp());
|
cameraVO.setName(camera.getName());
|
cameraVO.setRemp_h(camera.getRempH());
|
cameraVO.setRemp_w(camera.getRempW());
|
if(ObjectUtils.isNotEmpty(camera.getLeatherWidth())){
|
cameraVO.setBeltWidth(String.valueOf(camera.getLeatherWidth()));//皮带宽度
|
}
|
if(ObjectUtils.isNotEmpty(camera.getToRtmp())){
|
cameraVO.setToRtmp(camera.getToRtmp());
|
}
|
List<CameraRuleVO> rules = new ArrayList<>();
|
for (AiCameraRule cameraRule : camera.getRules()){
|
CameraRuleVO ruleVO = new CameraRuleVO();
|
ruleVO.setId(String.valueOf(cameraRule.getRuleId()));
|
if(ObjectUtils.isNotEmpty(cameraRule.getSecond())){
|
ruleVO.setDelay(cameraRule.getSecond());//延时时间数
|
}
|
if(ObjectUtils.isNotEmpty(cameraRule.getThreshold())){
|
ruleVO.setThreshold(cameraRule.getThreshold());//阈值
|
}
|
if(cameraRule.getIsRecord().equals("1")){
|
ruleVO.setIsRecord(cameraRule.getIsRecord());//是否录像
|
ruleVO.setRecordDuration(cameraRule.getRecordDuration());//录像时长
|
}else{
|
ruleVO.setIsRecord(cameraRule.getIsRecord());//是否录像
|
}
|
RuleAreaVO ruleAreaVO=new RuleAreaVO();
|
ruleAreaVO.setB(cameraRule.getB());
|
ruleAreaVO.setG(cameraRule.getG());
|
ruleAreaVO.setR(cameraRule.getR());
|
if(ObjectUtils.isNotEmpty(cameraRule.getPic_w())){
|
ruleAreaVO.setPic_w(cameraRule.getPic_w());
|
}
|
if(ObjectUtils.isNotEmpty(cameraRule.getPic_h())){
|
ruleAreaVO.setPic_h(cameraRule.getPic_h());
|
}
|
if(ObjectUtils.isNotEmpty(cameraRule.getRuleArea())){
|
List<Point> objects = JSON.parseArray(cameraRule.getRuleArea(),Point.class);
|
ruleAreaVO.setPoints(objects);
|
}
|
ruleVO.setRects(ruleAreaVO);
|
rules.add(ruleVO);
|
}
|
cameraVO.setModels(rules);
|
cameraControlVOS.add(cameraVO);
|
cameraCon.setCameras(cameraControlVOS);
|
|
//更新摄像头启动状态
|
camera.setStatus(runStatus);
|
aiCameraService.updateAiCameraStatus(camera);
|
//传入队列以及值
|
activeManager.send(destination, JSON.toJSONString(cameraCon).replace("\\", ""));
|
logger.info("cameraControlQueue队列："+JSON.toJSONString(cameraCon));
|
}
|
|
/**
|
* 批量启动设备
|
*/
|
public static void startCameraAll(String runStatus) {
|
activeManager = SpringUtils.getBean(ActiveManager.class);
|
aiCameraService = SpringUtils.getBean(IAiCameraService.class);
|
redisCache = SpringUtils.getBean(RedisCache.class);
|
|
|
Destination destination = new ActiveMQQueue("cameraControlQueue");//P2P模式单个消费者
|
List<AiCamera> list = aiCameraService.selectAllCamera();
|
redisCache.setCacheObject("AI::AiCameraList",list);
|
|
|
|
CameraCon cameraCon=new CameraCon();
|
List<CameraControlVO> cameraControlVOS=new ArrayList<>();
|
for (AiCamera camera : list) {
|
redisCache.setCacheObject("AI::AiCameraObj"+camera.getCameraNum(),camera);
|
cameraCon.setState(Integer.valueOf(runStatus));
|
CameraControlVO cameraVO = new CameraControlVO();
|
cameraVO.setId(String.valueOf(camera.getId()));
|
cameraVO.setRtspUrl(camera.getRtspUrl());
|
cameraVO.setIp(camera.getCameraIp());
|
cameraVO.setName(camera.getName());
|
cameraVO.setRemp_h(camera.getRempH());
|
cameraVO.setRemp_w(camera.getRempW());
|
if(ObjectUtils.isNotEmpty(camera.getLeatherWidth())){
|
cameraVO.setBeltWidth(String.valueOf(camera.getLeatherWidth()));//皮带宽度
|
}
|
if(ObjectUtils.isNotEmpty(camera.getToRtmp())){
|
cameraVO.setToRtmp(camera.getToRtmp());
|
}
|
List<CameraRuleVO> rules = new ArrayList<>();
|
for (AiCameraRule cameraRule : camera.getRules()){
|
CameraRuleVO ruleVO = new CameraRuleVO();
|
ruleVO.setId(String.valueOf(cameraRule.getRuleId()));
|
if(ObjectUtils.isNotEmpty(cameraRule.getSecond())){
|
ruleVO.setDelay(cameraRule.getSecond());//延时时间数
|
}
|
if(ObjectUtils.isNotEmpty(cameraRule.getThreshold())){
|
ruleVO.setThreshold(cameraRule.getThreshold());//阈值
|
}
|
RuleAreaVO ruleAreaVO=new RuleAreaVO();
|
ruleAreaVO.setB(cameraRule.getB());
|
ruleAreaVO.setG(cameraRule.getG());
|
ruleAreaVO.setR(cameraRule.getR());
|
if(ObjectUtils.isNotEmpty(cameraRule.getPic_w())){
|
ruleAreaVO.setPic_w(cameraRule.getPic_w());
|
}
|
if(ObjectUtils.isNotEmpty(cameraRule.getPic_h())){
|
ruleAreaVO.setPic_h(cameraRule.getPic_h());
|
}
|
if(ObjectUtils.isNotEmpty(cameraRule.getRuleArea())){
|
List<Point> objects = JSON.parseArray(cameraRule.getRuleArea(),Point.class);
|
ruleAreaVO.setPoints(objects);
|
}
|
ruleVO.setRects(ruleAreaVO);
|
rules.add(ruleVO);
|
}
|
cameraVO.setModels(rules);
|
cameraControlVOS.add(cameraVO);
|
cameraCon.setCameras(cameraControlVOS);
|
|
//更新摄像头启动状态
|
camera.setStatus(runStatus);
|
aiCameraService.updateAiCameraStatus(camera);
|
}
|
|
|
|
//传入队列以及值
|
activeManager.send(destination, JSON.toJSONString(cameraCon).replace("\\", ""));
|
logger.info("cameraControlQueue队列："+JSON.toJSONString(cameraCon));
|
}
|
}
|
