test all process

554325746@qq.com

2019-05-28 70df7b912014201e271a2966599b84d77addd0f9

 tasktag/tasktag.go

@@ -2,34 +2,33 @@

import (
   "fmt"
   "basic.com/pubsub/protomsg.git"
    "basic.com/dbapi.git"
)

/* 任务标签生成器
 *  描述： 用于在数据进入到特定的task时， 给这个数据加上任务标签，这样就能知道算法流程了
 */
var TaskMapLab = make(map[string] *protomsg.TaskLabel)
var taskapi dbapi.TaskApi

type TaskLabel struct {
   Taskid string
   Sdkids []string
   Index  int
}

var TaskMapLab = make(map[string]TaskLabel)

//
func Init() {
   var tls []TaskLabel

   sdk1 := "812b674b-2375-4589-919a-5c1c3278a972"
   sdk2 := "812b674b-2375-4589-919a-5c1c3278a971"
    fmt.Println("=========== tasktag info ====================")
   var tls []protomsg.TaskLabel

   task1 := TaskLabel{"5b0902ae-b1bd-43c0-816d-0a87f1f859d1", []string{sdk1, sdk2}, 0}
   tls = append(tls, task1)

   task2 := TaskLabel{"5b0902ae-b1bd-43c0-816d-0a87f1f859d2", []string{sdk2}, 0}
   tls = append(tls, task2)
     taskSdks := taskapi.FindAll()
     for _, taskSdk := range taskSdks {
         fmt.Println("test:    ", taskSdk)
         var tl  protomsg.TaskLabel
         tl.Taskid = taskSdk.Task.Taskid
         for _, sdkinfo := range taskSdk.Sdks {
             tl.Sdkids = append(tl.Sdkids, sdkinfo.Id)
         }
         fmt.Println(tl)
         tl.Index=int32(0)
         tls = append(tls, tl)
     }

   GenTasklab(tls)

   for key, value := range TaskMapLab {
      fmt.Println()
      fmt.Println(key, value)
@@ -38,8 +37,9 @@

// 从sqlite 接口拿到所有的任务, 每一个任务都有自己的几个算法
//以 taskid 作为key, 对应的算法组合作为 value
func GenTasklab(tasklab []TaskLabel) {
func GenTasklab(tasklab []protomsg.TaskLabel) {
   for _, value := range tasklab {
      TaskMapLab[value.Taskid] = value
        pv := value
       TaskMapLab[value.Taskid] = &pv  
   }
}