From 665ab9489e9e7874ec93d7816b786e65f28ffbcc Mon Sep 17 00:00:00 2001 From: gaoyutao Date: Fri, 12 Sep 2025 18:10:58 +0800 Subject: [PATCH] =?UTF-8?q?=E5=91=8A=E8=AD=A6=E7=AE=A1=E7=90=86=EF=BC=8C?= =?UTF-8?q?=E5=91=8A=E8=AD=A6=E6=97=A5=E5=BF=97=E6=8E=A5=E5=8F=A3=E3=80=82?= =?UTF-8?q?=E6=9B=B4=E6=94=B9=E8=AE=A1=E7=AE=9795=E5=80=BC=E5=AE=9A?= =?UTF-8?q?=E6=97=B6=E4=BB=BB=E5=8A=A1=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../system/api/RemoteRocketMqService.java | 34 ++- .../api/domain/RmAlarmRecordRemote.java | 150 +++++++++++ .../RemoteRocketMqFallbackFactory.java | 12 + .../system/config/TableScheduleConfig.java | 4 +- .../system/controller/ScreenController.java | 14 + .../impl/EpsNodeBandwidthServiceImpl.java | 2 +- .../RmResourceRegistrationServiceImpl.java | 2 +- .../system/util/EchartsDataConverter.java | 4 +- .../system/RmResourceRegistrationMapper.xml | 1 + .../controller/RmAlarmPolicyController.java | 103 ++++++++ .../controller/RmAlarmRecordController.java | 92 +++++++ .../controller/RmAlarmRuleController.java | 105 ++++++++ .../RmAlarmRuleTemplateController.java | 39 +++ .../ruoyi/rocketmq/domain/RmAlarmPolicy.java | 52 ++++ .../ruoyi/rocketmq/domain/RmAlarmRecord.java | 149 +++++++++++ .../ruoyi/rocketmq/domain/RmAlarmRule.java | 54 ++++ .../rocketmq/domain/RmAlarmRuleTemplate.java | 86 ++++++ .../com/ruoyi/rocketmq/domain/vo/AlarmVo.java | 21 ++ .../rocketmq/mapper/RmAlarmPolicyMapper.java | 61 +++++ .../rocketmq/mapper/RmAlarmRecordMapper.java | 61 +++++ .../rocketmq/mapper/RmAlarmRuleMapper.java | 76 ++++++ .../mapper/RmAlarmRuleTemplateMapper.java | 61 +++++ .../service/IRmAlarmPolicyService.java | 69 +++++ .../service/IRmAlarmRecordService.java | 65 +++++ .../rocketmq/service/IRmAlarmRuleService.java | 61 +++++ .../service/IRmAlarmRuleTemplateService.java | 61 +++++ .../impl/RmAlarmPolicyServiceImpl.java | 249 ++++++++++++++++++ .../impl/RmAlarmRecordServiceImpl.java | 133 ++++++++++ .../service/impl/RmAlarmRuleServiceImpl.java | 96 +++++++ .../impl/RmAlarmRuleTemplateServiceImpl.java | 96 +++++++ .../impl/RmMonitorPolicyServiceImpl.java | 59 ++--- .../ruoyi/rocketmq/utils/DataProcessUtil.java | 52 +++- .../utils/FieldNameConverterUtil.java | 73 +++++ .../mapper/rocketmq/RmAlarmPolicyMapper.xml | 92 +++++++ .../mapper/rocketmq/RmAlarmRecordMapper.xml | 102 +++++++ .../mapper/rocketmq/RmAlarmRuleMapper.xml | 145 ++++++++++ .../rocketmq/RmAlarmRuleTemplateMapper.xml | 82 ++++++ 37 files changed, 2568 insertions(+), 50 deletions(-) create mode 100644 ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/domain/RmAlarmRecordRemote.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmPolicyController.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmRecordController.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmRuleController.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmRuleTemplateController.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmPolicy.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmRecord.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmRule.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmRuleTemplate.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/vo/AlarmVo.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmPolicyMapper.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmRecordMapper.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmRuleMapper.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmRuleTemplateMapper.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmPolicyService.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmRecordService.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmRuleService.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmRuleTemplateService.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmPolicyServiceImpl.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmRecordServiceImpl.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmRuleServiceImpl.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmRuleTemplateServiceImpl.java create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/utils/FieldNameConverterUtil.java create mode 100644 ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmPolicyMapper.xml create mode 100644 ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRecordMapper.xml create mode 100644 ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRuleMapper.xml create mode 100644 ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRuleTemplateMapper.xml diff --git a/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/RemoteRocketMqService.java b/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/RemoteRocketMqService.java index 73e153e..8b0389e 100644 --- a/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/RemoteRocketMqService.java +++ b/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/RemoteRocketMqService.java @@ -3,17 +3,43 @@ package com.ruoyi.system.api; import com.ruoyi.common.core.constant.SecurityConstants; import com.ruoyi.common.core.constant.ServiceNameConstants; import com.ruoyi.common.core.domain.R; +import com.ruoyi.system.api.domain.RmAlarmRecordRemote; import com.ruoyi.system.api.factory.RemoteRocketMqFallbackFactory; import org.springframework.cloud.openfeign.FeignClient; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestHeader; -import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.*; +import java.util.List; import java.util.Map; @FeignClient(contextId = "remoteRocketMqService", value = ServiceNameConstants.ROCKETMQ_SERVICE, fallbackFactory = RemoteRocketMqFallbackFactory.class) public interface RemoteRocketMqService { - + /** + * 发送异步消息 + * @param topic + * @param tag + * @param key + * @param value + * @param source + * @return + */ @PostMapping("/api/rocketMessage/sendAsyncProducerMessage") public R sendAsyncProducerMessage(@RequestParam("topic") String topic, @RequestParam("tag") String tag, @RequestParam("key") String key, @RequestParam("value") String value, @RequestHeader(SecurityConstants.FROM_SOURCE) String source); + + /** + * 查询告警记录 + * + * @param rmAlarmRecordRemote + * @param source + * @return + */ + @PostMapping("/alarmRecord/getAlarmList") + public R> getAlarmList(@RequestBody RmAlarmRecordRemote rmAlarmRecordRemote, @RequestHeader(SecurityConstants.FROM_SOURCE) String source); + + /** + * 资源告警处理情况 + * @param source + * @return + */ + @GetMapping("/alarmRecord/alarmHandlingStatus") + public R alarmHandlingStatus(@RequestHeader(SecurityConstants.FROM_SOURCE) String source); } diff --git a/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/domain/RmAlarmRecordRemote.java b/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/domain/RmAlarmRecordRemote.java new file mode 100644 index 0000000..46afc18 --- /dev/null +++ b/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/domain/RmAlarmRecordRemote.java @@ -0,0 +1,150 @@ +package com.ruoyi.system.api.domain; + +import com.fasterxml.jackson.annotation.JsonFormat; +import com.ruoyi.common.core.annotation.Excel; +import com.ruoyi.common.core.web.domain.BaseEntity; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; + +import java.util.Date; + +/** + * 告警记录对象 rm_alarm_record + * + * @author gyt + * @date 2025-09-12 + */ +public class RmAlarmRecordRemote extends BaseEntity +{ + private static final long serialVersionUID = 1L; + + /** 主键ID */ + private Long id; + + /** 客户端ID/设备ID */ + @Excel(name = "客户端ID/设备ID") + private String clientId; + + /** 资源名称 */ + @Excel(name = "资源名称") + private String resourceName; + + /** 源IP地址 */ + @Excel(name = "源IP地址") + private String sourceIp; + + /** 告警发生时间 */ + @JsonFormat(pattern = "yyyy-MM-dd") + @Excel(name = "告警发生时间", width = 30, dateFormat = "yyyy-MM-dd") + private Date occurTime; + + /** 告警详细内容 */ + @Excel(name = "告警详细内容") + private String content; + + /** 重复告警次数 */ + @Excel(name = "重复告警次数") + private Long repeatCount; + + /** 状态：0-未处理，1-已处理 */ + @Excel(name = "状态：0-未处理，1-已处理") + private String status; + + public void setId(Long id) + { + this.id = id; + } + + public Long getId() + { + return id; + } + + public void setClientId(String clientId) + { + this.clientId = clientId; + } + + public String getClientId() + { + return clientId; + } + + public void setResourceName(String resourceName) + { + this.resourceName = resourceName; + } + + public String getResourceName() + { + return resourceName; + } + + public void setSourceIp(String sourceIp) + { + this.sourceIp = sourceIp; + } + + public String getSourceIp() + { + return sourceIp; + } + + public void setOccurTime(Date occurTime) + { + this.occurTime = occurTime; + } + + public Date getOccurTime() + { + return occurTime; + } + + public void setContent(String content) + { + this.content = content; + } + + public String getContent() + { + return content; + } + + public void setRepeatCount(Long repeatCount) + { + this.repeatCount = repeatCount; + } + + public Long getRepeatCount() + { + return repeatCount; + } + + public void setStatus(String status) + { + this.status = status; + } + + public String getStatus() + { + return status; + } + + @Override + public String toString() { + return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) + .append("id", getId()) + .append("clientId", getClientId()) + .append("resourceName", getResourceName()) + .append("sourceIp", getSourceIp()) + .append("occurTime", getOccurTime()) + .append("content", getContent()) + .append("repeatCount", getRepeatCount()) + .append("status", getStatus()) + .append("createTime", getCreateTime()) + .append("updateTime", getUpdateTime()) + .append("createBy", getCreateBy()) + .append("updateBy", getUpdateBy()) + .toString(); + } +} diff --git a/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/factory/RemoteRocketMqFallbackFactory.java b/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/factory/RemoteRocketMqFallbackFactory.java index 1b0b300..d7444b5 100644 --- a/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/factory/RemoteRocketMqFallbackFactory.java +++ b/ruoyi-api/ruoyi-api-system/src/main/java/com/ruoyi/system/api/factory/RemoteRocketMqFallbackFactory.java @@ -2,12 +2,14 @@ package com.ruoyi.system.api.factory; import com.ruoyi.common.core.domain.R; import com.ruoyi.system.api.RemoteRocketMqService; +import com.ruoyi.system.api.domain.RmAlarmRecordRemote; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.cloud.openfeign.FallbackFactory; import org.springframework.stereotype.Component; import java.util.HashMap; +import java.util.List; import java.util.Map; /** @@ -33,6 +35,16 @@ public class RemoteRocketMqFallbackFactory implements FallbackFactory> getAlarmList(RmAlarmRecordRemote rmAlarmRecordRemote, String source) { + return R.fail(throwable.getMessage()); + } + + @Override + public R alarmHandlingStatus(String source) { + return R.fail(throwable.getMessage()); + } }; } } diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/config/TableScheduleConfig.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/config/TableScheduleConfig.java index a232f1d..998240b 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/config/TableScheduleConfig.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/config/TableScheduleConfig.java @@ -48,7 +48,7 @@ public class TableScheduleConfig { } // 每天12点执行 计算95带宽值/日 - @Scheduled(cron = "0 0 0 * * ?", zone = "Asia/Shanghai") + @Scheduled(cron = "0 4 0 * * ?", zone = "Asia/Shanghai") public void calculate95BandwidthDaily() { // 获取昨天的日期范围（北京时间） LocalDate yesterday = LocalDate.now(ZoneId.of("Asia/Shanghai")).minusDays(1); @@ -66,7 +66,7 @@ public class TableScheduleConfig { } // 每月1号0点执行 计算95带宽值/月 - @Scheduled(cron = "0 0 0 1 * ?", zone = "Asia/Shanghai") + @Scheduled(cron = "0 3 0 1 * ?", zone = "Asia/Shanghai") public void calculateMonthlyBandwidthTasks() { // 获取上个月的日期范围 LocalDate lastMonth = LocalDate.now(ZoneId.of("Asia/Shanghai")).minusMonths(1); diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/ScreenController.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/ScreenController.java index 61e5eed..9c4db88 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/ScreenController.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/ScreenController.java @@ -1,8 +1,10 @@ package com.ruoyi.system.controller; +import com.ruoyi.common.core.constant.SecurityConstants; import com.ruoyi.common.core.web.controller.BaseController; import com.ruoyi.common.core.web.domain.AjaxResult; import com.ruoyi.common.security.annotation.RequiresPermissions; +import com.ruoyi.system.api.RemoteRocketMqService; import com.ruoyi.system.domain.RmResourceRegistration; import com.ruoyi.system.service.EpsInitialTrafficDataService; import com.ruoyi.system.service.IEpsServerRevenueConfigService; @@ -36,6 +38,8 @@ public class ScreenController extends BaseController private EpsInitialTrafficDataService epsInitialTrafficDataService; @Autowired private IInitialSwitchInfoDetailsService initialSwitchInfoDetailsService; + @Autowired + private RemoteRocketMqService remoteRocketMqService; /** * 统计当前在线服务器的流量相关的业务数 @@ -111,4 +115,14 @@ public class ScreenController extends BaseController { return success(initialSwitchInfoDetailsService.sumTrafficBySwitch()); } + /** + * 资源告警处理情况 + * @return + */ + @RequiresPermissions("system:config:list") + @GetMapping("/alarmProcess") + public AjaxResult alarmProcess() { + Map alarmList = remoteRocketMqService.alarmHandlingStatus(SecurityConstants.INNER).getData(); + return success(alarmList); + } } diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/EpsNodeBandwidthServiceImpl.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/EpsNodeBandwidthServiceImpl.java index 1356bc0..c238dec 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/EpsNodeBandwidthServiceImpl.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/EpsNodeBandwidthServiceImpl.java @@ -322,7 +322,7 @@ public class EpsNodeBandwidthServiceImpl implements IEpsNodeBandwidthService nodeData.put("resultData", EchartsDataConverter.convertToLineChart( nodeBandwidthList, bandwidthType, - node.getBusinessName(), + node.getNodeName(), epsNodeBandwidth.getStartTime(), epsNodeBandwidth.getEndTime(), timeUnit diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/RmResourceRegistrationServiceImpl.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/RmResourceRegistrationServiceImpl.java index 368cd8c..007f150 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/RmResourceRegistrationServiceImpl.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/RmResourceRegistrationServiceImpl.java @@ -189,7 +189,7 @@ public class RmResourceRegistrationServiceImpl implements IRmResourceRegistratio } // 发送消息通知 - sendRegistrationMessage(rmResourceRegistration); +// sendRegistrationMessage(rmResourceRegistration); // 更新注册状态 return updateRegistrationStatus(rmResourceRegistration); diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/util/EchartsDataConverter.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/util/EchartsDataConverter.java index 9b3b0e3..d8dd5ab 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/util/EchartsDataConverter.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/util/EchartsDataConverter.java @@ -18,7 +18,7 @@ public class EchartsDataConverter { */ public static Map convertToLineChart( List dataList, - String bandwidthType, String businessName, String startTime, String endTime, ChronoUnit timeUnit + String bandwidthType, String nodeName, String startTime, String endTime, ChronoUnit timeUnit ) { // 定义时间格式化器 SimpleDateFormat sdf = new SimpleDateFormat( @@ -32,7 +32,7 @@ public class EchartsDataConverter { item.getCreateTime() != null && item.getBandwidthResult() != null && (bandwidthType == null || bandwidthType.equals(item.getBandwidthType())) && - (businessName == null || businessName.equals(item.getBusinessName())) + (nodeName == null || nodeName.equals(item.getNodeName())) ) .sorted(Comparator.comparing(EpsNodeBandwidth::getCreateTime)) .collect(Collectors.toList()); diff --git a/ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml b/ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml index 19877c6..fb66818 100644 --- a/ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml +++ b/ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/RmResourceRegistrationMapper.xml @@ -72,6 +72,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" and updater_id = #{updaterId} and updater_name like concat('%', #{updaterName}, '%') + order by create_time desc + + + and alarm_name like concat('%', #{alarmName}, '%') + and alarm_description = #{alarmDescription} + and resource_group_id = #{resourceGroupId} + and status = #{status} + and deploy_time = #{deployTime} + + + + + + + insert into rm_alarm_policy + + alarm_name, + alarm_description, + resource_group_id, + status, + deploy_time, + create_time, + update_time, + create_by, + update_by, + + + #{alarmName}, + #{alarmDescription}, + #{resourceGroupId}, + #{status}, + #{deployTime}, + #{createTime}, + #{updateTime}, + #{createBy}, + #{updateBy}, + + + + + update rm_alarm_policy + + alarm_name = #{alarmName}, + alarm_description = #{alarmDescription}, + resource_group_id = #{resourceGroupId}, + status = #{status}, + deploy_time = #{deployTime}, + create_time = #{createTime}, + update_time = #{updateTime}, + create_by = #{createBy}, + update_by = #{updateBy}, + + where id = #{id} + + + + delete from rm_alarm_policy where id = #{id} + + + + delete from rm_alarm_policy where id in + + #{id} + + + \ No newline at end of file diff --git a/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRecordMapper.xml b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRecordMapper.xml new file mode 100644 index 0000000..e7dac71 --- /dev/null +++ b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRecordMapper.xml @@ -0,0 +1,102 @@ + + + + + + + + + + + + + + + + + + + + + select id, client_id, resource_name, source_ip, occur_time, content, repeat_count, status, create_time, update_time, create_by, update_by from rm_alarm_record + + + + + + + + insert into rm_alarm_record + + client_id, + resource_name, + source_ip, + occur_time, + content, + repeat_count, + status, + create_time, + update_time, + create_by, + update_by, + + + #{clientId}, + #{resourceName}, + #{sourceIp}, + #{occurTime}, + #{content}, + #{repeatCount}, + #{status}, + #{createTime}, + #{updateTime}, + #{createBy}, + #{updateBy}, + + + + + update rm_alarm_record + + client_id = #{clientId}, + resource_name = #{resourceName}, + source_ip = #{sourceIp}, + occur_time = #{occurTime}, + content = #{content}, + repeat_count = #{repeatCount}, + status = #{status}, + create_time = #{createTime}, + update_time = #{updateTime}, + create_by = #{createBy}, + update_by = #{updateBy}, + + where id = #{id} + + + + delete from rm_alarm_record where id = #{id} + + + + delete from rm_alarm_record where id in + + #{id} + + + \ No newline at end of file diff --git a/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRuleMapper.xml b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRuleMapper.xml new file mode 100644 index 0000000..1e3dc66 --- /dev/null +++ b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRuleMapper.xml @@ -0,0 +1,145 @@ + + + + + + + + + + + + + + + + + + + + + + select id, alarm_policy_id, rule_name, metric_key, operator, threshold, resource_type, status, port_whitelist, create_time, update_time, create_by, update_by from rm_alarm_rule + + + + + + + + insert into rm_alarm_rule + + alarm_policy_id, + rule_name, + metric_key, + operator, + threshold, + resource_type, + status, + port_whitelist, + create_time, + update_time, + create_by, + update_by, + + + #{alarmPolicyId}, + #{ruleName}, + #{metricKey}, + #{operator}, + #{threshold}, + #{resourceType}, + #{status}, + #{portWhitelist}, + #{createTime}, + #{updateTime}, + #{createBy}, + #{updateBy}, + + + + + update rm_alarm_rule + + alarm_policy_id = #{alarmPolicyId}, + rule_name = #{ruleName}, + metric_key = #{metricKey}, + operator = #{operator}, + threshold = #{threshold}, + resource_type = #{resourceType}, + status = #{status}, + port_whitelist = #{portWhitelist}, + create_time = #{createTime}, + update_time = #{updateTime}, + create_by = #{createBy}, + update_by = #{updateBy}, + + where id = #{id} + + + + delete from rm_alarm_rule where id = #{id} + + + + delete from rm_alarm_rule where id in + + #{id} + + + + delete from rm_alarm_rule where alarm_policy_id #{id} + + + + INSERT INTO rm_alarm_rule + ( + alarm_policy_id, + rule_name, + metric_key, + operator, + threshold, + resource_type, + status, + port_whitelist, + create_time, + update_time, + create_by, + update_by + ) + VALUES + + ( + #{item.alarmPolicyId}, + #{item.ruleName}, + #{item.metricKey}, + #{item.operator}, + #{item.threshold}, + #{item.resourceType}, + #{item.status}, + #{item.portWhitelist}, + #{item.createTime}, + #{item.updateTime}, + #{item.createBy}, + #{item.updateBy} + ) + + + \ No newline at end of file diff --git a/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRuleTemplateMapper.xml b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRuleTemplateMapper.xml new file mode 100644 index 0000000..e293cbd --- /dev/null +++ b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmRuleTemplateMapper.xml @@ -0,0 +1,82 @@ + + + + + + + + + + + + + + + + + select id, rule_name, metric_key, resource_type, create_time, update_time, create_by, update_by from rm_alarm_rule_template + + + + + + + + insert into rm_alarm_rule_template + + rule_name, + metric_key, + resource_type, + create_time, + update_time, + create_by, + update_by, + + + #{ruleName}, + #{metricKey}, + #{resourceType}, + #{createTime}, + #{updateTime}, + #{createBy}, + #{updateBy}, + + + + + update rm_alarm_rule_template + + rule_name = #{ruleName}, + metric_key = #{metricKey}, + resource_type = #{resourceType}, + create_time = #{createTime}, + update_time = #{updateTime}, + create_by = #{createBy}, + update_by = #{updateBy}, + + where id = #{id} + + + + delete from rm_alarm_rule_template where id = #{id} + + + + delete from rm_alarm_rule_template where id in + + #{id} + + + \ No newline at end of file