From cea9df7a2004dcd4c7e007e085c1e358ae5bb374 Mon Sep 17 00:00:00 2001 From: mg <maokecheng@163.com> Date: 星期三, 12 十月 2022 14:53:42 +0800 Subject: [PATCH] 添加机构用户查询,新增角色类类型字段 --- ycl-platform/src/main/java/com/ycl/service/message/impl/IMessageServiceImpl.java | 16 +++++++++++++++- 1 files changed, 15 insertions(+), 1 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/service/message/impl/IMessageServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/message/impl/IMessageServiceImpl.java index 79fb6e3..77a4d29 100644 --- a/ycl-platform/src/main/java/com/ycl/service/message/impl/IMessageServiceImpl.java +++ b/ycl-platform/src/main/java/com/ycl/service/message/impl/IMessageServiceImpl.java @@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ycl.dto.message.MessageParam; import com.ycl.entity.message.Message; +import com.ycl.exception.ApiException; import com.ycl.mapper.message.MessageMapper; import com.ycl.service.message.IMessageService; import com.ycl.service.message.Provider; @@ -13,6 +14,8 @@ import com.ycl.service.message.factory.InnerFactory; import com.ycl.service.message.factory.MailFactory; import com.ycl.service.message.factory.SmsFactory; +import com.ycl.service.user.UmsAdminService; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; /** @@ -25,6 +28,10 @@ */ @Service public class IMessageServiceImpl extends ServiceImpl<MessageMapper, Message> implements IMessageService { + + @Autowired + private UmsAdminService adminService; + @Override public Message sendMessage(MessageParam messageParam) { Message message = null; @@ -38,13 +45,20 @@ //閭欢鍙戦�� case "02": provider = new MailFactory(); + //id鎹㈡垚閭鍙� + String targetToMail = adminService.getTargetTo(messageParam.getTargetTo(), messageParam.getChannelCode()); + messageParam.setTargetTo(targetToMail); + break; //鐭俊鍙戦�� case "03": provider = new SmsFactory(); + //id鎹㈡垚鎵嬫満鍙� + String targetToPhone = adminService.getTargetTo(messageParam.getTargetTo(), messageParam.getChannelCode()); + messageParam.setTargetTo(targetToPhone); break; default: - System.out.println("鎶涘紓甯�"); + throw new ApiException("鏈尮閰嶅埌璇ョ被鍨�"); } Sender sender = provider.produce(); sender.sendMessage(messageParam); -- Gitblit v1.8.0