首页 > 其他分享 >阿里开源规则引擎QLExpress-入门实战

阿里开源规则引擎QLExpress-入门实战

时间:2022-11-01 16:35:04浏览次数:41  
标签:QLExpress 入门 double promotionList 促销 System 开源 context println

规则引擎

常用的规则引擎目前主要有Drools、Aviator、Easyrule、QLExpress,如下表格是对这些规则引擎的分析对比:
在这里插入图片描述
结合本人实际项目,我们的项目业务属性是电商,对性能要求比较高,因此发现阿里开源的QLExpress更适合现实的诉求,下面的章节将以电商促销活动的例子介绍QLExpress如何落地实操到业务代码中的

电商促销活动示例

比如我们的购物车现在有两个商品,对应的商品SKU分别为11120781和11120782,商品11120781参与的单品促销优惠活动,11120782参与的是单品促销打折活动,假设这两个商品来自同一个店家,店家给的运费优惠是满100减50关于两个活动规则的介绍如下:

单品促销优惠
该活动是在商品价格基础上优惠xxx元,比如商品原价为150,促销优惠50元,则优惠后的金额为150-50=100

单品促销打折
该活动是在商品价格基础上进行折扣,比如商品原价为150,促销打折5折,则优惠后的金额为150*0.5=75

第一步 引入依赖包

如下图所示,引入QLExpress的包

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>QLExpress</artifactId>
            <version>3.2.0</version>
        </dependency>

编写针对某一类活动规则的业务接口

此接口主要处理同一类型规则的逻辑,以上述的单品促销为例,代码示例如下:

/**
     * 查询商品促销活动匹配单品促销规则计算后的优惠金额
     *
     * @param promotionList 参与的促销活动
     * @param productPrice 商品价格
     * @return
     */
    private List<Double> querySinglePromotionPrice(List<Promotion> promotionList, double productPrice) {
        List<Double> nicePrices = Lists.newArrayList();
        DefaultContext<String, Object> context = new DefaultContext<>();
        ExpressRunner expressRunner = new ExpressRunner();
        promotionList = promotionList.stream().filter(r -> "singlePromotion".equals(r.getPromotionType())).collect(Collectors.toList());
        for (Promotion promotion : promotionList) {
            //查询促销活动对应的规则模版配置信息
            RuleTemplate template = queryRuleTemplate(promotion.getPromotionType());
            String express = template.getExpress();
            context.put("price", productPrice);
            context.put("promotionType", promotion.getPromotionWay());
            context.put("promotionValue", Double.parseDouble(promotion.getPromotionValue()));

            System.out.println("参与促销活动【" + promotion.getPromotionName() + "】优惠前的商品金额:" + productPrice);
            Object execute = null;
            try {
                execute = expressRunner.execute(express, context, null, true, true);
            } catch (Exception e) {
                System.out.println("计算规则[" + template.getTemplateName() + "]时发生异常,原因:" + e.getMessage());
            }
            System.out.println("优惠后的金额:" + execute);
            nicePrices.add((Double) execute);
        }

        return nicePrices;
    }


涉及到的运费计算,代码示例如下:

private double queryMinShippingFree(List<Promotion> promotionList,double productPrice,double freeShipping ){
        DefaultContext<String, Object> context = new DefaultContext<>();
        double minShipping = 0.0;
        List<Double> niceShipping = Lists.newArrayList();
        ExpressRunner expressRunner = new ExpressRunner();
        promotionList = promotionList.stream().filter(r -> "freeShipping".equals(r.getPromotionType())).collect(Collectors.toList());
        for (Promotion promotion : promotionList) {
            RuleTemplate template = queryRuleTemplate(promotion.getPromotionType());
            String express = template.getExpress();
            String condition = promotion.getConditionConfig();
            context.put("price", productPrice);
            context.put("amount", Double.parseDouble(JSONObject.parseObject(condition).getString("amountCondition")));
            context.put("shippingPrice",freeShipping);
            context.put("promotionValue", Double.parseDouble(JSONObject.parseObject(condition).getString("promotionAmount")));

            System.out.println("参与促销活动【" + promotion.getPromotionName() + "】优惠前的运费:" + freeShipping);
            Object execute = null;
            try {
                execute = expressRunner.execute(express, context, null, true, true);
            } catch (Exception e) {
                System.out.println("计算规则[" + template.getTemplateName() + "]时发生异常,原因:" + e.getMessage());
            }
            niceShipping.add((Double) execute);
        }

        if(niceShipping.isEmpty()){
            return minShipping;
        }
        minShipping = Collections.min(niceShipping);
        System.out.println("优惠后的运费:" + minShipping);
        return minShipping;
    }

封装以上两个方法,输出购物车中的最终优惠金额,代码示例如下:

