RWACha-API/application/common/model/UserModel.php

<?php

namespace app\common\model;

use think\db\exception\DataNotFoundException;
use think\db\exception\ModelNotFoundException;
use app\common\model\UserPathModel;
use think\Exception;
use app\common\model\LedgerWalletModel;
use fast\Asset;
use think\Model;
use think\Log;

/**
 * 会员模型
 */
class UserModel extends Model
{

    //    // 开启自动写入时间戳字段
    //    protected $autoWriteTimestamp = 'int';
    //    // 定义时间戳字段名
    //    protected $createTime = 'createtime';
    //    protected $updateTime = 'updatetime';
    //    // 追加属性
    //    protected $append = [
    //        'url',
    //    ];.

    //0未开始 1进行中 2已结束 Not started
    const Notstart       = 0;
    const Normal         = 1;
    const Stop           = 2;

    const LevelConta     = [1 => 2, 2 => 9,  3 => 3, 4 => 3];  //包含自己
    const LevelAll       = [1 => 3, 2 => 10, 3 => 3, 4 => 3];  //直推人数

    const LevelOne       = 1; //青铜
    const LevelTwo       = 2; //白银
    const LevelThre      = 3; //黄金
    const LevelFour      = 4; //翡翠
    const LevelFive      = 5; //彩带



    //超级福利标识
    const Hidden = 0;
    const NewPeo = 1;
    const Super  = 2;

    protected $name = 'user';


    public function getById($userID)
    {
        return $this->where('id', $userID)->find();
    }

    public function getByPhone(string $phone)
    {
        return $this->where("phone", $phone)->find();
    }



    public static function getByUserCount(array $where)
    {
        return self::where($where)->count();
    }

    public function getByUid($nickname)
    {
        return self::where('nickname', $nickname)->find();
    }

    public function getByAddress($address)
    {
        return $this->where("address", $address)->find();
    }

    public static function getByParentId(int $uid): int
    {
        return self::where('id', $uid)->value("parent_id");
    }

    //根据用户昵称获取用户ID: 0 地址 1 昵称
    public static function getUserByUid(string $nickname, int $type = 0)
    {
        $map = $type == 1 ? ['nickname' => $nickname] : ['address' => $nickname];
        return self::where($map)->value('id');
    }

    public function getAllAddress()
    {
        $all_list = $this->field('id,address')->select();
        $arr = [];
        foreach ($all_list as $item) {
            $arr[$item['address']] = $item['id'];
        }
        return $arr;
    }


    //获取用户RWA
    public static function getUserRwaNum(int $uid): int
    {
        return self::where('id', $uid)->value("rwa_num");
    }

    //获取用户团队等级
    public static function getTeamLevelId(int $uid): int
    {
        return self::where('id', $uid)->value("team_level_id");
    }

    /**
     * RWA更新数据
     * @param int $uid
     * @param string $power
     * @return void
     */
    public static function updateForRwaNum(int $uid, int $pid, string $score, string $action)
    {
        if ($action == '+') {
            //更新自己Rwa
            self::where('id', $uid)->setInc('rwa_num', $score);
            //更新直推Rwa
            return self::where('id', $pid)->setInc('direct_rwa', $score);
        } else {

            //更新自己Rwa
            self::where('id', $uid)->setDec('rwa_num', $score);
            //更新直推Rwa
            return self::where('id', $pid)->setDec('direct_rwa', $score);
        }
    }



