use camera and localconfig cache

liuxiaolong

2019-07-02 6d0a2b62a05d146440b425598201d52a56b8c911

use camera and localconfig cache

 cache/cache.go

@@ -5,6 +5,7 @@
    "basic.com/pubsub/cache.git/shardmap"
    "basic.com/pubsub/protomsg.git"
    "basic.com/valib/gopherdiscovery.git"
    "errors"
    "fmt"
    "github.com/gogo/protobuf/proto"
    "github.com/satori/go.uuid"
@@ -126,22 +127,22 @@
    }
}

func GetServerInfo() *protomsg.LocalConfig {
func GetServerInfo() (con protomsg.LocalConfig,err error) {
    config, b := cMap.Get(SERVER_KEY)
    if b {
        return config.(*protomsg.LocalConfig)
        return config.(protomsg.LocalConfig),nil
    } else {
        return nil
        return con,errors.New("conf not found")
    }
}

//通过cameraId获取摄像机信息
func GetCameraById(cameraId string) *protomsg.Camera {
func GetCameraById(cameraId string) (c protomsg.Camera,err error) {
    cam, b := cMap.Get(PREFIX_CAMERA + cameraId)
    if b {
        return cam.(*protomsg.Camera)
        return cam.(protomsg.Camera),nil
    } else {
        return nil
        return c,errors.New("camera not found")
    }
}


 insertdata/insertDataToEs.go

@@ -6,6 +6,7 @@
    "fmt"
    "log"
    "net"
    "ruleprocess/cache"
    "strings"
    "time"

@@ -211,12 +212,12 @@
        }
        // log.Println("图片上传返回值：", resp)
        // 查询本机信息
        flag, localConfig := dbapi.SysSetApi{}.GetServerInfo()
        if !flag {
        localConfig, err := cache.GetServerInfo()
        if err !=nil {
            log.Println("查询本机信息失败！")
        }
        // 查询cameraName
        camera, err := dbapi.CameraApi{}.GetCameraById(msg.Cid)
        camera, err := cache.GetCameraById(msg.Cid)
        if err != nil {
            log.Println("查询摄像机信息失败")
        }