| | |
| | | |
| | | import com.ycl.jxkg.domain.Message; |
| | | import com.ycl.jxkg.domain.MessageUser; |
| | | import com.ycl.jxkg.repository.MessageMapper; |
| | | import com.ycl.jxkg.repository.MessageUserMapper; |
| | | import com.ycl.jxkg.mapper.MessageMapper; |
| | | import com.ycl.jxkg.mapper.MessageUserMapper; |
| | | import com.ycl.jxkg.service.MessageService; |
| | | import com.ycl.jxkg.viewmodel.admin.message.MessagePageRequestVM; |
| | | import com.ycl.jxkg.viewmodel.student.user.MessageRequestVM; |
| | | import com.ycl.jxkg.vo.admin.message.MessagePageRequestVO; |
| | | import com.ycl.jxkg.vo.student.user.MessageRequestVO; |
| | | import com.github.pagehelper.PageHelper; |
| | | import com.github.pagehelper.PageInfo; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | } |
| | | |
| | | @Override |
| | | public PageInfo<MessageUser> studentPage(MessageRequestVM requestVM) { |
| | | public PageInfo<MessageUser> studentPage(MessageRequestVO requestVM) { |
| | | return PageHelper.startPage(requestVM.getPageIndex(), requestVM.getPageSize(), "id desc").doSelectPageInfo(() -> |
| | | messageUserMapper.studentPage(requestVM) |
| | | ); |
| | | } |
| | | |
| | | @Override |
| | | public PageInfo<Message> page(MessagePageRequestVM requestVM) { |
| | | public PageInfo<Message> page(MessagePageRequestVO requestVM) { |
| | | return PageHelper.startPage(requestVM.getPageIndex(), requestVM.getPageSize(), "id desc").doSelectPageInfo(() -> |
| | | messageMapper.page(requestVM) |
| | | ); |
| | |
| | | @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()); |
| | | } |
| | | |
| | | } |