kazusa
/
skywalking-java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

将保存-修改上次处理时间抽成一个方法

This commit is contained in:
zhangxin10 2015-12-09 21:58:35 +08:00
parent dd2e1e023b
commit 436eacf9b8
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
skywalking-alarm/src/main/java/com/ai/cloud/skywalking/alarm/procesor/AlarmMessageProcessor.java
View File

@ -51,8 +51,7 @@ public class AlarmMessageProcessor {
// 没有数据需要发送
if (sentData.size() <= 0) {
// 修改-保存上次处理时间
rule.setPreviousFireTimeM(currentFireTimeM);
savePreviousFireTime(userInfo.getUserId(), rule.getRuleId(), currentFireTimeM);
dealPreviousFireTime(userInfo, rule, currentFireTimeM);
} else {
if ("0".equals(rule.getTodoType())) {
// 发送邮件
@ -75,14 +74,18 @@ public class AlarmMessageProcessor {
}
}
// 修改-保存上次处理时间
rule.setPreviousFireTimeM(currentFireTimeM);
savePreviousFireTime(userInfo.getUserId(), rule.getRuleId(), currentFireTimeM);
dealPreviousFireTime(userInfo, rule, currentFireTimeM);
}
}
}
private static void dealPreviousFireTime(UserInfo userInfo, AlarmRule rule, long currentFireTimeM) {
rule.setPreviousFireTimeM(currentFireTimeM);
savePreviousFireTime(userInfo.getUserId(), rule.getRuleId(), currentFireTimeM);
}
private static String generateSubjects(int count, long startTime, long endTime) {
String title = "[Warning] There were " + count + " alarm information between " +
new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(startTime)) +