add 发送邮件给客服

netflix-service/src/main/java/com/cyksj/service/mail/MailService.java

@@ -12,4 +12,6 @@ public interface MailService {
 	 * 邮箱登录验证码
 	 */
 	String sendLoginCodeEmailToPeople(Integer digit, String toAddress);
+
+	void sendEmailMsgToPeople(String people, String subject, String msg);
 }

netflix-service/src/main/java/com/cyksj/service/mail/impl/MailServiceImpl.java

@@ -46,6 +46,15 @@ public class MailServiceImpl implements MailService {
 		return null;
 	}
 
+	@Override
+	public void sendEmailMsgToPeople(String people, String subject, String msg) {
+		log.info("发送邮件至用户:{}开始", people);
+		if (sendMail(people, subject, msg)) {
+			log.info("发送成功");
+			return;
+		}
+	}
+
 
 	public boolean sendMail(String toAddress, String subject, String text) {
 		SimpleMailMessage msg = new SimpleMailMessage();

netflix-web/src/main/java/com/cyksj/web/controller/manage/AdminController.java

@@ -9,21 +9,16 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.cyksj.common.constant.WeChatTemplateConst;
 import com.cyksj.common.exception.BusinessRuntimeException;
 import com.cyksj.common.util.Codec;
-import com.cyksj.common.util.Jsons;
 import com.cyksj.dto.Result;
 import com.cyksj.enums.GatewayResponse;
-import com.cyksj.mapper.CustomerServiceMapper;
 import com.cyksj.mapper.PhoneCodeMapper;
-import com.cyksj.model.dto.WxMpTemplateData;
-import com.cyksj.model.dto.WxMpTemplateMessage;
 import com.cyksj.model.entity.PhoneCode;
 import com.cyksj.model.manage.dto.AdminInfo;
 import com.cyksj.model.manage.entity.Admin;
+import com.cyksj.service.mail.MailService;
 import com.cyksj.service.mange.AdminService;
-import com.cyksj.service.wechat.WeChatService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
@@ -52,19 +47,21 @@ public class AdminController {
 
     private final AdminService adminService;
 
-    private final HttpServletRequest request;
-
-    private final WeChatService weChatService;
+    private final PhoneCodeMapper phoneCodeMapper;
 
-    private final CustomerServiceMapper customerServiceMapper;
+    private final MailService mailService;
 
-    private final PhoneCodeMapper phoneCodeMapper;
+    private static final List<String> SEND_LIST = List.of(
+            "1935822056@qq.com",
+            "598488687@qq.com",
+            "1991846178@qq.com",
+            "3301493050@qq.com",
+            "1031494735@qq.com",
+            "1814454156@qq.com",
+            "1094366385@qq.com"
+    );
 
-    private static final List<String> SEND_LIST = List.of("oXxcY6HY-Ts-vRIc003ienh16gb0",
-            "oXxcY6AsLXAuVusm2HtVtrgD7mKA",
-            "oXxcY6AuRTHav3Rt7VblOnFBWQ00",
-            "oXxcY6InnkO78zu6THeqSOeKDQFg",
-            "oXxcY6GZrptgTr-U0spJxSOBQ_xc");
+    private static final String YOUTUBE_URL = "https://zhaoju666.com/youtube_subscribe/";
 
     @PostMapping(value = "/login")
     public Result<String> login(@RequestBody Admin adminRequest) throws Exception {
@@ -232,20 +229,23 @@ public class AdminController {
 
     @GetMapping("/send/template")
     public Result<String> sendTemplate(String title, String channel, String url) throws Exception {
-        for (String openId : SEND_LIST) {
-            WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
-                    .setToUser(openId)
-                    .setTemplateId(WeChatTemplateConst.VDIEO_NOTIFY)
-                    .setUrl(" ");
-            WxMpTemplateMessage.TemplateData data = templateMessage.getData();
-            data.setFirst(new WxMpTemplateData("youtube频道有更新"));
-            data.setKeyword1(new WxMpTemplateData(title));
-            data.setKeyword2(new WxMpTemplateData(channel));
-            data.setKeyword3(new WxMpTemplateData(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss")));
-            data.setKeyword4(new WxMpTemplateData("默认"));
-            data.setRemark(new WxMpTemplateData(url));
-            log.info("发送video模板消息至客服:{}","磨牙怪");
-            weChatService.sendTemplateMessage(weChatService.getAccessToken(), Jsons.toJson(templateMessage));
+        for (String email : SEND_LIST) {
+//            WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
+//                    .setToUser(openId)
+//                    .setTemplateId(WeChatTemplateConst.VDIEO_NOTIFY)
+//                    .setUrl(" ");
+//            WxMpTemplateMessage.TemplateData data = templateMessage.getData();
+//            data.setFirst(new WxMpTemplateData("youtube频道有更新"));
+//            data.setKeyword1(new WxMpTemplateData(title));
+//            data.setKeyword2(new WxMpTemplateData(channel));
+//            data.setKeyword3(new WxMpTemplateData(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss")));
+//            data.setKeyword4(new WxMpTemplateData("默认"));
+//            data.setRemark(new WxMpTemplateData(url));
+//            log.info("发送video模板消息至客服:{}","磨牙怪");
+//            weChatService.sendTemplateMessage(weChatService.getAccessToken(), Jsons.toJson(templateMessage));
+            String subject = "youtube频道有更新";
+            String msg = String.format("title=%s+channel=%s+url=%s", title, channel, YOUTUBE_URL);
+            mailService.sendEmailMsgToPeople(email, subject, msg);
         }
         return GatewayResponse.SUCCESS.newBuilder().toResult();
     }