做外贸需要哪些网站有哪些,企业内部网站制作模板,wordpress主题背景,花乡做网站公司由于客户对于系统里的一些新增数据#xff0c;例如照片墙、照片等#xff0c;想实现上级逐级审批通过才可见的效果#xff0c;于是引入了Acitivity7工作流技术来实现#xff0c;本文是对实现过程的介绍讲解#xff0c;由于我是中途交接前同事的这块需求#xff0c;所以具… 由于客户对于系统里的一些新增数据例如照片墙、照片等想实现上级逐级审批通过才可见的效果于是引入了Acitivity7工作流技术来实现本文是对实现过程的介绍讲解由于我是中途交接前同事的这块需求所以具体实现方式和代码编写我暂时先按前同事的思路简单介绍不代表我个人看法。 参考文章 springbootActiviti7整合实践 (一)_vue2集成activit7-CSDN博客 org.springframework.security.core.userdetails.UsernameNotFoundException三步解决Activiti7和Security冲突问题_cause: org.springframework.security.core.userdetai-CSDN博客 Activiti7笔记二Activiti7一共涉及到25张表哪些操作会涉及哪些表每张表的作用是什么_activiti7数据表详细解读-CSDN博客 Activiti7笔记一Activiti7是什么入门流程操作的代码实现-腾讯云开发者社区-腾讯云 (tencent.com) 文章目录 一、引入依赖二、修改配置文件三、解决Activity7和Security框架冲突四、启动项目生成activity的数据库表审批流过程 五、画流程图六、部署流程七、发起流程1.示例2.相关代码 八、审批过程1.审核通过1.示例2.相关代码 2.审批不通过1.相关代码 九、业务表相关字段1.任务表2.业务数据表 十、业务表数据权限变化 一、引入依赖 !--activity7工作流--dependencygroupIdorg.activiti/groupIdartifactIdactiviti-spring-boot-starter/artifactIdversion${activity.starter.version}/versionexclusionsexclusion!-- 项目引入了mybatis-plus则需要排除 --groupIdorg.mybatis/groupIdartifactIdmybatis/artifactId/exclusion/exclusions/dependencydependencygroupIdorg.activiti.dependencies/groupIdartifactIdactiviti-dependencies/artifactIdversion${activity.starter.version}/versiontypepom/type/dependency!-- 生成流程图 --dependencygroupIdorg.activiti/groupIdartifactIdactiviti-image-generator/artifactIdversion${activity.starter.version}/version/dependency二、修改配置文件 spring:#activity工作流配置activiti:# 自动部署验证设置true-开启默认、false-关闭check-process-definitions: false# 保存历史数据history-level: full# 检测历史表是否存在db-history-used: true# 关闭自动部署deployment-mode: never-fail# 对数据库中所有表进行更新操作如果表不存在则自动创建# create_drop启动时创建表在关闭时删除表必须手动关闭引擎才能删除表# drop-create启动时删除原来的旧表然后在创建新表不需要手动关闭引擎database-schema-update: true# 解决频繁查询SQL问题async-executor-activate: falsedb-history-userd 和 history-level建议按图中配置方便查询工作流历史记录
三、解决Activity7和Security框架冲突 场景由于Activity升级到7版本后引入了Security来用于权限校验但是本项目自身已经引入了Security框架于是发生了冲突 【如果项目用的不是security框架例如用的shiro需要在启动项排除参考springbootActiviti7整合实践 (一)_vue2集成activit7-CSDN博客】 网上有很多的相关报错和解决办法【参考org.springframework.security.core.userdetails.UsernameNotFoundException三步解决Activiti7和Security冲突问题_cause: org.springframework.security.core.userdetai-CSDN博客】 但本项目主要报错的地方是 根据userid获取用户任务列表这个逻辑使用activity7原生api方法会报错 解决办法前同事处理的不去排除冲突直接另外新写一个方法去查activity7的表实现上述的逻辑
本项目
网上其他做法用的activity原生的api
从Activiti工作流中检索所有用户任务_在activiti 7中获取流程实例的所有任务_如何在Activiti工作流中的单独实例中强制顺序执行任务 - 腾讯云开发者社区 - 腾讯云 (tencent.com)
四、启动项目生成activity的数据库表
引入依赖、配置好后第一次启动会在数据库生成相关的表
具体介绍Activiti7笔记二Activiti7一共涉及到25张表哪些操作会涉及哪些表每张表的作用是什么_activiti7数据表详细解读-CSDN博客
本项目主要用到的表 流程部署表 [ACT_RE_PROCDEF] 每对一个流程图部署后会记录在该表里部署过程下面会讲到 历史流程实例表[ACT_HI_PROCINST] 流程一次从头到尾执行对应一个流程实例流程结束时会保留下来 运行时流程执行对象表 [ACT_RU_EXECUTION] 流程实例与执行对象的关系一个流程实例在执行过程中如果流程包含分支或聚合那么执行对象的数量可以多个【至少有2条数据其中第1条是对应历史流程实例表】。这是因为流程实例在运行过程中可能会产生多个并行的执行路径每个路径上的任务或活动都可以视为一个执行对象。例如在一个具有多个分支的审批流程中不同的审批人可能会同时处理不同的分支任务这些分支任务就代表了多个执行对象 Activiti工作流学习二流程实例、执行对象、任务 - 百度文库 (baidu.com) 这个表里面主要记录的是当前已经执行到哪个节点了把对应的节点对象记录到这个里面 流程结束后这张表对应的数据会清除 运行时节点人员数据信息表 [ACT_RU_IDENTITYLINK] 运行时用户关系信息存储任务节点与参与者的相关信息 也就是只要当前任务有参与者就会将参与者的信息保存到这个表多个人参与保存多个信息 **运行时任务节点表[ACT_RU_TASK] ** 一个流程有多个节点到某一个节点的时候都会更新这个表将当前节点的数据更新到这个表
审批流过程
部署流程到ACT_RE_PROCDEF表看有没有新增一条对应的数据启动流程实例执行流程对象可能多个到ACT_HI_PROCINST 和 ACT_RU_EXECUTION表看有没有新增对应数据完成整个流程过程主要看ACT_RU_TASK和 ACT_RU_IDENTITYLINK表的更新情况
五、画流程图 IDEA安装插件 在resource下创建一个目录process存放流程图文件 右键新建流程图文件 具体画图过程省略这里介绍画完之后的流程图的重点信息 以2个审批节点的流程图为例增加、减少节点都需要另外画图部署 定义流程的id和名字后续代码可以取到 开始节点 审批节点 第1个审批节点 第2个审批节点同上 结束节点 二级节点之后的网关 这里二级审批完之后会出现2种不同的可能走向审批通过继续到一级审批节点审批不通过直接结束所以需要加上一个网关 【由于时间较赶等原因本项目不做回退的实现所以审核不通过都是直接走向结束节点一级审批节点通过或不通过都是走向结束节点】 节点之间或节点与网关之间的连接线 重点注意网关后的线 定义一个条件变量当SecondJudgetrue时代码赋值即审核通过会走向 一级审核 节点否则走向结束节点如下图所示 【当二级组织发起审核但是选择最终审批组织也是二级的时候审核通过会赋值SecondJudgefalse直接走结束节点】
六、部署流程
本项目采用的是通过接口手动部署的方式【每新建或修改流程图都要调用一次接口来部署后续打算优化成自动部署或者定时任务调用接口部署】 ApiOperation(手动部署照片审核)GetMapping(/photo/process/{typeLevel})public String auditingPhotoProcessByTypeLevel(PathVariable(typeLevel) Integer typeLevel, RequestParam(force) Boolean force) {return auditingPhotoService.auditingPhotoProcessByTypeLevel(typeLevel,force);}/*** 手动部署* param typeLevel 组织等级* param force 是否强制部署当修改了流程图的时候需要传true* return 部署结果*/public String auditingPhotoProcessByTypeLevel(Integer typeLevel, Boolean force);Overridepublic String auditingPhotoProcessByTypeLevel(Integer typeLevel, Boolean force) {switch (typeLevel) {case 6:auditingPhotoSixService.process(force);break;case 5:auditingPhotoFiveService.process(force);break;case 4:auditingPhotoFourService.process(force);break;case 3:auditingPhotoThreeService.process(force);break;case 2:auditingPhotoTwoService.process(force);break;case 1:auditingPhotoOneService.process(force);break;default:throw new ServicesException(ResultStatus.ARGS_VALID_ERROR);}return typeLevel 级照片流程部署成功;}/*** 部署流程* param force* return*/public void process(Boolean force);public void process(Boolean force) {//判断流程是否已经部署当force0时if (force null || force) {//部署流程DeploymentBuilder builder repositoryService.createDeployment();builder.addClasspathResource(AuditingConstant.BpmnXmlPhotoPathConstant.AUDITING_PHOTO_SIX_XML).disableSchemaValidation();String id builder.deploy().getId();repositoryService.setDeploymentKey(id, AuditingConstant.BpmnIdConstant.AUDITING_PHOTO_SIX_ID);} else {//检测流程是否已经部署过ListProcessDefinition definitions repositoryService.createProcessDefinitionQuery().processDefinitionKey(AuditingConstant.BpmnIdConstant.AUDITING_PHOTO_SIX_ID).list();if (!definitions.isEmpty()) {// 已经部署过流程定义throw new ServicesException(ResultStatus.AUDITING_PROCESS_DUPLICATE);} else {//部署流程DeploymentBuilder builder repositoryService.createDeployment();builder.addClasspathResource(AuditingConstant.BpmnXmlPhotoPathConstant.AUDITING_PHOTO_SIX_XML).disableSchemaValidation();String id builder.deploy().getId();repositoryService.setDeploymentKey(id, AuditingConstant.BpmnIdConstant.AUDITING_PHOTO_SIX_ID);}}}这里AuditingConstant.BpmnXmlPhotoPathConstant.AUDITING_PHOTO_SIX_XML是流程图的路径如下图所示 部署好后查看数据表 ACT_RE_PROCDEF 即可判断是否成功部署 七、发起流程
前提 业务表需要审批的数据创建 —— 点击提交审核
如下图的照片墙审核创建一条新的数据此时一开始没审核状态是“草稿”点击发布后才会触发审批流程 1.示例
二级组织用户 新增一个照片墙点击发布选择审核等级为 上级一级组织即需要经过两个审批节点才截止
【只要是二级发起的都走的是2个审批节点的流程图只不过根据结束节点会有不同的走向逻辑如果这里选择本级二级结束则不论二级通过不通过都会直接走向结束节点】 点击发布后会启动一个流程实例并执行流程对象见表ACT_HI_PROCINST 和 ACT_RU_EXECUTION
ACT_HI_PROCINST历史流程实例表 ACT_RU_EXECUTION运行时流程执行对象表 如下图当二级用户点击发步后会发起审核先走到 “二级审核2” 节点对应上图的第1条数据 2.相关代码 ApiOperation(发起照片审核)ApiImplicitParams({ApiImplicitParam(type query, name taskName, value 任务名称, required true),ApiImplicitParam(type query, name priority, value 优先级, required true),ApiImplicitParam(type query, name desc, value 描述, required true),ApiImplicitParam(type query, name photoWallId, value 照片墙id, required true),ApiImplicitParam(type query, name auditingOrganizeId, value 审核的组织id, required true)})ApiResponses({ApiResponse(response ResponseResult.class, message 1, code 200),ApiResponse(response ServiceException.class, message 系统错误,请稍等!, code 4000)})PostMapping(/startPhotoAuditProcess)public ResponseResultString photoStartAuditing(RequestBody MapString, Object map) {return ResponseResult.success(auditingPhotoService.photoStartAuditing(map));}/*** 启动流程* param map* return success*/public String photoStartAuditing(MapString,Object map);下面代码解释根据当前用户的组织级别走不同的实现方法【代码比较臃肿后续再优化后面的代码同理】 OverrideTransactional(rollbackFor Exception.class)public String photoStartAuditing(MapString, Object map) {//根据照片墙id查找照片墙给照片墙设置审核的组织IDPhotoWall photoWall photoWallService.selectPhotoWallDetail(map.get(photoWallId) );photoWall.setOrganizeAuditingId(Long.parseLong(map.get(auditingOrganizeId) ));photoWall.setOpinion();OrganizeTreeVO userOrganize iOrganizeService.getUserOrganize();photoWallService.updatePhotoWallForAuditing(photoWall);//当前组织的级别Integer typeLevel userOrganize.getTypeLevel();Integer typeLevelSix 6;Integer typeLevelFive 5;Integer typeLevelFour 4;Integer typeLevelThree 3;Integer typeLevelTwo 2;Integer typeLevelOne 1;if (typeLevel.equals(typeLevelSix)) {auditingPhotoSixService.startAuditProcess(map);} else if (typeLevel.equals(typeLevelFive)) {auditingPhotoFiveService.startAuditProcess(map);} else if (typeLevel.equals(typeLevelFour)) {auditingPhotoFourService.startAuditProcess(map);} else if (typeLevel.equals(typeLevelThree)) {auditingPhotoThreeService.startAuditProcess(map);} else if (typeLevel.equals(typeLevelTwo)) {auditingPhotoTwoService.startAuditProcess(map);} else if (typeLevel.equals(typeLevelOne)) {auditingPhotoOneService.startAuditProcess(map);}return success;}/*** 启动流程* param map*/
public void startAuditProcess(MapString,Object map);public void startAuditProcess(MapString, Object map) {String id map.get(photoWallId) ;//修改照片墙的状态PhotoWall photoWall photoWallService.selectPhotoWallDetail(id);photoWall.setAuditState(1);photoWall.setOrganizeAuditingId(Long.parseLong(map.get(auditingOrganizeId) ));Boolean code photoWallService.updatePhotoWallForAuditing(photoWall);if (code) {// 获取当前登录用户的组织信息OrganizeTreeVO userOrganize iOrganizeService.getUserOrganize();//当前组织的级别Integer typeLevel userOrganize.getTypeLevel();//用来封装存储每一级组织的审核人,key是integer表示不同级的组织value是个list集合每一级组织的审核人HashMapString, ListSysUser auditors new HashMap(10);//找出每一级审批流人员activitiService.getAuditors(userOrganize,typeLevel,auditors);// 设置流程变量MapString, Object variables new HashMap(10);//获得每级审核的审核人ListString firstAuditor getAuditorsId(auditors.get(1));ListString secondAuditor getAuditorsId(auditors.get(2));//审核人variables.put(firstAuditor, firstAuditor);variables.put(secondAuditor, secondAuditor);String formKey AuditingConstant.BpmnIdConstant.AUDITING_PHOTO_TWO_ID :;String bussinessKey formKey id;variables.put(bussinessKey, bussinessKey);// 启动流程实例runtimeService.startProcessInstanceByKey(AuditingConstant.BpmnIdConstant.AUDITING_PHOTO_TWO_ID, bussinessKey, variables);//给接下来的每一个审核人都创建一个在刚发起的时候是同一级的审核人ListSysUser auditorsTypeLevel auditors.get(typeLevel );//获得和登录用户同一级的审核人的idListString auditorsTypeLevelIds getAuditorsId(auditorsTypeLevel);for (int i 0; i auditorsTypeLevelIds.size(); i) {SysTask sysTask new SysTask();sysTask.setTaskName((String) map.get(taskName));sysTask.setPriority(Integer.valueOf(map.get(priority) ));sysTask.setDescribe((String) map.get(desc));sysTask.setPhotoWallId((String) map.get(photoWallId));sysTask.setCreatorName(SecurityUtils.getLoginUser().getUsername());sysTask.setCreatorId(SecurityUtils.getLoginUser().getUserId());//审核人的名字 这里要怎么设置啊审核人的名字和id用的是候选用户啊sysTask.setAuditingPeople(auditorsTypeLevel.get(i).getUserName());//审核人的idsysTask.setAuditingPeopleid(Long.parseLong(auditorsTypeLevelIds.get(i)));sysTask.setState(1);sysTask.setAuditingType(2);//任务表添加iSysTaskService.addTask(sysTask);//审核人的消息Message message new Message();SimpleDateFormat sdf new SimpleDateFormat(yyyy年MM月dd日);String date sdf.format(new Date());message.setContent(你在 date 有一个照片墙的审核);message.setCreateTime(new Date());message.setState(1);message.setUserId(auditorsTypeLevelIds.get(i));message.setType(1);messageService.addMessage(message);}//登录用户的消息Message message new Message();SimpleDateFormat sdf new SimpleDateFormat(yyyy年MM月dd日);String date sdf.format(new Date());message.setContent(你在 date 发起了一个照片墙审核);message.setCreateTime(new Date());message.setState(1);message.setUserId(SecurityUtils.getLoginUser().getUserId() );message.setType(2);messageService.addMessage(message);}
}上方代码重点 设置变量启动流程实例 这里把每一级审核人提前都设置好后续不变【这里根据业务需求应该也可以设计成后续动态添加】 业务id bussinessKey 规则在此设定调用最后一行的activity api时候需要传递同时将其设置到流程变量 variables 中后续方便读取 业务部分 修改 照片墙业务表 流程相关字段新增 审核任务业务表发送消息
八、审批过程
现在流程走到第一个审批节点即 二级审核2 此时运行时节点人员数据信息表 ACT_RU_IDENTITYLINK存入二级审核2 节点的 是审核人角色 的 用户尾号20用户和尾号52用户都是该节点的审批人【该项目里只要其中一个审批通过就算通过反之一个拒绝就算拒绝】
且被分配到了任务同个任务见表ACT_RU_TASK如下图 对应业务表 任务表里也加了2条数据 他们之间通过 BUSINESS_KEY_ 来关联
1.审核通过
审批通过在activity7框架中只需要设置SecondJudge变量然后将task任务完成即可 1.示例
二级组织人员 尾号52用户 创建了一个照片墙点击发布后生成本级人员尾号52和尾号20的任务此时52用户进入“我的待办”里业务表 任务表找到对应任务点击审批通过如下图 2.相关代码
ApiOperation(照片墙审批通过)
ApiImplicitParams({ApiImplicitParam(type query, name id, value 任务id, required true),ApiImplicitParam(type query, name opinion, value 建议, required false)
})
PostMapping(/auditing/photo/approve/{id})
public ResponseResultString auditingPhotoApprove(PathVariable Integer id, RequestParam(required false) String opinion) {return ResponseResult.success(auditingPhotoService.auditingPhotoApprove(id, opinion));
}/*** 审核通过* param id* param opinion* return success*/
public String auditingPhotoApprove(Integer id,String opinion);下面代码解释
通过照片墙的创建者的组织等级走不同的审核通过实现类
Override
Transactional(rollbackFor Exception.class)
public String auditingPhotoApprove(Integer id, String opinion) {//id是任务的id可以获得照片墙的id//再去新建表中查询这个照片墙是哪级创建的//这个级数直接判断吗然后去调用哪个类的approve方法SysTask sysTask iSysTaskService.selectTaskById(id);//通过任务的informatinid来获得照片墙idString photoId sysTask.getPhotoWallId();//根据照片墙的id去查询审核创建者的级别LambdaQueryWrapperPhotoWall lambdaQueryWrapper new LambdaQueryWrapperPhotoWall();lambdaQueryWrapper.eq(PhotoWall::getPhotoWallId, photoId);PhotoWall photoWall photoWallService.getOne(lambdaQueryWrapper);//获得当前等级Long organizeId photoWall.getOrganizeId();Integer userOrganizeLevel iOrganizeService.searchOrganizeById(organizeId).getOrganizeLevel();Integer userOrganizeLevelOne 1;Integer userOrganizeLevelTwo 2;Integer userOrganizeLevelThree 3;Integer userOrganizeLevelFour 4;Integer userOrganizeLevelFive 5;Integer userOrganizeLevelSix 6;//获得审核组织的级别Long auditingOrganizeId photoWall.getOrganizeAuditingId();Integer auditingOrganizeLevel iOrganizeService.searchOrganizeById(auditingOrganizeId).getOrganizeLevel();if (userOrganizeLevel.equals(userOrganizeLevelOne)) {auditingPhotoOneService.approve(id, opinion);} else if (userOrganizeLevel.equals(userOrganizeLevelTwo)) {auditingPhotoTwoService.approve(id, opinion, auditingOrganizeLevel);} else if (userOrganizeLevel.equals(userOrganizeLevelThree)) {auditingPhotoThreeService.approve(id, opinion, auditingOrganizeLevel);} else if (userOrganizeLevel.equals(userOrganizeLevelFour)) {auditingPhotoFourService.approve(id, opinion, auditingOrganizeLevel);} else if (userOrganizeLevel.equals(userOrganizeLevelFive)) {auditingPhotoFiveService.approve(id, opinion, auditingOrganizeLevel);} else if (userOrganizeLevel.equals(userOrganizeLevelSix)) {auditingPhotoSixService.approve(id, opinion, auditingOrganizeLevel);}return success;
}/*** 审核通过* param id* param opinion* param auditingOrganizeLevel*/
public void approve(Integer id, String opinion,Integer auditingOrganizeLevel);Override
public void approve(Integer id, String opinion, Integer auditingOrganizeLevel) {//获取任务的候选人是登录用户的任务的方法ListTask taskList activitiService.getTaskIdByCandidate(SecurityUtils.getLoginUser().getUserId().toString());//当前登录用户的组织级别Integer typeLevel iOrganizeService.getUserOrganize().getTypeLevel();//搜索出工作台选的任务idSysTask sysTask iSysTaskService.selectTaskById(id);//通过任务的photoWallId来获得照片墙idPhotoWall photoWall photoWallService.selectPhotoWallDetail(sysTask.getPhotoWallId() );String photoWallId photoWall.getPhotoWallId();auditingInformTwoApproveService(taskList, photoWallId, typeLevel, photoWall, auditingOrganizeLevel, opinion);// 获取当前登录用户的组织信息OrganizeTreeVO userOrganize iOrganizeService.getUserOrganize();//用来封装存储每一级组织的审核人,key是integer表示不同级的组织value是个list集合每一级组织的审核人HashMapString, ListSysUser auditors new HashMap(10);//找出每一级审批流人员activitiService.getAuditors(userOrganize,typeLevel,auditors);ListString auditorsList new ArrayList();if(typeLevel.equals(AuditingConstant.Number.TWO)){auditorsList getAuditorsId(auditors.get(2));}if (typeLevel 1) {auditorsList getAuditorsId(auditors.get(1));}sysTask.setState(2);sysTask.setOpinion(opinion);sysTask.setCompletionTime(new Date());iSysTaskService.updateTask(sysTask);Long userId1 SecurityUtils.getLoginUser().getUserId();String photoWallId1 sysTask.getPhotoWallId();//删除其他用户中关联这个照片墙id的任务//循环审核人列表for (String s : auditorsList) {//当审核人不等于登录用户时即其他用户if (!Objects.equals(s, userId1 )) {//搜索出他的全部任务ListSysTask sysTaskList iSysTaskService.selectTaskByAuditorId(Long.parseLong(s));//循环任务for (SysTask task : sysTaskList) {//找出任务中关联的照片墙id等于当前登录用户审核的任务的关联的照片墙idif (photoWallId1.equals(task.getPhotoWallId())) {//删除iSysTaskService.deleteTask(task.getTaskId().intValue());}}}}if (typeLevel 1 || typeLevel.equals(auditingOrganizeLevel)) {photoWall.setAuditState(2);photoWallService.updatePhotoWallForAuditing(photoWall);Message message new Message();Date date new Date();message.setContent(你的照片墙在 typeLevel 级审核通过);message.setCreateTime(date);message.setState(1);String userId sysTask.getCreatorId() ;message.setUserId(userId);message.setType(2);message.setTaskId(sysTask.getTaskId().intValue());messageService.addMessage(message);return;}if (typeLevel.equals(AuditingConstant.Number.TWO)) {auditorsList getAuditorsId(auditors.get(1));}for (String s : auditorsList) {SysTask sysTask1 new SysTask();sysTask1.setTaskName(sysTask.getTaskName());sysTask1.setPriority(sysTask.getPriority());sysTask1.setDescribe(sysTask.getDescribe());sysTask1.setPhotoWallId(sysTask.getPhotoWallId());sysTask1.setCreatorName(SecurityUtils.getLoginUser().getUsername());sysTask1.setCreatorId(SecurityUtils.getLoginUser().getUserId());sysTask1.setAuditingPeopleid(Long.parseLong(s));SysUser sysUser iSysUserService.selectUserById(Long.parseLong(s));sysTask1.setAuditingPeople(sysUser.getUserName());sysTask1.setState(1);sysTask1.setAuditingType(2);iSysTaskService.addTask(sysTask1);sendMessage(s, sysTask);}sendMessage(typeLevel, sysTask);
}private void auditingInformTwoApproveService(ListTask taskList, String photoWallId, Integer typeLevel, PhotoWall photoWall, Integer auditingOrganizeLevel, String opinion) {if (!ObjectUtils.isEmpty(taskList)) {for (Task item : taskList) {ProcessInstance processInstance runtimeService.createProcessInstanceQuery().processInstanceId(item.getProcessInstanceId()).singleResult();//根据流程实例得到bussinesskey格式是formkey:idString a processInstance.getBusinessKey();if (StringUtils.isNotBlank(a)) {String[] b a.split(:);String photoId b[1];//判断bussinesskeybussinesskey是任务表中的记录的id在发起流程的时候会插入任务表任务表的id也会变成流程变量if (photoId.equals(photoWallId)) {if (typeLevel 2) {if (typeLevel.equals(auditingOrganizeLevel)) {taskService.setVariable(item.getId(), SecondJudge, false);} else {taskService.setVariable(item.getId(), SecondJudge, true);}} else if (typeLevel 1) {//如果当前审核人是一级组织的那审核就结束了photoWall.setAuditState(2);photoWall.setOpinion(opinion);photoWallService.updatePhotoWallForAuditing(photoWall);}taskService.addComment(item.getId(), item.getProcessInstanceId(), 审核通过);taskService.complete(item.getId());break;}}}}
}上面代码重点 找到activity的任务表中当前该用户的所有任务 Override
public ListTask getTaskIdByCandidate(String userId) {ListActivitiTaskId activitiTaskId activitiMapper.getTaskIdByCandidate(userId);ListString activitiTaskIds new ArrayList();for (com.znak.platform.entity.ActivitiTaskId taskId : activitiTaskId) {activitiTaskIds.add(taskId.getTaskId());}ListTask taskList new ArrayList();for (String taskId : activitiTaskIds) {Task task taskService.createTaskQuery().taskId(taskId).singleResult();taskList.add(task);}return taskList;
}select idgetTaskIdByCandidate resultTypecom.znak.platform.entity.ActivitiTaskIdselect distinct TASK_ID_ from ACT_RU_IDENTITYLINKwhere USER_ID_ #{userId} and TASK_ID_ !
/select根据bussinesskey找到对应的任务修改变量SecondJudge并完成任务 这里注意如果当前是走到一级审批节点了则走下面的else if逻辑直接将业务表修改审核通过不用设置变量因为没有网关了如下图 业务相关 修改业务表的审批流相关字段同时发送消息同上 然后删除同级别组织人员的 业务表 任务表新建下一级的人员的业务表 任务表见代码
2.审批不通过
过程和审批通过大致一样 1.相关代码
ApiOperation(照片审核不通过)
ApiResponses({ApiResponse(response ResponseResult.class, message 1, code 200),ApiResponse(response ServiceException.class, message 系统错误,请稍等!, code 4000)})
ApiImplicitParams({//发起资讯申请相关字段ApiImplicitParam(type query, name id, value 任务id, required true),ApiImplicitParam(type query, name opinion, value 建议, required false)
})
PostMapping(/auditing/photo/reject/{id})
public ResponseResultString auditingPhotoReject(PathVariable Integer id, RequestParam(required false) String opinion) {return ResponseResult.success(auditingPhotoService.auditingPhotoReject(id, opinion));
}/*** 审核不通过* param id* param opinion* return success*/
public String auditingPhotoReject(Integer id,String opinion);Override
Transactional(rollbackFor Exception.class)
public String auditingPhotoReject(Integer id, String opinion) {//id是任务的id可以获得资讯的id//再去新建表中查询这个资讯是哪级创建的//这个级数直接判断吗然后去调用哪个类的approve方法SysTask sysTask iSysTaskService.selectTaskById(id);//通过任务的informatinid来获得资讯idString photoWallId sysTask.getPhotoWallId();//根据资讯的id去查询审核创建者的级别LambdaQueryWrapperPhotoWall lambdaQueryWrapper new LambdaQueryWrapperPhotoWall();lambdaQueryWrapper.eq(PhotoWall::getPhotoWallId, photoWallId);PhotoWall photoWall photoWallService.getOne(lambdaQueryWrapper);//获得当前等级Long organizeId photoWall.getOrganizeId();Integer userOrganizeLevel iOrganizeService.searchOrganizeById(organizeId).getOrganizeLevel();Integer userOrganizeLevelOne 1;Integer userOrganizeLevelTwo 2;Integer userOrganizeLevelThree 3;Integer userOrganizeLevelFour 4;Integer userOrganizeLevelFive 5;Integer userOrganizeLevelSix 6;if (userOrganizeLevel.equals(userOrganizeLevelOne)) {auditingPhotoOneService.rej(id, opinion);} else if (userOrganizeLevel.equals(userOrganizeLevelTwo)) {auditingPhotoTwoService.rej(id, opinion);} else if (userOrganizeLevel.equals(userOrganizeLevelThree)) {auditingPhotoThreeService.rej(id, opinion);} else if (userOrganizeLevel.equals(userOrganizeLevelFour)) {auditingPhotoFourService.rej(id, opinion);} else if (userOrganizeLevel.equals(userOrganizeLevelFive)) {auditingPhotoFiveService.rej(id, opinion);} else if (userOrganizeLevel.equals(userOrganizeLevelSix)) {auditingPhotoSixService.rej(id, opinion);}return success;
}/*** 审核不通过* param id* param opinion*/
public void rej(Integer id, String opinion);public void rej(Integer id, String opinion) {//获取任务的候选人是登录用户的任务的方法ListTask taskList activitiService.getTaskIdByCandidate(SecurityUtils.getLoginUser().getUserId().toString());//当前登录用户的组织级别Integer typeLevel iOrganizeService.getUserOrganize().getTypeLevel();//搜索出工作台选的任务idSysTask sysTask iSysTaskService.selectTaskById(id);//通过任务的informatinid来获得资讯idPhotoWall photoWall photoWallService.selectPhotoWallDetail(sysTask.getPhotoWallId());String photoWallId photoWall.getPhotoWallId();auditingInformTwoRejService(taskList, photoWallId, typeLevel, photoWall,opinion);// 获取当前登录用户的组织信息OrganizeTreeVO userOrganize iOrganizeService.getUserOrganize();//用来封装存储每一级组织的审核人,key是integer表示不同级的组织value是个list集合每一级组织的审核人HashMapString, ListSysUser auditors new HashMap(4);//找出每一级审批流人员activitiService.getAuditors(userOrganize,typeLevel,auditors);//防止四级发起的审核然后任务到达三级的时候调用此方法会报错4级审核人找不到ListString auditorsList new ArrayList();Integer typeLevelTwo 2;if (typeLevel.equals(typeLevelTwo)) {auditorsList getAuditorsId(auditors.get(2));}if (typeLevel 1) {auditorsList getAuditorsId(auditors.get(1));}//这一个等级的组织的审核任务处理,处理上一阶段的任务//获得当前级别的审核人sysTask.setState(3);sysTask.setOpinion(opinion);sysTask.setCompletionTime(new Date());iSysTaskService.updateTask(sysTask);Long userId1 SecurityUtils.getLoginUser().getUserId();String photoWallId1 photoWall.getPhotoWallId();//删除其他用户中关联这个咨询id的任务//循环审核人列表for (String s : auditorsList) {//当审核人不等于登录用户时即其他用户if (!Objects.equals(s, userId1 )){//搜索出他的全部任务ListSysTask sysTaskList iSysTaskService.selectTaskByAuditorId(Long.parseLong(s));//循环任务for(SysTask task : sysTaskList){//找出任务中关联的照片墙id等于当前登录用户审核的任务的关联的照片墙idif(photoWallId1.equals(task.getPhotoWallId())){//删除iSysTaskService.deleteTask(task.getTaskId().intValue());}}}}Message message new Message();Date date new Date();message.setContent(你的照片墙在 typeLevel 级审核没有通过);message.setCreateTime(date);message.setState(1);//这个审核的是谁的流程String userId sysTask.getCreatorId() ;message.setUserId(userId);message.setType(2);message.setTaskId(sysTask.getTaskId().intValue());messageService.addMessage(message);}private void auditingInformTwoRejService(ListTask taskList, String photoWallId, Integer typeLevel, PhotoWall photoWall,String opinion) {if (!ObjectUtils.isEmpty(taskList)) {for (Task item : taskList) {ProcessInstance processInstance runtimeService.createProcessInstanceQuery().processInstanceId(item.getProcessInstanceId()).singleResult();//根据流程实例得到bussinesskey格式是formkey:idString a processInstance.getBusinessKey();if (StringUtils.isNotBlank(a)) {String[] b a.split(:);String photoId b[1];//判断bussinesskeybussinesskey是任务表中的记录的id在发起流程的时候会插入任务表任务表的id也会变成流程变量if (photoId.equals(photoWallId)) {//根据当前登录用户的组织级别判断是第几级判断设置相关的流程变量if (typeLevel 2) {photoWall.setAuditState(4);photoWall.setOpinion(opinion);photoWallService.updatePhotoWallForAuditing(photoWall);taskService.setVariable(item.getId(), SecondJudge, false);} else if (typeLevel 1) {//如果当前审核人是一级组织的那审核就结束了photoWall.setAuditState(4);photoWall.setOpinion(opinion);photoWallService.updatePhotoWallForAuditing(photoWall);}taskService.addComment(item.getId(), item.getProcessInstanceId(), 审核不通过);taskService.complete(item.getId());break;}}}}
}上面代码的重点 找到activity的任务表中当前该用户的所有任务 同上 根据bussinesskey找到对应的任务修改变量SecondJudge并完成任务 同上 业务相关 修改业务表的审批流相关字段同时发送消息同上 然后删除同级别组织人员的 业务表 任务表见代码
九、业务表相关字段
1.任务表 2.业务数据表
以 照片墙 为例 十、业务表数据权限变化
审核前即草稿状态的数据只能看自己创建的审核通过本级 到 最终审核组织 之间的用户都可见
