littleTiger/application/common/logic/saas/Wx3rdLogic.php

<?php
/**
 * tpshop
 * ============================================================================
 * * 版权所有 2015-2027 深圳搜豹网络科技有限公司，并保留所有权利。
 * 网站地址: http://www.tp-shop.cn
 * ----------------------------------------------------------------------------
 * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用 .
 * 不允许对程序代码以任何形式任何目的的再发布。
 * 采用TP5助手函数可实现单字母函数M D U等,也可db::name方式,可双向兼容
 * ============================================================================
 * @Author: lhb
 */ 
namespace app\common\logic\saas;

use app\common\model\saas\Users;
use app\common\model\saas\Wx3rd;
use app\common\model\saas\Miniapp;
use app\common\model\saas\UserMiniapp;
use app\common\logic\saas\wechat\Wx3rdPlatform;

/**
 * 微信第三方平台逻辑处理
 */
class Wx3rdLogic
{
    public $wx3rd = null;
    
    public function __construct()
    {
        $this->wx3rd = Wx3rdPlatform::getInstance();
    }

    /**
     * 处理：授权事件接收，配置在：第三方平台的授权事件接收URL
     */
    public function handleAuthMessage()
    {
        $this->wx3rd->handleAuthEvent(Wx3rdPlatform::AUTH_EVENT_VERIFY_TICKET, function ($msg) {
            $this->handleVerifyTicketEvent($msg);
        });

        $this->wx3rd->handleAuthEvent(Wx3rdPlatform::AUTH_EVENT_UNAUTHORIZED, function ($msg) {
            $this->handleUnauthorizedEvent($msg);
        });

        $this->wx3rd->handleAuthEvent(Wx3rdPlatform::AUTH_EVENT_AUTHORIZED, function ($msg) {
            $this->handleAuthSuccessEvent($msg);
        });

        $this->wx3rd->handleAuthEvent(Wx3rdPlatform::AUTH_EVENT_UPDATE_AUTHORIZED, function ($msg) {
            $this->handleAuthSuccessEvent($msg);
        });
    }

    private function handleVerifyTicketEvent($msg)
    {
        Wx3rd::update([
            'verify_ticket' => $msg['ComponentVerifyTicket'],
            'verify_ticket_time' => time()
        ], ['appid' => $msg['AppId']]);
    }

    private function handleUnauthorizedEvent($msg)
    {
        Miniapp::update([
            'is_auth' => 0,
            'access_token_expires' => 0,
            'tester' => ''
        ], ['appid' => $msg['AuthorizerAppid']]);
    }

    private function handleAuthSuccessEvent($msg)
    {
        $data = [
            'is_auth'           => 1,
            'appid'             => $msg['AuthorizerAppid'],
            //'auth_code'         => $msg['AuthorizationCode'],
            //'auth_code_expires' => $msg['AuthorizationCodeExpiredTime'],
            //'pre_auth_code'     => $msg['PreAuthCode'],
        ];
        $return = $this->getAuthUserInfo($msg['AuthorizerAppid']);
        if ($return['status'] == 1) {
            $data = array_merge($data, $return['result']);
        }
        $miniapp = Miniapp::update($data, ['appid' => $msg['AuthorizerAppid']]);

        $miniapp && $miniapp = Miniapp::get(['miniapp_id' => $miniapp->miniapp_id]);
        if ($miniapp && $user = Users::get(['user_id' => $miniapp->user_id])) {
            if (!$user->head_img && $miniapp->head_img) {
                $user->save(['head_img' => $miniapp->head_img]);
            }
        }
    }

    /**
     * 处理普通的推送消息，如公众号消息，小程序审核消息等
     * @param $appid
     */
    public function handleCommonMessage($appid)
    {
        $this->wx3rd->handleCommonEvent(Wx3rdPlatform::COMMON_EVENT_WEAPP_AUDIT_SUCCESS, function ($msg) {
            $this->handleMiniappAuditSuccessEvent($msg);
        });

        $this->wx3rd->handleCommonEvent(Wx3rdPlatform::COMMON_EVENT_WEAPP_AUDIT_FAIL, function ($msg) {
            $this->handleMiniappAuditFailEvent($msg);
        });
    }

