消息类型拆分并按类型推送至不同角色

hyingbo

2025-05-27 3a740faa161ec976986c0735ba18837f570a525f

 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/controller/MdcMessageApprovalController.java

@@ -5,10 +5,12 @@
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.api.dto.message.MessageDTO;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.aspect.annotation.AutoLog;
import org.jeecg.common.constant.enums.MessageSplitTypeEnum;
import org.jeecg.common.system.api.ISysBaseAPI;
import org.jeecg.common.system.base.controller.JeecgController;
import org.jeecg.common.system.vo.LoginUser;
@@ -75,7 +77,13 @@
    @ApiOperation(value = "mdc消息确认表-添加", notes = "mdc消息确认表-添加")
    @PostMapping(value = "/add")
    public Result<?> add(@RequestBody MdcMessageApproval mdcMessageApproval) {
        mdcMessageApprovalService.save(mdcMessageApproval);
        if (StringUtils.isBlank(mdcMessageApproval.getEquipmentId())) {
            return Result.error("未选择设备，请排查！");
        }
        boolean result = mdcMessageApprovalService.add(mdcMessageApproval);
        if (!result) {
            return Result.error("添加失败！");
        }
        return Result.OK("添加成功！");
    }

@@ -172,6 +180,7 @@
            //上报原因发送消息给确认人
            MessageDTO messageDTO = new MessageDTO();
            messageDTO.setTitle("设备状态长时间未变化原因上报确认！");
            messageDTO.setMessageType(MessageSplitTypeEnum.statusPermanentlyNoChange.getType());
            messageDTO.setCategory("消息");
            LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
            messageDTO.setFromUser(user.getUsername());
@@ -198,6 +207,7 @@
            messageDTO.setTitle("设备状态消息！");
            messageDTO.setCategory("消息");
            messageDTO.setFromUser("admin");
            messageDTO.setMessageType(MessageSplitTypeEnum.statusPermanentlyNoChange.getType());
            messageDTO.setToUser(mdcMessageApproval.getUpdateBy());
            messageDTO.setContent("您的设备编号为 [" + mdcMessageApproval.getEquipmentId() + "] 的设备状态长时间未变化上报已被设备超级管理员拒绝，请重新填写上报原因！");
            sysBaseApi.sendSysAnnouncement(messageDTO);