xyzshop/wsd_bridge.php

<?php

use rbridge\wsd\config;

define('APP_ID', 'bridge-wsd');
define('BASE_ROOT_PATH', str_replace('\\', '/', dirname(__FILE__)));

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_ROOT_PATH . '/helper/event_looper.php');
require_once(BASE_CORE_PATH . '/framework/function/http.php');


global $config;
$port = $config['wsd_bradge_port'];


class WSDBridge
{
    private $mListenPort;
    const KEY = 'ac59f54faf1ffcc1';

    public function __construct($port)
    {
        $this->mListenPort = $port;
    }

    public function looper()
    {
        $fd = event\util::listen_block("0.0.0.0", $this->mListenPort);
        if ($fd === false) {
            Log::record("Cannot Listen on port = {$this->mListenPort}", Log::DEBUG);
            return false;
        }

        while (true)
        {
            Log::record("Waitting another connect....");
            if (($client = socket_accept($fd)) !== false)
            {
                Log::record("Client {$client} has connected", Log::DEBUG);
                socket_set_option($client, SOL_SOCKET, SO_RCVTIMEO, ['sec' => 8, 'usec' => 0]);

                $body = $this->read_order($client);
                if($body !== false && !empty($body)) {
                    Log::record("req:{$body}",Log::DEBUG);
                    $response = $this->relay_request($body);
                    socket_write($client,$response);
                    Log::record("resp:{$response}",Log::DEBUG);
                }
                
                socket_close($client);
            }
        }
    }

    private function relay_request($body)
    {
        $url = BASE_SITE_URL . "/mobile/bridge_shr.php";
        $headers = ['Content-Type: application/json'];

        $resp = http_post_data($url,$body,$headers);
        if($resp === false) {
            Log::record("Net error.",Log::ERR);
            return $this->err_body($body);
        }
        else {
            return $resp;
        }
    }

    private function err_body($body)
    {
        $params = json_decode($body);

        //交易结果 0:未处理 1:充值成功 2:充值结果不确定 3:充值失败
        $retCode = 3;
        $retDetail = "服务维护中.....";

        $result = [
            'action' => 'CZ',
            'chargeId' => $params['chargeId'],
            'retCode'  => $retCode,
            'retDetail' => $retDetail,
            'retRsn' => $params['retRsn'] ];

        $body = "{$params['chargeId']}{$retCode}{$params['retRsn']}" . WSDBridge::KEY;
        $sign = md5($body);
        $result['sign'] = $sign;

        return json_encode($result);
    }

    private function read_order($client)
    {
        $content = '';
        while (true)
        {
            $buf = socket_read($client, 1024);
            if ($buf === false) {
                $error = socket_strerror(socket_last_error($client));
                Log::record("read_order err:{$error}", Log::ERR);
                return false;
            } else {
                $content .= $buf;
            }

            if ($this->isbody($content)) {
                return $content;
            }

            if(strlen($content) >  1024) {
                return false;
            }
        }
    }

    private function isbody($content)
    {
        $ret = json_decode($content, true);
        return ($ret !== false);
    }
}

$brider = new WSDBridge($port);
$brider->looper();