From e853c35455332a4652ec604c650ca82c411c864d Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期六, 13 九月 2025 15:24:46 +0800
Subject: [PATCH] 流程常量位置重构

---
 blade-service/blade-mdm/src/main/java/org/springblade/mdm/flow/service/FlowBusinessService.java |  392 +++++++++++++++++++++++++++++--------------------------
 1 files changed, 205 insertions(+), 187 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 6bdee86..f6e0bf3 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,33 +10,32 @@
 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.flow.constants.FlowContants;
+import org.springblade.mdm.flow.constants.FlowVariableContants;
 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.service.NcProgramService;
-import org.springblade.mdm.program.service.ProcessProgRefService;
 import org.springblade.system.feign.IUserClient;
 import org.springblade.system.pojo.entity.User;
 import org.springframework.stereotype.Service;
 
 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.*;
 
 /**
  * 娴佺▼涓氬姟瀹炵幇绫�
  *
- * @author Chill
+ * @author yangys
  */
 @Service
 @AllArgsConstructor
@@ -45,9 +44,6 @@
 	private final TaskService taskService;
 	private final HistoryService historyService;
 	private final IUserClient userClient;
-	private final ProcessProgRefService processProgRefService;
-	private final ApproveRecordService approveRecordService;
-	private final NcProgramService ncProgramService;
 	private final FlowProgramFileService flowProgramFileService;
 	/**
 	 * 鏌ヨ鎴戠殑娴佺▼(涓汉寰呭姙鍒楄〃)
@@ -65,9 +61,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 +75,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 +85,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(FlowVariableContants.TITLE,likeVal);
+			todoQuery.processVariableValueLike(FlowVariableContants.PROCESS_NO, likeVal);
+			todoQuery.processVariableValueLike(FlowVariableContants.MACHINE_CODE, likeVal);
+			todoQuery.processVariableValueLike(FlowVariableContants.MACHINE_MODE, likeVal);
+			todoQuery.processVariableValueLike(FlowVariableContants.PROCESS_NAME, likeVal);
+			todoQuery.processVariableValueLike(FlowVariableContants.PROCESS_EDITION, likeVal);
+			todoQuery.processVariableValueLike(FlowVariableContants.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;
-	}
-
-	*/
 	/**
 	 * 鏋勫缓娴佺▼
 	 *
@@ -291,8 +143,6 @@
 			flow.setProcessDefinitionId(task.getProcessDefinitionId());
 
 			flow.setFile(getFileString(task.getProcessInstanceId()));
-			//flow.setProcessDefinitionKey(processDefinition.getKey());
-			//flow.setProcessDefinitionVersion(processDefinition.getVersion());
 			flow.setProcessInstanceId(task.getProcessInstanceId());
 
 			// 鏌ヨ娴佺▼瀹炰緥鍒涘缓鏃堕棿
@@ -305,7 +155,6 @@
 			if(ru.isSuccess()) {
 				flow.setStartUserName(ru.getData().getName());
 			}
-			;
 			List<Comment> comments = lastStepComments(task);//taskService.getTaskComments(task.getId());
 			if(!comments.isEmpty()){
 				flow.setComment(comments.get(0).getFullMessage());
@@ -352,15 +201,7 @@
 			return Collections.emptyList();
 		}
 	}
-	/**
-	 * 鑾峰彇鍘嗗彶娴佺▼
-	 *
-	 * @param processInstanceId 娴佺▼瀹炰緥id
-	 * @return HistoricProcessInstance
-	 */
-	private HistoricProcessInstance getHistoricProcessInstance(String processInstanceId) {
-		return historyService.createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).singleResult();
-	}
+
 
 	public IPage<FlowVO> selectAllTaskPage(IPage<FlowVO> page, String keyword) {
 
@@ -436,10 +277,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));
@@ -447,8 +287,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(FlowVariableContants.MY_PROCESS_NAME, myProcessName);
 		}
 
 		addKeywordCondition(taskQuery, keyword);
@@ -481,11 +321,11 @@
 	 * @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(FlowVariableContants.MY_PROCESS_NAME, myProcessName);
 		}
 		if(createTimeBegin!=null) {
 			query.startedAfter(DateUtil.toDate(createTimeBegin));
@@ -493,6 +333,21 @@
 		if(createTimeEnd!=null) {
 			query.startedBefore(DateUtil.toDate(createTimeEnd));
 		}
+		if(Func.isNotEmpty(keyword)) {
+			String likeVal = "%" + keyword + "%";
+			query.or();
+			query.variableValueLike(FlowVariableContants.TITLE,likeVal);
+			query.variableValueLike(FlowVariableContants.PROCESS_NO, likeVal);
+			query.variableValueLike(FlowVariableContants.MACHINE_CODE, likeVal);
+			query.variableValueLike(FlowVariableContants.MACHINE_MODE, likeVal);
+			query.variableValueLike(FlowVariableContants.PROCESS_NAME, likeVal);
+			query.variableValueLike(FlowVariableContants.PROCESS_EDITION, likeVal);
+			query.variableValueLike(FlowVariableContants.CRAFT_EDITION, likeVal);
+
+			query.endOr();
+		}
+
+
 		query.orderByProcessInstanceEndTime().desc(); // 鎸夌粨鏉熸椂闂撮檷搴忔帓鍒�
 		page.setTotal(query.count());
 
@@ -512,6 +367,80 @@
 			vo.setProcessCreateTime(processInstance.getStartTime());
 			vo.setHistoryTaskEndTime(processInstance.getEndTime());
 
+			R<User> ru = userClient.userInfoById(Long.valueOf(processInstance.getStartUserId()));
+			if(ru.isSuccess()) {
+				vo.setStartUserName(ru.getData().getName());
+			}
+
+			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(FlowVariableContants.EXCEPTION, "1");
+		if(Func.isNotEmpty(myProcessName)) {
+			query.variableValueEquals(FlowVariableContants.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(FlowVariableContants.TITLE,likeVal);
+			query.variableValueLike(FlowVariableContants.PROCESS_NO, likeVal);
+			query.variableValueLike(FlowVariableContants.MACHINE_CODE, likeVal);
+			query.variableValueLike(FlowVariableContants.MACHINE_MODE, likeVal);
+			query.variableValueLike(FlowVariableContants.PROCESS_NAME, likeVal);
+			query.variableValueLike(FlowVariableContants.PROCESS_EDITION, likeVal);
+			query.variableValueLike(FlowVariableContants.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());
+			R<User> ru = userClient.userInfoById(Long.valueOf(processInstance.getStartUserId()));
+			if(ru.isSuccess()) {
+				vo.setStartUserName(ru.getData().getName());
+			}
 			vo.setFile(getFileString(processInstance.getId()));
 			records.add(vo);
 		}
@@ -531,4 +460,93 @@
 
 		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);
+		}
+
+		page.setRecords(records);
+
+		return page;
+	}
+
 }

--
Gitblit v1.9.3