From 4171453db37dab28918f63d0a45414d87f1bb7a7 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 30 十一月 2023 10:33:46 +0800
Subject: [PATCH] 工序状态改变增加改变时间
---
service/task.go | 1 +
model/common/common.go | 1 +
crontask/cron_task.go | 1 +
model/task_status_sync.go | 1 +
4 files changed, 4 insertions(+), 0 deletions(-)
diff --git a/crontask/cron_task.go b/crontask/cron_task.go
index eb99b68..ae1ff95 100644
--- a/crontask/cron_task.go
+++ b/crontask/cron_task.go
@@ -130,6 +130,7 @@
IsFinish: record.IsFinish,
FinishAmount: finishAmount,
ProductProcedureID: record.ProductProcedureID,
+ Ts: record.Ts,
}
caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicTaskProcedureStatusUpdate, conf.Conf.NsqConf.NodeId), "")
err = caller.Send(msg)
diff --git a/model/common/common.go b/model/common/common.go
index 985cbe4..7d40584 100644
--- a/model/common/common.go
+++ b/model/common/common.go
@@ -128,6 +128,7 @@
IsFinish bool //鏄惁瀹屾垚
FinishAmount int `json:"finishAmount"` //isFinish = true鏃跺彇宸ュ簭鏈�缁堝姞宸ユ暟浼犱笂鍘�
ProductProcedureID string `json:"productProcedureID"` //浜у搧宸ュ簭id
+ Ts int64 `json:"ts"` //鍙戠敓鏃堕棿
}
// DeviceMsg 涓嬪彂鍒扮粓绔殑璁惧淇℃伅
diff --git a/model/task_status_sync.go b/model/task_status_sync.go
index f9a6c14..e1eead2 100644
--- a/model/task_status_sync.go
+++ b/model/task_status_sync.go
@@ -16,6 +16,7 @@
DeviceId string `json:"deviceId"` //璁惧缂栧彿
IsProcessing bool //鏄惁澶勭悊涓�
IsFinish bool //鏄惁瀹屾垚
+ Ts int64 //鍙戠敓鏃堕棿
}
TaskStatusSyncSearch struct {
diff --git a/service/task.go b/service/task.go
index 7a9eb61..ec9f3f3 100644
--- a/service/task.go
+++ b/service/task.go
@@ -206,6 +206,7 @@
// SaveTaskStatusSync 淇濆瓨浠诲姟鍚屾淇℃伅
func (slf TaskService) SaveTaskStatusSync(db *gorm.DB, record *model.TaskStatusSync) (err error) {
+ record.Ts = time.Now().Unix()
return model.NewTaskStatusSyncSearch(db).Create(record)
}
--
Gitblit v1.8.0