package com.tievd.jyz.handler.alg.common;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.tievd.cube.modules.system.entity.SysDepart;
|
import com.tievd.jyz.cache.AlgorithmCache;
|
import com.tievd.jyz.cache.DepartCache;
|
import com.tievd.jyz.cache.DeviceCache;
|
import com.tievd.jyz.constants.SystemConstant;
|
import com.tievd.jyz.entity.*;
|
import com.tievd.jyz.handler.alg.AlgHandleInterface;
|
import com.tievd.jyz.mapper.CameraMapper;
|
import com.tievd.jyz.mapper.OilEventMapper;
|
import com.tievd.jyz.mapper.SpotcheckEventMapper;
|
import com.tievd.jyz.mqtt.command.MqttCommandReceiver;
|
import com.tievd.jyz.mqtt.dto.EventInfoDTO;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import java.sql.Timestamp;
|
import java.time.LocalDate;
|
|
/**
|
* 通用异常算法处理类
|
* @author timi
|
*/
|
@Slf4j
|
@Component
|
public class CommonAlarmAlgHandler implements AlgHandleInterface {
|
|
/** 通用算法标识头 */
|
private final String[] ALG_TAG = new String[]{
|
"C10002",
|
"C10003",
|
"C10005",
|
"C10006",
|
"C20001",
|
"C20002",
|
"C30001",
|
"C30002",
|
"C30003",
|
"C30004",
|
"C20003",
|
"C20004",
|
"C20005",
|
"C20006",
|
"C20007",
|
"C20008",
|
"C20009",
|
"C20010",
|
"C20011",
|
"S10001",
|
"S10002"
|
};
|
|
@Autowired
|
private OilEventMapper oilEventMapper;
|
|
@Autowired
|
private SpotcheckEventMapper spotcheckEventMapper;
|
|
@Autowired
|
private CameraMapper cameraMapper;
|
|
@Autowired
|
private MqttCommandReceiver mqttCommandReceiver;
|
@Value("${init.sendCommandTopic:/ty/aibox/command/}")
|
private String sendCommandTopic;
|
|
@Override
|
public String[] getAlgTag(){
|
return ALG_TAG;
|
}
|
|
/**
|
* 处理入口
|
* @param eventInfoDTO
|
* @param sn
|
* @param time
|
*/
|
@Override
|
public void handle(EventInfoDTO<JSONObject> eventInfoDTO, String sn,String time) {
|
//当前事件唯一标识
|
String eventCode = eventInfoDTO.getEventCode();;
|
//检测算法编码
|
String algCode = eventInfoDTO.getAlgCode();
|
//终端编码
|
String cameraCode = eventInfoDTO.getCameraCode();
|
//扩展属性
|
JSONObject extend = new JSONObject();
|
Object extendObj = eventInfoDTO.getExtend();
|
if(extendObj instanceof String){
|
extend = JSONObject.parseObject(extendObj.toString());
|
}else if(extendObj instanceof JSONObject){
|
extend = (JSONObject)extendObj;
|
}
|
log.info("通用异常事件 eventCode:{},extend:{}",eventCode,extendObj);
|
Device device = DeviceCache.getDeviceBySn(sn);
|
if(ObjectUtil.isNull(device)){
|
log.error("网关设备不存在,sn:{}",sn);
|
return;
|
}
|
alarmHandle(eventCode,algCode,cameraCode,time,extend,device);
|
}
|
|
|
/**
|
* 异常告警处理
|
* @param eventCode
|
* @param algCode
|
* @param cameraCode
|
* @param time
|
* @param extend
|
* @param device
|
*/
|
private void alarmHandle(String eventCode,String algCode, String cameraCode,String time,JSONObject extend,Device device){
|
JSONArray carArr = extend.getJSONArray("cars");
|
if(carArr.size() == 0){
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("number","");
|
carArr.add(jsonObject);
|
}
|
for(Object obj: carArr){
|
JSONObject infoObj = (JSONObject) obj;
|
String plateNumber = infoObj.getString("number");
|
OilEvent oilEvent = oilEventGen(eventCode,algCode,cameraCode,time,device);
|
if(ObjectUtil.isNotNull(oilEvent)){
|
if (algCode.contains("S")) {
|
SpotcheckEvent spotcheckEvent = BeanUtil.toBean(oilEvent, SpotcheckEvent.class);
|
spotcheckEventMapper.insert(spotcheckEvent);
|
} else {
|
oilEvent.setLicenseNum(plateNumber);
|
oilEventMapper.insert(oilEvent);
|
}
|
|
}
|
}
|
//默认自动请求
|
//请求图片和短视频
|
// log.info("请求图片和短视频,eventCode:{}",eventCode);
|
// EventResourceDTO eventResourceDTO = new EventResourceDTO(SystemConstant.ALL_SOURCE_TYPE,eventCode,cameraCode);
|
// EventResourceCommand eventResourceCommand = new EventResourceCommand(mqttCommandReceiver,eventResourceDTO,sendCommandTopic,device.getSn());
|
// eventResourceCommand.init();
|
// if(eventResourceCommand.execute() == SystemConstant.DEAL_FAIL){
|
// log.error("事件图片视频指令发送失败");
|
// }
|
}
|
|
/**
|
* 异常时间对象生成
|
* @param eventCode
|
* @param algCode
|
* @param cameraCode
|
* @param time
|
* @param device
|
* @return
|
*/
|
private OilEvent oilEventGen(String eventCode,String algCode,String cameraCode,String time,Device device){
|
Camera camera = cameraMapper.selectOne(new QueryWrapper<Camera>().eq("code",cameraCode).eq("device_id",device.getId()));
|
if(ObjectUtil.isNull(camera)){
|
log.error("平台终端不存在，code:{}",cameraCode);
|
return null;
|
}
|
OilEvent oilEvent = new OilEvent();
|
oilEvent.setAlgorithmCode(algCode);
|
SysAlgorithmItem sysAlgorithmItem = AlgorithmCache.getAlgorithmMap(algCode);
|
if(ObjectUtil.isNotNull(sysAlgorithmItem)){
|
oilEvent.setAlgorithmName(sysAlgorithmItem.getAlgorithmName());
|
}
|
oilEvent.setEventAddress(camera.getInstallAddress());
|
oilEvent.setCameraCode(camera.getCode());
|
oilEvent.setCameraName(camera.getName());
|
oilEvent.setDeviceId(device.getId());
|
oilEvent.setDeviceName(device.getName());
|
oilEvent.setOrgCode(device.getOrgCode());
|
oilEvent.setEventDay(LocalDate.now().format(SystemConstant.DATE_DAY_FORMATTER));
|
SysDepart sysDepart = DepartCache.getDepartByOrgCode(device.getOrgCode());
|
if(ObjectUtil.isNotNull(sysDepart)){
|
oilEvent.setOrgName(sysDepart.getDepartName());
|
}
|
oilEvent.setEventTime(new Timestamp(Long.parseLong(time)));
|
oilEvent.setImgUid(eventCode);
|
oilEvent.setCreateTime(new Timestamp(System.currentTimeMillis()));
|
return oilEvent;
|
}
|
}
|
