<?php
/**
 * SAAS应用系统 --- 十年开发经验汇集巨献!
 * ==========================================================
 * Copy right 2020-2050 成都众联思索科技有限公司,保留所有权利。
 * ----------------------------------------------------------
 * 官方网址: https://www.zoomtk.com
 * 这不是自由软件！未经允许不得用于商业目或程序代码摘取及修改。
 * 任何企业和个人不允许对程序代码以任何形式任何目的再发布传播。
 * 唯一发布渠道www.zoomtk.com;非官方渠道统一视为侵权行为。
 * ==========================================================
 */

namespace addon\wxoplatform\model;

use addon\weapp\model\Weapp;
use addon\wechat\model\Wechat;
use addon\wechat\model\Wechat as WechatModel;
use addon\wechat\model\WechatRequest;
use app\model\system\Servicer as ServicerModel;
use EasyWeChat\Factory;
use app\model\BaseModel;
use EasyWeChat\Kernel\Messages\Text;
use EasyWeChat\Kernel\Messages\Transfer;
use EasyWeChat\OpenPlatform\Server\Guard;
use EasyWeChat\OpenPlatform\Auth\VerifyTicket;
use think\Exception;
use think\facade\Cache;

/**
 * 微信开放平台
 */
class Oplatform extends BaseModel
{


    public $app;//微信公众对象
    public $appConfig = [];//微信公众对象
    public $openConfig = [];//微信公众对象

    public function __construct($site_id = 0, $appid = '')
    {
        //微信配置
        $config_model = new Config();
        $config_result = $config_model->getOplatformConfig($site_id);
        $config = $config_result["data"];
        if (!empty($config)) {
            $config_info = $config["value"];
            $this->openConfig = $config_info;
        }
        $config = [
            'app_id' => $config_info["appid"] ?? '',
            'secret' => $config_info["secret"] ?? '',
            'token' => $config_info["token"] ?? '',
            'aes_key' => $config_info["aes_key"] ?? '',
            'log' => [
                'level' => 'debug',
                'permission' => 0777,
                'file' => 'runtime/log/wechat/oplatform.logs',
            ],
            'http' => [
                'max_retries' => 1,
                'retry_delay' => 500,
                'timeout' => 30,
            ],
        ];
        $this->app = Factory::openPlatform($config);
        $this->app->rebind('request', request());
        $this->app->rebind('cache', Cache::store('redis_public'));
        $this->SetVerifyTicket();
    }

    use MiniCode;

    /**
     * 开放平台获取授权
     * @param $param
     * @return \EasyWeChat\OpenPlatform\Authorizer\MiniProgram\Account\Client|\EasyWeChat\OpenPlatform\Authorizer\OfficialAccount\Account\Client
     */
    public function app($param)
    {
        if ($param["type"] == "wechat") {
            // 代公众号实现业务
            $officialAccount = $this->app->officialAccount($param["authorizer_appid"], $param["authorizer_refresh_token"] ?? null);
            $account = $officialAccount;
        } else {
            // 代小程序实现业务
            $miniProgram = $this->app->miniProgram($param["authorizer_appid"], $param["authorizer_refresh_token"] ?? null);
            $account = $miniProgram;
        }
        return $account;
    }

    /**
     * 获取用户授权页 URL
     * @param $param
     * @return array
     */
    public function getPreAuthorizationUrl($param = [], $optional = [])
    {
        try {
            $result = $this->app->getPreAuthorizationUrl($param['callback'], $optional);
            return $this->success($result);
        } catch (\Exception $e) {
            return $this->error([], $e->getMessage());
        }
    }

    /**
     * 使用授权码换取接口调用凭据和授权信息
     * @param $param
     * @return array
     */
    public function handleAuthorize($param = [])
    {
        try {
            $code = $param["code"] ?? null;
            $result = $this->app->handleAuthorize($code);
            if (isset($result['errcode']) && $result['errcode'] != 0) {
                return $this->error($result, $result["errmsg"]);
            }
            return $this->success($result);
        } catch (\Exception $e) {
            return $this->error([], $e->getMessage());
        }
    }

