From ba442a966e3a0a79182f32110e6849d20c79fb28 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 30 十一月 2023 21:18:26 +0800
Subject: [PATCH] 重构生产进度存储和同步
---
model/procedures.go | 25 +++++++++++++++++--------
1 files changed, 17 insertions(+), 8 deletions(-)
diff --git a/model/procedures.go b/model/procedures.go
index d30f5a9..79e3842 100644
--- a/model/procedures.go
+++ b/model/procedures.go
@@ -7,6 +7,7 @@
"encoding/json"
"fmt"
"github.com/jinzhu/gorm"
+ "strings"
)
type (
@@ -23,6 +24,7 @@
EndTime int64 `json:"endTime"`
RealStartTime int64 `json:"realStartTime"`
RealEndTime int64 `json:"realEndTime"`
+ FinishedQuantity int `gorm:"type:int;" json:"finishedQuantity"`
Status ProcedureStatus
ProcedureData string `json:"-"` //common.ProductProcedure json涓�
ProceduresInfo common.ProductProcedure `json:"procedure" gorm:"-"` //common.ProductProcedure 瀵硅薄
@@ -44,6 +46,7 @@
Channels []int32
Offset int
Limit int
+ Fields []string
}
)
@@ -59,13 +62,15 @@
return "procedures"
}
func (slf *Procedures) AfterFind(db *gorm.DB) error {
- var proceduresInfo common.ProductProcedure
- err := json.Unmarshal([]byte(slf.ProcedureData), &proceduresInfo)
- if err != nil {
- logx.Errorf("AfterFind Unmarshal err: %v", err.Error())
- return err
+ if slf.ProcedureData != "" {
+ var proceduresInfo common.ProductProcedure
+ err := json.Unmarshal([]byte(slf.ProcedureData), &proceduresInfo)
+ if err != nil {
+ logx.Errorf("AfterFind Unmarshal err: %v", err.Error())
+ return err
+ }
+ slf.ProceduresInfo = proceduresInfo
}
- slf.ProceduresInfo = proceduresInfo
return nil
}
@@ -161,8 +166,8 @@
return slf
}
-func (slf *ProceduresSearch) SetChannel(channel int32) *ProceduresSearch {
- slf.Channel = channel
+func (slf *ProceduresSearch) SetFields(fields []string) *ProceduresSearch {
+ slf.Fields = fields
return slf
}
@@ -225,6 +230,10 @@
db = db.Where("channel IN (?)", slf.Channels)
}
+ if len(slf.Fields) > 0 {
+ db = db.Select(strings.Join(slf.Fields, ","))
+ }
+
return db
}
--
Gitblit v1.8.0