From d830cc0812ec66dcb6dd3300f09ab1998ab170e3 Mon Sep 17 00:00:00 2001 From: mg <maokecheng@163.com> Date: 星期三, 19 十月 2022 11:39:14 +0800 Subject: [PATCH] 添加发送消息优化。 --- ycl-platform/src/main/java/com/ycl/service/message/factory/InnerSender.java | 25 ++++++++++++++++++++++--- 1 files changed, 22 insertions(+), 3 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/service/message/factory/InnerSender.java b/ycl-platform/src/main/java/com/ycl/service/message/factory/InnerSender.java index 83a8744..6f7a149 100644 --- a/ycl-platform/src/main/java/com/ycl/service/message/factory/InnerSender.java +++ b/ycl-platform/src/main/java/com/ycl/service/message/factory/InnerSender.java @@ -4,6 +4,7 @@ import com.ycl.common.util.UtilNumber; import com.ycl.dto.message.MessageParam; import com.ycl.entity.message.Message; +import com.ycl.mapper.message.MessageMapper; import com.ycl.service.message.IMessageService; import com.ycl.service.message.Sender; import org.springframework.beans.BeanUtils; @@ -32,16 +33,35 @@ public void setIMessageService(IMessageService iMessageService) { InnerSender.iMessageService = iMessageService; } + private static MessageMapper messageMapper; + @Autowired + public void setMessageMapper(MessageMapper messageMapper) { + InnerSender.messageMapper = messageMapper; + } @Override public Message sendMessage(MessageParam messageParam) { Message message = new Message(); - List<Message> messages = new ArrayList<>(); - String[] ids = messageParam.getTargetTo().split(","); String messageNumber = UtilNumber.getNumber("MC", 6); + List<Message> messages = new ArrayList<>(); + BeanUtils.copyProperties(messageParam, message); + //鐢熸垚娑堟伅缂栫爜 + message.setMessageNumber(messageNumber); + //鐢熸垚榛樿鍙傛暟 + message.setIsView(0); + message.setVersion(0); + message.setIsScan(1); + message.setCreateTime(new Date()); + message.setUpdateTime(new Date()); + message.setCreateUser(messageParam.getCreateUser()); + message.setUpdateUser(messageParam.getCreateUser()); + messageMapper.insert(message); + String[] ids = messageParam.getTargetTo().split(","); for (String id : ids) { Message messageAdd = new Message(); BeanUtils.copyProperties(messageParam, messageAdd); + //璁剧疆鐖剁被Id + messageAdd.setParentId(message.getId()); //璁剧疆鎺ユ敹鑰� messageAdd.setTargetTo(id); //鐢熸垚8浣嶉殢鏈烘暟娑堟伅缂栫爜 @@ -64,7 +84,6 @@ messageAdd.setVersion(0); messages.add(messageAdd); } - BeanUtils.copyProperties(messageParam, message); //鎵归噺鏂板 iMessageService.saveBatch(messages); return message; -- Gitblit v1.8.0