ql-gw-laravel5/app/Http/Controllers/Weixin/UserController.php

<?php
namespace App\Http\Controllers\Weixin;

use App\Http\Controllers\Weixin\CommonController;
use Illuminate\Http\Request;
use App\Common\ReturnCode;
use App\Common\ReturnData;
use App\Common\Wechat\WechatAuth;
use App\Common\Helper;

class UserController extends CommonController
{
    public function __construct()
    {
        parent::__construct();
    }
	
    //个人中心
    public function index(Request $request)
	{
        //$_SESSION['weixin_user_info']['access_token'] = '72d623d26a1a6d61186a97f9ccf752f7';
        
        //获取会员信息
        $postdata = array(
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_info";
		$res = curl_request($url,$postdata,'GET');
        $data['user_info'] = $res['data'];
        
        if($res['code'] != ReturnData::SUCCESS){unset($_SESSION['weixin_user_info']);$this->error_jump('请先登录',route('weixin_login'));}
        
		return view('weixin.user.index', $data);
	}
    
    //个人中心设置
    public function userinfo(Request $request)
	{
        //获取会员信息
        $postdata = array(
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_info";
		$res = curl_request($url,$postdata,'GET');
        $data['user_info'] = $res['data'];
        
		return view('weixin.user.userinfo', $data);
	}
    
    //我的分销
    public function userDistribution(Request $request)
	{
        //获取会员信息
        $postdata = array(
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_info";
		$res = curl_request($url,$postdata,'GET');
        $data['user_info'] = $res['data'];
        
        //获取直属下级会员列表
        $pagesize = 10;
        $offset = 0;
        if(isset($_REQUEST['page'])){$offset = ($_REQUEST['page']-1)*$pagesize;}
        
        $postdata = array(
            'limit'  => $pagesize,
            'offset' => $offset,
            'parent_id' => $_SESSION['weixin_user_info']['id'],
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_list";
		$res = curl_request($url,$postdata,'GET');
        $data['list'] = $res['data']['list'];
        
        $data['totalpage'] = ceil($res['data']['count']/$pagesize);
        
        if(isset($_REQUEST['page_ajax']) && $_REQUEST['page_ajax']==1)
        {
    		$html = '';
            
            if($res['data']['list'])
            {
                foreach($res['data']['list'] as $k => $v)
                {
                    $html .= '<li><span class="goods_thumb" style="width:72px;height:72px;"><img style="width:72px;height:72px;" alt="'.$v['user_name'].'" src="'.$v['head_img'].'"></span>';
                    $html .= '<div class="goods_info"><p class="goods_tit">'.$v['user_name'].'</p>';
                    $html .= '<p style="line-height:24px;">佣金：'.$v['commission'].'</p>';
                    $html .= '<p style="line-height:24px;">注册时间：'.date('Y-m-d',$v['add_time']).'</p>';
                    $html .= '</div></li>';
                }
            }
            
    		exit(json_encode($html));
    	}
        
		return view('weixin.user.userDistribution', $data);
	}
    
    //资金管理
    public function userAccount(Request $request)
	{
        $postdata = array(
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_info";
		$res = curl_request($url,$postdata,'GET');
        $data['user_info'] = $res['data'];
        
        return view('weixin.user.userAccount', $data);
    }
    
    //提现
    public function userWithdraw(Request $request)
	{
        $postdata = array(
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_info";
		$res = curl_request($url,$postdata,'GET');
        $data['user_info'] = $res['data'];
        $data['is_withdraw'] = 0; //是否达到可提现要求，0否
        $data['min_withdraw_money'] = sysconfig('CMS_MIN_WITHDRAWAL_MONEY'); //最低可提现金额
        
        if($data['user_info']['money']>=$data['min_withdraw_money']){$data['is_withdraw'] = 1;}
        
        return view('weixin.user.userWithdraw', $data);
    }
    
    //提现明细
    public function userWithdrawList(Request $request)
	{
        $pagesize = 10;
        $offset = 0;
        if(isset($_REQUEST['page'])){$offset = ($_REQUEST['page']-1)*$pagesize;}
        
        $postdata = array(
            'limit'  => $pagesize,
            'offset' => $offset,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_withdraw_list";
		$res = curl_request($url,$postdata,'GET');
        $data['list'] = $res['data']['list'];
        
        $data['totalpage'] = ceil($res['data']['count']/$pagesize);
        
        if(isset($_REQUEST['page_ajax']) && $_REQUEST['page_ajax']==1)
        {
    		$html = '';
            
            if($res['data']['list'])
            {
                foreach($res['data']['list'] as $k => $v)
                {
                    $html .= '<li>';
                    $html .= '<span class="green">- '.$v['money'].'</span>';
                    $html .= '<div class="info"><p class="tit">提现</p>';
                    $html .= '<p class="des">收款账号:'.$v['name'].' ,提现方式:'.$v['method'].' ,姓名:'.$v['name'].'<br>状态:<font color="red">'.$v['status_text'].'</font></p>';
                    $html .= '<p class="time">'.date('Y-m-d H:i:s',$v['add_time']).'</p></div>';
                    $html .= '</li>';
                }
            }
            
    		exit(json_encode($html));
    	}
        
        return view('weixin.user.userWithdrawList', $data);
    }
    
    //用户充值
    public function userRecharge(Request $request)
	{
        return view('weixin.user.userRecharge');
    }
    
    //充值明细
    public function userRechargeOrder(Request $request)
	{
        $pagesize = 10;
        $offset = 0;
        if(isset($_REQUEST['page'])){$offset = ($_REQUEST['page']-1)*$pagesize;}
        
        $postdata = array(
            'limit'  => $pagesize,
            'offset' => $offset,
            'status' => 1,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_recharge_list";
		$res = curl_request($url,$postdata,'GET');
        $data['list'] = $res['data']['list'];
        
        $data['totalpage'] = ceil($res['data']['count']/$pagesize);
        
        if(isset($_REQUEST['page_ajax']) && $_REQUEST['page_ajax']==1)
        {
    		$html = '';
            
            if($res['data']['list'])
            {
                foreach($res['data']['list'] as $k => $v)
                {
                    $html .= '<li>';
                    $html .= '<span class="green">+ '.$v['money'].'</span>';
                    $html .= '<div class="info"><p class="tit">充值</p>';
                    $html .= '<p class="time">'.date('Y-m-d H:i:s', $v['created_at']).'</p></div>';
                    $html .= '</li>';
                }
            }
            
    		exit(json_encode($html));
    	}
        
        return view('weixin.user.userRechargeOrder', $data);
    }
    
    //用户充值第二步，支付
    public function userRechargeOrderDetail(Request $request)
	{
        $id = $request->input('id','');
        if($id == ''){$this->error_jump(ReturnData::PARAMS_ERROR);}
        
        //获取充值记录详情
        $postdata = array(
            'id' => $id,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_recharge_detail";
		$res = curl_request($url,$postdata,'GET');
        $user_recharge = $data['post'] = $res['data'];
        
        //微信支付-start
        require_once(resource_path('org/wxpay/WxPayConfig.php')); // 导入微信配置类
        require_once(resource_path('org/wxpay/WxPayPubHelper.class.php')); // 导入微信支付类
        
		$body = '充值';//订单详情
		$out_trade_no = $user_recharge['recharge_sn'];//订单号
		$total_fee = floatval($user_recharge['money']*100);//价格0.01
        $attach = 'pay_type=1'; //附加数据，pay_type=1充值支付，示例：xxx=1&yyy=2
		$notify_url = route('notify_wxpay_jsapi');//通知地址
		$wxconfig= \WxPayConfig::wxconfig();
        
		//=========步骤1：网页授权获取用户openid============
		$jsApi = new \JsApi_pub($wxconfig);
		$openid = $jsApi->getOpenid();
		//=========步骤2：使用统一支付接口，获取prepay_id============
		//使用统一支付接口
        $unifiedOrder = new \UnifiedOrder_pub($wxconfig);
		//设置统一支付接口参数
		//设置必填参数
		//appid已填,商户无需重复填写
		//mch_id已填,商户无需重复填写
		//noncestr已填,商户无需重复填写
		//spbill_create_ip已填,商户无需重复填写
		//sign已填,商户无需重复填写
		$unifiedOrder->setParameter("openid","$openid");//微信用户
		$unifiedOrder->setParameter("body","$body");//商品描述
		$unifiedOrder->setParameter("out_trade_no","$out_trade_no");//商户订单号
		$unifiedOrder->setParameter("total_fee","$total_fee");//总金额
		$unifiedOrder->setParameter("attach","$attach"); //附加数据，选填，在查询API和支付通知中原样返回，可作为自定义参数使用，示例：a=1&b=2
        $unifiedOrder->setParameter("notify_url","$notify_url");//通知地址
		$unifiedOrder->setParameter("trade_type","JSAPI");//交易类型
		$prepay_id = $unifiedOrder->getPrepayId();
		//=========步骤3：使用jsapi调起支付============
		$jsApi->setPrepayId($prepay_id);
		$jsApiParameters = $jsApi->getParameters();
        
		$data['jsApiParameters'] = $jsApiParameters;
        $data['returnUrl'] = route('weixin_user_recharge_order'); //支付完成要跳转的url
        return view('weixin.user.userRechargeOrderDetail', $data);
    }
    
    //余额明细
    public function userMoneyList(Request $request)
	{
        $pagesize = 10;
        $offset = 0;
        if(isset($_REQUEST['page'])){$offset = ($_REQUEST['page']-1)*$pagesize;}
        
        $postdata = array(
            'limit'  => $pagesize,
            'offset' => $offset,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_money_list";
		$res = curl_request($url,$postdata,'GET');
        $data['list'] = $res['data']['list'];
        
        $data['totalpage'] = ceil($res['data']['count']/$pagesize);
        
        if(isset($_REQUEST['page_ajax']) && $_REQUEST['page_ajax']==1)
        {
    		$html = '';
            
            if($res['data']['list'])
            {
                foreach($res['data']['list'] as $k => $v)
                {
                    $html .= '<li>';
                    if($v['type']==0)
                    {
                        $html .= '<span class="green">+ '.$v['money'].'</span>';
                    }
                    else
                    {
                        $html .= '<span>- '.$v['money'].'</span>';
                    }
                    $html .= '<div class="info"><p class="tit">'.$v['des'].'</p>';
                    $html .= '<p class="time">'.date('Y-m-d H:i:s',$v['add_time']).'</p></div>';
                    $html .= '</li>';
                }
            }
            
    		exit(json_encode($html));
    	}
        
        return view('weixin.user.userMoneyList', $data);
    }
    
    //积分明细
    public function userPointList(Request $request)
	{
        $pagesize = 10;
        $offset = 0;
        if(isset($_REQUEST['page'])){$offset = ($_REQUEST['page']-1)*$pagesize;}
        
        $postdata = array(
            'limit'  => $pagesize,
            'offset' => $offset,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_point_list";
		$res = curl_request($url,$postdata,'GET');
        $data['list'] = $res['data']['list'];
        
        $data['totalpage'] = ceil($res['data']['count']/$pagesize);
        
        if(isset($_REQUEST['page_ajax']) && $_REQUEST['page_ajax']==1)
        {
    		$html = '';
            
            if($res['data']['list'])
            {
                foreach($res['data']['list'] as $k => $v)
                {
                    $html .= '<li>';
                    if($v['type']==0)
                    {
                        $html .= '<span class="green">+ '.$v['point'].'</span>';
                    }
                    else
                    {
                        $html .= '<span>- '.$v['point'].'</span>';
                    }
                    $html .= '<div class="info"><p class="tit">'.$v['des'].'</p>';
                    $html .= '<p class="time">'.date('Y-m-d H:i:s',$v['add_time']).'</p></div>';
                    $html .= '</li>';
                }
            }
            
    		exit(json_encode($html));
    	}
        
        return view('weixin.user.userPointList', $data);
    }
    
    //用户优惠券列表
    public function userBonusList(Request $request)
	{
        //商品列表
        $pagesize = 10;
        $offset = 0;
        if(isset($_REQUEST['page'])){$offset = ($_REQUEST['page']-1)*$pagesize;}
        
        $postdata = array(
            'limit'  => $pagesize,
            'offset' => $offset,
            'status' => 0,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_bonus_list";
		$res = curl_request($url,$postdata,'GET');
        $data['list'] = $res['data']['list'];
        
        $data['totalpage'] = ceil($res['data']['count']/$pagesize);
        
        if(isset($_REQUEST['page_ajax']) && $_REQUEST['page_ajax']==1)
        {
    		$html = '';
            
            if($res['data']['list'])
            {
                foreach($res['data']['list'] as $k => $v)
                {
                    $html .= '<div class="flow-have-adr">';
                    $html .= '<p class="f-h-adr-title">'.$v['bonus']['name'].'</label><span class="ect-colory fr"><small>￥</small>'.$v['bonus']['money'].'</span><div class="cl"></div></p>';
                    $html .= '<p class="f-h-adr-con">有效期至'.$v['bonus']['end_time'].' <span class="fr">满'.$v['bonus']['min_amount'].'可用</span></p>';
                    //$html .= '<div class="adr-edit-del">说明</div>';
                    $html .= '</div>';
                }  
            }
            
    		exit(json_encode($html));
    	}
        
        return view('weixin.user.userBonusList', $data);
	}
    
    //用户消息
    public function userMessageList(Request $request)
	{
        $pagesize = 10;
        $offset = 0;
        if(isset($_REQUEST['page'])){$offset = ($_REQUEST['page']-1)*$pagesize;}
        
        $postdata = array(
            'limit'  => $pagesize,
            'offset' => $offset,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_message_list";
		$res = curl_request($url,$postdata,'GET');
        $data['list'] = $res['data']['list'];
        
        $data['totalpage'] = ceil($res['data']['count']/$pagesize);
        
        if(isset($_REQUEST['page_ajax']) && $_REQUEST['page_ajax']==1)
        {
    		$html = '';
            
            if($res['data']['list'])
            {
                foreach($res['data']['list'] as $k => $v)
                {
                    $html .= '<li>';
                    if($v['title']==0)
                    {
                        $html .= '<p class="tit">'.$v['title'].'</p>';
                    }
                    
                    if($v['des']==0)
                    {
                        $html .= '<p class="des">'.$v['des'].'</p>';
                    }
                    
                    $html .= '<p class="time">'.date('Y-m-d H:i:s',$v['add_time']).'</p>';
                    $html .= '</li>';
                }
            }
            
    		exit(json_encode($html));
    	}
        
        return view('weixin.user.userMessageList', $data);
    }
    
    //浏览记录
    public function userGoodsHistory(Request $request)
	{
        //商品列表
        $pagesize = 10;
        $offset = 0;
        if(isset($_REQUEST['page'])){$offset = ($_REQUEST['page']-1)*$pagesize;}
        
        $postdata = array(
            'limit'  => $pagesize,
            'offset' => $offset,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_goods_history_list";
		$res = curl_request($url,$postdata,'GET');
        $data['user_goods_history'] = $res['data']['list'];
        
        $data['totalpage'] = ceil($res['data']['count']/$pagesize);
        
        if(isset($_REQUEST['page_ajax']) && $_REQUEST['page_ajax']==1)
        {
    		$html = '';
            
            if($res['data']['list'])
            {
                foreach($res['data']['list'] as $k => $v)
                {
                    $html .= '<li><a href="'.$v['goods']['goods_detail_url'].'"><span class="goods_thumb"><img alt="'.$v['goods']['title'].'" src="'.env('APP_URL').$v['goods']['litpic'].'"></span></a>';
                    $html .= '<div class="goods_info"><p class="goods_tit">'.$v['goods']['title'].'</p>';
                    $html .= '<p class="goods_price">￥<b>'.$v['goods']['price'].'</b></p>';
                    $html .= '<p class="goods_des fr"><span id="del_history" onclick="delconfirm(\''.route('weixin_user_goods_history_delete',array('id'=>$v['id'])).'\')">删除</span></p>';
                    $html .= '</div></li>';
                }
            }
            
    		exit(json_encode($html));
    	}
        
        return view('weixin.user.userGoodsHistory', $data);
	}
    
    //浏览记录删除
    public function userGoodsHistoryDelete(Request $request)
	{
        $id = $request->input('id','');
        
        if($id == ''){$this->error_jump(ReturnData::PARAMS_ERROR);}
        
        $postdata = array(
            'id' => $id,
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_goods_history_delete";
		$res = curl_request($url,$postdata,'POST');
        
        if($res['code'] != ReturnData::SUCCESS){$this->error_jump(ReturnCode::FAIL);}
        
        $this->success_jump(ReturnCode::SUCCESS);
	}
    
    //浏览记录清空
    public function userGoodsHistoryClear(Request $request)
	{
        $postdata = array(
            'access_token' => $_SESSION['weixin_user_info']['access_token']
		);
        $url = env('APP_API_URL')."/user_goods_history_clear";
		$res = curl_request($url,$postdata,'POST');
        
        if($res['code'] != ReturnData::SUCCESS){$this->error_jump(ReturnCode::FAIL);}
        
        $this->success_jump(ReturnCode::SUCCESS);
	}
    
    //微信网页授权登录
    public function oauth(Request $request)
	{
        if (!isset($_SESSION['weixin_oauth']['userinfo']))
        {
            $wechat_auth = new WechatAuth(sysconfig('CMS_WX_APPID'),sysconfig('CMS_WX_APPSECRET'));
            
            // 获取code码，用于和微信服务器申请token。 注：依据OAuth2.0要求，此处授权登录需要用户端操作
            if(!isset($_GET['code']))
            {
                $http_type = ((isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] == 'on') || (isset($_SERVER['HTTP_X_FORWARDED_PROTO']) && $_SERVER['HTTP_X_FORWARDED_PROTO'] == 'https')) ? 'https://' : 'http://';
                $callback_url = $http_type . $_SERVER['HTTP_HOST'] . $_SERVER['REQUEST_URI']; //回调地址，当前页面
                //生成唯一随机串防CSRF攻击
                $state = md5(uniqid(rand(), true));
                $_SESSION['weixin_oauth']['state'] = $state; //存到SESSION
                $authorize_url = $wechat_auth->get_authorize_url($callback_url, $state);
                
                header("Location: $authorize_url");exit;
            }
            
            // 依据code码去获取openid和access_token，自己的后台服务器直接向微信服务器申请即可
            $_SESSION['weixin_oauth']['code'] = $_GET['code'];
            
            if($_GET['state'] != $_SESSION['weixin_oauth']['state'])
            {
                $this->error_jump('您访问的页面不存在或已被删除');
            }
            
            //得到 access_token 与 openid
            $_SESSION['weixin_oauth']['token'] = $wechat_auth->get_access_token($_GET['code']);
            // 依据申请到的access_token和openid，申请Userinfo信息。
            $_SESSION['weixin_oauth']['userinfo'] = $wechat_auth->get_user_info($_SESSION['weixin_oauth']['token']['access_token'], $_SESSION['weixin_oauth']['token']['openid']);
        }
        
        $postdata = array(
            'openid' => $_SESSION['weixin_oauth']['userinfo']['openid'],
            'unionid' => isset($_SESSION['weixin_oauth']['userinfo']['unionid']) ? $_SESSION['weixin_oauth']['userinfo']['unionid'] : '',
            'nickname' => $_SESSION['weixin_oauth']['userinfo']['nickname'],
            'sex' => $_SESSION['weixin_oauth']['userinfo']['sex'],
            'head_img' => $_SESSION['weixin_oauth']['userinfo']['headimgurl'],
            'parent_id' => isset($_SESSION['weixin_user_invite_code']) ? $_SESSION['weixin_user_invite_code'] : 0,
            'parent_mobile' => '',
            'mobile' => ''
        );
        $url = env('APP_API_URL')."/wx_oauth_register";
        $res = curl_request($url,$postdata,'POST');
        if($res['code'] != ReturnData::SUCCESS){$this->error_jump('系统错误');}
        
        $_SESSION['weixin_user_info'] = $res['data'];
        header('Location: '.route('weixin_user'));exit;
	}
    
    //登录
    public function login(Request $request)
	{
        if(isset($_SESSION['weixin_user_info']))
        {
            if(isset($_SERVER["HTTP_REFERER"])){header('Location: '.$_SERVER["HTTP_REFERER"]);exit;}
            header('Location: '.route('weixin_user'));exit;
        }
        
        $return_url = '';
        if(isset($_REQUEST['return_url']) && !empty($_REQUEST['return_url'])){$return_url = $_SESSION['weixin_history_back_url'] = $_REQUEST['return_url'];}
        
        if($_SERVER['REQUEST_METHOD'] == 'POST')
        {
            if($_POST['user_name'] == '')
            {
                $this->error_jump('账号不能为空');
            }
            
            if($_POST['password'] == '')
            {
                $this->error_jump('密码不能为空');
            }
            
            $postdata = array(
                'user_name' => $_POST['user_name'],
                'password' => md5($_POST['password'])
            );
            $url = env('APP_API_URL')."/wx_login";
            $res = curl_request($url,$postdata,'POST');
            
            if($res['code'] != ReturnData::SUCCESS){$this->error_jump('登录失败');}
            
            $_SESSION['weixin_user_info'] = $res['data'];
            
            if($return_url != ''){header('Location: '.$return_url);exit;}
            header('Location: '.route('weixin_user'));exit;
        }
        
        return view('weixin.user.login');
	}
    
    //注册
    public function register(Request $request)
	{
        if(isset($_SESSION['weixin_user_info']))
        {
            if(isset($_SERVER["HTTP_REFERER"])){header('Location: '.$_SERVER["HTTP_REFERER"]);exit;}
            header('Location: '.route('weixin_user'));exit;
        }
        
        $return_url = '';
        if(isset($_REQUEST['return_url']) && !empty($_REQUEST['return_url'])){$_SESSION['weixin_history_back_url'] = $_REQUEST['return_url'];}
        if(isset($_REQUEST['invite_code']) && !empty($_REQUEST['invite_code'])){$_SESSION['weixin_user_invite_code'] = $_REQUEST['invite_code'];} //推荐人id存在session，首页入口也存了一次
        
        return view('weixin.user.register');
	}
    
    public function logout(Request $request)
	{
        session_unset();
        session_destroy(); // 退出登录，清除session
        
		$this->success_jump('退出成功',route('weixin'));
	}
}