| | |
| | | |
| | | import ( |
| | | "fmt" |
| | | |
| | | "github.com/long/test/protomsg" |
| | | ) |
| | | |
| | | /* 任务标签生成器 |
| | | * 描述: 用于在数据进入到特定的task时, 给这个数据加上任务标签,这样就能知道算法流程了 |
| | | */ |
| | | |
| | | type TaskLabel struct { |
| | | Taskid string |
| | | Sdkids []string |
| | | Index int |
| | | } |
| | | |
| | | var TaskMapLab = make(map[string]TaskLabel) |
| | | var TaskMapLab = make(map[string]*protomsg.TaskLabel) |
| | | |
| | | // |
| | | func Init() { |
| | | var tls []TaskLabel |
| | | var tls []protomsg.TaskLabel |
| | | |
| | | sdk1 := "812b674b-2375-4589-919a-5c1c3278a972" |
| | | sdk2 := "812b674b-2375-4589-919a-5c1c3278a971" |
| | | |
| | | task1 := TaskLabel{"5b0902ae-b1bd-43c0-816d-0a87f1f859d1", []string{sdk1, sdk2}, 0} |
| | | task1 := protomsg.TaskLabel{Taskid: "5b0902ae-b1bd-43c0-816d-0a87f1f859d1", Sdkids: []string{sdk1, sdk2}, Index: int32(0)} |
| | | tls = append(tls, task1) |
| | | |
| | | task2 := TaskLabel{"5b0902ae-b1bd-43c0-816d-0a87f1f859d2", []string{sdk2}, 0} |
| | | task2 := protomsg.TaskLabel{Taskid: "5b0902ae-b1bd-43c0-816d-0a87f1f859d2", Sdkids: []string{sdk1}, Index: int32(0)} |
| | | tls = append(tls, task2) |
| | | |
| | | GenTasklab(tls) |
| | |
| | | |
| | | // 从sqlite 接口拿到所有的任务, 每一个任务都有自己的几个算法 |
| | | //以 taskid 作为key, 对应的算法组合作为 value |
| | | func GenTasklab(tasklab []TaskLabel) { |
| | | func GenTasklab(tasklab []protomsg.TaskLabel) { |
| | | for _, value := range tasklab { |
| | | TaskMapLab[value.Taskid] = value |
| | | TaskMapLab[value.Taskid] = &value |
| | | } |
| | | } |