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 := 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())
	}
}