diff --git a/app/task_worker.py b/app/task_worker.py
index c6f8119..d554352 100644
--- a/app/task_worker.py
+++ b/app/task_worker.py
@@ -572,9 +572,6 @@ def do_add_task(params):
             logging.error(e)
             return json.dumps(make_common_res(2, '台账任务创建成功，但路口列表配时方案状态更新失败，请反馈该情况至管理员！'))
     elif task_type_class == 3:
-        creator_id = check_param(params, 'creator_id')
-        if not creator_id:
-            return json.dumps(make_common_res(2, '需求核验单创建者信息缺失，请检查后重试'))
         task_info = db_task.query_task(taskno, nodeid, area_id)
         creator_name, executor_name = task_info['creatorid'], task_info['executor']
         userids = db_user.query_user_info_by_name([creator_name, executor_name])
@@ -582,6 +579,9 @@ def do_add_task(params):
             require_confirm_info = check_param(params, 'require_confirm_info')
             if not require_confirm_info and full_review != 1:
                 return json.dumps(make_common_res(2, '缺少需求核验单信息，请检查后重试'))
+            creator_id = check_param(params, 'creator_id')
+            if not creator_id:
+                return json.dumps(make_common_res(2, '需求核验单创建者信息缺失，请检查后重试'))
             require_confirm_info = json.loads(require_confirm_info)
             save_require_confirm_ret = db_task.save_task_require_confirm_info(taskno, nodeid, area_id, require_confirm_info, creator_id, operator)
             if not save_require_confirm_ret: