| | |
| | | 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.entity.message.Message; |
| | | import com.ycl.entity.message.SendReq; |
| | | import com.ycl.entity.message.SendRes; |
| | | import com.ycl.entity.user.UmsAdmin; |
| | | import com.ycl.exception.ApiException; |
| | | import com.ycl.mapper.message.MessageMapper; |
| | | import com.ycl.mapper.user.UmsAdminMapper; |
| | |
| | | Message savedMessage = messageMapper.selectOne(new LambdaQueryWrapper<Message>() |
| | | .eq(Message::getTargetTo, message.getTargetTo()) |
| | | .eq(Message::getTargetFrom, message.getTargetFrom()) |
| | | .eq(Message::getBody,message.getBody()) |
| | | .eq(Message::getHead,message.getHead())); |
| | | .eq(Message::getBody, message.getBody()) |
| | | .eq(Message::getHead, message.getHead())); |
| | | if (savedMessage != null) { |
| | | messageMapper.deleteById(savedMessage); |
| | | } |
| | |
| | | //短信发送 |
| | | case ChannelCode.MAIL: |
| | | sendMail(message); |
| | | break; |
| | | case ChannelCode.INNER: |
| | | break; |
| | | default: |
| | | throw new ApiException("未匹配到该类型"); |
| | |
| | | @Override |
| | | 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 |