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 think\Model;

/**
 * 会员模型
 */
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 level          = [1=>3, 2=> 10, 3=>3, 4=>3];  //直推人数
    const LevelOne       = 1; 
    const LevelTwo       = 2;
    const LevelThre      = 3;
    const LevelFour      = 4;
    const LevelFive      = 5;
    protected $name = 'user';


    public function getById($userID)
    {
        return $this->where('id', $userID)->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");
    }


    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");
    }

    
    /**
     * 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 string $parentId
     * @return void
     */
    public static function updateUserLevel(int $uid, int $parentId)
    {
        if (!empty($parentId)) {
            $paths  = UserPathModel::where('user_id', $uid)->order('distance', 'asc')->column('parent_id');
            foreach ($paths as $item) 
            {
                $parent = self::where('id', $item)->find();
                //更新等级
                if (empty($parent->address_level)) {
                    $parent->address_level = self::LevelOne;
                }else{
                    if ($parent->address_level < self::LevelFive) {
                        $parentCount = self::where('parent_id', $item)->where('address_level', '>=', self::LevelOne)->count();
                        if($parentCount >= self::level[1]) $parent->address_level = self::LevelTwo;
                        if($parentCount >= self::level[2]) $parent->address_level = self::LevelThre;
                        if($parent->address_level == self::LevelThre){
                            $parentCount = self::where('parent_id', $item)->where('address_level', '>=', self::LevelThre)->count();
                            if($parentCount >= self::level[3]) $parent->address_level = self::LevelFour;
                        }
                        if($parent->address_level == self::LevelFour) {
                            $parentCounts = self::where('parent_id', $item)->where('address_level', '>=', self::LevelFour)->count();
                            if($parentCounts >= self::level[4]) $parent->address_level = self::LevelFive;
                        }
                    }
                }
                //更新直推领取人数
                if($parentId == $item) $parent->direct_super +=  self::Normal;
                $parent->save();
            }
        }
        return self::where('id', $uid)->setInc('address_level', self::Normal);
    }

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

                //是否升级翡翠
                if($addressLevel == self::LevelThre) {
                    $parentCounts = self::where('parent_id', $item)->where('address_level', '>=', self::LevelThre)->count();
                    if($parentCounts >= self::level[3]) $addressLevel = self::LevelFour;
                }
                //彩宝
                if($addressLevel == self::LevelFour) {
                    $parentCounts = self::where('parent_id', $item)->where('address_level', '>=', self::LevelFour)->count();
                    if($parentCounts >= self::level[4]) $addressLevel = self::LevelFive;
                }
                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, $model::Community, $uid);
                }else{
                    //间接推荐有效会员大于层级
                    if(self::where('parent_id', $item)->where('rwa_num','>', 0)->count() >= $kk){
                        $model->changeWalletAccount($item, $token, $pv, $model::Community, $uid);
                    }
                }
            }
        }
    }
}