add tablename by id

554325746@qq.com

2019-06-25 58cdde93bbe0c913c0c45a63bb9d7307fac65962

add tablename by id

 esutil/EsApi.go

@@ -53,15 +53,14 @@
}

// 根据tableid 查询tablename

func Dbtablename(tableid string ) (tablename string) {
func Dbtablename(tableid string ) (tablename string, err error) {
    var dbinfotable =` {
        "query": {
            "bool": {
                "filter": [
                {
                    "term": {
                        "id":`+tableid+`
                        "id":"`+tableid+`"
                    }
                }
                ]
@@ -74,18 +73,18 @@
    `
    buf, err := EsReq("POST", "http://192.168.1.182:9200/dbtables/_search",[]byte(dbinfotable))
    if err != nil {
        return nil ,errors.New("http request dbtablename info is err!")
        return "" ,errors.New("http request dbtablename info is err!")
    }
    sources, err := Sourcelist(buf)
    if err != nil {
          return nil,err 
          return "",err 
    }

    for _, source := range sources {
        if name, ok := souce["tableName"].(string); ok {
        if name, ok := source["tableName"].(string); ok {
            tablename = name
            break
        }
    }
    return 
    return tablename, nil 
}

 esutil/EsClient.go

@@ -39,6 +39,10 @@
        tmpinfo.Idcard,ok       =  source["idCard"].(string)
            Isnil("idCard", ok)
        tmpinfo.MonitorLevel,ok =  source["monitorLevel"].(string)

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