qimall/common/logic/order/limit/UserLimit.php

<?php

namespace common\logic\order\limit;

use common\enums\OrderStatusEnum;

use common\enums\StatusEnum;
use common\models\order\OrderDetail;
use common\models\user\UserLevel;
use Exception;
use yii\helpers\Json;


class UserLimit extends BaseLimit
{
    public function execute( $form)
    {
        try {
        } catch (Exception $e) {
            $this->setError('用户购买限制验证不通过，原因：' . $e->getMessage());
            return false;
        }

    }

    /**
     * 购买等级验证
     * User: wniu
     * Date: 2021/10/7
     * Time: 3:43 下午
     * * @param $form
     * @throws Exception
     */
    public static function compute($form)
    {
        $user = $form->user;
        $goods_arr = [];
        foreach ($form->order_goods as $goods) {
            if(isset($goods_arr[$goods['goods_id']])){
                $goods_arr[$goods['goods_id']] += $goods['num'];
            }else{
                $goods_arr[$goods['goods_id']] = $goods['num'];
            }
        }
        foreach ($goods_arr as $goods_id=>$num){
            $member_buy_limit_setting = Json::decode($form->sku[$goods_id]['goods']['extra']['member_buy_limit_setting'] ?? '[]');
            if (!empty($member_buy_limit_setting['member_level'])) {
                $user_level = UserLevel::lists([
                    'where'=>[
                        ['level'=>$member_buy_limit_setting['member_level']],
                        ['status'=>StatusEnum::ENABLED],
                        ['mall_id'=>$form->mall_id],
                    ]
                ]);
                $user_level_arr = array_column($user_level,'level');
                // 勾选了普通会员
                if (in_array(0, $member_buy_limit_setting['member_level'])) {
                    $user_level_arr[] = 0;
                }
                if (!empty($user_level_arr) && !in_array($user->level, $user_level_arr)) {
                    throw new Exception('该商品为指定会员购买请升级购买');
                }
            }
            if (($member_buy_limit_setting['nums'] ?? 0) > $num) {
                throw new Exception('该商品起购数量为' . $member_buy_limit_setting['nums']);
            }
            if (($member_buy_limit_setting['every_num'] ?? 0) < $num && ($member_buy_limit_setting['every_num'] ?? 0) != 0) {
                throw new Exception('该商品每次限购' . $member_buy_limit_setting['every_num']);
            }
            $already_buy = self::statisticsBuyGoodsId($goods_id, $user->id);

            if (($member_buy_limit_setting['total_num'] ?? 0) < $num + $already_buy['all'] && ($member_buy_limit_setting['total_num'] ?? 0) != 0) {
                throw new Exception('该商品限购' . $member_buy_limit_setting['total_num']);
            }
            if (($member_buy_limit_setting['every_day_num'] ?? 0) < $num + $already_buy['day'] && ($member_buy_limit_setting['every_day_num'] ?? 0) != 0) {
                throw new Exception('该商品每日限购' . $member_buy_limit_setting['every_day_num']);
            }
            if (($member_buy_limit_setting['every_week_num'] ?? 0) < $num + $already_buy['week'] && ($member_buy_limit_setting['every_week_num'] ?? 0) != 0) {
                throw new Exception('该商品每周限购' . $member_buy_limit_setting['every_week_num']);
            }

            //开启了会员指定等级每月限购数量
            if ($form->sku[$goods_id]['goods']['extra']['is_member_alone_buy_limit']) {
                $member_alone_buy_limit_setting = Json::decode($form->sku[$goods_id]['goods']['extra']['member_alone_buy_limit_setting'] ?? '[]');
                if ($member_alone_buy_limit_setting) $member_alone_buy_limit_setting = array_column($member_alone_buy_limit_setting, null, 'level');

                if (isset($member_alone_buy_limit_setting[$user->level])) {
                    //存在会员等级的设置，替换公共限购设置
                    $member_buy_limit_setting['every_month_num'] = $member_alone_buy_limit_setting[$user->level]['every_month_num'] ?? 0;
                }
            }

            if (($member_buy_limit_setting['every_month_num'] ?? 0) < $num + $already_buy['month'] && ($member_buy_limit_setting['every_month_num'] ?? 0) != 0) {
                throw new Exception('该商品每月限购' . $member_buy_limit_setting['every_month_num']);
            }
        }
    }

    /**
     * User: wniu
     * Date: 2021/9/29
     * Time: 11:16 上午
     * * @param $goods_id
     * @param $user_id
     * @return array
     */
    public static function statisticsBuyGoodsId($goods_id, $user_id): array
    {
        $params['where'] = [
            ['=', 'user_id', $user_id],
            ['=', 'goods_id', $goods_id],
            ['>=', 'order_status', 0],
//            ['=', 'is_feedback', OrderStatusEnum::NOT_FEEDBACK]
        ];
        $params['select'] = 'created_at,num';
        $already_buy = OrderDetail::lists($params);
        $res_data = [
            'day' => 0,
            'week' => 0,
            'month' => 0,
            'all' => 0,
        ];
        if (!empty($already_buy)) {
            $time = time();
            $date = date('Y-m-d', $time);

            $day_start = strtotime($date . ' 00:00:00');
            $day_end = strtotime($date . ' 23:59:59');


            $w = date('w', strtotime($date));
            $week_start = strtotime(date('Y-m-d', strtotime($date . '-' . ($w ? $w - 1 : 6) . 'days')) . ' 00:00:00');
            $week_end = $week_start + (86400 * 6) - 1;


            $date = date('Y-m', $time);
            $month_start = strtotime(date('Y-m-01', strtotime(date($date))) . ' 00:00:00');
            $month_end = $month_start + (86400 * date('t')) - 1;
            foreach ($already_buy as $k) {
                $date = $k['created_at'];
                $num = $k['num'];
                if ($date > $day_start && $date < $day_end) {
                    $res_data['day'] += $num;
                }
                if ($date > $week_start && $date < $week_end) {
                    $res_data['week'] += $num;
                }
                if ($date > $month_start && $date < $month_end) {
                    $res_data['month'] += $num;
                }
                $res_data['all'] += $num;
            }
        }
        return $res_data;
    }
}