From 70e943269a3a8b59d6917b6e78df5098c4a04881 Mon Sep 17 00:00:00 2001
From: gaoyutao <duguprogromer@163.com>
Date: Tue, 11 Nov 2025 18:03:50 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E8=AE=A1=E6=B6=88=E6=81=AF=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81=E6=95=B0=E6=8D=AE=E8=A1=A8=E3=80=81=E5=BC=80=E5=8F=91?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=8E=A8=E9=80=81=E7=9B=B8=E5=85=B3=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91=E6=96=B9=E6=B3=95=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../system/EpsInitialTrafficDataMapper.xml    |   4 +-
 .../RmAlarmPushConfigController.java          | 105 +++++++
 .../com/ruoyi/rocketmq/domain/RmAlarmLog.java |  87 +-----
 .../rocketmq/domain/RmAlarmPushConfig.java    |  44 +++
 .../ruoyi/rocketmq/enums/AlarmTypeEnum.java   |  14 +
 .../ruoyi/rocketmq/enums/PushMethodEnum.java  |  14 +
 .../rocketmq/handler/MessageHandler.java      |  28 +-
 .../mapper/RmAlarmPushConfigMapper.java       |  61 ++++
 .../service/IRmAlarmPushConfigService.java    |  61 ++++
 .../impl/RmAlarmPushConfigServiceImpl.java    |  96 ++++++
 .../ruoyi/rocketmq/utils/WeChatWorkBot.java   | 285 ++++++++++++++++++
 .../rocketmq/RmAlarmPushConfigMapper.xml      |  97 ++++++
 12 files changed, 812 insertions(+), 84 deletions(-)
 create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmPushConfigController.java
 create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmPushConfig.java
 create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/enums/AlarmTypeEnum.java
 create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/enums/PushMethodEnum.java
 create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmPushConfigMapper.java
 create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmPushConfigService.java
 create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmPushConfigServiceImpl.java
 create mode 100644 ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/utils/WeChatWorkBot.java
 create mode 100644 ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmPushConfigMapper.xml

diff --git a/ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/EpsInitialTrafficDataMapper.xml b/ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/EpsInitialTrafficDataMapper.xml
index 4622bb1..93b7eb6 100644
--- a/ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/EpsInitialTrafficDataMapper.xml
+++ b/ruoyi-modules/ruoyi-system/src/main/resources/mapper/system/EpsInitialTrafficDataMapper.xml
@@ -182,7 +182,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <select id="selectByCondition" resultType="EpsInitialTrafficData">
         SELECT
         a.id,
-        a.`name` AS name,
+        GROUP_CONCAT(DISTINCT a.`name` SEPARATOR ',') AS name,
         a.`mac` AS mac,
         a.`status` AS status,
         a.`type` AS type,
@@ -208,7 +208,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         a.update_by AS updateBy,
         a.client_id AS clientId
         FROM ${tableName} a
-        INNER JOIN rm_network_interface b ON a.client_id = b.client_id and and a.mac=b.mac_address
+        INNER JOIN rm_network_interface b ON a.client_id = b.client_id and a.mac=b.mac_address
         AND (b.bind_ip = 1 OR b.bind_ip = 3)
         AND b.new_flag = 1
         <where>
diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmPushConfigController.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmPushConfigController.java
new file mode 100644
index 0000000..f0cde9c
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/controller/RmAlarmPushConfigController.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.RmAlarmPushConfig;
+import com.ruoyi.rocketmq.service.IRmAlarmPushConfigService;
+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-11
+ */
+@RestController
+@RequestMapping("/alarmPushConfig")
+public class RmAlarmPushConfigController extends BaseController
+{
+    @Autowired
+    private IRmAlarmPushConfigService rmAlarmPushConfigService;
+
+    /**
+     * 查询告警推送配置列表
+     */
+    @RequiresPermissions("rocketmq:alarmPushConfig:list")
+    @GetMapping("/list")
+    public TableDataInfo list(RmAlarmPushConfig rmAlarmPushConfig)
+    {
+        startPage();
+        List<RmAlarmPushConfig> list = rmAlarmPushConfigService.selectRmAlarmPushConfigList(rmAlarmPushConfig);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出告警推送配置列表
+     */
+    @RequiresPermissions("rocketmq:alarmPushConfig:export")
+    @Log(title = "告警推送配置", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, RmAlarmPushConfig rmAlarmPushConfig)
+    {
+        List<RmAlarmPushConfig> list = rmAlarmPushConfigService.selectRmAlarmPushConfigList(rmAlarmPushConfig);
+        ExcelUtil<RmAlarmPushConfig> util = new ExcelUtil<RmAlarmPushConfig>(RmAlarmPushConfig.class);
+        util.exportExcel(response, list, "告警推送配置数据");
+    }
+
+    /**
+     * 获取告警推送配置详细信息
+     */
+    @RequiresPermissions("rocketmq:alarmPushConfig:query")
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Long id)
+    {
+        return success(rmAlarmPushConfigService.selectRmAlarmPushConfigById(id));
+    }
+
+    /**
+     * 新增告警推送配置
+     */
+    @RequiresPermissions("rocketmq:alarmPushConfig:add")
+    @Log(title = "告警推送配置", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody RmAlarmPushConfig rmAlarmPushConfig)
+    {
+        return toAjax(rmAlarmPushConfigService.insertRmAlarmPushConfig(rmAlarmPushConfig));
+    }
+
+    /**
+     * 修改告警推送配置
+     */
+    @RequiresPermissions("rocketmq:alarmPushConfig:edit")
+    @Log(title = "告警推送配置", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody RmAlarmPushConfig rmAlarmPushConfig)
+    {
+        return toAjax(rmAlarmPushConfigService.updateRmAlarmPushConfig(rmAlarmPushConfig));
+    }
+
+    /**
+     * 删除告警推送配置
+     */
+    @RequiresPermissions("rocketmq:alarmPushConfig:remove")
+    @Log(title = "告警推送配置", businessType = BusinessType.DELETE)
+	@DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Long[] ids)
+    {
+        return toAjax(rmAlarmPushConfigService.deleteRmAlarmPushConfigByIds(ids));
+    }
+}
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
index c7c584c..b16b844 100644
--- a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmLog.java
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmLog.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_log
@@ -13,6 +13,7 @@ import com.ruoyi.common.core.web.domain.BaseEntity;
  * @author gyt
  * @date 2025-11-10
  */
+@Data
 public class RmAlarmLog extends BaseEntity
 {
     private static final long serialVersionUID = 1L;
@@ -25,8 +26,8 @@ public class RmAlarmLog extends BaseEntity
     private String clientId;
 
     /** 告警时间 */
-    @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 alarmTime;
 
     /** 管理网-公网IP */
@@ -40,80 +41,4 @@ public class RmAlarmLog extends BaseEntity
     /** 告警内容 */
     @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/RmAlarmPushConfig.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmPushConfig.java
new file mode 100644
index 0000000..a155747
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/domain/RmAlarmPushConfig.java
@@ -0,0 +1,44 @@
+package com.ruoyi.rocketmq.domain;
+
+import com.ruoyi.common.core.annotation.Excel;
+import com.ruoyi.common.core.web.domain.BaseEntity;
+import lombok.Data;
+
+/**
+ * 告警推送配置对象 rm_alarm_push_config
+ * 
+ * @author gyt
+ * @date 2025-11-11
+ */
+@Data
+public class RmAlarmPushConfig extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** 主键ID */
+    private Long id;
+
+    /** 配置名称 */
+    @Excel(name = "配置名称")
+    private String configName;
+
+    /** 推送方式 */
+    @Excel(name = "推送方式")
+    private String pushMethod;
+
+    /** 推送地址 */
+    @Excel(name = "推送地址")
+    private String pushAddress;
+
+    /** 推送告警类型 */
+    @Excel(name = "推送告警类型")
+    private String pushAlarmTypes;
+
+    /** 消息内容 */
+    @Excel(name = "消息内容")
+    private String messageContent;
+
+    /** 消息提示人手机号 */
+    @Excel(name = "消息提示人手机号")
+    private String contactPhones;
+}
diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/enums/AlarmTypeEnum.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/enums/AlarmTypeEnum.java
new file mode 100644
index 0000000..da2573d
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/enums/AlarmTypeEnum.java
@@ -0,0 +1,14 @@
+package com.ruoyi.rocketmq.enums;
+
+import lombok.Getter;
+
+@Getter
+public enum AlarmTypeEnum {
+    服务器下线("1", "服务器下线");
+    private final String code;
+    private final String msg;
+    AlarmTypeEnum(String code, String msg){
+        this.code = code;
+        this.msg = msg;
+    }
+}
diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/enums/PushMethodEnum.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/enums/PushMethodEnum.java
new file mode 100644
index 0000000..1087962
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/enums/PushMethodEnum.java
@@ -0,0 +1,14 @@
+package com.ruoyi.rocketmq.enums;
+
+import lombok.Getter;
+
+@Getter
+public enum PushMethodEnum {
+    企业微信("1", "企业微信");
+    private final String code;
+    private final String msg;
+    PushMethodEnum(String code, String msg){
+        this.code = code;
+        this.msg = msg;
+    }
+}
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 4212c03..efaac4b 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
@@ -10,9 +10,12 @@ import com.ruoyi.rocketmq.domain.vo.CollectDataVo;
 import com.ruoyi.rocketmq.domain.vo.RegisterMsgVo;
 import com.ruoyi.rocketmq.domain.vo.RspResultVo;
 import com.ruoyi.rocketmq.domain.vo.RspVo;
