任务接口返回通道数量

zhangqian

2023-09-25 cb2f80a627413d6dda5b9071a2711cb03964ed15

 service/task.go

@@ -23,8 +23,16 @@
   return &TaskService{}
}

type TaskMode int

const (
   TaskModeUnStarted    TaskMode = 1 //未开始的
   TaskModeCurrent      TaskMode = 2
   TaskModeLastFinished TaskMode = 3 //上一个结束的
)

// GetTask 获取任务，未完成的开始时间小于等于当前时间，结束时间大于当前时间的任务
func (slf TaskService) GetTask(page, pageSize int) (taskResp *response.TaskResponse, code int) {
func (slf TaskService) GetTask(page, pageSize int, mode TaskMode) (taskResp *response.TaskResponse, code int) {
   var taskList []*response.TaskData
   var count int64
   var workers []*common.ProcedureWorker
@@ -35,21 +43,29 @@
      procedures   []*model.Procedures
      workOrderIds []string
   )
   procedures, err = model.NewProceduresSearch(nil).SetOrder("start_time asc").
      SetStartTimeMax(nowTs).
      SetEndTimeMin(nowTs).
   search := model.NewProceduresSearch(nil).
      SetDeviceId(conf.Conf.System.DeviceId).
      SetStatusNot(model.ProcedureStatusFinished).
      SetPage(page, pageSize).
      SetOrder("status desc").
      FindNotTotal()
      SetPage(page, pageSize)

   if mode == TaskModeUnStarted {
      search.SetStatus(model.ProcedureStatusWaitProcess).
         SetStartTimeMax(nowTs).
         SetEndTimeMin(nowTs).
         SetOrder("start_time asc")
   } else if mode == TaskModeCurrent {
      search.SetStatusNot(model.ProcedureStatusFinished).
         SetStartTimeMax(nowTs).
         SetEndTimeMin(nowTs).
         SetOrder("start_time asc, status desc")
   } else if mode == TaskModeLastFinished {
      search.SetStatus(model.ProcedureStatusFinished).SetOrder("updated_at desc")
   }

   procedures, err = search.FindNotTotal()
   if err != nil {
      return nil, ecode.DBErr
   }
   count, err = model.NewProceduresSearch(nil).
      SetDeviceId(conf.Conf.System.DeviceId).
      SetStatusNot(model.ProcedureStatusFinished).
      Count()
   count, err = search.Count()
   if err != nil {
      return nil, ecode.DBErr
   }
@@ -75,7 +91,7 @@
         Procedure:             procedure,
         AllProcedures:         procedure.ProceduresInfo.AllProcedureNames,
         CurrentProcedureIndex: 0,
         Position:              procedure.Position,
         Channel:               procedure.Channel,
      }
      index := 0
      for _, name := range procedure.ProceduresInfo.AllProcedureNames {
@@ -116,19 +132,19 @@
   return procedure, ecode.OK
}

func (slf TaskService) UpdateProcedureStatusAndPosition(db *gorm.DB, id int, status model.ProcedureStatus, position int) error {
func (slf TaskService) UpdateProcedureStatusAndChannel(db *gorm.DB, id int, status model.ProcedureStatus, channel int32) error {
   if status == model.ProcedureStatusFinished {
      ProgressCacheUnset(position)
      ProgressCacheUnset(channel)
   }
   return model.NewProceduresSearch(db).SetId(id).UpdateByMap(map[string]interface{}{
      "status":   status,
      "position": position,
      "status":  status,
      "channel": channel,
   })
}

func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id int, status model.ProcedureStatus, position int) error {
func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id int, status model.ProcedureStatus, channel int32) error {
   if status == model.ProcedureStatusFinished {
      ProgressCacheUnset(position)
      ProgressCacheUnset(channel)
   }
   return model.NewProceduresSearch(db).SetId(id).UpdateByMap(map[string]interface{}{
      "status": status,