fix bug

liuxiaolong

2019-06-26 6ec6ad3a594049599b912c8e9acc7ec996ad0cdb

 service/FaceSdkService.go

@@ -53,30 +53,35 @@
   imgPushChan = make(chan protomsg.Recvmsg)
   client_push := deliver.NewClient(deliver.PushPull, Url_Service_PUSH)
   client_pull := deliver.NewClient(deliver.PushPull, Url_Service_PULL)
   for {
      select {

   go func() {
      for {
         select {
         case is := <- imgPushChan:
            fmt.Println("imgPushChan in")
            b, _ := json.Marshal(is)
            client_push.Send(b)
      default:
         fmt.Println("no img in")
         default:
            //fmt.Println("no img in")
         }
      }
   }
   }()

   //接收人脸提取结果
   for {
      resultBytes, err := client_pull.Recv()
      if err !=nil{
         fmt.Println("pull err:",err)
         continue
      }
      rMsg := protomsg.SdkMessage{}
      if err := proto.Unmarshal(resultBytes, &rMsg);err !=nil{
         fmt.Println("recv MSG:",rMsg)
         resultMap[rMsg.Cid] = rMsg
      }
   go func() {
      //接收人脸提取结果
      for {
         resultBytes, err := client_pull.Recv()
         if err !=nil{
            fmt.Println("pull err:",err)
            continue
         }
         rMsg := protomsg.SdkMessage{}
         if err := proto.Unmarshal(resultBytes, &rMsg);err !=nil{
            fmt.Println("recv MSG:",rMsg)
            resultMap[rMsg.Cid] = rMsg
         }

   }
      }
   }()

}