package ruleserver import ( "basic.com/pubsub/protomsg.git" "basic.com/valib/logger.git" uuid "github.com/satori/go.uuid" "ruleprocess/cache" ) func GetAttachInfo(msg *protomsg.SdkMessage){ //人脸检测,没有相似的底库人员 push := new(protomsg.PushAttach) localConfig, err := cache.GetServerInfo() if err != nil { logger.Error("查询本机信息失败!") } logger.Info("localConfig信息:",localConfig) push.ServerId = localConfig.ServerId push.ServerName = localConfig.ServerName serverIp, err := GetLocalIP() push.LocalIp = serverIp // 查询cameraName camera, err := cache.GetCameraById(msg.Cid) if err != nil { logger.Error("查询摄像机信息失败") } push.Cam = &camera push.PushId = uuid.NewV4().String() // 视频地址占位符 //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) // push.VideoUrl = path //} msg.Push = push }