package com.tievd.jyz.handler.alg.oil;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
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.mqtt.command.MqttCommandReceiver;
|
import com.tievd.jyz.mqtt.dto.EventInfoDTO;
|
import com.tievd.jyz.service.IOiloutEventService;
|
import com.tievd.jyz.service.IOiloutRecordService;
|
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;
|
import java.util.Date;
|
|
/**
|
* 卸油算法处理类
|
* @author timi
|
*/
|
@Slf4j
|
@Component
|
public class OilAlgHandler implements AlgHandleInterface {
|
/** 卸油算法标识头 */
|
private final String[] ALG_TAG = new String[]{
|
"X10001", "X10002", "X10003",
|
"X10004", "X10005", "X10006",
|
"X10007", "X10008"};
|
|
private final String lastAlgTag = "X10008";
|
@Override
|
public String[] getAlgTag(){
|
return ALG_TAG;
|
}
|
@Autowired
|
private IOiloutEventService oiloutEventService;
|
@Autowired
|
private IOiloutRecordService oiloutRecordService;
|
@Autowired
|
private CameraMapper cameraMapper;
|
@Autowired
|
private MqttCommandReceiver mqttCommandReceiver;
|
@Value("${init.sendCommandTopic:/ty/aibox/command/}")
|
private String sendCommandTopic;
|
|
/**
|
* 处理入口
|
* @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();
|
//车牌
|
String plateNumber = "";
|
|
Device device = DeviceCache.getDeviceBySn(sn);
|
if(ObjectUtil.isNull(device)){
|
log.error("网关设备不存在,sn:{}",sn);
|
return;
|
}
|
SysAlgorithmItem sysAlgorithmItem = AlgorithmCache.getAlgorithmMap(algCode);
|
if(ObjectUtil.isNull(sysAlgorithmItem)){
|
log.error("算法类型不存在,algCode:{}",algCode);
|
return;
|
}
|
SysDepart sysDepart = DepartCache.getDepartByOrgCode(device.getOrgCode());
|
if(ObjectUtil.isNull(sysDepart)){
|
log.error("机构不存在,orgCode:{}",device.getOrgCode());
|
return;
|
}
|
//上传信息中无车牌号，暂时使用第三方的processId作为id传入记录中
|
OiloutRecord oiloutRecord = BeanUtil.copyProperties(eventInfoDTO.getExtend(), OiloutRecord.class);
|
LambdaQueryWrapper<OiloutRecord> wrapper = new LambdaQueryWrapper<>(oiloutRecord).eq(OiloutRecord::getOrgCode, device.getOrgCode()).isNull(OiloutRecord::getEndTime);
|
OiloutRecord recordSelect = oiloutRecordService.getOne(wrapper, false);
|
|
if(ObjectUtil.isNull(recordSelect)){
|
oiloutRecord = oilOutRecordGen(oiloutRecord, plateNumber,System.currentTimeMillis(),cameraCode,device.getId(), device.getName(),sysDepart);
|
oiloutRecordService.save(oiloutRecord);
|
} else {
|
oiloutRecord = recordSelect;
|
}
|
OiloutEvent oiloutEvent = oiloutEventService.getOne(new LambdaQueryWrapper<OiloutEvent>().eq(OiloutEvent::getRecordId,oiloutRecord.getId()).eq(OiloutEvent::getAlgorithmCode,algCode), false);
|
if(ObjectUtil.isNotNull(oiloutEvent)){
|
return;
|
}
|
oiloutEvent = oilOutEventGen( eventCode, sysAlgorithmItem, device, sysDepart, cameraCode, time, SystemConstant.OILOUT_EVETN_TYPE_RIGHT.byteValue());
|
//将扩展信息的图片和是否合规赋值
|
BeanUtil.copyProperties(eventInfoDTO.getExtend(), oiloutEvent);
|
oiloutEvent.setId(null);
|
oiloutEvent.setRecordId(oiloutRecord.getId());
|
oiloutEventService.save(oiloutEvent);
|
//请求图片和短视频
|
// 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("事件图片视频指令发送失败");
|
// }
|
//第三方上报顺序不一致，取消阶段检测
|
// if(sysAlgorithmItem.getPhraseSymbol() == (byte)1){
|
// //为阶段标志
|
// if(sysAlgorithmItem.getPhrase() > SystemConstant.OILOUT_EVENT_PHRASE_FRONT){
|
// //为阶段标志，完善之前阶段事件数据
|
// List<SysAlgorithmItem> algorithmItemList = AlgorithmCache.getPhraseAlgorithmMap((byte) (sysAlgorithmItem.getPhrase()-1));
|
// for(SysAlgorithmItem sysAlgorithmItem1:algorithmItemList){
|
// OiloutEvent tmpOiloutEvent = oiloutEventService.getOne(new QueryWrapper<OiloutEvent>().eq("record_id",oiloutRecord.getId()).eq("algorithm_code",sysAlgorithmItem1.getAlgorithmCode()), false);
|
// if(ObjectUtil.isNull(tmpOiloutEvent)){
|
// tmpOiloutEvent = oilOutEventGen(RandomUtil.randomNumbers(10), sysAlgorithmItem1,device, sysDepart, cameraCode, time, SystemConstant.OILOUT_EVETN_TYPE_ERROR.byteValue());
|
// tmpOiloutEvent.setRecordId(oiloutRecord.getId());
|
// tmpOiloutEvent.setImgPath(oiloutEvent.getImgPath());
|
// oiloutEventService.save(tmpOiloutEvent);
|
// //TODO 请求图片视频
|
//
|
// }
|
// }
|
// }
|
// }else{
|
//
|
// }
|
if(lastAlgTag.equals(algCode)){
|
oiloutRecord.setEndTime(new Timestamp(System.currentTimeMillis()));
|
int spandTime = (int) (oiloutRecord.getEndTime().getTime() - oiloutRecord.getStartTime().getTime())/1000/60;
|
oiloutRecord.setSpandTime(spandTime);
|
oiloutRecordService.updateById(oiloutRecord);
|
}
|
}
|
|
|
/**
|
* 卸油记录生成
|
* @param plateNumber
|
* @param startTime
|
* @param cameraCode
|
* @param deviceId
|
* @param sysDepart
|
* @return
|
*/
|
private OiloutRecord oilOutRecordGen(OiloutRecord oiloutRecord, String plateNumber, Long startTime,String cameraCode,Long deviceId, String deviceName,SysDepart sysDepart){
|
oiloutRecord.setCameraCode(cameraCode);
|
oiloutRecord.setDeviceId(deviceId);
|
oiloutRecord.setOrgCode(sysDepart.getOrgCode());
|
oiloutRecord.setOrgName(sysDepart.getDepartName());
|
oiloutRecord.setLicenseNum(plateNumber);
|
oiloutRecord.setStartTime(new Timestamp(startTime));
|
oiloutRecord.setCreateTime(new Date());
|
return oiloutRecord;
|
}
|
|
|
/**
|
* 卸油事件生成
|
* @param eventCode
|
* @param sysAlgorithmItem
|
* @param device
|
* @param sysDepart
|
* @param cameraCode
|
* @param time
|
* @param eventType
|
* @return
|
*/
|
private OiloutEvent oilOutEventGen(String eventCode, SysAlgorithmItem sysAlgorithmItem, Device device,SysDepart sysDepart, String cameraCode, String time,Byte eventType){
|
Camera camera = cameraMapper.selectOne(new QueryWrapper<Camera>().eq("code",cameraCode).eq("device_id",device.getId()));
|
if(ObjectUtil.isNull(camera)){
|
return null;
|
}
|
OiloutEvent oiloutEvent = new OiloutEvent();
|
oiloutEvent.setAlgorithmCode(sysAlgorithmItem.getAlgorithmCode());
|
oiloutEvent.setAlgorithmName(sysAlgorithmItem.getAlgorithmName());
|
oiloutEvent.setEventType(eventType);
|
oiloutEvent.setEventPhrase(sysAlgorithmItem.getPhrase());
|
oiloutEvent.setCameraCode(camera.getCode());
|
oiloutEvent.setCameraName(camera.getName());
|
oiloutEvent.setDeviceId(device.getId());
|
oiloutEvent.setDeviceName(device.getName());
|
oiloutEvent.setOrgCode(sysDepart.getOrgCode());
|
oiloutEvent.setEventDay(LocalDate.now().format(SystemConstant.DATE_DAY_FORMATTER));
|
oiloutEvent.setOrgName(sysDepart.getDepartName());
|
oiloutEvent.setEventTime(new Timestamp(Long.parseLong(time)));
|
oiloutEvent.setImgUid(eventCode);
|
oiloutEvent.setCreateTime(new Timestamp(System.currentTimeMillis()));
|
return oiloutEvent;
|
}
|
}
|
