add querybyId controllers

sunty

2019-07-12 2fb553ab4774ad2605f18dacb5bacb481bfe2f8c

add querybyId controllers

 esutil/EsApi.go

@@ -43,16 +43,53 @@
}

// 根据底库id查询底库信息
func Dbpersoninfosbyid (id string) (protomsg.Baseinfo, error) {
    var dbinfo protomsg.Baseinfo
func Dbtablefosbyid(id string) (protomsg.Dbtable, error) {
    var dbinfo protomsg.Dbtable
    
        var dbinfoRequest = `
            {
                "query":{
                    "bool": {
                        "filter": [{
                    "terms":{
                        "_id":[
                            "`+ id +`"
                        ]
                            }
                        }]
                    }
                }
            }
        `
    buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtables/_search", []byte(dbinfoRequest))
    if err != nil {
        return dbinfo, err
    }

    sources, err := Sourcelist(buf)
    if err != nil {
        return dbinfo, err
    }

    dbtable := Dbtablebyid(sources)
    return dbtable, nil
}

// 根据底库人员id查询底库人员信息
func Dbpersoninfosbyid(id string) (protomsg.Dbperson, error) {
    var dbinfo protomsg.Dbperson

    var dbinfoRequest = `
            {
                "query": {
                    "bool": {
                        "filter": [{
                            "terms": {
                                "_id": [
                                    "` + id + `"
                                ]
                            }
                        }]
                    }
                }
            }
@@ -67,10 +104,9 @@
        return dbinfo , err
    }

    baseinfo := Dbpersonbyid(sources) 
    return baseinfo, nil
    dbperson := Dbpersonbyid(sources)
    return dbperson, nil
}


// 根据tableid 查询tablename
func Dbtablename(tableid string ) (tablename string, err error) {

 esutil/EsClient.go

@@ -1,17 +1,16 @@
package esutil

import (
    "bytes"
    "encoding/json"
    "errors"
    "fmt"
    "io/ioutil"
    "net/http"
    "time"
    "bytes"

    "basic.com/pubsub/protomsg.git"
)


func Parsesources(sources []map[string]interface{}) (esinfos []*protomsg.Esinfo) {
    var ok bool
@@ -54,17 +53,18 @@
    return 
}

func Dbpersonbyid(sources []map[string]interface{}) (protomsg.Baseinfo) {
//解析底库人员结构
func Dbpersonbyid(sources []map[string]interface{}) protomsg.Dbperson {
        var ok bool
        
        var tmpinfo protomsg.Baseinfo
    var tmpinfo protomsg.Dbperson
        for _, source := range  sources{
            tmpinfo.FaceFeature, ok =   source["faceFeature"].(string)
            if !ok {
                continue
            }

            tmpinfo.PersonId, ok    =   source["id"].(string)  
        tmpinfo.Id, ok = source["id"].(string)
            if !ok {
                continue
            }
@@ -82,13 +82,92 @@
                Isnil("phoneNum", ok)
            tmpinfo.Sex,ok          =  source["sex"].(string)
                Isnil("sex", ok)
            tmpinfo.Idcard,ok       =  source["idCard"].(string)
        tmpinfo.IdCard, ok = source["idCard"].(string)
                Isnil("idCard", ok)
            tmpinfo.MonitorLevel,ok =  source["monitorLevel"].(string)
        Isnil("monitorLevel", ok)
        tmpinfo.UpdateTime, ok = source["updateTime"].(string)
        Isnil("updateTime", ok)
        tmpinfo.Age, ok = source["age"].(string)
        Isnil("age", ok)

        isDelete, ok := source["isDelete"].(float64)
        if ok {
            tmpinfo.IsDelete = int32(isDelete)
        }
        Isnil("isDelete", ok)

        enable, ok := source["enable"].(float64)
        if ok {
            tmpinfo.Enable = int32(enable)
        }
        Isnil("endTime", ok)

        tmpinfo.Reserved, ok = source["reserved"].(string)
        Isnil("reserved", ok)
        tmpinfo.PicDesc, ok = source["picDesc"].(string)
        Isnil("picDesc", ok)
        tmpinfo.CreateTime, ok = source["createTime"].(string)
        Isnil("createTime", ok)
        tmpinfo.CreateBy, ok = source["createBy"].(string)
        Isnil("createBy", ok)

            //根据 tableid 获取 tablename
            name, _:= Dbtablename(tmpinfo.TableId) 
            tmpinfo.TableName= name 
        //name, _:= Dbtablename(tmpinfo.TableId)
        //tmpinfo.TableName= name
    }

    return tmpinfo
}

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

    var tmpinfo protomsg.Dbtable
    for _, source := range sources {

        tmpinfo.Id, ok = source["id"].(string)
        if !ok {
            continue
        }
        tmpinfo.TableName, ok = source["tableName"].(string)
        Isnil("tableName", ok)
        tmpinfo.TableType, ok = source["tableType"].(string)
        Isnil("tableType", ok)
        tmpinfo.CreateBy, ok = source["createBy"].(string)
        Isnil("createBy", ok)
        tmpinfo.TableDesc, ok = source["tableDesc"].(string)
        Isnil("tableDesc", ok)
        tmpinfo.BwType, ok = source["bwType"].(string)
        Isnil("bwType", ok)
        tmpinfo.StartTime, ok = source["startTime"].(string)
        Isnil("startTime", ok)
        tmpinfo.EndTime, ok = source["endTime"].(string)
        Isnil("endTime", ok)

        isDelete, ok := source["isDelete"].(float64)
        if ok {
            tmpinfo.IsDelete = int32(isDelete)
        }
        Isnil("isDelete", ok)

        enable, ok := source["enable"].(float64)
        if ok {
            tmpinfo.Enable = int32(enable)
        }
        Isnil("endTime", ok)

        tmpinfo.CreateTime, ok = source["createTime"].(string)
        Isnil("createTime", ok)
        tmpinfo.UpdateTime, ok = source["updateTime"].(string)
        Isnil("updateTime", ok)
        tmpinfo.IsForever, ok = source["isForever"].(string)
        Isnil("isForever", ok)
        tmpinfo.IsSync, ok = source["isSync"].(string)
        Isnil("isSync", ok)
        tmpinfo.AnalyServerId, ok = source["analyServerId"].(string)
        Isnil("analyServerId", ok)
        }

        return tmpinfo