liuxiaolong
2019-07-23 00c6fb6a7196832f46bbce513b58bc6d9a3c9fa5
service/FaceSdkService.go
@@ -17,6 +17,7 @@
   File []byte
   Id string
   Result []*protomsg.ResultFaceDetect
   DeadTime time.Duration
}
const (
@@ -29,8 +30,8 @@
   Url_Service_PULL   = Ipc_Url_Pre + Virtual_FaceSdkId + Ipc_Pull_Ext
)
func GetFaceFeaFromSdk(fileBytes []byte) ([]*protomsg.ResultFaceDetect,error,*protomsg.Image){
   s := NewFaceSdkService(fileBytes)
func GetFaceFeaFromSdk(fileBytes []byte,deadTime time.Duration) ([]*protomsg.ResultFaceDetect,error,*protomsg.Image){
   s := NewFaceSdkService(fileBytes, deadTime)
   i, err := s.ReadFromUploadImg()
   if err !=nil{
      logger.Debug("readFromUploadImg err:",err)
@@ -50,10 +51,11 @@
   }
}
func NewFaceSdkService(fileBytes []byte) FaceSdkService{
func NewFaceSdkService(fileBytes []byte, deadTime time.Duration) FaceSdkService{
   return FaceSdkService{
      File:fileBytes,
      Id:uuid.NewV4().String(),
      DeadTime:deadTime,
   }
}
@@ -135,7 +137,7 @@
func (s *FaceSdkService) GetFaceFea(){
   var wg sync.WaitGroup
   wg.Add(1)
   ticker := time.NewTicker(time.Second * 3)
   ticker := time.NewTicker(s.DeadTime)
   go func(ticker *time.Ticker, s *FaceSdkService) {
      defer ticker.Stop()
      defer wg.Done()