From 50fdb4bc0545136c14b7b1b50c55430e5c8d970a Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 20 十月 2023 17:03:04 +0800
Subject: [PATCH] 删除或改造gorm v1不支持的批量保存方法
---
nsq/msg_handler.go | 9 ---------
model/device_plc.go | 11 -----------
model/production_progress.go | 11 -----------
model/work_order.go | 11 -----------
4 files changed, 0 insertions(+), 42 deletions(-)
diff --git a/model/device_plc.go b/model/device_plc.go
index 9ce9bbc..4136ecb 100644
--- a/model/device_plc.go
+++ b/model/device_plc.go
@@ -109,17 +109,6 @@
return nil
}
-// CreateBatch 鎵归噺鎻掑叆
-func (slf *DevicePlcSearch) CreateBatch(records []*DevicePlc) error {
- var db = slf.build()
-
- if err := db.Create(&records).Error; err != nil {
- return fmt.Errorf("create batch err: %v, records: %+v", err, records)
- }
-
- return nil
-}
-
func (slf *DevicePlcSearch) Save(record *DevicePlc) error {
var db = slf.build()
diff --git a/model/production_progress.go b/model/production_progress.go
index d928936..293a660 100644
--- a/model/production_progress.go
+++ b/model/production_progress.go
@@ -133,17 +133,6 @@
return nil
}
-// CreateBatch 鎵归噺鎻掑叆
-func (slf *ProductionProgressSearch) CreateBatch(records []*ProductionProgress) error {
- var db = slf.build()
-
- if err := db.Create(&records).Error; err != nil {
- return fmt.Errorf("create batch err: %v, records: %+v", err, records)
- }
-
- return nil
-}
-
func (slf *ProductionProgressSearch) Save(record *ProductionProgress) error {
var db = slf.build()
diff --git a/model/work_order.go b/model/work_order.go
index b854461..a6ed58a 100644
--- a/model/work_order.go
+++ b/model/work_order.go
@@ -161,17 +161,6 @@
return nil
}
-// CreateBatch 鎵归噺鎻掑叆
-func (slf *OrderSearch) CreateBatch(records []*Order) error {
- var db = slf.build()
-
- if err := db.Create(&records).Error; err != nil {
- return fmt.Errorf("create batch err: %v, records: %+v", err, records)
- }
-
- return nil
-}
-
func (slf *OrderSearch) Updates(record *Order) error {
var db = slf.build()
diff --git a/nsq/msg_handler.go b/nsq/msg_handler.go
index 6c646e6..15cbf29 100644
--- a/nsq/msg_handler.go
+++ b/nsq/msg_handler.go
@@ -82,31 +82,22 @@
var err error
if oldWorkOrder != nil && oldWorkOrder.WorkOrderID != "" {
if err = model.NewOrderSearch(db).SetId(oldWorkOrder.ID).Updates(&orderRecord); err != nil {
- logx.Errorf(" save task message error err1: %v", err)
return err
}
- logx.Errorf(" save task message error no err1: %v", err)
for _, procedure := range procedureRecords {
err = model.NewProceduresSearch(db).SetWorkOrderId(procedure.WorkOrderID).SetProcedureId(procedure.ProcedureID).Upsert(procedure)
if err != nil {
- logx.Errorf(" save task message error err2: %v", err)
return err
}
}
- logx.Errorf(" save task message error no err2: %v", err)
} else {
if err = model.NewOrderSearch(db).Create(&orderRecord); err != nil {
- logx.Errorf(" save task message error err3: %v", err)
return err
}
- logx.Errorf(" save task message error no err3: %v", err)
if err = model.NewProceduresSearch(db).CreateBatch(procedureRecords); err != nil {
- logx.Errorf(" save task message error err4: %v", err)
return err
}
- logx.Errorf(" save task message error no err4: %v", err)
}
- logx.Errorf(" save task message error no err5: %v", err)
return nil
})
if err != nil {
--
Gitblit v1.8.0