| | |
| | | @Override |
| | | @Transactional |
| | | public void sendMessage(Message message, List<MessageUser> messageUsers) { |
| | | messageMapper.insertSelective(message); |
| | | messageMapper.insert(message); |
| | | messageUsers.forEach(d -> d.setMessageId(message.getId())); |
| | | messageUserMapper.inserts(messageUsers); |
| | | } |
| | |
| | | @Override |
| | | @Transactional |
| | | public void read(Integer id) { |
| | | MessageUser messageUser = messageUserMapper.selectByPrimaryKey(id); |
| | | MessageUser messageUser = messageUserMapper.selectById(id); |
| | | if (messageUser.getReaded()) |
| | | return; |
| | | messageUser.setReaded(true); |
| | | messageUser.setReadTime(new Date()); |
| | | messageUserMapper.updateByPrimaryKeySelective(messageUser); |
| | | messageUserMapper.updateById(messageUser); |
| | | messageMapper.readAdd(messageUser.getMessageId()); |
| | | } |
| | | |
| | |
| | | |
| | | @Override |
| | | public Message messageDetail(Integer id) { |
| | | MessageUser messageUser = messageUserMapper.selectByPrimaryKey(id); |
| | | return messageMapper.selectByPrimaryKey(messageUser.getMessageId()); |
| | | MessageUser messageUser = messageUserMapper.selectById(id); |
| | | return messageMapper.selectById(messageUser.getMessageId()); |
| | | } |
| | | |
| | | } |