hemall.terabimsoft.com.cn/app/process/WebSocketHandle.php

<?php
/**
 * Created by PhpStorm.
 * Name: 芸众商城系统
 * Company: 广州市芸众信息科技有限公司
 * Profile: 广州市芸众信息科技有限公司位于国际商贸中心的广州，专注于移动电子商务生态系统打造，拥有芸众社交电商系统、区块链数字资产管理系统、供应链管理系统、电子合同等产品/服务。官网 ：www.yunzmall.com  www.yunzshop.com
 * Date: 2022/5/9
 * Time: 15:51
 * Author: Merlin
 */

namespace app\process;


use app\common\helpers\YunSession;
use app\common\helpers\YunSessionMemcache;
use app\common\helpers\YunSessionRedis;
use app\common\services\Session;
use Illuminate\Support\Facades\Redis;
use Workerman\Connection\TcpConnection;

class WebSocketHandle
{

    protected $service;


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


    public function login(TcpConnection $connection, array $res)
    {
        $session_id = $res['session_id'];
        if (empty($session_id)) {
            return $connection->send(json_encode(['msg' => '授权失败', 'result' => 0]));
        }
        $session_data = Redis::hgetall('PHPSESSID:' . $session_id);
        $member_id = $this->getMemberId($session_data['data']);
        if (empty($member_id)) {
            return $connection->send(json_encode(['msg' => '授权失败', 'result' => 0]));
        }
        if (empty($res['group'])) {
            return $connection->send(json_encode(['msg' => '授权失败，没有分组', 'result' => 0]));
        }
        $connection->member_id = $member_id;
        $connection->is_login = 1;
        $this->service->setMember($member_id, $res['group'] , $connection);
        return $connection->send(json_encode(['msg' => '登陆成功', 'result' => 1]));
    }

    public function register(TcpConnection $connection, $res)
    {
        $connection->group = $res['group'];
        $connection->is_login = 0;
        $this->service->setGroup($res['group'],$connection);
        return $connection->send(json_encode(['msg' => '注册成功', 'result' => 1]));

    }

    public function ping(TcpConnection $connection, $res)
    {
        return $connection->send('pong');
    }

    private function getMemberId($read_data)
    {
        $member_data = '';

        if (!empty($read_data)) {
            preg_match_all('/yunzshop_([\w]+[^|]*|)/', $read_data, $name_matches);
            preg_match_all('/(a:[\w]+[^}]*})/', $read_data, $value_matches);

            if (!empty($name_matches)) {
                foreach ($name_matches[0] as $key => $val) {
                    if ($val == 'yunzshop_member_id') {
                        $member_data = $val . '|' . $value_matches[0][$key];
                    }
                }
            }
        }
        $member_id = unserialize(explode('|', $member_data)[1])['data'];

        return $member_id;
    }

}