fix: 关机时不再发送

dev
huangfeng 1 year ago
parent 4f994c15b3
commit 1e249b8cbb

@ -52,10 +52,12 @@ public class MntnCheckTask {
Integer termId = it.next(); Integer termId = it.next();
this.checkOne(termId); this.checkOne(termId);
} }
if (shutdown == 0) {
String str = sb.toString(); String str = sb.toString();
if (StringUtils.isNotBlank(str)) { if (StringUtils.isNotBlank(str)) {
DingTalkPushUtil.pushText(str); DingTalkPushUtil.pushText(str);
} }
}
log.info("MntnCheckTask.checkAll 结束."); log.info("MntnCheckTask.checkAll 结束.");
} catch (Exception e) { } catch (Exception e) {
log.error("MntnCheckTask.checkAll error.", e); log.error("MntnCheckTask.checkAll error.", e);
@ -72,11 +74,13 @@ public class MntnCheckTask {
MntnRawReportsExample.Criteria criteria = example.createCriteria(); MntnRawReportsExample.Criteria criteria = example.createCriteria();
criteria.andTermIdEqualTo(termId); criteria.andTermIdEqualTo(termId);
criteria.andCreateTimeGreaterThan(time); criteria.andCreateTimeGreaterThan(time);
if (shutdown == 0) {
long count = rawReportsMapper.countByExample(example); long count = rawReportsMapper.countByExample(example);
if (count > max) { if (count > max) {
this.sendWarning(term, count); this.sendWarning(term, count);
} }
} }
}
private void sendWarning(Terminals term, long count) { private void sendWarning(Terminals term, long count) {
String str = "装置" + term.getCmdid() + "最近" + minutes + "分钟内,运维报送次数:" + count String str = "装置" + term.getCmdid() + "最近" + minutes + "分钟内,运维报送次数:" + count

Loading…
Cancel
Save