From e7d5e1be855743ee472269607c549d0c2f56533f Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 28 九月 2023 17:13:49 +0800
Subject: [PATCH] 根据设备支持的工序返回最新的工艺参数

---
 nsq/msg_handler.go |   11 ++++++++++-
 1 files changed, 10 insertions(+), 1 deletions(-)

diff --git a/nsq/msg_handler.go b/nsq/msg_handler.go
index 7b62157..175f3e7 100644
--- a/nsq/msg_handler.go
+++ b/nsq/msg_handler.go
@@ -219,7 +219,16 @@
 		logx.Infof("unmarshal process params sync err :%s", err)
 		return err
 	}
-	err = model.NewProcessModelSearch().Save(&processModel)
+	err = model.WithTransaction(func(db *gorm.DB) error {
+		err = model.NewProcessModelSearch().SetOrm(db).SetProduct(processModel.Product).SetProcedure(processModel.Procedure).
+			UpdateByMap(map[string]interface{}{"is_new": 0})
+		if err != nil {
+			return err
+		}
+		processModel.IsNew = true
+		return model.NewProcessModelSearch().SetOrm(db).Create(&processModel)
+	})
+
 	if err != nil {
 		logx.Infof("save process params sync err :%s", err)
 		return err

--
Gitblit v1.8.0