xyzshop/test/TestRBridge.php

<?php

use PHPUnit\Framework\TestCase;

define('APP_ID', 'test');
define('BASE_ROOT_PATH', str_replace('/test', '', dirname(__FILE__)));

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_CORE_PATH . '/lrlz.php');
require_once(BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_CORE_PATH . '/framework/function/http.php');
require_once(BASE_HELPER_PATH . '/rbridge/RBridgeFactory.php');
require_once(BASE_HELPER_PATH . '/refill/RefillFactory.php');


class TestRBridge extends TestCase
{
    public static function setUpBeforeClass(): void
    {
        Base::run_util();
    }

    private function getParams()
    {
         $params = ["action" => "CZ",
            "chargeId" => $this->make_sn(),
            "chargeAcct" => "13911129867",
            "chargeCash" => 100.000,
            "chargeType" => 0,
            "amount" => 1,
            "faceValue" => 0,
            "var1" => "",
            "var2" => "",
            "var3" => "",
            "var4" => "",
            "productSn" => 0,
            "nbrArea" => "广东省深圳-移动",
            "cardSn" => "",
            "cardPassword" => "",
            "agentAcct" => "",
            "agentPass" => "",
            "cardId" => 0,
            "retRsn" => "0"];
        $params['sign'] = $this->sign($params);

        return $params;
    }

    public function testWSDAdd()
    {
        $resp = http_post_data(BASE_SITE_URL . "/mobile/bridge/bridge_shr.php", json_encode($this->getParams()), ['Content-Type: application/json']);
        $body = '{"action":"CZ","chargeId":547835,"chargeAcct":"18608991269","chargeCash":30.000,"chargeType":0,"amount":1,"faceValue":30.000,"var1":"","var2":"","var3":"","var4":"","productSn":0,"flowPackageSize":0,"flowPackageType":0,"ispNameCode":2,"province":"ȫ??","otaPort":"VCOM3","nbrArea":"????ʡ????-??ͨ","sellProtectPrice":0.000,"couponPrice":0.000,"cardSn":"","cardPassword":"","agentAcct":"","agentPass":"","cardId":0,"retRsn":"20201230182251579","sign":"2656624671c2ee2ddc37011e847bb75e"}';
        $resp = http_post_data(BASE_SITE_URL . "/mobile/bridge/bridge_shr.php", json_encode($this->getParams()), ['Content-Type: application/json']);
    }
    public function testWSDAddBody()
    {
        $body = '{"action":"CZ","chargeId":547835,"chargeAcct":"18608991269","chargeCash":30.000,"chargeType":0,"amount":1,"faceValue":30.000,"var1":"","var2":"","var3":"","var4":"","productSn":0,"flowPackageSize":0,"flowPackageType":0,"ispNameCode":2,"province":"全国","otaPort":"VCOM3","nbrArea":"海南省海口-联通","sellProtectPrice":0.000,"couponPrice":0.000,"cardSn":"","cardPassword":"","agentAcct":"","agentPass":"","cardId":0,"retRsn":"20201230182251579","sign":"2656624671c2ee2ddc37011e847bb75e"}';
        $resp = http_post_data(BASE_SITE_URL . "/mobile/bridge/bridge_shr.php", $body, ['Content-Type: application/json']);
    }

    public function testWSDCB()
    {
        $body = '{"action":"CZ","chargeId":547843,"retCode":3,"retDetail":"充值失败","retRsn":"20201231123124394","userContent":"","retCost":"0.000","retBalance":"171.200","retCash":"30.000","sign":"34e6b65f6a89378156eae1370d5ae8f4"}';
        $body = mb_convert_encoding($body, 'GBK', 'UTF-8');
        $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        socket_set_option($sock, SOL_SOCKET, SO_RCVTIMEO, ['sec' => 5, 'usec' => 0]);
        if (socket_connect($sock, '121.37.249.48', 50899)) {
            socket_write($sock, $body);
            $resp = socket_read($sock, 1024);
            return $resp;
        }
    }

