add sdk cache

liuxiaolong

2019-07-09 8ed8a432c4f9db9963d314f246b106aa36e1fb7c

add sdk cache

 cache/cache.go

@@ -17,6 +17,7 @@
    PREFIX_TIME = "TIME_"
    PREFIX_RULE = "RULE_"
    SERVER_KEY = "SERVERINFO"
    PREFIX_SDK = "SDK_"
)

var cMap *shardmap.ShardMap
@@ -51,6 +52,8 @@

    initServerInfo()//初始化服务器配置信息

    initSdks() //初始化sdk列表信息

    initChan <- true
}

@@ -74,6 +77,8 @@
        initCameraTaskRules()
    case protomsg.TableChanged_T_CameraTaskArgs://更新摄像机规则配置参数
        initCameraTaskRules()
    case protomsg.TableChanged_T_Sdk://更新sdk配置
        initSdks()
    default:
        fmt.Println("unknown operation")

@@ -133,6 +138,14 @@
    }
}

func initSdks(){
    var api dbapi.SdkApi
    sdks := api.FindAll("")
    for _,sdk :=range sdks {
        cMap.Set(PREFIX_SDK+sdk.Id,sdk)
    }
}

func GetServerInfo() (con protomsg.LocalConfig,err error) {
    config, b := cMap.Get(SERVER_KEY)
    if b {
@@ -179,4 +192,13 @@
    } else {
        return nil
    }
}

func GetSdkById(sdkId string) (sdk protomsg.Sdk,err error){
    obj,b :=cMap.Get(PREFIX_SDK + sdkId)
    if b {
        return obj.(protomsg.Sdk),nil
    } else {
        return sdk,errors.New("sdk not found")
    }
}