B2B2C商城系统基于脚本引擎的运费架构分享

脚本的生成过程

添加模板的时候生成script，商家添加商品的时候拷贝相应的script到sku中。

更新运费模板的时候，发消息到消费者，批量更新相关sku的模板信息。

计算过程

缓存数据结构

script和模板id作为sku的一部分存储是为了计算使用相同模板的sku的总价。

脚本示例

1function getShipPrice(){
2  var firstWeight=1;            //首重
3  var firstPrice=1；            //首重
4  var continuedWeight=1;    //续重
5  var continuedPrice=1;        //续重续费
6  var shipPrice=firstPrice;
7  //校验是否超出首重
8  if(firstWeight < $goodsWeight){
9    //续重 = 总重/续重
10     var count = ($goodsWeight - firstWeight)/ continuedWeight;
11    //总价 = 首重 + (续重*价格)
12     shipPrice = firstPrice + count*continuedPrice;
13  }
14  return shipPrice; 
15
16}

参数

类型

详细

$goodsWeight

double

商品总重量

$goodsNum

Integer

商品总数

返回值示例 2

领域模型

伪代码：

1 public Map<Integer, Double> setShippingPrice() {
2        //获取购物车信息
3        Cart cart = cache.get();
4        //获取购物车中的所有的sku
5        List<Sku> skuList = cart.getSkuList();
6        //获取所有sku中的key集合，用来批量的从缓存中读取脚本信息
7        List<String> keyList = getKeyList(skuList);
8        //批量从缓存中读取所有的运费模板
9        List<TemplateScript> templateScripts = getCache(keyList);
10        //根据模板id进行分组,查询出所有用到相同模板的sku
11        Map<Integer, List<Sku>> maps = group(templateScripts);
12        Iterator iter = maps.entrySet().iterator();
13        //用来存储每一个商家的运费
14        Map<Integer, Double> shipPriceMap = new HashMap<>()；
15        Integer sellerId = 0;
16        Double price = 0.0;
17        while (iter.hasNext()) {
18            List<Sku> sList = (List<Sku>) iter.next();
19            TemplateScript script = sList.get(0).getScript();
20            //计算总重量
21            Double goodsWeigth = countWeight(sList);
22            //计算总数量
23            int goodsNum = countNum(sList);
24            //调用脚本引擎计算价格
25            ScriptEngineManager manager = new ScriptEngineManager();
26            ScriptEngine engine = manager.getEngineByName("javascript");
27            engine.put("$weight", goodsWeigth);
28            engine.put("$num", goodsNum);
29            String jsFunc = script;
30            engine.eval(jsFunc);
31            Invocable invocable = (Invocable) engine;
32            double shipPrice = (Double) invocable.invokeFunction("price");
33            price += shipPrice;
34            Integer newselelrid = getSellerId(sList);
35            if (!sellerId.equals(newselelrid)) {
36                //记录这个sellerid的运费价格
37                shipPriceMap.put(newselelrid, price);
38                sellerId = newselelrid;
39                price = 0.0;
40            }
41        }
42        return shipPriceMap;
43
44
45    }

易族智汇（javashop）原创文章