| | |
| | | package insertdata |
| | | |
| | | import ( |
| | | "os" |
| | | "ruleprocess/logger" |
| | | "encoding/json" |
| | | "errors" |
| | |
| | | func InsertToEs(msg ruleserver.ResultMsg) { |
| | | |
| | | // 直接从规则的标签数据里拿符合规则的人脸结果 |
| | | //logger.Info("------------------------------------从配置文件读取的值:",weedfsUrl) |
| | | if msg.RuleResult["face"] != nil && len(msg.RuleResult["face"].([]ruleserver.Arg)) > 0 { |
| | | logger.Info("往ES插人脸数据") |
| | | for _, face := range msg.RuleResult["face"].([]ruleserver.Arg) { |
| | |
| | | } |
| | | i := protomsg.Image{} |
| | | err = proto.Unmarshal(bdata, &i) |
| | | logger.Info("-------------------------------------------看下宽和高", int(face.Location.X),int(face.Location.Y),int(face.Location.X+face.Location.Width),int(face.Location.Y+face.Location.Height)) |
| | | bytes := util.SubImg(i, int(face.Location.X), int(face.Location.Y), int(face.Location.X+face.Location.Width), int(face.Location.Y+face.Location.Height)) |
| | | resp, err := util.PostFormBufferData1(weedfsUrl, bytes, uuid.NewV4().String()) |
| | | if err != nil { |
| | |
| | | //logger.Info(err.Error()) |
| | | } else { |
| | | // 人脸比对 |
| | | logger.Warn("___________________________________________这是有baseinfo的") |
| | | localConfig, err := cache.GetServerInfo() |
| | | if err != nil { |
| | | logger.Info("查询本机信息失败!") |
| | |
| | | |
| | | } |
| | | err = EsReq("POST", "http://192.168.1.182:9200/videopersons/perVideoPicture", requstbody) |
| | | logger.Info("跟底库的相似数据---------:", face.Liker) |
| | | |
| | | fmt.Println("------------------------------------------哈哈哈哈,底库有人") |
| | | logger.Info("------------------------------------------哈哈哈哈,底库有人") |
| | | |
| | | } |
| | | } |
| | |
| | | if err != nil { |
| | | logger.Error("画框或上传图片服务器出错", err) |
| | | } else { |
| | | logger.Info("已报警并上传改帧图片到服务器") |
| | | logger.Info("上传的图片信息:",resp) |
| | | } |
| | | } else { |
| | | isAlarm = 0 |