| | |
| | | for _, ruleGroup := range allRules { |
| | | if ruleGroup.Enable { // 大规则开关开启状态 |
| | | // 先过时间规则 |
| | | timeJudge(label, ruleGroup) |
| | | timeFlag := timeJudge(label, ruleGroup) |
| | | if !timeFlag { |
| | | logger.Info("不在规则的时间范围内,不推送!") |
| | | return |
| | | } |
| | | result := "" |
| | | var Connector string |
| | | if ruleGroup.IsSatisfyAll { |
| | |
| | | } |
| | | |
| | | // 是否符合时间规则 |
| | | func timeJudge(label *Label, groupRule protomsg.EventPush) string { |
| | | func timeJudge(label *Label, groupRule protomsg.EventPush) bool { |
| | | timeNow := time.Now().Format("2006-01-02 15:04:05") |
| | | logger.Info("标签过滤器起始时间为:",groupRule.TimeStart,groupRule.TimeEnd) |
| | | flag1 := isBefore(groupRule.TimeStart, timeNow) |
| | | flag2 := isBefore(timeNow, groupRule.TimeEnd) |
| | | if flag1 && flag2 { |
| | | return "true" |
| | | return true |
| | | } else { |
| | | logger.Info("不在规定的时间范围内!") |
| | | return "false" |
| | | return false |
| | | } |
| | | } |
| | | |