设备列表返回是否设置工艺参数字段

zhangqian

2023-11-09 02a84fb6fb2a39bfe7fc5cf6c0137bbf231b17fe

 api/v1/task.go

@@ -10,7 +10,6 @@
   "apsClient/pkg/ecode"
   "apsClient/pkg/logx"
   "apsClient/service"
   "apsClient/service/plc_address"
   "errors"
   "github.com/gin-gonic/gin"
   "github.com/jinzhu/gorm"
@@ -78,7 +77,7 @@
      taskMode = params.TaskMode
   }

   taskResponse, code := service.NewTaskService().GetTask(params.DeviceID, params.Page, params.PageSize, taskMode, nil) //取进行中的或未开始的
   taskResponse, code := service.NewTaskService().GetTask(conf.Conf.CurrentDeviceID, params.Page, params.PageSize, taskMode, nil) //取进行中的或未开始的
   if code != ecode.OK {
      ctx.Fail(code)
      return
@@ -93,7 +92,7 @@
         if existsChannel[int32(i)] {
            continue
         }
         taskResponseTemp, code := service.NewTaskService().GetTask(params.DeviceID, params.Page, 1, constvar.TaskModeLastFinished, []int32{int32(i)}) //取上一个完成的
         taskResponseTemp, code := service.NewTaskService().GetTask(conf.Conf.CurrentDeviceID, params.Page, 1, constvar.TaskModeLastFinished, []int32{int32(i)}) //取上一个完成的
         if code != ecode.OK {
            ctx.Fail(code)
            return
@@ -235,7 +234,7 @@
   }

   service.TaskFlagUnset(procedure.Channel)

   service.TaskEndTimeSet(procedure.Channel, time.Now().Unix()) //设置工序运行结束时间
   ctx.Ok()
}

@@ -322,7 +321,9 @@
      return
   }

   service.TaskFlagSet(procedure.Channel)
   service.TaskFlagSet(procedure.Channel, int(procedure.ID))
   service.TaskStartTimeSet(procedure.Channel, time.Now().Unix()) //设置工序运行开始时间
   service.TaskEndTimeSet(procedure.Channel, 0)                   //设置工序运行结束时间
   ctx.Ok()
}

@@ -390,8 +391,12 @@
      logx.Info("----------------开始下发工艺参数-----------------")
   }
   var failedNumbers int
   processModelAddress, err := service.GetProcessModelAddress(conf.Conf.CurrentDeviceID)
   if err != nil {
      return err
   }
   for k, v := range paramsMap {
      address, ok := plc_address.Get(k)
      address, ok := processModelAddress[k]
      if !ok {
         logx.Errorf("miss param address, k:%v, v:%v", k, v)
         continue
@@ -420,7 +425,7 @@
// @Produce   application/json
// @Param     object  query    request.TaskListByChannel true  "查询参数"
// @Success   200   {object}  contextx.Response{data=map[int32]response.TaskResponse}  "成功"
// @Router    /v1/task/listByChannel [get]
// @Router    /v1/task/list [get]
func (slf *TaskApi) TaskListByChannel(c *gin.Context) {
   var params request.TaskListByChannel
   ctx, ok := contextx.NewContext(c, &params)