|
|
@ -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 { |
|
|
|