diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/EpsBusinessDeployController.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/EpsBusinessDeployController.java index 55db1f2..bcc2873 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/EpsBusinessDeployController.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/EpsBusinessDeployController.java @@ -1,5 +1,6 @@ package com.ruoyi.system.controller; +import com.ruoyi.common.core.utils.poi.ExcelUtil; import com.ruoyi.common.core.web.controller.BaseController; import com.ruoyi.common.core.web.domain.AjaxResult; import com.ruoyi.common.core.web.page.PageDomain; @@ -12,6 +13,7 @@ import com.ruoyi.system.service.IEpsBusinessDeployService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; +import javax.servlet.http.HttpServletResponse; import java.util.List; /** @@ -42,6 +44,20 @@ public class EpsBusinessDeployController extends BaseController return getDataTable(list); } + /** + * 导出 + * @param response + * @param epsBusinessDeploy + */ + @PostMapping("/export") + public void export(HttpServletResponse response, @RequestBody EpsBusinessDeploy epsBusinessDeploy) + { + List list = epsBusinessDeployService.selectEpsBusinessDeployList(epsBusinessDeploy); + ExcelUtil util = new ExcelUtil(EpsBusinessDeploy.class); + util.showColumn(epsBusinessDeploy.getProperties()); + util.exportExcel(response, list, "业务下发管理"); + } + /** * 获取业务下发管理详细信息 diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/EpsTaskStatisticsController.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/EpsTaskStatisticsController.java index a417080..fecc6bc 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/EpsTaskStatisticsController.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/controller/EpsTaskStatisticsController.java @@ -52,7 +52,7 @@ public class EpsTaskStatisticsController extends BaseController @RequiresPermissions("system:taskStatistics:export") @Log(title = "业务95值计算任务", businessType = BusinessType.EXPORT) @PostMapping("/export") - public void export(HttpServletResponse response, EpsTaskStatistics epsTaskStatistics) + public void export(HttpServletResponse response, @RequestBody EpsTaskStatistics epsTaskStatistics) { List list = epsTaskStatisticsService.selectEpsTaskStatisticsList(epsTaskStatistics); ExcelUtil util = new ExcelUtil(EpsTaskStatistics.class); diff --git a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/domain/RmResourceRegistration.java b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/domain/RmResourceRegistration.java index 3722e69..3b6a1c3 100644 --- a/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/domain/RmResourceRegistration.java +++ b/ruoyi-modules/ruoyi-system/src/main/java/com/ruoyi/system/domain/RmResourceRegistration.java @@ -88,7 +88,7 @@ public class RmResourceRegistration extends BaseEntity private String registrationStatus; /** 在线状态 0-离线，1-在线 */ - @Excel(name = "在线状态") + @Excel(name = "在线状态", readConverterExp = "0=离线,1=在线") private String onlineStatus; private String switchOnlineStatus; diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmLogController.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmLogController.java new file mode 100644 index 0000000..f20926d --- /dev/null +++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmLogController.java @@ -0,0 +1,105 @@ +package com.ruoyi.rocketmq.controller; + +import java.util.List; +import java.io.IOException; +import javax.servlet.http.HttpServletResponse; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import com.ruoyi.common.log.annotation.Log; +import com.ruoyi.common.log.enums.BusinessType; +import com.ruoyi.common.security.annotation.RequiresPermissions; +import com.ruoyi.rocketmq.domain.RmAlarmLog; +import com.ruoyi.rocketmq.service.IRmAlarmLogService; +import com.ruoyi.common.core.web.controller.BaseController; +import com.ruoyi.common.core.web.domain.AjaxResult; +import com.ruoyi.common.core.utils.poi.ExcelUtil; +import com.ruoyi.common.core.web.page.TableDataInfo; + +/** + * 客户端告警信息Controller + * + * @author gyt + * @date 2025-11-10 + */ +@RestController +@RequestMapping("/alarmLog") +public class RmAlarmLogController extends BaseController +{ + @Autowired + private IRmAlarmLogService rmAlarmLogService; + + /** + * 查询客户端告警信息列表 + */ + @RequiresPermissions("rocketmq:alarmLog:list") + @GetMapping("/list") + public TableDataInfo list(RmAlarmLog rmAlarmLog) + { + startPage(); + List list = rmAlarmLogService.selectRmAlarmLogList(rmAlarmLog); + return getDataTable(list); + } + + /** + * 导出客户端告警信息列表 + */ + @RequiresPermissions("rocketmq:alarmLog:export") + @Log(title = "客户端告警信息", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, RmAlarmLog rmAlarmLog) + { + List list = rmAlarmLogService.selectRmAlarmLogList(rmAlarmLog); + ExcelUtil util = new ExcelUtil(RmAlarmLog.class); + util.exportExcel(response, list, "客户端告警信息数据"); + } + + /** + * 获取客户端告警信息详细信息 + */ + @RequiresPermissions("rocketmq:alarmLog:query") + @GetMapping(value = "/{id}") + public AjaxResult getInfo(@PathVariable("id") Long id) + { + return success(rmAlarmLogService.selectRmAlarmLogById(id)); + } + + /** + * 新增客户端告警信息 + */ + @RequiresPermissions("rocketmq:alarmLog:add") + @Log(title = "客户端告警信息", businessType = BusinessType.INSERT) + @PostMapping + public AjaxResult add(@RequestBody RmAlarmLog rmAlarmLog) + { + return toAjax(rmAlarmLogService.insertRmAlarmLog(rmAlarmLog)); + } + + /** + * 修改客户端告警信息 + */ + @RequiresPermissions("rocketmq:alarmLog:edit") + @Log(title = "客户端告警信息", businessType = BusinessType.UPDATE) + @PutMapping + public AjaxResult edit(@RequestBody RmAlarmLog rmAlarmLog) + { + return toAjax(rmAlarmLogService.updateRmAlarmLog(rmAlarmLog)); + } + + /** + * 删除客户端告警信息 + */ + @RequiresPermissions("rocketmq:alarmLog:remove") + @Log(title = "客户端告警信息", businessType = BusinessType.DELETE) + @DeleteMapping("/{ids}") + public AjaxResult remove(@PathVariable Long[] ids) + { + return toAjax(rmAlarmLogService.deleteRmAlarmLogByIds(ids)); + } +} diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmDeploymentPolicyController.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmDeploymentPolicyController.java index 4488d1c..c289c00 100644 --- a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmDeploymentPolicyController.java +++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmDeploymentPolicyController.java @@ -52,10 +52,11 @@ public class RmDeploymentPolicyController extends BaseController @RequiresPermissions("rocketmq:policy:export") @Log(title = "服务器脚本策略", businessType = BusinessType.EXPORT) @PostMapping("/export") - public void export(HttpServletResponse response, RmDeploymentPolicy rmDeploymentPolicy) + public void export(HttpServletResponse response, @RequestBody RmDeploymentPolicy rmDeploymentPolicy) { List list = rmDeploymentPolicyService.selectRmDeploymentPolicyList(rmDeploymentPolicy); ExcelUtil util = new ExcelUtil(RmDeploymentPolicy.class); + util.showColumn(rmDeploymentPolicy.getProperties()); util.exportExcel(response, list, "服务器脚本策略数据"); } diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmLog.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmLog.java new file mode 100644 index 0000000..c7c584c --- /dev/null +++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmLog.java @@ -0,0 +1,119 @@ +package com.ruoyi.rocketmq.domain; + +import java.util.Date; +import com.fasterxml.jackson.annotation.JsonFormat; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.ruoyi.common.core.annotation.Excel; +import com.ruoyi.common.core.web.domain.BaseEntity; + +/** + * 客户端告警信息对象 rm_alarm_log + * + * @author gyt + * @date 2025-11-10 + */ +public class RmAlarmLog extends BaseEntity +{ + private static final long serialVersionUID = 1L; + + /** 主键ID */ + private Long id; + + /** 客户端ID */ + @Excel(name = "客户端ID") + private String clientId; + + /** 告警时间 */ + @JsonFormat(pattern = "yyyy-MM-dd") + @Excel(name = "告警时间", width = 30, dateFormat = "yyyy-MM-dd") + private Date alarmTime; + + /** 管理网-公网IP */ + @Excel(name = "管理网-公网IP") + private String mgmPublicIp; + + /** 告警类型 */ + @Excel(name = "告警类型") + private String alarmType; + + /** 告警内容 */ + @Excel(name = "告警内容") + private String alarmContent; + + 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 setAlarmTime(Date alarmTime) + { + this.alarmTime = alarmTime; + } + + public Date getAlarmTime() + { + return alarmTime; + } + + public void setMgmPublicIp(String mgmPublicIp) + { + this.mgmPublicIp = mgmPublicIp; + } + + public String getMgmPublicIp() + { + return mgmPublicIp; + } + + public void setAlarmType(String alarmType) + { + this.alarmType = alarmType; + } + + public String getAlarmType() + { + return alarmType; + } + + public void setAlarmContent(String alarmContent) + { + this.alarmContent = alarmContent; + } + + public String getAlarmContent() + { + return alarmContent; + } + + @Override + public String toString() { + return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) + .append("id", getId()) + .append("clientId", getClientId()) + .append("alarmTime", getAlarmTime()) + .append("mgmPublicIp", getMgmPublicIp()) + .append("alarmType", getAlarmType()) + .append("alarmContent", getAlarmContent()) + .append("createTime", getCreateTime()) + .append("updateTime", getUpdateTime()) + .append("createBy", getCreateBy()) + .append("updateBy", getUpdateBy()) + .toString(); + } +} diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmRecord.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmRecord.java index f5ca9b3..a8d6f33 100644 --- a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmRecord.java +++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmRecord.java @@ -1,11 +1,11 @@ package com.ruoyi.rocketmq.domain; -import java.util.Date; import com.fasterxml.jackson.annotation.JsonFormat; -import org.apache.commons.lang3.builder.ToStringBuilder; -import org.apache.commons.lang3.builder.ToStringStyle; import com.ruoyi.common.core.annotation.Excel; import com.ruoyi.common.core.web.domain.BaseEntity; +import lombok.Data; + +import java.util.Date; /** * 告警记录对象 rm_alarm_record @@ -13,6 +13,7 @@ import com.ruoyi.common.core.web.domain.BaseEntity; * @author gyt * @date 2025-09-12 */ +@Data public class RmAlarmRecord extends BaseEntity { private static final long serialVersionUID = 1L; @@ -33,8 +34,8 @@ public class RmAlarmRecord extends BaseEntity private String sourceIp; /** 告警发生时间 */ - @JsonFormat(pattern = "yyyy-MM-dd") - @Excel(name = "告警发生时间", width = 30, dateFormat = "yyyy-MM-dd") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "告警发生时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") private Date occurTime; /** 告警详细内容 */ @@ -49,101 +50,4 @@ public class RmAlarmRecord extends BaseEntity @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-rocketmq/src/main/java/com/ruoyi/rocketmq/handler/MessageHandler.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/handler/MessageHandler.java index 9e39644..4212c03 100644 --- a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/handler/MessageHandler.java +++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/handler/MessageHandler.java @@ -87,6 +87,8 @@ public class MessageHandler { private IRmDeploymentPolicyService rmDeploymentPolicyService; @Autowired private IInitialBandwidthTrafficTempService initialBandwidthTrafficTempService; + @Autowired + private IRmAlarmLogService rmAlarmLogService; /** @@ -1079,6 +1081,37 @@ public class MessageHandler { log.error("插入心跳日志失败", e); } } + private void insertAlarmRecords(String clientId){ + RmAlarmLog rmAlarmLog = new RmAlarmLog(); + // 查询管理网公网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()); + }); + } + rmAlarmLog.setClientId(clientId); + rmAlarmLog.setAlarmContent(clientId + "下线"); + rmAlarmLog.setAlarmTime(DateUtils.getNowDate()); + rmAlarmLog.setAlarmType("1"); + // 查询此告警是否存在 + RmAlarmLog query = new RmAlarmLog(); + query.setClientId(clientId); + query.setAlarmType("1"); + List alarmLog = rmAlarmLogService.selectRmAlarmLogList(query); + if(alarmLog != null && !alarmLog.isEmpty()){ + rmAlarmLogService.updateRmAlarmLog(rmAlarmLog); + }else{ + rmAlarmLogService.insertRmAlarmLog(rmAlarmLog); + } + + } /** * 应答信息 diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmLogMapper.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmLogMapper.java new file mode 100644 index 0000000..25d1768 --- /dev/null +++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmLogMapper.java @@ -0,0 +1,61 @@ +package com.ruoyi.rocketmq.mapper; + +import java.util.List; +import com.ruoyi.rocketmq.domain.RmAlarmLog; + +/** + * 客户端告警信息Mapper接口 + * + * @author gyt + * @date 2025-11-10 + */ +public interface RmAlarmLogMapper +{ + /** + * 查询客户端告警信息 + * + * @param id 客户端告警信息主键 + * @return 客户端告警信息 + */ + public RmAlarmLog selectRmAlarmLogById(Long id); + + /** + * 查询客户端告警信息列表 + * + * @param rmAlarmLog 客户端告警信息 + * @return 客户端告警信息集合 + */ + public List selectRmAlarmLogList(RmAlarmLog rmAlarmLog); + + /** + * 新增客户端告警信息 + * + * @param rmAlarmLog 客户端告警信息 + * @return 结果 + */ + public int insertRmAlarmLog(RmAlarmLog rmAlarmLog); + + /** + * 修改客户端告警信息 + * + * @param rmAlarmLog 客户端告警信息 + * @return 结果 + */ + public int updateRmAlarmLog(RmAlarmLog rmAlarmLog); + + /** + * 删除客户端告警信息 + * + * @param id 客户端告警信息主键 + * @return 结果 + */ + public int deleteRmAlarmLogById(Long id); + + /** + * 批量删除客户端告警信息 + * + * @param ids 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteRmAlarmLogByIds(Long[] ids); +} diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmLogService.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmLogService.java new file mode 100644 index 0000000..4d5c95a --- /dev/null +++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmLogService.java @@ -0,0 +1,61 @@ +package com.ruoyi.rocketmq.service; + +import java.util.List; +import com.ruoyi.rocketmq.domain.RmAlarmLog; + +/** + * 客户端告警信息Service接口 + * + * @author gyt + * @date 2025-11-10 + */ +public interface IRmAlarmLogService +{ + /** + * 查询客户端告警信息 + * + * @param id 客户端告警信息主键 + * @return 客户端告警信息 + */ + public RmAlarmLog selectRmAlarmLogById(Long id); + + /** + * 查询客户端告警信息列表 + * + * @param rmAlarmLog 客户端告警信息 + * @return 客户端告警信息集合 + */ + public List selectRmAlarmLogList(RmAlarmLog rmAlarmLog); + + /** + * 新增客户端告警信息 + * + * @param rmAlarmLog 客户端告警信息 + * @return 结果 + */ + public int insertRmAlarmLog(RmAlarmLog rmAlarmLog); + + /** + * 修改客户端告警信息 + * + * @param rmAlarmLog 客户端告警信息 + * @return 结果 + */ + public int updateRmAlarmLog(RmAlarmLog rmAlarmLog); + + /** + * 批量删除客户端告警信息 + * + * @param ids 需要删除的客户端告警信息主键集合 + * @return 结果 + */ + public int deleteRmAlarmLogByIds(Long[] ids); + + /** + * 删除客户端告警信息信息 + * + * @param id 客户端告警信息主键 + * @return 结果 + */ + public int deleteRmAlarmLogById(Long id); +} diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmLogServiceImpl.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmLogServiceImpl.java new file mode 100644 index 0000000..ca28f83 --- /dev/null +++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmLogServiceImpl.java @@ -0,0 +1,96 @@ +package com.ruoyi.rocketmq.service.impl; + +import java.util.List; +import com.ruoyi.common.core.utils.DateUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import com.ruoyi.rocketmq.mapper.RmAlarmLogMapper; +import com.ruoyi.rocketmq.domain.RmAlarmLog; +import com.ruoyi.rocketmq.service.IRmAlarmLogService; + +/** + * 客户端告警信息Service业务层处理 + * + * @author gyt + * @date 2025-11-10 + */ +@Service +public class RmAlarmLogServiceImpl implements IRmAlarmLogService +{ + @Autowired + private RmAlarmLogMapper rmAlarmLogMapper; + + /** + * 查询客户端告警信息 + * + * @param id 客户端告警信息主键 + * @return 客户端告警信息 + */ + @Override + public RmAlarmLog selectRmAlarmLogById(Long id) + { + return rmAlarmLogMapper.selectRmAlarmLogById(id); + } + + /** + * 查询客户端告警信息列表 + * + * @param rmAlarmLog 客户端告警信息 + * @return 客户端告警信息 + */ + @Override + public List selectRmAlarmLogList(RmAlarmLog rmAlarmLog) + { + return rmAlarmLogMapper.selectRmAlarmLogList(rmAlarmLog); + } + + /** + * 新增客户端告警信息 + * + * @param rmAlarmLog 客户端告警信息 + * @return 结果 + */ + @Override + public int insertRmAlarmLog(RmAlarmLog rmAlarmLog) + { + rmAlarmLog.setCreateTime(DateUtils.getNowDate()); + return rmAlarmLogMapper.insertRmAlarmLog(rmAlarmLog); + } + + /** + * 修改客户端告警信息 + * + * @param rmAlarmLog 客户端告警信息 + * @return 结果 + */ + @Override + public int updateRmAlarmLog(RmAlarmLog rmAlarmLog) + { + rmAlarmLog.setUpdateTime(DateUtils.getNowDate()); + return rmAlarmLogMapper.updateRmAlarmLog(rmAlarmLog); + } + + /** + * 批量删除客户端告警信息 + * + * @param ids 需要删除的客户端告警信息主键 + * @return 结果 + */ + @Override + public int deleteRmAlarmLogByIds(Long[] ids) + { + return rmAlarmLogMapper.deleteRmAlarmLogByIds(ids); + } + + /** + * 删除客户端告警信息信息 + * + * @param id 客户端告警信息主键 + * @return 结果 + */ + @Override + public int deleteRmAlarmLogById(Long id) + { + return rmAlarmLogMapper.deleteRmAlarmLogById(id); + } +} diff --git a/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml new file mode 100644 index 0000000..373825e --- /dev/null +++ b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmLogMapper.xml @@ -0,0 +1,101 @@ + + + + + + + + + + + + + + + + + + + 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 + + + + + + + + insert into rm_alarm_log + + client_id, + alarm_time, + mgm_public_ip, + alarm_type, + alarm_content, + create_time, + update_time, + create_by, + update_by, + + + #{clientId}, + #{alarmTime}, + #{mgmPublicIp}, + #{alarmType}, + #{alarmContent}, + #{createTime}, + #{updateTime}, + #{createBy}, + #{updateBy}, + + + + + update rm_alarm_log + + mgm_public_ip = #{mgmPublicIp}, + alarm_content = #{alarmContent}, + 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 + + + + + + + delete from rm_alarm_log where id = #{id} + + + + delete from rm_alarm_log where id in + + #{id} + + + \ No newline at end of file