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