kge/application/api/controller/Usercenter.php

<?php

namespace app\api\controller;

use addons\epay\library\Service;
use app\api\controller\Common;
use app\api\validate\user\Report;
use app\common\model\UserPower;
use app\common\service\TenimService;
use outh\outh;
use think\Db;
use app\common\controller\RedisLeaderboard;
use Redis;
use GatewayClient\Gateway;
use think\Exception;

/**
 * 会员中心接口
 */
class UserCenter extends Common
{
    protected $noNeedLogin = ['shujuhuifu','getAnchorType','getRecharConfig','getExchangeConfig','getLevelExplain'];
    protected $noNeedRight = '*';

    public function _initialize()
    {
        parent::_initialize();
        $this->userModel = new \app\common\model\User();
    }



    /**
     * 获取个人信息
     */
    public function getUserInfo() {
        $user_id = input("user_id");
        if (!$user_id) {
            $this->error(__('Invalid parameters'));
        }
        // 获取基本信息
        $where = [];
        $where["id"] = $user_id;
        $userInfo = $this->userModel->field("id,nickname,mobile,avatar,gender,u_id,level,age_id,province_id,city_id,desc,charm_level,wealth_level,job_id")->where($where)->find();
        if(!$userInfo){
            $this->error('不存在的用户');
        }
        $userInfo = info_domain_image($userInfo,['avatar']);

        //用户钱包
        $userwallet = Db::name('user_wallet')->where('user_id',$user_id)->find();
        $userInfo['wallet'] = $userwallet;


        $userInfoA = $this->userModel->getAppendData($userInfo);
        $userInfo['age_text'] = $userInfoA['age_text'];
        $userInfo['province_text'] = $userInfoA['province_text'];
        $userInfo['city_text'] = $userInfoA['city_text'];
//        $userInfo['friends_num'] = $userInfoA['friends_num'];
        $userInfo['look_num'] = $userInfoA['look_num'];

        //关注人数,粉丝人数
        $follow_num = Db::name('user_follow')->where(['uid'=>$user_id])->count('id');
        $fans_num   = Db::name('user_follow')->where(['follow_uid'=>$user_id])->count('id');
        $userinfo['follow_num'] = $follow_num;
        $userinfo['fans_num'] = $fans_num;

        // 查看者是否已关注
        $userInfo["is_follow"] = $this->is_follow($this->auth->id,$user_id);
        $userInfo['is_friend'] = $this->is_friend($this->auth->id,$user_id);
        $userInfo['is_black']  = $this->is_black($this->auth->id,$user_id);


        // 获取用户在派对直播间情况信息
        $redis = new Redis();
        $redisconfig = config("redis");
        $redis->connect($redisconfig["host"], $redisconfig["port"]);
        if ($redisconfig['redis_pwd']) {
            $redis->auth($redisconfig['redis_pwd']);
        }
        if($redisconfig['redis_selectdb'] > 0){
            $redis->select($redisconfig['redis_selectdb']);
        }
        $livingUserPartyId = $redis->hGet("livingUser", $user_id);

        $userInfo['party_info'] = json([]);
        if ($livingUserPartyId) {
            $party = \app\common\model\Party::where('id',$livingUserPartyId)->field('id,room_type')->find();
            $userInfo['party_info'] = ['party_id' => $party['id'], 'room_type' => $party['room_type']];
        }

        $memberinfo = Db::name('guild_member')->alias('m')->field('m.id as `member_id`,m.user_id,guild.name,guild.image,guild.member,guild.desc')->join('guild','m.guild_id = guild.id','LEFT')->where(['m.user_id'=>$user_id,'m.status'=>1])->find();
        if ($memberinfo) {
            $userInfo['memberinfo'] = $memberinfo;
        }
        //家族信息
        $guildField = 'g.id,g.g_id,g.user_id,g.party_id,g.name,g.image,g.desc,g.member,g.status';
        $guildWhere['gm.user_id'] = $user_id;
        $guildWhere['g.status'] = 1;
        $guildInfo = model('Guild')->alias('g')->field($guildField)
            ->join('guild_member gm','gm.guild_id = g.id','LEFT')
            ->where($guildWhere)->order('id desc')->find();
        $userInfo['guild_info'] = !empty($guildInfo) ? $guildInfo : [];
        $guildStatus = -2;
        if (!empty($guildInfo)) {
            $guildStatus = (int)$guildInfo['status'];
        }
        $userInfo['guild_status'] = $guildStatus;//家族状态:公会状态:0=待审核,1=正常,-1=已解散,-2无公会

        //访客记录
        if ($this->auth->id != $user_id) {
            $visit_data = [
                'user_id' => $this->auth->id,
                'visit_user_id' => $user_id,
            ];
            $visit_check = Db::name('user_visitlist')->where($visit_data)->find();
            if(empty($visit_check)){
                $visit_data['updatetime'] = time();
                Db::name('user_visitlist')->insertGetId($visit_data);
            }else{
                Db::name('user_visitlist')->where('id',$visit_check['id'])->update(['updatetime'=>time()]);
            }
        }

        $this->success("获取成功！",$userInfo);
    }







