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 "{$host}:{$port}";
    }

    public function create_bargain($goods_id,$user)
    {
        $param = ["act" => 'factory','op' => 'create', "type" => 'bargain','params' => ['goods_id' => $goods_id,'user' => $user]];

        $result = $this->request($param);
        if(empty($result)) return false;

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

    public function create_chat($creator,$user)
    {
        $param = ["act" => 'factory','op' => 'create', "type" => 'chat','params' => ['creator' => $creator,'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 create_group($creator)
    {
        $param = ["act" => 'factory','op' => 'create', "type" => 'group','creator' => $creator];
        $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)
    {
        $param = ["act" => 'factory','op' => 'create', "type" => 'shake_bonus','creator' => $creator];
        $result = $this->request($param);
        if(empty($result)) return false;

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

    public function invite($roomid,$user)
    {
        $param = ["act" => 'factory','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'];
        }
    }
}