From 0ef4cc755bddd87799b8bfdd65c8123df6e149d0 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期日, 17 八月 2025 23:52:51 +0800
Subject: [PATCH] 锁定流程完成

---
 blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/FlowBusinessService.java |  394 ++++++++++++++++++++++++++++++-------------------------
 1 files changed, 213 insertions(+), 181 deletions(-)

diff --git a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/FlowBusinessService.java b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/FlowBusinessService.java
index edbf158..5b8613e 100644
--- a/blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/FlowBusinessService.java
+++ b/blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/FlowBusinessService.java
@@ -10,17 +10,20 @@
 import org.flowable.engine.history.HistoricProcessInstanceQuery;
 import org.flowable.engine.task.Comment;
 import org.flowable.task.api.Task;
+import org.flowable.task.api.TaskInfoQuery;
 import org.flowable.task.api.TaskQuery;
 import org.flowable.task.api.history.HistoricTaskInstance;
+import org.flowable.task.api.history.HistoricTaskInstanceQuery;
 import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.api.R;
 import org.springblade.core.tool.utils.*;
 
-import org.springblade.mdm.basesetting.machine.MachineService;
+import org.springblade.mdm.flow.constants.FlowContants;
+import org.springblade.mdm.flow.entity.FlowProgramFile;
 import org.springblade.mdm.flow.entity.MdmFlowProcess;
 import org.springblade.mdm.flow.util.MdmFlowCache;
 import org.springblade.mdm.flow.vo.FlowVO;
-import org.springblade.mdm.program.entity.ProcessProgRef;
+import org.springblade.mdm.program.service.NcProgramService;
 import org.springblade.mdm.program.service.ProcessProgRefService;
 import org.springblade.system.feign.IUserClient;
 import org.springblade.system.pojo.entity.User;
@@ -28,11 +31,7 @@
 
 import java.time.LocalDate;
 import java.time.LocalDateTime;
