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