1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
| package test
|
| import (
| "apsClient/conf"
| "apsClient/constvar"
| "apsClient/model/common"
| "apsClient/nsq"
| "apsClient/pkg/logx"
| "apsClient/service"
| "fmt"
| "testing"
| )
|
| func TestTaskStatusUpdate(t *testing.T) {
| Init()
| procedureId := uint(1)
| taskService := service.NewTaskService()
| procedure, _ := taskService.GetProcedureById(procedureId)
| msg := &common.MsgTaskStatusUpdate{
| WorkOrderId: procedure.WorkOrderID,
| ProcedureID: procedure.ProceduresInfo.ProcedureID,
| DeviceId: procedure.ProceduresInfo.DeviceID,
| IsProcessing: false,
| IsFinish: true,
| }
| caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicTaskProcedureStatusUpdate, conf.Conf.NsqConf.NodeId), "")
| err := caller.Send(msg)
| if err != nil {
| logx.Errorf("send task status update msg error:%v", err.Error())
| }
| }
|
|
