| | |
| | | package model |
| | | |
| | | import ( |
| | | "apsClient/constvar" |
| | | "apsClient/pkg/sqlitex" |
| | | "fmt" |
| | | "github.com/jinzhu/gorm" |
| | |
| | | // TaskStatusSync 任务状态同步 |
| | | TaskStatusSync struct { |
| | | gorm.Model |
| | | 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"` |
| | | 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"` |
| | | SyncStatus constvar.SyncStatus `json:"-"` |
| | | } |
| | | |
| | | TaskStatusSyncSearch struct { |
| | |
| | | PageSize int |
| | | Orm *gorm.DB |
| | | IDs []uint |
| | | SyncWait bool |
| | | } |
| | | ) |
| | | |
| | |
| | | return slf |
| | | } |
| | | |
| | | func (slf *TaskStatusSyncSearch) SetSyncWait() *TaskStatusSyncSearch { |
| | | slf.SyncWait = true |
| | | return slf |
| | | } |
| | | |
| | | func (slf *TaskStatusSyncSearch) build() *gorm.DB { |
| | | var db = slf.Orm.Table(slf.TableName()) |
| | | |
| | |
| | | db = db.Where("work_order_id = ?", slf.WorkOrderId) |
| | | } |
| | | |
| | | if slf.SyncWait { |
| | | db = db.Where("sync_status != ?", constvar.SyncStatusOk) |
| | | } |
| | | |
| | | return db |
| | | } |
| | | |