配置Activiti以重用Spring Boot中的现有用户/组数据
我正在使用Spring Boot 1.4.3.RELEASE。 我已经创建了一个简单的MVC应用程序来管理用户和组。 现在，我正在尝试将Activiti 5.21.0集成到我的项目中，并重新使用 Activiti的现有用户/组表。
我已经从Activiti扩展了默认的UserEntityManager和GroupEntityManager类，如下所示：
CustomUserEntityManager.java
import java.util.List; import org.activiti.engine.impl.Page; import org.activiti.engine.impl.UserQueryImpl; import org.activiti.engine.impl.persistence.entity.IdentityInfoEntity; import org.activiti.engine.impl.persistence.entity.UserEntity; import org.activiti.engine.impl.persistence.entity.UserEntityManager; import com.example.spring.dao.UserDao; import com.example.spring.model.User; public class CustomUserEntityManager extends UserEntityManager { private UserDao userDao; public CustomUserEntityManager(UserDao userDao) { this.userDao = userDao; } @Override public UserEntity findUserById(String userId) { User user = userDao.findById(Integer.parseInt(userId)); return userToActivitiUser(user); } @Override public org.activiti.engine.identity.User createNewUser(String userId) { throw new UnsupportedOperationException(); } @Override public void insertUser(org.activiti.engine.identity.User user) { throw new UnsupportedOperationException(); } @Override public void updateUser(org.activiti.engine.identity.User updatedUser) { throw new UnsupportedOperationException(); } @Override public void deleteUser(String userId) { throw new UnsupportedOperationException(); } @Override public List findUserByQueryCriteria(UserQueryImpl query, Page page) { throw new UnsupportedOperationException(); } @Override public long findUserCountByQueryCriteria(UserQueryImpl query) { throw new UnsupportedOperationException(); } @Override public IdentityInfoEntity findUserInfoByUserIdAndKey(String userId, String key) { throw new UnsupportedOperationException(); } @Override public List findUserInfoKeysByUserIdAndType(String userId, String type) { throw new UnsupportedOperationException(); } private UserEntity userToActivitiUser(User user) { UserEntity activitiUser = new UserEntity(); activitiUser.setId(user.getId().toString()); activitiUser.setPassword(user.getPassword()); activitiUser.setFirstName(user.getUsername()); activitiUser.setLastName(user.getLastName()); activitiUser.setEmail(user.getEmail()); return activitiUser; } }
ActivitiGroupEntityManager.java
import java.util.List; import org.activiti.engine.identity.Group; import org.activiti.engine.identity.GroupQuery; import org.activiti.engine.impl.GroupQueryImpl; import org.activiti.engine.impl.Page; import org.activiti.engine.impl.persistence.entity.GroupEntityManager; import com.example.spring.dao.CMSGroupDao; public class CustomGroupEntityManager extends GroupEntityManager { private CMSGroupDao groupDao; public CustomGroupEntityManager(CMSGroupDao groupDao) { this.groupDao = groupDao; } @Override public List findGroupsByUser(String userId) { // TODO add logic return null; } @Override public Group createNewGroup(String groupId) { throw new UnsupportedOperationException(); } @Override public void deleteGroup(String groupId) { throw new UnsupportedOperationException(); } @Override public GroupQuery createNewGroupQuery() { return super.createNewGroupQuery(); } @Override public List findGroupByQueryCriteria(GroupQueryImpl query, Page page) { throw new UnsupportedOperationException(); } @Override public long findGroupCountByQueryCriteria(GroupQueryImpl query) { throw new UnsupportedOperationException(); } }
然后，我添加了我的自定义工厂，如下所示：
CustomUserManagerFactory.java
import org.activiti.engine.impl.interceptor.Session; import org.activiti.engine.impl.interceptor.SessionFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import com.example.spring.dao.UserDao; @Component(value = "customUserManagerFactory") public class CustomUserManagerFactory implements SessionFactory { @Autowired private UserDao userDao; @Override public Class getSessionType() { return CustomUserEntityManager.class; } @Override public Session openSession() { return new CustomUserEntityManager(userDao); } }
CustomGroupManagerFactory.java
import org.activiti.engine.impl.interceptor.Session; import org.activiti.engine.impl.interceptor.SessionFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import com.example.spring.dao.CMSGroupDao; @Component(value = "customGroupManagerFactory") public class CustomGroupManagerFactory implements SessionFactory { @Autowired private CMSGroupDao groupDao; @Override public Class getSessionType() { return CustomGroupEntityManager.class; } @Override public Session openSession() { return new CustomGroupEntityManager(groupDao); } }
最后，我添加了我的ProcessEngine配置bean，如下所示：
ProcessEngineConfig.java
package com.example.spring.configuration; import java.util.ArrayList; import java.util.List; import javax.annotation.Resource; import org.activiti.engine.impl.interceptor.SessionFactory; import org.activiti.spring.SpringProcessEngineConfiguration; import org.activiti.spring.boot.ProcessEngineConfigurationConfigurer; import org.springframework.boot.autoconfigure.AutoConfigureBefore; import org.springframework.context.annotation.Configuration; @Configuration @AutoConfigureBefore(org.springframework.boot.autoconfigure.security.SecurityAutoConfiguration.class) public class ProcessEngineConfig implements ProcessEngineConfigurationConfigurer{ @Resource(name = "customUserManagerFactory") private SessionFactory userManagerFactory; @Resource(name = "customGroupManagerFactory") private SessionFactory groupManagerFactory; public void configure(SpringProcessEngineConfiguration pec) { pec.setDbIdentityUsed(false); List customSessionFactories = new ArrayList(); customSessionFactories.add(userManagerFactory); customSessionFactories.add(groupManagerFactory); if (pec.getCustomSessionFactories() == null){ pec.setCustomSessionFactories(customSessionFactories); } else{ pec.getCustomSessionFactories().addAll(customSessionFactories); } } }
pom.xml的重要部分
UTF-8 UTF-8 1.8 5.21.0 org.activiti activiti-spring-boot-starter-basic ${activiti.version} org.activiti activiti-spring-boot-starter-actuator ${activiti.version} org.springframework.boot spring-boot-starter-data-jpa org.springframework.boot spring-boot-starter-security org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-devtools runtime org.springframework.boot spring-boot-starter-tomcat provided org.springframework.boot spring-boot-starter-test test ....... .......
应用程序正在执行而没有任何运行时错误， 但是当我使用org.activiti.engine.IdentityService.newUser()创建用户时，用户被创建并保存在Activit用户表中并且UnsupportedOperationException()抛出UnsupportedOperationException() ，这意味着自定义配置不起作用。
任何帮助将不胜感激！！
对于CustomGroupManagerFactory，类型应为：
@Override public Class getSessionType() { return GroupIdentityManager.class; }
对于CustomUserManagerFactory，类型应为：
@Override public Class getSessionType() { return UserIdentityManager.class; }
我希望上面的解决方案可以帮助您实现它。