feat: validate_dag增加传入参数2

This commit is contained in:
caoqianming 2025-12-09 09:41:53 +08:00
parent 77c7811476
commit 18c66eee7a
2 changed files with 4 additions and 4 deletions

View File

@ -476,7 +476,7 @@ class Route(CommonADModel):
return rqs return rqs
@classmethod @classmethod
def validate_dag(cls, final_material_out:Material, rqs, check_input=True): def validate_dag(cls, final_material_out:Material, rqs, check_final=True):
""" """
TN:校验工艺路线是否正确 TN:校验工艺路线是否正确
- 所有 Route 必须有 material_in material_out - 所有 Route 必须有 material_in material_out
@ -507,7 +507,7 @@ class Route(CommonADModel):
# 3. 检查final_material_out是否是终点 # 3. 检查final_material_out是否是终点
final_id = final_material_out.id final_id = final_material_out.id
if check_input and final_id in reverse_graph: if check_final and final_id in reverse_graph:
# raise ParseError( # raise ParseError(
# f"最终物料 {final_material_out.name}(ID:{final_id}) 不能作为任何Route的输入" # f"最终物料 {final_material_out.name}(ID:{final_id}) 不能作为任何Route的输入"
# ) # )
@ -527,7 +527,7 @@ class Route(CommonADModel):
# 5. 检查未到达的物料 # 5. 检查未到达的物料
unreachable_ids = all_material_ids - visited unreachable_ids = all_material_ids - visited
if unreachable_ids: if check_final and unreachable_ids:
# unreachable_materials = Material.objects.filter(id__in=unreachable_ids).values_list('name', flat=True) # unreachable_materials = Material.objects.filter(id__in=unreachable_ids).values_list('name', flat=True)
# raise ParseError( # raise ParseError(
# f"以下物料无法到达最终物料: {list(unreachable_materials)}" # f"以下物料无法到达最终物料: {list(unreachable_materials)}"

View File

@ -218,7 +218,7 @@ class PmService:
rqs = Route.get_routes(material=product) rqs = Route.get_routes(material=product)
if not rqs.exists(): if not rqs.exists():
raise ParseError('未配置工艺路线') raise ParseError('未配置工艺路线')
Route.validate_dag(product, rqs, check_input=False) Route.validate_dag(product, rqs, check_final=False)