Spring Boot与Activiti集成实战

为什么80%的码农都做不了架构师？>>>

Spring Boot基于Spring和“习惯由于配置”原则，实现快速搭建项目的准生产框架。建议现在的Java从业者快速迁移到以Spring Boot为基础开发，这将大大降低开发的难度和极大的提高开发效率。

项目搭建

pom.xml

<?xml version="1.0" encoding="UTF-8"?>

<projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<groupId>com.wisely</groupId>

<artifactId>activiti</artifactId>

<version>0.0.1-SNAPSHOT</version>

<name>activiti</name>

<description>Demo project for Spring Boot</description>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-parent</artifactId>

<version>1.3.0.RELEASE</version>

</parent>

<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

<java.version>1.8</java.version>

<activiti.version>5.21.0</activiti.version>

</properties>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-data-jpa</artifactId>

</dependency>

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId>

</dependency>

<groupId>org.activiti</groupId>

<artifactId>activiti-spring-boot-starter-basic</artifactId>

<version>${activiti.version}</version>

</dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-test</artifactId>

</dependency>

</dependencies>

<build>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-maven-plugin</artifactId>

</plugin>

</plugins>

</build>

</project>

application.properties配置

spring.jpa.hibernate.ddl-auto=update

spring.jpa.database=MYSQL

spring.datasource.url=jdbc:mysql://192.168.1.68:3306/activiti-spring-boot?characterEncoding=UTF-8

spring.datasource.username=root

spring.datasource.password=密码

spring.datasource.driver-class-name=com.mysql.jdbc.Driver

实体类

@Entity

publicclass Person {

@Id

@GeneratedValue

private Long personId;

private String personName;

@ManyToOne(targetEntity = Comp.class)

private Comp comp;

publicPerson(){

}

publicPerson(String personName){

super();

this.personName = personName;

}

//省略getter、setter方法

}

@Entity

publicclass Comp {

@Id

@GeneratedValue

private Long compId;

private

String compName;

@OneToMany(mappedBy = "comp",targetEntity = Person.class)

private List<Person> people;

public Comp(String compName)

{this.compName = compName;}

publicComp(){

}

//省略getter、setter方法

}

DAO

public interface PersonRepository extends JpaRepository<Person, Long> {

public Person findByPersonName(String personName);

}

public interface CompRepository extends JpaRepository<Comp, Long>{

}

Activiti服务

@Service
@Transactional
public class ActivitiService {
//注入为我们自动配置好的服务
@Autowired
private RuntimeService runtimeService;
@Autowired
private TaskService taskService;
//开始流程，传入申请者的id以及公司的id
public voidstartProcess( Long personId, Long compId){
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("personId", personId);
variables.put("compId", compId);
runtimeService.startProcessInstanceByKey("joinProcess", variables);
}
//获得某个人的任务别表
public List<Task> getTasks(String assignee){
return taskService.createTaskQuery().taskCandidateUser(assignee).list();
}
//完成任务
publicvoidcompleteTasks(Boolean joinApproved, String taskId){
Map<String, Object> taskVariables = new HashMap<String, Object>();
taskVariables.put("joinApproved", joinApproved);
taskService.complete(taskId, taskVariables);
}
}

Service Task服务

@Service
public class JoinService {
@Autowired
PersonRepository personRepository;
@Autowired
private CompRepository compRepository;
//加入公司操作，可从DelegateExecution获取流程中的变量
public void joinGroup(DelegateExecution execution){
Boolean bool = (Boolean) execution.getVariable("joinApproved");
if(bool){
Long personId = (Long) execution.getVariable("personId");
Long compId = (Long) execution.getVariable("compId");
Comp comp = compRepository.findOne(compId);
Person person = personRepository.findOne(personId);
person.setComp(comp);
personRepository.save(person);
System.out.println("加入组织成功");
}else{
System.out.println("加入组织失败");
}
}
//获取符合条件的审批人，演示这里写死，使用应用使用实际代码
public List<String> findUsers(DelegateExecution execution){
return Arrays.asList("admin","wtr");
}
}

控制器

@RestController
publicclass MyRestController {
@Autowired
private ActivitiService myService;
//开启流程实例
@RequestMapping(value="/process/{personId}/{compId}", method= RequestMethod.GET)
publicvoidstartProcessInstance(@PathVariable Long personId,@PathVariable Long compId){
myService.startProcess(personId,compId);
}
//获取当前人的任务
@RequestMapping(value="/tasks", method= RequestMethod.GET)
public List<TaskRepresentation> getTasks(@RequestParamString assignee){
List<Task> tasks = myService.getTasks(assignee);
List<TaskRepresentation> dtos = new ArrayList<TaskRepresentation>();
for(Task task : tasks){
dtos.add(newTaskRepresentation(task.getId(), task.getName()));
}
return dtos;
}
//完成任务
@RequestMapping(value="/complete/{joinApproved}/{taskId}", method= RequestMethod.GET)
publicStringcomplete(@PathVariable Boolean joinApproved,@PathVariableString taskId){
myService.completeTasks(joinApproved,taskId);
return"ok";
}
//Task的dto
staticclass TaskRepresentation {
privateString id;
privateString name;
publicTaskRepresentation(String id, String name){
this.id = id;
this.name = name;
}
publicStringgetId(){
return id;
}
publicvoidsetId(String id){
this.id = id;
}
publicStringgetName(){
return name;
}
publicvoidsetName(String name){
this.name = name;
}
}
}

入口类

@SpringBootApplication
publicclass ActivitiApplication {
@Autowired
private PersonRepository personRepository;
@Autowired
private CompRepository compRepository;
publicstaticvoidmain(String[] args){
SpringApplication.run(ActivitiApplication.class, args);
}
//初始化模拟数据
@Bean
public CommandLineRunner init(final ActivitiService myService){
returnnewCommandLineRunner(){
publicvoidrun(String... strings)throws Exception {
if(personRepository.findAll().size() == 0){
personRepository.save(newPerson("wtr"));
personRepository.save(newPerson("wyf"));
personRepository.save(newPerson("admin"));
}
if(compRepository.findAll().size() == 0){
Comp group = newComp("great company");
compRepository.save(group);
Person admin = personRepository.findByPersonName("admin");
Person wtr = personRepository.findByPersonName("wtr");
admin.setComp(group);wtr.setComp(group);
personRepository.save(admin);personRepository.save(wtr);
}
}
};
}
}

例子用的是jpa作为数据DAO层，实际开发中用hibernate或者jdbc或者mybatis于此集成大同小异，自己可以根据实际情况进行调整

转载于:https://my.oschina.net/VILLE/blog/792756