From 8426708ecdf4f25656a04d7b182643b27c188157 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期六, 19 八月 2023 11:05:43 +0800
Subject: [PATCH] 增加测试数据
---
nsq/msg_handler.go | 7 +++----
1 files changed, 3 insertions(+), 4 deletions(-)
diff --git a/nsq/msg_handler.go b/nsq/msg_handler.go
index dd692fe..7545fe7 100644
--- a/nsq/msg_handler.go
+++ b/nsq/msg_handler.go
@@ -7,7 +7,6 @@
"apsClient/pkg/logx"
"apsClient/pkg/structx"
"encoding/json"
- "fmt"
"gorm.io/gorm"
)
@@ -19,10 +18,8 @@
}
func (slf *ScheduleTask) HandleMessage(data []byte) (err error) {
- fmt.Println(string(data))
-
+ logx.Infof("get an message :%s", data)
var tasks = make([]*request.DeliverScheduleTask, 0)
-
err = json.Unmarshal(data, &tasks)
if err != nil {
logx.Errorf("ScheduleTask HandleMessage Unmarshal json err: %v", err.Error())
@@ -46,6 +43,8 @@
}
}
procedureRecord := model.Procedures{
+ StartTime: procedure.StartTime,
+ EndTime: procedure.EndTime,
WorkOrderID: task.WorkOrder.WorkOrderID,
OrderID: task.WorkOrder.OrderID,
Status: model.ProcedureStatusUnFinished,
--
Gitblit v1.8.0