| | |
| | | package dbapi |
| | | |
| | | import ( |
| | | "basic.com/pubsub/protomsg.git" |
| | | "crypto/rand" |
| | | "encoding/json" |
| | | "fmt" |
| | | "reflect" |
| | | "testing" |
| | | "time" |
| | | ) |
| | | |
| | | func Add(a,b string) (string,string) { |
| | | ret := a+" "+b |
| | | return ret,ret |
| | | } |
| | | |
| | | func PseudoUuid() (uuid string) { |
| | | b := make([]byte, 16) |
| | | rand.Read(b) |
| | | uuid = fmt.Sprintf("%X-%X-%X-%X-%X", b[0:4], b[4:6], b[6:8], b[8:10], b[10:]) |
| | | |
| | | return uuid |
| | | } |
| | | |
| | | var funcMap = map[string]interface{}{"add":Add} |
| | | |
| | | func Call(name string, params ...interface{}) ([]reflect.Value){ |
| | | fun :=reflect.ValueOf(funcMap[name]) |
| | | if len(params) != fun.Type().NumIn() { |
| | | return nil |
| | | } |
| | | in := make([]reflect.Value,len(params)) |
| | | for k,v :=range params { |
| | | in[k] = reflect.ValueOf(v) |
| | | } |
| | | |
| | | return fun.Call(in) |
| | | } |
| | | |
| | | func TestGetLocalCameraTree(t *testing.T) { |
| | | var api AreaApi |
| | | body := api.GetLocalCameraTree(0, 0, "c") |
| | | fmt.Println(body) |
| | | //var api AreaApi |
| | | //body := api.GetLocalCameraTree("0", "0", "c") |
| | | //fmt.Println(body) |
| | | |
| | | ret := Call("add", "hello", "world") |
| | | fmt.Println("NewUUID:",PseudoUuid()) |
| | | fmt.Println(ret) |
| | | } |
| | | |
| | | func TestAreaAdd(t *testing.T) { |
| | | var api AreaApi |
| | | var area = Area{ |
| | | var area = protomsg.Area{ |
| | | Parentid: 0, |
| | | Name: "哈哈哈", |
| | | } |
| | | dataBytes, _ := json.Marshal(area) |
| | | paramBody := make(map[string]interface{},0) |
| | | json.Unmarshal(dataBytes,paramBody) |
| | | |
| | | flag := api.AreaAdd(area) |
| | | flag := api.AreaAdd(paramBody) |
| | | fmt.Println(flag) |
| | | } |
| | | |
| | | func TestAreaUpdate(t *testing.T) { |
| | | var api AreaApi |
| | | var area = Area{ |
| | | var area = protomsg.Area{ |
| | | Id: 1, |
| | | Name: "区域更新测试", |
| | | Parentid: 0, |
| | | } |
| | | flag := api.AreaUpdate(area) |
| | | dataBytes, _ := json.Marshal(area) |
| | | paramBody := make(map[string]interface{},0) |
| | | json.Unmarshal(dataBytes,paramBody) |
| | | flag := api.AreaUpdate(paramBody) |
| | | fmt.Println(flag) |
| | | } |
| | | |
| | |
| | | fmt.Println(camera) |
| | | } |
| | | |
| | | func TestMangosReqClient(t *testing.T){ |
| | | var client ReqrepApi |
| | | func TestCameraApi_Add(t *testing.T) { |
| | | var api CameraApi |
| | | camera := protomsg.Camera{ |
| | | Name:"测试啊啊啊啊啊啊啊啊", |
| | | Areaid:0, |
| | | } |
| | | dataBytes, _ := json.Marshal(camera) |
| | | paramBody := make(map[string]interface{},0) |
| | | json.Unmarshal(dataBytes,paramBody) |
| | | result := api.CameraAdd(paramBody) |
| | | fmt.Println("add result: ",result) |
| | | |
| | | client.SendRequestAndGetReply("one") |
| | | } |
| | | |
| | | func TestSdkApi_Save(t *testing.T) { |
| | | for { |
| | | time.Sleep(10 * time.Second) |
| | | var api SdkApi |
| | | sdk := protomsg.Sdk{ |
| | | SdkName:"awfewagewag", |
| | | Icon:"bbb", |
| | | Url:"baidu", |
| | | } |
| | | dataBytes, _ := json.Marshal(sdk) |
| | | paramBody := make(map[string]interface{},0) |
| | | json.Unmarshal(dataBytes,paramBody) |
| | | result,data := api.Save(paramBody) |
| | | fmt.Println("add result: ",result,data) |
| | | } |
| | | |
| | | } |
| | | |
| | | func TestMangosReqClient(t *testing.T){ |
| | | |
| | | } |
| | | |
| | | func TestSdkApi_FindAll(t *testing.T) { |
| | |
| | | |
| | | func TestSdkApi_GetById(t *testing.T) { |
| | | var api SdkApi |
| | | model := api.GetById("812b674b-2375-4589-919a-5c1c3278a97e") |
| | | fmt.Println(model) |
| | | _,data := api.GetById("812b674b-2375-4589-919a-5c1c3278a97e") |
| | | |
| | | dataBytes, _ := json.Marshal(data) |
| | | var sdkInfo protomsg.Sdk |
| | | err := json.Unmarshal(dataBytes,&sdkInfo) |
| | | if err !=nil { |
| | | fmt.Println("sdk Unmarshal err",err) |
| | | } |
| | | fmt.Println(sdkInfo.Args) |
| | | } |
| | | |
| | | func TestSdkApi_GetAllSdkIds(t *testing.T) { |
| | |
| | | var api TaskApi |
| | | taskInfos := api.FindAll() |
| | | fmt.Println(taskInfos) |
| | | } |
| | | |
| | | func TestCameraApi_FindAll(t *testing.T) { |
| | | var api CameraApi |
| | | cameras := api.FindAll() |
| | | fmt.Println(cameras) |
| | | } |
| | | |
| | | //查找所有的多边形 |
| | | func TestCameraApi_FindAllPolygons(t *testing.T) { |
| | | var api CameraApi |
| | | data := api.FindAllPolygons() |
| | | fmt.Println("polygons:",data) |
| | | } |
| | | |
| | | //查找所有时间规则 |
| | | func TestCameraApi_FindAllTimeRules(t *testing.T) { |
| | | var api CameraApi |
| | | _, rules := api.FindAllTimeRules() |
| | | fmt.Println("timeRules:",rules) |
| | | } |
| | | |
| | | //查找所有任务规则 |
| | | func TestCameraTaskArgsApi_FindAll(t *testing.T) { |
| | | var api CameraTaskArgsApi |
| | | all := api.FindAll() |
| | | fmt.Println("all:",all) |
| | | } |
| | | |
| | | func TestSysSetApi_GetServerInfo(t *testing.T) { |
| | | var api SysSetApi |
| | | flag, sysconf := api.GetServerInfo() |
| | | fmt.Println("flag:",flag) |
| | | fmt.Println("server.Info:",sysconf) |
| | | } |
| | | |
| | | func TestCameraApi_GetCamerasByRunType(t *testing.T) { |
| | | var api CameraApi |
| | | flag, cameras := api.GetCamerasByRunType(0,"") |
| | | fmt.Println("flag:",flag) |
| | | fmt.Println("cameras:",cameras) |
| | | } |