likeshop.project/app/shopapi/logic/Order/FreightLogic.php

<?php
// +----------------------------------------------------------------------
// | LikeShop100%开源免费商用电商系统
// +----------------------------------------------------------------------
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
// | 开源版本可自由商用，可去除界面版权logo
// | 商业版本务必购买商业授权，以免引起法律纠纷
// | 禁止对系统程序代码以任何目的，任何形式的再发布
// | Gitee下载：https://gitee.com/likeshop_gitee/likeshop
// | 访问官网：https://www.likemarket.net
// | 访问社区：https://home.likemarket.net
// | 访问手册：http://doc.likemarket.net
// | 微信公众号：好象科技
// | 好象科技开发团队 版权所有 拥有最终解释权
// +----------------------------------------------------------------------

// | Author: LikeShopTeam
// +----------------------------------------------------------------------

namespace app\shopapi\logic\Order;

use app\common\enum\DeliveryEnum;
use app\common\enum\FreightEnum;
use app\common\enum\YesNoEnum;
use app\common\logic\BaseLogic;
use app\common\model\Freight;
use app\common\service\ConfigService;

/**
 * 运费逻辑
 * Class FreightLogic
 * @package app\api\logic
 */
class FreightLogic extends BaseLogic
{
    /**
     * @notes 计算运费
     * @param $goods
     * @param $userAddress
     * @return float|int|mixed
     * @author 段誉
     * @date 2021/7/30 18:37
     */
    public static function calculateFreight($goods, $userAddress)
    {
        $expressPrice = 0;
        $templateList = [];
        $goodsExpressMoneys = [];
        outFileLog($goods,'freight','$goods');
        // 配送方式配置, 如果配送方式-快递配送已关闭则不参与运费计算
        $expressConfig = ConfigService::get('delivery_type', 'is_express', 1);

        if (empty($userAddress) || $expressConfig == YesNoEnum::NO) {
            return ['goods'=>$goods,'express_price'=>$expressPrice];
        }
        $area_flag =  ConfigService::get('shop', 'area_flag');
        foreach ($goods as &$good) {
    
            $good['total_weight']   = $good['weight'] * $good['goods_num'];
            $good['total_volume']   = $good['volume'] * $good['goods_num'];
            
            // 统一邮费
            if ($good['express_type'] == 2) {
                $good['express_price'] = round($good['express_money'] * $good['goods_num'], 2);
                $expressPrice += $good['express_price'];
            }
            
            // 指定运费模板
            if ($good['express_type'] == 3 && $good['express_template_id'] > 0) {
                $templateList[$good['express_template_id']][] = $good;
            }
        }

        if($area_flag == 1){
            $expressPrice += 2;//self::calculate2($goods, $userAddress);
        }else {


            foreach ($templateList as $templateId => $templateGoods) {

                $freight = FreightLogic::getFreightsByAddress($templateId, $userAddress);

                if (empty($freight)) {
                    continue;
                }

                switch ($freight['charge_way']) {
                    // 件数
                    case FreightEnum::CHARGE_WAY_PIECE:
                        $nums = array_sum(array_column($templateGoods, 'goods_num'));
                        $real_count_field = 'goods_num';
                        break;
                    // 重量
                    case FreightEnum::CHARGE_WAY_WEIGHT:
                        $nums = array_sum(array_column($templateGoods, 'total_weight'));
                        $real_count_field = 'total_weight';
                        break;
                    // 体积
                    case FreightEnum::CHARGE_WAY_VOLUME:
                        $nums = array_sum(array_column($templateGoods, 'total_volume'));
                        $real_count_field = 'total_volume';
                        break;
                    default:
                        continue 2;
                }

                // 计算运费
                if ($nums > $freight['first_unit'] && $freight['continue_unit'] > 0) {
                    $left = ceil(($nums - $freight['first_unit']) / $freight['continue_unit']);
                    $this_express_money = $freight['first_money'] + $left * $freight['continue_money'];
                } else {
                    $this_express_money = $freight['first_money'];
                }

                // 计算每个商品 所占运费金额
                $goods_moneys = static::array_proportion($this_express_money, array_column($templateGoods, $real_count_field), 2, 'end');

                foreach ($templateGoods as $ko => $templateGood) {
                    $goodsExpressMoneys[$templateGood['id']] = $goods_moneys['gets'][$ko] ?? 0;
                }

                // 总的运费
                $expressPrice += $this_express_money;
            }

            foreach ($goods as &$good) {
                $good['express_price'] = $goodsExpressMoneys[$good['id']] ?? $good['express_price'] ?? 0;
            }
        }
        return [ 'goods' => $goods, 'express_price' => $expressPrice ];
    }


