|
|
|
|
@ -3,13 +3,17 @@ package org.springblade.plugin.workbench.service.impl; |
|
|
|
|
import lombok.AllArgsConstructor; |
|
|
|
|
import org.flowable.engine.TaskService; |
|
|
|
|
import org.flowable.task.api.Task; |
|
|
|
|
import org.springblade.core.tool.utils.DateUtil; |
|
|
|
|
import org.springblade.core.tool.utils.Func; |
|
|
|
|
import org.springblade.plugin.workbench.service.IWorkBenchService; |
|
|
|
|
import org.springblade.plugin.workflow.core.utils.WfTaskUtil; |
|
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
|
|
import java.util.Date; |
|
|
|
|
import java.util.HashMap; |
|
|
|
|
import java.util.List; |
|
|
|
|
import java.util.Map; |
|
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* @Description |
|
|
|
|
@ -23,11 +27,28 @@ public class WorkBenchServiceImpl implements IWorkBenchService { |
|
|
|
|
private final TaskService taskService; |
|
|
|
|
|
|
|
|
|
public void getTask(){ |
|
|
|
|
//获取正在运行的任务
|
|
|
|
|
List<Task> list = taskService.createTaskQuery().taskTenantId(WfTaskUtil.getTenantId()).list(); |
|
|
|
|
|
|
|
|
|
Map<String,List<Task>> taskRemindMap = new HashMap<>(); |
|
|
|
|
|
|
|
|
|
list.forEach(hi -> { |
|
|
|
|
//筛选出到期的任务
|
|
|
|
|
List<Task> collect = list.stream().filter(ts -> { |
|
|
|
|
Map<String, Object> variableMap = ts.getProcessVariables(); |
|
|
|
|
if(Func.isNotEmpty(variableMap.get("qiwangwanchengshijian")) && Func.isNotBlank(variableMap.get("qiwangwanchengshijian").toString())){ |
|
|
|
|
Date qiwangwanchengshijian = DateUtil.parse(variableMap.get("qiwangwanchengshijian").toString(), "yyyy-MM-dd HH:mm:ss"); |
|
|
|
|
if(DateUtil.between(DateUtil.now(), qiwangwanchengshijian).isNegative()){ |
|
|
|
|
return true; |
|
|
|
|
}else{ |
|
|
|
|
return false; |
|
|
|
|
} |
|
|
|
|
}else{ |
|
|
|
|
return false; |
|
|
|
|
} |
|
|
|
|
}).collect(Collectors.toList()); |
|
|
|
|
|
|
|
|
|
//将到期任务按照
|
|
|
|
|
collect.forEach(cl ->{ |
|
|
|
|
|
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
|