+import com.ruoyi.rocketmq.enums.AlarmTypeEnum;
+import com.ruoyi.rocketmq.enums.PushMethodEnum;
 import com.ruoyi.rocketmq.service.*;
 import com.ruoyi.rocketmq.utils.DataProcessUtil;
 import com.ruoyi.rocketmq.utils.JsonDataParser;
+import com.ruoyi.rocketmq.utils.WeChatWorkBot;
 import com.ruoyi.system.api.RemoteRevenueConfigService;
 import com.ruoyi.system.api.domain.*;
 import lombok.extern.slf4j.Slf4j;
@@ -89,6 +92,8 @@ public class MessageHandler {
     private IInitialBandwidthTrafficTempService initialBandwidthTrafficTempService;
     @Autowired
     private IRmAlarmLogService rmAlarmLogService;
+    @Autowired
+    private IRmAlarmPushConfigService rmAlarmPushConfigService;
 
 
     /**
@@ -1014,6 +1019,8 @@ public class MessageHandler {
                     if (lostCount >= 3) {
                         log.warn("客户端ID: {} 连续三次心跳丢失，触发告警", clientId);
                         insertHeartbeatLog(clientId, "3", "连续三次心跳丢失");
+                        // 告警
+                        insertAlarmRecords(clientId);
                         redisTemplate.opsForValue().set(HEARTBEAT_ALERT_PREFIX + clientId, "1");
                         // 设置告警后删除timeKey和statusKey
                         redisTemplate.delete(timeKey);
@@ -1103,12 +1110,31 @@ public class MessageHandler {
         // 查询此告警是否存在
         RmAlarmLog query = new RmAlarmLog();
         query.setClientId(clientId);
-        query.setAlarmType("1");
+        query.setAlarmType(AlarmTypeEnum.服务器下线.getCode());
         List<RmAlarmLog> alarmLog = rmAlarmLogService.selectRmAlarmLogList(query);
         if(alarmLog != null && !alarmLog.isEmpty()){
             rmAlarmLogService.updateRmAlarmLog(rmAlarmLog);
         }else{
             rmAlarmLogService.insertRmAlarmLog(rmAlarmLog);
+            // 拿到消息模板
+            RmAlarmPushConfig rmAlarmPushConfig = new RmAlarmPushConfig();
+            rmAlarmPushConfig.setPushMethod(PushMethodEnum.企业微信.getCode());
+            rmAlarmPushConfig.setPushAlarmTypes(AlarmTypeEnum.服务器下线.getCode());
+            List<RmAlarmPushConfig> alarmConfigList = rmAlarmPushConfigService.selectRmAlarmPushConfigList(rmAlarmPushConfig);
+            if(alarmConfigList != null && !alarmConfigList.isEmpty()){
+                for (RmAlarmPushConfig alarmPushConfig : alarmConfigList) {
+                    String contentTemplate = alarmPushConfig.getMessageContent();
+                    String webhookUrl = alarmPushConfig.getPushAddress();
+                    Map<String, Object> alarmMap = new HashMap<>();
+                    alarmMap.put("告警时间", rmAlarmLog.getAlarmTime());
+                    alarmMap.put("管理网-公网IP", rmAlarmLog.getMgmPublicIp());
+                    alarmMap.put("告警类型", AlarmTypeEnum.服务器下线.getMsg());
+                    alarmMap.put("告警设备", rmAlarmLog.getClientId());
+                    alarmMap.put("告警内容", rmAlarmLog.getAlarmContent());
+                    // 推送消息到企业微信
+                    WeChatWorkBot.sendTemplateMessage(webhookUrl, contentTemplate, alarmMap);
+                }
+            }
         }
 
     }
diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmPushConfigMapper.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmPushConfigMapper.java
new file mode 100644
index 0000000..38962ce
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/mapper/RmAlarmPushConfigMapper.java
@@ -0,0 +1,61 @@
+package com.ruoyi.rocketmq.mapper;
+
+import java.util.List;
+import com.ruoyi.rocketmq.domain.RmAlarmPushConfig;
+
+/**
+ * 告警推送配置Mapper接口
+ * 
+ * @author gyt
+ * @date 2025-11-11
+ */
+public interface RmAlarmPushConfigMapper 
+{
+    /**
+     * 查询告警推送配置
+     * 
+     * @param id 告警推送配置主键
+     * @return 告警推送配置
+     */
+    public RmAlarmPushConfig selectRmAlarmPushConfigById(Long id);
+
+    /**
+     * 查询告警推送配置列表
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 告警推送配置集合
+     */
+    public List<RmAlarmPushConfig> selectRmAlarmPushConfigList(RmAlarmPushConfig rmAlarmPushConfig);
+
+    /**
+     * 新增告警推送配置
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 结果
+     */
+    public int insertRmAlarmPushConfig(RmAlarmPushConfig rmAlarmPushConfig);
+
+    /**
+     * 修改告警推送配置
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 结果
+     */
+    public int updateRmAlarmPushConfig(RmAlarmPushConfig rmAlarmPushConfig);
+
+    /**
+     * 删除告警推送配置
+     * 
+     * @param id 告警推送配置主键
+     * @return 结果
+     */
+    public int deleteRmAlarmPushConfigById(Long id);
+
+    /**
+     * 批量删除告警推送配置
+     * 
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteRmAlarmPushConfigByIds(Long[] ids);
+}
diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmPushConfigService.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmPushConfigService.java
new file mode 100644
index 0000000..f558ade
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/IRmAlarmPushConfigService.java
@@ -0,0 +1,61 @@
+package com.ruoyi.rocketmq.service;
+
+import java.util.List;
+import com.ruoyi.rocketmq.domain.RmAlarmPushConfig;
+
+/**
+ * 告警推送配置Service接口
+ * 
+ * @author gyt
+ * @date 2025-11-11
+ */
+public interface IRmAlarmPushConfigService 
+{
+    /**
+     * 查询告警推送配置
+     * 
+     * @param id 告警推送配置主键
+     * @return 告警推送配置
+     */
+    public RmAlarmPushConfig selectRmAlarmPushConfigById(Long id);
+
+    /**
+     * 查询告警推送配置列表
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 告警推送配置集合
+     */
+    public List<RmAlarmPushConfig> selectRmAlarmPushConfigList(RmAlarmPushConfig rmAlarmPushConfig);
+
+    /**
+     * 新增告警推送配置
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 结果
+     */
+    public int insertRmAlarmPushConfig(RmAlarmPushConfig rmAlarmPushConfig);
+
+    /**
+     * 修改告警推送配置
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 结果
+     */
+    public int updateRmAlarmPushConfig(RmAlarmPushConfig rmAlarmPushConfig);
+
+    /**
+     * 批量删除告警推送配置
+     * 
+     * @param ids 需要删除的告警推送配置主键集合
+     * @return 结果
+     */
+    public int deleteRmAlarmPushConfigByIds(Long[] ids);
+
+    /**
+     * 删除告警推送配置信息
+     * 
+     * @param id 告警推送配置主键
+     * @return 结果
+     */
+    public int deleteRmAlarmPushConfigById(Long id);
+}
diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmPushConfigServiceImpl.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmPushConfigServiceImpl.java
new file mode 100644
index 0000000..0390bcc
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/service/impl/RmAlarmPushConfigServiceImpl.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.RmAlarmPushConfigMapper;
+import com.ruoyi.rocketmq.domain.RmAlarmPushConfig;
+import com.ruoyi.rocketmq.service.IRmAlarmPushConfigService;
+
+/**
+ * 告警推送配置Service业务层处理
+ * 
+ * @author gyt
+ * @date 2025-11-11
+ */
+@Service
+public class RmAlarmPushConfigServiceImpl implements IRmAlarmPushConfigService 
+{
+    @Autowired
+    private RmAlarmPushConfigMapper rmAlarmPushConfigMapper;
+
+    /**
+     * 查询告警推送配置
+     * 
+     * @param id 告警推送配置主键
+     * @return 告警推送配置
+     */
+    @Override
+    public RmAlarmPushConfig selectRmAlarmPushConfigById(Long id)
+    {
+        return rmAlarmPushConfigMapper.selectRmAlarmPushConfigById(id);
+    }
+
+    /**
+     * 查询告警推送配置列表
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 告警推送配置
+     */
+    @Override
+    public List<RmAlarmPushConfig> selectRmAlarmPushConfigList(RmAlarmPushConfig rmAlarmPushConfig)
+    {
+        return rmAlarmPushConfigMapper.selectRmAlarmPushConfigList(rmAlarmPushConfig);
+    }
+
+    /**
+     * 新增告警推送配置
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 结果
+     */
+    @Override
+    public int insertRmAlarmPushConfig(RmAlarmPushConfig rmAlarmPushConfig)
+    {
+        rmAlarmPushConfig.setCreateTime(DateUtils.getNowDate());
+        return rmAlarmPushConfigMapper.insertRmAlarmPushConfig(rmAlarmPushConfig);
+    }
+
+    /**
+     * 修改告警推送配置
+     * 
+     * @param rmAlarmPushConfig 告警推送配置
+     * @return 结果
+     */
+    @Override
+    public int updateRmAlarmPushConfig(RmAlarmPushConfig rmAlarmPushConfig)
+    {
+        rmAlarmPushConfig.setUpdateTime(DateUtils.getNowDate());
+        return rmAlarmPushConfigMapper.updateRmAlarmPushConfig(rmAlarmPushConfig);
+    }
+
+    /**
+     * 批量删除告警推送配置
+     * 
+     * @param ids 需要删除的告警推送配置主键
+     * @return 结果
+     */
+    @Override
+    public int deleteRmAlarmPushConfigByIds(Long[] ids)
+    {
+        return rmAlarmPushConfigMapper.deleteRmAlarmPushConfigByIds(ids);
+    }
+
+    /**
+     * 删除告警推送配置信息
+     * 
+     * @param id 告警推送配置主键
+     * @return 结果
+     */
+    @Override
+    public int deleteRmAlarmPushConfigById(Long id)
+    {
+        return rmAlarmPushConfigMapper.deleteRmAlarmPushConfigById(id);
+    }
+}
diff --git a/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/utils/WeChatWorkBot.java b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/utils/WeChatWorkBot.java
new file mode 100644
index 0000000..dca7b38
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/java/com/ruoyi/rocketmq/utils/WeChatWorkBot.java
@@ -0,0 +1,285 @@
+package com.ruoyi.rocketmq.utils;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+public class WeChatWorkBot {
+    private static final ObjectMapper mapper = new ObjectMapper();
+
+    /**
+     * 发送基于模板的文本消息
+     * @param webhookUrl webhook地址
+     * @param template 消息模板，例如："项目[项目名称]在[时间]发生[事件类型]"
+     * @param fieldValues 字段值的映射，key为中文字段名，value为实际值（支持String、Number、Boolean等）
+     * @return 是否发送成功
+     */
+    public static boolean sendTemplateMessage(String webhookUrl, String template,
+                                              Map<String, Object> fieldValues) {
+        return sendTemplateMessage(webhookUrl, template, fieldValues, null, null, false);
+    }
+
+    /**
+     * 发送基于模板的文本消息（支持@功能）
+     * @param webhookUrl webhook地址
+     * @param template 消息模板
+     * @param fieldValues 字段值的映射
+     * @param mentionedList 被@的用户列表（手机号）
+     * @param mentionedAll 是否@所有人
+     * @return 是否发送成功
+     */
+    public static boolean sendTemplateMessage(String webhookUrl, String template,
+                                              Map<String, Object> fieldValues,
+                                              String[] mentionedList, boolean mentionedAll) {
+        return sendTemplateMessage(webhookUrl, template, fieldValues, null, mentionedList, mentionedAll);
+    }
+
+    /**
+     * 发送基于模板的文本消息（完整参数）
+     * @param webhookUrl webhook地址
+     * @param template 消息模板
+     * @param fieldValues 字段值的映射
+     * @param defaultValue 未找到字段时的默认值
+     * @param mentionedList 被@的用户列表（手机号）
+     * @param mentionedAll 是否@所有人
+     * @return 是否发送成功
+     */
+    public static boolean sendTemplateMessage(String webhookUrl, String template,
+                                              Map<String, Object> fieldValues, Object defaultValue,
+                                              String[] mentionedList, boolean mentionedAll) {
+        try {
+            String actualContent = processTemplate(template, fieldValues, defaultValue);
+            return sendTextMessage(webhookUrl, actualContent, mentionedList, mentionedAll);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 处理模板，替换字段占位符
+     * @param template 消息模板
+     * @param fieldValues 字段值映射
+     * @param defaultValue 默认值
+     * @return 处理后的消息内容
+     */
+    public static String processTemplate(String template, Map<String, Object> fieldValues,
+                                         Object defaultValue) {
+        if (template == null) return "";
+        if (fieldValues == null || fieldValues.isEmpty()) {
+            return template;
+        }
+
+        Pattern pattern = Pattern.compile("\\[(.*?)\\]");
+        Matcher matcher = pattern.matcher(template);
+        StringBuffer result = new StringBuffer();
+
+        while (matcher.find()) {
+            String fieldName = matcher.group(1);
+            Object fieldValueObj = fieldValues.get(fieldName);
+            String fieldValue = convertToString(fieldValueObj);
+
+            // 如果字段值为空，使用默认值或保留原占位符
+            if (fieldValue == null || fieldValue.trim().isEmpty()) {
+                fieldValue = convertToString(defaultValue);
+                if (fieldValue == null) {
+                    fieldValue = "[" + fieldName + "]";
+                }
+            }
+
+            // 对替换值进行转义，防止正则表达式特殊字符问题
+            matcher.appendReplacement(result, Matcher.quoteReplacement(fieldValue));
+        }
+        matcher.appendTail(result);
+
+        return result.toString();
+    }
+
+    /**
+     * 将对象转换为字符串
+     * @param obj 要转换的对象
+     * @return 字符串表示
+     */
+    private static String convertToString(Object obj) {
+        if (obj == null) {
+            return null;
+        }
+
+        if (obj instanceof String) {
+            return (String) obj;
+        } else if (obj instanceof Number || obj instanceof Boolean) {
+            return String.valueOf(obj);
+        } else if (obj instanceof java.util.Date) {
+            return new java.text.SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format((java.util.Date) obj);
+        } else {
+            return obj.toString();
+        }
+    }
+
+    /**
+     * 验证模板中的字段是否都有对应的值
+     * @param template 消息模板
+     * @param fieldValues 字段值映射
+     * @return 是否所有字段都有值
+     */
+    public static boolean validateTemplate(String template, Map<String, Object> fieldValues) {
+        if (template == null || fieldValues == null) {
+            return false;
+        }
+
+        Pattern pattern = Pattern.compile("\\[(.*?)\\]");
+        Matcher matcher = pattern.matcher(template);
+
+        while (matcher.find()) {
+            String fieldName = matcher.group(1);
+            Object fieldValue = fieldValues.get(fieldName);
+            String strValue = convertToString(fieldValue);
+
+            if (!fieldValues.containsKey(fieldName) ||
+                    strValue == null ||
+                    strValue.trim().isEmpty()) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    /**
+     * 获取模板中的所有字段名
+     * @param template 消息模板
+     * @return 字段名列表
+     */
+    public static java.util.List<String> getTemplateFields(String template) {
+        java.util.List<String> fields = new java.util.ArrayList<>();
+        if (template == null) {
+            return fields;
+        }
+
+        Pattern pattern = Pattern.compile("\\[(.*?)\\]");
+        Matcher matcher = pattern.matcher(template);
+
+        while (matcher.find()) {
+            fields.add(matcher.group(1));
+        }
+        return fields;
+    }
+
+    /**
+     * 发送Markdown模板消息
+     * @param webhookUrl webhook地址
+     * @param template Markdown模板
+     * @param fieldValues 字段值映射
+     * @return 是否发送成功
+     */
+    public static boolean sendMarkdownTemplateMessage(String webhookUrl, String template,
+                                                      Map<String, Object> fieldValues) {
+        return sendMarkdownTemplateMessage(webhookUrl, template, fieldValues, null);
+    }
+
+    /**
+     * 发送Markdown模板消息
+     * @param webhookUrl webhook地址
+     * @param template Markdown模板
+     * @param fieldValues 字段值映射
+     * @param defaultValue 默认值
+     * @return 是否发送成功
+     */
+    public static boolean sendMarkdownTemplateMessage(String webhookUrl, String template,
+                                                      Map<String, Object> fieldValues,
+                                                      Object defaultValue) {
+        try {
+            String actualContent = processTemplate(template, fieldValues, defaultValue);
+            return sendMarkdownMessage(webhookUrl, actualContent);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 发送文本消息
+     */
+    public static boolean sendTextMessage(String webhookUrl, String content) {
+        return sendTextMessage(webhookUrl, content, null, false);
+    }
+
+    /**
+     * 发送文本消息（支持@功能）
+     */
+    public static boolean sendTextMessage(String webhookUrl, String content,
+                                          String[] mentionedList, boolean mentionedAll) {
+        try {
+            Map<String, Object> message = new HashMap<>();
+            message.put("msgtype", "text");
+
+            Map<String, Object> textContent = new HashMap<>();
+            textContent.put("content", content);
+
+            if (mentionedAll) {
+                textContent.put("mentioned_list", new String[]{"@all"});
+            } else if (mentionedList != null && mentionedList.length > 0) {
+                textContent.put("mentioned_list", mentionedList);
+            }
+
+            message.put("text", textContent);
+
+            return sendMessage(webhookUrl, mapper.writeValueAsString(message));
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 发送Markdown消息
+     */
+    public static boolean sendMarkdownMessage(String webhookUrl, String content) {
+        try {
+            Map<String, Object> message = new HashMap<>();
+            message.put("msgtype", "markdown");
+
+            Map<String, Object> markdownContent = new HashMap<>();
+            markdownContent.put("content", content);
+
+            message.put("markdown", markdownContent);
+
+            return sendMessage(webhookUrl, mapper.writeValueAsString(message));
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    private static boolean sendMessage(String webhookUrl, String jsonBody) {
+        try {
+            URL url = new URL(webhookUrl);
+            HttpURLConnection connection = (HttpURLConnection) url.openConnection();
+
+            connection.setRequestMethod("POST");
+            connection.setRequestProperty("Content-Type", "application/json");
+            connection.setDoOutput(true);
+            connection.setConnectTimeout(5000);
+            connection.setReadTimeout(10000);
+
+            try (OutputStream os = connection.getOutputStream()) {
+                byte[] input = jsonBody.getBytes("UTF-8");
+                os.write(input, 0, input.length);
+            }
+
+            int responseCode = connection.getResponseCode();
+            return responseCode == 200;
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+}
\ No newline at end of file
diff --git a/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmPushConfigMapper.xml b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmPushConfigMapper.xml
new file mode 100644
index 0000000..f7a7386
--- /dev/null
+++ b/ruoyi-rocketmq/src/main/resources/mapper/rocketmq/RmAlarmPushConfigMapper.xml
@@ -0,0 +1,97 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ruoyi.rocketmq.mapper.RmAlarmPushConfigMapper">
+    
+    <resultMap type="RmAlarmPushConfig" id="RmAlarmPushConfigResult">
+        <result property="id"    column="id"    />
+        <result property="configName"    column="config_name"    />
+        <result property="pushMethod"    column="push_method"    />
+        <result property="pushAddress"    column="push_address"    />
+        <result property="pushAlarmTypes"    column="push_alarm_types"    />
+        <result property="messageContent"    column="message_content"    />
+        <result property="contactPhones"    column="contact_phones"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateTime"    column="update_time"    />
+        <result property="createBy"    column="create_by"    />
+        <result property="updateBy"    column="update_by"    />
+    </resultMap>
+
+    <sql id="selectRmAlarmPushConfigVo">
+        select id, config_name, push_method, push_address, push_alarm_types, message_content, contact_phones, create_time, update_time, create_by, update_by from rm_alarm_push_config
+    </sql>
+
+    <select id="selectRmAlarmPushConfigList" parameterType="RmAlarmPushConfig" resultMap="RmAlarmPushConfigResult">
+        <include refid="selectRmAlarmPushConfigVo"/>
+        <where>  
+            <if test="configName != null  and configName != ''"> and config_name like concat('%', #{configName}, '%')</if>
+            <if test="pushMethod != null  and pushMethod != ''"> and push_method = #{pushMethod}</if>
+            <if test="pushAddress != null  and pushAddress != ''"> and push_address = #{pushAddress}</if>
+            <if test="pushAlarmTypes != null  and pushAlarmTypes != ''"> and push_alarm_types = #{pushAlarmTypes}</if>
+            <if test="messageContent != null  and messageContent != ''"> and message_content = #{messageContent}</if>
+            <if test="contactPhones != null  and contactPhones != ''"> and contact_phones = #{contactPhones}</if>
+        </where>
+    </select>
+    
+    <select id="selectRmAlarmPushConfigById" parameterType="Long" resultMap="RmAlarmPushConfigResult">
+        <include refid="selectRmAlarmPushConfigVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertRmAlarmPushConfig" parameterType="RmAlarmPushConfig" useGeneratedKeys="true" keyProperty="id">
+        insert into rm_alarm_push_config
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="configName != null and configName != ''">config_name,</if>
+            <if test="pushMethod != null and pushMethod != ''">push_method,</if>
+            <if test="pushAddress != null and pushAddress != ''">push_address,</if>
+            <if test="pushAlarmTypes != null">push_alarm_types,</if>
+            <if test="messageContent != null">message_content,</if>
+            <if test="contactPhones != null">contact_phones,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateTime != null">update_time,</if>
+            <if test="createBy != null">create_by,</if>
+            <if test="updateBy != null">update_by,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="configName != null and configName != ''">#{configName},</if>
+            <if test="pushMethod != null and pushMethod != ''">#{pushMethod},</if>
+            <if test="pushAddress != null and pushAddress != ''">#{pushAddress},</if>
+            <if test="pushAlarmTypes != null">#{pushAlarmTypes},</if>
+            <if test="messageContent != null">#{messageContent},</if>
+            <if test="contactPhones != null">#{contactPhones},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+            <if test="createBy != null">#{createBy},</if>
+            <if test="updateBy != null">#{updateBy},</if>
+         </trim>
+    </insert>
+
+    <update id="updateRmAlarmPushConfig" parameterType="RmAlarmPushConfig">
+        update rm_alarm_push_config
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="configName != null and configName != ''">config_name = #{configName},</if>
+            <if test="pushMethod != null and pushMethod != ''">push_method = #{pushMethod},</if>
+            <if test="pushAddress != null and pushAddress != ''">push_address = #{pushAddress},</if>
+            <if test="pushAlarmTypes != null">push_alarm_types = #{pushAlarmTypes},</if>
+            <if test="messageContent != null">message_content = #{messageContent},</if>
+            <if test="contactPhones != null">contact_phones = #{contactPhones},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+            <if test="createBy != null">create_by = #{createBy},</if>
+            <if test="updateBy != null">update_by = #{updateBy},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteRmAlarmPushConfigById" parameterType="Long">
+        delete from rm_alarm_push_config where id = #{id}
+    </delete>
+
+    <delete id="deleteRmAlarmPushConfigByIds" parameterType="String">
+        delete from rm_alarm_push_config where id in 
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>
\ No newline at end of file