diff --git a/tongran-api/tongran-api-system/src/main/java/com/tongran/system/api/domain/RmResourceRegistrationRemote.java b/tongran-api/tongran-api-system/src/main/java/com/tongran/system/api/domain/RmResourceRegistrationRemote.java index ad674e0..bc34781 100644 --- a/tongran-api/tongran-api-system/src/main/java/com/tongran/system/api/domain/RmResourceRegistrationRemote.java +++ b/tongran-api/tongran-api-system/src/main/java/com/tongran/system/api/domain/RmResourceRegistrationRemote.java @@ -189,5 +189,7 @@ public class RmResourceRegistrationRemote extends BaseEntity private String frpcServerAddr; /** 出省流量占比 */ private BigDecimal outboundRate; + /** 公网ip */ + private String ip1PublicIp; } diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmResourceRegistrationServiceImpl.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmResourceRegistrationServiceImpl.java index 16e7b1b..1257701 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmResourceRegistrationServiceImpl.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/RmResourceRegistrationServiceImpl.java @@ -279,9 +279,11 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio // 优化检查顺序,先检查最可能匹配的字段 String clientId = item.getClientId(); String hardwareSn = item.getHardwareSn(); + String remark = item.getRemark(); if ((clientId != null && clientId.toLowerCase().contains(queryValue)) || - (hardwareSn != null && hardwareSn.toLowerCase().contains(queryValue))) { + (hardwareSn != null && hardwareSn.toLowerCase().contains(queryValue)) || + (remark != null && remark.toLowerCase().contains(queryValue))) { return true; } diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java index 1bfca1c..26fdb61 100644 --- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/handler/MessageHandler.java @@ -1697,28 +1697,15 @@ public class MessageHandler { rmAlarmLog.setAlarmType("2"); alarmContent = switchName + "下线"; } else { - // 查询管理网公网ip - RmNetworkInterface rmNetworkInterface = new RmNetworkInterface(); - rmNetworkInterface.setClientId(clientId); - rmNetworkInterface.setNewFlag(1); - List interfaceList = rmNetworkInterfaceService.selectRmNetworkInterfaceList(rmNetworkInterface); - if (interfaceList != null && !interfaceList.isEmpty()) { - interfaceList.stream() - .filter(info -> "2".equals(info.getBindIp()) || "3".equals(info.getBindIp())) - .findFirst() - .ifPresent(networkInterface -> { - rmAlarmLog.setMgmPublicIp(networkInterface.getPublicIp()); - }); - } - // 查询业务名称 + // 查询服务器信息 RmResourceRegistrationRemote query = new RmResourceRegistrationRemote(); query.setClientId(clientId); - R registrationR = remoteRevenueConfigService.getListByHardwareSn(query, SecurityConstants.INNER); - if(registrationR != null){ - RmResourceRegistrationRemote registrationMsg = registrationR.getData(); - if(registrationMsg != null){ - rmAlarmLog.setBusinessName(registrationMsg.getBusinessName()); - } + R registerMsgR = remoteRevenueConfigService.getListByHardwareSn(query, SecurityConstants.INNER); + if(registerMsgR != null && registerMsgR.getData() != null){ + RmResourceRegistrationRemote serverMsg = registerMsgR.getData(); + rmAlarmLog.setMgmPublicIp(serverMsg.getIp1PublicIp()); + rmAlarmLog.setBusinessName(serverMsg.getBusinessName()); + rmAlarmLog.setRemark(serverMsg.getRemark()); } rmAlarmLog.setClientId(clientId); rmAlarmLog.setAlarmType("1"); diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/utils/SendAlarmPushUtil.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/utils/SendAlarmPushUtil.java index 0c01cf8..1d97c91 100644 --- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/utils/SendAlarmPushUtil.java +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/utils/SendAlarmPushUtil.java @@ -1,12 +1,14 @@ package com.tongran.rocketmq.utils; +import com.tongran.common.core.constant.SecurityConstants; +import com.tongran.common.core.domain.R; import com.tongran.rocketmq.domain.RmAlarmLog; import com.tongran.rocketmq.domain.RmAlarmPushConfig; -import com.tongran.rocketmq.domain.RmNetworkInterface; import com.tongran.rocketmq.enums.PushMethodEnum; import com.tongran.rocketmq.service.IRmAlarmLogService; import com.tongran.rocketmq.service.IRmAlarmPushConfigService; -import com.tongran.rocketmq.service.IRmNetworkInterfaceService; +import com.tongran.system.api.RemoteRevenueConfigService; +import com.tongran.system.api.domain.RmResourceRegistrationRemote; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -25,7 +27,7 @@ public class SendAlarmPushUtil { @Autowired private IRmAlarmPushConfigService rmAlarmPushConfigService; @Autowired - private IRmNetworkInterfaceService rmNetworkInterfaceService; + private RemoteRevenueConfigService remoteRevenueConfigService; @Autowired private SmsAlarmUtil smsAlarmUtil; /** @@ -42,18 +44,15 @@ public class SendAlarmPushUtil { updateData.setId(rmAlarmLog.getId()); if (alarmConfigList != null && !alarmConfigList.isEmpty()) { try { - // 查询管理网公网ip - RmNetworkInterface rmNetworkInterface = new RmNetworkInterface(); - rmNetworkInterface.setClientId(rmAlarmLog.getClientId()); - rmNetworkInterface.setNewFlag(1); - List interfaceList = rmNetworkInterfaceService.selectRmNetworkInterfaceList(rmNetworkInterface); - if (interfaceList != null && !interfaceList.isEmpty()) { - interfaceList.stream() - .filter(info -> "2".equals(info.getBindIp()) || "3".equals(info.getBindIp())) - .findFirst() - .ifPresent(networkInterface -> { - rmAlarmLog.setMgmPublicIp(networkInterface.getPublicIp()); - }); + // 查询服务器信息 + RmResourceRegistrationRemote query = new RmResourceRegistrationRemote(); + query.setClientId(clientId); + R registerMsgR = remoteRevenueConfigService.getListByHardwareSn(query, SecurityConstants.INNER); + if(registerMsgR != null && registerMsgR.getData() != null){ + RmResourceRegistrationRemote serverMsg = registerMsgR.getData(); + rmAlarmLog.setMgmPublicIp(serverMsg.getIp1PublicIp()); + rmAlarmLog.setBusinessName(serverMsg.getBusinessName()); + rmAlarmLog.setRemark(serverMsg.getRemark()); } Map alarmMap = new HashMap<>(); alarmMap.put("告警时间", rmAlarmLog.getAlarmTime()); @@ -61,6 +60,8 @@ public class SendAlarmPushUtil { alarmMap.put("告警类型", alarmTypeMsg); alarmMap.put("告警设备", clientId.substring(clientId.length() - 8)); alarmMap.put("告警内容", rmAlarmLog.getAlarmContent()); + alarmMap.put("标签", rmAlarmLog.getRemark()); + alarmMap.put("业务名称", rmAlarmLog.getBusinessName()); for (RmAlarmPushConfig alarmPushConfig : alarmConfigList) { if(PushMethodEnum.企业微信.getCode().equals(alarmPushConfig.getPushMethod())){ updateData.setPushFlag(processWeComPush(alarmPushConfig, alarmMap)); @@ -89,7 +90,7 @@ public class SendAlarmPushUtil { String webhookUrl = alarmPushConfig.getPushAddress(); if (alarmPushConfig.getContactPhones() != null) { String[] phones = alarmPushConfig.getContactPhones().split(","); - WeChatWorkBot.sendTemplateMessage(webhookUrl, contentTemplate, alarmMap, alarmMap.get("告警内容"), phones, false); + WeChatWorkBot.sendTemplateMessage(webhookUrl, contentTemplate, alarmMap, "", phones, false); } else { WeChatWorkBot.sendTemplateMessage(webhookUrl, contentTemplate, alarmMap); } diff --git a/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml b/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml index 9f9392e..a4cc8b6 100644 --- a/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml +++ b/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml @@ -1,7 +1,7 @@ + PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> @@ -13,6 +13,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + @@ -20,7 +21,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - select id, client_id, alarm_time, mgm_public_ip, alarm_type, alarm_content, business_name, push_flag, create_time, update_time, create_by, update_by from rm_alarm_log + select id, client_id, alarm_time, mgm_public_ip, alarm_type, alarm_content, business_name, push_flag, remark, create_time, update_time, create_by, update_by from rm_alarm_log - +