增加实时获取生产进度接口

zhangqian

2023-09-16 ef7d02ce56e98e8cbc5ed6ec746ea39bf0b8c9e2

 model/procedures.go

@@ -17,6 +17,7 @@
      OrderID        string `gorm:"index;type:varchar(191);not null;comment:订单ID" json:"-"`
      DeviceID       string `gorm:"index;type:varchar(191);comment:设备ID" json:"deviceId"`
      ProcedureID    string `gorm:"index;type:varchar(191);comment:工序ID" json:"procedureId"`
      Position       int    `gorm:"type:int;comment:工作位置" json:"position"` //每个设备可能有多个机位同时生产，用position表示位置
      StartTime      int64  `gorm:"comment:计划开始时间" json:"startTime"`
      EndTime        int64  `gorm:"comment:计划结束时间" json:"endTime"`
      Status         ProcedureStatus
@@ -85,6 +86,12 @@
   slf.WorkOrderID = orderId
   return slf
}

func (slf *ProceduresSearch) SetProcedureId(id string) *ProceduresSearch {
   slf.ProcedureID = id
   return slf
}

func (slf *ProceduresSearch) SetStartTimeMax(ts int64) *ProceduresSearch {
   slf.StartTimeMax = ts
   return slf
@@ -159,6 +166,10 @@
      db = db.Where("procedure_id in ?", slf.ProcedureIds)
   }

   if slf.ProcedureID != "" {
      db = db.Where("procedure_id = ?", slf.ProcedureID)
   }

   return db
}

@@ -184,10 +195,10 @@
   return nil
}

func (slf *ProceduresSearch) Save(record *Procedures) error {
func (slf *ProceduresSearch) Updates(record *Procedures) error {
   var db = slf.build()

   if err := db.Save(record).Error; err != nil {
   if err := db.Updates(record).Error; err != nil {
      return fmt.Errorf("save err: %v, record: %+v", err, record)
   }

@@ -261,6 +272,17 @@
   return records, total, nil
}

func (slf *ProceduresSearch) Count() (int64, error) {
   var (
      total int64
      db    = slf.build()
   )
   if err := db.Count(&total).Error; err != nil {
      return total, fmt.Errorf("find count err: %v", err)
   }
   return total, nil
}

func (slf *ProceduresSearch) FindNotTotal() ([]*Procedures, error) {
   var (
      records = make([]*Procedures, 0)