xyzshop/helper/room/factory_processor.php

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

namespace room;

use search\IProcessor;
use errcode;
use scope_trace;

class factory_processor implements IProcessor
{
    private $mFactory;
    private $mRoomClients;
    private $mLastBuilding;

    public function __construct()
    {
        $this->mFactory = new factory();
        $this->mRoomClients = [];
        $this->mLastBuilding = 0;
        $this->init();
    }

    private function init()
    {
        global $config;
        $room_addrs = $config['room_factory']['rooms_addr'];
        foreach ($room_addrs as $addr) {
            $room_client = new room_client($addr['host'],$addr['port']);
            $this->mRoomClients[] = $room_client;
        }
    }

    public function onRequest($bufid, $body)
    {
        new scope_trace(__METHOD__);
        $input = json_decode($body,true);
        if($input == false) {
            return false;
        }

        $act = $input['act'];
        if(!empty($act) && $act == proto_type::act_factory) {
            $ret = $this->onFactory($input);
            factory_server::instance()->write($bufid,$ret);
            return true;
        }
        else {
            return false;
        }
    }

    public function onClose($bufid)
    {
    }
    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
    private function onFactory($input)
    {
        $op = $input['op'];
        if($op == 'create')
        {
            $ret = $this->mFactory->create($input);

            if($ret != false)
            {
                $invite  = $input['invite'];
                if($invite)
                {
                    $roomid  = $ret['room'];
                    $inviter  = $ret['creator'];

                    if($roomid <= 0 || $inviter <= 0) {
                        return $this->error(errcode::ErrRoomCreate);
                    }

                    $result = $this->invite($roomid,$inviter,[$inviter]);
                    if($result != false) {
                        $ret = array_merge($ret,$result);
                        return $this->success($ret);
                    } else {
                        return $this->error(errcode::ErrRoomInvite);
                    }
                }
                else {
                    return $this->success($ret);
                }
            }

            return $this->error(errcode::ErrRoomCreate);
        }
        elseif($op == 'invite')
        {
            $roomid   = intval($input['room']);
            $inviter  = intval($input['inviter']);
            $invitees = $input['invitees'];

            if($roomid <= 0 || $inviter <= 0 || empty($invitees)) {
                return $this->error(errcode::ErrRoomInvite);
            }

            $ret = $this->invite($roomid,$inviter,$invitees);
            if($ret != false) {
                return $this->success($ret);
            } else {
                return $this->error(errcode::ErrRoomInvite);
            }
        }
        elseif($op == 'leave')
        {
            $roomid   = intval($input['room']);
            $user  = intval($input['user']);

            if($roomid <= 0 || $user <= 0) {
                return $this->error(errcode::ErrRoomInvite);
            }

            $ret = $this->leave($roomid,$user);
            if($ret != false) {
                return $this->success($ret);
            } else {
                return $this->error(errcode::ErrRoomInvite);
            }
        }
        else {
            return $this->error(errcode::ErrRoomFactoryOp);
        }
    }

    private function invite($roomid, $inviter,$invitees)
    {
        foreach ($this->mRoomClients as  $client)
        {
            if($client->contain_room($roomid))
            {
                $ret = $client->invite($roomid,$inviter,$invitees);
                if($ret != false) {
                    return $ret;
                }
            }
        }

        $client = $this->room_client();
        if($client != false)
        {
            $ret = $client->invite($roomid,$inviter,$invitees);
            if($ret != false) {
                $client->add_room($roomid);
            }
        }

        return $ret;
    }

    private function leave($roomid, $user)
    {
        foreach ($this->mRoomClients as  $client)
        {
            if($client->contain_room($roomid))
            {
                $ret = $client->leave($roomid,$user);
                if($ret != false) {
                    return $ret;
                }
            }
        }

        $client = $this->room_client();
        if($client != false) {
            return $client->leave($roomid,$user);
        } else {
            return false;
        }
    }

    private function room_client()
    {
        $count = count($this->mRoomClients);
        if($count <= 0) return false;

        $pos = $this->mLastBuilding;
        if($pos < $count) {
            $this->mLastBuilding++;
            return $this->mRoomClients[$pos];
        } else {
            $this->mLastBuilding = 0;
            return $this->mRoomClients[0];
        }
    }

    private function success($datas) {
        $code = errcode::Success;
        $data['code'] = $code;
        $data['message'] = errcode::msg($code);
        $data['data'] = $datas;

        return json_encode($data);
    }

    private function error($code,$message = '')
    {
        if (empty($message)) {
            $message = errcode::msg($code);
        }

        $data = array();
        $data['code'] = $code;
        $data['message'] = $message;
        $data['datas'] = null;
        return json_encode($data);
    }
}