diff --git a/services/schedule/SchedTask.Ctrl.go b/services/schedule/SchedTask.Ctrl.go index 06005f9..cdfa55e 100644 --- a/services/schedule/SchedTask.Ctrl.go +++ b/services/schedule/SchedTask.Ctrl.go @@ -345,11 +345,27 @@ func (tasksrv *TaskSrv) ReleaseSerialOrder(relQty int, releaseId string) (err er // 写入打印条码的逻辑 snr := new(models.Snrtab) snr.Finr = common.PlantNr - printID, err := snr.GetNextSnrWithSession(session, "Printer") - if err != nil { - innerLog.Error("ReleaseSerialOrder 更新工单工艺详细步骤状态失败, error:"+err.Error()+" serialOrderId:"+serialOrderStatus.SerialOrderId, "release id:"+releaseId) - _ = session.Rollback() - return grmi.NewBusinessError("获取打印条码流水号失败, error:" + err.Error()) + var next bool + var printID string + for !next { + printID, err = snr.GetNextSnrWithSession(session, "Printer") + if err != nil { + innerLog.Error("ReleaseSerialOrder 更新工单工艺详细步骤状态失败, error:"+err.Error()+" serialOrderId:"+serialOrderStatus.SerialOrderId, "release id:"+releaseId) + _ = session.Rollback() + return grmi.NewBusinessError("获取打印条码流水号失败, error:" + err.Error()) + } + existPrintHead, err := printHeadDao.SelectOne(printID) + if err != nil { + innerLog.Error("ReleaseSerialOrder 获取失败, error:"+err.Error()+" serialOrderId:"+serialOrderStatus.SerialOrderId, "release id:"+releaseId) + _ = session.Rollback() + return grmi.NewBusinessError("获取打印条码流水号失败, error:" + err.Error()) + } + if existPrintHead != nil { + continue + } else { + next = true + break + } } article, exist := artMap[serialOrder.ArtId] if !exist {