<?php

namespace Home\Controller;

use Workerman\Worker;
use Think\Controller;
use Workerman\Connection\AsyncTcpConnection;

require_once APP_PATH . 'Workerman/Autoloader.php';

class WorkermanController extends Controller
{
    public $clientGateway = array();

    public $gatewayClients = array();

    public $uidConnections = array();

    public function index()
    {
        if (!IS_CLI) {
            die("access illegal");
        }
        Worker::$daemonize = true;//以守護(hù)進(jìn)程運(yùn)行
        Worker::$pidFile = APP_PATH . '/workerman.pid';//方便監(jiān)控WorkerMan進(jìn)程狀態(tài)
        Worker::$stdoutFile = APP_PATH . '/stdout.log';//輸出日志, 如echo，var_dump等
        Worker::$logFile = APP_PATH . '/workerman.log';//workerman自身相關(guān)的日志，包括啟動(dòng)、停止等,不包含任何業(yè)務(wù)日志
        $worker = new Worker('websocket://0.0.0.0:2345');//此處我使用內(nèi)網(wǎng)ip
        $worker->name = 'weiChatWorker';
        $worker->onConnect = function ($con) {
            global $uidConnections;
            $uidConnections = $con;
        };

        $worker->onWorkerStart = function ($worker) {

            $con = new AsyncTcpConnection('xxxxxxxxxxxxxxxx');

            // 設(shè)置以ssl加密方式訪問，使之成為wss
            $con->transport = 'ssl';

            $con->onConnect = function ($con) {
                echo "tcp connect success\n";
            };

            $con->onMessage = function ($con, $data) {
                self::receiveController($data);
            };

            $con->connect();
            echo "Worker starting...\n";
        };

        $worker->onMessage = function ($connection, $data) {
            global $gatewayClients, $clientGateway;
            $postData = json_decode($data);
            $cmd = $postData->cmd;
            $gateway = $postData->bindGateway;
            if ($cmd == "01") {
                $gwArray = explode(",", $gateway);
                //        初始化客戶端綁定的網(wǎng)關(guān)
                $id = $connection->id;
                $clientGateway = $gwArray;
                foreach ($gwArray as $key) {
                    $temp = $gatewayClients;
                    if ($temp == null) {
                        $temp = array();
                    }
                    array_push($temp, $id);
                    $gatewayClients = $temp;
                }
            }
        };

        $worker->onBufferFull = function ($connection) {
            echo "bufferFull and do not send again\n";
        };
        $worker->onBufferDrain = function ($connection) {
            echo "buffer drain and continue send\n";
        };
        $worker->onWorkerStop = function ($worker) {
            echo "Worker stopping...\n";
        };
        $worker->onError = function ($connection, $code, $msg) {
            self::clearClient($connection);
            echo "error $code $msg\n";
        };

        $worker->onClose = function ($connection) {
            self::clearClient($connection);
            echo "connection closed\n";
        };
        // 運(yùn)行worker
        Worker::runAll();
    }

    function clearClient($connection)
    {
        global $gatewayClients, $clientGateway, $uidConnections;
        $id = $connection->id;
        $allGateway = $clientGateway;
        foreach ($allGateway as $item) {
//            獲取網(wǎng)關(guān)的所有client
            $allClient = $gatewayClients;
            unset($gatewayClients);
        }
        unset($clientGateway);
        unset($uidConnections);
    }

    /**
     * 接收OMS消息的處理類
     * @param $data
     */
    function receiveController($data)
    {
        global $gatewayClients, $uidConnections;
        echo $data . "\n";
        $tempData = json_decode($data);
        $cmd = $tempData->cmd;
        if ($cmd == "13") {
//            處理設(shè)備告警
//{"cmd":"13","gwID":"4612C9ECDED6","devID":"A1","type":"02","ep":"14","epData":"1","epType":"02","time":"1487061135651","amqpResource":"v1"}
            foreach ($gatewayClients as $cons) {
                $uidConnections->send($data);
            }
        }
    }
}