add log and fix pubusb

554325746@qq.com

2019-07-22 40d864645ff608e3a81d115fef26bba87954be2c

 tasktag/tasktag.go

@@ -1,37 +1,63 @@
package tasktag

import (
   "fmt"
   "sync"

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

var TaskMapLab = make(map[string]*protomsg.TaskLabel)
var TaskMapLab sync.Map

//
func Init() {

   logger.Info("============= init tasktag info =====================")
   GenTaskMap()
   go func(taskflag chan bool) {
      for _ = range taskflag {
         GenTaskMap()
         logger.Info("update task finished!")
      }

   }(util.TaskSdkflag)
}

func GenTaskMap() {
   var tls []protomsg.TaskLabel
   for _, taskSdk := range util.TaskSdks {

   sdk1 := "812b674b-2375-4589-919a-5c1c3278a972"
   sdk2 := "812b674b-2375-4589-919a-5c1c3278a971"
      var tl protomsg.TaskLabel
      tl.Taskid = taskSdk.Task.Taskid
        tl.Taskname = taskSdk.Task.Taskname

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

   task2 := protomsg.TaskLabel{Taskid: "5b0902ae-b1bd-43c0-816d-0a87f1f859d2", Sdkids: []string{sdk1}, Index: int32(0)}
   tls = append(tls, task2)

   GenTasklab(tls)
   for key, value := range TaskMapLab {
      fmt.Println()
      fmt.Println(key, value)
      for _, sdkinfo := range taskSdk.Sdks {
            sdkinfowithtask := new(protomsg.SdkmsgWithTask) 
            sdkinfowithtask.Ipcid = sdkinfo.IpcId
            sdkinfowithtask.Sdktype = sdkinfo.SdkType
            sdkinfowithtask.Sdkdata = make([]byte, 1)
            tl.Sdkinfos = append(tl.Sdkinfos, sdkinfowithtask)
      }
      tl.Index = int32(0)
      tls = append(tls, tl)
   }
   GenTasklab(tls)
   TaskMapLab.Range(func(k, v interface{}) bool {
      logger.Info(k, v)
      return true
   })
}

// 从sqlite 接口拿到所有的任务, 每一个任务都有自己的几个算法
//以 taskid 作为key, 对应的算法组合作为 value
func GenTasklab(tasklab []protomsg.TaskLabel) {
   TaskMapLab.Range(func(key interface{}, value interface{}) bool {
      TaskMapLab.Delete(key)
      return true
   })

   for _, value := range tasklab {
      TaskMapLab[value.Taskid] = &value
      pv := value
      TaskMapLab.Store(value.Taskid, &pv)
   }
}