From 2a9be15f941698c8cb52a2b027176e58605b4f08 Mon Sep 17 00:00:00 2001 From: luozukai Date: Wed, 20 Feb 2019 18:32:59 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=AE=A1=E6=89=B9=E6=B5=81][=E6=B7=BB?= =?UTF-8?q?=E5=8A=A0][=E6=B7=BB=E5=8A=A0=E5=90=88=E5=90=8C=E6=8F=90?= =?UTF-8?q?=E5=89=8D=E7=BB=88=E6=AD=A2=E5=AE=A1=E6=89=B9]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/WxFlowServiceImpl.java | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxFlowServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxFlowServiceImpl.java index 49c4f3494..28798c8ec 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxFlowServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxFlowServiceImpl.java @@ -515,17 +515,17 @@ public class WxFlowServiceImpl implements WxFlowService { @Override @Transactional(propagation = Propagation.REQUIRED,rollbackFor = {Exception.class}) public ResultData reject(Map params,Long userId,String userName,String tenantId) { - String taskId = (String)params.get("taskId"); String processInstanceId = (String)params.get("processInstanceId"); String remark = (String)params.get("remark"); - Map mapInfo = taskService.getVariables(taskId); + + Task task = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult(); + Map mapInfo = taskService.getVariables(task.getId()); Long businessId = Long.parseLong((String)mapInfo.get("businessId")); Integer flowType = (Integer)mapInfo.get("flowType"); MallUserInfo starter = (MallUserInfo)mapInfo.get("starter"); String taskName; String taskKey; - Task task = taskService.createTaskQuery().taskId(taskId).singleResult(); if (task == null) { return new ResultData(ErrorCode.FLOW_INST_NOT_EXIST.getCode(), "任务不存在"); } @@ -541,7 +541,7 @@ public class WxFlowServiceImpl implements WxFlowService { //保存wx_flow_record表审批记录 WxFlowRecord wxFlowRecord = new WxFlowRecord(); wxFlowRecord.setBusinessId(businessId); - wxFlowRecord.setTaskId(taskId); + wxFlowRecord.setTaskId(task.getId()); wxFlowRecord.setProcessInstanceId(processInstanceId); wxFlowRecord.setRemark(remark); wxFlowRecord.setUserId(userId); @@ -568,21 +568,19 @@ public class WxFlowServiceImpl implements WxFlowService { return new ResultData(); } - @Override @Transactional(propagation = Propagation.REQUIRED,rollbackFor = {Exception.class}) public ResultData setBack(Map params,Long userId,String userName) { - String taskId = (String)params.get("taskId"); String processInstanceId = (String)params.get("processInstanceId"); String remark = (String)params.get("remark"); - Map mapInfo = taskService.getVariables(taskId); + Task task = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult(); + Map mapInfo = taskService.getVariables(task.getId()); Long businessId = Long.parseLong((String)mapInfo.get("businessId")); Integer flowType = (Integer)mapInfo.get("flowType"); String taskName; String taskKey; - Task task = taskService.createTaskQuery().taskId(taskId).singleResult(); if (task == null) { return new ResultData(ErrorCode.FLOW_INST_NOT_EXIST.getCode(), "任务不存在"); } @@ -598,7 +596,7 @@ public class WxFlowServiceImpl implements WxFlowService { //保存wx_flow_record表审批记录 WxFlowRecord wxFlowRecord = new WxFlowRecord(); wxFlowRecord.setBusinessId(businessId); - wxFlowRecord.setTaskId(taskId); + wxFlowRecord.setTaskId(task.getId()); wxFlowRecord.setProcessInstanceId(processInstanceId); wxFlowRecord.setRemark(remark); wxFlowRecord.setUserId(userId); @@ -610,7 +608,6 @@ public class WxFlowServiceImpl implements WxFlowService { wxFlowRecordService.saveOrUpdate(wxFlowRecord); //修改记录表当前状态 wxFlowRecordMapper.updateCurrStatus(new WxFlowRecord(processInstanceId,EnumFlowRecordStatus.SETBACK.getCode())); - return new ResultData(); }