From 3f21cddda071af37e902c98c8e6b0f82dd9dd303 Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期三, 04 六月 2025 18:34:01 +0800 Subject: [PATCH] 优化报警附件逻辑 --- ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/WarnMsgService.java | 446 +++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 428 insertions(+), 18 deletions(-) diff --git a/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/WarnMsgService.java b/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/WarnMsgService.java index fa98d92..0197955 100644 --- a/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/WarnMsgService.java +++ b/ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/WarnMsgService.java @@ -1,12 +1,17 @@ package com.ruoyi.dataInterchange.server; import com.alibaba.fastjson.JSON; -import com.ruoyi.dataInterchange.dao.UPExgMsgRealLocationDao; -import com.ruoyi.dataInterchange.dao.UPWarnMsgAdptInfoDao; -import com.ruoyi.dataInterchange.dao.UPWarnMsgUrgeTodoAckDao; +import com.alibaba.fastjson2.JSONArray; +import com.alibaba.fastjson2.JSONObject; +import com.ruoyi.dataInterchange.dao.*; import com.ruoyi.dataInterchange.model.*; import com.ruoyi.dataInterchange.model.enu.DataType; import com.ruoyi.dataInterchange.netty.client.ChannelMap; +import com.ruoyi.dataInterchange.util.haikang.Artemis; +import com.ruoyi.dataInterchange.util.haikang.model.Alarm; +import com.ruoyi.dataInterchange.util.haikang.model.Event; +import com.ruoyi.dataInterchange.util.haikang.model.FindPicturesByAlarmIdRequest; +import com.ruoyi.dataInterchange.util.haikang.model.SubscriptionEvent; import com.ruoyi.dataInterchange.util.jtt809.common.Jtt809Util; import com.ruoyi.dataInterchange.util.jtt809.packet.common.OuterPacket; import io.netty.buffer.ByteBuf; @@ -16,11 +21,15 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Component; +import org.springframework.util.StringUtils; import javax.annotation.Resource; import java.time.LocalDateTime; import java.time.ZoneOffset; +import java.time.format.DateTimeFormatter; +import java.util.Arrays; import java.util.List; +import java.util.StringJoiner; /** * @author zhibing.pu @@ -40,15 +49,25 @@ private UPWarnMsgAdptInfoDao upWarnMsgAdptInfoDao; @Resource + private UPWarnMsgOperationInfoDao upWarnMsgOperationInfoDao; + + @Resource + private UpWarnMsgFileListAckDao upWarnMsgFileListAckDao; + + @Resource private RedisTemplate redisTemplate; @Resource private UPExgMsgRealLocationDao upExgMsgRealLocationDao; + //走川标的公司 + private List<Integer> enterprise = Arrays.asList(17458936, 43984060, 13914394); + //固定报警类型 + private List<Integer> warnType = Arrays.asList(0x0201, 0x0202, 0x0301, 0x000B, 0x0012, 0x0203, 0x0208, 0x0002, 0x0211, 0x0212, 0x0214, 0x0213, 0x0215, 0x0217, 0x0307); public void up_warn_msg(ChannelHandlerContext ctx, OuterPacket out) { if (!redisTemplate.hasKey("login:" + out.getGnsscenterId())) { - log.error("链路还未登录校验,拒绝连接"); + log.error("链路还未登录校验,拒绝连接:{}", out.getGnsscenterId()); ctx.close(); return; } @@ -63,11 +82,18 @@ log.info("上报报警信息({}):{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), out); up_warn_msg_adpt_info(ctx, out.getGnsscenterId(), warnMsg); break; + case UP_WARN_MSG_OPERATION_INFO: + log.info("上报报警处理信息({}):{}", DataType.UP_WARN_MSG_OPERATION_INFO.getCode(), out); + up_warn_msg_operation_info(ctx, out.getGnsscenterId(), warnMsg); + break; + case UP_WARN_MSG_FILELIST_ACK: + log.info("报警附件目录请求应答({}):{}", DataType.UP_WARN_MSG_FILELIST_ACK.getCode(), out); + up_warn_msg_filelist_ack(ctx, out.getGnsscenterId(), warnMsg); + break; default: break; } } - /** * 解析子业务数据 @@ -97,8 +123,7 @@ warnMsg.setData(data); return warnMsg; } - - + /** * 报警督办应答消息 * @@ -112,7 +137,7 @@ upWarnMsgUrgeTodoAck.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8))); upWarnMsgUrgeTodoAckDao.save(upWarnMsgUrgeTodoAck); } - + /** * 上报报警信息 * @@ -121,27 +146,147 @@ * @param warnMsg */ public void up_warn_msg_adpt_info(ChannelHandlerContext ctx, int inferiorPlatformId, WarnMsg warnMsg) { - UPWarnMsgAdptInfo upWarnMsgAdptInfo = new UPWarnMsgAdptInfo().decode(warnMsg); + UPWarnMsgAdptInfo upWarnMsgAdptInfo = enterprise.contains(inferiorPlatformId) ? new UPWarnMsgAdptInfo().decode2(warnMsg) : new UPWarnMsgAdptInfo().decode1(warnMsg); + if(!warnType.contains(upWarnMsgAdptInfo.getWarnType())){ + return; + } upWarnMsgAdptInfo.setResult(0x00); upWarnMsgAdptInfo.setInferiorPlatformId(inferiorPlatformId); upWarnMsgAdptInfo.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8))); - UPExgMsgRealLocation upExgMsgRealLocation = upExgMsgRealLocationDao.findByVehicleNoOrderByCreateTimeDesc(upWarnMsgAdptInfo.getVehicleNo()); - if (null != upExgMsgRealLocation) { - GnssData gnssData = upExgMsgRealLocation.getGnssData(); - upWarnMsgAdptInfo.setSpeed(gnssData.getVec1()); - upWarnMsgAdptInfo.setLongitude(gnssData.getLon()); - upWarnMsgAdptInfo.setLatitude(gnssData.getLat()); + if(0 == upWarnMsgAdptInfo.getLongitude()){ + UPExgMsgRealLocation upExgMsgRealLocation = upExgMsgRealLocationDao.findByVehicleNoOrderByCreateTimeDesc(upWarnMsgAdptInfo.getVehicleNo()); + if (null != upExgMsgRealLocation) { + GnssData gnssData = upExgMsgRealLocation.getGnssData(); + upWarnMsgAdptInfo.setSpeed(gnssData.getVec1()); + upWarnMsgAdptInfo.setLongitude(gnssData.getLon()); + upWarnMsgAdptInfo.setLatitude(gnssData.getLat()); + } + } + upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo); + + //请求报警附件(川标协议) + if(enterprise.contains(inferiorPlatformId)){ + DOWNWarnMsgFileListReq downWarnMsgFileListReq = new DOWNWarnMsgFileListReq(); + downWarnMsgFileListReq.setVehicleNo(upWarnMsgAdptInfo.getVehicleNo()); + downWarnMsgFileListReq.setVehicleColor(upWarnMsgAdptInfo.getVehicleColor()); + downWarnMsgFileListReq.setDataType(DataType.DOWN_WARN_MSG_FILELIST_REQ.getCode()); + downWarnMsgFileListReq.setDataLength(32); + downWarnMsgFileListReq.setInfoId(upWarnMsgAdptInfo.getInfoId()); + byte[] body = downWarnMsgFileListReq.encode(); + OuterPacket out = new OuterPacket(DataType.DOWN_WARN_MSG.getCode(), inferiorPlatformId, body); + //获取从链路通道 + Channel channel = ChannelMap.getClientChannel(inferiorPlatformId); + if (null != channel && channel.isActive()) { + channel.writeAndFlush(out); + log.info("报警附件目录请求({}):{}", DataType.DOWN_WARN_MSG_FILELIST_REQ.getCode(), JSON.toJSONString(downWarnMsgFileListReq)); + } + } + } + + + /** + * 上报报警处理信息 + * @param ctx + * @param inferiorPlatformId + * @param warnMsg + */ + public void up_warn_msg_operation_info(ChannelHandlerContext ctx, int inferiorPlatformId, WarnMsg warnMsg) { + UPWarnMsgOperationInfo upWarnMsgOperationInfo = new UPWarnMsgOperationInfo().decode(warnMsg); + upWarnMsgOperationInfo.setInferiorPlatformId(inferiorPlatformId); + upWarnMsgOperationInfo.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8))); + upWarnMsgOperationInfoDao.save(upWarnMsgOperationInfo); + //修改报警处理结果 + UPWarnMsgAdptInfo upWarnMsgAdptInfo = upWarnMsgAdptInfoDao.findByInfoIdIs(upWarnMsgOperationInfo.getInfoId()); + if(null != upWarnMsgAdptInfo){ + upWarnMsgAdptInfo.setResult(upWarnMsgOperationInfo.getResult()); + upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo); + } + } + + + /** + * 报警附件目录请求应答 + * @param ctx + * @param inferiorPlatformId + * @param warnMsg + */ + public void up_warn_msg_filelist_ack(ChannelHandlerContext ctx, int inferiorPlatformId, WarnMsg warnMsg){ + UpWarnMsgFileListAck upWarnMsgFileListAck = new UpWarnMsgFileListAck().decode(warnMsg).decode(warnMsg); + upWarnMsgFileListAck.setInferiorPlatformId(inferiorPlatformId); + upWarnMsgFileListAck.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8))); + upWarnMsgFileListAckDao.save(upWarnMsgFileListAck); + //修改报警附件数据 + UPWarnMsgAdptInfo upWarnMsgAdptInfo = upWarnMsgAdptInfoDao.findByInfoIdIs(upWarnMsgFileListAck.getInfoId()); + if(upWarnMsgFileListAck.getFileList().size() > 0){ + StringJoiner joiner = new StringJoiner(","); + upWarnMsgFileListAck.getFileList().forEach(file->{ + if(file.getFileType() == 0x00){ + joiner.add(file.getFileUrl()); + } + }); + upWarnMsgAdptInfo.setPicUrl(joiner.toString()); + }else{ + upWarnMsgAdptInfo.setPicUrl("*"); } upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo); } + /** - * 定时任务督办报警请求 + * 定时任务督办报警请求和附件请求 */ public void taskUrgeTodo() { - List<UPWarnMsgAdptInfo> list = upWarnMsgAdptInfoDao.findByResultIsAndPushTimeBefore(0x00, LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8))); + List<UPWarnMsgAdptInfo> list = upWarnMsgAdptInfoDao.findByResultIsAndLevelNotNullAndPushTimeBefore(0x00, LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8))); for (UPWarnMsgAdptInfo upWarnMsgAdptInfo : list) { + Integer inferiorPlatformId = upWarnMsgAdptInfo.getInferiorPlatformId(); + //海康威视直接走接口 + if(25439966 == inferiorPlatformId){ + try { + if(!StringUtils.hasLength(upWarnMsgAdptInfo.getPicUrl())){ + FindPicturesByAlarmIdRequest findPicturesByAlarmIdRequest = new FindPicturesByAlarmIdRequest(); + findPicturesByAlarmIdRequest.setAlarmId(upWarnMsgAdptInfo.getInfoId()); + long warnTime = upWarnMsgAdptInfo.getWarnTime(); + String format = LocalDateTime.ofEpochSecond(warnTime, 0, ZoneOffset.ofHours(8)).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS")); + format = format.replace(" ", "T") + "+08:00"; + findPicturesByAlarmIdRequest.setAlarmTime(format); + String pictures = Artemis.findPicturesByAlarmId(findPicturesByAlarmIdRequest); + JSONObject jsonObject = JSONObject.parseObject(pictures); + Integer code = jsonObject.getInteger("code"); + if(0 == code){ + JSONArray data = jsonObject.getJSONArray("data"); + StringJoiner joiner = new StringJoiner(","); + for (int i = 0; i < data.size(); i++) { + JSONObject jsonObject1 = data.getJSONObject(0); + String url = jsonObject1.getString("url"); + joiner.add(url); + } + upWarnMsgAdptInfo.setPicUrl(joiner.length() > 0 ? joiner.toString() : "*"); + upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo); + } + } + }catch (Exception e){ + e.printStackTrace(); + } + } + //请求报警附件(川标协议) + if(enterprise.contains(inferiorPlatformId) && !StringUtils.hasLength(upWarnMsgAdptInfo.getPicUrl())){ + DOWNWarnMsgFileListReq downWarnMsgFileListReq = new DOWNWarnMsgFileListReq(); + downWarnMsgFileListReq.setVehicleNo(upWarnMsgAdptInfo.getVehicleNo()); + downWarnMsgFileListReq.setVehicleColor(upWarnMsgAdptInfo.getVehicleColor()); + downWarnMsgFileListReq.setDataType(DataType.DOWN_WARN_MSG_FILELIST_REQ.getCode()); + downWarnMsgFileListReq.setDataLength(32); + downWarnMsgFileListReq.setInfoId(upWarnMsgAdptInfo.getInfoId()); + byte[] body = downWarnMsgFileListReq.encode(); + OuterPacket out = new OuterPacket(DataType.DOWN_WARN_MSG.getCode(), inferiorPlatformId, body); + //获取从链路通道 + Channel channel = ChannelMap.getClientChannel(inferiorPlatformId); + if (null != channel && channel.isActive()) { + channel.writeAndFlush(out); + log.info("报警附件目录请求({}):{}", DataType.DOWN_WARN_MSG_FILELIST_REQ.getCode(), JSON.toJSONString(downWarnMsgFileListReq)); + } + } + down_warn_msg_urge_todo_req(upWarnMsgAdptInfo); } } @@ -152,7 +297,7 @@ */ public void down_warn_msg_urge_todo_req(UPWarnMsgAdptInfo upWarnMsgAdptInfo) { if (!redisTemplate.hasKey("login:" + upWarnMsgAdptInfo.getInferiorPlatformId())) { - log.error("链路还未登录校验,拒绝连接"); + log.error("链路还未登录校验,拒绝连接:{}", upWarnMsgAdptInfo.getInferiorPlatformId()); return; } int inferiorPlatformId = upWarnMsgAdptInfo.getInferiorPlatformId(); @@ -170,4 +315,269 @@ upWarnMsgAdptInfo.setPushTime(LocalDateTime.now().plusDays(7).toEpochSecond(ZoneOffset.ofHours(8))); upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo); } + + + /** + * 存储mqtt协议报警信息 + */ + public void saveWarnMsgService(JSONObject jsonObject) { + SubscriptionEvent subscriptionEvent = jsonObject.getObject("params", SubscriptionEvent.class); + List<Event> events = subscriptionEvent.getEvents(); + if(null != events){ + events.forEach(event -> { + try { + //车牌号 + String srcName = event.getSrcName(); + Alarm data = JSONObject.parseObject(event.getData(), Alarm.class); + if(!StringUtils.hasLength(data.getAlarmId())){ + return; + } + UPWarnMsgAdptInfo upWarnMsgAdptInfo = upWarnMsgAdptInfoDao.findByInfoIdIs(data.getAlarmId()); + if(null == upWarnMsgAdptInfo){ + upWarnMsgAdptInfo = new UPWarnMsgAdptInfo(); + } + upWarnMsgAdptInfo.setVehicleNo(srcName); + upWarnMsgAdptInfo.setVehicleColor(null == data.getVehicleLicenseColor() ? 0 : data.getVehicleLicenseColor()); + upWarnMsgAdptInfo.setWarnSrc(data.getSourceType() + 1); + upWarnMsgAdptInfo.setWarnType(getAlarmType(data.getEventType())); + if(null != data.getAlarmTime()){ + upWarnMsgAdptInfo.setWarnTime(LocalDateTime.parse(data.getAlarmTime(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")).toEpochSecond(ZoneOffset.ofHours(8))); + } + upWarnMsgAdptInfo.setInfoId(data.getAlarmId()); + upWarnMsgAdptInfo.setLevel(getLevel(data.getLevel())); +// if(null != data.getLatitude()){ +// upWarnMsgAdptInfo.setLongitude(data.getLatitude().intValue() * 10); +// } +// if(null != data.getLongitude()){ +// upWarnMsgAdptInfo.setLatitude(data.getLongitude().intValue()); +// } + //调用获取实时定位数据 + UPExgMsgRealLocation upExgMsgRealLocation = upExgMsgRealLocationDao.findByVehicleNoOrderByCreateTimeDesc(upWarnMsgAdptInfo.getVehicleNo()); + if (null != upExgMsgRealLocation) { + GnssData gnssData = upExgMsgRealLocation.getGnssData(); + upWarnMsgAdptInfo.setSpeed(gnssData.getVec1()); + upWarnMsgAdptInfo.setLongitude(gnssData.getLon()); + upWarnMsgAdptInfo.setLatitude(gnssData.getLat()); + } + if(null != data.getHeight()){ + upWarnMsgAdptInfo.setAltitude(data.getHeight().intValue() / 10); + } + if(null != data.getSpeed()){ + upWarnMsgAdptInfo.setSpeed(data.getSpeed().intValue() / 100000); + } + if(null != data.getSpeed()){ + upWarnMsgAdptInfo.setVec2(data.getSpeed().intValue() / 100000); + } + upWarnMsgAdptInfo.setStatus(data.getStatus()); + if(null != data.getDirection()){ + upWarnMsgAdptInfo.setDirection(data.getDirection() / 100); + } + upWarnMsgAdptInfo.setInfoContent(data.getAlarmInfo()); + upWarnMsgAdptInfo.setInferiorPlatformId(25439966); + upWarnMsgAdptInfo.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8))); + if(!warnType.contains(upWarnMsgAdptInfo.getWarnType())){ + return; + } + upWarnMsgAdptInfo.setResult(0x00); + + //获取报警抓拍图片 + if(data.getPicNum() > 0){ + FindPicturesByAlarmIdRequest findPicturesByAlarmIdRequest = new FindPicturesByAlarmIdRequest(); + findPicturesByAlarmIdRequest.setAlarmId(data.getAlarmId()); + long warnTime = upWarnMsgAdptInfo.getWarnTime(); + String format = LocalDateTime.ofEpochSecond(warnTime, 0, ZoneOffset.ofHours(8)).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS")); + format = format.replace(" ", "T") + "+08:00"; + findPicturesByAlarmIdRequest.setAlarmTime(format); + String pictures = Artemis.findPicturesByAlarmId(findPicturesByAlarmIdRequest); + JSONObject jsonObject1 = JSONObject.parseObject(pictures); + Integer code = jsonObject1.getInteger("code"); + if(0 == code){ + JSONArray data1 = jsonObject1.getJSONArray("data"); + StringJoiner joiner = new StringJoiner(","); + for (int i = 0; i < data1.size(); i++) { + JSONObject jsonObject2 = data1.getJSONObject(0); + String url = jsonObject2.getString("url"); + joiner.add(url); + } + upWarnMsgAdptInfo.setPicUrl(joiner.toString()); + } + }else{ + upWarnMsgAdptInfo.setPicUrl("*"); + } + upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo); + + }catch (Exception e){ + e.printStackTrace(); + } + }); + } + } + + public int getAlarmType(long eventType){ + switch ((int) eventType){ + case 0x00020501: + return 0x0301; + case 0x00020502: + return 0x0201; + case 0x00020503: + return 0x0202; + case 0x00020504: + return 0x0202; + case 0x00020505: + return 0x0202; + case 0x00020506: + return 0x0202; + case 0x00020507: + return 0x0203; + case 0x00020508: + return 0x0203; + case 0x00020509: + return 0x0204; + case 0x00020510: + return 0x0204; + case 0x00037017: + return 0x00FF; + case 0x00020511: + return 0x00FF; + case 0x00037005: + return 0x00FF; + case 0x00020512: + return 0x0002; + case 0x00020513: + return 0x0002; + case 0x00020514: + return 0x00FF; + case 0x00020515: + return 0x00FF; + case 0x00020516: + return 0x0214; + case 0x00020517: + return 0x0213; + case 0x00020519: + return 0x0215; + case 0x00020520: + return 0x0234; + case 0x00020521: + return 0x0234; + case 0x00020522: + return 0x0234; + case 0x00020523: + return 0x0241; + case 0x00020524: + return 0x0242; + case 0x00020525: + return 0x0243; + case 0x00020526: + return 0x0243; + case 0x00020531: + return 0x00FF; + case 0x00020532: + return 0x00FF; + case 0x00020533: + return 0x00FF; + case 0x00020534: + return 0x0218; + case 0x00020518: + return 0xA0FF; + case 0x00037001: + return 0xA0FF; + case 0x00037002: + return 0x0216; + case 0x00037006: + return 0x0216; + case 0x00020535: + return 0x0001; + case 0x00020536: + return 0x0001; + case 0x00020537: + return 0x000D; + case 0x00020102: + return 0x0102; + case 0x00020538: + return 0x0005; + case 0x00020539: + return 0x0004; + case 0x00020540: + return 0x0304; + case 0x00020541: + return 0x0304; + case 0x00020542: + return 0x000B; + case 0x00020543: + return 0x0001; + case 0x00020544: + return 0x0001; + case 0x00020545: + return 0xA001; + case 0x00020546: + return 0x0305; + case 0x00020547: + return 0x0305; + case 0x00020548: + return 0xA0FF; + case 0x00010202: + return 0x0103; + case 0x00010206: + return 0x0103; + case 0x00020101: + return 0x0101; + case 0x00020103: + return 0x000C; + case 0x00020549: + return 0xA00A; + case 0x00020550: + return 0xA00A; + case 0x00020551: + return 0xA00A; + case 0x00020552: + return 0x0308; + case 0x00020553: + return 0x0308; + case 0x00020554: + return 0x0308; + case 0x00020555: + return 0x0308; + case 0x00020556: + return 0x0308; + case 0x00020557: + return 0x0308; + case 0x00020558: + return 0x0308; + case 0x00020559: + return 0x0003; + case 0x00020527: + return 0x0301; + case 0x00020528: + return 0x0201; + case 0x00020529: + return 0x0302; + case 0x00020530: + return 0x0302; + case 0x00020560: + return 0x0009; + case 0x00020561: + return 0x0306; + case 0x00020562: + return 0x0307; + case 0x00090001: + return 0x00FF; + default: + return 0x00FF; + } + } + + public int getLevel(String level){ + switch (level){ + case "h": + case "m": + return 1; + case "l": + case "w": + return 2; + default: + return 0; + } + } + + } -- Gitblit v1.7.1