按通道数量给前端返回任务数

zhangqian

2023-09-23 3a1d4cc4ddfe02942e5c8dee0b2187cf758f3bde

 api/v1/task.go

@@ -59,13 +59,19 @@
   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 {
      ctx.Fail(code)
@@ -84,6 +90,8 @@
         task.CanStarted = true
      }
   }

   taskResponse.Prompt = conf.Conf.Prompt

   ctx.OkWithDetailed(taskResponse)
}
@@ -105,7 +113,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 +207,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 +268,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 +294,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 +313,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