diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/TongRanMtragentApplication.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/TongRanMtragentApplication.java index f67aa9a..64b5af0 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/TongRanMtragentApplication.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/TongRanMtragentApplication.java @@ -20,6 +20,6 @@ public class TongRanMtragentApplication public static void main(String[] args) { SpringApplication.run(TongRanMtragentApplication.class, args); - System.out.println("(♥◠‿◠)ノ゙ RuoYiMtragent模块启动成功 ლ(´ڡ`ლ)゙"); + System.out.println("(♥◠‿◠)ノ゙ TongRanMtragent模块启动成功 ლ(´ڡ`ლ)゙"); } } diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/RmMtrPolicyConfig.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/RmMtrPolicyConfig.java index 7527749..a45d270 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/RmMtrPolicyConfig.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/domain/RmMtrPolicyConfig.java @@ -60,4 +60,6 @@ public class RmMtrPolicyConfig extends BaseEntity private Long probeFrequency; /** clientId和ip对应集合 */ private Map> clientIdToIpsMap; + /** 查询条件 */ + private String queryName; } diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/handler/MessageHandler.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/handler/MessageHandler.java index d91624b..534ea4e 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/handler/MessageHandler.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/handler/MessageHandler.java @@ -230,27 +230,28 @@ public class MessageHandler { RegisterMsgVo registerMsgVo = interfaces.get(0); String mtrClientId = registerMsgVo.getClientId(); List mtrPolicyConfigList = rmMtrPolicyConfigService.getPoliciesForMtrClient(mtrClientId); - if(mtrPolicyConfigList != null && !mtrPolicyConfigList.isEmpty()){ - // 构建mtrclient消息 - String mtrPolicyListStr = JSONObject.toJSONString(mtrPolicyConfigList); - PolicyTypeVo policyTypeVo = new PolicyTypeVo(); - policyTypeVo.setMtrPolicys(mtrPolicyListStr); - String configJson = JSONObject.toJSONString(policyTypeVo); - try { - DeviceMessage message = new DeviceMessage(); - message.setClientId(mtrClientId); - message.setData(configJson); - message.setDataType(MsgEnum.获取最新策略应答.getValue()); + if(mtrPolicyConfigList == null){ + mtrPolicyConfigList = new ArrayList<>(); + } + // 构建mtrclient消息 + String mtrPolicyListStr = JSONObject.toJSONString(mtrPolicyConfigList); + PolicyTypeVo policyTypeVo = new PolicyTypeVo(); + policyTypeVo.setMtrPolicys(mtrPolicyListStr); + String configJson = JSONObject.toJSONString(policyTypeVo); + try { + DeviceMessage message = new DeviceMessage(); + message.setClientId(mtrClientId); + message.setData(configJson); + message.setDataType(MsgEnum.获取最新策略应答.getValue()); - messageProducer.sendAsyncProducerMessage( - producerMode.getAgentTopic(), - "", - "", - JSONObject.toJSONString(message) - ); - } catch (Exception e) { - log.error("发送mtr策略失败,mtrClientId: {}", mtrClientId, e); - } + messageProducer.sendAsyncProducerMessage( + producerMode.getAgentTopic(), + "", + "", + JSONObject.toJSONString(message) + ); + } catch (Exception e) { + log.error("发送mtr策略失败,mtrClientId: {}", mtrClientId, e); } } } diff --git a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/impl/RmMtrPolicyConfigServiceImpl.java b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/impl/RmMtrPolicyConfigServiceImpl.java index ad1c0d8..88769aa 100644 --- a/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/impl/RmMtrPolicyConfigServiceImpl.java +++ b/tongran-modules/tongran-mtragent/src/main/java/com/tongran/mtragent/service/impl/RmMtrPolicyConfigServiceImpl.java @@ -189,9 +189,8 @@ public class RmMtrPolicyConfigServiceImpl implements IRmMtrPolicyConfigService return result; } - // 查询所有有效的策略(探测标志为1) + // 查询所有策略 RmMtrPolicyConfig query = new RmMtrPolicyConfig(); - query.setProbeFlag(1L); // 只查询启用探测的策略 List allPolicies = rmMtrPolicyConfigMapper.selectRmMtrPolicyConfigList(query); if (allPolicies == null || allPolicies.isEmpty()) { diff --git a/tongran-modules/tongran-mtragent/src/main/resources/bootstrap.yml b/tongran-modules/tongran-mtragent/src/main/resources/bootstrap.yml index 2b1b7dd..ab754f2 100644 --- a/tongran-modules/tongran-mtragent/src/main/resources/bootstrap.yml +++ b/tongran-modules/tongran-mtragent/src/main/resources/bootstrap.yml @@ -14,8 +14,7 @@ spring: nacos: discovery: # 服务注册地址 - server-addr: 172.16.15.52:8848 -# server-addr: 172.16.15.103:8848 + server-addr: ${spring.cloud.nacos.config.server-addr} namespace: ${spring.cloud.nacos.config.namespace} username: ${spring.cloud.nacos.config.username} password: ${spring.cloud.nacos.config.password} diff --git a/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmMtrPolicyConfigMapper.xml b/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmMtrPolicyConfigMapper.xml index a6d2309..422298e 100644 --- a/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmMtrPolicyConfigMapper.xml +++ b/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmMtrPolicyConfigMapper.xml @@ -37,6 +37,9 @@ and start_time = #{startTime} and end_time = #{endTime} and probe_frequency = #{probeFrequency} + and (policy_name like concat('%', #{queryName}, '%') + or mtr_client_id like concat('%', #{queryName}, '%') or server_group like concat('%', #{queryName}, '%') + ) diff --git a/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmNetworkInterfaceMapper.xml b/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmNetworkInterfaceMapper.xml index 48a60fd..da415f3 100644 --- a/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmNetworkInterfaceMapper.xml +++ b/tongran-modules/tongran-mtragent/src/main/resources/mapper/mtragent/RmNetworkInterfaceMapper.xml @@ -143,6 +143,6 @@ bind_ip = #{bindIp}, new_flag = #{newFlag}, - where mac_address = #{macAddress} and clientId = #{clientId} + where mac_address = #{macAddress} and client_id = #{clientId} \ No newline at end of file diff --git a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/SysMenuClickServiceImpl.java b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/SysMenuClickServiceImpl.java index a9bc357..b969dfe 100644 --- a/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/SysMenuClickServiceImpl.java +++ b/tongran-modules/tongran-system/src/main/java/com/tongran/system/service/impl/SysMenuClickServiceImpl.java @@ -68,7 +68,7 @@ public class SysMenuClickServiceImpl implements ISysMenuClickService * 获取当前用户有权限的菜单 */ private List getPermittedMenusForCurrentUser() { - // 使用Ruoyi的权限服务(推荐) + // 使用TongRan的权限服务(推荐) if (SecurityUtils.getLoginUser() != null) { Long userId = SecurityUtils.getUserId(); return sysMenuService.getMenuListByWelcome(userId); diff --git a/tongran-modules/tongran-system/src/main/resources/bootstrap.yml b/tongran-modules/tongran-system/src/main/resources/bootstrap.yml index ad5c2bf..d4eb062 100644 --- a/tongran-modules/tongran-system/src/main/resources/bootstrap.yml +++ b/tongran-modules/tongran-system/src/main/resources/bootstrap.yml @@ -18,11 +18,11 @@ spring: username: ${spring.cloud.nacos.config.username} password: ${spring.cloud.nacos.config.password} config: - server-addr: 172.16.15.52:8848 # 配置中心地址 + server-addr: 172.16.15.52:8848 # server-addr: 172.16.15.103:8848 -# namespace: public namespace: saas-local +# namespace: public username: nacos password: nacos # 配置文件格式 diff --git a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/RmAlarmLog.java b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/RmAlarmLog.java index 4b67179..5bb071d 100644 --- a/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/RmAlarmLog.java +++ b/tongran-rocketmq/src/main/java/com/tongran/rocketmq/domain/RmAlarmLog.java @@ -41,4 +41,11 @@ public class RmAlarmLog extends BaseEntity /** 告警内容 */ @Excel(name = "告警内容") private String alarmContent; + /** 业务名称 */ + @Excel(name = "业务名称") + private String businessName; + + /** 推送标志(0失败,1成功,3未配置消息推送机制) */ + @Excel(name = "推送标志", readConverterExp = "0=失败,1=成功,3=未配置消息推送机制") + private Long pushFlag; } 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 cd7c3ae..ecfe5aa 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 @@ -1198,6 +1198,10 @@ public class MessageHandler { rmAlarmLog.setMgmPublicIp(networkInterface.getPublicIp()); }); } + // 查询业务名称 + RmResourceRegistrationRemote query = new RmResourceRegistrationRemote(); + query.setClientId(clientId); + R registrationR = remoteRevenueConfigService.getListByHardwareSn(query, SecurityConstants.INNER); rmAlarmLog.setClientId(clientId); rmAlarmLog.setAlarmType("1"); } @@ -1283,7 +1287,7 @@ public class MessageHandler { if(businessScriptMsgR != null && businessScriptMsgR.getData() != null){ EpsBusinessScriptRemote businessScriptMsg = businessScriptMsgR.getData(); String failedKeywords = businessScriptMsg.getFailedKeywords(); - if(resOut.contains(failedKeywords)){ + if(failedKeywords != null && resOut.contains(failedKeywords)){ insertData.setResultFlag(0); }else { insertData.setResultFlag(1); diff --git a/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml b/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml index ed4032c..9f9392e 100644 --- a/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml +++ b/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml @@ -3,7 +3,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> - + @@ -11,6 +11,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + + @@ -18,17 +20,19 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - select id, client_id, alarm_time, mgm_public_ip, alarm_type, alarm_content, 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, create_time, update_time, create_by, update_by from rm_alarm_log @@ -46,47 +50,44 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" mgm_public_ip, alarm_type, alarm_content, + business_name, + push_flag, create_time, update_time, create_by, update_by, - + #{clientId}, #{alarmTime}, #{mgmPublicIp}, #{alarmType}, #{alarmContent}, + #{businessName}, + #{pushFlag}, #{createTime}, #{updateTime}, #{createBy}, #{updateBy}, - + update rm_alarm_log + client_id = #{clientId}, + alarm_time = #{alarmTime}, mgm_public_ip = #{mgmPublicIp}, + alarm_type = #{alarmType}, alarm_content = #{alarmContent}, + business_name = #{businessName}, + push_flag = #{pushFlag}, create_time = #{createTime}, update_time = #{updateTime}, create_by = #{createBy}, update_by = #{updateBy}, - - - - and id = #[id] - - - and client_id = #{clientId} and alarm_type = #{alarmType} - - - and 1=0 - - - + where id = #{id} diff --git a/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmNetworkInterfaceMapper.xml b/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmNetworkInterfaceMapper.xml index 7fb8170..b442aba 100644 --- a/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmNetworkInterfaceMapper.xml +++ b/tongran-rocketmq/src/main/resources/mapper/rocketmq/RmNetworkInterfaceMapper.xml @@ -150,6 +150,6 @@ bind_ip = #{bindIp}, new_flag = #{newFlag}, - where mac_address = #{macAddress} and clientId = #{clientId} + where mac_address = #{macAddress} and client_id = #{clientId} \ No newline at end of file