From 6a413e1d7d485f506e81c669bc692868c29cefb9 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期四, 18 七月 2019 17:37:25 +0800
Subject: [PATCH] fix sdkcompare
---
esutil/EsClient.go | 142 ++++++++++++++++++++++++++++++++++++++++-------
1 files changed, 120 insertions(+), 22 deletions(-)
diff --git a/esutil/EsClient.go b/esutil/EsClient.go
index 53a5072..9972c13 100644
--- a/esutil/EsClient.go
+++ b/esutil/EsClient.go
@@ -1,13 +1,13 @@
package esutil
import (
- "encoding/json"
- "errors"
- "fmt"
- "io/ioutil"
- "net/http"
- "time"
"bytes"
+ "encoding/json"
+ "errors"
+ "fmt"
+ "io/ioutil"
+ "net/http"
+ "time"
"basic.com/pubsub/protomsg.git"
)
@@ -18,11 +18,19 @@
for _, source := range sources {
var tmpinfo protomsg.Esinfo
tmpinfo.FaceFeature, ok = source["faceFeature"].(string)
- Isnil("faceFeature", ok)
+ if !ok {
+ continue
+ }
+
tmpinfo.Id, ok = source["id"].(string)
- Isnil("id", ok)
+ if !ok {
+ continue
+ }
tmpinfo.Tableid, ok = source["tableId"].(string)
- Isnil("tableId", ok)
+ if !ok {
+ continue
+ }
+
esinfos = append(esinfos, &tmpinfo)
// tmpinfo.PersonName,ok = source["personName"].(string)
@@ -43,20 +51,28 @@
// binfos.Infos = append(binfos.Infos, &tmpinfo)
}
- return
+ return
}
-
-func Dbpersonbyid(sources []map[string]interface{}) (protomsg.Baseinfo) {
+//瑙ｆ瀽搴曞簱浜哄憳缁撴瀯
+func Dbpersonbyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbperson) {
var ok bool
-
- var tmpinfo protomsg.Baseinfo
+
+ var tmpinfo protomsg.Dbperson
for _, source := range sources{
tmpinfo.FaceFeature, ok = source["faceFeature"].(string)
- Isnil("faceFeature", ok)
- tmpinfo.PersonId, ok = source["id"].(string)
- Isnil("id", ok)
+ if !ok {
+ continue
+ }
+
+ tmpinfo.Id, ok = source["id"].(string)
+ if !ok {
+ continue
+ }
+
tmpinfo.TableId, ok = source["tableId"].(string)
- Isnil("tableId", ok)
+ if !ok {
+ continue
+ }
tmpinfo.PersonName,ok = source["personName"].(string)
Isnil("personName", ok)
@@ -66,16 +82,98 @@
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
+ tmpinfos = append(tmpinfos, tmpinfo)
}
- return tmpinfo
+ return tmpinfos
+}
+
+//瑙ｆ瀽搴曞簱缁撴瀯
+func Dbtablebyid(sources []map[string]interface{}) (tmpinfos []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)
+
+ tmpinfos = append(tmpinfos, tmpinfo)
+ }
+
+ return tmpinfos
}
func Sourcelist(buf []byte)(sources []map[string]interface{}, err error){
--
Gitblit v1.8.0