add querybyId controllers

sunty

2019-07-12 2fb553ab4774ad2605f18dacb5bacb481bfe2f8c

 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