xyzshop/helper/fcgi_server.php

<?php

/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 16/3/10
 * Time: 下午9:08
 */

require_once (BASE_ROOT_PATH . '/mobile/index.php');
require_once (BASE_ROOT_PATH . '/helper/area_helper.php');
require_once (BASE_CORE_PATH . '/framework/function/http.php');

class fcgi_server
{
    static private $stInstance = NULL;
    static public function instance()
    {
        if(self::$stInstance == NULL) {
            self::$stInstance = new fcgi_server();
        }
        return self::$stInstance;
    }

    private function is_exclude($file)
    {
        static $exfiles = ['web_wxnotify.php',
            'wxnotify.php','pub_wxnotify.php','alipay_notify_url.php','dispatch_notify.php','kdniao_notify.php',
            'cmbpay_notify.php','cmbpay_sign.php','wxauthor.php','api/wxLogin/index.php','api/wxLogin/callback.php',
            'signature.php',
            'refill_suhc.php','refill_beixt.php','refill_bxtwt.php'
        ];
        $path = BASE_ROOT_PATH . '/mobile/';
        $file = str_replace($path,'',$file);

        return in_array($file,$exfiles);
    }

    private function parase_requri()
    {
        $method = strtolower(request_helper::method());
        if($method == 'get') {
            return;
        }

        $file = request_helper::req_uri();
        $ops = explode("?",$file);
        if(count($ops) == 2)
        {
            $squery = $ops[1];
            $params = preg_split('/&/', $squery);
            foreach ($params as $pair)
            {
                $kv = explode('=', $pair);
                $count = count($kv);
                if($count === 1) {
                    $key = $kv[0];
                    $val = "";
                }
                elseif($count === 2) {
                    $key = $kv[0];
                    $val = urldecode($kv[1]);
                }
                else {
                    continue;
                }
                $_GET[$key] = $val;
                $_POST[$key] = $val;

                Log::record("{$key}:{$val}",Log::DEBUG);
            }
        }
    }

    private function clear_global()
    {
        $_SESSION = [];
        $_COOKIE = [];
        $_POST = [];
        $_GET = [];
    }

    public function handle_error($level, $message, $file, $line)
    {
        if($level == E_NOTICE) return;
        $trace = "handle_error: level={$level},msg={$message} file={$file},line={$line}\n";
        $backtrace = debug_backtrace();
        foreach ($backtrace as $item) {
            $trace .= "{$item['file']}\t{$item['line']}\t{$item['function']}\n";
        }

        Log::record($trace,Log::ERR);
    }

    public function run_looper()
    {
        Log::record(__FUNCTION__,Log::DEBUG);
        DFAFilter::instance();
        area_helper::instance();
        set_error_handler([$this, 'handle_error']);

        Log::record('Waiting......',Log::DEBUG);
        while(($ret = fcgi_accept()) >= 0)
        {
            $start = microtime(true);

            ob_start();
            $this->clear_global();
            performance_helper::clear();
            http_header::instance()->start();

            try
            {
                Log::start_sql_log();
                $this->parase_requri();
                init_request();
                init_cookie($_SERVER['HTTP_COOKIE']);
                $file = request_helper::script_file();

                if(file_exists($file))
                {
                    if(defined('CROSS_DOAMIN') && CROSS_DOAMIN == true) {
                        $host = 'http://localhost:3333';
                        fcgi_header("Content-Type: text/html; charset=UTF-8");
                        fcgi_header("Access-Control-Allow-Credentials: true");
                        fcgi_header("Access-Control-Allow-Origin: {$host}");
                        fcgi_header('Access-Control-Allow-Methods: GET, POST, PUT,DELETE,PATCH');
                    }

                    if(self::is_exclude($file)) {
                        include $file;
                    }
                    else
                    {
                        if(!isset($_GET['act'])) {
                            $_GET['act'] = 'index';
                        }
                        if(!isset($_GET['op'])) {
                            $_GET['op'] = 'index';
                        }
                        if(!isset($_POST['act'])) {
                            $_POST['act'] = 'index';
                        }
                        if(!isset($_POST['op'])) {
                            $_POST['op'] = 'index';
                        }

                        //部分控制器不需要使用session.
                        $act = $_GET['act'];
                        if($act != 'refill') {
                            session::instance()->start();
                            Log::record("member_id=" . session_helper::memberid(),Log::DEBUG);
                        }

                        Base::mobile_control();
                    }
                }
                else
                {
                    fcgi_header("Content-Type: text/html; charset=UTF-8");
                    echo "no such file.";
                }
            }
            catch (UnloginException $ex) {
                mobileControl::outerr(errcode::ErrUnLogin,errcode::msg(errcode::ErrUnLogin));
            }
            catch (Exception $ex) {
                mobileControl::outerr($ex->getCode(),$ex->getMessage());
                Log::record("run_looper exception catch code={$ex->getCode()} msg={$ex->getMessage()} trace={$ex->getTraceAsString()}",Log::ERR);
            }
            session::instance()->end();
            fcgi_headers_sent();
            $contents = ob_get_clean();
            fcgi_echo($contents);
            Log::end_sql_log();
            Log::record("content={$contents}",Log::DEBUG);

            //fcgi_finish();//单线程的情况下不需要调用
            $msg = sprintf("request time=%.6f\r\n\r\n",microtime(true) - $start);
//            Log::record($msg ,Log::DEBUG);
        }

        fcgi_fini();
        Log::record('Waiting quit......',Log::DEBUG);
    }
}