zhuishuyun_quickapp/app/Http/Controllers/Wap/Oauth/UsersV2Controller.php

<?php

namespace App\Http\Controllers\Wap\Oauth;

use App\Modules\User\Services\WapReaderPageFissionService;
use Illuminate\Http\Request;
use App\Http\Controllers\Controller;
use Cookie;
use App\Modules\User\Services\UserService;
use Log;
use EasyWeChat\Foundation\Application;
use DB;
use Hashids;
use Redis;

class UsersV2Controller extends Controller
{
    public function user_oauth(Request $request){
        Log::info('UsersV2Controller--user_oauth--enter-----------');
        Log::info($request->all());
        $url = $request->get('redirect_url');
        $appid = $request->get('gzh_app_id');
        $channel_id = $request->get('channel_id');
        $sid = $request->get('sid');
        $secter = $this->getAppSecretByAppId($appid);
        $params['appid'] = $appid;
        $params['redirect_url'] = $url;
        $params['channel_id'] = $channel_id;
        $params['sid'] = $sid;
        $options = [
            'app_id'=>$appid,
            'secret'=>$secter,
            'oauth' => [
                'scopes'   => ['snsapi_base'],
                'callback' => env('AUTH_CALLBACK_URL').'?'.http_build_query($params),
            ],
        ];
        Log::info('$options is:');
        Log::info($options);
        $app = new Application($options);
        return $app->oauth->redirect();
    }


    public function wcCallbackParse(Request $request){
        Log::info('UsersV2Controller--wcCallbackParse--enter-----------');
        Log::info($request->all());
        $appid = $request->get('appid');
        $secret = $this->getAppSecretByAppId($appid);
        $url = $request->get('redirect_url');
        $distribution_channel_id = $request->get('channel_id');
        $send_order_id = $request->get('sid');
        $url = urldecode($url);
        $options = [
            'app_id'=>$appid,
            'secret'=>$secret,
        ];
        $url_info = parse_url($url);
        $app = new Application($options);
        $user = null;
        try{
            $user = $app->oauth->user();
        }catch (\Exception $e){
            Log::error('------------wcCallbackParse---------error');
            Log::error($e);
            Log::error('error appid is: '.$appid);
            Log::error(json_encode($request->all()));
            Log::error('------------wcCallbackParse---------error end');
        }
        $user_data = $user['original'];
        Log::info('$user_data is: ');
        Log::info($user_data);
        if(!isset($user_data['unionid'])){
            $user_data['unionid'] = $user_data['openid'];
        }
        $openid = $user_data['openid'];
        $unionid = $user_data['unionid'];
        $user = UserService::getUserByUnionAndChannelId($openid,$distribution_channel_id);
        !isset($url_info['path']) && $url_info['path'] = '/';
        $rp = [];
        $ip = '';
        if(isset($url_info['query'])){
            parse_str($url_info['query'],$rp);
            if(isset($rp['ip'])){
                $ip = $rp['ip'];
                unset($rp['ip']);
            }
        }
        if(!$user){
            $user = $this->createUser($openid,$unionid,$distribution_channel_id,$send_order_id,$ip);
            $from = $request->get('from');
            if($from && $from == 'xiyue' && $distribution_channel_id == 6985){
                $this->xiyueUser($user->id,$openid);
            }
        }


        $query = ['auth_uid'=>$user->id,'atime'=>time()];
        $sign = get_sign($query);
        $query['sign'] = $sign;
        if($rp) $query = array_merge($query,$rp);

        $url = sprintf('%s://%s%s?%s',$url_info['scheme'],$url_info['host'],$url_info['path'],http_build_query($query));
        Log::info('wcCallbackParse back url is :');
        Log::info($url);
        if($send_order_id){
            try{
                Redis::hset('book_read:' . $user->id, 'send_order_id', $send_order_id);
            }catch (\Exception $e){}
        }
        //$previous = url()->previous();
        return redirect()->to($url)->withHeaders(['referer'=>url()->current()]);
    }

