| | |
| | | package com.ycl.service.message.impl; |
| | | |
| | | import cn.hutool.core.net.url.UrlBuilder; |
| | | import cn.hutool.core.net.url.UrlPath; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
| | |
| | | import com.ycl.mapper.user.UmsAdminMapper; |
| | | import com.ycl.service.message.IMessageService; |
| | | import com.ycl.utils.MD5Util; |
| | | import com.ycl.vo.message.MessageVO; |
| | | import lombok.SneakyThrows; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.beans.BeanUtils; |
| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public String sendMessage(Message message) { |
| | | |
| | | Message savedMessage = messageMapper.selectOne(new LambdaQueryWrapper<Message>() |
| | | .eq(Message::getTargetTo, message.getTargetTo()) |
| | | .eq(Message::getTargetFrom, message.getTargetFrom())); |
| | | .eq(Message::getTargetFrom, message.getTargetFrom()) |
| | | .eq(Message::getBody, message.getBody()) |
| | | .eq(Message::getHead, message.getHead())); |
| | | if (savedMessage != null) { |
| | | messageMapper.deleteById(savedMessage); |
| | | } |
| | | |
| | | ArrayList<Long> ids = new ArrayList<>(); |
| | | |
| | | message.setTargetFrom(umsAdminMapper.selectById(message.getCreateUser()).getUsername()); |
| | | for (String receive : message.getTargetTo().split(",")) { |
| | | Message sendMessage = new Message(); |
| | | BeanUtils.copyProperties(message, sendMessage); |
| | |
| | | //短信发送 |
| | | case ChannelCode.MAIL: |
| | | sendMail(message); |
| | | break; |
| | | case ChannelCode.INNER: |
| | | break; |
| | | default: |
| | | throw new ApiException("未匹配到该类型"); |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Page<Message> list(MessageParam messageParam) { |
| | | public Page<MessageVO> list(MessageParam messageParam) { |
| | | Page<Message> page = new Page<>(messageParam.getCurrent(), messageParam.getPageSize()); |
| | | return messageMapper.selectMessagePage(page,messageParam); |
| | | return messageMapper.selectMessagePage(page, messageParam); |
| | | } |
| | | |
| | | @Override |