---

panlei

2019-07-05 b307d3c7ad7213625b6d4c8d4fa1b027b0cafce6

---

 insertdata/insertDataToEs.go

@@ -3,6 +3,7 @@
import (
    "encoding/json"
    "errors"
    "fmt"
    "net"
    "ruleprocess/cache"
    "ruleprocess/logger"
@@ -186,6 +187,8 @@
                logger.Info(err.Error())
            } else {
                logger.Info("跟底库的相似数据---------：", face.Liker)
                fmt.Println("------------------------------------------哈哈哈哈，底库有人")

            }
        }
    }

 ruleserver/timeTicker.go

@@ -1,6 +1,7 @@
package ruleserver

import (
    "fmt"
    "ruleprocess/logger"
    "time"
)
@@ -27,7 +28,7 @@

func TimeTicker() {
    logger.Info("定时器执行了")
    //fmt.Println("定时器执行了")
    fmt.Println("定时器执行了")
    ticker := time.NewTicker(1 * time.Second)
    go func(ticker *time.Ticker) {
        defer ticker.Stop()
@@ -35,7 +36,7 @@
            select {
            case <-ticker.C:
                logger.Info("定时器执行单元")
                //fmt.Println("定时器执行单元")
                fmt.Println("定时器执行单元")
                // 每秒钟计数器池子里所有的计数器元素都减一，减到0的是该报警的
                for _, timeEle := range TimeEleList {
                    if timeEle.N > 0 {