增加测试数据

zhangqian

2023-08-19 8426708ecdf4f25656a04d7b182643b27c188157

 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,