From 941666a9e9e48b0e86140d5e7d81983c7457f0d6 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 30 十一月 2023 11:32:11 +0800
Subject: [PATCH] 保存完成消息时查一下开始时间并存储

---
 crontask/cron_task.go |    3 ++-
 1 files changed, 2 insertions(+), 1 deletions(-)

diff --git a/crontask/cron_task.go b/crontask/cron_task.go
index ae1ff95..24ffc22 100644
--- a/crontask/cron_task.go
+++ b/crontask/cron_task.go
@@ -130,7 +130,8 @@
 			IsFinish:           record.IsFinish,
 			FinishAmount:       finishAmount,
 			ProductProcedureID: record.ProductProcedureID,
-			Ts:                 record.Ts,
+			StartTs:            record.StartTs,
+			FinishTs:           record.FinishTs,
 		}
 		caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicTaskProcedureStatusUpdate, conf.Conf.NsqConf.NodeId), "")
 		err = caller.Send(msg)

--
Gitblit v1.8.0