任务接口返回通道数量

zhangqian

2023-09-25 cb2f80a627413d6dda5b9071a2711cb03964ed15

 api/v1/task.go

@@ -51,7 +51,7 @@
// @Summary   获取任务
// @Produce   application/json
// @Param     object  query    request.TaskList true  "查询参数"
// @Success   200   {object}  contextx.Response{data=response.TaskData}  "成功"
// @Success   200   {object}  contextx.Response{data=response.TaskResponse}  "成功"
// @Router    /v1/task/get [get]
func (slf *TaskApi) TaskGet(c *gin.Context) {
   var params request.TaskList
@@ -59,12 +59,18 @@
   if !ok {
      return
   }

   channelAmount, err := service.NewDevicePlcService().GetDeviceChannelAmount()
   if err != nil {
      ctx.FailWithMsg(ecode.NeedConfirmedErr, err.Error())
      return
   }

   if params.Page <= 0 {
      params.Page = 1
   }
   if params.PageSize <= 0 {
      params.PageSize = 1
   }

   params.PageSize = channelAmount

   taskResponse, code := service.NewTaskService().GetTask(params.Page, params.PageSize, service.TaskModeCurrent) //取进行中的或未开始的
   if code != ecode.OK {
@@ -84,6 +90,9 @@
         task.CanStarted = true
      }
   }

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

   ctx.OkWithDetailed(taskResponse)
}
@@ -105,7 +114,7 @@
      params.Page = 1
   }
   if params.PageSize <= 0 {
      params.PageSize = 1
      params.PageSize = 100
   }

   taskResponse, code := service.NewTaskService().GetTask(params.Page, params.PageSize, service.TaskModeUnStarted) //时间到了未开始的
@@ -199,7 +208,7 @@
      ctx.Fail(code)
      return
   }
   err := service.NewTaskService().UpdateProcedureStatus(nil, id, model.ProcedureStatusFinished, procedure.Position)
   err := service.NewTaskService().UpdateProcedureStatus(nil, id, model.ProcedureStatusFinished, procedure.Channel)
   if err != nil {
      logx.Errorf("UpdateProcedureStatus err: %v", err.Error())
      ctx.Fail(ecode.UnknownErr)
@@ -260,11 +269,11 @@
   }

   err = model.WithTransaction(func(db *gorm.DB) error {
      err = taskService.UpdateProcedureStatusAndPosition(db, params.ProcedureId, model.ProcedureStatusProcessing, params.Position)
      err = taskService.UpdateProcedureStatusAndChannel(db, params.ProcedureId, model.ProcedureStatusProcessing, params.Channel)
      if err != nil {
         return err
      }
      procedure.Position = params.Position
      procedure.Channel = params.Channel
      err = taskService.UpdateOrderStatus(db, order.ID, model.OrderStatusProcessing)
      if err != nil {
         return err
@@ -286,11 +295,11 @@
   if err != nil {
      logx.Errorf("SendProcessParams: %v", err.Error())
      err = model.WithTransaction(func(db *gorm.DB) error {
         err = taskService.UpdateProcedureStatusAndPosition(db, params.ProcedureId, model.ProcedureStatusWaitProcess, params.Position)
         err = taskService.UpdateProcedureStatusAndChannel(db, params.ProcedureId, model.ProcedureStatusWaitProcess, params.Channel)
         if err != nil {
            return err
         }
         procedure.Position = params.Position
         procedure.Channel = params.Channel
         err = taskService.UpdateOrderStatus(db, order.ID, model.OrderStatusWaitProcess)
         if err != nil {
            return err
@@ -305,7 +314,7 @@
      return
   }
   plcConfig.CurrentTryTimes = 0
   err = service.PlcWrite(plcConfig, constvar.PlcStartAddressTypeTotalNumber, params.Position, order.Amount.IntPart())
   err = service.PlcWrite(plcConfig, constvar.PlcStartAddressTypeTotalNumber, params.Channel, order.Amount.IntPart())
   if err != nil {
      ctx.FailWithMsg(ecode.NeedConfirmedErr, "糟糕，工艺下发失败。")
      return