add heartbeat

龙赣华

2019-05-31 3c8609a3da72cb2f3610f3f1789dafacc6c0f40f

 tasktag/tasktag.go

@@ -2,30 +2,27 @@

import (
   "fmt"

   "basic.com/pubsub/protomsg.git"
    "basic.com/dbapi.git"
   "github.com/long/test/util"
)

var TaskMapLab = make(map[string] *protomsg.TaskLabel)
var taskapi dbapi.TaskApi
var TaskMapLab = make(map[string]*protomsg.TaskLabel)

func Init() {

    fmt.Println("=========== tasktag info ====================")
   var tls []protomsg.TaskLabel
   fmt.Println("============= init tasktag info =====================")

     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)
     }
   for _, taskSdk := range util.TaskSdks {
      var tl protomsg.TaskLabel
      tl.Taskid = taskSdk.Task.Taskid
      for _, sdkinfo := range taskSdk.Sdks {
         tl.Sdkids = append(tl.Sdkids, sdkinfo.Id)
      }
      tl.Index = int32(0)
      tls = append(tls, tl)
   }

   GenTasklab(tls)

@@ -39,7 +36,7 @@
//以 taskid 作为key, 对应的算法组合作为 value
func GenTasklab(tasklab []protomsg.TaskLabel) {
   for _, value := range tasklab {
        pv := value
       TaskMapLab[value.Taskid] = &pv  
      pv := value
      TaskMapLab[value.Taskid] = &pv
   }
}