    private function handleMiniappAuditSuccessEvent($msg)
    {
        $miniapp = Miniapp::get(['origin_id' => $msg['ToUserName']]);
        if ($miniapp) {
            $miniapp->userMiniapps()
                ->where(['status' => UserMiniapp::STATUS_AUDITING])
                ->update(['status' => UserMiniapp::STATUS_AUDIT_DONG]);
        }
    }

    private function handleMiniappAuditFailEvent($msg)
    {
        $miniapp = Miniapp::get(['origin_id' => $msg['ToUserName']]);
        if ($miniapp) {
            $miniapp->userMiniapps()
                ->where(['status' => UserMiniapp::STATUS_AUDITING])
                ->update(['status' => UserMiniapp::STATUS_AUDIT_FAIL, 'audit_fail_reason' => $msg['Reason']]);
        }
    }
    
    /**
     * 用户授权
     * @param string $userId
     * @param string $authCode 用户授权码，用户扫码授权后返回的授权码
     * @return array
     */
    public function authByUser($userId, $authCode)
    {
        $user = Users::get($userId);
        if (!$user) {
            return ['status' => -1, 'msg' => '账户不存在'.$userId];
        }

        $info = $this->wx3rd->getAuthInfo($authCode);
        if ($info === false) {
            return ['status' => -1, 'msg' => $this->wx3rd->getError()];
        }

        $miniapp = Miniapp::where(['appid' => $info['authorizer_appid']])->find();
        if ($miniapp && $miniapp->is_auth && $miniapp->user_id != $userId) {
            return ['status' => -1, 'msg' => '小程序已被其他账号绑定！'];
        }
        
        $data = [
            'appid'         => $info['authorizer_appid'],
            'access_token'  => $info['authorizer_access_token'],
            'access_token_expires' => time() + $info['expires_in'] - 200, //提前200s失效
            'refresh_token' => $info['authorizer_refresh_token'],
            'is_auth'       => 1,
            'auth_time'     => time(),
            'user_id'       => $userId
        ];
        $authUser = $this->getAuthUserInfo($info['authorizer_appid']);
        if ($authUser['status'] == 1) {
            $data = array_merge($data, $authUser['result']);
        }

        if ($miniapp) {
            $miniapp->save($data);
        } else {
            $miniapp = Miniapp::create($data);
        }

        if (!$user->head_img && $miniapp->head_img) {
            $user->save(['head_img' => $miniapp->head_img]);
        }

        session('saas_user', $user->toArray());

        return ['status' => 1, 'msg' => '授权成功'];
    }

    /**
     * 转换用户数据
     * @param array $data
     * @return array
     */
    public function convertUserData($data)
    {
        return [
            'origin_id'      => $data['authorizer_info']['user_name'],
            'nickname'       => $data['authorizer_info']['nick_name'] ?: '我的小程序'.rand(0, 999),
            'head_img'       => $data['authorizer_info']['head_img'],
            'principal_name' => $data['authorizer_info']['principal_name'],
            'signature'      => $data['authorizer_info']['signature'],
            'domains' => $data['authorizer_info']['MiniProgramInfo']['network'],
        ];
    }

    /**
     * 更新用户授权信息
     * @param $appid
     * @return array
     */
    public function getAuthUserInfo($appid)
    {
        $authUser = $this->wx3rd->getAuthorizerInfo($appid);
        if ($authUser === false) {
            return ['status' => -1, 'msg' => $this->wx3rd->getError()];
        }
        return ['status' => 1, 'msg' => '获取成功', 'result' => $this->convertUserData($authUser)];
    }

    /**
     * 接收消息成功后返回
     */
    public function echoMsgSuccess()
    {
        if (ob_get_level() == 0) {
            ob_start();
        }

        ob_implicit_flush(true);
        ob_clean();

        header("Content-type: text/plain");
        echo('success');

        ob_flush();
        flush();
        ob_end_flush();

        exit();
    }
}