    /**
     * 添加用户上级标识
     * 领取超级福利后就会变成青铜地址
     * 直推3个领取了超级福利的变成白银地址
     * 直推10个领取了超级福利的变成黄金地址
     * 有3个是黄金地址的 就变成翡翠地址
     * @param int $uid
     * @param int $parentId 上级
     * @param int $addressLevel 等级
     * @return void
     */
    public static function updateUserLevel(int $uid, int $parentId, $addressLevel)
    {



        if (!empty($parentId)) {
            $model = new ProductOrder();
            $paths  = UserPathModel::where('user_id', $uid)->order('distance', 'asc')->column('parent_id');
            foreach ($paths as $item) {
                try {
                    $parent = self::where('id', $item)->find();
                    //更新等级
                    if ($parent->address_level < self::LevelFive) {
                        //升级条件
                        $level = ($parentId == $item) ? self::LevelConta : self::LevelAll;
                        //升级
                        if ($parent->address_level < self::LevelThre) {
                            $parentCount = self::where('parent_id', $item)->where('address_level', '>=', self::LevelOne)->count();
                            if ($parentCount >= $level[1]) $parent->address_level = self::LevelTwo;
                            if ($parentCount >= $level[2]) $parent->address_level = self::LevelThre;
                        } elseif ($parent->address_level == self::LevelThre) {
                            $parentCount = self::where('parent_id', $item)->where('address_level', '>=', self::LevelThre)->count();
                            if ($parentCount >= $level[3]) {
                                $parent->address_level = self::LevelFour;
                                //空投
                                $welfare = config('super_welfare')[self::LevelFour];
                                $model::setPopularNoAreaOrder($welfare['num'], 0, 0, $welfare['product_id'], $item, $model::Airdrop);
                            }
                        } elseif ($parent->address_level == self::LevelFour) {
                            $parentCounts = self::where('parent_id', $item)->where('address_level', '>=', self::LevelFour)->count();
                            if ($parentCounts >= $level[4]) {
                                $parent->address_level = self::LevelFive;
                                //空投
                                $welfare = config('super_welfare')[self::LevelFive];
                                $model::setPopularNoAreaOrder($welfare['num'], 0, 0, $welfare['product_id'], $item, $model::Airdrop);
                            }
                        }
                    }
                    //更新直推领取人数
                    if ($parentId == $item) $parent->direct_super += self::Normal;
                    $parent->save();
                } catch (\Exception $e) {

                    Log::error($e->getMessage(), 'updateUserLevel,user_id_'.$item);
                }
            }
        }
        //
        return self::where('id', $uid)->update(['address_level' => $addressLevel + 1, 'is_super' => self::Super]);
    }

    /**
     * 添加用户上级标识
     * 领取超级福利后就会变成青铜地址
     * 直推3个领取了超级福利的变成白银地址
     * 直推10个领取了超级福利的变成黄金地址
     * 有3个是黄金地址的 就变成翡翠地址
     * */
    public static function updateUserAddresLevel(int $uid, int $parentId)
    {
        $addressLevel = 0;
        if (!empty($parentId)) {
            $paths = UserPathModel::where('user_id', $uid)->order('distance', 'asc')->column('parent_id');
            array_unshift($paths, $uid);
            foreach ($paths as $item) {
                //更新等级
                $level =  self::LevelAll;
                $parentCount = self::where('parent_id', $item)->where('address_level', '>=', self::LevelOne)->count();
                if ($parentCount >= $level[1]) $addressLevel = self::LevelTwo;
                if ($parentCount >= $level[2]) $addressLevel = self::LevelThre;

                //是否升级翡翠
                if ($addressLevel == self::LevelThre) {
                    $parentCounts = self::where('parent_id', $item)->where('address_level', '>=', self::LevelThre)->count();
                    if ($parentCounts >= $level[3]) $addressLevel = self::LevelFour;
                }
                //彩宝
                if ($addressLevel == self::LevelFour) {
                    $parentCounts = self::where('parent_id', $item)->where('address_level', '>=', self::LevelFour)->count();
                    if ($parentCounts >= $level[4]) $addressLevel = self::LevelFive;
                }
                if ($addressLevel > 0) self::where('id', $item)->setField('address_level', $addressLevel);
            }
        }
        return  $addressLevel;
    }

    //社区向上发放奖励津贴
    public static function setCommunityRewards($uid, $pv, $token)
    {
        $paths  = UserPathModel::where('user_id', $uid)->where('distance', '<', 11)->order('distance', 'asc')->column('distance,parent_id');
        if (!empty($paths)) {
            $model = new LedgerWalletModel();
            foreach ($paths as $kk => $item) {
                if ($kk == 1) {
                    $model->changeWalletAccount($item, $token, $pv, ledgerTokenChangeModel::Community, $uid);
                } else {
                    //间接推荐有效会员大于层级
                    if (self::where('parent_id', $item)->where('rwa_num', '>', 0)->count() >= $kk) {
                        $model->changeWalletAccount($item, $token, $pv, ledgerTokenChangeModel::Community, $uid);
                    }
                }
            }
        }
    }
}