当前位置：首页 > news >正文

项目中用到的责任链模式

news 2025/9/8 21:19:48

1.什么是责任链？它的原理是什么？

2.应用场景

3.项目中的应用

传送门：策略模式，工作中你用上了吗？

1.什么是责任链？它的原理是什么？

将请求的发送和接收解耦，让多个接收对象都有机会处理这个请求。将这些接收对象串成一条链，并沿着这条链传递这个请求，直到链上的某个接收对象能够处理它为止。

以上定义来自《设计模式之美》

2.应用场景

责任链模式的应用场景，在实际工作中，通常有如下两种应用场景。

操作需要经过一系列的校验，通过校验后才执行某些操作。

工作流。企业中通常会制定很多工作流程，一级一级的去处理任务。

3.项目中的应用

责任链要执行的业务：

public interface AcptRegisterService {/*** ************** @param acptRegisterBO*/void check(AcptRegisterBO acptBusinRegisterBO);}

责任链第一次执行的实现：


@Slf4j
@Order(1)
@Service
@RequiredArgsConstructor
public class AcptFormExistsCheckImpl implements AcptRegisterService{private final AcptformCtrl acptformCtrl;@Overridepublic void check(AcptRegisterBO checkBO) {//写自己的业务逻辑Boolean counter = BpsCommonUtils.isCounterSystem(checkBO.getOpEntrustWay());if (counter) {return;} else if (StringUtils.isBlank(checkBO.getAcptEnrouteField())){// 如果【受理在途校验字段】为空，则校验结束return;}
}

责任链第二次执行的实现：

@Slf4j
@Order(2)
@Service
@RequiredArgsConstructor
public class Eservice724ConfigCheckImpl implements AcptRegisterService{private final AcptTemplateComCtrl acptTemplateComCtrl;private final String STAGING_PROCESS_INSTANCE = "stagingance";/***** @param acptRegisterBO */@Overridepublic void check(AcptRegisterBO acptRegisterBO ) {Character config76135 = SysConfigUtils.getCharConfig(HsSysConfigConstants.SYSCONFIG_76135);if (CHARACTOR_1 != config76135) {// 76135开关关闭时，不校验return;}Acpttpl acpttpl = acptTemplateComCtrl.getAcpttpl(acptBusinRegisterCheckBO.getAcptBusinId());if (acpttpl.getAcptType() != BUSIN) {// 参数类、运营类的业务受理模板没有7*24小时受理开关，不校验return;}

责任链第三次执行的实现：

@Slf4j
@Order(3)
@Service
public class ApprovalNodeCheckImpl implements AcptRegisterService{@Autowiredprivate AcptTemplateCtrl acptTemplateCtrl;@Autowiredprivate AcptTemplateComCtrl acptTemplateComCtrl;@Autowiredprivate DependenceConfigCtrl dependenceConfigCtrl;@CloudReferenceprivate WFProcessDefinitionService wfProcessDefinitionService;//    @Value("${approval.node.acptBusinIds}")
//    private String acptBusinIds;/***登记校验** @param acptRegisterBO */@Overridepublic void check(AcptRegisterBO acptRegisterBO ) {// 柜台接口不需要人工审核接口校验Boolean counter = BpsCommonUtils.isCounterSystem(acptBusinRegisterCheckBO.getOpEntrustWay());if (counter) {return;}String acptBusinIds = dependenceConfigCtrl.getApprovalNodeBusinIds();String acptBusinId = acptBusinRegisterCheckBO.getAcptBusinId();log.info("需要检测人工节点的业务编号：{}", acptBusinId);if (StringUtils.isNoneBlank(acptBusinIds)) {boolean present = Arrays.stream(StringUtils.split(acptBusinIds, ",")).anyMatch(e -> StringUtils.equals(e, acptBusinId));// 不存在需要校验的业务编号，无需处理if (!present) {return;}}

具体的应用：

  @Autowiredprivate List<AcptRegisterService > acptRegisterServiceList;/*** 受理信息登记** @param input 入参* @return*/public PostBpsacptformRegistOutput postBpsacptformRegist(PostBpsacptformRegistInput input) {PostBpsacptformRegistOutput output = new PostBpsacptformRegistOutput();// 1.登记检查AcptRegisterBO acptRegisterBO = new AcptRegisterBO ();DataCopyUtil.copyData(input, acptBusinRegisterCheckBO);//******************* 1.在途校验 2.业务受理时间校验 3.人工审核节点校验 ************//acptRegisterServiceList.forEach(e -> e.check(acptRegisterBO ));
}