    /**
     * 获取授权方的帐号基本信息
     * @param array $param
     */
    public function getAuthorizer($param = [])
    {
        try {
            $result = $this->app->getAuthorizer($param["authorizer_appid"]);
            if (isset($result['errcode']) && $result['errcode'] != 0) {
                return $this->error($result, $result["errmsg"]);
            }
            return $this->success($result);
        } catch (\Exception $e) {
            return $this->error([], $e->getMessage());
        }
    }

    /**
     * 授权回调事件响应 https://www.easywechat.com
     */
    public function server()
    {
        $server = $this->app->server;

        $server->push(function ($message) {
            $component_verify_ticket = $message['ComponentVerifyTicket'];
//            file_put_contents(root_path() . 'runtime/log/' . date('YmdHis', time()) . 'ComponentVerifyTicket.TXT', $component_verify_ticket);
            Cache::set('ComponentVerifyTicket', $component_verify_ticket);
            $verify_ticket = new VerifyTicket($this->app);
            $verify_ticket->setTicket(Cache::get('ComponentVerifyTicket'));
            $config_model = new Config();
            $config_result = $config_model->getOplatformConfig();
            $data = $config_result['data']["value"];
            $data['ComponentVerifyTicket'] = $component_verify_ticket;
            $data['VerifyTicketTime'] = time();
            $config_model->setOplatformConfig($data, 1);
        }, Guard::EVENT_COMPONENT_VERIFY_TICKET);

        $server->push(function ($message) { //完成小程序注册授权
            if (isset($message['InfoType']) && $message['InfoType'] == 'notify_third_fasteregister') {
                event('WeappRegister', $message);
            }
        }, Guard::EVENT_THIRD_FAST_REGISTERED);

        // 授权成功事件
        $server->push(function ($message) {

        }, Guard::EVENT_AUTHORIZED);

        // 小程序认证事件
        $server->push(function ($message) {

         file_put_contents(root_path() . 'runtime/log/' . date('YmdHis', time()) . 'notify_3rd_wxa_auth.txt', json_encode($message, JSON_UNESCAPED_UNICODE));

        }, 'notify_3rd_wxa_auth');

        /***
         * 授权更新
         */
        $server->push(function ($message) {


        }, Guard::EVENT_UPDATE_AUTHORIZED);
        // 授权取消事件
        $server->push(function ($message) {
            $appid = $message['AuthorizerAppid'];
            model('config')->update(['value' => ''], [['app_module', '=', 'shop'], ['config_key', 'in', ['WECHAT_CONFIG', 'WEAPP_CONFIG']], ['value', 'like', '%' . $appid . '%'], ['value', 'like', '%is_authopen%']]);
            Cache::tag("config")->clear();
        }, Guard::EVENT_UNAUTHORIZED);

        return $server->serve();
    }

    /***
     * 设置验证
     * @param $ComponentVerifyTicket
     * @return void
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
     * @throws \EasyWeChat\Kernel\Exceptions\RuntimeException
     * @throws \Psr\SimpleCache\InvalidArgumentException
     */
    public function SetVerifyTicket()
    {
        $verify_ticket = new VerifyTicket($this->app);
        try {
            $verify_ticket->getTicket();
        } catch (\Exception $e) {


            $where = [['site_id', '=', 0], ['app_module', '=', 'admin'], ['config_key', '=', 'OPLATFORM_CONFIG']];
            $info = model('config')->getValue($where, 'value');
            if ($info) {
                $v = json_decode($info, true);
                $verify_ticket->setTicket($v['ComponentVerifyTicket'] ?? '');
            }
        }
    }

