spotify提交信息状态修改邮件通知

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

@@ -1,5 +1,7 @@
 package com.cyksj.service.mail;
 
+import com.cyksj.model.entity.SpotifyUserUpgradeSubmitRecord;
+
 /*
  *项目名: netflix
  *文件名: MailService
@@ -21,4 +23,6 @@ public interface MailService {
 	 * 发送课程给用户
 	 */
 	void sendCoursewareByGoodsId(Long goodsId, Long relationId, Long userId, String goodsTitle, String email) throws Exception;
+
+	void sendSpotifyUpgradeEmail(SpotifyUserUpgradeSubmitRecord.Status status, String email);
 }

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

@@ -9,10 +9,7 @@ import com.cyksj.mapper.EmailConfigMapper;
 import com.cyksj.mapper.GoodsCoursewareFileMapper;
 import com.cyksj.mapper.GroupsRelationMapper;
 import com.cyksj.mapper.OrderDonMapper;
-import com.cyksj.model.entity.EmailConfig;
-import com.cyksj.model.entity.GoodsCoursewareFile;
-import com.cyksj.model.entity.GroupsRelation;
-import com.cyksj.model.entity.OrderDon;
+import com.cyksj.model.entity.*;
 import com.cyksj.redis.RedisService;
 import com.cyksj.service.mail.MailService;
 import lombok.RequiredArgsConstructor;
@@ -189,6 +186,25 @@ public class MailServiceImpl implements MailService {
 		});
 	}
 
+	@Override
+	public void sendSpotifyUpgradeEmail(SpotifyUserUpgradeSubmitRecord.Status status, String email) {
+		try {
+			SimpleMailMessage msg = new SimpleMailMessage();
+			if (status == SpotifyUserUpgradeSubmitRecord.Status.success) {
+				msg.setSubject("【银河录像局】Spotify开通成功");
+				msg.setText("尊敬的用户，您申请Spotify个人车已成功开通，您可登录银河官网查看车票https://nf.video。");
+			} else {
+				msg.setSubject("【银河录像局】Spotify开通失败");
+				msg.setText("尊敬的用户，您申请Spotify个人车因账号密码错误开通失败，您可登录银河官网https://nf.video，在车票页修改提交的账号密码。");
+			}
+			msg.setFrom(from);
+			msg.setTo(email);
+			mailSender.send(msg);
+		} catch (Exception e) {
+			log.error("发送用户邮件：{}  spotify升级邮件失败:{}", email, StringUtil.getErrorText(e));
+		}
+	}
+
 	private void sendMsgIfFailRetry(JavaMailSenderImpl sender, MimeMessage msg) {
 		try {
 			sender.send(msg);

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

@@ -10,6 +10,7 @@ import com.cyksj.mapper.SpotifyUserUpgradeSubmitRecordMapper;
 import com.cyksj.model.entity.SpotifyUserUpgradeSubmitRecord;
 import com.cyksj.model.views.SpotifyUserUpgradeOrderView;
 import com.cyksj.model.views.SpotifyUserUpgradeSubmitRecordView;
+import com.cyksj.service.mail.MailService;
 import com.cyksj.service.order.OrderRefundService;
 import com.ejlchina.searcher.BeanSearcher;
 import com.ejlchina.searcher.SearchResult;
@@ -41,6 +42,8 @@ public class SpotifyUpgradeController {
 
 	private final GroupsRelationMapper relationMapper;
 
+	private final MailService mailService;
+
 	/**
 	 * 提交账号列表
 	 */
@@ -75,6 +78,8 @@ public class SpotifyUpgradeController {
 				relationMapper.updateById(relation);
 			});
 		}
+		//发送spotify个人升级状态邮件
+		mailService.sendSpotifyUpgradeEmail(submitRecord.getStatus(), submitRecord.getEmail());
 		return GatewayResponse.SUCCESS.newBuilder().toResult();
 	}