    public function testTCPAdd()
    {
        $params = $this->getParams();
        $resp = $this->send('121.89.223.81', json_encode($params,JSON_UNESCAPED_UNICODE));
    }

    public function send($host, $body)
    {
        global $config;
        $port = $config['wsd_bradge_port'];

        $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        if (socket_connect($sock, $host, $port)) {
            socket_write($sock, $body);
            $resp = socket_read($sock, 1024);
            return $resp;
        }
        return false;
    }

    public function testOrgBody()
    {
//        $body = '{"action":"CZ","chargeId":547835,"chargeAcct":"18608991269","chargeCash":30.000,"chargeType":0,"amount":1,"faceValue":30.000,"var1":"","var2":"","var3":"","var4":"","productSn":0,"flowPackageSize":0,"flowPackageType":0,"ispNameCode":2,"province":"全国","otaPort":"VCOM3","nbrArea":"海南省海口-联通","sellProtectPrice":0.000,"couponPrice":0.000,"cardSn":"","cardPassword":"","agentAcct":"","agentPass":"","cardId":0,"retRsn":"20201230182251579","sign":"2656624671c2ee2ddc37011e847bb75e"}';
        $body = '{"action":"CZ","chargeId":547889,"chargeAcct":"18608903719","chargeCash":30.000,"chargeType":0,"amount":1,"faceValue":30.000,"var1":"","var2":"","var3":"","var4":"","productSn":0,"flowPackageSize":0,"flowPackageType":0,"ispNameCode":2,"province":"全国","otaPort":"VCOM3","nbrArea":"海南省海口-联通","sellProtectPrice":0.000,"couponPrice":0.000,"cardSn":"","cardPassword":"","agentAcct":"","agentPass":"","cardId":0,"retRsn":"20210104151104656","sign":"31e60799a83bd77f18d2e9888e7a6766"}';
        $encode = mb_detect_encoding($body);
        $body = mb_convert_encoding($body, 'GBK', 'UTF-8');
        $resp = $this->send('121.89.223.81', $body);
        $resp = mb_convert_encoding($resp, 'UTF-8', 'GBK');
    }

    public function testJson()
    {
        $body = $this->getParams();
        $data = json_encode($body,JSON_UNESCAPED_UNICODE);
        $encode = mb_detect_encoding($data);
        $ret = mb_convert_encoding($data, 'GBK',$encode);
        $ret = mb_convert_encoding($data, $encode,'GBK');

    }

    public function testSurAdd()
    {
        $input = '{"action":"CZ","chargeId":196,"chargeAcct":"13530017201","chargeCash":100.000,"chargeType":0,"amount":1,"faceValue":100.000,"var1":"","var2":"","var3":"","var4":"","productSn":0,"nbrArea":"广东省深圳-移动","cardSn":"","cardPassword":"","agentAcct":"","agentPass":"","cardId":0,"retRsn":"0","sign":"3c90ed55aa363a22cd86746f34eeedb0"}';
        $params = json_decode($input, true);
        $ret = rbridge\RBridgeFactory::instance()->add('shr', $params);
    }

    public function testCallBack()
    {
        refill\RefillFactory::instance()->notify_merchant(304,true);
    }

    private function make_sn()
    {
        return mt_rand(1000, 9999)
            . sprintf('%010d', time())
            . sprintf('%06d', (float)microtime() * 1000000);
    }

    private function sign($params)
    {
        //md5(chargeId + chargeAcct + var1 + var2 + var3 + var4 + chargeCash + md5key)
        $keys = ['chargeId', 'chargeAcct', 'var1', 'var2', 'var3', 'var4', 'chargeCash'];
        $body = "";
        foreach ($keys as $key) {
            $body .= $params[$key] ?? "";
        }
        $body .= 'ac59f54faf1ffcc1';
        $sign = md5($body);

        return $sign;
    }