/**
     * 计算最优促销活动价格
     *
     * @param cart  购物车信息
     * @param shippingFee  运费
     * @return 计算出最优价格
     * @throws Exception
     */
    @Override
    public double queryMinPromotionPrice(String cart,double shippingFee) {
        JSONArray cartArray = JSONObject.parseArray(cart);
        double sum = 0.0,sumNicePrice = 0.0,sumNiceShipping = 0.0;
        for(int i=0;i<cartArray.size();i++){
            double minNicePrice = 0.0d;
            String productCode = cartArray.getJSONObject(i).getString("productCode");
            double productPrice = cartArray.getJSONObject(i).getDoubleValue("price");
            //查询商品参与的促销活动
            List<Promotion> promotionList = queryPromotion(productCode);
            sum += productPrice;
            //根据促销活动匹配的规则计算出优惠价格
            List<Double> nicePrices = querySinglePromotionPrice(promotionList, productPrice);
            //计算出最便宜的优惠价格
            minNicePrice = Collections.min(nicePrices);
            sumNicePrice +=minNicePrice;

            //运费
            double niceShipping = queryMinShippingFree(promotionList,productPrice,shippingFee);
            sumNiceShipping+=niceShipping;
        }
        sum = sum+shippingFee;
        System.out.println("参与促销之前购物车结算价格为:"+sum);
        sumNicePrice = sumNicePrice+sumNiceShipping;
        System.out.println("参与促销之后购物车结算价格金额:" + sumNicePrice);

        return sumNicePrice;

    }

暴露给外部的http接口,代码示例如下:

 @PostMapping("/queryMinPromotionPrice")
    public double queryMinPromotionPrice(String cart,double shippingFee) {
        System.out.println("开始获取商品优惠金额");
        long startTime = System.currentTimeMillis();
        double minPrice =  expressService.queryMinPromotionPrice(cart,shippingFee);

        System.out.println("获取商品优惠金额结束,耗时:"+(System.currentTimeMillis()-startTime)+"毫秒");
        return  minPrice;
    }

以上的这行代码 RuleTemplate template = queryRuleTemplate(promotion.getPromotionType());是代表规则表达式的模版,可以配置在数据看中,如下图所示:
在这里插入图片描述

以上代码,通过postman或者insomnia工具,执行结果如下图所示:
在这里插入图片描述

执行过程打印log信息如下图所示:

在这里插入图片描述

标签:QLExpress,入门,double,promotionList,促销,System,开源,context,println
From: https://www.cnblogs.com/sjkzy/p/16848173.html

相关文章

  • 开源字节设计思想
    面向对象的方法主要是把事物给对象化,包括其属性和行为。面向对象编程更贴近实际生活的思想。总体来说面向对象的底层还是面向过程,面向过程抽象成类,然后封装,方便使用就是面......
  • 动态规划学习入门(小白零基础)
    动态规划学习入门(小白零基础)基础概念如果某一问题可拆解成若干重叠子问题,即可用动态规划解决。重叠子问题:比如斐波那契数列F(n)可分解成F(n-1)+F(n-2),而F(n-1)又可......
  • 阿里云配置负载均衡快速入门
    慎选监听配置的高级配置“开启会话保持”功能,单机测试负截均衡,看不到调度IP切换效果负载均衡从诞生到现在也随着网络业务的变化而不断的进化,逐渐发展成为现在云化的负......
  • Logstash 入门实战(3)--input plugin 介绍
    本文主要概述Logstash的一些最受欢迎的输入插件,以大致了解Logstash的用途;相关的环境及软件信息如下:CentOS 7.9、Logstash8.2.2。1、什么是Logstashinput插件Logsta......
  • AJAX基础+Axios快速入门+JSON使用+综合案例
    目录1、AJAX1.1概述1.1.1作用1.1.2同步和异步1.2快速入门1.2.1服务端实现1.2.2客户端实现1.3案例1.3.1需求1.3.2分析1.3.2后端实现1.3.3前端实现2、Axios异步......
  • 实验6:开源控制器实践——RYU
    实验6:开源控制器实践——RYU一、实验目的能够独立部署RYU控制器;能够理解RYU控制器实现软件定义的集线器原理;能够理解RYU控制器实现软件定义的交换机原理。二、实验环......
  • PhantomJS入门使用
    概述​​官网​​​,​​GitHub​​​,​​下载地址​​​简介:一个基于webkit的JSAPI。它使用QtWebKit作为它核心浏览器的功能,使用webkit来编译解释执行JS代码。任何你可以......
  • git和github新手安装使用教程(三步入门)
    git和github新手安装使用教程(三步入门)对于新手来说,每次更换设备时,github的安装和配置都会耗费大量时间。主要原因是每次安装时都只关心了【怎么做】,而忘记了记住【为什么......
  • fscan:一键自动化、全方位漏洞扫描的开源工具
    https://blog.csdn.net/osfront/article/details/116049846打开服务器看到了一个软件fscan64,并有运行页面。因为没见过,吓了我一跳,搜索了下是什么,记录下。简介fscan是......
  • Python 基础:入门必备知识
    Python基础:入门必备知识1标识符标识符是编程时使用的名字,用于给变量、函数、语句块等命名,Python中标识符由字母、数字、下划线组成,不能以数字开头,区分大小写。以下......