From a3c999c3427ee38d9a3956fdff36b979a7703c5d Mon Sep 17 00:00:00 2001 From: liao Date: Fri, 10 Nov 2023 18:24:59 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E6=B6=88=E6=81=AF=E6=A8=A1=E6=9D=BF?= =?UTF-8?q?=E5=A4=9A=E9=80=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/SendMessageServiceImpl.java | 34 ++++++++++--------- 1 file changed, 18 insertions(+), 16 deletions(-) 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("发送消息异常");