access/extend/queue.logic.php

<?php

class queue_logic
{
    public function login($req_url,$key)
    {
        $resp = $this->reqest($req_url,'/login',['key' => $key]);
        if(!empty($resp) && $resp['code'] == 0) {
            return $resp['data']['token'];
        } else {
            Log::record("Login Error,{$resp['msg']}",Log::ERR);
            return false;
        }
    }

    private function reqest($url,$api,$params,$token='')
    {
        if(empty($token)) {
            $url = "{$url}{$api}";
        }
        else {
            $url = "{$url}{$api}?token={$token}";
        }
        $resp = http_post_data($url,json_encode($params));
        $resp = json_decode($resp,true);
        return $resp;
    }

    public function OpenBox($params) {
        $postData['cabinet_code']       = $params['cabinet_code'];
        $postData['box_position_list']  = $params['box_position_list'];
        $postData['delay_time']         = 0;

        $token = $this->login($params['req_url'],$params['key']);
        if(empty($token)) {
            $ret = ['code'=> 1,'msg' => '柜体服务器错误'];
            $this->sync_return($params['ret_queue'],$params['method'],$ret);
            return $ret;
        }
        $resp = $this->reqest($params['req_url'] ,'/open_box', $postData,$token);
        if(empty($resp)) {
            $ret = ['state'=> 1,'msg' => 'openbox fail.'];
            $this->sync_return($params['ret_queue'],$params['method'],$ret);
            return $ret;
        }
        $resp = $this->sync_return($params['ret_queue'],$params['method'],$resp);
        return $resp;
    }

    public function LockCabinet($params) {
        $box_list[] = $params['box_number'];
        $postData['cabinet_code']       = $params['cabinet_number'];
        $postData['box_position_list']  = $box_list;
        $postData['delay_time']         = 0;

        $token = $this->login($params['req_url'],$params['key']);
        $resp = $this->reqest($params['req_url'] ,'/open_box', $postData,$token);

        $this->sync_return($params['ret_queue'],$params['method'],$resp);
    }



    private function sync_return($queue_name,$key,$params){
        global $config;
        $host = $config['net_queue']['host'];
        $port = $config['net_queue']['port'];
        try {
            QueueClient::push($queue_name,$host ,$port ,$key,$params);
            return ['code'=>0 , 'msg' => 'ok'];
        } catch (Exception $ex) {
            return ['code'=>1 , 'msg' => 'cabinet redis connect error'];
        }
    }
}