| | |
|---|
| | | for _, record := range records { |
|---|
| | | var finishAmount int |
|---|
| | | if record.IsFinish { |
|---|
| | | progress, err := model.NewProductionProgressSearch(nil).SetProcedureId(record.ProcedureID).First() |
|---|
| | | progress, err := model.NewProductionProgressSearch(nil).SetWorkOrderId(record.WorkOrderId).SetProductProcedureId(record.ProductProcedureID).First() |
|---|
| | | if err == nil { |
|---|
| | | finishAmount = int(progress.FinishedQuantity) |
|---|
| | | } |
|---|
| | | } |
|---|
| | | 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, |
|---|
| | | StartTs: record.StartTs, |
|---|
| | | FinishTs: record.FinishTs, |
|---|
| | | } |
|---|
| | | caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicTaskProcedureStatusUpdate, conf.Conf.NsqConf.NodeId), "") |
|---|
| | | err = caller.Send(msg) |
|---|
