| | |
| | | ctx.Fail(code) |
| | | return |
| | | } |
| | | if procedure.Status != model.ProcedureStatusWaitProcess { |
| | | ctx.FailWithMsg(ecode.ParamsErr, "该工序状态不是未开始") |
| | | return |
| | | } |
| | | |
| | | order, err := service.NewTaskService().GetOrderByWorkOrderId(procedure.WorkOrderID) |
| | | if err != nil { |
| | |
| | | return |
| | | } |
| | | |
| | | if procedure.Status == model.ProcedureStatusProcessing { |
| | | ctx.FailWithMsg(ecode.ParamsErr, "该工序已开始生产") |
| | | return |
| | | } |
| | | |
| | | caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicProcessParamsRequest, conf.Conf.NsqConf.NodeId), fmt.Sprintf(constvar.NsqTopicProcessParamsResponse, conf.Conf.NsqConf.NodeId)) |
| | | var result common.ResponseProcessParams |
| | | |