From d91a802e7aa2ad4075ed803b8ddc7536a91a0ef0 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 27 十月 2023 20:33:06 +0800
Subject: [PATCH] update

---
 service/task.go |   13 ++++++-------
 1 files changed, 6 insertions(+), 7 deletions(-)

diff --git a/service/task.go b/service/task.go
index fbc355f..ed8b6ea 100644
--- a/service/task.go
+++ b/service/task.go
@@ -137,20 +137,19 @@
 	upMap := map[string]interface{}{"status": status}
 	if status == model.ProcedureStatusProcessing {
 		upMap["process_model_number"] = processModelNumber
+		upMap["real_start_time"] = time.Now().Unix()
 	} else if status == model.ProcedureStatusWaitProcess {
 		upMap["process_model_number"] = ""
+	} else if status == model.ProcedureStatusFinished {
+		upMap["real_end_time"] = time.Now().Unix()
 	}
 
 	return model.NewProceduresSearch(db).SetId(id).UpdateByMap(upMap)
 }
 
-func (slf TaskService) UpdateProcedureStatus(db *gorm.DB, id uint, status model.ProcedureStatus, channel int32) error {
-	if status == model.ProcedureStatusFinished {
-		ProgressCacheUnset(channel)
-	}
-	return model.NewProceduresSearch(db).SetId(id).UpdateByMap(map[string]interface{}{
-		"status": status,
-	})
+func (slf TaskService) UpdateProcessModelNumber(db *gorm.DB, id uint, processModelNumber string) error {
+	upMap := map[string]interface{}{"process_model_number": processModelNumber}
+	return model.NewProceduresSearch(db).SetId(id).UpdateByMap(upMap)
 }
 
 func (slf TaskService) UpdateOrderStatus(db *gorm.DB, id uint, status model.OrderStatus) error {

--
Gitblit v1.8.0