| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | msg := &common.MsgTaskStatusUpdate{ |
|---|
| | | WorkOrderId: record.WorkOrderId, |
|---|
| | | ProcedureID: record.ProcedureID, |
|---|
| | | DeviceId: record.DeviceId, |
|---|
| | | IsProcessing: record.IsProcessing, |
|---|
| | | IsFinish: record.IsFinish, |
|---|
| | | FinishAmount: finishAmount, |
|---|
| | | WorkOrderId: record.WorkOrderId, |
|---|
| | | ProcedureID: record.ProcedureID, |
|---|
| | | DeviceId: record.DeviceId, |
|---|
| | | IsProcessing: record.IsProcessing, |
|---|
| | | IsFinish: record.IsFinish, |
|---|
| | | FinishAmount: finishAmount, |
|---|
| | | ProductProcedureID: record.ProductProcedureID, |
|---|
| | | } |
|---|
| | | caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicTaskProcedureStatusUpdate, conf.Conf.NsqConf.NodeId), "") |
|---|
| | | err = caller.Send(msg) |
|---|
