工艺模型库字段精简

zhangqian

2023-09-21 510da2930e2e639b3d490e6fddc15af64520f8eb

 service/task.go

@@ -23,7 +23,7 @@
   return &TaskService{}
}

// GetTask 获取任务，未完成的开始时间最早的任务
// GetTask 获取任务，未完成的开始时间小于等于当前时间，结束时间大于当前时间的任务
func (slf TaskService) GetTask(page, pageSize int) (taskResp *response.TaskResponse, code int) {
   var taskList []*response.TaskData
   var count int64
@@ -37,6 +37,7 @@
   )
   procedures, err = model.NewProceduresSearch(nil).SetOrder("start_time asc").
      SetStartTimeMax(nowTs).
      SetEndTimeMin(nowTs).
      SetDeviceId(conf.Conf.System.DeviceId).
      SetStatusNot(model.ProcedureStatusFinished).
      SetPage(page, pageSize).
@@ -116,7 +117,7 @@

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

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

func (slf TaskService) GetProcessParams(procedure *model.Procedures, order *model.Order) (processModel *model.ProcessModel, err error) {
   data, err := model.NewProcessModelSearch().
      SetWorkOrder(procedure.WorkOrderID).
      SetDevice(procedure.ProceduresInfo.DeviceName).
      SetOrderId(procedure.OrderID).
      SetProcedure(procedure.ProceduresInfo.ProcedureName).
      SetProduct(order.ProductName).
      SetOrder("id desc").First()