zhangqian
2023-11-29 28addaa46cb97c20ad37e13eb10535de7b75e71c
model/production_progress.go
@@ -9,21 +9,24 @@
type (
   ProductionProgress struct {
      gorm.Model
      WorkOrderID      string `gorm:"index;type:varchar(191);not null" json:"workOrderID"`
      OrderID          string `gorm:"index;type:varchar(191);not null" json:"orderID"`
      ProcedureID      string `gorm:"type:varchar(191)" json:"procedureId"`
      DeviceID         string `gorm:"type:varchar(191);not null" json:"deviceId"`
      FinishedQuantity int64  `gorm:"type:int;not null" json:"finishedQuantity"`
      Channel          int32  `gorm:"type:int" json:"channel"` //通道
      TotalQuantity    int64  `gorm:"type:int;not null" json:"totalQuantity"`
      ProceduresID       uint   `gorm:"index;type:varchar(191)" json:"proceduresId"` //procedures表的id
      WorkOrderID        string `gorm:"index;type:varchar(191);not null" json:"workOrderID"`
      OrderID            string `gorm:"index;type:varchar(191);not null" json:"orderID"`
      ProcedureID        string `gorm:"type:varchar(191)" json:"procedureId"`
      ProductProcedureID string `gorm:"type:varchar(191);" json:"productProcedureID"` //产品工序id
      DeviceID           string `gorm:"type:varchar(191);not null" json:"deviceId"`
      FinishedQuantity   int64  `gorm:"type:int;not null" json:"finishedQuantity"`
      Channel            int32  `gorm:"type:int" json:"channel"` //通道
      TotalQuantity      int64  `gorm:"type:int;not null" json:"totalQuantity"`
   }
   ProductionProgressSearch struct {
      ProductionProgress
      Order    string
      PageNum  int
      PageSize int
      Orm      *gorm.DB
      Order      string
      PageNum    int
      PageSize   int
      Orm        *gorm.DB
      UnFinished bool
   }
)
@@ -63,8 +66,18 @@
   return slf
}
func (slf *ProductionProgressSearch) SetProceduresId(proceduresId uint) *ProductionProgressSearch {
   slf.ProceduresID = proceduresId
   return slf
}
func (slf *ProductionProgressSearch) SetDeviceId(id string) *ProductionProgressSearch {
   slf.DeviceID = id
   return slf
}
func (slf *ProductionProgressSearch) SetProductProcedureId(productProcedureId string) *ProductionProgressSearch {
   slf.ProductProcedureID = productProcedureId
   return slf
}
@@ -75,6 +88,11 @@
func (slf *ProductionProgressSearch) SetChannel(channel int32) *ProductionProgressSearch {
   slf.Channel = channel
   return slf
}
func (slf *ProductionProgressSearch) SetUnFinished() *ProductionProgressSearch {
   slf.UnFinished = true
   return slf
}
@@ -101,12 +119,24 @@
      db = db.Where("procedure_id = ?", slf.ProcedureID)
   }
   if slf.ProceduresID != 0 {
      db = db.Where("procedures_id = ?", slf.ProceduresID)
   }
   if slf.DeviceID != "" {
      db = db.Where("device_id = ?", slf.DeviceID)
   }
   if slf.Channel != 0 {
      db = db.Where("channel = ?", slf.Channel)
   }
   if slf.UnFinished {
      db = db.Where("finished_quantity <  total_quantity")
   }
   if slf.ProductProcedureID != "" {
      db = db.Where("product_procedure_id = ?", slf.ProductProcedureID)
   }
   return db
@@ -118,17 +148,6 @@
   if err := db.Create(record).Error; err != nil {
      return fmt.Errorf("create err: %v, record: %+v", err, record)
   }
   return nil
}
// CreateBatch 批量插入
func (slf *ProductionProgressSearch) CreateBatch(records []*ProductionProgress) error {
   var db = slf.build()
   if err := db.Create(&records).Error; err != nil {
      return fmt.Errorf("create batch err: %v, records: %+v", err, records)
   }
   return nil