    public function testDetail()
    {
        $detail_id_getter = function ($mchid,$mch_order)
        {
            $mod_refill = Model('refill_order');
            $detail = $mod_refill->get_detail($mchid,$mch_order);
            if(empty($detail)) {
                return [false, []];
            }
            else {
                return [intval($detail['detail_id']), json_decode($detail['params'], true)];
            }
        };

        [$detail_id,$info] = $detail_id_getter(10234,'5a095fd33955c4ef941f04e9307c4845');
    }

    //gao yang test
    public function testGyAdd()
    {
        $signer = function ($params,$names)
        {
            $key = '57ccb90f02ad5d5b099f518f8afb2c19';
            $body = '';
            foreach ($names as $name) {
                $val = $params[$name] ?? '';
                $body .= $val;
            }
            $body .= $key;

            $sign = strtoupper(md5($body));
            return $sign;
        };

        $params = [
            'userid' => 10234,
            'request_id' => $this->make_sn(),
            'telephone' => 13911129867,
            'money' => 50,
            'callbackurl' => 'https://api.mhigh.cn/racc/callback/testcb.php'
        ];
        $names = ['userid','request_id','telephone','money','callbackurl'];

        $sign = $signer($params,$names);
        $params['sign'] = $sign;

        [$succ,$xml] = rbridge\RBridgeFactory::instance()->add('gy', $params);
    }

    public function testGyQuery()
    {
        $signer = function ($params,$names)
        {
            $key = '57ccb90f02ad5d5b099f518f8afb2c19';
            $body = '';
            foreach ($names as $name) {
                $val = $params[$name] ?? '';
                $body .= $val;
            }
            $body .= $key;

            $sign = strtoupper(md5($body));
            return $sign;
        };

        $params = [
            'userid' => 10234,
            'request_id' => '60871702829743177981',
        ];
        $names = ['userid','request_id'];

        $sign = $signer($params,$names);
        $params['sign'] = $sign;

        $ret = rbridge\RBridgeFactory::instance()->query('gy', $params);
    }

    public function testGyBalance()
    {
        $signer = function ($params,$names)
        {
            $key = '57ccb90f02ad5d5b099f518f8afb2c19';
            $body = '';
            foreach ($names as $name) {
                $val = $params[$name] ?? '';
                $body .= $val;
            }
            $body .= $key;

            $sign = strtoupper(md5($body));
            return $sign;
        };

        $params = [
            'userid' => 10234
        ];
        $names = ['userid'];

        $sign = $signer($params,$names);
        $params['sign'] = $sign;

        $ret = rbridge\RBridgeFactory::instance()->balance('gy', $params);
    }


    public function testXML()
    {
        $xml = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?><root></root>');
        $ar2xml = function ($obj, $array) use(&$ar2xml)
        {
            foreach ($array as $k => $v)
            {
                if(is_numeric($k))
                    $k = 'item' . $k;
                if(is_array($v)){
                    $node = $obj->addChild($k);
                    $ar2xml($node, $v);
                }else{
                    $obj->addChild($k, htmlspecialchars($v));
                }
            }
        };

        $params = [
            'userid' => 10234,
            'request_id' => $this->make_sn(),
            'telephone' => 13911129867,
            'money' => 50,
            'callbackurl' => 'https://api.mhigh.cn/racc/callback/testcb.php'
        ];

        self::arrayToXml($xml,$params);

        $val = $xml->asXML();

    }

    public static function arrayToXml($obj, $array)
    {
        foreach ($array as $k => $v)
        {
            if (is_numeric($k))
                $k = 'item' . $k;
            if (is_array($v)) {
                $node = $obj->addChild($k);
                arrayToXml($node, $v);
            } else {
                $obj->addChild($k, htmlspecialchars($v));
            }
        }
    }
}