From d7c6faf69ff5cd591530c917d99354b4ece9290f Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期四, 07 十一月 2019 16:16:02 +0800 Subject: [PATCH] --- --- ruleserver/attachInfo.go | 42 ++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 42 insertions(+), 0 deletions(-) diff --git a/ruleserver/attachInfo.go b/ruleserver/attachInfo.go new file mode 100644 index 0000000..cc2b5ab --- /dev/null +++ b/ruleserver/attachInfo.go @@ -0,0 +1,42 @@ +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 +} \ No newline at end of file -- Gitblit v1.8.0