api/lib/Platform.php

<?php namespace Api\Lib;
use Dever;
use Api\Lib\Platform\Field;
use Api\Lib\Platform\Ssl;
use Api\Lib\Platform\Request;
use Api\Lib\Platform\Response;
class Platform
{
    protected $platform;
    protected $info;
    protected $field;

    protected function setting($id, $field = array())
    {
        $this->info($id);
        $this->platform();
        $this->field($field);
        return $this;
    }

    protected function info($id)
    {
        $this->info = is_array($id) ? $id : Dever::db($this->type, 'api')->find($id);
        if (!$this->info) {
            Dever::error('info error');
        }
    }

    protected function platform()
    {
        $this->platform = Dever::db('platform', 'api')->find($this->info['platform_id']);
        if (!$this->platform) {
            Dever::error('platform error');
        }
        if ($this->info['method'] == -1) {
            $this->info['method'] = $this->platform['method'];
            $this->info['post_method'] = $this->platform['post_method'];
        }
        if ($this->info['method'] == 1) {
            $this->info['post_method'] = 1;
        }
    }

    protected function field($field)
    {
        if (isset($field['account_project']) && isset($field['account_id'])) {
            $this->info['account_id'] = $field['account_id'];
            $this->info['account_project'] = $field['account_project'];
            $setting = Dever::db('account_setting', $field['account_project'])->select(array('account_id' => $field['account_id']));
            if ($setting) {
                foreach ($setting as $k => $v) {
                    $info = Dever::db('platform_setting', 'api')->find($v['platform_setting_id']);
                    if ($info) {
                        $v['key'] = $info['key'];
                        if (isset($field[$v['key']])) {
                            $v['value'] = $field[$v['key']];
                        }
                        $field[$v['key']] = $v['value'];
                    }
                }
            }
        } else {
            Dever::error('account error');
        }
        $this->field = new Field($field);
        $this->field->setPlatformId($this->platform['id']);
        $this->field->setApid($this->info['id']);
        $this->field->setHost($this->platform['host']);
        $this->field->setUri($this->info['uri']);
        $this->field->setNotify($this->createNotify($field));

        $setting = Dever::db('api_setting', 'api')->select(array('api_id' => $this->info['id']));
        if ($setting) {
            foreach ($setting as $k => $v) {
                $this->field->set($v['key'], $this->field->value($v['value'], $v['type']));
            }
        }
    }

    # 发起请求
    protected function curl($url = false)
    {
        # 生成请求ID
        $this->field->createRequestId();
        if (!$url) {
            $url = $this->url();
        }
        $method = $this->method();
        $request = new Request($this->field, $this->platform['id'], $this->type, $this->info['id']);
        $body = $request->body();
        $header = $request->header();
        $json = $this->info['post_method'] == 3 ? true : false;
        $curl = Dever::curl($url, $body, $method, $json, $header);
        $curl->setResultHeader(true);
        $response_body = $curl->result();
        $response_header = $curl->header();
        $response_config = array('id' => $this->platform['id'], 'type' => $this->platform['response_type']);
        $response = new Response($response_body, $response_header, $this->field, $response_config, $this->type, $this->info['id']);
        $result = $response->out();
        $log = array();
        $log['platform_id'] = $this->platform['id'];
        $log['api_id'] = $this->info['id'];
        $log['account_id'] = $this->info['account_id'];
        $log['account_project'] = $this->info['account_project'];
        $log['request_id'] = $this->field->request_id;
        $log['url'] = $url;
        $log['method'] = $method;
        $log['body'] = $body;
        $log['header'] = $header;
        $log['response_body'] = $response_body;
        $log['response_header'] = $response_header;
        $log['data'] = $result;
        Dever::db('api_log', 'api')->update($log['request_id'], $log);
        if ($this->field->log) {
            Dever::log($log, 'api');
            Dever::debug($log, 'api');
        }
        return $result;
    }

    # 直接跳转
    protected function location($url = false)
    {
        if (!$url) {
            $url = $this->url();
        }
        $method = $this->method();
        $request = new Request($this->field, $this->platform['id'], $this->type, $this->info['id']);
        $request->body();
        $url .= '?';
        foreach ($this->field->body as $k => $v) {
            if ($k == '#') {
                $url .= $k . $v;
            } else {
                $url .= $k . '=' . $v . '&';
            }
        }
        header('Location: '. $url);
    }

    protected function method()
    {
        $method = 'get';
        if ($this->info['post_method'] == 2) {
            $method = 'file';
        } elseif ($this->info['method'] == 2) {
            $method = 'post';
        }
        $this->field->setMethod($method);
        return $method;
    }

    protected function url()
    {
        if (strstr($this->info['uri'], 'http')) {
            $this->platform['host'] = '';
        }
        $path = Dever::db('api_path', 'api')->select(array('api_id' => $this->info['id']));
        if ($path) {
            $path = array();
            foreach ($path as $k => $v) {
                $v['value'] = $this->field->value($v['value']);
                if ($v['type'] == 1) {
                    $path[] = $v['value'];
                } elseif ($v['type'] == 2) {
                    $path[] = $v['key'] . '/' . $v['value'];
                } elseif ($v['type'] == 3) {
                    $path[] = $v['key'] . '=' . $v['value'];
                }
            }
            if ($path) {
                $path = implode('/', $path);
                $this->field->setPath($path);
                $this->info['uri'] .= $path;
            }
        }

        $query = Dever::db('api_query', 'api')->select(array('api_id' => $this->info['id']));
        if ($query) {
            $param = array();
            foreach ($query as $k => $v) {
                $param[$v['key']] = $this->field->value($v['value'], $v['type']);
                if (is_array($param[$v['key']])) {
                    $param[$v['key']] = Dever::json_encode($param[$v['key']]);
                }
            }
            if ($param) {
                $this->field->setQuery($param);
                $this->info['uri'] .= '?' . http_build_query($param);
            }
        }
        $url = $this->platform['host'] . $this->info['uri'];
        $this->field->setUrl($url);
        return $url;
    }
}