diff --git a/laws-modules-docking/src/main/java/com/jero/modules/docking/hiwork/service/impl/SendMessageServiceImpl.java b/laws-modules-docking/src/main/java/com/jero/modules/docking/hiwork/service/impl/SendMessageServiceImpl.java index 650eb831..f56fce94 100644 --- a/laws-modules-docking/src/main/java/com/jero/modules/docking/hiwork/service/impl/SendMessageServiceImpl.java +++ b/laws-modules-docking/src/main/java/com/jero/modules/docking/hiwork/service/impl/SendMessageServiceImpl.java @@ -16,6 +16,7 @@ import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import javax.annotation.Resource; +import java.util.Arrays; import java.util.List; import java.util.Map; import java.util.Objects; @@ -64,22 +65,23 @@ public class SendMessageServiceImpl implements SendMessageAPI { sysMessageTemplate.getTemplateContent().replace("${" + k + "}", v))); } - ISendMsgHandle sendMsgHandle; - - if ("5".equals(sysMessageTemplate.getTemplateType())) { - // Hiwork钉钉消息 - sendMsgHandle = new DingDingSendMsgHandle(); - } else if ("6".equals(sysMessageTemplate.getTemplateType())) { - // Hiwork系统消息 - sendMsgHandle = new SystemSendMsgHandle(); - } else { - return; - } - log.info("消息标题:{},消息内容:{}", sysMessageTemplate.getTemplateName(),sysMessageTemplate.getTemplateContent()); - if (!isSend) { - return; - } - sendMsgHandle.SendMsg(sendMessageDTO.getToUserId(), sysMessageTemplate.getTemplateName(), sysMessageTemplate.getTemplateContent()); + List typeList = Arrays.asList(sysMessageTemplate.getTemplateType().split(",")); + typeList.forEach(type -> { + ISendMsgHandle sendMsgHandle; + if ("5".equals(type)) { + // Hiwork钉钉消息 + sendMsgHandle = new DingDingSendMsgHandle(); + } else if ("6".equals(type)) { + // Hiwork系统消息 + sendMsgHandle = new SystemSendMsgHandle(); + } else { + return; + } + log.info("消息标题:{},消息内容:{},消息类型:{}", sysMessageTemplate.getTemplateName(),sysMessageTemplate.getTemplateContent(), type); + if (isSend) { + sendMsgHandle.SendMsg(sendMessageDTO.getToUserId(), sysMessageTemplate.getTemplateName(), sysMessageTemplate.getTemplateContent()); + } + }); } catch (Exception e){ log.error("发送消息异常",e); throw new JeroBootException("发送消息异常");