• 设计模式-组合模式（决策树）

    一、只如初见

            组合模式也许大家第一联想到的就是把两个模块组合起来使用，其实好像是这样也其实不是这样，废话不多说，学习一件新的事物总要先了解一下他的概念，老规矩先上概念（摘自百度百科）：

    组合模式_百度百科组合模式，将对象组合成树形结构以表示“部分-整体”的层次结构。https://baike.baidu.com/item/%E7%BB%84%E5%90%88%E6%A8%A1%E5%BC%8F/1441281?fromModule=lemma_inlink

           看完概念想了一下完全和自己想的不一样，最近在看重学Java设计模式其中就讲到了这篇设计模式，其中讲的很容易理解（没有官方的晦涩哈），把其中的精华拿出来与大家分享；给大家的建议就是可能看一遍觉得似懂非懂，但是写一遍就会发现茅塞顿开。

    二、登堂入室

            相信大家都玩过积木或者乐高玩具，其中每个零部件都是有自己的职责以及功能的。比如说小汽车光有轮子他是无法行走的，必须得有发动机，底盘，车身，电器设备等等部件组成。

            像这种利用ABCD功能组合对外提供服务就类似组合模式。对于代码实现有什么特点？那么这使用有他对于项目有什么好处呢？对于加入他对于团队有什么好处呢？灵魂三问，也许你也有类似的问题在脑海中循环，就像这样子。

    开个玩笑让大家紧绷的思维放松一下,下面言归正传。

    三、抽丝剥茧

    3.1 实现特点

    什么？你看完这个还是有点迷糊。确实这样有点官方，如果这样不太好理解可以看下这个图：

    这样大概就好解释了，假设产品有一个业务诉求先找到了经理，经理说我知道谁能做这个事，找到了A组长，A组长了解了下需求把具体的任务分配到了对应的工程师；相信看完我说的这些各位大概心里有点朦胧的概念了，已经跃跃欲试了；别着急，我们接着往下看。

    3.2加入项目中的优势/对于团队好处

            前面我们了解到这种设计模式其实就是一个类似树型结构，递归去查找对应的功能，可以让代码易于扩展和维护，更降低团队的维护成本，最重要的是避免接班的伙伴的吐槽。这时候就有人反驳了，我觉得不尽然，这玩意不就是我加个if else的事么需要搞的这么高深莫测么？有疑问是正常的，我刚开始看的时候也有类似的疑问不过相信大家看完后面的就觉得不会有类似的疑问了。

    四、举一反三

            前面我们讲到其实这种设计模式也没啥好处，对于实现功能来说就是一个if else 的事，下面我们就来举个例子让大家思考下为什么要用这个例子。

    4.1   反例     

    下面以一个产品与研发的实际业务场景来举例：

    日期需求程序员（内心独白）
    星期一（早上）哥哥，业务说有一个紧急需求，要在这里加一个判断根据不同渠道发放不同激励。行吧。（也不难，这里加个判断就能上线）

    星期二

    （下午）

    		哥哥，上线效果非常不错，业务说要按不同业务类型的在细分下，激励团队。也不难。（加个类型判断上线吧）

    星期三

    （晚上）

    		喂，睡了吗？业务说这次搞的划分非常不错，还要在细分下按照团队销量来细分下。行吧，加。（已经意识到 if else有点多了）

    星期四

    （凌晨）

    		哇，你们太棒了，上线真快，有一个小要求，需要调整下根据团队中个人销量来细分下激励。好吧，加。（一大堆if else 要修改）

    星期五

    （半夜）

    		喂，坏了，怎么发的激励不对了，业务那边开始投诉了，你快看看是什么问题。（留下了悔恨的泪水）

    代码实现：

    1. public class EngineController {
    2.  
    3.     private Logger logger = LoggerFactory.getLogger(EngineController.class);
    4.  
    5.     public String process(final String channelId, final String userId, final BigDecimal teamSalesVolume,final BigDecimal salesVolume) {
    6.  
    7.         logger.info("ifelse实现方式判断用户结果。channelId：{} userId：{} teamSalesVolume：{} salesVolume：{}", channelId, userId, teamSalesVolume,salesVolume);
    8.  
    9.         if ("0001".equals(channelId)) {
    10.             if (new BigDecimal("1000").compareTo(teamSalesVolume)>0||new BigDecimal("1000").compareTo(salesVolume)>0) {
    11.                 return "奖励A";
    12.             }
    13.  
    14.             if (new BigDecimal("1000").compareTo(teamSalesVolume)<=0||new BigDecimal("1000").compareTo(salesVolume)<=0) {
    15.                 return "奖励B";
    16.             }
    17.         }
    18.  
    19.         if ("0002".equals(channelId)) {
    20.             if (new BigDecimal("1000").compareTo(teamSalesVolume)>0||new BigDecimal("1000").compareTo(salesVolume)>0) {
    21.                 return "奖励C";
    22.             }
    23.  
    24.             if (new BigDecimal("1000").compareTo(teamSalesVolume)<=0||new BigDecimal("1000").compareTo(salesVolume)<=0) {
    25.                 return "奖励D";
    26.             }
    27.         }
    28.  
    29.         return null;
    30.  
    31.     }
    32.  
    33.  
    34. }

            从上面的结果来看无疑是最快的方式实现了对应的逻辑，但是后续如果if else 太多了就会变成最终的烂代码对后续的维护和迭代造成不同程度的影响。

    4.2 正例

    工程目录

    下面我们开始按层级讲解对应模块功能以及作用 

    4.2.1 LogicFilter原始过滤接口

    LogicFilter ：原始过滤接口，定义了原始行为方法，逻辑决策器方法，获取决策值方法，每一个提供决策能力的节点必须实现此接口。

    1. package cn.test.design.domain.service.logic;
    2.  
    3. import java.util.List;
    4. import java.util.Map;
    5.  
    6. import cn.test.design.domain.model.vo.TreeNodeLink;
    7.  
    8. /**
    9.  * 原始决策过滤器
    10.  */
    11. public interface LogicFilter {
    12.  
    13.     /**
    14.      * 逻辑决策器
    15.      *
    16.      * @param matterValue          决策值
    17.      * @param treeNodeLineInfoList 决策节点
    18.      * @return 下一个节点Id
    19.      */
    20.     Long filter(String matterValue, List treeNodeLineInfoList);
    21.  
    22.     /**
    23.      * 获取决策值
    24.      *
    25.      * @param decisionMatter 决策物料
    26.      * @return 决策值
    27.      */
    28.     String matterValue(Long treeId, String userId, Map decisionMatter);
    29.  
    30. }

    4.2.2 BaseLogic抽象基本实现

    BaseLogic：抽象基本实现了LogicFilter 中基本的决策逻辑根据不同类型大于等于，小于等判断逻辑，同时定义了抽象方法让实现他的类都必须实现获取决策值方法，这个决策值用于逻辑对比。

    1. package cn.test.design.domain.service.logic;
    2.  
    3.  
    4. import java.util.List;
    5. import java.util.Map;
    6.  
    7. import cn.test.design.domain.model.vo.TreeNodeLink;
    8.  
    9. /**
    10.  * 过滤器抽象基本实现实现，实现基本基本决策逻辑
    11.  */
    12. public abstract class BaseLogic implements LogicFilter {
    13. 	
    14. 	/**
    15. 	 * 实现基本基本决策逻辑
    16. 	 */
    17.     @Override
    18.     public Long filter(String matterValue, List treeNodeLinkList) {
    19.         for (TreeNodeLink nodeLine : treeNodeLinkList) {
    20.             if (decisionLogic(matterValue, nodeLine)) return nodeLine.getNodeIdTo();
    21.         }
    22.         return 0L;
    23.     }
    24.     
    25.     /**
    26.      * 让子类必须实现获取决策值的方法用于对比获取最终的结果
    27.      */
    28.     @Override
    29.     public abstract String matterValue(Long treeId, String userId, Map decisionMatter);
    30.  
    31.     private boolean decisionLogic(String matterValue, TreeNodeLink nodeLink) {
    32.         switch (nodeLink.getRuleLimitType()) {
    33.             case 1:
    34.                 return matterValue.equals(nodeLink.getRuleLimitValue());
    35.             case 2:
    36.                 return Double.parseDouble(matterValue) > Double.parseDouble(nodeLink.getRuleLimitValue());
    37.             case 3:
    38.                 return Double.parseDouble(matterValue) < Double.parseDouble(nodeLink.getRuleLimitValue());
    39.             case 4:
    40.                 return Double.parseDouble(matterValue) <= Double.parseDouble(nodeLink.getRuleLimitValue());
    41.             case 5:
    42.                 return Double.parseDouble(matterValue) >= Double.parseDouble(nodeLink.getRuleLimitValue());
    43.             default:
    44.                 return false;
    45.         }
    46.     }
    47.  
    48. }

    4.2.3 树根节点实现（ChannelGenderFilter，UserSalesVolumeFilter）

    这里我们目前业务场景只用到了渠道与销售额所以目前只定义了两种如果实际需要可以定义更多哦；当然目前是直接获取物料值，实际开发中肯定是根据配置文件或从rpc接口或从数据库中获取对应需要的信息。

    ChannelGenderFilter：渠道节点

    1. package cn.test.design.domain.service.logic.impl;
    2.  
    3. import java.util.Map;
    4.  
    5. import cn.test.design.domain.service.logic.BaseLogic;
    6.  
    7. /**
    8.  * 
    9.  * 渠道基本过滤器
    10.  *
    11.  */
    12. public class ChannelGenderFilter extends BaseLogic {
    13.  
    14. 	@Override
    15. 	public String matterValue(Long treeId, String userId, Map decisionMatter) {
    16. 		// 目前是直接获取物料值，实际开发中肯定是根据配置文件或从rpc接口或从数据库中获取对应需要的信息。
    17. 		return decisionMatter.get("channel");
    18. 	}
    19.  
    20. }

    UserSalesVolumeFilter：用户销售额

    1. package cn.test.design.domain.service.logic.impl;
    2.  
    3. import java.util.Map;
    4.  
    5. import cn.test.design.domain.service.logic.BaseLogic;
    6. /**
    7.  * 用户销售额过滤器
    8.  *
    9.  */
    10. public class UserSalesVolumeFilter extends BaseLogic {
    11.  
    12.     @Override
    13.     public String matterValue(Long treeId, String userId, Map decisionMatter) {
    14.     	// 目前是直接获取物料值，实际开发中肯定是根据配置文件或从rpc接口或从数据库中获取对应需要的信息.
    15.     	return decisionMatter.get("userSalesVolume");
    16.     }
    17.  
    18. }

    4.2.4 IEngine决策引擎

            提供给调用方的决策引擎接口，定义好了对应的方法后续如果有新的决策逻辑可以实现对应方法。

    1. package cn.test.design.domain.service.engine;
    2.  
    3. import java.util.Map;
    4.  
    5. import cn.test.design.domain.model.aggregates.TreeRich;
    6. import cn.test.design.domain.model.vo.EngineResult;
    7.  
    8. /**
    9.  * 决策引擎接口
    10.  *
    11.  */
    12. public interface IEngine {
    13. 	
    14.     EngineResult process(final Long treeId, final String userId, TreeRich treeRich, final Map decisionMatter);
    15.  
    16. }

    4.2.5 EngineConfig 决策节点配置

            这里的决策配置目前是固定的两个树根节点实现（ChannelGenderFilter，UserSalesVolumeFilter）实际场景是把需要的实现配置到表中，可以方便在运营后台配置。

    1. package cn.test.design.domain.service.engine;
    2.  
    3.  
    4. import java.util.Map;
    5. import java.util.concurrent.ConcurrentHashMap;
    6.  
    7. import cn.test.design.domain.service.logic.LogicFilter;
    8. import cn.test.design.domain.service.logic.impl.ChannelGenderFilter;
    9. import cn.test.design.domain.service.logic.impl.UserSalesVolumeFilter;
    10.  
    11. /**
    12.  * 
    13.  * 决策节点配置，此处可以配置至数据库中方便后续界面操作维护
    14.  *
    15.  */
    16. public class EngineConfig {
    17.  
    18.     static Map logicFilterMap;
    19.  
    20.     static {
    21.         logicFilterMap = new ConcurrentHashMap<>();
    22.         logicFilterMap.put("channel", new ChannelGenderFilter());
    23.         logicFilterMap.put("userSalesVolume", new UserSalesVolumeFilter());
    24.     }
    25.  
    26.     public Map getLogicFilterMap() {
    27.         return logicFilterMap;
    28.     }
    29.  
    30.     @SuppressWarnings("static-access")
    31. 	public void setLogicFilterMap(Map logicFilterMap) {
    32.         this.logicFilterMap = logicFilterMap;
    33.     }
    34.  
    35. }

    4.2.6 EngineBase 基础决策引擎

            这里是主要决策树处理流程，有点像找树叶的果实一样。同时实现了IEngine 基础决策引擎

    但是只是提供了抽像并没有实现，由最终的决策实现类引擎实现。

    1. package cn.test.design.domain.service.engine;
    2.  
    3. import java.util.Map;
    4.  
    5. import org.slf4j.Logger;
    6. import org.slf4j.LoggerFactory;
    7.  
    8. import cn.test.design.domain.model.aggregates.TreeRich;
    9. import cn.test.design.domain.model.vo.EngineResult;
    10. import cn.test.design.domain.model.vo.TreeNode;
    11. import cn.test.design.domain.model.vo.TreeRoot;
    12. import cn.test.design.domain.service.logic.LogicFilter;
    13.  
    14. /**
    15.  * 决策树引擎
    16.  */
    17. public abstract class EngineBase extends EngineConfig implements IEngine {
    18.  
    19.     private Logger logger = LoggerFactory.getLogger(EngineBase.class);
    20.  
    21.     @Override
    22.     public abstract EngineResult process(Long treeId, String userId, TreeRich treeRich, Map decisionMatter);
    23.  
    24.     protected TreeNode engineDecisionMaker(TreeRich treeRich, Long treeId, String userId, Map decisionMatter) {
    25.         TreeRoot treeRoot = treeRich.getTreeRoot();
    26.         Map treeNodeMap = treeRich.getTreeNodeMap();
    27.         // 规则树根ID
    28.         Long rootNodeId = treeRoot.getTreeRootNodeId();
    29.         TreeNode treeNodeInfo = treeNodeMap.get(rootNodeId);
    30.         //循环获取对应的处理节点直到获取到对应的结果
    31.         //节点类型[NodeType]；1子叶、2果实 我们只需要使用果实
    32.         while (treeNodeInfo.getNodeType().equals(1)) {
    33.             //对应处理规则key用于获取对应实现LogicFilter 的处理节点主要用来获取物料中用于对比的相关值
    34.         	String ruleKey = treeNodeInfo.getRuleKey();
    35.         	//实际的处理节点
    36.             LogicFilter logicFilter = logicFilterMap.get(ruleKey);
    37.             String matterValue = logicFilter.matterValue(treeId, userId, decisionMatter);
    38.             //基础决策抽象中的能力，使用物料值判断使用那个决策节点（获取的是下一个节点）
    39.             Long nextNode = logicFilter.filter(matterValue, treeNodeInfo.getTreeNodeLinkList());
    40.             //赋值对应的处理节点，直到找到期望的处理节点（我们这里是最终的果实节点）
    41.             treeNodeInfo = treeNodeMap.get(nextNode);
    42.             logger.info("决策树引擎=>{} userId：{} treeId：{} treeNode：{} ruleKey：{} matterValue：{}", treeRoot.getTreeName(), userId, treeId, treeNodeInfo.getTreeNodeId(), ruleKey, matterValue);
    43.         }
    44.         return treeNodeInfo;
    45.     }
    46.  
    47. }

    4.2.7 TreeEngineHandle 基础决策引擎实现

            这里基本都比较简单直接使用用户传递的对应值传入对应方法即可获取到对应结果

    1. package cn.test.design.domain.service.engine.impl;
    2.  
    3. import java.util.Map;
    4.  
    5. import cn.test.design.domain.model.aggregates.TreeRich;
    6. import cn.test.design.domain.model.vo.EngineResult;
    7. import cn.test.design.domain.model.vo.TreeNode;
    8. import cn.test.design.domain.service.engine.EngineBase;
    9. /**
    10.  * 基础决策引擎实现
    11.  *
    12.  */
    13. public class TreeEngineHandle extends EngineBase {
    14.  
    15.     @Override
    16.     public EngineResult process(Long treeId, String userId, TreeRich treeRich, Map decisionMatter) {
    17.         // 决策流程
    18.         TreeNode treeNode = engineDecisionMaker(treeRich, treeId, userId, decisionMatter);
    19.         // 决策结果
    20.         return new EngineResult(userId, treeId, treeNode.getTreeNodeId(), treeNode.getNodeValue());
    21.     }
    22.  
    23. }

    4.2.8 单元测试

            这里的初始化配置目前均为手动配置，实际代码可以使用数据库配置动态配置所需要的节点信息。

    1. package cn.test.design.test;
    2.  
    3. import java.util.ArrayList;
    4. import java.util.HashMap;
    5. import java.util.List;
    6. import java.util.Map;
    7.  
    8. import org.junit.Before;
    9. import org.junit.Test;
    10. import org.slf4j.Logger;
    11. import org.slf4j.LoggerFactory;
    12.  
    13. import com.alibaba.fastjson.JSON;
    14.  
    15. import cn.test.design.domain.model.aggregates.TreeRich;
    16. import cn.test.design.domain.model.vo.EngineResult;
    17. import cn.test.design.domain.model.vo.TreeNode;
    18. import cn.test.design.domain.model.vo.TreeNodeLink;
    19. import cn.test.design.domain.model.vo.TreeRoot;
    20. import cn.test.design.domain.service.engine.IEngine;
    21. import cn.test.design.domain.service.engine.impl.TreeEngineHandle;
    22.  
    23. public class ApiTest {
    24.  
    25.     private Logger logger = LoggerFactory.getLogger(ApiTest.class);
    26.  
    27.     private TreeRich treeRich;
    28.  
    29.     @Before
    30.     public void init() {
    31.  
    32.         // 节点：1
    33.         TreeNode treeNode_01 = new TreeNode();
    34.         treeNode_01.setTreeId(10001L);
    35.         treeNode_01.setTreeNodeId(1L);
    36.         treeNode_01.setNodeType(1);
    37.         treeNode_01.setNodeValue(null);
    38.         treeNode_01.setRuleKey("channel");
    39.         treeNode_01.setRuleDesc("渠道");
    40.  
    41.         // 链接：1->11
    42.         TreeNodeLink treeNodeLink_11 = new TreeNodeLink();
    43.         treeNodeLink_11.setNodeIdFrom(1L);
    44.         treeNodeLink_11.setNodeIdTo(11L);
    45.         treeNodeLink_11.setRuleLimitType(1);
    46.         treeNodeLink_11.setRuleLimitValue("0001");
    47.  
    48.         // 链接：1->12
    49.         TreeNodeLink treeNodeLink_12 = new TreeNodeLink();
    50.         treeNodeLink_12.setNodeIdTo(1L);
    51.         treeNodeLink_12.setNodeIdTo(12L);
    52.         treeNodeLink_12.setRuleLimitType(1);
    53.         treeNodeLink_12.setRuleLimitValue("0002");
    54.  
    55.         List treeNodeLinkList_1 = new ArrayList<>();
    56.         treeNodeLinkList_1.add(treeNodeLink_11);
    57.         treeNodeLinkList_1.add(treeNodeLink_12);
    58.  
    59.         treeNode_01.setTreeNodeLinkList(treeNodeLinkList_1);
    60.  
    61.         // 节点：11
    62.         TreeNode treeNode_11 = new TreeNode();
    63.         treeNode_11.setTreeId(10001L);
    64.         treeNode_11.setTreeNodeId(11L);
    65.         treeNode_11.setNodeType(1);
    66.         treeNode_11.setNodeValue(null);
    67.         treeNode_11.setRuleKey("userSalesVolume");
    68.         treeNode_11.setRuleDesc("销售额A");
    69.  
    70.         // 链接：11->111
    71.         TreeNodeLink treeNodeLink_111 = new TreeNodeLink();
    72.         treeNodeLink_111.setNodeIdFrom(11L);
    73.         treeNodeLink_111.setNodeIdTo(111L);
    74.         treeNodeLink_111.setRuleLimitType(3);
    75.         treeNodeLink_111.setRuleLimitValue("25");
    76.  
    77.         // 链接：11->112
    78.         TreeNodeLink treeNodeLink_112 = new TreeNodeLink();
    79.         treeNodeLink_112.setNodeIdFrom(11L);
    80.         treeNodeLink_112.setNodeIdTo(112L);
    81.         treeNodeLink_112.setRuleLimitType(5);
    82.         treeNodeLink_112.setRuleLimitValue("25");
    83.  
    84.         List treeNodeLinkList_11 = new ArrayList<>();
    85.         treeNodeLinkList_11.add(treeNodeLink_111);
    86.         treeNodeLinkList_11.add(treeNodeLink_112);
    87.  
    88.         treeNode_11.setTreeNodeLinkList(treeNodeLinkList_11);
    89.  
    90.         // 节点：12
    91.         TreeNode treeNode_12 = new TreeNode();
    92.         treeNode_12.setTreeId(10001L);
    93.         treeNode_12.setTreeNodeId(12L);
    94.         treeNode_12.setNodeType(1);
    95.         treeNode_12.setNodeValue(null);
    96.         treeNode_12.setRuleKey("userSalesVolume");
    97.         treeNode_12.setRuleDesc("销售额B");
    98.  
    99.         // 链接：12->121
    100.         TreeNodeLink treeNodeLink_121 = new TreeNodeLink();
    101.         treeNodeLink_121.setNodeIdFrom(12L);
    102.         treeNodeLink_121.setNodeIdTo(121L);
    103.         treeNodeLink_121.setRuleLimitType(3);
    104.         treeNodeLink_121.setRuleLimitValue("25");
    105.  
    106.         // 链接：12->122
    107.         TreeNodeLink treeNodeLink_122 = new TreeNodeLink();
    108.         treeNodeLink_122.setNodeIdFrom(12L);
    109.         treeNodeLink_122.setNodeIdTo(122L);
    110.         treeNodeLink_122.setRuleLimitType(5);
    111.         treeNodeLink_122.setRuleLimitValue("25");
    112.  
    113.         List treeNodeLinkList_12 = new ArrayList<>();
    114.         treeNodeLinkList_12.add(treeNodeLink_121);
    115.         treeNodeLinkList_12.add(treeNodeLink_122);
    116.  
    117.         treeNode_12.setTreeNodeLinkList(treeNodeLinkList_12);
    118.  
    119.         // 节点：111
    120.         TreeNode treeNode_111 = new TreeNode();
    121.         treeNode_111.setTreeId(10001L);
    122.         treeNode_111.setTreeNodeId(111L);
    123.         treeNode_111.setNodeType(2);
    124.         treeNode_111.setNodeValue("果实A");
    125.  
    126.         // 节点：112
    127.         TreeNode treeNode_112 = new TreeNode();
    128.         treeNode_112.setTreeId(10001L);
    129.         treeNode_112.setTreeNodeId(112L);
    130.         treeNode_112.setNodeType(2);
    131.         treeNode_112.setNodeValue("果实B");
    132.  
    133.         // 节点：121
    134.         TreeNode treeNode_121 = new TreeNode();
    135.         treeNode_121.setTreeId(10001L);
    136.         treeNode_121.setTreeNodeId(121L);
    137.         treeNode_121.setNodeType(2);
    138.         treeNode_121.setNodeValue("果实C");
    139.  
    140.         // 节点：122
    141.         TreeNode treeNode_122 = new TreeNode();
    142.         treeNode_122.setTreeId(10001L);
    143.         treeNode_122.setTreeNodeId(122L);
    144.         treeNode_122.setNodeType(2);
    145.         treeNode_122.setNodeValue("果实D");
    146.  
    147.         // 树根
    148.         TreeRoot treeRoot = new TreeRoot();
    149.         treeRoot.setTreeId(10001L);
    150.         treeRoot.setTreeRootNodeId(1L);
    151.         treeRoot.setTreeName("规则决策树");
    152.  
    153.         Map treeNodeMap = new HashMap<>();
    154.         treeNodeMap.put(1L, treeNode_01);
    155.         treeNodeMap.put(11L, treeNode_11);
    156.         treeNodeMap.put(12L, treeNode_12);
    157.         treeNodeMap.put(111L, treeNode_111);
    158.         treeNodeMap.put(112L, treeNode_112);
    159.         treeNodeMap.put(121L, treeNode_121);
    160.         treeNodeMap.put(122L, treeNode_122);
    161.  
    162.         treeRich = new TreeRich(treeRoot, treeNodeMap);
    163.  
    164.     }
    165.  
    166.     @Test
    167.     public void test_tree() {
    168.         logger.info("决策树组合结构信息：\r\n" + JSON.toJSONString(treeRich));
    169.  
    170.         IEngine treeEngineHandle = new TreeEngineHandle();
    171.  
    172.         /**
    173.          * 测试数据
    174.          * 果实A：gender=man、age=22
    175.          * 果实B：gender=man、age=29
    176.          * 果实C：gender=woman、age=22
    177.          * 果实D：gender=woman、age=29
    178.          */
    179.         Map decisionMatter = new HashMap<>();
    180.         decisionMatter.put("channel", "0001");
    181.         decisionMatter.put("userSalesVolume", "29");
    182.  
    183.         EngineResult result = treeEngineHandle.process(10001L, "Oli09pLkdjh", treeRich, decisionMatter);
    184.         logger.info("测试结果：{}", JSON.toJSONString(result));
    185.  
    186.     }
    187.  
    188.     @Test
    189.     public void t() {
    190.         
    191.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01000011", 2)).trim()));
    192.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01101111", 2)).trim()));
    193.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01100100", 2)).trim()));
    194.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01101001", 2)).trim()));
    195.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01101110", 2)).trim()));
    196.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01100111", 2)).trim()));
    197.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01001000", 2)).trim()));
    198.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01100101", 2)).trim()));
    199.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01101100", 2)).trim()));
    200.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01110000", 2)).trim()));
    201.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01110011", 2)).trim()));
    202.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01001100", 2)).trim()));
    203.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01101001", 2)).trim()));
    204.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01100110", 2)).trim()));
    205.         System.out.println(hexStringToString(String.format("%21X", Long.parseLong("01100101", 2)).trim()));
    206.     }
    207.  
    208.     public static String hexStringToString(String s) {
    209.         if (s == null || s.equals("")) {
    210.             return null;
    211.         }
    212.         s = s.replace(" ", "");
    213.         byte[] baKeyword = new byte[s.length() / 2];
    214.         for (int i = 0; i < baKeyword.length; i++) {
    215.             try {
    216.                 baKeyword[i] = (byte) (0xff & Integer.parseInt(s.substring(i * 2, i * 2 + 2), 16));
    217.             } catch (Exception e) {
    218.                 e.printStackTrace();
    219.             }
    220.         }
    221.         try {
    222.             s = new String(baKeyword, "UTF-8");
    223.             new String();
    224.         } catch (Exception e1) {
    225.             e1.printStackTrace();
    226.         }
    227.         return s;
    228.     }
    229. }

    4.2.9 相关基础节点类

            这里写下相关基础类

    cn.test.design.domain.model.aggregatesTreeRich

    规则树聚合

    组织树各节点（叶子，果实）

    cn.test.design.domain.model.voEngineResult决策结果
    cn.test.design.domain.model.voTreeNode规则树节点信息
    cn.test.design.domain.model.voTreeNodeLink规则树线信息 链接叶子节点和果实节点
    cn.test.design.domain.model.voTreeRoot树根信息

    规则树聚合TreeRich

    1. package cn.test.design.domain.model.aggregates;
    2.  
    3. import java.util.Map;
    4.  
    5. import cn.test.design.domain.model.vo.TreeNode;
    6. import cn.test.design.domain.model.vo.TreeRoot;
    7.  
    8. /**
    9.  * 规则树聚合
    10.  */
    11. public class TreeRich {
    12. 	// 树根信息
    13. 	private TreeRoot treeRoot;
    14. 	// 树节点ID -> 子节点
    15. 	private Map treeNodeMap;
    16.  
    17. 	public TreeRich(TreeRoot treeRoot, Map treeNodeMap) {
    18. 		this.treeRoot = treeRoot;
    19. 		this.treeNodeMap = treeNodeMap;
    20. 	}
    21.  
    22. 	public TreeRoot getTreeRoot() {
    23. 		return treeRoot;
    24. 	}
    25.  
    26. 	public void setTreeRoot(TreeRoot treeRoot) {
    27. 		this.treeRoot = treeRoot;
    28. 	}
    29.  
    30. 	public Map getTreeNodeMap() {
    31. 		return treeNodeMap;
    32. 	}
    33.  
    34. 	public void setTreeNodeMap(Map treeNodeMap) {
    35. 		this.treeNodeMap = treeNodeMap;
    36. 	}
    37. }

    决策结果EngineResult

    1. package cn.test.design.domain.model.vo;
    2.  
    3. /**
    4.  * 决策结果
    5.  */
    6. public class EngineResult {
    7.  
    8. 	// 执行结果
    9. 	private boolean isSuccess;
    10. 	// 用户ID
    11. 	private String userId;
    12. 	// 规则树ID
    13. 	private Long treeId;
    14. 	// 果实节点ID
    15. 	private Long nodeId;
    16. 	// 果实节点值
    17. 	private String nodeValue;
    18.  
    19. 	public EngineResult() {
    20. 	}
    21.  
    22. 	public EngineResult(boolean isSuccess) {
    23. 		this.isSuccess = isSuccess;
    24. 	}
    25.  
    26. 	public EngineResult(String userId, Long treeId, Long nodeId, String nodeValue) {
    27. 		this.isSuccess = true;
    28. 		this.userId = userId;
    29. 		this.treeId = treeId;
    30. 		this.nodeId = nodeId;
    31. 		this.nodeValue = nodeValue;
    32. 	}
    33.  
    34. 	public boolean isSuccess() {
    35. 		return isSuccess;
    36. 	}
    37.  
    38. 	public void setSuccess(boolean success) {
    39. 		isSuccess = success;
    40. 	}
    41.  
    42. 	public String getUserId() {
    43. 		return userId;
    44. 	}
    45.  
    46. 	public void setUserId(String userId) {
    47. 		this.userId = userId;
    48. 	}
    49.  
    50. 	public Long getTreeId() {
    51. 		return treeId;
    52. 	}
    53.  
    54. 	public void setTreeId(Long treeId) {
    55. 		this.treeId = treeId;
    56. 	}
    57.  
    58. 	public Long getNodeId() {
    59. 		return nodeId;
    60. 	}
    61.  
    62. 	public void setNodeId(Long nodeId) {
    63. 		this.nodeId = nodeId;
    64. 	}
    65.  
    66. 	public String getNodeValue() {
    67. 		return nodeValue;
    68. 	}
    69.  
    70. 	public void setNodeValue(String nodeValue) {
    71. 		this.nodeValue = nodeValue;
    72. 	}
    73. }

    规则树节点信息 TreeNode

    1. package cn.test.design.domain.model.vo;
    2.  
    3. import java.util.List;
    4.  
    5. /**
    6.  * 规则树节点信息
    7.  */
    8. public class TreeNode {
    9.  
    10. 	// 规则树ID
    11. 	private Long treeId;
    12. 	// 规则树节点ID
    13. 	private Long treeNodeId;
    14. 	// 节点类型；1叶子、2 果实
    15. 	private Integer nodeType;
    16. 	// 节点值[nodeType=2]；果实值
    17. 	private String nodeValue;
    18. 	// 规则Key
    19. 	private String ruleKey;
    20. 	// 规则描述
    21. 	private String ruleDesc;
    22. 	// 节点链路
    23. 	private List treeNodeLinkList; 
    24.  
    25. 	public Long getTreeId() {
    26. 		return treeId;
    27. 	}
    28.  
    29. 	public void setTreeId(Long treeId) {
    30. 		this.treeId = treeId;
    31. 	}
    32.  
    33. 	public Long getTreeNodeId() {
    34. 		return treeNodeId;
    35. 	}
    36.  
    37. 	public void setTreeNodeId(Long treeNodeId) {
    38. 		this.treeNodeId = treeNodeId;
    39. 	}
    40.  
    41. 	public Integer getNodeType() {
    42. 		return nodeType;
    43. 	}
    44.  
    45. 	public void setNodeType(Integer nodeType) {
    46. 		this.nodeType = nodeType;
    47. 	}
    48.  
    49. 	public String getNodeValue() {
    50. 		return nodeValue;
    51. 	}
    52.  
    53. 	public void setNodeValue(String nodeValue) {
    54. 		this.nodeValue = nodeValue;
    55. 	}
    56.  
    57. 	public String getRuleKey() {
    58. 		return ruleKey;
    59. 	}
    60.  
    61. 	public void setRuleKey(String ruleKey) {
    62. 		this.ruleKey = ruleKey;
    63. 	}
    64.  
    65. 	public String getRuleDesc() {
    66. 		return ruleDesc;
    67. 	}
    68.  
    69. 	public void setRuleDesc(String ruleDesc) {
    70. 		this.ruleDesc = ruleDesc;
    71. 	}
    72.  
    73. 	public List getTreeNodeLinkList() {
    74. 		return treeNodeLinkList;
    75. 	}
    76.  
    77. 	public void setTreeNodeLinkList(List treeNodeLinkList) {
    78. 		this.treeNodeLinkList = treeNodeLinkList;
    79. 	}
    80.  
    81. }

    规则树线信息 链接叶子节点和果实节点 TreeNodeLink

    1. package cn.test.design.domain.model.vo;
    2.  
    3. /**
    4.  * 规则树线信息 链接叶子节点和果实节点
    5.  */
    6. public class TreeNodeLink {
    7.  
    8. 	// 节点From
    9. 	private Long nodeIdFrom;
    10. 	// 节点To
    11. 	private Long nodeIdTo;
    12. 	// 限定类型；1:=;2:>;3:<;4:>=;5<=;6:enum[枚举范围]
    13. 	private Integer ruleLimitType;
    14. 	// 限定值
    15. 	private String ruleLimitValue;
    16.  
    17. 	public Long getNodeIdFrom() {
    18. 		return nodeIdFrom;
    19. 	}
    20.  
    21. 	public void setNodeIdFrom(Long nodeIdFrom) {
    22. 		this.nodeIdFrom = nodeIdFrom;
    23. 	}
    24.  
    25. 	public Long getNodeIdTo() {
    26. 		return nodeIdTo;
    27. 	}
    28.  
    29. 	public void setNodeIdTo(Long nodeIdTo) {
    30. 		this.nodeIdTo = nodeIdTo;
    31. 	}
    32.  
    33. 	public Integer getRuleLimitType() {
    34. 		return ruleLimitType;
    35. 	}
    36.  
    37. 	public void setRuleLimitType(Integer ruleLimitType) {
    38. 		this.ruleLimitType = ruleLimitType;
    39. 	}
    40.  
    41. 	public String getRuleLimitValue() {
    42. 		return ruleLimitValue;
    43. 	}
    44.  
    45. 	public void setRuleLimitValue(String ruleLimitValue) {
    46. 		this.ruleLimitValue = ruleLimitValue;
    47. 	}
    48. }

    树根信息 TreeRoot

    1. package cn.test.design.domain.model.vo;
    2.  
    3. /**
    4.  * 树根信息
    5.  */
    6. public class TreeRoot {
    7.  
    8. 	// 规则树ID
    9. 	private Long treeId;
    10. 	// 规则树根ID
    11. 	private Long treeRootNodeId;
    12. 	// 规则树名称
    13. 	private String treeName;
    14.  
    15. 	public Long getTreeId() {
    16. 		return treeId;
    17. 	}
    18.  
    19. 	public void setTreeId(Long treeId) {
    20. 		this.treeId = treeId;
    21. 	}
    22.  
    23. 	public Long getTreeRootNodeId() {
    24. 		return treeRootNodeId;
    25. 	}
    26.  
    27. 	public void setTreeRootNodeId(Long treeRootNodeId) {
    28. 		this.treeRootNodeId = treeRootNodeId;
    29. 	}
    30.  
    31. 	public String getTreeName() {
    32. 		return treeName;
    33. 	}
    34.  
    35. 	public void setTreeName(String treeName) {
    36. 		this.treeName = treeName;
    37. 	}
    38. }

    五、扬帆起航

            写在最后是不是发现这种模式就像电脑主机一样不同的接口是可以组合拔插的也可以随时配置不同的配置，这种模式保证了开闭原则只要前期定义好对应的结构，每次新增诉求只需要新增对应的节点即可，或者都可以做为运营后台模式由运营动态配置对应的路由规则便于后续维护。

    本文参考：

    《重学java设计模式》-付政委。

      百度百科。

  • 相关阅读:
    SpringBoot中properties和yml有什么区别？
    【JAVA基础】专题课(综合案例上)
    三个烂怂八股文，变成两个场景题，打得我一脸问号。
    计算机毕业设计 基于SSM+Vue的农业信息管理系统的设计与实现 Java实战项目 附源码+文档+视频讲解
    最新版的Python写春联，支持行书隶书楷书，不再有缺失汉字
    【ubuntu 搜狗输入法】ubuntu下搜狗输入法不能打印中文的所有问题都这样解决！
    git笔记
    煤矿皮带跑偏监测识别系统
    LDAP的理解
    jvm 的主要组成部分_java培训
  • 原文地址：https://blog.csdn.net/m0_37506254/article/details/128051240