Commit 446665a5 by yinyong

update config

parent f7ca41d2
package com.bailuntec.service.impl; package com.bailuntec.service.impl;
import com.bailuntec.dto.AlarmMessageDto;
import com.bailuntec.service.SkyWalkingNoticeService; import com.bailuntec.service.SkyWalkingNoticeService;
import com.sun.mail.util.MailSSLSocketFactory; import com.sun.mail.util.MailSSLSocketFactory;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
...@@ -14,6 +15,10 @@ import javax.mail.internet.MimeBodyPart; ...@@ -14,6 +15,10 @@ import javax.mail.internet.MimeBodyPart;
import javax.mail.internet.MimeMessage; import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeMultipart; import javax.mail.internet.MimeMultipart;
import java.security.GeneralSecurityException; import java.security.GeneralSecurityException;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.time.format.DateTimeFormatter;
import java.util.List;
import java.util.Properties; import java.util.Properties;
@Service @Service
...@@ -35,7 +40,7 @@ public class SkyWalkingNoticeServiceImpl implements SkyWalkingNoticeService { ...@@ -35,7 +40,7 @@ public class SkyWalkingNoticeServiceImpl implements SkyWalkingNoticeService {
private String protocol; private String protocol;
@Override @Override
public void send(String subject, String content) throws GeneralSecurityException, MessagingException { public void send(List<AlarmMessageDto> alarmMessageList) throws GeneralSecurityException, MessagingException {
//创建一个配置文件并保存 //创建一个配置文件并保存
Properties properties = new Properties(); Properties properties = new Properties();
...@@ -79,10 +84,16 @@ public class SkyWalkingNoticeServiceImpl implements SkyWalkingNoticeService { ...@@ -79,10 +84,16 @@ public class SkyWalkingNoticeServiceImpl implements SkyWalkingNoticeService {
mimeMessage.setRecipient(Message.RecipientType.TO,new InternetAddress(recipient)); mimeMessage.setRecipient(Message.RecipientType.TO,new InternetAddress(recipient));
//邮件标题 //邮件标题
mimeMessage.setSubject(subject); mimeMessage.setSubject("服务链路告警");
StringBuffer stringBuffer = new StringBuffer();
DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
for(AlarmMessageDto alarmMessageDto : alarmMessageList) {
LocalDateTime time = LocalDateTime.ofEpochSecond(alarmMessageDto.getStartTime() / 1000, 0, ZoneOffset.ofHours(8));
String dateTime = df.format(time);
stringBuffer.append("服务名称: "+alarmMessageDto.getName()+"<br/>告警信息: "+alarmMessageDto.getAlarmMessage()+"<br/>记录时间: "+dateTime+"<br/>");
}
//邮件内容 //邮件内容
mimeMessage.setContent(content,"text/html;charset=UTF-8"); mimeMessage.setContent(stringBuffer.toString(),"text/html;charset=UTF-8");
//发送邮件 //发送邮件
transport.sendMessage(mimeMessage,mimeMessage.getAllRecipients()); transport.sendMessage(mimeMessage,mimeMessage.getAllRecipients());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment