\App\ModelsUsers

<?php


namespace App\Models;

use Illuminate\Support\Facades\DB;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\Request;
use mysql_xdevapi\Exception;

class Users extends Model
{
    protected $table = "users";

    /**
     * 获取所有用户
     * @return \Illuminate\Support\Collection 返回用户对象
     */
    public function getAll(){
        return DB::table($this->table)->get();
    }

    /**
     * 通过openid获取用户信息
     * @param $openid 微信openid
     * @return \Illuminate\Support\Collection 返回用户对象或NULL
     */
    public function getUserById($openid){
        return DB::table($this->table)->where('id',$openid)->first();
    }

    /**
     * 通过会员运营id获取用户信息
     * @param $special_id 会员运营id
     * @return \Illuminate\Support\Collection 返回用户对象或NULL
     */
    public function getUserBySpecialId($special_id){
        return DB::table($this->table)->where('special_id', $special_id)->first();
    }

    /**
     * 注册用户
     * @param $openid 微信openid
     * @return int 如执行成功返回1
     */
    public function userRegistration($openid,$invite_id){
        return DB::table($this->table)
            ->insert([
                'id' => $openid,
                'invite_id'=>$invite_id,
                'invitation_reward'=>$invite_id!=null?1:0,
                'rebate_ratio' => config('config.default_rebate_ratio')
            ]);
    }

    /**
     * 用户信息补全更新 通过Request获取参数
     * $openid 微信openid
     * $nickname 用户填写的昵称
     * $username ～姓名
     * $alipay_id ～支付宝账号
     * @return int 如执行成功返回1
     */
    public function userUpdate(){
        $openid = Request::post("openid");
        $nickname = Request::post("nickname");
        $username = Request::post("username");
        $alipay_id = Request::post("alipay_id");
        return DB::table($this->table)
            ->where('id', $openid)
            ->update([
                'nickname' => $nickname,
                'username' => $username,
                'alipay_id' => $alipay_id
            ]);
    }

    public function updateNickname($openid,$nickname){
        return DB::table($this->table)
            ->where('id', $openid)
            ->update([
                'nickname' => $nickname
            ]);
    }

    /**
     * 更新用户的粉丝运营id
     * @param $openid 微信openid
     * @param $special_id 粉丝运营id
     * @return int 如执行成功返回1
     */
    public function updateSpecial_id($openid,$special_id){
        try {
            return DB::table($this->table)
                ->where('id', $openid)
                ->update([
                    'special_id' => $special_id
                ]);
        }catch (Exception $e){
            return 0;
        }

    }

    /**
     * 更新未结算金额
     * @param $openid
     * @param $unsettled_balance
     * @return int
     */
    public function updateUnsettled_balance($openid,$unsettled_balance){
        return DB::table($this->table)
            ->where('id', $openid)
            ->update([
                'unsettled_balance' => $unsettled_balance
            ]);

    }

    /**
     * 更新可用金额
     * @param $openid
     * @param $available_balance
     * @return int
     */
    public function updateAvailable_balance($openid,$available_balance){
        return DB::table($this->table)
            ->where('id', $openid)
            ->update([
                'available_balance' => $available_balance
            ]);

    }

    /**
     * 分页查询用户信息
     * @param null $openid 筛选openid或昵称精准查询
     * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator 分页查询对象
     */
    public function getAllByPaginate($openid=null){
        if($openid==null){
            //判断是否传入筛选条件，如未传入则全量分页查询
            return DB::table('users')->paginate(10);
        }else{
            return DB::table('users')
                ->where('id',$openid)
                ->orWhere('nickname','like',"%".$openid."%")
                ->paginate(5);
            //分别对openid和nickname执行条件筛选，openid为精准，nickname为模糊
        }

    }

    /**
     * 根据openid修改返利比例和运营id
     * @param $id openid
     * @param $rebate_ratio 返利比例
     * @param $special_id 用户运营id
     * @return int 修改成功返回1否则0
     */
    public function modifyUserById($id,$rebate_ratio,$special_id){
        return DB::table($this->table)
            ->where('id', $id)
            ->update([
                'rebate_ratio' => $rebate_ratio,
                'special_id' => $special_id,
            ]);
    }

    /**
     * 根据openid修改返利比例
     * @param $id openid
     * @param $rebate_ratio 返利比例
     * @return int 修改成功返回1否则0
     */
    public function modifyRebateRatioById($id,$rebate_ratio){
        return DB::table($this->table)
            ->where('id', $id)
            ->update([
                'rebate_ratio' => $rebate_ratio
            ]);
    }

    public function getAlipayTraversalInReceive($receives){
        $alipays = array();
        foreach ($receives as $receive){
            $openid=$receive->openid;
            $user = $this->getUserById($openid);
            $alipay = array();
            $alipay["username"] = $user->username;
            $alipay["alipay_id"] = $user->alipay_id;
            array_push($alipays,$alipay);
        }
        return $alipays;
    }

    //通过邀请id查询邀请的用户数量
    public function getUserCountByInviteId($invite_id){
        return DB::table($this->table)
            ->where('invite_id',$invite_id)
            ->count();
    }

    //通过邀请id查询邀请的用户invitation_reward为0的数量
    public function getUserCountByInviteIdAndInvitationReward($invite_id){
        return DB::table($this->table)
            ->where('invite_id',$invite_id)
            ->where('invitation_reward',0)
            ->count();
    }

    //修改用户的invitation_reward为0
    public function updateInvitationReward($openid){
        return DB::table($this->table)
            ->where('id',$openid)
            ->update(['invitation_reward'=>0]);
    }
}