1 微信开发文档如下图

2. 模板消息推送javaBean封装

package com.ruoyi.platform.weixin.domainTemplate;

import lombok.Data;

@Data
public class Template {
    //接收者openid
    private String touser;
    //模板ID
    private String template_id;
    //模板跳转链接
    private String url;
    //跳小程序所需数据，不需跳小程序可不用传该数据
    private String miniprogram;
    private MsgData data;


    public Template(String touser, String template_id, String url, String miniprogram, MsgData data) {
        this.touser = touser;
        this.template_id = template_id;
        this.url = url;
        this.miniprogram = miniprogram;
        this.data = data;
    }
}

根据自己选择的模板样式来封装模板数据

package com.ruoyi.platform.weixin.domainTemplate;

import lombok.Data;

@Data
public class MsgData {

    private MsgContent first;
    //报警类型 1消火栓 2烟感器 3消防水压 4水箱 5安全用电
    private MsgContent keyword1;
    //设备名称
    private MsgContent keyword2;
    //报警内容
    private MsgContent keyword3;
    //报警时间
    private MsgContent keyword4;
    //地址
    private MsgContent remark;

    public MsgData(MsgContent first, MsgContent keyword1, MsgContent keyword2, MsgContent keyword3, MsgContent keyword4, MsgContent remark) {
        this.first = first;
        this.keyword1 = keyword1;
        this.keyword2 = keyword2;
        this.keyword3 = keyword3;
        this.keyword4 = keyword4;
        this.remark = remark;
    }
}

package com.ruoyi.platform.weixin.domainTemplate;

import lombok.Data;

@Data
public class MsgContent {

    private String value;
    private String color;

    public MsgContent(String value, String color) {
        this.value = value;
        this.color = color;
    }


}

package com.ruoyi.platform.weixin.domainTemplate;

public enum EnumEquipment {

    Fire("1", "消火栓"), Smoke("2", "烟感器"), WaterPress("3", "消防水压"),WaterBox("4","消防水箱"),Aqyd("5","安全用电");

    private final String code;
    private final String name;

    EnumEquipment(String code, String name) {
        this.code = code;
        this.name = name;
    }

    public String getCode() {
        return code;
    }

    public String getName() {
        return name;
    }
}

package com.ruoyi.platform.zxhPushMsg.domain;

public enum EnumAlarmReason {


    XF_yongshui("110", "用水"),
    XF_kaigai("120", "开盖"),
    XF_dianyadi("130", "电池电压低"),
    XF_shuiyadi("140","水压低"),
    XF_shuiweidi("220","水位低"),
    XF_huojing("210","火警"),
    XF_lixian("200","离线"),

    AQYD_shengyudianliu("150","剩余电流"),
    AQYD_guoya("160","过压"),
    AQYD_guoliu("170","过流"),
    AQYD_qianya("180","欠压"),
    AQYD_chaowen("190","超温"),
    AQYD_duanxian("230","断线"),
    AQYD_duanlu("240","短路"),
    AQYD_lixian("999","离线");


    private final String code;
    private final String name;

    EnumAlarmReason(String code, String name) {
        this.code = code;
        this.name = name;
    }

    public String getCode() {
        return code;
    }

    public String getName() {
        return name;
    }
}

3. 模板消息推送服务

package com.ruoyi.platform.weixin.service;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ruoyi.common.utils.BdTools;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.HttpsUtil;
import com.ruoyi.platform.weixin.domainTemplate.EnumEquipment;
import com.ruoyi.platform.weixin.domainTemplate.MsgContent;
import com.ruoyi.platform.weixin.domainTemplate.MsgData;
import com.ruoyi.platform.weixin.domainTemplate.Template;
import com.ruoyi.platform.zxhPushMsg.domain.EnumAlarmReason;
import com.ruoyi.platform.zxhPushMsg.domain.ZxhPushMsg;
import com.ruoyi.platform.zxhPushMsg.service.IZxhPushMsgService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;


/**
 * 模板消息推送服务
 */
@Service
public class TemplateMessageService {