    /**
     * 获取最近访客
     * (消息)
     */
    public function getMyVisitList(){
        $list = Db::name('user_visitlist')->alias('uv')
            ->field('uv.user_id,uv.updatetime,user.nickname,user.avatar,user.gender,user.desc')
            ->join('user','uv.user_id = user.id','LEFT')
            ->where('uv.visit_user_id',$this->auth->id) //被访问者
            ->order('uv.id desc')->autopage()->select();
        $list = list_domain_image($list,['avatar']);

        if(!empty($list)){
            foreach($list as $key => &$val){
                //关注
                $val['is_follow'] = $this->is_follow($this->auth->id,$val['user_id']);
            }
        }

        $this->success(1,$list);
    }


///////////////////////////////////////////////////


    /**
     * 获取关注人列表.派对信息
     */
    public function getFollowsLive() {
        $is_online = $this->request->request("is_online");// 是否在线:1=直播中,0=未开播
        $page = $this->request->request('page',1); // 分页
        $pageNum = $this->request->request('pageNum',10); // 分页
        // 分页搜索构建
        $pageStart = ($page-1)*$pageNum;

        $is_online == 1 || $is_online = 0;

        $fanfollowModel = new \app\common\model\UserFansFollow();
        $where = [];
        $where["a.fans_id"] = $this->auth->id;
        $where["p.room_type"] = 2;
        $where["p.is_online"] = $is_online;
        if($is_online == 1) {
            $field = "p.id as party_id,u.u_id,u.nickname,p.party_name,p.party_hot,p.party_logo,u.avatar,t.id as party_type";
        } else {
            $field = "p.id as party_id,a.user_id,u.avatar,u.gender,u.level,u.nickname,p.party_name,p.party_logo,t.id as party_type";
        }
        $list = $fanfollowModel->alias("a")
            ->field($field)
            ->join("hx_user u","u.id = a.user_id")
            ->join("hx_party p","p.user_id = a.user_id")
            ->join("hx_party_type t","t.id = p.party_type","left")
            ->limit($pageStart,$pageNum)
            ->where($where)->select();
        if($list) {
            foreach($list as $k => $v) {
                $mod = isset($v["party_type"])?intval($v["party_type"])%5:1;
                if(isset($v["type_name"]) && $v["type_name"]) {
                    $type_name = $v["type_name"];
                } else {
                    $type_name = "普通房";
                }
                $list[$k]["party_type"] = $type_name;
                $list[$k]["party_type_color"] = $mod == 0?5:$mod;
            }

            $this->success("获取成功！",$list);
        } else {
            $this->success("数据为空！",[]);
        }

    }





    /**
     * 主播申请
     */
    public function anchorApply() {
        $type_id = $this->request->request('type_id',0); // 技能分类ID
        $party_type_id = $this->request->request('party_type_id'); //分类ID
        $desc = $this->request->request('desc'); // 申请备注
        if (!$party_type_id && !$desc) {
            $this->error(__('Invalid parameters'));
        }
        $useranchorModel = new \app\common\model\UserAnchor();
        $data = [];
        $data["user_id"] = $this->auth->id;
        $data["type_id"] = $type_id;
        $data["party_type_id"] = $party_type_id;
        if($useranchorModel->where($data)->find()) $this->error(__('您已申请过该类型的主播，请勿重复申请！'));
        $data["desc"] = $desc;
        $data["createtime"] = time();
        $res = $useranchorModel->insertGetId($data);
        if($res) {
            \app\common\model\User::update(["is_anchor"=>1],["id"=>$this->auth->id]);
            $vbot = new \addons\vbot\Vbot();
            $vbot->vbotSendMsg('Anchor_Application_Notice', [], []);
            $this->success("申请发送成功！");
        } else {
            $this->error("网络错误，请稍后重试");
        }
    }

    /**
     * 实名认证
     */
    public function authApply() {
        $realname = $this->request->request('realname'); // 真实姓名
        $idcard = $this->request->request('idcard'); // 身份证号
        $zimage = $this->request->request('zimage'); // 身份证正面照
        $fimage = $this->request->request('fimage'); // 身份证反面照
        if (!$realname && !$idcard && !$zimage && !$fimage) {
            $this->error(__('Invalid parameters'));
        }
        $userauthModel = new \app\common\model\UserAuth();
        $data = [];
        $data["user_id"] = $this->auth->id;
        //$data["idcard"] = $idcard;
        $userAuth = $userauthModel->where($data)->find();
        if (!empty($userAuth)) {
            if(in_array($userAuth['status'],[0,1])) $this->error('您已经申请过了，请勿重复操作！');
        }
        
        // 测试需要 开始
        $data["realname"] = $realname;
        $zimage && $data["zimage"] = $zimage;
        $fimage && $data["fimage"] = $fimage;
        $data["status"] = 1;
        if (!empty($userAuth)) {
            $data["updatetime"] = time();
            $authWhere['user_id'] = $this->auth->id;
            $res = $userauthModel->where($authWhere)->update($data);
        } else {
            $data["createtime"] = time();
            $res = $userauthModel->insertGetId($data);
        }
        if($res) {
            \app\common\model\User::update(["is_auth"=>2],["id"=>$this->auth->id]);
            $this->success("恭喜，实名认证成功！");
        } else {
            $this->error("网络错误，请稍后重试");
        }
        // 测试需要 结束

        // 实名认证验证
        $configInfo = config("auth");
        $outh = new outh($configInfo["api_url"],$configInfo["customer_code"],$configInfo["private_key"],$configInfo["key"]);

        $out_trade_no = date("YmdHis").rand(1000,9999);
        $ret = $outh->toVerify($out_trade_no,$realname,$idcard);

        if(isset($ret["code"])) {
           if($ret["code"] == "1008") {
               $this->error(__('身份证格式错误'));
           }
            if($ret["code"] == "1009") {
                $this->error(__('身份证格式错误'));
            }
            if($ret["code"] == "0001") {
                $this->error(__('姓名和身份证号不匹配！'));
            }
            if($ret["code"] == "0000") {
                $data["realname"] = $realname;
                $zimage && $data["zimage"] = $zimage;
                $fimage && $data["fimage"] = $fimage;
                $data["status"] = 1;
                $data["createtime"] = time();
                $res = $userauthModel->insertGetId($data);
                if($res) {
                    \app\common\model\User::update(["is_auth"=>2],["id"=>$this->auth->id]);
                    $this->success("恭喜，实名认证成功！");
                } else {
                    $this->error("网络错误，请稍后重试");
                }
            }
        } else {
            $this->error("网络错误，请稍后重试");
        }

    }

    /**
     * 获取主播分类
     */
    public function getAnchorType() {
        $this->success("获取成功！",\app\common\model\UserAnchorType::select());
    }





