<?php
namespace app\http;
use app\facade\RedisCache;
use app\http\service\ChatCloseService;
use app\http\service\ChatMessageService;
use app\http\service\ChatService;
use app\http\service\MessageQueueService;
use think\facade\Log;
use think\swoole\Server;
class Swoole extends Server
{
    protected $serverType = 'socket';
    protected $port = 9502;
    protected $sockType = SWOOLE_SOCK_TCP | SWOOLE_SSL;
    protected $option = [
        'worker_num'=> 4,
        'task_worker_num' => 4,
        'daemonize' => true,
        'backlog' => 128,
        'heartbeat_idle_time' => 600,
        'heartbeat_check_interval' => 60,
        'ssl_cert_file' => '/usr/local/nginx/conf/cert/jinhu11.pem',
        'ssl_key_file' => '/usr/local/nginx/conf/cert/jinhu11.key',
    ];

    public function onOpen($server, $request)
    {
        //建立连接时，应将用户信息入缓存，并将客服分配给该用户
        //Cache::setCliUser($request->fd,['id'=>$request->fd, 'ip'=>$request->server['remote_addr']]);
        //echo '连接建立';
        //echo json_encode($request);
        //Log::info(json_encode($request));
        //Log::info('读$_COOKIE参数'.json_encode($_COOKIE));
        //Log::info('读cookie参数'.$request->cookie['PHPSESSID']);
        //取缓存
        //Log::info('session原会话信息'.Cache::store('session_store')->get($request->cookie['PHPSESSID']));
        //$session_data=$this->unserialize_php(Cache::store('session_store')->get($request->cookie['PHPSESSID']));
        //读取user_id
        //如果不存在user_id，则为游客，随机分配在线客服
        //如果存在user_id，则查询专属客服，若专属客服不在线，则随机分配在线客服
        //Log::info('session自解码会话信息'.json_encode();
        $chat_deal=new ChatService($server,$request);
        $chat_deal->onOpen();
    }

    public function onMessage($server, $frame) {
        //收到消息，根据用户信息发给指定人
        $chat_message_deal=new ChatMessageService($server,$frame);
        $chat_message_deal->deal();

        /*$data = json_decode($frame->data,true);
        switch ($data['type']) {
            case 'openService' :
                $chat_deal=new ChatService($server,$frame->fd,$data);
                $result=$chat_deal->openService();
                break;
            default:
                $result['message_type']='error';
                $result['data']=['错误消息类型'];
        }
        $server->push($frame->fd,myResult($result['message_type'],['content'=>$result['data']]));*/
    }

    public function onClose($server, $fd) {
        //连接关闭，将用户信息从缓存中移除，并存入聊天日志
        $chat_deal=new ChatCloseService($server,$fd);
        $chat_deal->onClose();
    }

    public function onStart($server) {
        //清空所有缓存
        $base_keys=['CHAT_USER_FD_MAP','CHAT_USER_FD','CHAT_USER_INFO','CHAT_USER_QUEUE','CHAT_CS_FD_MAP','CHAT_CS_FD','CHAT_CS_INFO','CUSTOMER_ONLINE_QUEUE','CHAT_ADMIN_FD_MAP','CHAT_ADMIN_FD','CHAT_ADMIN_INFO'];
        $chat_list=RedisCache::keys('CHAT_DATA_*');
        $offline_chat_list=RedisCache::keys('OFFLINE_CHAT_DATA_*');
        RedisCache::batch_del(array_merge($base_keys,$chat_list,$offline_chat_list));

        Log::info('主进程清除缓存结束');

        //定时刷下数据链接，试试看有没有效果。实际有效果，但有个pipe的问题，因为主进程和工作进程之间实际并没有共享数据库实例，尝试在工作进程中开定时器刷新，以防broken pipe的情况出现
        /*swoole_timer_tick(1000*600, function () {
            Db::name('users')->where(['user_id'=>0])->value('user_id');
        });*/
    }

    public function onWorkerStart($server,$worker_id) {
        //定时刷下数据链接，试试看有没有效果。由于8个进程都会刷新，减少刷新频率，30分钟刷一次，试下TP的自动重连机制，暂不刷新
        /*swoole_timer_tick(1000*1800, function () {
            Db::name('users')->where(['user_id'=>0])->value('user_id');
        });*/

        if ($server->taskworker) {
            Log::info('启动消息队列监听任务进程'.$worker_id);
            //每个任务进程起一个监听，尝试监听redis，以便实现消息通知
            while (true) {
                if (($msgs = RedisCache::brpop('MESSAGE_QUEUE', 5))==null) {
                    //没有则继续监听
                    continue;
                } else {
                    $message_queue_deal=new MessageQueueService($server,$msgs);
                    $message_queue_deal->deal();
                }
            }
        } else {
            Log::info('启动通话处理任务进程'.$worker_id);
        }
    }

    public function onTask($server,$task_id,$src_worker_id,$data) {
        //暂不使用
    }
    public function onFinish($server,$task_id,$data) {
        //暂不使用
    }
}