add TaskSdkRun and SdkRun

liuxiaolong

2019-07-09 8a9676731a654165e1610a41c867e8be8dc5d696

add TaskSdkRun and SdkRun

 api_test.go

@@ -45,6 +45,7 @@

    ret := Call("add", "hello", "world")
    fmt.Println("NewUUID:",PseudoUuid())

    fmt.Println(ret)
}

@@ -114,8 +115,18 @@

}

func TestMangosReqClient(t *testing.T){
type Point struct {
    X float64 `json:"x"`
    Y float64 `json:"y"`
}

func TestMangosReqClient(t *testing.T){
    location := make([]Point, 0)
    if err := json.Unmarshal([]byte(""), &location); err == nil {
        fmt.Println("location:",location)
    } else {
        fmt.Println("unmarshal err:",err)
    }
}

func TestSdkApi_FindAll(t *testing.T) {
@@ -135,6 +146,18 @@
        fmt.Println("sdk Unmarshal err",err)
    }
    fmt.Println(sdkInfo.Args)
}

func TestTaskApi_FindAllForIpc(t *testing.T) {
    var api TaskApi
    taskSdks := api.FindAllTaskSdkRun()
    fmt.Println(taskSdks)
}

func TestSdkApi_FindAllSdkRun(t *testing.T) {
    var api SdkApi
    sdkRuns := api.FindAllSdkRun()
    fmt.Println(sdkRuns)
}

func TestSdkApi_GetAllSdkIds(t *testing.T) {
@@ -185,7 +208,13 @@

func TestCameraApi_GetCamerasByRunType(t *testing.T) {
    var api CameraApi
    flag, cameras := api.GetCamerasByRunType(0,"")
    flag, cameras := api.GetCamerasByRunType(1,"")
    fmt.Println("flag:",flag)
    fmt.Println("cameras:",cameras)
}

func TestSysSetApi_GetPollConfig(t *testing.T) {
    var api SysSetApi
    _, config := api.GetPollConfig()
    fmt.Println("config:",config)
}

 sdkApi.go

@@ -47,16 +47,42 @@
    return sdkArr
}

//查找算法id的slice
func (api SdkApi) GetAllSdkIds() (sdkIds []string){
func (api SdkApi) FindAllSdkRun()(sdkRuns []protomsg.SdkRun){
    sdkArr := api.FindAll("")
    if len(sdkArr) == 0 {
        return nil
    }
    idMap :=make(map[string]string,0)
    for _,sdk := range sdkArr{
        sdkIds = append(sdkIds, sdk.Id)
        if sdk.IpcId !=""{
            if _,ok :=idMap[sdk.IpcId];!ok{
                idMap[sdk.IpcId] = sdk.IpcId
                sdkRuns = append(sdkRuns,protomsg.SdkRun{
                    IpcId:sdk.IpcId,
                    SdkType:sdk.SdkType,
                })
    }
    return sdkIds
        }
    }
    return sdkRuns
}

//查找算法id的slice
func (api SdkApi) GetAllSdkIds() (ipcIds []string){
    sdkArr := api.FindAll("")
    if len(sdkArr) == 0 {
        return nil
    }
    idMap :=make(map[string]string,0)
    for _,sdk := range sdkArr{
        if sdk.IpcId !=""{
            if _,ok :=idMap[sdk.IpcId];!ok{
                idMap[sdk.IpcId] = sdk.IpcId
                ipcIds = append(ipcIds,sdk.IpcId)
            }
        }
    }
    return ipcIds
}

//通过id获取算法信息

 taskApi.go

@@ -27,6 +27,30 @@
    return taskInfos
}

func (api TaskApi) FindAllTaskSdkRun() (taskSdks []protomsg.TaskSdkRun) {
    taskInfos := api.FindAll()
    if taskInfos !=nil {
        for _,ti :=range taskInfos{
            tsr := protomsg.TaskSdkRun{
                Task:ti.Task,
            }
            m := make(map[string]string,0)
            for _,s := range ti.Sdks{
                if _,ok :=m[s.IpcId];!ok{
                    m[s.IpcId] = s.IpcId
                    tsr.Sdks = append(tsr.Sdks,&protomsg.SdkRun{
                        IpcId:s.IpcId,
                        SdkType:s.SdkType,
                    })
                }
            }

            taskSdks = append(taskSdks,tsr)
        }
    }
    return taskSdks
}

func (api TaskApi) Add(paramBody map[string]interface{}) (bool,interface{}) {
    url := BASIC_URL + DATA_URL_PREFIX + "/task/add"
    client := NewClient()