diff --git a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow/FlowableRest.java b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow/FlowableRest.java index 63faca6404..eb43f7840b 100644 --- a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow/FlowableRest.java +++ b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flow/FlowableRest.java @@ -186,6 +186,11 @@ public class FlowableRest implements FlowableFeign { return rb.setMsg("抄送失败,流程定义不存在!"); } mfq.setModuleName(process.get("NAME_")); + if(processVariables.containsKey("orderNames")){ + mfq.setMsgTitle(processVariables.get("orderNames").toString()); + }else{ + mfq.setMsgTitle(process.get("NAME_")); + } mfq.setMsgTitle(process.get("NAME_")); mfq.setUserSids(userSids.toString()); ResultBean resultBean = messageFeign.pushMessageCC(mfq); diff --git a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskMapper.xml b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskMapper.xml index e392111903..ade8538b75 100644 --- a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskMapper.xml +++ b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskMapper.xml @@ -150,15 +150,18 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" LEFT JOIN ACT_RE_PROCDEF arpd ON ahpi.PROC_DEF_ID_ = arpd.ID_ LEFT JOIN sys_form_link sfl ON ahpi.PROC_INST_ID_ = sfl.procInsId - + AND ahpi.START_TIME_ = ]]> #{startDate} AND ahpi.START_TIME_ #{endDate} + + and (A0.NAME_ = 'orderNames' and A0.TEXT_ LIKE concat('%',#{names},'%') or arpd.NAME_ LIKE concat('%',#{proDefName},'%')) + ) flow GROUP BY flow.PROC_INST_ID_ diff --git a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskService.java b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskService.java index 2b18bb1de4..3ce16a9139 100644 --- a/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskService.java +++ b/anrui-flowable/anrui-flowable-biz/src/main/java/com/yxt/anrui/flowable/biz/flowtask/FlowTaskService.java @@ -500,6 +500,11 @@ public class FlowTaskService extends MybatisBaseService taskList = taskQuery.listPage(p, pageSize); - List taskList = taskQuery.list(); + }*/ + page.setTotal(taskQuery.count()); + int p = (pageNum - 1) * pageSize; + List taskList = taskQuery.listPage(p, pageSize); +// List taskList = taskQuery.list(); List flowList = new ArrayList<>(); for (Task task : taskList) { FlowTaskDto flowTask = new FlowTaskDto(); @@ -578,7 +583,7 @@ public class FlowTaskService extends MybatisBaseService v.getStartUserName().contains(finalStartUserNameParams)).collect(Collectors.toList()); } @@ -588,7 +593,7 @@ public class FlowTaskService extends MybatisBaseService> rb = new ResultBean>(); return rb.success().setData(page); @@ -716,18 +721,19 @@ public class FlowTaskService extends MybatisBaseService> maps = baseMapper.finishedList1(paraMap); int count = baseMapper.finishedListCount(paraMap); List hisTaskList = new ArrayList(); @@ -816,7 +822,7 @@ public class FlowTaskService extends MybatisBaseService v.getStartUserName().contains(finalStartUserNameParams)).collect(Collectors.toList()); } @@ -826,8 +832,8 @@ public class FlowTaskService extends MybatisBaseService> rb = new ResultBean>(); return rb.success().setData(page); @@ -860,14 +866,15 @@ public class FlowTaskService extends MybatisBaseService> maps = baseMapper.finishedList1(paraMap); int count = baseMapper.finishedListCount(paraMap); List hisTaskList = new ArrayList(); @@ -963,7 +970,7 @@ public class FlowTaskService extends MybatisBaseService userHisTaskList = Optional.ofNullable(hisTaskList).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), FlowTaskDto.class)).collect(Collectors.toList()); List namesHisTaskList = Optional.ofNullable(hisTaskList).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), FlowTaskDto.class)).collect(Collectors.toList()); //对hisTaskList进行筛选发起人 - if (StringUtils.isNotBlank(names)) { + /* if (StringUtils.isNotBlank(names)) { String finalStartUserNameParams = names; userHisTaskList = userHisTaskList.stream().filter(v -> v.getStartUserName().contains(finalStartUserNameParams)).collect(Collectors.toList()); namesHisTaskList = namesHisTaskList.stream().filter(v -> v.getProcDefName().contains(finalStartUserNameParams)).collect(Collectors.toList()); @@ -974,9 +981,10 @@ public class FlowTaskService extends MybatisBaseService> rb = new ResultBean>(); return rb.success().setData(page); } @@ -1989,7 +1997,6 @@ public class FlowTaskService extends MybatisBaseService taskList = taskQuery.listPage(p, pageSize);*/ - List taskList = taskQuery.list(); + List taskList = taskQuery.listPage(p, pageSize); +// List taskList = taskQuery.list(); List flowList = new ArrayList<>(); for (Task task : taskList) { FlowTaskDto flowTask = new FlowTaskDto(); @@ -2081,7 +2093,7 @@ public class FlowTaskService extends MybatisBaseService userHisTaskList = Optional.ofNullable(flowList).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), FlowTaskDto.class)).collect(Collectors.toList()); + /*List userHisTaskList = Optional.ofNullable(flowList).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), FlowTaskDto.class)).collect(Collectors.toList()); List namesHisTaskList = Optional.ofNullable(flowList).orElse(new ArrayList<>()).stream().map(m -> JSON.parseObject(JSON.toJSONString(m), FlowTaskDto.class)).collect(Collectors.toList()); if (StringUtils.isNotBlank(names)) { String finalStartUserNameParams = names; @@ -2093,8 +2105,8 @@ public class FlowTaskService extends MybatisBaseService> rb = new ResultBean>(); return rb.success().setData(page); }