From 8ea377e0c6977ff0d97c4f2aa7986741600e4393 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期四, 07 八月 2025 13:57:39 +0800
Subject: [PATCH] 福临数据推送问题排查
---
ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/WarnMsgService.java | 83 +++++++++++++++++++++++++++++++++++------
1 files changed, 71 insertions(+), 12 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 1d3791a..767b71c 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
@@ -60,9 +60,17 @@
@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);
+ private List<Integer> enterprise = Arrays.asList(17458936,13914394,43984060,25439966);
+ //富临报警类型
+ private List<Integer> fl_warnType = Arrays.asList(0x0201, 0x0012, 0x0202, 0x0203, 0x0208, 0x0002, 0x0212, 0x0214, 0x0213, 0x0215, 0x0217);
+ //均辉报警类型
+ private List<Integer> jh_warnType = Arrays.asList(0x0201, 0x0012, 0x0202, 0x0203, 0x0208, 0x0002, 0x0212, 0x0214, 0x0213, 0x0215, 0x0217, 0x0307);
+ //出租车报警类型
+ private List<Integer> cz_warnType = Arrays.asList(0x0001, 0x0004, 0x0005);
+ //公交报警类型
+ private List<Integer> gj_warnType = Arrays.asList(0x0002, 0x0212, 0x0214, 0x0213, 0x0215, 0x0217, 0x0001);
+ //平安报警类型
+ private List<Integer> pa_warnType = Arrays.asList(0x0201, 0x0012, 0x0202, 0x0208, 0x0002, 0x0212, 0x0214, 0x0213, 0x0215, 0x0217, 0x0307);
public void up_warn_msg(ChannelHandlerContext ctx, OuterPacket out) {
@@ -75,7 +83,7 @@
DataType dataType = DataType.getDataType(warnMsg.getDataType());
switch (dataType) {
case UP_WARN_MSG_URGE_TODO_ACK:
- log.info("报警督办应答消息({})：{}", DataType.UP_WARN_MSG_URGE_TODO_ACK.getCode(), out);
+ log.debug("报警督办应答消息({})：{}", DataType.UP_WARN_MSG_URGE_TODO_ACK.getCode(), out);
up_warn_msg_urge_todo_ack(ctx, out.getGnsscenterId(), warnMsg);
break;
case UP_WARN_MSG_ADPT_INFO:
@@ -83,11 +91,11 @@
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);
+ log.debug("上报报警处理信息({})：{}", 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);
+ log.debug("报警附件目录请求应答({})：{}", DataType.UP_WARN_MSG_FILELIST_ACK.getCode(), out);
up_warn_msg_filelist_ack(ctx, out.getGnsscenterId(), warnMsg);
break;
default:
@@ -136,6 +144,7 @@
upWarnMsgUrgeTodoAck.setInferiorPlatformId(inferiorPlatformId);
upWarnMsgUrgeTodoAck.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8)));
upWarnMsgUrgeTodoAckDao.save(upWarnMsgUrgeTodoAck);
+ log.info("报警督办应答消息({})：{}", DataType.UP_WARN_MSG_URGE_TODO_ACK.getCode(), JSON.toJSONString(upWarnMsgUrgeTodoAck));
}
/**
@@ -146,14 +155,54 @@
* @param warnMsg
*/
public void up_warn_msg_adpt_info(ChannelHandlerContext ctx, int inferiorPlatformId, WarnMsg warnMsg) {
+ log.info("上报报警信息cz0({})：{}",inferiorPlatformId,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)));
+ log.info("上报报警信息cz1({})：{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo));
+ switch (inferiorPlatformId) {
+ case 17458936:
+
+ if(!fl_warnType.contains(upWarnMsgAdptInfo.getWarnType())){
+ return;
+ }
+ break;
+ case 43984060:
+ if(!jh_warnType.contains(upWarnMsgAdptInfo.getWarnType())){
+ return;
+ }
+ break;
+ case 17235341:
+ log.info("上报报警信息cz88888({})：{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType());
+ if(!cz_warnType.contains(upWarnMsgAdptInfo.getWarnType())){
+ log.info("上报报警信息czcontains({})：{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType());
+ return;
+ }
+ break;
+ case 82296583:
+ log.info("上报报警信息cz88888({})：{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType());
+ if(!cz_warnType.contains(upWarnMsgAdptInfo.getWarnType())){
+ log.info("上报报警信息czcontains({})：{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType());
+
+ return;
+ }
+ break;
+ case 25439966:
+ if(!gj_warnType.contains(upWarnMsgAdptInfo.getWarnType())){
+ return;
+ }
+ break;
+ case 13914394:
+ if(!pa_warnType.contains(upWarnMsgAdptInfo.getWarnType())){
+ return;
+ }
+ break;
+ }
+ log.info("上报报警信息555555({})：{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType());
+ try {
if(0 == upWarnMsgAdptInfo.getLongitude()){
+ log.info("上报报警信息6666666({})：{}:{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo),upWarnMsgAdptInfo.getWarnType());
UPExgMsgRealLocation upExgMsgRealLocation = upExgMsgRealLocationDao.findByVehicleNoOrderByCreateTimeDesc(upWarnMsgAdptInfo.getVehicleNo());
if (null != upExgMsgRealLocation) {
GnssData gnssData = upExgMsgRealLocation.getGnssData();
@@ -162,7 +211,15 @@
upWarnMsgAdptInfo.setLatitude(gnssData.getLat());
}
}
- upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo);
+ log.info("上报报警信息333333");
+
+ upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo);
+ }catch (Exception e){
+ e.printStackTrace();
+ log.info("上报报警信息保存失败{}",e.getMessage());
+ }
+
+ log.info("上报报警信息2({})：{}", DataType.UP_WARN_MSG_ADPT_INFO.getCode(), JSON.toJSONString(upWarnMsgAdptInfo));
//请求报警附件（川标协议）
if(enterprise.contains(inferiorPlatformId)){
@@ -195,6 +252,7 @@
upWarnMsgOperationInfo.setInferiorPlatformId(inferiorPlatformId);
upWarnMsgOperationInfo.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8)));
upWarnMsgOperationInfoDao.save(upWarnMsgOperationInfo);
+ log.info("上报报警处理信息({})：{}", DataType.UP_WARN_MSG_OPERATION_INFO.getCode(), JSON.toJSONString(upWarnMsgOperationInfo));
//修改报警处理结果
UPWarnMsgAdptInfo upWarnMsgAdptInfo = upWarnMsgAdptInfoDao.findByInfoIdIs(upWarnMsgOperationInfo.getInfoId());
if(null != upWarnMsgAdptInfo){
@@ -215,6 +273,7 @@
upWarnMsgFileListAck.setInferiorPlatformId(inferiorPlatformId);
upWarnMsgFileListAck.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8)));
upWarnMsgFileListAckDao.save(upWarnMsgFileListAck);
+ log.info("报警附件目录请求应答({})：{}", DataType.UP_WARN_MSG_FILELIST_ACK.getCode(), JSON.toJSONString(upWarnMsgFileListAck));
//修改报警附件数据
UPWarnMsgAdptInfo upWarnMsgAdptInfo = upWarnMsgAdptInfoDao.findByInfoIdIs(upWarnMsgFileListAck.getInfoId());
if(upWarnMsgFileListAck.getFileList().size() > 0){
@@ -287,7 +346,7 @@
}
}
- down_warn_msg_urge_todo_req(upWarnMsgAdptInfo);
+// down_warn_msg_urge_todo_req(upWarnMsgAdptInfo);
}
}
@@ -377,7 +436,7 @@
upWarnMsgAdptInfo.setInfoContent(data.getAlarmInfo());
upWarnMsgAdptInfo.setInferiorPlatformId(25439966);
upWarnMsgAdptInfo.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8)));
- if(!warnType.contains(upWarnMsgAdptInfo.getWarnType())){
+ if(!gj_warnType.contains(upWarnMsgAdptInfo.getWarnType())){
return;
}
upWarnMsgAdptInfo.setResult(0x00);
--
Gitblit v1.7.1