qimall/addons/Happiness/common/logic/order/marketing/PvMarketing.php

<?php

namespace addons\Happiness\common\logic\order\marketing;

use addons\Happiness\common\enums\HappinessPvEnum;
use addons\Happiness\common\models\HappinessPvWallet;
use addons\Happiness\common\service\PvService;
use common\enums\AppEnum;
use common\enums\StatusEnum;
use common\traits\ErrorTrait;
use Yii;

class PvMarketing
{
    use ErrorTrait;

    public static function compute($item, &$form, array &$extra = [])
    {
        try {
            $mall_id = $item['mch_order_info']['mall_id'];
            $user_id = $item['mch_order_info']['user_id'];
     
            $deduct_money = 0;// 抵扣总额
            $deduct_arr = [];// 抵扣冻结跟金额数组
            
            //同步积分
            $power_name='幸福宝积分';
            $pvService=new PvService();
            $uid=$pvService->syncUserPv($user_id);
            if($uid===false){
                throw new \Exception($pvService->getError());
            }
            // 商品处理
            $user_power_wallet = HappinessPvWallet::findOne(['user_id'=>$user_id, 'status' => StatusEnum::ENABLED]);
            
            if(!$user_power_wallet || $user_power_wallet->score_value<=0)
            {
                return $item;
            }

            $value['deduct_type']=1;//单件抵扣
            $value['is_deduct_percent']=1;//百分比抵扣
            $value['deduct_money']=100;//百分百


            foreach ($item['goods'] as $goods_id => &$goods) {
                // 单件抵扣：比如单件抵扣10元，购买A商品共3件，每件50元，总价=150元，可抵扣的金额30元
                // 多件抵扣：比如多件抵扣10元，购买A商品共3件，每件50元，总价=150元，可抵扣的金额10元
                $total_goods_price = array_sum(array_column($goods['goods_details'],'goods_price'));//同一种商品不同规格总价格
                $total_num = array_sum(array_column($goods['goods_details'],'num'));// 同一种商品不同规格总数量

                if (!empty($value['is_deduct_percent'])) {
                    // 按照百分比抵扣 = 商品金额 * 设置比例 / 100；百分比抵扣跟商品数量无关
                    $money = $item['goods'][$goods_id]['goods_price'] * bcdiv($value['deduct_money'],100,2);
                } else {
                    // 固定金额抵扣
                    $money = $value['deduct_type'] == 2 ? $value['deduct_money'] : $value['deduct_money'] * $total_num;// 计算抵扣金额
                }

                if($user_power_wallet['score_value']<$money){
                    $money = $user_power_wallet['score_value'];
                }
                $user_power_wallet['score_value'] -= $money;// 余额逐步减少

                if($money<=0) continue;
                $pv_score_en = 'pv_score';
                // 检查是否有被选中
                $temp_total_deduct_money = 0;
                $is_use = false;
                if($total_goods_price<=0) continue;
                if (!empty($form->data['is_use_' . $pv_score_en])) $is_use = true;
                foreach ($goods['goods_details'] as $k=>&$detail) {
                    $rate = $detail['goods_price']/$total_goods_price;
                    if(!isset($goods['goods_details'][$k+1])){
                        //最后一个
                        $temp_deduct_money = bcsub($money, $temp_total_deduct_money, 2);
                    } else {
                        $temp_deduct_money = bcmul($rate, $money, 2);
                    }

                    if( $detail['goods_price']>$temp_deduct_money){
                        $is_use && $detail['goods_price'] -= $temp_deduct_money;
                    }else{
                        $temp_deduct_money = $detail['goods_price'];
                        $is_use && $detail['goods_price'] =0;
                    }

                    $temp_total_deduct_money += $temp_deduct_money;
                    if ($is_use) {
                        $deduct_currency = $detail['marketing']['deduct_currency'];
                        if($deduct_currency){
                            $deduct_currency = json_decode($deduct_currency,true);
                            $deduct_currency = (array_merge($deduct_currency, [$pv_score_en => ['name' => $power_name,'money' => $temp_deduct_money]]));// 将合并的数组转为json字符串
                        }else{
                            $deduct_currency = [$pv_score_en => ['name' => $power_name,'money' => $temp_deduct_money]];
                        }
                        $detail['marketing']['deduct_currency'] = json_encode($deduct_currency);// 插入order_marketing表数据
                    }
                }
                if ($is_use) {
                    $item['goods'][$goods_id]['goods_price'] -= $temp_total_deduct_money;// 此商品减扣后的金额计算
                    if($item['goods'][$goods_id]['goods_price']<0) $item['goods'][$goods_id]['goods_price'] = 0;
                    $deduct_arr[$pv_score_en] = empty($deduct_arr[$pv_score_en]) ? $temp_total_deduct_money : $deduct_arr[$pv_score_en] + $temp_total_deduct_money;
                }

                // 前端抵扣数据展示组合
                if ($form->action == AppEnum::ACTION_PREVIEW) {
                    $form->marketing['deduct']['pv_score'] = [
                        'name' => $power_name,
                        'deduct_val' => empty($form->marketing['deduct']['pv_score']['deduct_val']) ? round($temp_total_deduct_money, 2) : bcadd($form->marketing['deduct']['pv_score']['deduct_val'], $temp_total_deduct_money, 2),
                        'money' => empty($form->marketing['deduct']['pv_score']['money']) ? round($temp_total_deduct_money, 2) :  bcadd($form->marketing['deduct']['pv_score']['money'], $temp_total_deduct_money, 2),
                        'is_show_radio' => true,// 是否显示单选按钮
                        'is_use' => $is_use,// 是否被选中单选按钮
                    ];
                }
                $is_use && $deduct_money += $temp_total_deduct_money;
            }

            // 计算订单减扣后的金额
            if ($deduct_money > 0) {
                $item['mch_order_info']['pay_money'] -= $deduct_money;
                $item['mch_order_info']['goods_price'] = bcsub(floatval($item['mch_order_info']['goods_price']), $deduct_money, 2);
                // 扣减积分金额

                if ($form->action == AppEnum::ACTION_CREATE && $deduct_arr) {
                    foreach ($deduct_arr as $key => $deduct_big_power_money) {
                        self::checkScore($mall_id, $user_id, $deduct_big_power_money);
                    }
                }
            }
            return $item;
        } catch (\Exception $e) {
            self::setStaticError($e->getMessage());
            return false;
        }
    }

    /**
     * 检测用户余额是否足够
     * @param $mall_id
     * @param $user_id
     * @param $money
     * @param $redpack_type
     * @return void
     * @throws \Exception
     */
    public static function checkScore($mall_id, $user_id, $money)
    {
        $wallet = HappinessPvWallet::findOne(['user_id' => $user_id, 'status' => StatusEnum::ENABLED]);
        if (empty($wallet)) throw new \Exception(  "幸福宝积分不足");
        if ($wallet[HappinessPvEnum::SCORE_VALUE] < $money) throw new \Exception("幸福宝积分不足");
    }
}