From 066a30751bdc20f9e83b34539de71ae392783e1b Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期六, 19 八月 2023 15:58:09 +0800
Subject: [PATCH] 网络配置获取和删除，品牌增删改查
---
nsq/msg_handler.go | 11 +++++------
1 files changed, 5 insertions(+), 6 deletions(-)
diff --git a/nsq/msg_handler.go b/nsq/msg_handler.go
index dd692fe..9485653 100644
--- a/nsq/msg_handler.go
+++ b/nsq/msg_handler.go
@@ -3,11 +3,10 @@
import (
"apsClient/conf"
"apsClient/model"
- "apsClient/model/request"
+ "apsClient/model/common"
"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))
-
- var tasks = make([]*request.DeliverScheduleTask, 0)
-
+ logx.Infof("get an message :%s", data)
+ var tasks = make([]*common.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