项目中用到的责任链模式

news2025/10/31 17:07:34

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;

   
    @Override
    public 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 
     */
    @Override
    public 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{

    @Autowired
    private AcptTemplateCtrl acptTemplateCtrl;

    @Autowired
    private AcptTemplateComCtrl acptTemplateComCtrl;
    @Autowired
    private DependenceConfigCtrl dependenceConfigCtrl;

    @CloudReference
    private WFProcessDefinitionService wfProcessDefinitionService;

//    @Value("${approval.node.acptBusinIds}")
//    private String acptBusinIds;

    /**
     *登记校验
     *
     * @param acptRegisterBO 
     */
    @Override
    public 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;
            }
        }

具体的应用：

  @Autowired
    private 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 ));
}