diff --git a/app/workflow/approve.py b/app/workflow/approve.py index 10608e4..688fabf 100644 --- a/app/workflow/approve.py +++ b/app/workflow/approve.py @@ -38,6 +38,10 @@ def create_approve_workflow( if has_supervisor_approve: # 触发中断,等待上级审批恢复中断,拿到审批结果 approve_result = interrupt({}) + # 中断恢复之后进入下一个循环 + else: + # 已经没有上级主管了,退出循环 + break # 退出循环之后,如果审批结果是驳回,则结束审批流程 if not approve_result.get('flag'): @@ -69,6 +73,10 @@ def create_approve_workflow( # 直接找审批人的上级来审批 supervisor_user = await aget_supervisor_user(user_id=user_id, session=session) + print('\n\n', ":::::::::::task_supervisor_approve start::::::::::::", '\n\n') + print(supervisor_user.full_name, user_id, approve_id) + print('\n\n', ":::::::::::task_supervisor_approve end::::::::::::", '\n\n') + if not supervisor_user: return False