-import java.util.Collections;
-import java.util.Date;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.stream.Collectors;
+import java.util.*;
 
 /**
  * 娴佺▼涓氬姟瀹炵幇绫�
@@ -46,9 +45,7 @@
 	private final TaskService taskService;
 	private final HistoryService historyService;
 	private final IUserClient userClient;
-	private final ProcessProgRefService processProgRefService;
-	private final ApproveRecordService approveRecordService;
-
+	private final FlowProgramFileService flowProgramFileService;
 	/**
 	 * 鏌ヨ鎴戠殑娴佺▼(涓汉寰呭姙鍒楄〃)
 	 * @param page 鍒嗛〉淇℃伅
@@ -65,9 +62,6 @@
 		TaskQuery todoQuery = taskService.createTaskQuery().taskAssignee(userId).active().includeProcessVariables();
 		if (Func.isNotEmpty(createTimeBegin)) {
 			todoQuery.taskCreatedAfter(DateUtil.toDate(createTimeBegin));
-
-			////濡傛灉鏌ヨ瀹炰緥鐨勫紑濮嬫椂闂达細鍙兘鐢ㄤ互涓嬭繖涓紝鍏堟煡鍑哄疄渚媔d鏉�
-			//todoQuery.processInstanceIdIn()
 		}
 		if (Func.isNotEmpty(createTimeEnd)) {
 			todoQuery.taskCreatedBefore(DateUtil.toDate(createTimeEnd));
@@ -82,11 +76,7 @@
 		// 鏋勫缓鍒楄〃鏁版嵁
 		FlowVO bladeFlow = new FlowVO();
 		buildFlowTaskList(bladeFlow, flowList, todoQuery,page.getCurrent(),page.getSize());
-		flowList.forEach(flowVO -> {
-			if(flowVO.getVariables().containsKey("machineCode")){
-				//Machine machinemachineService.getByCode((String)flowVO.getVariables().get("machineCode"))
-			}
-		});
+
 		// 璁$畻鎬绘暟
 		long count = todoQuery.count();
 
@@ -96,161 +86,24 @@
 		page.setRecords(flowList);
 		return page;
 	}
-
-	void addKeywordCondition(TaskQuery todoQuery,String keyword) {
+	//TaskInfoQuery
+	//void addKeywordCondition(TaskQuery todoQuery,String keyword) {
+	void addKeywordCondition(TaskInfoQuery todoQuery, String keyword) {
 		if(Func.isNotEmpty(keyword)) {
+			String likeVal = "%" + keyword + "%";
 			todoQuery.or();
+			todoQuery.processVariableValueLike(FlowContants.TITLE,likeVal);
+			todoQuery.processVariableValueLike(FlowContants.PROCESS_NO, likeVal);
+			todoQuery.processVariableValueLike(FlowContants.MACHINE_CODE, likeVal);
+			todoQuery.processVariableValueLike(FlowContants.MACHINE_MODE, likeVal);
+			todoQuery.processVariableValueLike(FlowContants.PROCESS_NAME, likeVal);
+			todoQuery.processVariableValueLike(FlowContants.PROCESS_EDITION, likeVal);
+			todoQuery.processVariableValueLike(FlowContants.CRAFT_EDITION, likeVal);
 
-			todoQuery.processVariableValueLike("processNo", "%" + keyword + "%");
-			todoQuery.processVariableValueLike("machineCode", "%" + keyword + "%");
-			todoQuery.processVariableValueLike("machineMode", "%" + keyword + "%");
-			todoQuery.processVariableValueLike("processName", "%" + keyword + "%");
-			todoQuery.processVariableValueLike("processEdition", "%" + keyword + "%");
-			todoQuery.processVariableValueLike("craftEdition", "%" + keyword + "%");
-
+			todoQuery.processDefinitionNameLike(likeVal);
 			todoQuery.endOr();
 		}
 	}
-	/*
-	@Override
-	public IPage<BladeFlow> selectSendPage(IPage<BladeFlow> page, BladeFlow bladeFlow) {
-		String taskUser = TaskUtil.getTaskUser();
-		List<BladeFlow> flowList = new LinkedList<>();
-
-		HistoricProcessInstanceQuery historyQuery = historyService.createHistoricProcessInstanceQuery().startedBy(taskUser).orderByProcessInstanceStartTime().desc();
-
-		if (bladeFlow.getCategory() != null) {
-			historyQuery.processDefinitionCategory(bladeFlow.getCategory());
-		}
-		if (bladeFlow.getProcessDefinitionName() != null) {
-			historyQuery.processDefinitionName(bladeFlow.getProcessDefinitionName());
-		}
-		if (bladeFlow.getBeginDate() != null) {
-			historyQuery.startedAfter(bladeFlow.getBeginDate());
-		}
-		if (bladeFlow.getEndDate() != null) {
-			historyQuery.startedBefore(bladeFlow.getEndDate());
-		}
-
-		// 鏌ヨ鍒楄〃
-		List<HistoricProcessInstance> historyList = historyQuery.listPage(Func.toInt((page.getCurrent() - 1) * page.getSize()), Func.toInt(page.getSize()));
-
-		historyList.forEach(historicProcessInstance -> {
-			BladeFlow flow = new BladeFlow();
-			// historicProcessInstance
-			flow.setCreateTime(historicProcessInstance.getStartTime());
-			flow.setEndTime(historicProcessInstance.getEndTime());
-			flow.setVariables(historicProcessInstance.getProcessVariables());
-			String[] businessKey = Func.toStrArray(StringPool.COLON, historicProcessInstance.getBusinessKey());
-			if (businessKey.length > 1) {
-				flow.setBusinessTable(businessKey[0]);
-				flow.setBusinessId(businessKey[1]);
-			}
-			flow.setHistoryActivityName(historicProcessInstance.getName());
-			flow.setProcessInstanceId(historicProcessInstance.getId());
-			flow.setHistoryProcessInstanceId(historicProcessInstance.getId());
-			// ProcessDefinition
-			FlowProcess processDefinition = FlowCache.getProcessDefinition(historicProcessInstance.getProcessDefinitionId());
-			flow.setProcessDefinitionId(processDefinition.getId());
-			flow.setProcessDefinitionName(processDefinition.getName());
-			flow.setProcessDefinitionVersion(processDefinition.getVersion());
-			flow.setProcessDefinitionKey(processDefinition.getKey());
-			flow.setCategory(processDefinition.getCategory());
-			flow.setCategoryName(FlowCache.getCategoryName(processDefinition.getCategory()));
-			flow.setProcessInstanceId(historicProcessInstance.getId());
-			// HistoricTaskInstance
-			List<HistoricTaskInstance> historyTasks = historyService.createHistoricTaskInstanceQuery().processInstanceId(historicProcessInstance.getId()).orderByHistoricTaskInstanceEndTime().desc().list();
-			if (Func.isNotEmpty(historyTasks)) {
-				HistoricTaskInstance historyTask = historyTasks.iterator().next();
-				flow.setTaskId(historyTask.getId());
-				flow.setTaskName(historyTask.getName());
-				flow.setTaskDefinitionKey(historyTask.getTaskDefinitionKey());
-			}
-			// Status
-			if (historicProcessInstance.getEndActivityId() != null) {
-				flow.setProcessIsFinished(FlowEngineConstant.STATUS_FINISHED);
-			} else {
-				flow.setProcessIsFinished(FlowEngineConstant.STATUS_UNFINISHED);
-			}
-			flow.setStatus(FlowEngineConstant.STATUS_FINISH);
-			flowList.add(flow);
-		});
-
-		// 璁$畻鎬绘暟
-		long count = historyQuery.count();
-		// 璁剧疆鎬绘暟
-		page.setTotal(count);
-		page.setRecords(flowList);
-		return page;
-	}
-
-	@Override
-	public IPage<BladeFlow> selectDonePage(IPage<BladeFlow> page, BladeFlow bladeFlow) {
-		String taskUser = TaskUtil.getTaskUser();
-		List<BladeFlow> flowList = new LinkedList<>();
-
-		HistoricTaskInstanceQuery doneQuery = historyService.createHistoricTaskInstanceQuery().taskAssignee(taskUser).finished()
-			.includeProcessVariables().orderByHistoricTaskInstanceEndTime().desc();
-
-		if (bladeFlow.getCategory() != null) {
-			doneQuery.processCategoryIn(Func.toStrList(bladeFlow.getCategory()));
-		}
-		if (bladeFlow.getProcessDefinitionName() != null) {
-			doneQuery.processDefinitionName(bladeFlow.getProcessDefinitionName());
-		}
-		if (bladeFlow.getBeginDate() != null) {
-			doneQuery.taskCompletedAfter(bladeFlow.getBeginDate());
-		}
-		if (bladeFlow.getEndDate() != null) {
-			doneQuery.taskCompletedBefore(bladeFlow.getEndDate());
-		}
-
-		// 鏌ヨ鍒楄〃
-		List<HistoricTaskInstance> doneList = doneQuery.listPage(Func.toInt((page.getCurrent() - 1) * page.getSize()), Func.toInt(page.getSize()));
-		doneList.forEach(historicTaskInstance -> {
-			BladeFlow flow = new BladeFlow();
-			flow.setTaskId(historicTaskInstance.getId());
-			flow.setTaskDefinitionKey(historicTaskInstance.getTaskDefinitionKey());
-			flow.setTaskName(historicTaskInstance.getName());
-			flow.setAssignee(historicTaskInstance.getAssignee());
-			flow.setCreateTime(historicTaskInstance.getCreateTime());
-			flow.setExecutionId(historicTaskInstance.getExecutionId());
-			flow.setHistoryTaskEndTime(historicTaskInstance.getEndTime());
-			flow.setVariables(historicTaskInstance.getProcessVariables());
-
-			FlowProcess processDefinition = FlowCache.getProcessDefinition(historicTaskInstance.getProcessDefinitionId());
-			flow.setProcessDefinitionId(processDefinition.getId());
-			flow.setProcessDefinitionName(processDefinition.getName());
-			flow.setProcessDefinitionKey(processDefinition.getKey());
-			flow.setProcessDefinitionVersion(processDefinition.getVersion());
-			flow.setCategory(processDefinition.getCategory());
-			flow.setCategoryName(FlowCache.getCategoryName(processDefinition.getCategory()));
-
-			flow.setProcessInstanceId(historicTaskInstance.getProcessInstanceId());
-			flow.setHistoryProcessInstanceId(historicTaskInstance.getProcessInstanceId());
-			HistoricProcessInstance historicProcessInstance = getHistoricProcessInstance((historicTaskInstance.getProcessInstanceId()));
-			if (Func.isNotEmpty(historicProcessInstance)) {
-				String[] businessKey = Func.toStrArray(StringPool.COLON, historicProcessInstance.getBusinessKey());
-				flow.setBusinessTable(businessKey[0]);
-				flow.setBusinessId(businessKey[1]);
-				if (historicProcessInstance.getEndActivityId() != null) {
-					flow.setProcessIsFinished(FlowEngineConstant.STATUS_FINISHED);
-				} else {
-					flow.setProcessIsFinished(FlowEngineConstant.STATUS_UNFINISHED);
-				}
-			}
-			flow.setStatus(FlowEngineConstant.STATUS_FINISH);
-			flowList.add(flow);
-		});
-		// 璁$畻鎬绘暟
-		long count = doneQuery.count();
-		// 璁剧疆鎬绘暟
-		page.setTotal(count);
-		page.setRecords(flowList);
-		return page;
-	}
-
-	*/
 	/**
 	 * 鏋勫缓娴佺▼
 	 *
@@ -274,7 +127,7 @@
 
 		//List<Task> tasks = taskQuery.list();
 		long total = taskQuery.count();
-		Long firstResult = (currentPage-1)*pageSize+1;
+		Long firstResult = (currentPage-1)*pageSize;
 		List<Task> tasks = taskQuery.listPage(Func.toInt(firstResult), Func.toInt(pageSize));
 		tasks.forEach(task -> {
 			FlowVO flow = new FlowVO();
@@ -290,8 +143,7 @@
 
 			flow.setProcessDefinitionId(task.getProcessDefinitionId());
 
-			//flow.setProcessDefinitionKey(processDefinition.getKey());
-			//flow.setProcessDefinitionVersion(processDefinition.getVersion());
+			flow.setFile(getFileString(task.getProcessInstanceId()));
 			flow.setProcessInstanceId(task.getProcessInstanceId());
 
 			// 鏌ヨ娴佺▼瀹炰緥鍒涘缓鏃堕棿
@@ -435,10 +287,9 @@
 	 * @param keyword
 	 * @return
 	 */