    @Autowired
    private WeiXinTokenService weiXinPublicService;
    @Autowired
    private IZxhPushMsgService zxhPushMsgService;

    /**
     * 定时任务轮询的方法
     */
    public void selectPushMsg() {
        QueryWrapper<ZxhPushMsg> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("zpm.del_flag", 0).eq("zpm.send_status", 0)
                .eq("zpm.msg_type", 1).eq("zpm.msg_status", 0);
        //sql语句左关联了用户表且已经按时间升序
        List<ZxhPushMsg> zxhPushMsgLsit = zxhPushMsgService.selectZxhPushMsgList(queryWrapper);
        if (!zxhPushMsgLsit.isEmpty()) {
            for (ZxhPushMsg zxhPushMsg : zxhPushMsgLsit) {
                String openId = zxhPushMsg.getOpenId();
                if (BdTools.notEmpty(openId)) {
                    String equipmentTypeName = this.getEquipmentType(zxhPushMsg.getHardwareType());
                    String hardwareName = zxhPushMsg.getHardwareName();
                    String alarmReasonInfo = this.alarmReasonInfo(zxhPushMsg.getPlatformType(), zxhPushMsg.getAlarmReason(), zxhPushMsg.getAlarmValue());
                    String occurrenceTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, zxhPushMsg.getOccurrenceTime());
                    String address = zxhPushMsg.getAddress();
                    Boolean aBoolean = this.initTemplateMsg(openId, equipmentTypeName, hardwareName, alarmReasonInfo, occurrenceTime, address);
                    if (aBoolean) {
                        //推送微信消息成功
                        //业务1：修改发送状态为已发送
                        this.updateSendStatus(zxhPushMsg.getId(), 1);

                    } else {
                        //推送微信消息失败--》更新发送状态为发送失败
                        this.updateSendStatus(zxhPushMsg.getId(), 99);
                    }
                }
            }
        }
    }

    /**
     * 封装接口所需格式的模板消息推送
     *
     * @param openId            用户openId
     * @param equipmentTypeName 设备类型  消火栓1  烟感器2 水压3  水箱4 安全用电5
     * @param equipmentName     设备名称
     * @param alarmContent      报警内容
     * @param occurrenceTime    报警发生时间
     * @param address           发生地址
     * @return
     */
    public Boolean initTemplateMsg(String openId, String equipmentTypeName, String equipmentName, String alarmContent, String occurrenceTime, String address) {
        // 模板ID
        String templateId = "jbYukFYPThnqiPSKZQ5MUYQU2AxPSOtAY3WvVi8cbRw";
        MsgContent first = new MsgContent("中旭昊智能科技提醒您", "#173177");
        // 报警类型 设备类型(1消火栓 2烟感器 3消防水压 4水箱 5安全用电)
        MsgContent kw1 = new MsgContent(equipmentTypeName, "#173177");
        // 设备名称
        MsgContent kw2 = new MsgContent(equipmentName, "#173177");
        // 报警内容
        MsgContent kw3 = new MsgContent(alarmContent, "#FF0000");
        //报警时间
        MsgContent kw4 = new MsgContent(occurrenceTime, "#173177");
        // 报警地址
        MsgContent remark = new MsgContent(address, "#173177");
        MsgData msgData = new MsgData(first, kw1, kw2, kw3, kw4, remark);
        Template template = new Template(openId, templateId, "http://qh.zxhznkj.com:8070/", "", msgData);
        String jsonData = JSONObject.toJSONString(template);
        //调用模板消息接口
        Boolean aBoolean = this.sendTemplateMsg(jsonData);
        return aBoolean;
    }

    /**
     * 调用模板消息接口
     *
     * @param jsonData
     * @return
     */
    public Boolean sendTemplateMsg(String jsonData) {
        //获取有效accessToken
        String accessToken = weiXinPublicService.accessTokenIsValid();
        String sendTemplatemsgUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken;
        String jsonResult = null;
        try {
            /**
             *  {
             *     "errcode":0,
             *      "errmsg":"ok",
             *      "msgid":200228332
             *   }
             */
            jsonResult = HttpsUtil.post(sendTemplatemsgUrl, null, jsonData);
            System.out.println(">>>>>>>>>>>>>>>>模板消息发送完成：" + jsonResult + ">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
            JSONObject object = JSON.parseObject(jsonResult);
            String errmsg = object.getString("errmsg");
            if ("ok".equals(errmsg)) {
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
        return false;
    }

    /**
     * 获取设备类型编号所对应的名称
     *
     * @param equipmentType 消火栓1  烟感器2 水压3  水箱4 安全用电5
     * @return
     */
    public String getEquipmentType(Integer equipmentType) {
        switch (equipmentType) {
            case 1:
                return EnumEquipment.Fire.getName();
            case 2:
                return EnumEquipment.Smoke.getName();
            case 3:
                return EnumEquipment.WaterPress.getName();
            case 4:
                return EnumEquipment.WaterBox.getName();
            case 5:
                return EnumEquipment.Aqyd.getName();
        }
        return null;
    }

    /**
     * 重新组装报警原因提示信息
     *
     * @param platformType 消息来源类型（1 消防 2用电）
     * @param alarmReason  报警原因
     * @param alarmValue   报警值
     * @return
     */
    public String alarmReasonInfo(Integer platformType, String alarmReason, String alarmValue) {
        String msg = null;
        //封装智慧消防平台报警信息
        if (platformType == 1) {
            if (EnumAlarmReason.XF_yongshui.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.XF_yongshui.getName();
            } else if (EnumAlarmReason.XF_kaigai.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.XF_kaigai.getName();
            } else if (EnumAlarmReason.XF_dianyadi.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.XF_kaigai.getName();
            } else if (EnumAlarmReason.XF_shuiyadi.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.XF_shuiyadi.getName();
            } else if (EnumAlarmReason.XF_shuiweidi.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.XF_shuiweidi.getName();
            } else if (EnumAlarmReason.XF_huojing.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.XF_huojing.getName();
            } else if (EnumAlarmReason.XF_lixian.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.XF_lixian.getName();
            }
            if (BdTools.notEmpty(alarmValue)) {
                return "发生" + msg + "报警，设备报警值" + alarmValue + "请及时查看处理.";
            }
            return "发生" + msg + "报警，请及时查看处理";
        }
        //封装安全用电平台报警信息
        if (platformType == 2) {
            if (EnumAlarmReason.AQYD_shengyudianliu.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.AQYD_shengyudianliu.getName();
            } else if (EnumAlarmReason.AQYD_guoya.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.AQYD_guoya.getName();
            } else if (EnumAlarmReason.AQYD_guoliu.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.AQYD_guoliu.getName();
            } else if (EnumAlarmReason.AQYD_qianya.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.AQYD_qianya.getName();
            } else if (EnumAlarmReason.AQYD_chaowen.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.AQYD_chaowen.getName();
            } else if (EnumAlarmReason.AQYD_duanxian.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.AQYD_duanxian.getName();
            } else if (EnumAlarmReason.AQYD_duanlu.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.AQYD_duanlu.getName();
            } else if (EnumAlarmReason.AQYD_lixian.getCode().equals(alarmReason)) {
                msg = EnumAlarmReason.AQYD_lixian.getName();
            }
            if (BdTools.notEmpty(alarmValue)) {
                return "发生" + msg + "报警，设备报警值" + alarmValue + "请及时查看处理.";
            }
            return "发生" + msg + "报警，请及时查看处理";
        }
        return null;
    }

    /**
     * 微信消息推送完成后,更新微信消息表中的发送状态
     *
     * @param pushMsgId
     * @param sendStatus 0 未发送 1 已发送 99 发送失败
     * @return
     */
    public Boolean updateSendStatus(Integer pushMsgId, Integer sendStatus) {
        ZxhPushMsg zxhPushMsg = new ZxhPushMsg();
        zxhPushMsg.setId(pushMsgId);
        zxhPushMsg.setSendStatus(sendStatus);
        boolean byId = zxhPushMsgService.updateById(zxhPushMsg);
        return byId;
    }
}