CRMEB/crmeb/services/workerman/WorkermanHandle.php

<?php


namespace crmeb\services\workerman;


use think\facade\Middleware;
use think\facade\Session;
use Workerman\Connection\TcpConnection;

class WorkermanHandle
{
    protected $service;

    public function __construct(WorkermanService &$service)
    {
        $this->service = &$service;
    }

    public function login(TcpConnection &$connection, array $res, Response $response)
    {
        if (!isset($res['data']) || !$sessionId = $res['data']) {
            return $response->close([
                'msg' => '授权失败!'
            ]);
        }

        $session = app('session',[],true);
        $session->init();
        $session->setId($sessionId);
        $session->start();

        if (!$session->has('adminId') || !$session->has('adminInfo')) {
            return $response->close([
                'msg' => '授权失败!'
            ]);
        }

        $connection->adminInfo = $session->get('adminInfo');
        $connection->sessionId = $sessionId;
        $this->service->setUser($connection);

        return $response->success();
    }
}