fix

554325746@qq.com

2020-06-17 f993d1206315fb3e9eb59dbd001aa373008e2d2b

fix

 .gitignore

@@ -1,2 +1,3 @@
.idea
test.exe
logs

 esutil/EsClient.go

@@ -75,12 +75,14 @@

            tB, err := json.Marshal(source["targetInfo"])
            if err != nil {
                log.Log.Infoln("err:", err)
                continue
            }

            tiArr := []TargetInfo{}
            err = json.Unmarshal(tB, &tiArr)
            if err !=nil {
                log.Log.Infoln("err:", err)
                continue
            }
            if len(tiArr) > 0 {
@@ -220,7 +222,7 @@
    var filterArr []string
    //是否查报警数据
    if ishub == "hub" {
        filterArr = append(filterArr,"{\"term\":{\"alarmRules.alarmLevel.raw\":\"一级\"}}")
        filterArr = append(filterArr,"{\"term\":{\"alarmRules.alarmLevel.raw\":\"二级\"}}")
    }

    filterArr = append(filterArr, "{\"range\":{\"picDate\":{\"gte\":\"now+8h-"+preSec+"s\",\"lt\":\"now+8h\"}}}")
@@ -238,7 +240,9 @@
        log.Log.Errorln("GetEsDataReq err:", err)
        return nil
    }
    log.Log.Infoln("tokenRes:", tokenRes)
    jsonstring, _ := json.Marshal(tokenRes)
    log.Log.Infoln("len(result):", len(jsonstring))
    if len(jsonstring) <= 26 {
        return nil
    }

 go.mod

@@ -8,5 +8,5 @@
    github.com/rifflock/lfshook v0.0.0-20180920164130-b9218ef580f5
    github.com/sirupsen/logrus v1.4.2
    github.com/spf13/viper v1.4.0
    github.com/streadway/amqp v0.0.0-20190827072141-edfb9018d271 // indirect
    github.com/streadway/amqp v0.0.0-20190827072141-edfb9018d271
)

 logs/error.log

@@ -1 +1 @@
logs/error.log.201905280000
logs/error.log.202006170000

 server.go

@@ -13,7 +13,7 @@
)

var addr = flag.String("addr", "0.0.0.0", "The address to listen to")
var Eurl = flag.String("eurl", "http://172.16.50.241:9200/", "The port to listen on")
var Eurl = flag.String("eurl", "http://192.168.20.10:9200/", "The port to listen on")
//var Picurl = flag.String("picurl", "http://58.118.225.79:41242/", "picture url")

var port = flag.Int("port", 6000, "The port to listen on")
@@ -23,7 +23,7 @@
var IsHub = flag.String("hub", "hub", "hub is personIsHub=1")
var Size = flag.Int("size", 100, "size default is 100")
var env = flag.String("env", "config", "env set")
var mqIp = flag.String("mqIp", "172.17.50.245", "default mq ip")
var mqIp = flag.String("mqIp", "192.168.20.10", "default mq ip")
var mqPort = flag.Int("mqPort", 5672, "default mq port")
var mqUser = flag.String("mqUser", "basic", "default rabbitmq user")
var mqPass = flag.String("mqPass", "basic", "default rabbitmq pass")