mirror of
https://github.com/hs-web/hsweb-framework.git
synced 2026-06-08 08:54:07 +08:00
Merge remote-tracking branch 'origin/master'
This commit is contained in:
@@ -3,7 +3,7 @@ spring:
|
||||
auto: true
|
||||
proxy-target-class: true
|
||||
datasource:
|
||||
url : jdbc:h2:mem:example
|
||||
url: jdbc:h2:file:F:\working\hsweb-framework\hsweb-system\hsweb-system-workflow\hsweb-system-workflow-flowable\src\main\resources\db\act
|
||||
username : sa
|
||||
password :
|
||||
type: com.alibaba.druid.pool.DruidDataSource
|
||||
@@ -14,6 +14,6 @@ spring:
|
||||
logging:
|
||||
level:
|
||||
org.flowable: debug
|
||||
org.activiti: debug
|
||||
# org.activiti: debug
|
||||
mybatis:
|
||||
dynamic-datasource: false
|
||||
@@ -1,6 +1,8 @@
|
||||
package org.hswebframework.web.workflow.flowable.service;
|
||||
|
||||
import org.activiti.engine.history.HistoricProcessInstance;
|
||||
import org.activiti.engine.impl.pvm.process.ActivityImpl;
|
||||
import org.activiti.engine.impl.task.TaskDefinition;
|
||||
import org.activiti.engine.task.Task;
|
||||
import org.hswebframework.web.workflow.flowable.entity.TaskInfo;
|
||||
|
||||
@@ -27,6 +29,13 @@ public interface BpmTaskService{
|
||||
|
||||
HistoricProcessInstance selectHisProInst(String procInstId);
|
||||
|
||||
/**
|
||||
* 根据taskId获取流程图对应的图元
|
||||
* @param taskId
|
||||
* @return
|
||||
*/
|
||||
ActivityImpl selectActivityImplByTask(String taskId);
|
||||
|
||||
/**
|
||||
* 领取(签收)任务
|
||||
*
|
||||
@@ -81,6 +90,7 @@ public interface BpmTaskService{
|
||||
* @param userId 用户ID
|
||||
*/
|
||||
void setAssignee(String taskId, String userId);
|
||||
|
||||
/**
|
||||
* 结束流程
|
||||
* @param procInstId 流程实例ID
|
||||
|
||||
@@ -1,8 +1,13 @@
|
||||
package org.hswebframework.web.workflow.flowable.service.imp;
|
||||
|
||||
import org.activiti.engine.history.HistoricProcessInstance;
|
||||
import org.activiti.engine.impl.RepositoryServiceImpl;
|
||||
import org.activiti.engine.impl.TaskServiceImpl;
|
||||
import org.activiti.engine.impl.persistence.entity.ExecutionEntity;
|
||||
import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity;
|
||||
import org.activiti.engine.impl.pvm.process.ActivityImpl;
|
||||
import org.activiti.engine.impl.task.TaskDefinition;
|
||||
import org.activiti.engine.repository.ProcessDefinition;
|
||||
import org.activiti.engine.runtime.Execution;
|
||||
import org.activiti.engine.runtime.ProcessInstance;
|
||||
import org.activiti.engine.task.Task;
|
||||
@@ -175,6 +180,20 @@ public class BpmTaskServiceImp extends FlowableAbstract implements BpmTaskServic
|
||||
return historyService.createHistoricProcessInstanceQuery().processInstanceId(procInstId).singleResult();
|
||||
}
|
||||
|
||||
@Override
|
||||
public ActivityImpl selectActivityImplByTask(String taskId) {
|
||||
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
|
||||
ProcessDefinitionEntity entity = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService).getDeployedProcessDefinition(task.getProcessDefinitionId());
|
||||
List<ActivityImpl> activities = entity.getActivities();
|
||||
ActivityImpl activity = null;
|
||||
for(ActivityImpl activity1 : activities){
|
||||
if(activity1.getProperty("name").equals(task.getName())){
|
||||
activity = activity1;
|
||||
}
|
||||
}
|
||||
return activity;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Map<String,Object> getUserTasksByProcDefKey(String procDefKey){
|
||||
String definitionId = repositoryService.createProcessDefinitionQuery().processDefinitionKey(procDefKey).orderByProcessDefinitionVersion().desc().list().get(0).getId();
|
||||
|
||||
@@ -106,6 +106,13 @@ public class ControllerTest extends SimpleWebApplicationTests {
|
||||
System.out.println("当前流程图元");
|
||||
System.out.println(activity);
|
||||
System.out.println("=========>>>");
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
public void task(){
|
||||
List<Task> task = bpmTaskService.selectTaskByProcessId("5");
|
||||
System.out.println(task);
|
||||
}
|
||||
|
||||
@Configuration
|
||||
|
||||
@@ -1,12 +1,19 @@
|
||||
package org.hswebframework.web.workflow.flowable.test;
|
||||
|
||||
import org.activiti.engine.history.HistoricTaskInstance;
|
||||
import org.activiti.engine.impl.pvm.process.ActivityImpl;
|
||||
import org.activiti.engine.repository.ProcessDefinition;
|
||||
import org.activiti.engine.task.Task;
|
||||
import org.hswebframework.web.workflow.flowable.service.BpmActivityService;
|
||||
import org.hswebframework.web.workflow.flowable.utils.FlowableAbstract;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* Created by zhouhao on 2017/7/20.
|
||||
*/
|
||||
@@ -14,10 +21,21 @@ import org.springframework.test.context.junit4.SpringRunner;
|
||||
@SpringBootTest
|
||||
public class ServiceTest extends FlowableAbstract {
|
||||
|
||||
@Autowired
|
||||
BpmActivityService bpmActivityService;
|
||||
|
||||
@Test
|
||||
public void getProcessDefinition(){
|
||||
ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery().processDefinitionKey("test").singleResult();
|
||||
System.out.println(processDefinition);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void getHiTask(){
|
||||
//查出历史信息
|
||||
HistoricTaskInstance historicTaskInstance = historyService.createHistoricTaskInstanceQuery().processInstanceId("5").taskAssignee("admin").singleResult();
|
||||
|
||||
Task task = taskService.createTaskQuery().taskId("123456").singleResult();
|
||||
|
||||
}
|
||||
}
|
||||
@@ -3,7 +3,8 @@ spring:
|
||||
auto: true
|
||||
proxy-target-class: true
|
||||
datasource:
|
||||
url : jdbc:h2:mem:example
|
||||
# url : jdbc:h2:mem:example
|
||||
url: jdbc:h2:file:F:\working\hsweb-framework\hsweb-system\hsweb-system-workflow\hsweb-system-workflow-flowable\src\main\resources\db\act
|
||||
username : sa
|
||||
password :
|
||||
type: com.alibaba.druid.pool.DruidDataSource
|
||||
|
||||
Reference in New Issue
Block a user