New file |
| | |
| | | package ruleserver |
| | | |
| | | import ( |
| | | "basic.com/pubsub/protomsg.git" |
| | | "basic.com/valib/logger.git" |
| | | "ruleprocess/cache" |
| | | "basic.com/fileserver/WeedFSClient.git" |
| | | "strconv" |
| | | ) |
| | | func GetAttachInfo(msg *protomsg.SdkMessage){ |
| | | //人脸检测,没有相似的底库人员 |
| | | localConfig, err := cache.GetServerInfo() |
| | | if err != nil { |
| | | logger.Error("查询本机信息失败!") |
| | | } |
| | | logger.Info("localConfig信息:",localConfig) |
| | | //msg.Push.ServerId = "localConfig.ServerId" |
| | | //msg.Push.ServerName = "localConfig.ServerName" |
| | | serverIp, err := GetLocalIP() |
| | | //msg.Push.LocalIp = serverIp |
| | | // 查询cameraName |
| | | camera, err := cache.GetCameraById(msg.Cid) |
| | | if err != nil { |
| | | logger.Error("查询摄像机信息失败") |
| | | } |
| | | //msg.Push.Cam = &camera |
| | | // 视频地址占位符 |
| | | localConfig1, err := cache.GetServerInfo() |
| | | if err != nil { |
| | | panic("配置文件不合法") |
| | | } |
| | | logger.Info("请求视频路径:",msg.Push,serverIp,camera) |
| | | weedfsUrl := "http://" + localConfig1.WebPicIp + ":" + strconv.Itoa(int(localConfig1.WebPicPort)) + "/dir/assign" |
| | | if path,err := WeedFSClient.GetFid(weedfsUrl);err != nil { |
| | | logger.Info("请求文件地址失败:",err) |
| | | } else { |
| | | logger.Info("视频路径为:",path) |
| | | msg.Push.VideoUrl = path |
| | | } |
| | | } |