struct to map[string]float32]

554325746@qq.com

2019-07-08 1c8c14cb32884c1a0885e669509e2152f1d3e5e8

 esutil/EsApi.go

@@ -8,7 +8,8 @@
        )

// 查询底库人员信息
func DbPersoninfos( queryindex int, querynums int ) (dbpersoninfos []*protomsg.Baseinfo, err error){
func DbPersoninfos( queryindex int, querynums int ) ([]*protomsg.Esinfo, error){
            var dbinfos []*protomsg.Esinfo
            point   := strconv.Itoa(queryindex)
            number   := strconv.Itoa(querynums)

@@ -17,38 +18,27 @@
                    "query": {
                        "match_all": {}
                    },
                        "size":`+ number +`,
                        "_source": [
                     "size":`+ number +`,
                     "_source": [
                       "id",
                       "tableId",
                       "tableName",
                       "compareScore",
                       "personId",
                       "personName",
                       "personPicUrl",
                       "phoneNum",
                       "sex",
                       "idCard",
                       "monitorLevel",
                       "faceFeature",
                       "content",
                       "id"
                       "faceFeature"
                       ]
                }`
                    }`

      // 返回请求的buf
      buf, err := GetDbinfo(dbinfoRequest )
      if err != nil {
        return nil ,errors.New("http request get dbperson info is err!")
      }
    buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtablepersons/dbpersons/_search",[]byte(dbinfoRequest))
    if err != nil {
        return dbinfos ,errors.New("http request dbtablename info is err!")
    }

      // 返回 _source 数组
      sources, err := Sourcelist(buf)
      if err != nil {
            return nil,err 
            return dbinfos,err 
      }

      // 返回所有查询的数据
      dbpersoninfos =  Parsesources(sources)
     dbpersoninfos :=  Parsesources(sources)
      return dbpersoninfos, nil
}