xyzshop/helper/room/factory_client.php

<?php
/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 2017/12/14
 * Time: 上午11:43
 */


namespace room;

use search\tcp_client;

class factory_client extends tcp_client
{
    protected static $stInstance;

    public function __construct()
    {
        parent::__construct();
        $this->mBodyType = tcp_client::JsonType;
    }

    public static function instance()
    {
        if(self::$stInstance == null) {
            self::$stInstance = new factory_client();
        }
        return self::$stInstance;
    }

    public function __destruct()
    {
        parent::__destruct();
    }

    public function remote_addr()
    {
        global $config;

        $host = $config['room_factory']['host'];
        $port = $config['room_factory']['port'];
        return "tcp://{$host}:{$port}";
    }
    //////////////////////////////////////fcgi//////////////////////////////////////////////////////////////////////////
    public function create_bargain($goods_id,$user,$lowest_price,$usable_days,$random = true,$total_num = 10,$finvite = true)
    {
        $random = $random ? 1 : 0;
        $param = ["act" => 'fcgi','op' => 'create', "type" => 'bargain_goods','creator' => $user,'invite' => $finvite,
            'goods_id' => $goods_id,
            'lowest_price' => $lowest_price,
            'usable_days' => $usable_days,
            'random' => $random,'total_num' => $total_num];
        $result = $this->request($param);
        if(empty($result)) return false;

        $code = intval($result['code']);
        if($code != 200) {
            return false;
        }
        else {
            return $result['data'];
        }
    }

    public function create_chat($creator,$finvite = true)
    {
        $param = ["act" => 'fcgi','op' => 'create', "type" => proto_type::sroom_chat,'creator' => $creator,'invite' => $finvite];
        $result = $this->request($param);
        if(empty($result)) return false;

        $code = intval($result['code']);
        if($code != 200) {
            return false;
        }
        else {
            return $result['data'];
        }
    }

    public function create_shake($creator,$finvite = true)
    {
        $param = ["act" => 'fcgi','op' => 'create', "type" => 'shake_bonus','creator' => $creator,'invite' => $finvite];
        $result = $this->request($param);
        if(empty($result)) return false;

        $code = intval($result['code']);
        if($code != 200) {
            return false;
        }
        else {
            return $result['data'];
        }
    }
    //////////////////////////////////////fcgi//////////////////////////////////////////////////////////////////////////
    public function invite($roomid, $inviter,$invitees)
    {
        $users = [];
        foreach ($invitees as $user) {
            $users[] = intval($user);
        }
        $users = array_unique($users);
        if(empty($users)) return false;

        $param = ["act" => 'fcgi','op' => 'invite','room' => $roomid,'inviter' => $inviter,'invitees' => $users];
        $result = $this->request($param);
        if(empty($result)) return false;

        $code = intval($result['code']);
        if($code != 200 || empty($result['data']['invitees'])) {
            return false;
        }
        else {
            return $result['data'];
        }
    }
    public function leave($roomid, $user)
    {
        $param = ["act" => 'fcgi','op' => 'invite','room' => $roomid,'user' => $user];
        $result = $this->request($param);
        if(empty($result)) return false;

        $code = intval($result['code']);
        if($code != 200) {
            return false;
        }
        else {
            return $result['data'];
        }
    }

    public function push($content)
    {
        $param = ["act" => 'fcgi','op' => 'push','content' => $content];
        $result = $this->request($param);
        if(empty($result)) return false;

        $code = intval($result['code']);
        if($code != 200) {
            return false;
        }
        else {
            return true;
        }
    }
    //////////////////////////////////////access////////////////////////////////////////////////////////////////////////
    public function access()
    {
        $param = ["act" => 'access','op' => 'who'];
        $result = $this->request($param);
        if(empty($result)) return false;

        $code = intval($result['code']);
        if($code != 200) {
            return false;
        }
        else {
            return true;
        }
    }
}