tcp server 用于给andriod 客户端定时发送消息
liuxiaolong
2019-05-29 92e4dc50a25785f7a051e09e4968e45c465922f0
esutil/EsClient.go
@@ -95,9 +95,17 @@
            source["picSmUrl"] = picurl + psm
         }
         prace, exist := source["Race"]
         if exist {
            source["race"] = prace
         }
         fmt.Println("race: ", source["race"])
         source["ageDescription"] = getAgeDesc(source["Age"])
         source["videoNum"] = getVideoUrl(source)
         timeFormat := "2019-05-28 15:04:05"
         picDateStr, err := time.Parse(timeFormat, source["picDate"].(string))
         fmt.Println("picDate: ", picDateStr)
         if err == nil {
            source["picDate"] = picDateStr
         }
@@ -112,6 +120,27 @@
   } else {
      return nil, dat
   }
}
func getAgeDesc(age interface{})(ageDesc string) {
   if age !=nil {
      ageInt := age.(int32)
      if ageInt >0 && ageInt<7 {
         ageDesc = "童年"
      } else if ageInt >=7 && ageInt<18 {
         ageDesc = "少年"
      } else if ageInt >=18 && ageInt<40 {
         ageDesc = "青年"
      } else if ageInt >=40 && ageInt<65 {
         ageDesc = "中年"
      } else if ageInt >=65 {
         ageDesc = "老年"
      } else {
         ageDesc = ""
      }
   }
   fmt.Println("ageDescription: ", ageDesc)
   return ageDesc
}
type BaseInfo struct {
@@ -132,6 +161,7 @@
func getSourceBaseInfo(source map[string]interface{}) (baseInfoJson string) {
   sdkType := source["sdkType"].(string)
   baseInfoArr := make([]BaseInfo,0)
   if sdkType == "人脸" {
      likePer,baseName,personId,idCard,personPicUrl,gender,content :="","","","","","",""
      if source["likePer"] !=nil {
@@ -170,7 +200,9 @@
         MonitorLevel:"",//2.0新字段
         Content:content,
      }
      bytes, err := json.Marshal(baseInfo)
      baseInfoArr = append(baseInfoArr, baseInfo)
      bytes, err := json.Marshal(baseInfoArr)
      if err !=nil {
         return ""
      }