昼伏夜出调试

sunty

2024-03-25 ebfa610f8c66fd2827a2eec619bfb3e0e22c332f

 EsClient.go

@@ -15,7 +15,6 @@
   "time"
)


func Parsesources(sources []map[string]interface{}) (multiInfos []*protomsg.MultiFeaCache) {
   var ok bool
   for _, source := range sources {
@@ -104,7 +103,7 @@
   return
}

//解析抓拍库人员结构
// 解析抓拍库人员结构
func AIOceanAnalysis(sources []map[string]interface{}) (tmpinfos []protomsg.AIOcean) {
   var ok bool
   for _, source := range sources {
@@ -311,7 +310,7 @@
   return tmpinfos
}

//解析底库人员结构
// 解析底库人员结构
func Dbpersonbyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbperson) {
   var ok bool

@@ -379,7 +378,7 @@
   return tmpinfos
}

//解析底库结构
// 解析底库结构
func Dbtablebyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbtable) {
   var ok bool

@@ -548,7 +547,7 @@
   return allSource, nil
}

func SourceDeduplication(buf [] byte) ([]map[string]interface{}, error) {
func SourceDeduplication(buf []byte) ([]map[string]interface{}, error) {
   var info interface{}
   json.Unmarshal(buf, &info)
   out, ok := info.(map[string]interface{})
@@ -577,8 +576,8 @@
   return faceId, nil
}

//解析聚合计数结构
func SourceStatistics(buf [] byte) ([]map[string]interface{}, error) {
// 解析聚合计数结构
func SourceStatistics(buf []byte) ([]map[string]interface{}, error) {
   var info interface{}
   json.Unmarshal(buf, &info)
   out, ok := info.(map[string]interface{})
@@ -604,7 +603,7 @@
   return resultData, nil
}

func SourceAggregations(buf [] byte, thresholdTime float64, queryUseTime float64) (sources map[string]interface{}, err error) {
func SourceAggregations(buf []byte, thresholdTime float64, queryUseTime float64) (sources map[string]interface{}, err error) {
   s := make(map[string]interface{})
   loc, err := time.LoadLocation("Asia/Shanghai")
   if err != nil {
@@ -739,7 +738,7 @@
   return s, nil
}

func SourceAggregationsReturnByGrouped(buf [] byte, thresholdTime float64) (sources []map[string]interface{}, err error) {
func SourceAggregationsReturnByGrouped(buf []byte, thresholdTime float64) (sources []map[string]interface{}, err error) {
   loc, err := time.LoadLocation("Asia/Shanghai")
   if err != nil {
      return nil, errors.New("时区设置错误")
@@ -868,7 +867,7 @@
   return sources, nil
}

//解析抓拍库人员结构
// 解析抓拍库人员结构
func PerSonAnalysis(preData []map[string]interface{}) (sources []map[string]interface{}, err error) {
   loc, err := time.LoadLocation("Asia/Shanghai")
   if err != nil {
@@ -1034,15 +1033,43 @@
      return -1, errors.New("first total change error!")
   }

   tmp,b := middle["total"].(map[string]interface{})
   tmp, b := middle["total"].(map[string]interface{})
   if b != true {
      v := middle["total"].(float64)
      t := int(v)
      return t,nil
      return t, nil
   }
   value := tmp["value"].(float64)
   total = int(value)
   return total, nil
}

func SourceAggregationList(buf []byte) (sources []map[string]interface{}, err error) {
   var info interface{}
   json.Unmarshal(buf, &info)
   out, ok := info.(map[string]interface{})
   if !ok {
      return nil, errors.New("http response interface can not change map[string]interface{}")
   }

   middle, ok := out["aggregations"].(map[string]interface{})
   if !ok {
      return nil, errors.New("first hits change error!")
   }

   documentAggregations := middle["group_by_documentnumber"].(map[string]interface{})
   buckets := documentAggregations["buckets"].([]interface{})
   if len(buckets) == 0 {
      return nil, nil
   }
   for _, in := range buckets {
      tmpbuf, ok := in.(map[string]interface{})
      if !ok {
         return nil, errors.New("")
      }
      sources = append(sources, tmpbuf)
   }
   return sources, nil
}

func EsReq(method string, url string, parama []byte) (buf []byte, err error) {
@@ -1053,7 +1080,7 @@
   }
   request, err := http.NewRequest(method, url, bytes.NewBuffer(parama))
   request.Header.Set("Content-type", "application/json")
   request.Header.Set("Authorization",Token)
   request.Header.Set("Authorization", Token)

   if err != nil {
      fmt.Println("build request fail !")
@@ -1086,15 +1113,14 @@
// 赋值时检测是否能够赋值
//func //Isnil(key string, ok bool){
//    if !ok {
//            fmt.Println(key, "is nil can not asign") 
//            fmt.Println(key, "is nil can not asign")
//    }
//}

type account struct {
   Username string `mapstructure: "username"`
   Username     string `mapstructure: "username"`
   Userpassword string `mapstructure: "userpassword"`
}


var Account = &account{}

@@ -1109,9 +1135,9 @@
   v.AddConfigPath("/opt/vasystem/config/")
   err := v.ReadInConfig()
   if err != nil {
      log.Fatal("err on parsing configuration file!",err)
      log.Fatal("err on parsing configuration file!", err)
   }
   v.UnmarshalKey("es.account",Account)
   v.UnmarshalKey("es.account", Account)

   Token = "Basic "+base64.StdEncoding.EncodeToString([]byte(Account.Username+":"+Account.Userpassword))
   Token = "Basic " + base64.StdEncoding.EncodeToString([]byte(Account.Username+":"+Account.Userpassword))
}