    /***
     * 全网验证
     */
    public function openCheck($appid)
    {
        $openPlatform = $this->app;
        $server = $openPlatform->server;
        $message = $server->getMessage();
        if (isset($message['MsgType']) && $message['MsgType'] == 'text') {
            if (strpos($message['Content'], 'QUERY_AUTH_CODE') !== false) {
                $query_auth_code = str_replace('QUERY_AUTH_CODE:', '', $message['Content']);
                $authorizerInfo = $openPlatform->handleAuthorize($query_auth_code)['authorization_info'];
                cache($appid, $authorizerInfo);
                $content = "{$query_auth_code}_from_api";
                $curOfficialAccount = $openPlatform->officialAccount(
                    $authorizerInfo['authorizer_appid'],
                    $authorizerInfo['authorizer_refresh_token']
                );
                $curOfficialAccount->customer_service->message($content)
                    ->from($message['ToUserName'])->to($message['FromUserName'])->send();
            }
            if ($message['Content'] == 'TESTCOMPONENT_MSG_TYPE_TEXT') {
                $authorizerInfo = cache($appid);
                $curOfficialAccount = $openPlatform->officialAccount($appid, $authorizerInfo['authorizer_refresh_token']);
                $curOfficialAccount->server->push(function () use ($message) {
                    return new Text('TESTCOMPONENT_MSG_TYPE_TEXT_callback');
                });
                $curOfficialAccount->server->serve()->send();
            }
        } else {
            $server->serve()->send();
        }
    }

    /***
     * 微信消息事件处理
     * @throws \EasyWeChat\Kernel\Exceptions\BadRequestException
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
     * @throws \GuzzleHttp\Exception\GuzzleException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function MsgEvent()
    {
        $openPlatform = $this->app;
        $server = $openPlatform->server;
        $message = $server->getMessage();
        if ($message && isset($message['Event'])) {
            switch ($message['Event']) {
                case 'weapp_audit_fail':
                case 'weapp_audit_success'://小程序审核
                    event('WeappAuditEvent', $message);
                    $server->serve()->send();
                    break;
                case 'weapp_audit_delay':
                case 'wxa_nickname_audit':
                    $server->serve()->send();
                case 'wxa_privacy_apply':
                default:
                    if ($this->appConfig['app_type'] == 'wechat') {
                        $wechat = new WechatModel($this->appConfig['site_id']);
                        $wechat->relateWeixin();
                    }
            }
        } else {
            if ($this->appConfig['config_key'] == 'WEAPP_CONFIG') { //转发客服消息
                $servicer_model = new ServicerModel();
                $config = $servicer_model->getServicerConfig($this->appConfig['site_id'], 'shop')['data']['value'];
                if (isset($config['system']) && !$config['system']) {
                    // 转发收到的消息给客服
                    $app = $this->app->miniProgram($this->appConfig['value']['appid'], $this->appConfig['value']['authorizer_refresh_token']);
                    $server = $app->server;
                    $server->push(function () {
                        return new Transfer();
                    });
                    $server->serve()->send();
                }
            }
        }
    }

    /**
     * 消息通知
     * @param $appid
     */
    public function message($appid)
    {
        try {
            $where = [
                ['config_key', 'in', ['WECHAT_CONFIG', 'WEAPP_CONFIG']],
                ['value', 'like', '%' . $appid . '%'],
                ['value', 'like', '%is_authopen%']
            ];
//            $site_id=Db::name('config')->where($where)->order('modify_time desc')->value('site_id');
//            $site_id=0;
            //公众号处理
            $officialAccount = $this->app(['authorizer_appid' => $appid, 'type' => 'wechat']);
            $wechat_model = new Wechat(0);
            $wechat_model->app = $officialAccount;
            $wechat_model->relateWeixin();
            //微信处理
            $officialAccount = $this->app(['authorizer_appid' => $appid, 'type' => 'weapp']);
            $weapp_model = new Weapp(0);
            $weapp_model->app = $officialAccount;
            $weapp_model->relateWeixin();
        } catch (\Exception $e) {

        }
    }
}