    /**
     * redis 数据恢复---非redis数据丢失请勿使用！！！！
     */
    public function shujuhuifu() {
        $key = $this->request->request("key");// 操作验证 123456
        if($key != 123456) {
            $this->error(__('Invalid parameters'));
        }
        $giftuserpartyModel = new \app\common\model\GiftUserParty();
        $redis = new Redis();
        $redisconfig = config("redis");
        $redis->connect($redisconfig["host"], $redisconfig["port"]);
        if ($redisconfig['redis_pwd']) {
            $redis->auth($redisconfig['redis_pwd']);
        }
        if($redisconfig['redis_selectdb'] > 0){
            $redis->select($redisconfig['redis_selectdb']);
        }

        // 获取本周第一天
        $weekday = $this->firstOfWeek(date("Y-m-d H:i:s"));
        // 获取本月第一天
        $monthday = date("Ym01");
        $where = [];
        $where["createtime"] = ["gt",strtotime($weekday)];
        $list1 = $giftuserpartyModel->where($where)->select();

        foreach($list1 as $k => $v) {
            // 添加redis记录做财富排行榜周榜用
            $redis->zIncrBy("jewel_get_".$v["party_id"].":".$weekday,$v["value"],$v["user_to_id"]);
            // 添加redis记录做贡献排行榜周榜用
            $redis->zIncrBy("jewel_to_".$v["party_id"].":".$weekday,$v["value"],$v["user_id"]);
        }

        $where = [];
        $where["createtime"] = ["gt",strtotime(date("Y-m-01"))];
        $list2 = $giftuserpartyModel->where($where)->select();

        foreach($list2 as $k => $v) {
            // 添加redis记录做财富排行榜月榜用
            $redis->zIncrBy("jewel_get_".$v["party_id"].":".$monthday,$v["value"],$v["user_to_id"]);
            // 添加redis记录做贡献排行榜月榜用
            $redis->zIncrBy("jewel_to_".$v["party_id"].":".$monthday,$v["value"],$v["user_id"]);
        }
        $this->success("执行成功！");
    }



    /**
     * 获取用户等级说明
     */
    public function getLevelExplain() {
        $data = \app\common\model\UserLevelExplain::field("title,content")->select();
        return $this->success("获取成功！",$data);
    }

    /**
     * 获取用户等级信息
     */
    public function getUserLevelInfo() {
        $res = [];$exstart = 0;$exend = 0;
        $userModel = new \app\common\model\User();
        $userInfo = $userModel->field("id,nickname,avatar,level,empirical")->where(["id"=>$this->auth->id])->find();
        if(!$userInfo) {
            $this->error("用户信息获取失败！");
        }
        $res["avatar"] = $userInfo['avatar'];
        $res["nickname"] = $userInfo['nickname'];

        // 获取用户当前经验值对应等级
        $userconfigModel = new \app\common\model\UserLevelConfig();
        $where = [];
        $where["empirical"] = ["elt",$userInfo["empirical"]];
        $userexplainstart = $userconfigModel->where($where)->order("empirical","desc")->limit(1)->select();
        $where = [];
        $where["empirical"] = ["gt",$userInfo["empirical"]];
        $userexplainend = $userconfigModel->where($where)->order("empirical","asc")->limit(1)->select();
        if(!$userexplainstart && !$userexplainend) {
            $this->error("经验等级信息获取失败！");
        } elseif(!$userexplainstart && $userexplainend) {
            $res["level_start"] = 0;
            $res["level_end"] = $userexplainend[0]["level"];
        } elseif($userexplainstart && !$userexplainend) {
            $res["level_start"] = $userexplainstart[0]["level"];
            $res["level_end"] = $userexplainstart[0]["level"];
        } elseif($userexplainstart && $userexplainend) {
            $res["level_start"] = $userexplainstart[0]["level"];
            $res["level_end"] = $userexplainend[0]["level"];
        }
        $userexplainstart && $exstart = $userexplainstart[0]["empirical"];
        $userexplainend && $exend = $userexplainend[0]["empirical"];
        $r1 = $exend-$exstart; // 等级经验值差
        $r2 = $userInfo["empirical"]-$exstart; // 当前等级与最低等级经验值差
        $r3 = $exend-$userInfo["empirical"]; // 还需多少经验值升级
        if($r1 == 0) {
            $res["level_rate"] = 1;
        } elseif($r2 == 0) {
            $res["level_rate"] = 0;
            if($res["level_start"] == $res["level_end"]) {
                $res["level_rate"] = 1;
            }
        } else {
            $res["level_rate"] = intval(($r2/$r1)*100)/100;
        }
        $res["to_up_need"] = $r3>0?$r3:0;

//        // 满级
//        if($r3 == 0 && !$userexplainend) {
//            $res["level_rate"] = 1;
//        }

        $this->success("获取成功！",$res);
    }



}