| | |
| | | import com.ycl.entity.message.Message; |
| | | import com.ycl.mapper.message.MessageMapper; |
| | | import com.ycl.service.message.IMessageService; |
| | | import org.springframework.beans.BeanUtils; |
| | | import com.ycl.service.message.Provider; |
| | | import com.ycl.service.message.Sender; |
| | | import com.ycl.service.message.factory.InnerFactory; |
| | | import com.ycl.service.message.factory.MailFactory; |
| | | import com.ycl.service.message.factory.SmsFactory; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.Date; |
| | | |
| | | /** |
| | | * <p> |
| | |
| | | @Service |
| | | public class IMessageServiceImpl extends ServiceImpl<MessageMapper, Message> implements IMessageService { |
| | | @Override |
| | | public Message sendMessage(MessageParam mssageParam) { |
| | | Message message = new Message(); |
| | | BeanUtils.copyProperties(mssageParam, message); |
| | | //生成默认参数 |
| | | message.setCreateTime(new Date()); |
| | | message.setUpdateTime(new Date()); |
| | | baseMapper.insert(message); |
| | | public Message sendMessage(MessageParam messageParam) { |
| | | Message message = null; |
| | | Provider provider = null; |
| | | switch (messageParam.getChannelCode()) |
| | | { |
| | | //内站发送 |
| | | case "01": |
| | | provider = new InnerFactory(); |
| | | break; |
| | | //邮件发送 |
| | | case "02": |
| | | provider = new MailFactory(); |
| | | break; |
| | | //短信发送 |
| | | case "03": |
| | | provider = new SmsFactory(); |
| | | break; |
| | | default: |
| | | System.out.println("抛异常"); |
| | | } |
| | | Sender sender = provider.produce(); |
| | | sender.sendMessage(messageParam); |
| | | return message; |
| | | } |
| | | } |