diff --git a/laws-modules/src/main/java/com/jero/modules/activiti/process/projectassess/service/ProcessProjectAssessService.java b/laws-modules/src/main/java/com/jero/modules/activiti/process/projectassess/service/ProcessProjectAssessService.java
index 528e38fc..33462ce1 100644
--- a/laws-modules/src/main/java/com/jero/modules/activiti/process/projectassess/service/ProcessProjectAssessService.java
+++ b/laws-modules/src/main/java/com/jero/modules/activiti/process/projectassess/service/ProcessProjectAssessService.java
@@ -509,6 +509,17 @@ public class ProcessProjectAssessService extends ServiceImpl<ProcessProjectAsses
         Task task = processDTO.getTask();
         String executionId = task.getExecutionId();
         ProcessProjectAssessVO businessInfoDTO = processInfoVO.getBusinessInfoDTO();
+        String assessmentId = processInfoVO.getBusinessId();
+        //查询模块负责人列表
+        LambdaQueryWrapper<ProcessProjectAssessTermUser> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(ProcessProjectAssessTermUser::getAssessmentId, assessmentId);
+        wrapper.eq(ProcessProjectAssessTermUser::getResponsibleUnitLeader, originUserId);
+        List<ProcessProjectAssessTermUser> projectAssessTermUsers = processProjectAssessTermUserService.list(wrapper);
+        List<String> moduleOwnerList = projectAssessTermUsers.stream()
+                .map(ProcessProjectAssessTermUser::getModuleOwner)
+                .filter(Objects::nonNull)
+                .distinct().collect(Collectors.toList());
+
         List<ProcessProjectAssessTerm> processProjectAssessTermList = businessInfoDTO.getProcessProjectAssessTermList();
         List<ProcessProjectAssessTermUser> allTermUserList = new ArrayList<>();
         for (ProcessProjectAssessTerm processProjectAssessTerm : processProjectAssessTermList) {
@@ -519,25 +530,7 @@ public class ProcessProjectAssessService extends ServiceImpl<ProcessProjectAsses
             allTermUserList.add(termUser);
         }
         processProjectAssessTermUserService.updateBatchById(allTermUserList);
-        String assessmentId = processInfoVO.getBusinessId();
 
-
-        LambdaQueryWrapper<ProcessProjectAssessTermUser> wrapper = new LambdaQueryWrapper<>();
-        wrapper.eq(ProcessProjectAssessTermUser::getAssessmentId, assessmentId);
-        wrapper.eq(ProcessProjectAssessTermUser::getResponsibleUnitLeader, originUserId);
-        List<ProcessProjectAssessTermUser> projectAssessTermUsers = processProjectAssessTermUserService.list(wrapper);
-        List<String> moduleOwnerList = projectAssessTermUsers.stream()
-                .map(ProcessProjectAssessTermUser::getModuleOwner)
-                .filter(Objects::nonNull)
-                .distinct().collect(Collectors.toList());
-        ThreadLocalUtil.put(ProcessProjectAssessCommon.EXECUTION_ID, executionId);
-        // 完成任务
-        String taskId = processDTO.getTaskId();
-        Map<String, Object> variables = new HashMap<>();
-        variables.put(ProcessProjectAssessCommon.PASS, pass);
-        variables.put(ProcessProjectAssessCommon.MODULE_OWNER_LIST, moduleOwnerList);
-        taskService.complete(taskId, variables);
-        ThreadLocalUtil.remove();
         if (!Objects.equals(userId,originUserId)){
             LambdaQueryWrapper<ProcessProjectAssessTermUser> wrapper1 = new LambdaQueryWrapper<>();
             wrapper1.eq(ProcessProjectAssessTermUser::getAssessmentId, businessId);
@@ -551,7 +544,18 @@ public class ProcessProjectAssessService extends ServiceImpl<ProcessProjectAsses
                 updateTermUserList.add(termUser);
             }
             processProjectAssessTermUserService.updateBatchById(updateTermUserList);
+            runtimeService.setVariable(executionId,ProcessProjectAssessCommon.MANAGER_LEADER,userId);
         }
+        // 完成任务
+        String taskId = processDTO.getTaskId();
+        Map<String, Object> variables = new HashMap<>();
+        variables.put(ProcessProjectAssessCommon.PASS, pass);
+        if (!pass){
+            runtimeService.setVariable(executionId,ProcessProjectAssessCommon.MODULE_OWNER_LIST,moduleOwnerList);
+        }
+        ThreadLocalUtil.put(ProcessProjectAssessCommon.EXECUTION_ID, executionId);
+        taskService.complete(taskId, variables);
+        ThreadLocalUtil.remove();
     }
     //模块负责人修改
     private void mkfzrxgApprove(ProcessInfoVO<ProcessProjectAssessVO> processInfoVO, ProcessDTO processDTO, boolean pass) {