From b554a106bc1b06e0320b642d16c31554ae558301 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 03 六月 2025 17:28:11 +0800
Subject: [PATCH] 新增加川标报警处理结果

---
 ruoyi-service/ruoyi-dataInterchange/src/main/java/com/ruoyi/dataInterchange/server/WarnMsgService.java |   26 ++++++++++++++++++++++++++
 1 files changed, 26 insertions(+), 0 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 b3872c8..50040d3 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
@@ -4,6 +4,7 @@
 import com.alibaba.fastjson2.JSONObject;
 import com.ruoyi.dataInterchange.dao.UPExgMsgRealLocationDao;
 import com.ruoyi.dataInterchange.dao.UPWarnMsgAdptInfoDao;
+import com.ruoyi.dataInterchange.dao.UPWarnMsgOperationInfoDao;
 import com.ruoyi.dataInterchange.dao.UPWarnMsgUrgeTodoAckDao;
 import com.ruoyi.dataInterchange.model.*;
 import com.ruoyi.dataInterchange.model.enu.DataType;
@@ -48,6 +49,9 @@
 	private UPWarnMsgAdptInfoDao upWarnMsgAdptInfoDao;
 	
 	@Resource
+	private UPWarnMsgOperationInfoDao upWarnMsgOperationInfoDao;
+	
+	@Resource
 	private RedisTemplate redisTemplate;
 	
 	@Resource
@@ -74,6 +78,10 @@
 			case UP_WARN_MSG_ADPT_INFO:
 				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;
 			default:
 				break;
@@ -152,6 +160,24 @@
 	
 	
 	/**
+	 * 上报报警处理信息
+	 * @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());
+		upWarnMsgAdptInfo.setResult(upWarnMsgOperationInfo.getResult());
+		upWarnMsgAdptInfoDao.save(upWarnMsgAdptInfo);
+	}
+	
+	
+	/**
 	 * 定时任务督办报警请求
 	 */
 	public void taskUrgeTodo() {

--
Gitblit v1.7.1