-	public IPage<FlowVO> selectSearchPage(IPage<FlowVO> page, LocalDate createTimeBegin, LocalDate createTimeEnd,String processDefinitionKey,String keyword) {
+	public IPage<FlowVO> selectSearchPage(IPage<FlowVO> page,String myProcessName,String keyword, LocalDate createTimeBegin, LocalDate createTimeEnd) {
 
 		List<FlowVO> flowList = new LinkedList<>();
-		Date now = new Date();
 		TaskQuery taskQuery = taskService.createTaskQuery().active().includeProcessVariables();
 		if(Func.isNotEmpty(createTimeBegin)) {
 			taskQuery.taskCreatedAfter(DateUtil.toDate(createTimeBegin));
@@ -446,8 +297,8 @@
 		if(Func.isNotEmpty(createTimeEnd)) {
 			taskQuery.taskCreatedBefore(DateUtil.toDate(createTimeEnd.plusDays(1)));
 		}
-		if(Func.isNotEmpty(processDefinitionKey)) {
-			taskQuery.processDefinitionKey(processDefinitionKey);
+		if(Func.isNotEmpty(myProcessName)) {
+			taskQuery.processVariableValueEquals(FlowContants.MY_PROCESS_NAME, myProcessName);
 		}
 
 		addKeywordCondition(taskQuery, keyword);
@@ -474,17 +325,17 @@
 
 	/**
 	 * 宸插畬缁撶殑娴佺▼鍒嗛〉鍒楄〃
-	 * @param page
+	 * @param page 鍒嗛〉淇℃伅
 	 * @param createTimeBegin
 	 * @param createTimeEnd
-	 * @param keyword
+	 * @param keyword 鍏抽敭瀛�
 	 * @return
 	 */
-	public IPage<FlowVO> selectFinishedPage(IPage<FlowVO> page, String processDefinitionKey,LocalDate createTimeBegin, LocalDate createTimeEnd, String keyword) {
-		HistoricProcessInstanceQuery query = this.historyService.createHistoricProcessInstanceQuery().includeProcessVariables();
+	public IPage<FlowVO> selectFinishedPage(IPage<FlowVO> page, String myProcessName, String keyword,LocalDateTime createTimeBegin, LocalDateTime createTimeEnd) {
+		HistoricProcessInstanceQuery query = this.historyService.createHistoricProcessInstanceQuery().finished().includeProcessVariables();
 			//.finished() // 鍙煡璇㈠凡瀹屾垚鐨勬祦绋�.unfinished() // 鏌ヨ鏈畬鎴愮殑娴佺▼
-		if(Func.isNotEmpty(processDefinitionKey)) {
-			query.processDefinitionKey(processDefinitionKey);
+		if(Func.isNotEmpty(myProcessName)) {
+			query.variableValueEquals(FlowContants.MY_PROCESS_NAME, myProcessName);
 		}
 		if(createTimeBegin!=null) {
 			query.startedAfter(DateUtil.toDate(createTimeBegin));
@@ -492,10 +343,25 @@
 		if(createTimeEnd!=null) {
 			query.startedBefore(DateUtil.toDate(createTimeEnd));
 		}
+		if(Func.isNotEmpty(keyword)) {
+			String likeVal = "%" + keyword + "%";
+			query.or();
+			query.variableValueLike(FlowContants.TITLE,likeVal);
+			query.variableValueLike(FlowContants.PROCESS_NO, likeVal);
+			query.variableValueLike(FlowContants.MACHINE_CODE, likeVal);
+			query.variableValueLike(FlowContants.MACHINE_MODE, likeVal);
+			query.variableValueLike(FlowContants.PROCESS_NAME, likeVal);
+			query.variableValueLike(FlowContants.PROCESS_EDITION, likeVal);
+			query.variableValueLike(FlowContants.CRAFT_EDITION, likeVal);
+
+			query.endOr();
+		}
+
+
 		query.orderByProcessInstanceEndTime().desc(); // 鎸夌粨鏉熸椂闂撮檷搴忔帓鍒�
 		page.setTotal(query.count());
 
-		long firstResult = (page.getCurrent()-1) * page.getSize() + 1;
+		long firstResult = (page.getCurrent()-1) * page.getSize();
 		List<HistoricProcessInstance> processes = query
 			.listPage((int)firstResult, (int)page.getSize());
 
@@ -511,6 +377,172 @@
 			vo.setProcessCreateTime(processInstance.getStartTime());
 			vo.setHistoryTaskEndTime(processInstance.getEndTime());
 
+			vo.setFile(getFileString(processInstance.getId()));
+			records.add(vo);
+		}
+
+		page.setRecords(records);
+
+		return page;
+	}
+
+	/**
+	 * 寮傚父娴佺▼
+	 * @param page
+	 * @param myProcessName
+	 * @param keyword
+	 * @param createTimeBegin
+	 * @param createTimeEnd
+	 * @return
+	 */
+	public IPage<FlowVO> selectExceptionPage(IPage<FlowVO> page, String myProcessName, String keyword,LocalDateTime createTimeBegin, LocalDateTime createTimeEnd) {
+		HistoricProcessInstanceQuery query = this.historyService.createHistoricProcessInstanceQuery().finished().includeProcessVariables();
+		//.finished() // 鍙煡璇㈠凡瀹屾垚鐨勬祦绋�.unfinished() // 鏌ヨ鏈畬鎴愮殑娴佺▼
+
+		query.variableValueEquals(FlowContants.EXCEPTION, "1");
+		if(Func.isNotEmpty(myProcessName)) {
+			query.variableValueEquals(FlowContants.MY_PROCESS_NAME, myProcessName);
+		}
+		if(createTimeBegin!=null) {
+			query.startedAfter(DateUtil.toDate(createTimeBegin));
+		}
+		if(createTimeEnd!=null) {
+			query.startedBefore(DateUtil.toDate(createTimeEnd));
+		}
+		if(Func.isNotEmpty(keyword)) {
+			String likeVal = "%" + keyword + "%";
+			query.or();
+			query.variableValueLike(FlowContants.TITLE,likeVal);
+			query.variableValueLike(FlowContants.PROCESS_NO, likeVal);
+			query.variableValueLike(FlowContants.MACHINE_CODE, likeVal);
+			query.variableValueLike(FlowContants.MACHINE_MODE, likeVal);
+			query.variableValueLike(FlowContants.PROCESS_NAME, likeVal);
+			query.variableValueLike(FlowContants.PROCESS_EDITION, likeVal);
+			query.variableValueLike(FlowContants.CRAFT_EDITION, likeVal);
+
+			query.endOr();
+		}
+
+
+		query.orderByProcessInstanceEndTime().desc(); // 鎸夌粨鏉熸椂闂撮檷搴忔帓鍒�
+		page.setTotal(query.count());
+
+		long firstResult = (page.getCurrent()-1) * page.getSize();
+		List<HistoricProcessInstance> processes = query
+			.listPage((int)firstResult, (int)page.getSize());
+
+		List<FlowVO> records = new LinkedList<>();
+
+		for(HistoricProcessInstance processInstance : processes) {
+			FlowVO vo = new FlowVO();
+			vo.setProcessDefinitionKey(processInstance.getProcessDefinitionKey());
+			vo.setProcessInstanceId(processInstance.getId());
+			vo.setProcessDefinitionName(processInstance.getProcessDefinitionName());
+			vo.setVariables(processInstance.getProcessVariables());
+
+			vo.setProcessCreateTime(processInstance.getStartTime());
+			vo.setHistoryTaskEndTime(processInstance.getEndTime());
+
+			vo.setFile(getFileString(processInstance.getId()));
+			records.add(vo);
+		}
+
+		page.setRecords(records);
+
+		return page;
+	}
+	/*
+	鑾峰彇鍒楄〃涓殑鏂囦欢鍚�
+	 */
+	String getFileString(String processInstanceId){
+		String result = "";
+		List<FlowProgramFile> fileList = flowProgramFileService.lambdaQuery().eq(FlowProgramFile::getProcessInstanceId, processInstanceId).list();
+
+		result = String.join(",",fileList.stream().map(FlowProgramFile::getName).toList());
+
+		return result;
+	}
+
+	/**
+	 * 涓汉宸插姙(宸插畬鎴愪换鍔�)
+	 * @param page
+	 * @param processDefinitionKey
+	 * @param createTimeBegin
+	 * @param createTimeEnd
+	 * @param keyword
+	 * @return
+	 */
+	public IPage<FlowVO> selectDonePage(IPage<FlowVO> page, String processDefinitionKey,LocalDateTime createTimeBegin, LocalDateTime createTimeEnd, String keyword) {
+		String userId = "" + AuthUtil.getUserId();
+		HistoricTaskInstanceQuery doneTaskQuery = historyService.createHistoricTaskInstanceQuery().taskAssignee(userId).finished().includeProcessVariables();
+
+		//.finished() // 鍙煡璇㈠凡瀹屾垚鐨勬祦绋�.unfinished() // 鏌ヨ鏈畬鎴愮殑娴佺▼
+		if(Func.isNotEmpty(processDefinitionKey)) {
+			doneTaskQuery.processDefinitionKey(processDefinitionKey);
+		}
+		if(createTimeBegin!=null) {
+			Date after = DateUtil.toDate(createTimeBegin);
+
+			doneTaskQuery.taskCreatedAfter(after);
+
+			//doneTaskQuery.taskCreatedOn(after);
+			//doneTaskQuery.taskInProgressStartTimeAfter(after);
+		}
+		if(createTimeEnd!=null) {
+			Date before = DateUtil.toDate(createTimeEnd);
+
+			doneTaskQuery.taskCreatedBefore(before);
+
+			//doneTaskQuery.taskInProgressStartTimeBefore(before);
+		}
+
+		if (Func.isNotEmpty(keyword)) {
+			addKeywordCondition(doneTaskQuery, keyword);
+		}
+
+		doneTaskQuery.orderByTaskCreateTime().desc(); // 鎸夌粨鏉熸椂闂撮檷搴忔帓鍒�
+		page.setTotal(doneTaskQuery.count());
+
+		long firstResult = (page.getCurrent()-1) * page.getSize();
+
+		List<HistoricTaskInstance> processes = doneTaskQuery
+			.listPage((int)firstResult, (int)page.getSize());
+
+		List<FlowVO> records = new LinkedList<>();
+
+		Map<String,String> startUserMap = new HashMap<>();//浣跨敤userId缂撳瓨鍏跺鍚�
+		for(HistoricTaskInstance hisTask : processes) {
+			FlowVO vo = new FlowVO();
+
+			HistoricProcessInstance processInstance = historyService
+				.createHistoricProcessInstanceQuery()
+				.processInstanceId(hisTask.getProcessInstanceId())
+				.singleResult();
+
+			if(startUserMap.containsKey(processInstance.getStartUserId())) {
+				vo.setStartUserName(startUserMap.get(processInstance.getStartUserId()));
+			}else {
+				R<User> ru = userClient.userInfoById(Long.valueOf(processInstance.getStartUserId()));
+				if (ru.isSuccess()) {
+					vo.setStartUserName(ru.getData().getName());
+					startUserMap.put(processInstance.getStartUserId(),ru.getData().getName());
+				}
+			}
+			vo.setProcessCreateTime(processInstance.getStartTime());
+
+			vo.setProcessInstanceId(hisTask.getProcessInstanceId());
+			vo.setProcessDefinitionName(processInstance.getProcessDefinitionName());
+			vo.setProcessDefinitionKey(processInstance.getProcessDefinitionKey());
+			vo.setTaskName(hisTask.getName());
+			vo.setTaskDefinitionKey(hisTask.getTaskDefinitionKey());
+			vo.setCreateTime(hisTask.getCreateTime());
+			vo.setEndTime(hisTask.getEndTime());
+			vo.setVariables(hisTask.getProcessVariables());
+
+			vo.setProcessCreateTime(processInstance.getStartTime());
+			vo.setHistoryTaskEndTime(hisTask.getEndTime());
+
+			vo.setFile(getFileString(hisTask.getProcessInstanceId()));
 			records.add(vo);
 		}
 

--
Gitblit v1.9.3