是否可以开始增加开始时间判断，考虑进程退出和断电情况

zhangqian

2023-10-08 d4243f398b84a8b8cdcd27c35ace72f6a30a6452

 api/v1/task.go

@@ -68,10 +68,14 @@
      return
   }

   taskCount := service.NewTaskService().NewTaskCount()
   params.Page = 1

   if params.PageSize <= 0 {
      params.PageSize = channelAmount
      if params.TaskMode == constvar.TaskModeUnStarted {
         params.PageSize = int(taskCount)
      } else {
         params.PageSize = channelAmount
      }
   }

   taskMode := constvar.TaskModeCurrent
@@ -107,14 +111,16 @@
      return taskResponse.Tasks[i].Channel < taskResponse.Tasks[i].Channel
   })

   nowTs := time.Now().Unix()
   for _, task := range taskResponse.Tasks {
      if !service.TaskFlagGet(task.Channel) {
      if !service.TaskFlagGet(task.Channel) && task.Procedure.StartTime <= nowTs {
         task.CanStarted = true
      }
   }

   taskResponse.Prompt = conf.Conf.Prompt
   taskResponse.ChannelAmount = channelAmount
   taskResponse.TaskCount = taskCount

   ctx.OkWithDetailed(taskResponse)
}
@@ -202,6 +208,14 @@
      ctx.Fail(code)
      return
   }
   if procedure.Status == model.ProcedureStatusFinished {
      ctx.Ok()
      return
   }
   if procedure.Status != model.ProcedureStatusProcessing {
      ctx.Fail(ecode.ParamsErr)
      return
   }
   err := service.NewTaskService().UpdateProcedureStatus(nil, id, model.ProcedureStatusFinished, procedure.Channel)
   if err != nil {
      logx.Errorf("UpdateProcedureStatus err: %v", err.Error())