xny/app/common/model/user/OilLevel.php

<?php

namespace app\common\model\user;

use app\common\model\BaseModel;
use app\common\model\store\order\StoreOrder;
include_once app_path('app/common.php');
class OilLevel extends BaseModel
{
    public static function tablePk(): ?string
    {
        return 'id';
    }

    public static function tableName(): string
    {
        return 'oil_level';
    }
//买节能油商品的时候触发 检测升级
    public function checkLevel($uid, $pass = [])
    {
        if (in_array($uid, $pass)) return true;
        $user = User::find($uid);
        $group_users = get_group_user($user);
        //Todo 获取在$group_users内所有用户的消费情况
        $achievement = 0;
        //获取该用户购买过的节能油商品的全部订单
        $achievement1 = StoreOrder::where('uid', 'in',$group_users)->where('paid', 1)->where('product_type',1)->whereNotIn('status',-1)->sum('pay_price');
        $achievement2 = StoreOrder::where('uid', $uid)->where('paid', 1)->where('product_type',1)->whereNotIn('status',-1)->sum('pay_price');
        $achievement = bcadd($achievement1, $achievement2, 2);
        $old_level = self::where('id', $user['level'])->find();
        if (!$old_level) $old_level = [
            'grade' => 0,
            'name' => '普通会员'
        ];
        $level = self::where('grade', '>', $old_level['grade'])->where('achievement', '<=', $achievement)
            ->order('grade', 'desc')->find();
        if ($level) {
            $user->level = $level['id'];
            $user->save();
        }

        $pass[] = $uid;
        $spread = User::where('uid', $user['spread_uid'])->find();
        if ($spread) return $this->checkLevel($spread['id'], $pass);
        return true;
    }

}