|
@@ -66,6 +66,7 @@ func WarningDm() {
|
|
|
send1, send2 := true, true // 预警，上限 发送标记
|
|
send1, send2 := true, true // 预警，上限 发送标记
|
|
|
info := TiDb.SelectBySql(dmInfoCount, d1, cfg.WarningValue)
|
|
info := TiDb.SelectBySql(dmInfoCount, d1, cfg.WarningValue)
|
|
|
if info != nil && len(*info) > 0 {
|
|
if info != nil && len(*info) > 0 {
|
|
|
|
|
+ send = false
|
|
|
send1 = false
|
|
send1 = false
|
|
|
}
|
|
}
|
|
|
info1 := TiDb.SelectBySql(dmInfoCount, d1, cfg.AllocationCap)
|
|
info1 := TiDb.SelectBySql(dmInfoCount, d1, cfg.AllocationCap)
|
|
@@ -112,7 +113,6 @@ func WarningDm() {
|
|
|
WillWarningByDm(d1, to, toCc)
|
|
WillWarningByDm(d1, to, toCc)
|
|
|
_, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail | (1 << 2)"), posid) // 倒数第三位修改成0
|
|
_, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail | (1 << 2)"), posid) // 倒数第三位修改成0
|
|
|
} else {
|
|
} else {
|
|
|
- send = false // 所有人
|
|
|
|
|
if !send1 && sendFlag1 == 1 {
|
|
if !send1 && sendFlag1 == 1 {
|
|
|
_, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail & ~(1 << 2)"), posid) // 倒数第三位修改成1
|
|
_, _ = TiDb.ExecBySql(fmt.Sprintf(sql1, "send_mail & ~(1 << 2)"), posid) // 倒数第三位修改成1
|
|
|
}
|
|
}
|
