| | |
| | | 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() |