get ip,port config from db,update realtime

liuxiaolong

2019-09-19 2dd1fa03c93b400ff1e8e4f44e27387965e4daa7

 service/EnableStatusControlService.go

@@ -2,18 +2,24 @@

import (
   "basic.com/dbapi.git"
   "basic.com/valib/logger.git"
   "encoding/json"
   "fmt"
   "strconv"
   "strings"
   "time"
   "webserver/cache"
   "webserver/extend/config"
   "webserver/extend/esutil"
   "basic.com/valib/logger.git"
)

func GetVerificationData() []map[string]interface{} {
   url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
   localConf, err2 := cache.GetServerInfo()
   if err2 !=nil || localConf.AlarmIp == "" {
      logger.Debug("localConfig is wrong!!!")
      return nil
   }
   url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
      "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/_search"
   var setApi dbapi.SysSetApi
   _, sysconf := setApi.GetServerInfo()
@@ -83,7 +89,12 @@
      status = 1
   }
   enable := strconv.Itoa(status)
   url := "http://" + config.EsInfo.Masterip + ":" + config.EsInfo.Httpport +
   localConf, err2 := cache.GetServerInfo()
   if err2 !=nil || localConf.AlarmIp == "" {
      logger.Debug("localConfig is wrong!!!")
      return "localConf wrong"
   }
   url := "http://" + localConf.AlarmIp + ":" + strconv.Itoa(int(localConf.AlarmPort)) +
      "/" + config.EsInfo.EsIndex.DbTables.IndexName + "/_update_by_query?refresh"
   jsonDsl := `
         {