Activiti对接业务表实现自定义用户和用户组
声明:Activiti版本5.22.0。 Activiti在初始化时会生成act_id_*系列与用户、用户组相关的表,但在实际业务中,我们系统可能初期并没有接入工作流,后期接入时就涉及到如何将现有业务表中的用户与Activiti进行对接,本文即简单介绍下思路。
1、自定义实现Activiti用户管理接口
自定义类CustomUserEntityManagerFactory实现SessionFactory接口,重写getSessionType和openSession方法,核心代码如下:
import org.activiti.engine.impl.interceptor.Session;
import org.activiti.engine.impl.interceptor.SessionFactory;
import org.activiti.engine.impl.persistence.entity.UserIdentityManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class CustomUserEntityManagerFactory implements SessionFactory{
@Autowired
private CustomUserEntityManager customUserEntityManager;
@Override
public Class<?> getSessionType() {
return UserIdentityManager.class;
}
@Override
public Session openSession() {
return customUserEntityManager;
}
}
其中,类CustomUserEntityManager继承UserEntityManager类:
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import org.activiti.engine.identity.Group;
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 org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Component;
import com.fengunion.scf.data.usermanage.role.service.RoleService;
import com.fengunion.scf.data.usermanage.user.entity.User;
import com.fengunion.scf.data.usermanage.user.service.UserService;
import com.fengunion.scf.data.workflow.common.constant.WorkflowConstants;
import com.fengunion.scf.data.workflow.common.util.ActivitiUserUtil;
@Component
public class CustomUserEntityManager extends UserEntityManager{
@Autowired
@Lazy
private UserService userService;
@Autowired
@Lazy
private RoleService roleService;
@Override
public UserEntity findUserById(String userId) {
User user = getUser(userId);
return ActivitiUserUtil.toActivitiUser(user);
}
@Override
public List<Group> findGroupsByUser(String userId) {
if (userId == null) {
return null;
}
User uparam = new User();
uparam.setPkid(Long.valueOf(userId));
User user = userService.selectOne(uparam);
List<String> list = roleService.fingRoleCodeByUserId(Long.valueOf(userId));
List<Group> gs = ActivitiUserUtil.toActivitiGroups(user.getFkEnterpriseBasicId(),list);
return gs;
}
@Override
public List<org.activiti.engine.identity.User> findUserByQueryCriteria(UserQueryImpl query, Page page) {
User user = getUser(query.getId());
List<org.activiti.engine.identity.User> list = new ArrayList<>();
list.add(ActivitiUserUtil.toActivitiUser(user));
return list;
}
private User getUser(String userId) {
User user = new User();
if(WorkflowConstants.INTERFACE_SYSTEM_ID.equals(userId)) {
user.setPkid(Long.valueOf(WorkflowConstants.INTERFACE_SYSTEM_ID));
user.setNickName(WorkflowConstants.INTERFACE_SYSTEM_NAME);
user.setRealName(WorkflowConstants.INTERFACE_SYSTEM_NAME);
user.setPswd("");
user.setEmail("");
}else {
User prarmUser = new User();
prarmUser.setPkid(Long.valueOf(userId));
user = userService.selectOne(prarmUser);
}
return user;
}
@Override
public long findUserCountByQueryCriteria(UserQueryImpl query) {
throw new RuntimeException("not implement method.");
}
@Override
public IdentityInfoEntity findUserInfoByUserIdAndKey(String userId, String key) {
throw new RuntimeException("not implement method.");
}
@Override
public List<String> findUserInfoKeysByUserIdAndType(String userId, String type) {
throw new RuntimeException("not implement method.");
}
@Override
public List<org.activiti.engine.identity.User> findPotentialStarterUsers(String proceDefId) {
throw new RuntimeException("not implement method.");
}
@Override
public List<org.activiti.engine.identity.User> findUsersByNativeQuery(Map<String, Object> parameterMap,
int firstResult, int maxResults) {
throw new RuntimeException("not implement method.");
}
@Override
public long findUserCountByNativeQuery(Map<String, Object> parameterMap) {
throw new RuntimeException("not implement method.");
}
}
2、自定义实现Activiti用户管理接口
自定义类CustomGroupEntityManagerFactory 实现SessionFactory接口,重写getSessionType和openSession方法,核心代码如下:
import org.activiti.engine.impl.interceptor.Session;
import org.activiti.engine.impl.interceptor.SessionFactory;
import org.activiti.engine.impl.persistence.entity.GroupIdentityManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class CustomGroupEntityManagerFactory implements SessionFactory{
@Autowired
private CustomGroupEntityManager customGroupEntityManager;
@Override
public Class<?> getSessionType() {
return GroupIdentityManager.class;
}
@Override
public Session openSession() {
return customGroupEntityManager;
}
}
其中,CustomGroupEntityManager类如下:
import java.util.List;
import java.util.Map;
import org.activiti.engine.identity.Group;
import org.activiti.engine.impl.GroupQueryImpl;
import org.activiti.engine.impl.Page;
import org.activiti.engine.impl.persistence.entity.GroupEntityManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.stereotype.Component;
import com.fengunion.scf.data.usermanage.role.service.RoleService;
import com.fengunion.scf.data.usermanage.user.entity.User;
import com.fengunion.scf.data.usermanage.user.service.UserService;
import com.fengunion.scf.data.workflow.common.util.ActivitiUserUtil;
@Component
public class CustomGroupEntityManager extends GroupEntityManager{
@Lazy
@Autowired
private RoleService roleService;
@Lazy
@Autowired
private UserService userService;
@Override
public List<Group> findGroupsByUser(String userId) {
if (userId == null){
return null;
}
try {
User uparam = new User();
uparam.setPkid(Long.valueOf(userId));
User user = userService.selectOne(uparam);
List<String> list = roleService.fingRoleCodeByUserId(Long.valueOf(userId));
List<Group> gs = ActivitiUserUtil.toActivitiGroups(user.getFkEnterpriseBasicId(),list);
return gs;
} catch (EmptyResultDataAccessException e) {
return null;
}
}
@Override
public List<Group> findGroupByQueryCriteria(GroupQueryImpl query, Page page) {
throw new RuntimeException("not implement method.");
}
@Override
public long findGroupCountByQueryCriteria(GroupQueryImpl query) {
throw new RuntimeException("not implement method.");
}
@Override
public List<Group> findGroupsByNativeQuery(Map<String, Object> parameterMap, int firstResult, int maxResults) {
throw new RuntimeException("not implement method.");
}
@Override
public long findGroupCountByNativeQuery(Map<String, Object> parameterMap) {
throw new RuntimeException("not implement method.");
}
}
3、在Activiti配置中注册自己定义的用户、用户组管理类,核心代码如下(我这儿以springboot配置方式为例):
...
@Autowired
private CustomUserEntityManagerFactory customUserEntityManagerFactory;
@Autowired
private CustomGroupEntityManagerFactory customGroupEntityManagerFactory;
...
@Override
public void configure(SpringProcessEngineConfiguration processEngineConfiguration) {
...
//自定义用户和组
List<SessionFactory> customSessionFactories = new ArrayList<>();
customSessionFactories.add(customUserEntityManagerFactory);
customSessionFactories.add(customGroupEntityManagerFactory);
processEngineConfiguration.setCustomSessionFactories(customSessionFactories);
...
}
其中ActivitiUserUtil工具类如下:
import java.util.ArrayList;
import java.util.List;
import org.activiti.engine.identity.Group;
import org.activiti.engine.impl.persistence.entity.GroupEntity;
import org.activiti.engine.impl.persistence.entity.UserEntity;
import com.fengunion.scf.data.usermanage.user.entity.User;
public class ActivitiUserUtil {
public static UserEntity toActivitiUser(User bUser){
UserEntity userEntity = new UserEntity();
userEntity.setId(bUser.getPkid().toString());
userEntity.setFirstName(bUser.getNickName());
userEntity.setLastName(bUser.getRealName());
userEntity.setPassword(bUser.getPswd());
userEntity.setEmail(bUser.getEmail());
userEntity.setRevision(1);
return userEntity;
}
public static GroupEntity toActivitiGroup(Long enterpriseBasicId,String code){
GroupEntity groupEntity = new GroupEntity();
groupEntity.setRevision(1);
groupEntity.setType("assignment");
groupEntity.setId(enterpriseBasicId+"_"+code);
return groupEntity;
}
public static List<Group> toActivitiGroups(Long enterpriseBasicId,List<String> roleCodeList){
List<Group> groups = new ArrayList<>();
for (String code : roleCodeList) {
GroupEntity groupEntity = toActivitiGroup(enterpriseBasicId,code);
groups.add(groupEntity);
}
return groups;
}
}
至此,实现自定义用户和用户组就基本实现了。

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
-
上一篇
三次握手和四次挥手(TCP/IP协议)
前言 为了准备这次面试,特意对TCP/IP的工作机制进行一个温顾~ TCP(Transmission Control Protocol)网络传输控制协议,是一种面向连接的、可靠的、基于字节流的传输层通信协议,数据传输前建立连接的工作要经过“三次握手”,数据传输后断开连接的工作要经过“四次挥手”。 工作过程 从图上可以得出6个标志位,分别是: 1)、SYN(synchronous):建立联机; 2)、ACK(acknowledgement):确认; 3)、PSH(push):传输; 4)、FIN(finish):结束; 5)、RST(reset):重置; 6)、URG(urgent):紧急。 三次握手: (1)、第一次握手:Client将标志位SYN置为1,并将该数据包发送给Server,Client进入SYN_SENT状态,等待Server确认; (2)、第二次握手:Server收到数据包后由标志位SYN=1知道Client请求建立连接,Server将标志位SYN和ACK都置为1,并将该数据包发送给Client以确认连接请求,Server进入SYN_RCVD状态; (3)、第三次握...
-
下一篇
Arthas实践--排查Spring Boot应用NoSuchMethodError
前言 有时spring boot应用会遇到java.lang.NoSuchMethodError的问题,下面以具体的demo来说明怎样利用arthas来排查。 Demo: https://github.com/hengyunabc/spring-boot-inside/tree/master/demo-NoSuchMethodError 在应用的main函数里catch住异常,保证进程不退出 很多时候当应用抛出异常后,进程退出了,就比较难排查问题。可以先改下main函数,把异常catch住: public static void main(String[] args) throws IOException { try { SpringApplication.run(DemoNoSuchMethodErrorApplication.class, args); } catch (Throwable e) { e.printStackTrace(); } // block System.in.read(); } Demo启动之后,抛出的异常是: java....
相关文章
文章评论
共有0条评论来说两句吧...