fix

zhangqian

2023-12-01 8324f872ef3a4d0c978a9b1d062800c6a1701c12

 model/task_status_sync.go

@@ -10,11 +10,15 @@
   // TaskStatusSync 任务状态同步
   TaskStatusSync struct {
      gorm.Model
      WorkOrderId  string `json:"workOrderId"` //工单编号
      ProcedureID  string `json:"procedureId"` // 工序编号
      DeviceId     string `json:"deviceId"`    //设备编号
      IsProcessing bool   //是否处理中
      IsFinish     bool   //是否完成
      WorkOrderId        string `json:"workOrderId"`                                  //工单编号
      ProductProcedureID string `gorm:"type:varchar(191);" json:"productProcedureID"` //产品工序id
      ProcedureID        string `json:"procedureId"`                                  // 工序编号
      DeviceId           string `json:"deviceId"`                                     //设备编号
      IsProcessing       bool   //是否处理中
      IsFinish           bool   //是否完成
      StartTs            int64  `json:"start_ts"`  //开始时间
      FinishTs           int64  `json:"finish_ts"` //结束时间
      FinishedQuantity   int    `json:"finishedQuantity"`
   }

   TaskStatusSyncSearch struct {
@@ -23,6 +27,7 @@
      PageNum  int
      PageSize int
      Orm      *gorm.DB
      IDs      []uint
   }
)

@@ -57,6 +62,21 @@
   return slf
}

func (slf *TaskStatusSyncSearch) SetProductProcedureId(productProcedureId string) *TaskStatusSyncSearch {
   slf.ProductProcedureID = productProcedureId
   return slf
}

func (slf *TaskStatusSyncSearch) SetWorkOrderId(workOrderId string) *TaskStatusSyncSearch {
   slf.WorkOrderId = workOrderId
   return slf
}

func (slf *TaskStatusSyncSearch) SetIDs(ids []uint) *TaskStatusSyncSearch {
   slf.IDs = ids
   return slf
}

func (slf *TaskStatusSyncSearch) build() *gorm.DB {
   var db = slf.Orm.Table(slf.TableName())

@@ -64,10 +84,22 @@
      db = db.Where("id = ?", slf.ID)
   }

   if slf.ProductProcedureID != "" {
      db = db.Where("product_procedure_id = ?", slf.ProductProcedureID)
   }

   if len(slf.IDs) != 0 {
      db = db.Where("id in (?)", slf.IDs)
   }

   if slf.Order != "" {
      db = db.Order(slf.Order)
   }

   if slf.WorkOrderId != "" {
      db = db.Where("work_order_id = ?", slf.WorkOrderId)
   }

   return db
}