| | |
| | | logger.SetSaveDays(logSaveDays) |
| | | logger.Info("loginit success !") |
| | | flag.Parse() |
| | | service.InitService() |
| | | //service.InitService() |
| | | |
| | | p, err := strconv.Atoi(*dbPort) |
| | | if err != nil { |
| | |
| | | logger.Debug("readFromUploadImg err:",err) |
| | | return nil,err,i |
| | | } |
| | | bc, err := ImgCompress(i) |
| | | logger.Debug("ImgCompress用时:", time.Since(t1)) |
| | | t1 = time.Now() |
| | | imgBytes, err := proto.Marshal(i) |
| | | if err !=nil { |
| | | logger.Debug("ImgCompress err:",err) |
| | | logger.Debug("i marshal err:",err) |
| | | return nil,err,i |
| | | } |
| | | s.PushImgMsg(bc) |
| | | logger.Debug("PushImgMsg用时:", time.Since(t1)) |
| | | t1 = time.Now() |
| | | s.GetFaceFea() |
| | | logger.Debug("GetFaceFea用时:", time.Since(t1)) |
| | | if s.Result == nil{ |
| | | return nil,errors.New("no fea"),i |
| | | detectResults, err := DoFDetectWithRpc(&protomsg.FaceDetectRequest{ReqParam: imgBytes}, deadTime) |
| | | if err !=nil { |
| | | logger.Debug("DoFDetectWithRpc err:",err) |
| | | return nil,err,i |
| | | } else { |
| | | return s.Result,nil,i |
| | | return detectResults,nil,i |
| | | } |
| | | |
| | | //bc, err := ImgCompress(i) |
| | | //logger.Debug("ImgCompress用时:", time.Since(t1)) |
| | | //t1 = time.Now() |
| | | //if err !=nil { |
| | | // logger.Debug("ImgCompress err:",err) |
| | | // return nil,err,i |
| | | //} |
| | | //s.PushImgMsg(bc) |
| | | //logger.Debug("PushImgMsg用时:", time.Since(t1)) |
| | | //t1 = time.Now() |
| | | //s.GetFaceFea() |
| | | //logger.Debug("GetFaceFea用时:", time.Since(t1)) |
| | | //if s.Result == nil{ |
| | | // return nil,errors.New("no fea"),i |
| | | //} else { |
| | | // return s.Result,nil,i |
| | | //} |
| | | } |
| | | |
| | | func NewFaceSdkService(fileBytes []byte, deadTime time.Duration) FaceSdkService{ |