From dcf393c077af5638ea12c05dd6e1754fa535be20 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期一, 27 十一月 2023 16:30:04 +0800 Subject: [PATCH] 排程任务下发增加productProcedureID,报工表和工序表增加productProcedureID --- model/procedures.go | 38 ++++++++++++++++++++++++++++++++++++++ 1 files changed, 38 insertions(+), 0 deletions(-) diff --git a/model/procedures.go b/model/procedures.go index 4e10260..d38401c 100644 --- a/model/procedures.go +++ b/model/procedures.go @@ -12,6 +12,7 @@ type ( Procedures struct { gorm.Model + ProductProcedureID string `gorm:"index;type:varchar(191);not null" json:"productProcedureID"` //浜у搧宸ュ簭id WorkOrderID string `gorm:"index;type:varchar(191);not null" json:"-"` OrderID string `gorm:"index;type:varchar(191);not null" json:"-"` DeviceID string `gorm:"index;type:varchar(191)" json:"deviceId"` @@ -34,11 +35,15 @@ PageSize int Orm *gorm.DB Preload bool + StartTimeMin int64 StartTimeMax int64 EndTimeMin int64 + EndTimeMax int64 StatusNot ProcedureStatus ProcedureIds []string Channels []int32 + Offset int + Limit int } ) @@ -81,6 +86,11 @@ return slf } +func (slf *ProceduresSearch) SetOffset(offset, limit int) *ProceduresSearch { + slf.Offset, slf.Limit = offset, limit + return slf +} + func (slf *ProceduresSearch) SetOrder(order string) *ProceduresSearch { slf.Order = order return slf @@ -96,6 +106,11 @@ return slf } +func (slf *ProceduresSearch) SetStartTimeMin(ts int64) *ProceduresSearch { + slf.StartTimeMin = ts + return slf +} + func (slf *ProceduresSearch) SetStartTimeMax(ts int64) *ProceduresSearch { slf.StartTimeMax = ts return slf @@ -103,6 +118,11 @@ func (slf *ProceduresSearch) SetEndTimeMin(ts int64) *ProceduresSearch { slf.EndTimeMin = ts + return slf +} + +func (slf *ProceduresSearch) SetEndTimeMax(ts int64) *ProceduresSearch { + slf.EndTimeMax = ts return slf } @@ -141,6 +161,11 @@ return slf } +func (slf *ProceduresSearch) SetChannel(channel int32) *ProceduresSearch { + slf.Channel = channel + return slf +} + func (slf *ProceduresSearch) build() *gorm.DB { var db = slf.Orm.Model(&Procedures{}) @@ -168,8 +193,16 @@ db = db.Where("start_time <= ?", slf.StartTimeMax) } + if slf.StartTimeMin != 0 { + db = db.Where("start_time >= ?", slf.StartTimeMin) + } + if slf.EndTimeMin != 0 { db = db.Where("end_time > ?", slf.EndTimeMin) + } + + if slf.EndTimeMax != 0 { + db = db.Where("end_time < ?", slf.EndTimeMax) } if slf.Status != 0 { @@ -303,6 +336,11 @@ if slf.PageNum*slf.PageSize > 0 { db = db.Offset((slf.PageNum - 1) * slf.PageSize).Limit(slf.PageSize) } + + if slf.Limit > 0 { + db = db.Offset(slf.Offset).Limit(slf.Limit) + } + if err := db.Find(&records).Error; err != nil { return records, total, fmt.Errorf("find records err: %v", err) } -- Gitblit v1.8.0