一个人不能同时跑两个同类型业务——工作流互斥的设计与实现政务系统里一个人正在办参保登记就不能同时再办一个参保变更——因为两个流程会动同一个人的同一批数据。这套互斥校验不是靠人工判断是靠一张mutex表和一个v_personrun视图在流程启动时自动拦截。文章目录一个人不能同时跑两个同类型业务——工作流互斥的设计与实现一、场景为什么需要流程互斥二、核心设计mutex表 v_personrun视图2.1 mutex表——哪些流程类型互斥2.2 v_personrun视图——每个人当前在跑哪些流程三、互斥查询一条SQL搞定四、拦截流程启动前校验4.1 后端校验4.2 前端调用五、完整生命周期启动→检查→拦截→完成→释放六、mutex表的设计优势七、一个边界情况同类业务的重入八、结语一、场景为什么需要流程互斥社保系统里很多业务是互斥的——不是业务规则规定不能同时办是数据层面的冲突当前运行中想新开的为什么冲突参保登记参保登记同一个人不能登记两次参保登记参保变更登记还没完变更改什么待遇核定待遇停发核定完了才能停不能边核边停社保关系转出社保关系转入这个人到底在哪边前台操作员看到报错提示该人员已有在办业务时这个判断不是人工去查的是系统在流程启动前自动拦截的。二、核心设计mutex表 v_personrun视图2.1 mutex表——哪些流程类型互斥-- mutex表结构CREATETABLEmutex(prockey VARCHAR2(50),-- 当前流程的KeykeysVARCHAR2(500)-- 与哪些流程Key互斥逗号分隔);-- 示例数据INSERTINTOmutexVALUES(social_enroll,social_enroll,social_modify);INSERTINTOmutexVALUES(pension_calc,pension_calc,pension_stop);INSERTINTOmutexVALUES(social_transfer_out,social_transfer_out,social_transfer_in);prockey是当前要启动的流程Keykeys是逗号分隔的互斥流程Key列表包含自己——同类流程也不允许重入。2.2 v_personrun视图——每个人当前在跑哪些流程-- v_personrun视图基于act_ru_execution 业务表CREATEORREPLACEVIEWv_personrunASSELECTe.PROC_INST_ID_,b.AAC002,p.NAME_ASMATTER_NAME,e.PROC_DEF_ID_FROMact_ru_execution eJOINact_re_procdef pONe.PROC_DEF_ID_p.ID_JOINzy_brry bON...;-- 关联业务表获取身份证号视图关联了Activiti的运行实例表和业务数据表实时反映谁AAC002身份证号当前有哪些流程在跑PROC_DEF_ID_。三、互斥查询一条SQL搞定SELECTPROC_INST_ID_,AAC002,MATTER_NAME,PROC_DEF_ID_FROMv_personrunWHEREaac002#{aac002}ANDEXISTS(SELECT1FROMmutexWHEREprockey#{procDefId}ANDkeysLIKE%||v_personrun.proc_def_id_||,%)逻辑拆解① 查这个人的所有在跑流程v_personrun WHERE aac002 43012xxxx ② 对于当前要启动的流程KeyprocDefId social_enroll查mutex表确认它的互斥列表 ③ 如果此人的在跑流程的PROC_DEF_ID_出现在互斥列表中 → 有冲突 → 拦截SQL返回count 0就说明冲突。前端在流程启动前调checkMutex方法返回冲突了就弹提示框。四、拦截流程启动前校验4.1 后端校验publicbooleancheckMutex(Stringaac002,StringprocDefKey){personrun daonewpersonrun();dao.setAac002(aac002);dao.setProcDefId(procDefKey);Listpersonrunlist(Listpersonrun)dao.search();returnlist!nulllist.size()0;}4.2 前端调用vardcnewbrowise.ds.DataCenter();varaac002browise.byId(aac002).getValue();if(aac002key){URLwebRootDir/BusinessAction?BusinessflowActioncheckMutex;dc.setParameter(aac002,aac002);dc.setParameter(key,key);vardata{url:URL,sync:false,load:function(dc1){if(dc1.getCode()0){MessageBox.alert({title:提示信息,message:dc1.getDetail()});}}};browise.Action.requestData(data,dc,true);}同步调用——启动流程前先跑互斥检查有冲突直接弹提示不让继续。操作员看到的不是流程启动失败的500错误而是该人员已有在办业务参保登记受理中这样的明确提示。五、完整生命周期启动→检查→拦截→完成→释放用户点新增参保登记 │ ▼ checkMutex(aac00243012xxx, procDefKeysocial_enroll) │ ├── 无冲突 → 启动流程 → insert v_personrun → 进入表单 │ └── 有冲突此人已有social_enroll在跑 └── 返回错误码提示信息 → 弹提示框 → 用户不能继续 用户完成/终止流程 │ ▼ completeG() → 流程结束 → delete from v_personrun(对应记录消失)流程启动时插一条运行记录结束时删掉。v_personrun永远只反映当前运行中的流程。流程一结束互斥锁自动解除。六、mutex表的设计优势用一张配置表而不是硬编码if-else的原因方式新增互斥规则生产变更硬编码改代码、编译、部署、重启走发版流程mutex表插一条SQL即时生效社保政策经常变——今天说参保登记和参保变更不能同时办下个月说参保登记和待遇核定也不行。用配置表改一行记录立刻生效不需要发版。-- 新增互斥规则参保登记 和 待遇核定 互斥INSERTINTOmutexVALUES(social_enroll,social_enroll,social_modify,pension_calc);七、一个边界情况同类业务的重入keys里始终包含prockey自己——这保证了同一个人不能同时启动两个同类型的流程-- social_enroll的keys包含自己INSERTINTOmutexVALUES(social_enroll,social_enroll,social_modify);-- 当此人已有social_enroll在跑又点了一次social_enroll-- keys LIKE %social_enroll% 命中 → 拦截这和接口幂等不同——不是防止重复提交是防止业务逻辑上的重复办理。同一个人、同一业务、同时两笔——审核时到底批哪个八、结语流程互斥的核心不是技术问题是数据一致性问题——两个人不能同时改同一份档案。这套设计的巧妙之处在于用一张配置表管理互斥规则随时可变用一个视图反映实时运行状态精确到人用一条SQL完成所有判断性能可控。相比在自己的业务代码里写if (person.hasRunningProcess(登记))——那个只能判断同类流程一旦互斥规则扩展登记和变更也互斥if-else就会膨胀。mutex表把什么和什么互斥从代码里抽到数据里代码只负责查表→判断→拦截三步规则完全由数据驱动。