    /**
     * @notes 计算运费
     * @param $data
     * @param $userAddress
     * @return float|int|mixed
     * @author 段誉
     * @date 2021/7/30 18:37
     */
    public static function calculate($data, $userAddress)
    {
        $expressPrice = 0;

        $freight = FreightLogic::getFreightsByAddress($data['template_id'], $userAddress);

        if (empty($freight)) {
            return $expressPrice;
        }
        $unit = 0;
        //按重量计算
        if ($freight['charge_way'] == FreightEnum::CHARGE_WAY_WEIGHT) {
            $unit = $data['total_weight'];
        }

        //按件数计算
        if ($freight['charge_way'] == FreightEnum::CHARGE_WAY_PIECE) {
            $unit = $data['goods_num'];
        }

        //按体积计算
        if ($freight['charge_way'] == FreightEnum::CHARGE_WAY_VOLUME) {
            $unit = $data['total_volume'];
        }

        if ($unit > $freight['first_unit'] && $freight['continue_unit'] > 0) {
            $left = ceil(($unit - $freight['first_unit']) / $freight['continue_unit']);//取整
            return $freight['first_money'] + $left * $freight['continue_money'];
        } else {
            return $freight['first_money'];
        }
    }
    //特定地区运费计算
    public static function calculate2($data, $userAddress)
    {

        $goods_price=0;
        foreach ($data as &$v){
            outFileLog($v,'fright_fee','$v');
            $goods_price +=isset($v['sub_price']) ?? 0;
        }
        return $goods_price;
    }

    /**
     * @notes 通过用户地址获取运费模板
     * @param $templateId
     * @param $address
     * @return mixed
     * @author 段誉
     * @date 2021/7/30 18:36
     */
    public static function getFreightsByAddress($templateId, $address)
    {
        $districtId = $address['district_id'];
        $cityId = $address['city_id'];
        $provinceId = $address['province_id'];

        $freights = Freight::alias('f')
            ->join('freight_config c', 'c.freight_id = f.id')
            ->where('f.id', $templateId)
            ->order(['f.id' => 'desc', 'c.id' => 'desc'])
            ->select();
        $nationalFreight = [];
        foreach ($freights as $freight) {
            $regionIds = explode(',', $freight['region_id']);
            if (in_array($districtId, $regionIds)) {
                return $freight;
            }

            if (in_array($cityId, $regionIds)) {
                return $freight;
            }

            if (in_array($provinceId, $regionIds)) {
                return $freight;
            }
            //全国统一运费
            if (100000 == $freight['region_id']) {
                $nationalFreight = $freight;
            }
        }
        //会员的省市区id在商家的运费模板(指定地区)中找不到,查一下商家的全国运费模板
        return $nationalFreight;
    }

    /**
     * @notes 模板中指定地区id是否存在
     * @param $freights
     * @param $regionId
     * @return bool
     * @author 段誉
     * @date 2021/7/30 18:36
     */
    public static function isExistRegionId($freights, $regionId)
    {
        foreach ($freights as $freight) {
            $regionIds = explode(',', $freight['region_id']);
            if (in_array($regionId, $regionIds)) {
                return $freight;
            }
        }
        return false;
    }
    
    /**
     * 获取占比值
     * @Author     lbzy
     * @DateTime   2020-11-29T20:48:28+0800
     */
    static function array_proportion(float $totals, array $proportions, int $point_length = 0, string $remain_deal = null, array $totals_max = []) : array
    {
        $proportions    = array_values($proportions);
        $totals_max     = array_values($totals_max);
        
        $result         = [];
        $sums           = array_sum($proportions);
        $point_length   = max($point_length, 0);
        
        $multiple       = pow(10, $point_length);
        
        $gets = [];
        $gets2 = 0;
        
        foreach ($proportions as $proportion) {
            $get    = $sums == 0 ? 0 : bcadd(floor($proportion * $multiple * $totals / $sums ) / $multiple, 0, $point_length);
            
            $gets[] = $get;
            $gets2  = bcadd($get, $gets2, $point_length);
        }
        
        $gets_length    = count($gets);
        $over           = bcsub($gets2, $totals, $point_length);
        $remain         = $over > 0 ? 0 : bcsub($totals, $gets2, $point_length);
        
        // 多出 按顺序扣减
        while ($over > 0) {
            foreach ($gets as $key => $get) {
                $over_must  = min($get, $over);
                $gets[$key] = bcsub($get, $over_must, $point_length);
                $over       = bcsub($over, $over_must, $point_length);
            }
        }
        
        // 剩下的放哪里
        switch ($remain_deal) {
            //
            case 'start':
                $gets[0]                = bcadd($gets[0], $remain, $point_length);
                $remain                 = '0';
                break;
            //
            case 'end':
                $gets[$gets_length - 1] = bcadd($gets[$gets_length - 1], $remain, $point_length);
                $remain                 = '0';
                break;
            // 自动填充
            case 'auto':
                foreach ($gets as $ko => $vo) {
                    if ($vo < $totals_max[$ko]) {
                        $remain_must    = min($remain, $totals_max[$ko] - $vo);
                        $gets[$ko]      = bcadd($gets[$ko] + $remain_must, 0, $point_length);
                        $remain         = bcsub($remain, $remain_must, $point_length);
                    }
                }
                break;
            default:
                
                break;
        }
        
        return [ 'gets' => $gets, 'remain' => $remain ];
    }
}