Flowable工作流详细使用介绍+配置详解

你的名字 2023-01-20 10:00 433阅读 0赞

flowbale工作流各个表和字段的介绍:[https://www.cnblogs.com/phyger/p/14067201.html][https_www.cnblogs.com_phyger_p_14067201.html]

运行官方demo:[https://blog.csdn.net/u013972652/article/details/109990809][https_blog.csdn.net_u013972652_article_details_109990809]

flowable使用流程:

1.首先画流程图,给流程图绑定流程变量;

2.部署流程图,产生流程定义.

3.开启流程实例

流程部署之后:act\_re\_deployment记录数+1;act\_re\_procdef记录数+1;

act\_ru\_actinst:运行中的节点信息表,开启流程实例后,生成流程实例id,把模型的各个节点往里边插入值.

ac\_ru\_identitylink开启流程实例后,该流程实例的所有的参与人放到此表中.

act\_ru\_variable 开启一个流程实例后,往里边插入运行中变量的id,根据流程实例查询出开启流程实例put进去的变量,随着流程的递进增加或减少,流程完毕,流程实例下变量清空,进入到了历史表中.

act\_ru\_execution 每一个用户节点都是一个执行的实例.但是数据根流程实例.随着流程的递进,流程完毕,进入到历史表中

act\_ru\_task 开启流程实例后,当前要处理的人物存储在这个表中.随着节点的递进,流程实例下的记录不断改变

act\_hi\_varinst存放所有的历史变量

act\_hi\_taskinst存放所有的用户任务

act\_hi\_procinst存放单个流程实例

act\_hi\_comment存放用户操作的信息,包括审批信息,附言信息等.

act\_hi\_actinst存放所有的节点信息

流程图绑定变量\#\{deptManager\} 跳过表达式$\{deptManager==''\}

下边是配置代码:flowable的maven子模块

若依后台框架整合flowable的配置
    flowable的maven包下的config配置
    
    ＠Configuration
    @ComponentScan(value={"org.flowable.ui.modeler.rest.app"},excludeFilters={
    	@ComponentScan.Filter(type=FilterType.ASSIGNABLE_TYPE,value=DatabaseConfiguration.class),
    	@ComponentScan.Filter(type=FilterType.ASSIGNABLE_TYPE,value=StencilSetResource.class),
    	@ComponentScan.Filter(type=FilterType.ASSIGNABLE_TYPE,value=EditorUsersResource.class),
    	@ComponentScan.Filter(type=FilterType.ASSIGNABLE_TYPE,value=EditorGroupsResource.class),
    })
    @EnableAsync
    public class AppDispatcherServletConfiguration　implements WebMvcRegistrations{
    	private static final LOGGER　＝　ＬoggerFactory.getLogger(AppDispatcherServletConfiguration.class);
    	@Bean
    	public SessionLocaleResolver localeResolver(){
    		return new SessionLocaleResolver();
    	}
    	@Bean
    	public LocaleChangeInterceptor LocaleChangeInterceptor(){
    		LOGGER.debug("Configution localeChangeInterceptor");
    		LocaleChangeInterceptor localeChangeInterceptor = new LocaleChangeInterceptor();
    		localeChangeInterceptor.setParamName("language");
    		return localeChangeInterceptor;
    	}
    
    	@SuppressWarnings("deprecation")
    	@Override
    	public RequestMappingHandlerMapping getRequestMappingHandlerMapping(){
    		RequestMappingHandlerMapping requestMappingHandlerMapping = new RequestMappingHandlerMapping();
    		requestMappingHandlerMapping.setUseSuffixPatternMatch(false);
    		requestMappingHandlerMapping.setRemoveSemicolonContext(false);
    		Object [] interceptors = {localeChangeInterceptor()};
    		requestMappingHandlerMapping.setInterceptros(interceptors);
    		return requestMappingHandlerMapping;
    	}
    }
    
    @Configuration
    @EnableConfigurationProperities({FlowableModelerAppProperties.class})
    @ComponentScan(basePackages={
    	"org.flowable.ui.modeler.repository",
    	"org.flowable.ui.modeler.service",
    	"org.flowable.ui.common.service",
    	"org.flowable.ui.common.repository",
    	"org.flowable.ui.comon.tenant"
    },execludeFilters={
    	@ComponentScan.Filter(type=FilterType.ASSIGNABLE_TYPE,value=RemoteIdmService.class)
    })
    public class ApplicationConfiguration{
    	@SuppressWarnings({"rawtypes","unchecked"})
    	@Bean
    	public ServletRegistrationBean apiServlet(ApplicationContext applicationContext){
    		AnnotationConfigWebApplicationContext dispatcherServletConfiguration = new AnnotationConfigWebApplicationContext();
    		AnnotationConfigWebApplicationContext.setParent(applicationContext);
    		AnnotationConfigWebApplicationContext.register(ApiDispatcherServletConfiguration.class);
    		DispatcherServlet servlet = new DispatcherServlet(dispatcherServletConfiguration)
    		ServletRegistrationBean registrationBean = new ServletRegistrationBean(servlet,"/api/*");
    		registrationBean.setName("Flowable IDM App API Servlet");
    		registrationBean.setLoadOnStartup(1);
    		registrationBean.setAsyncSupoorted(true);
    		return registrationBean;
    	}
    
    	@Bean
    	public HttpFirewall allowUrlEncodedSlashHttpFirewall(){
    		StricHttpFirewall firewall = new StrictHttpFirewall();
    		firewall.setAllowUrlEncodeSlash(true);
    		return firewall;
    	}
    }
    
    
    @Configutation
    public class DatabaseLiquiAutoConfiguration{
    	private static final Logger LOGGER = LoggerFactory.getLogger(DatabaseLiquiAutoConfigutation.class);
    
    	protect static fianl String LIQUIBASE_CHANGELOG_PREFIX = "ACT_DE_";
    
    	@Bean
    	public Liquibase liquibase(DataSource dataSource){
    		LOGGER.info("configuring Liquibase");
    		Liquibase liquibase = null;
    		try{
    			DatabaseConnection connection = new JdbcConnection(dataSource.getConnection());
    			Databse database = DatabaseFactory.getInstance().findCorrectDatabaseImplementation(connection);
    			database.setDatabaseChangeLogTableName(LIQUIBASE_CHANGELOG_PREFIX+database.getDatabaseChangeLogTableName());
    			database.setDatabaseChangeLogLockTableName(LIQUIBASE_CHANGELOG_PREFIX=database.getDatabaseChangeLogLockTableName());
    			liquibase = new Liquibase("META_INF/liquibase/flowable0modeler-app-db-changelog.xml",new ClassLoaderResourceAccessor(),database);
    			liquibase.updata("flowable");
    			return liquibase;
    		}catch(Exception e){
    			throw new InternalServerErrorException("Error creating liquibase database",e)
    		}finally{
    			closeDatabase(liquibase);
    		}
    	}
    
    	public void closeDatabase(Liquibase liquibase){
    		if(liquibase!=null){
    			Database database = liquibase.getDatabase();
    			if(database!=null){
    				try{
    					database.close();
    				}catch(DatabaseException e){
    					LOGGER.warn("Error closing database",e);
    				}
    			}
    		}
    	}
    }
    
    
    
    
    @Api
    @RestController
    @RequestMapping("/app")
    public class FlowableStencilSetResource{
    	private static final Logger LOGGER = LoggerFactory.getLogger(FlowableStencilSetResource.class);
    
    	@Autowired
    	protected ObjectMapper  objectMapper;
    
    	@ApiOperation("获取bpmn sets文件")
    	@RequestMapping(value="rest/stencli-sets/editor",method=RequestMethod.GET,produces="application/json")
    	public JsonNode getStencilSetForEditor(){
    		try{
    			InputStream is = this.getClass().getClassLoader().getReourceAsStream("stencilset/stencilset_bpmn.json");
    			JsonNode stencilNode = objectMapper.readTree(is);
    			return stencilNode;
    		}catch(Exception e){
    			LOGGER.error("Error reading bpmn stencil set json",e);
    			throw new InternalServerErrorException("Error reading bpmn stencli set json");
    		}
    	}
    
    	@ApiOperation(value="获取cmmn sets文件")
    	@RequestMapping(value="/rest/stencil-sets/cmmneditor",method=RequestMethod.GET,produces="application/json")
    	public JsonNode getCmmnStencilSetForEditor(){
    		try{
    			JsonNode stencilNode = objectMapper.readTree(this.getClass.getClassLoader().getResourceAsStream("stencilset/stencilset_cmmn.json"));
    			return stencilNode;
    		}catch(Exception e){
    			LOGGER.error("Error reading bpmn stencli set json",e);
    			throw new InternalSeverErrorException("Error reading bpmn stencil set json")
    		}
    	}
    }
    
    
    //流程引擎配置文件
    @Configuration
    public class ProcessEngineConfig{
    	private Logger logger = LoggerFactory.getLogger(ProcessEngineConfig.class);
    
    	@Bean
    	public SpringProcessEngineConfiguration springProcessEngineConfiuration(DataSourceTransactionManager datasourceTransactionManager,DataSource dataSource){
    		SpringProcessEngineConfiguration.springProcessEngineConfiguration = new SpringProcessEngineConfiguration();
    		springProcessEngineConfiguration.setDataSource(dataSource);
    		springProcessEngineConfiguration.setTransactionManager(datasourceTransactionManager);
    		springProcessEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEME_UPDATE_TRUE);
    		springProcessEngineConfiguration.setAsyncExcutorActivate(true);
    		springProcessEngineConfiguration.setActivityFontName();
    		springProcessEngineConfiguration.setLabelFontName();
    		springProcessEngineConfiguration.setAnnotationFontName();
    		
    		return springProcessEngineConfiguration;
    	}
    }
    
    FlowableController.java
    @Api(tags="flowable测试接口")
    @RestController
    @RequestMapping("/flowable")
    public class FlowableController{
    	@Autowired
    	private IdentityService identityService;
    
    	@Autowired
    	private RepositoryService repositoryService;
    
    	@Autowired
    	private RuntimeService runtimeService;
    
    	@Autowired
    	private TaskService taskService;
    
    	@Autowired
    	private ProcessEngine processEngine;
    
    	@ApiOperation("新建用户")
    	@GetMaping("/user/createUser",produces={"application/json"})
    	public User createUser(String name,String firstName,String lastName){
    		User user = identityService.newUser(name);
    		user.setFirstName(firstName);
    		user.setLastName(lastName);
    		user.setEmail("123@qq.com");
    		user.setPassword("123456");
    		identityService.saveUser(user);
    		return user;  //org.flowable.idm.api.User;
    
    	}
    
    	@ApiOperation("获取用户的任务")
    	@GetMapping("value=/getTasks/{userId}",produces={"application/json"})
    	public List<Title> getTasks(@PathVariable String userId){
    		return taskService.createTaskQuery().taskAssignee(userId).orderByTaskCreateTime().desc().list();
    	}
    
    	@ApiOperation("审批不通过")
    	@PostMapping("value=/faile/{taskId}")
    	public String faile(@PathVariable String taskId){
    		Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
    		if(task == null){
    			return "流程不存在";
    		}
    		HashMap<String,Object> map = new HashMap<>();
    		map.put("approved",false);
    		taskService.complete(taskId,map);
    		return "审批不通过";
    	}
    
    	@ApiOperation("获取流程图")
    	@PostMapping(value="processDiagram")
    	public void getProcessDiagram(HttpServletResponse response,String processId) throws IOException{
    		ProcessInstance pi = runtimeService.createProcessInstanceQuery().processInstanceId(processId).singleResult();
    		//流程走完的不显示图
    		if(pi==null){
    			return;
    		}
    		Task task = taskService.createTaskQuery().processInstanceId(pi.getId()).singleResult();
    		String instanceId = task.getProcessInstanceId();
    		List<Execution> executions = runtimeService.createExecutionQuery().processInstanceId(instanceId).list();
    
    		List<String> activityIds = new ArrayList<>();
    		List<String> flows = new ArrayList<>();
    		for(Execution exe:executions){
    			List<String> ids = runtimeService.getActiveActivityIds(exe.getId());
    			activityIds.addAll(ids);
    		}
    		//获取流程图
    		BpmnModel bpmnModel = repositoryService.getBpmnModel(pi.getProcessDefinitionId());
    		ProcessEngineConfiguration engconf = processEngine.getprocessEngineConfiguration();
    		ProcesDiagramGenerator diagramGenerator = engconf.getProcessDiagramGenerator();
    		InputStream in = diagramGeneratro.generateDiagram(bpmnMode,"png",activityIds,flows,engconf.getActivityFontName(),engconf.getLabelFontName(),engconf.getAnnotaionFontName(),
    			engconf.getClassLoader(),1.0,true);
    		OutputStream out = null;
    		byte[] buf = new byte[1024];
    		int length = 0;
    		try{
    			out = response.getOutputStream();
    			while((length=in.read(buf))!=-1){
    				out.write(buf,0,length);
    			}
    		}finally{
    			if(in!=null){
    				in.close();
    			}
    			if(out!=null){
    				out.close();
    			}
    		}
    	}
    }
    
    
    ModelController.java
    @Api(tags="流程管理模块")
    @RestController
    @RequestMapping("/modelmanager")
    public class ModelController{
    	private static final Logger LOGGER = LoggerFactory.getLogger(ModelController.class);
    
    	@Autowired
    	private IFlowableModelService flowableModelService;
    	@Autowired
    	private ModelService modelService;
    	@Autowired
    	private ProcessEngine processEngine;
    	@Autowired
    	private AddFlwProcessModelService addFlwProcessModelService;
    	@Autowired
    	private TokenService tokenService;
    
    	@ApiOperation("获取模型列表")
    	@GetMapping("/list-model")
    	public ReturnVo<List<ChildModel>> listModel(){
    		ReturnVo<List<ChildModel>> returnVo = new ReturnVo<>(ReturnCode.SUCCESS,"OK");
    		List<AbstractModel> datas = modelService.getModelByModelType(Abstract.MODEL_TYPE_BPMN);
    ..........
    .........
    ........
    	}
    }

[https_www.cnblogs.com_phyger_p_14067201.html]: https://www.cnblogs.com/phyger/p/14067201.html
[https_blog.csdn.net_u013972652_article_details_109990809]: https://blog.csdn.net/u013972652/article/details/109990809