FT/foton-wkflow-rest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

合并分支 'dev_20230216' 到 'master'

Browse Source 
Dev 20230216

查看合并请求 laws-foton-slrs/foton-wkflow-rest!39
This commit is contained in:
高嵩
2023-05-11 18:12:28 +08:00
parent ee813a6709 81b05b01fc
commit 053c441a7f
7 changed files with 457 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/ydw/bat/wkflow/business_activiti/dto/TaskCommonQuery.java
+3
View File
@@ -54,4 +54,7 @@ public class TaskCommonQuery {
@ApiModelProperty(value = "流程编号") @ApiModelProperty(value = "流程编号")
private String prcNum; private String prcNum;
@ApiModelProperty(value = "标识")
private Boolean tag = true;
} }
src/main/java/com/ydw/bat/wkflow/business_activiti/task/TodoTaskController.java
+410 -8
View File
@@ -26,27 +26,19 @@ import com.ydw.bat.wkflow.business_main.datas.service.IOaTaskExecService;
import com.ydw.bat.wkflow.business_mq.service.CreateMQService; import com.ydw.bat.wkflow.business_mq.service.CreateMQService;
import com.ydw.bat.wkflow.business_oa.webService.service.WebServiceOAService; import com.ydw.bat.wkflow.business_oa.webService.service.WebServiceOAService;
import com.ydw.bat.wkflow.business_oa.webService.service.impl.WebServiceOAServiceImpl; import com.ydw.bat.wkflow.business_oa.webService.service.impl.WebServiceOAServiceImpl;
import com.ydw.bat.wkflow.business_oa.webService.todoContent.NotifyTodoSendContext;
import com.ydw.bat.wkflow.business_oa.webService.todoResult.NotifyTodoAppResult;
import com.ydw.bat.wkflow.business_wkflow.form.dto.FormSubmitDto; import com.ydw.bat.wkflow.business_wkflow.form.dto.FormSubmitDto;
import com.ydw.bat.wkflow.business_wkflow.form.service.FormValsService; import com.ydw.bat.wkflow.business_wkflow.form.service.FormValsService;
import com.ydw.bat.wkflow.util.SpringContextUtil;
import org.activiti.bpmn.model.BpmnModel;
import org.activiti.bpmn.model.FlowNode;
import org.activiti.engine.*; import org.activiti.engine.*;
import org.activiti.engine.history.*; import org.activiti.engine.history.*;
import org.activiti.engine.repository.ProcessDefinition; import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.runtime.ProcessInstanceQuery; import org.activiti.engine.runtime.ProcessInstanceQuery;
import org.activiti.engine.task.Comment;
import org.activiti.engine.task.NativeTaskQuery; import org.activiti.engine.task.NativeTaskQuery;
import org.activiti.engine.task.Task; import org.activiti.engine.task.Task;
import org.activiti.engine.task.TaskQuery;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Async;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import com.tmsps.fk.common.base.action.BaseAction; import com.tmsps.fk.common.base.action.BaseAction;
@@ -190,6 +182,111 @@ public class TodoTaskController extends BaseAction {
} }
} }
if(taskCommonQuery.getPrcType().equals("buss1") && taskCommonQuery.getTag()){
QueryWrapper<BusProcessName> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("PRC_TYPE",25);
if(StringUtils.isNotBlank(taskCommonQuery.getPrcNum())){
objectQueryWrapper.eq("PRC_NUM",taskCommonQuery.getPrcNum());
}
if(StringUtils.isNotBlank(taskCommonQuery.getPrcName())){
objectQueryWrapper.like("PRC_NAME",taskCommonQuery.getPrcName());
}
int count = iBusProcessNameService.count(objectQueryWrapper);
TaskCommonQuery taskCommonQueryInfo = new TaskCommonQuery();
taskCommonQueryInfo.setPrcType("25");
//标识 如果是技术标准搜索，则无需进入 制修订的方法
taskCommonQueryInfo.setTag(false);
taskCommonQueryInfo.setSize(count);
taskCommonQueryInfo.setTaskName(taskCommonQuery.getTaskName());
taskCommonQueryInfo.setCategory_id(taskCommonQuery.getCategory_id());
taskCommonQueryInfo.setCreatuserId(taskCommonQuery.getCreatuserId());
taskCommonQueryInfo.setCurrent(taskCommonQuery.getCurrent());
taskCommonQueryInfo.setEndTime(taskCommonQuery.getEndTime());
taskCommonQueryInfo.setFinishEndTime(taskCommonQuery.getFinishEndTime());
taskCommonQueryInfo.setFinishStartTime(taskCommonQuery.getFinishStartTime());
taskCommonQueryInfo.setName(taskCommonQuery.getName());
taskCommonQueryInfo.setPrcName(taskCommonQuery.getPrcName());
taskCommonQueryInfo.setPrcNameOrId(taskCommonQuery.getPrcNameOrId());
taskCommonQueryInfo.setPrcNum(taskCommonQuery.getPrcNum());
taskCommonQueryInfo.setPrcState(taskCommonQuery.getPrcState());
taskCommonQueryInfo.setStartTime(taskCommonQuery.getStartTime());
taskCommonQueryInfo.setTaskList(taskCommonQuery.getTaskList());
taskCommonQueryInfo.setUserId(taskCommonQuery.getUserId());
List<BusProcessName> busProcessNames = todoTaskListByUserId(taskCommonQueryInfo);
List<BusProcessName> listName = new ArrayList<>();
if(!todoList.isEmpty()){
for (BusProcessName nameData:todoList){
listName.add(nameData);
}
}
if(!busProcessNames.isEmpty()){
for (BusProcessName nameData : busProcessNames){
if(nameData.getTaskInfo().equals("技术标准起草")){
listName.add(nameData);
}
}
listName.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
todoList.clear();
//page.setCount(pageInfo.getCount()+page.getCount());
for (int i = 0; i <listName.size() ; i++) {
//if(taskCommonQuery.getSize()>i){
todoList.add(listName.get(i));
//}
}
}
}
if(taskCommonQuery.getPrcType().equals("25") && taskCommonQuery.getTag()){
QueryWrapper<BusProcessName> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("PRC_TYPE",25);
if(StringUtils.isNotBlank(taskCommonQuery.getPrcNum())){
objectQueryWrapper.eq("PRC_NUM",taskCommonQuery.getPrcNum());
}
if(StringUtils.isNotBlank(taskCommonQuery.getPrcName())){
objectQueryWrapper.like("PRC_NAME",taskCommonQuery.getPrcName());
}
int count = iBusProcessNameService.count(objectQueryWrapper);
TaskCommonQuery taskCommonQueryInfo = new TaskCommonQuery();
taskCommonQueryInfo.setPrcType("25");
taskCommonQueryInfo.setTag(false);
taskCommonQueryInfo.setSize(count);
taskCommonQueryInfo.setTaskName(taskCommonQuery.getTaskName());
taskCommonQueryInfo.setCategory_id(taskCommonQuery.getCategory_id());
taskCommonQueryInfo.setCreatuserId(taskCommonQuery.getCreatuserId());
taskCommonQueryInfo.setCurrent(taskCommonQuery.getCurrent());
taskCommonQueryInfo.setEndTime(taskCommonQuery.getEndTime());
taskCommonQueryInfo.setFinishEndTime(taskCommonQuery.getFinishEndTime());
taskCommonQueryInfo.setFinishStartTime(taskCommonQuery.getFinishStartTime());
taskCommonQueryInfo.setName(taskCommonQuery.getName());
taskCommonQueryInfo.setPrcName(taskCommonQuery.getPrcName());
taskCommonQueryInfo.setPrcNameOrId(taskCommonQuery.getPrcNameOrId());
taskCommonQueryInfo.setPrcNum(taskCommonQuery.getPrcNum());
taskCommonQueryInfo.setPrcState(taskCommonQuery.getPrcState());
taskCommonQueryInfo.setStartTime(taskCommonQuery.getStartTime());
taskCommonQueryInfo.setTaskList(taskCommonQuery.getTaskList());
taskCommonQueryInfo.setUserId(taskCommonQuery.getUserId());
List<BusProcessName> busProcessNames = todoTaskListByUserId(taskCommonQueryInfo);
List<BusProcessName> listName = new ArrayList<>();
if(!busProcessNames.isEmpty()){
for (BusProcessName nameData : busProcessNames){
if(!nameData.getTaskInfo().equals("技术标准起草")){
listName.add(nameData);
}
}
listName.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
todoList.clear();
//page.setCount(pageInfo.getCount()+page.getCount());
for (int i = 0; i <listName.size() ; i++) {
todoList.add(listName.get(i));
}
}
}
todoList.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
return todoList; return todoList;
} }
@@ -2193,6 +2290,106 @@ public class TodoTaskController extends BaseAction {
page.setPageSize(taskCommonQuery.getSize()); page.setPageSize(taskCommonQuery.getSize());
page.setPageNo(taskCommonQuery.getCurrent()); page.setPageNo(taskCommonQuery.getCurrent());
} }
if(taskCommonQuery.getPrcType().equals("buss1") && taskCommonQuery.getTag()){
QueryWrapper<BusProcessName> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("PRC_TYPE",25);
if(StringUtils.isNotBlank(taskCommonQuery.getPrcNum())){
objectQueryWrapper.eq("PRC_NUM",taskCommonQuery.getPrcNum());
}
if(StringUtils.isNotBlank(taskCommonQuery.getPrcName())){
objectQueryWrapper.like("PRC_NAME",taskCommonQuery.getPrcName());
}
int count = iBusProcessNameService.count(objectQueryWrapper);
TaskCommonQuery taskCommonQueryInfo = new TaskCommonQuery();
taskCommonQueryInfo.setPrcType("25");
taskCommonQueryInfo.setTag(false);
taskCommonQueryInfo.setSize(count);
taskCommonQueryInfo.setTaskName(taskCommonQuery.getTaskName());
taskCommonQueryInfo.setCategory_id(taskCommonQuery.getCategory_id());
taskCommonQueryInfo.setCreatuserId(taskCommonQuery.getCreatuserId());
taskCommonQueryInfo.setCurrent(taskCommonQuery.getCurrent());
taskCommonQueryInfo.setEndTime(taskCommonQuery.getEndTime());
taskCommonQueryInfo.setFinishEndTime(taskCommonQuery.getFinishEndTime());
taskCommonQueryInfo.setFinishStartTime(taskCommonQuery.getFinishStartTime());
taskCommonQueryInfo.setName(taskCommonQuery.getName());
taskCommonQueryInfo.setPrcName(taskCommonQuery.getPrcName());
taskCommonQueryInfo.setPrcNameOrId(taskCommonQuery.getPrcNameOrId());
taskCommonQueryInfo.setPrcNum(taskCommonQuery.getPrcNum());
taskCommonQueryInfo.setPrcState(taskCommonQuery.getPrcState());
taskCommonQueryInfo.setStartTime(taskCommonQuery.getStartTime());
taskCommonQueryInfo.setTaskList(taskCommonQuery.getTaskList());
taskCommonQueryInfo.setUserId(taskCommonQuery.getUserId());
Page pageInfo = IssuedProcess(taskCommonQueryInfo);
List<BusProcessName> listName = new ArrayList<>();
if(!page.getList().isEmpty()){
for (BusProcessName nameData: page.getList()){
listName.add(nameData);
}
}
if(!pageInfo.getList().isEmpty()){
for (BusProcessName nameData : pageInfo.getList()){
if(nameData.getTaskInfo().equals("技术标准起草")){
listName.add(nameData);
}
}
listName.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
page.getList().clear();
page.setCount(Long.valueOf(listName.size()));
for (int i = 0; i <listName.size() ; i++) {
if(page.getPageSize()>i){
page.getList().add(listName.get(i));
}
}
}
}
if(taskCommonQuery.getPrcType().equals("25") && taskCommonQuery.getTag()){
QueryWrapper<BusProcessName> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("PRC_TYPE",25);
if(StringUtils.isNotBlank(taskCommonQuery.getPrcNum())){
objectQueryWrapper.eq("PRC_NUM",taskCommonQuery.getPrcNum());
}
if(StringUtils.isNotBlank(taskCommonQuery.getPrcName())){
objectQueryWrapper.like("PRC_NAME",taskCommonQuery.getPrcName());
}
int count = iBusProcessNameService.count(objectQueryWrapper);
TaskCommonQuery taskCommonQueryInfo = new TaskCommonQuery();
taskCommonQueryInfo.setPrcType("25");
taskCommonQueryInfo.setTag(false);
taskCommonQueryInfo.setSize(count);
taskCommonQueryInfo.setTaskName(taskCommonQuery.getTaskName());
taskCommonQueryInfo.setCategory_id(taskCommonQuery.getCategory_id());
taskCommonQueryInfo.setCreatuserId(taskCommonQuery.getCreatuserId());
taskCommonQueryInfo.setCurrent(taskCommonQuery.getCurrent());
taskCommonQueryInfo.setEndTime(taskCommonQuery.getEndTime());
taskCommonQueryInfo.setFinishEndTime(taskCommonQuery.getFinishEndTime());
taskCommonQueryInfo.setFinishStartTime(taskCommonQuery.getFinishStartTime());
taskCommonQueryInfo.setName(taskCommonQuery.getName());
taskCommonQueryInfo.setPrcName(taskCommonQuery.getPrcName());
taskCommonQueryInfo.setPrcNameOrId(taskCommonQuery.getPrcNameOrId());
taskCommonQueryInfo.setPrcNum(taskCommonQuery.getPrcNum());
taskCommonQueryInfo.setPrcState(taskCommonQuery.getPrcState());
taskCommonQueryInfo.setStartTime(taskCommonQuery.getStartTime());
taskCommonQueryInfo.setTaskList(taskCommonQuery.getTaskList());
taskCommonQueryInfo.setUserId(taskCommonQuery.getUserId());
Page pageInfo = IssuedProcess(taskCommonQueryInfo);
List<BusProcessName> listName = new ArrayList<>();
if(!pageInfo.getList().isEmpty()){
for (BusProcessName nameData : pageInfo.getList()){
if(!nameData.getTaskInfo().equals("技术标准起草")){
listName.add(nameData);
}
}
listName.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
page.getList().clear();
page.setCount(Long.valueOf(listName.size()));
for (int i = 0; i <listName.size() ; i++) {
if(page.getPageSize()>i){
page.getList().add(listName.get(i));
}
}
}
}
page.getList().sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
return page; return page;
} }
@@ -2338,6 +2535,110 @@ public class TodoTaskController extends BaseAction {
page.setPageSize(taskCommonQuery.getSize()); page.setPageSize(taskCommonQuery.getSize());
page.setPageNo(taskCommonQuery.getCurrent()); page.setPageNo(taskCommonQuery.getCurrent());
} }
if(taskCommonQuery.getPrcType().equals("buss1") && taskCommonQuery.getTag()){
QueryWrapper<BusProcessName> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("PRC_TYPE",25);
if(StringUtils.isNotBlank(taskCommonQuery.getPrcNum())){
objectQueryWrapper.eq("PRC_NUM",taskCommonQuery.getPrcNum());
}
if(StringUtils.isNotBlank(taskCommonQuery.getPrcName())){
objectQueryWrapper.like("PRC_NAME",taskCommonQuery.getPrcName());
}
int count = iBusProcessNameService.count(objectQueryWrapper);
TaskCommonQuery taskCommonQueryInfo = new TaskCommonQuery();
taskCommonQueryInfo.setPrcType("25");
taskCommonQueryInfo.setTag(false);
taskCommonQueryInfo.setSize(count);
taskCommonQueryInfo.setTaskName(taskCommonQuery.getTaskName());
taskCommonQueryInfo.setCategory_id(taskCommonQuery.getCategory_id());
taskCommonQueryInfo.setCreatuserId(taskCommonQuery.getCreatuserId());
taskCommonQueryInfo.setCurrent(taskCommonQuery.getCurrent());
taskCommonQueryInfo.setEndTime(taskCommonQuery.getEndTime());
taskCommonQueryInfo.setFinishEndTime(taskCommonQuery.getFinishEndTime());
taskCommonQueryInfo.setFinishStartTime(taskCommonQuery.getFinishStartTime());
taskCommonQueryInfo.setName(taskCommonQuery.getName());
taskCommonQueryInfo.setPrcName(taskCommonQuery.getPrcName());
taskCommonQueryInfo.setPrcNameOrId(taskCommonQuery.getPrcNameOrId());
taskCommonQueryInfo.setPrcNum(taskCommonQuery.getPrcNum());
taskCommonQueryInfo.setPrcState(taskCommonQuery.getPrcState());
taskCommonQueryInfo.setStartTime(taskCommonQuery.getStartTime());
taskCommonQueryInfo.setTaskList(taskCommonQuery.getTaskList());
taskCommonQueryInfo.setUserId(taskCommonQuery.getUserId());
Page pageInfo = doneProcess(taskCommonQueryInfo);
List<BusProcessName> listName = new ArrayList<>();
if(!page.getList().isEmpty()){
for (BusProcessName nameData: page.getList()){
listName.add(nameData);
}
}
if(!pageInfo.getList().isEmpty()){
for (BusProcessName nameData : pageInfo.getList()){
if(nameData.getTaskInfo().equals("技术标准起草")){
listName.add(nameData);
}
}
listName.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
page.getList().clear();
page.setCount(Long.valueOf(listName.size()));
for (int i = 0; i <listName.size() ; i++) {
if(page.getPageSize()>i){
page.getList().add(listName.get(i));
}
}
}
}
if(taskCommonQuery.getPrcType().equals("25") && taskCommonQuery.getTag()){
QueryWrapper<BusProcessName> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("PRC_TYPE",25);
if(StringUtils.isNotBlank(taskCommonQuery.getPrcNum())){
objectQueryWrapper.eq("PRC_NUM",taskCommonQuery.getPrcNum());
}
if(StringUtils.isNotBlank(taskCommonQuery.getPrcName())){
objectQueryWrapper.like("PRC_NAME",taskCommonQuery.getPrcName());
}
int count = iBusProcessNameService.count(objectQueryWrapper);
TaskCommonQuery taskCommonQueryInfo = new TaskCommonQuery();
taskCommonQueryInfo.setPrcType("25");
taskCommonQueryInfo.setTag(false);
taskCommonQueryInfo.setSize(count);
taskCommonQueryInfo.setTaskName(taskCommonQuery.getTaskName());
taskCommonQueryInfo.setCategory_id(taskCommonQuery.getCategory_id());
taskCommonQueryInfo.setCreatuserId(taskCommonQuery.getCreatuserId());
taskCommonQueryInfo.setCurrent(taskCommonQuery.getCurrent());
taskCommonQueryInfo.setEndTime(taskCommonQuery.getEndTime());
taskCommonQueryInfo.setFinishEndTime(taskCommonQuery.getFinishEndTime());
taskCommonQueryInfo.setFinishStartTime(taskCommonQuery.getFinishStartTime());
taskCommonQueryInfo.setName(taskCommonQuery.getName());
taskCommonQueryInfo.setPrcName(taskCommonQuery.getPrcName());
taskCommonQueryInfo.setPrcNameOrId(taskCommonQuery.getPrcNameOrId());
taskCommonQueryInfo.setPrcNum(taskCommonQuery.getPrcNum());
taskCommonQueryInfo.setPrcState(taskCommonQuery.getPrcState());
taskCommonQueryInfo.setStartTime(taskCommonQuery.getStartTime());
taskCommonQueryInfo.setTaskList(taskCommonQuery.getTaskList());
taskCommonQueryInfo.setUserId(taskCommonQuery.getUserId());
Page pageInfo = doneProcess(taskCommonQueryInfo);
List<BusProcessName> listName = new ArrayList<>();
if(!pageInfo.getList().isEmpty()){
for (BusProcessName nameData : pageInfo.getList()){
if(!nameData.getTaskInfo().equals("技术标准起草")){
listName.add(nameData);
}
}
listName.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
page.getList().clear();
page.setCount(Long.valueOf(listName.size()));
for (int i = 0; i <listName.size() ; i++) {
if(page.getPageSize()>i){
page.getList().add(listName.get(i));
}
}
}
}
page.getList().sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
return page; return page;
} }
@@ -2437,6 +2738,107 @@ public class TodoTaskController extends BaseAction {
page.setPageSize(taskCommonQuery.getSize()); page.setPageSize(taskCommonQuery.getSize());
page.setPageNo(taskCommonQuery.getCurrent()); page.setPageNo(taskCommonQuery.getCurrent());
} }
if(taskCommonQuery.getPrcType().equals("buss1") && taskCommonQuery.getTag()){
QueryWrapper<BusProcessName> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("PRC_TYPE",25);
if(StringUtils.isNotBlank(taskCommonQuery.getPrcNum())){
objectQueryWrapper.eq("PRC_NUM",taskCommonQuery.getPrcNum());
}
if(StringUtils.isNotBlank(taskCommonQuery.getPrcName())){
objectQueryWrapper.like("PRC_NAME",taskCommonQuery.getPrcName());
}
int count = iBusProcessNameService.count(objectQueryWrapper);
TaskCommonQuery taskCommonQueryInfo = new TaskCommonQuery();
taskCommonQueryInfo.setPrcType("25");
taskCommonQueryInfo.setTag(false);
taskCommonQueryInfo.setSize(count);
taskCommonQueryInfo.setTaskName(taskCommonQuery.getTaskName());
taskCommonQueryInfo.setCategory_id(taskCommonQuery.getCategory_id());
taskCommonQueryInfo.setCreatuserId(taskCommonQuery.getCreatuserId());
taskCommonQueryInfo.setCurrent(taskCommonQuery.getCurrent());
taskCommonQueryInfo.setEndTime(taskCommonQuery.getEndTime());
taskCommonQueryInfo.setFinishEndTime(taskCommonQuery.getFinishEndTime());
taskCommonQueryInfo.setFinishStartTime(taskCommonQuery.getFinishStartTime());
taskCommonQueryInfo.setName(taskCommonQuery.getName());
taskCommonQueryInfo.setPrcName(taskCommonQuery.getPrcName());
taskCommonQueryInfo.setPrcNameOrId(taskCommonQuery.getPrcNameOrId());
taskCommonQueryInfo.setPrcNum(taskCommonQuery.getPrcNum());
taskCommonQueryInfo.setPrcState(taskCommonQuery.getPrcState());
taskCommonQueryInfo.setStartTime(taskCommonQuery.getStartTime());
taskCommonQueryInfo.setTaskList(taskCommonQuery.getTaskList());
taskCommonQueryInfo.setUserId(taskCommonQuery.getUserId());
Page pageInfo = allProcess(taskCommonQueryInfo);
List<BusProcessName> listName = new ArrayList<>();
if(!page.getList().isEmpty()){
for (BusProcessName nameData: page.getList()){
listName.add(nameData);
}
}
if(!pageInfo.getList().isEmpty()){
for (BusProcessName nameData : pageInfo.getList()){
if(nameData.getTaskInfo().equals("技术标准起草")){
listName.add(nameData);
}
}
listName.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
page.getList().clear();
page.setCount(Long.valueOf(listName.size()));
for (int i = 0; i <listName.size() ; i++) {
if(page.getPageSize()>i){
page.getList().add(listName.get(i));
}
}
}
}
if(taskCommonQuery.getPrcType().equals("25") && taskCommonQuery.getTag()){
QueryWrapper<BusProcessName> objectQueryWrapper = new QueryWrapper<>();
objectQueryWrapper.eq("PRC_TYPE",25);
if(StringUtils.isNotBlank(taskCommonQuery.getPrcNum())){
objectQueryWrapper.eq("PRC_NUM",taskCommonQuery.getPrcNum());
}
if(StringUtils.isNotBlank(taskCommonQuery.getPrcName())){
objectQueryWrapper.like("PRC_NAME",taskCommonQuery.getPrcName());
}
int count = iBusProcessNameService.count(objectQueryWrapper);
TaskCommonQuery taskCommonQueryInfo = new TaskCommonQuery();
taskCommonQueryInfo.setPrcType("25");
taskCommonQueryInfo.setTag(false);
taskCommonQueryInfo.setSize(count);
taskCommonQueryInfo.setTaskName(taskCommonQuery.getTaskName());
taskCommonQueryInfo.setCategory_id(taskCommonQuery.getCategory_id());
taskCommonQueryInfo.setCreatuserId(taskCommonQuery.getCreatuserId());
taskCommonQueryInfo.setCurrent(taskCommonQuery.getCurrent());
taskCommonQueryInfo.setEndTime(taskCommonQuery.getEndTime());
taskCommonQueryInfo.setFinishEndTime(taskCommonQuery.getFinishEndTime());
taskCommonQueryInfo.setFinishStartTime(taskCommonQuery.getFinishStartTime());
taskCommonQueryInfo.setName(taskCommonQuery.getName());
taskCommonQueryInfo.setPrcName(taskCommonQuery.getPrcName());
taskCommonQueryInfo.setPrcNameOrId(taskCommonQuery.getPrcNameOrId());
taskCommonQueryInfo.setPrcNum(taskCommonQuery.getPrcNum());
taskCommonQueryInfo.setPrcState(taskCommonQuery.getPrcState());
taskCommonQueryInfo.setStartTime(taskCommonQuery.getStartTime());
taskCommonQueryInfo.setTaskList(taskCommonQuery.getTaskList());
taskCommonQueryInfo.setUserId(taskCommonQuery.getUserId());
Page pageInfo = allProcess(taskCommonQueryInfo);
List<BusProcessName> listName = new ArrayList<>();
if(!pageInfo.getList().isEmpty()){
for (BusProcessName nameData : pageInfo.getList()){
if(!nameData.getTaskInfo().equals("技术标准起草")){
listName.add(nameData);
}
}
listName.sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
page.getList().clear();
page.setCount(Long.valueOf(listName.size()));
for (int i = 0; i <listName.size() ; i++) {
if(page.getPageSize()>i){
page.getList().add(listName.get(i));
}
}
}
}
page.getList().sort((m1,m2)-> m2.getCreatTime().compareTo(m1.getCreatTime()));
return page; return page;
} }
src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java
+6
View File
@@ -101,5 +101,11 @@ public class BusProcessNewController extends BaseAction {
public List<SarBussionessStandState> getSarBussionStandPageNo(@RequestBody List<SarBussionessStandState> rows) { public List<SarBussionessStandState> getSarBussionStandPageNo(@RequestBody List<SarBussionessStandState> rows) {
return iBusProcessNewService.getSarBussionStandPageNo(rows); return iBusProcessNewService.getSarBussionStandPageNo(rows);
} }
@ApiOperation(value = "福企标制修订计划流程变更 在合并 延期 取消 更名 流程变更 批准则结束")
@GetMapping("/endPrcName")
public String endPrcName(@RequestParam("prcName")String prcName,@RequestParam("esId") String esId) {
return iBusProcessNewService.endPrcName(prcName,esId);
}
} }
src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java
+2
View File
@@ -53,4 +53,6 @@ public interface IBusProcessNewService extends IService<BusProcessNew> {
ResponseMessage<BusProcessNew> updateBusProcessNew(String id, String mags); ResponseMessage<BusProcessNew> updateBusProcessNew(String id, String mags);
List<SarBussionessStandState> getSarBussionStandPageNo(List<SarBussionessStandState> rows); List<SarBussionessStandState> getSarBussionStandPageNo(List<SarBussionessStandState> rows);
String endPrcName(String prcName,String esId);
} }
src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java
+32
View File
@@ -14,9 +14,14 @@ import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessNewMapper;
import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService;
import com.ydw.bat.wkflow.business_oa.webService.service.impl.WebServiceOAServiceImpl; import com.ydw.bat.wkflow.business_oa.webService.service.impl.WebServiceOAServiceImpl;
import com.ydw.bat.wkflow.config.ScheduledJobEsPlan; import com.ydw.bat.wkflow.config.ScheduledJobEsPlan;
import com.ydw.bat.wkflow.util.activiti.DeleteTaskCommond;
import com.ydw.bat.wkflow.util.http.ResponseMessage; import com.ydw.bat.wkflow.util.http.ResponseMessage;
import com.ydw.bat.wkflow.util.http.Result; import com.ydw.bat.wkflow.util.http.Result;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService; import org.activiti.engine.TaskService;
import org.activiti.engine.impl.ProcessEngineImpl;
import org.activiti.engine.runtime.ProcessInstanceQuery;
import org.activiti.engine.task.Task; import org.activiti.engine.task.Task;
import org.activiti.engine.task.TaskQuery; import org.activiti.engine.task.TaskQuery;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
@@ -40,6 +45,9 @@ public class BusProcessNewServiceImpl extends ServiceImpl<BusProcessNewMapper, B
@Autowired @Autowired
private TaskService taskService; private TaskService taskService;
@Autowired
private RuntimeService runtimeService;
@Autowired @Autowired
private WebServiceOAServiceImpl webServiceOAService; private WebServiceOAServiceImpl webServiceOAService;
@Autowired @Autowired
@@ -246,6 +254,30 @@ public class BusProcessNewServiceImpl extends ServiceImpl<BusProcessNewMapper, B
return row; return row;
} }
@Override
public String endPrcName(String prcName,String esId) {
// 获取企标的id
QueryWrapper<BusProcessNew> busProcessNewQueryWrapper = new QueryWrapper<>();
busProcessNewQueryWrapper.eq("PRC_NAME",prcName);
List<BusProcessNew> busProcessNews = baseMapper.selectList(busProcessNewQueryWrapper);
if(!busProcessNews.isEmpty()){
for (BusProcessNew newData:busProcessNews){
//判断是否是同一条企标计划
JSONObject jsonObject = JSON.parseObject(newData.getMesg());
String esIdMesg = jsonObject.getString("esId");
if(StringUtils.isNotBlank(esIdMesg)){
if(esId.equals(esIdMesg)){
//是同一条企标计划 删除当前待办 是否是起草页面
//删除OA待办任务
// taskService.deleteTask(newData.getTaskId());
runtimeService.deleteProcessInstance(newData.getPId(),"原始数据已被更改");
}
}
}
}
return "成功";
}
public void taskInfo(List<BusProcessNew> busProcessNews){ public void taskInfo(List<BusProcessNew> busProcessNews){
} }
src/main/java/com/ydw/bat/wkflow/listener/bussFs/BussFsSub1Before.java
+2 -1
View File
@@ -44,7 +44,8 @@ public class BussFsSub1Before implements TaskListener{
busBean.saveOrUpdate(one1); busBean.saveOrUpdate(one1);
// 发送 oa 待办 设置 跳转页面 router ? 后面流程类型 // 发送 oa 待办 设置 跳转页面 router ? 后面流程类型
one1.setLink("bussFsSub1?prcType=buss3"); //one1.setLink("bussFsSub1?prcType=buss3");
one1.setLink("qbfsStepSub1?prcType=buss3");
one1.setTaskInfo(delegateTask.getName()); one1.setTaskInfo(delegateTask.getName());
oaService.sendTodoMq(one1); oaService.sendTodoMq(one1);
src/main/java/com/ydw/bat/wkflow/listener/bussFs/BussFsSub2Before.java
+2 -1
View File
@@ -41,7 +41,8 @@ public class BussFsSub2Before implements TaskListener{
busBean.saveOrUpdate(one1); busBean.saveOrUpdate(one1);
// 发送 oa 待办 设置 跳转页面 router ? 后面流程类型 // 发送 oa 待办 设置 跳转页面 router ? 后面流程类型
one1.setLink("bussFsSub2?prcType=buss3"); //one1.setLink("bussFsSub2?prcType=buss3");
one1.setLink("qbfsStepSub2?prcType=buss3");
one1.setTaskInfo(delegateTask.getName()); one1.setTaskInfo(delegateTask.getName());
oaService.sendTodoMq(one1); oaService.sendTodoMq(one1);