huahuibao/app-ghs/controllers/WsController.php

<?php

// websocket相关
namespace ghs\controllers;

use bizGhs\ws\services\WsService;
use common\components\util;
use Yii;
use GatewayClient\Gateway;

class WsController extends BaseController
{

    public $guestAccess = ['bind','send'];

    //绑定用户
    public function actionBind()
    {
        $post = Yii::$app->request->post();
        $clientId = isset($post['clientId']) ? $post['clientId'] : '';
        $shopAdminId = $this->shopAdminId;
        Yii::info("ws band shopAdminId clientId ". $shopAdminId.'---'.$clientId);
        Gateway::bindUid($clientId, $shopAdminId);
        util::complete();
    }

    //关闭当前链接
    public function actionClose()
    {
        $post = Yii::$app->request->post();
        $clientId = isset($post['clientId']) ? $post['clientId'] : '';
        Gateway::closeClient($clientId);
    }

    //模拟推送ws (仅供测试联调用)
    public function actionSend()
    {
        WsService::arrivalNotice($this->shopAdminId, 9866.29);
        util::complete();
    }

    //模拟推送订单通知
    public function actionSendOrder()
    {
        WsService::newOrderNotice($this->shopAdminId);
        util::complete();
    }
}