多个新任务只能第一个可以开始

zhangqian

2023-10-08 847e73ca2be7cb0b0df2eef425f4adedda20a874

 api/v1/task.go

@@ -111,8 +111,12 @@
      return taskResponse.Tasks[i].Channel < taskResponse.Tasks[i].Channel
   })

   nowTs := time.Now().Unix()

   flagMap := make(map[int32]struct{}, 0)

   for _, task := range taskResponse.Tasks {
      if !service.TaskFlagGet(task.Channel) {
      if _, ok := flagMap[task.Channel]; !ok && !service.TaskFlagGet(task.Channel) && task.Procedure.StartTime <= nowTs {
         task.CanStarted = true
      }
   }