---

panlei

2019-07-05 3f5e966a8331186b9c30cc82836c64fa9a917551

---

 logger/logger.go

@@ -116,7 +116,7 @@
    }
}

func Fatalf(args ...interface{}) {
func Fatal(args ...interface{}) {
    if logFile.level >= FatalLevel {
        log.SetPrefix(red(fatalPrefix))
        _ = log.Output(2, fmt.Sprintln(args...))

 ruleserver/ruleToformula.go

@@ -233,7 +233,7 @@
            logger.Error("比对规则有误", err.(string))
        }
    }()
    logger.Warn("+++++++++++规则开始运行+++++++++++++++++当前规则--：", *groupRule)
    logger.Info("+++++++++++规则开始运行+++++++++++++++++当前规则--：", *groupRule)
    resultSplice := []*LittleRuleResult{}
    // 先过完条件规则
    for j := 0; j < len(groupRule.Rules); j++ {

 ruleserver/timeTicker.go

@@ -2,6 +2,7 @@

import (
    "fmt"
    "os"
    "ruleprocess/logger"
    "time"
)
@@ -35,8 +36,8 @@
        for {
            select {
            case <-ticker.C:
                logger.Info("定时器执行单元")
                fmt.Println("定时器执行单元")
                logger.Info("定时器执行单元",time.Now().Unix())
                fmt.Println("定时器执行单元",time.Now().Unix())
                // 每秒钟计数器池子里所有的计数器元素都减一，减到0的是该报警的
                for _, timeEle := range TimeEleList {
                    if timeEle.N > 0 {
@@ -47,7 +48,7 @@
            case stop := <-stopChan:
                if stop {
                    logger.Info("定时器结束")
                    //os.Exit(0)
                    os.Exit(0)
                }
            }
        }