From 02a84fb6fb2a39bfe7fc5cf6c0137bbf231b17fe Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 09 十一月 2023 14:14:17 +0800
Subject: [PATCH] 设备列表返回是否设置工艺参数字段

---
 model/procedures.go |   47 +++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 43 insertions(+), 4 deletions(-)

diff --git a/model/procedures.go b/model/procedures.go
index 4c93059..d2d85d5 100644
--- a/model/procedures.go
+++ b/model/procedures.go
@@ -20,6 +20,8 @@
 		ProcessModelNumber string `gorm:"index;" json:"processModelNumber"` //宸ヨ壓妯″瀷缂栧彿
 		StartTime          int64  `json:"startTime"`
 		EndTime            int64  `json:"endTime"`
+		RealStartTime      int64  `json:"realStartTime"`
+		RealEndTime        int64  `json:"realEndTime"`
 		Status             ProcedureStatus
 		ProcedureData      string                  `json:"-"`                  //common.ProductProcedure  json涓�
 		ProceduresInfo     common.ProductProcedure `json:"procedure" gorm:"-"` //common.ProductProcedure  瀵硅薄
@@ -32,11 +34,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
 	}
 )
 
@@ -79,6 +85,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
@@ -94,6 +105,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
@@ -101,6 +117,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
 }
 
@@ -139,6 +160,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{})
 
@@ -166,8 +192,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 {
@@ -207,11 +241,11 @@
 // CreateBatch 鎵归噺鎻掑叆
 func (slf *ProceduresSearch) CreateBatch(records []*Procedures) error {
 	var db = slf.build()
-
-	if err := db.Create(&records).Error; err != nil {
-		return fmt.Errorf("create batch err: %v, records: %+v", err, records)
+	for _, record := range records {
+		if err := db.Create(record).Error; err != nil {
+			return fmt.Errorf("create batch err: %v, records: %+v", err, records)
+		}
 	}
-
 	return nil
 }
 
@@ -301,6 +335,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