    public function wcCallbackParse2(Request $request){
        Log::info('UsersV2Controller--wcCallbackParse--enter-----------');
        Log::info($request->all());
        $appid = $request->get('appid');
        $secret = $this->getAppSecretByAppId($appid);
        $url = $request->get('redirect_url');
        $distribution_channel_id = $request->get('channel_id');
        $send_order_id = $request->get('sid');
        $auth_times = $request->get('auth_times',1);
        $url = urldecode($url);
        $options = [
            'app_id'=>$appid,
            'secret'=>$secret,
        ];
        $url_info = parse_url($url);
        $app = new Application($options);

        $user = null;
        try{
            $user = $app->oauth->user();
        }catch (\Exception $e){
            Log::error('----------------wcCallbackParse2 error----------------');
            Log::error($e);
            Log::error('error appid is: '.$appid);
            Log::error(json_encode($request->all()));
            Log::error('----------------wcCallbackParse2 error------end----------');
        }
        //$user = $app->oauth->user();
        $user_data = $user['original'];
        Log::info('$user_data is: ');
        Log::info($user_data);
        if(!isset($user_data['unionid'])){
            $user_data['unionid'] = $user_data['openid'];
        }
        $openid = $user_data['openid'];
        $unionid = $user_data['unionid'];
        $user = UserService::getUserByUnionAndChannelId($openid,$distribution_channel_id);
        !isset($url_info['path']) && $url_info['path'] = '/';
        $ip = '';
        $rp = [];
        if(isset($url_info['query'])){
            parse_str($url_info['query'],$rp);
            if(isset($rp['ip'])){
                $ip = $rp['ip'];
                unset($rp['ip']);
            }
        }
        if(!$user){
            $auth_redirect_two_appids = specialChannelAuthInfo();
            if($auth_times == 1 && $auth_redirect_two_appids && isset($auth_redirect_two_appids[$distribution_channel_id])){
                $params['redirect_url'] = $request->get('redirect_url');
                $params['timestamp'] = time();
                $params['channel_id'] = $distribution_channel_id;
                $params['appid'] = $auth_redirect_two_appids[$distribution_channel_id];
                $params['sid'] = $send_order_id;
                $params['auth_times'] = 2;
                //$params['sign'] = $this->getSign($params, env('OAUTH_KEY'));
                $secret = $this->getAppSecretByAppId($auth_redirect_two_appids[$distribution_channel_id]);
                $options = [
                    'app_id' => $auth_redirect_two_appids[$distribution_channel_id],
                    'secret' => $secret,
                    'oauth' => [
                        'scopes' => ['snsapi_base'],
                        'callback' => env('AUTH_CALLBACK_URL_V2_2') . '?' . http_build_query($params),],];
                $app = new Application($options);
                return $app->oauth->redirect();
            }else{
                $user = $this->createUser($openid,$unionid,$distribution_channel_id,$send_order_id,$ip);
            }
        }

        $query = ['auth_uid'=>$user->id,'atime'=>time()];
        $sign = get_sign($query);
        $query['sign'] = $sign;
        if($rp) $query = array_merge($query,$rp);
        $url = sprintf('%s://%s%s?%s',$url_info['scheme'],$url_info['host'],$url_info['path'],http_build_query($query));
        Log::info('wcCallbackParse back url is :');
        Log::info($url);
        if($send_order_id){
            try{
                Redis::hset('book_read:' . $user->id, 'send_order_id', $send_order_id);
            }catch (\Exception $e){}
        }
        //$previous = url()->previous();
        return redirect()->to($url);
    }

    private function createUser($openid,$unionid,$distribution_channel_id,$send_order_id,$ip){
        $user = null;
        try{
            $user =  UserService::addUser(
                ['openid' => $openid,
                    'unionid' => $unionid,
                    'distribution_channel_id' =>$distribution_channel_id,
                    'send_order_id'=>$send_order_id,
                    'is_new'=>1,
                    'register_ip'=>$ip
                ]);
        }catch (\Exception $e){
            myLog('user-error')->info($e);
        }

        // 注册动作
        $action_type = 'Register';
        $param = [
            'openid' => $openid,
            'uid' => isset($user->id)?$user->id:'0',
        ];
        UserService::PushUserActionToQueue($action_type,$distribution_channel_id,$param);
        return $user;
    }

    /**
     * 根据apid获取secret
     * @param $appId
     * @return string
     */
    private function getAppSecretByAppId($appId){
        $info = DB::table('official_setting')->where('appid',$appId)->select('secret')->first();
        if($info){
            return $info->secret;
        }
        return '';
    }


    private function xiyueUser($uid,$openid){
        try{
            DB::table('xiyue_zsy_users')->insert([
                'uid'=>$uid,
                'xiyue_uid'=>0,
                'openid'=>$openid,
                'created_at'=>date('Y-m-d H:i:s'),
                'updated_at'=>date('Y-m-d H:i:s')
            ]);
        }catch (\Exception $e){}

    }

}