xyzshop/test/TestRefill.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 . '/refill/RefillFactory.php');
require_once(BASE_HELPER_PATH . '/mtopcard/mtopcard.php');

const LocalTest = 1;
const NetTest = 2;

const CurrentTest = NetTest;

class TestRefill extends TestCase
{
    private $mReqHost;
    private $mKey;
    private $mMchid;

    public function __construct(?string $name = null, array $data = [], $dataName = '')
    {
        parent::__construct($name, $data, $dataName);

        if (CurrentTest == LocalTest) {
            $this->mReqHost = BASE_SITE_URL;
            $this->mMchid = 1;
            $this->mKey = '1ff02223b771c0414468c8892151c602';
        } else {
            $this->mReqHost = 'https://www.xyzshops.cn';
            $this->mMchid = 1092;
            $this->mKey = '210fe406954220f56085997d6a4c5b80';
        }
    }

    public static function setUpBeforeClass(): void
    {
        Base::run_util();
    }

    public function testFactory()
    {
        $providers = refill\RefillFactory::instance();
    }

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

    public function testBJBAddPhone()
    {
        $providers = new refill\bjb\RefillPhone([]);
        for ($i = 3; $i > 0; --$i) {
            $resp = $providers->add(13911129867, 4, 10, ['order_sn' => $this->make_sn()]);
            $resp = $providers->add(18500608333, 4, 10, ['order_sn' => $this->make_sn()]);
            $resp = $providers->add(18510683168, 4, 10, ['order_sn' => $this->make_sn()]);
            $resp = $providers->add(18513846008, 4, 10, ['order_sn' => $this->make_sn()]);
            $resp = $providers->add(18518237398, 4, 10, ['order_sn' => $this->make_sn()]);
        }
    }

    public function testIpWhiteList()
    {
        $x = serialize(['47.99.57.105']);
        $ips = unserialize('a:1:{i:0;s:12:"47.99.57.105";}');
        if (!empty($ips)) {
            $addr = '47.99.57.105';
            Log::record("request ip:{$addr}", Log::DEBUG);
            if (!in_array($addr, $ips)) {
                throw new Exception("请求地址不在白名单中");
            }
        }
    }

    public function testXcPhone(){
        $providers = new refill\xc\RefillPhone([]);
        $resp = $providers->add(18500608333, 5, 100, ['order_sn' => $this->make_sn()]);
    }

    public function testYifaPhone(){
        $providers = new refill\yifa\RefillPhone([]);
        $resp = $providers->add(15120035568, 5, 100, ['order_sn' => $this->make_sn()]);
    }

    public function testXcQuery(){
        $providers = new refill\xc\RefillPhone([]);
        $refill_info = ['order_sn' => 950663423236726632 , 'ch_trade_no' => 499 , 'card_no' => 	1000111200005252927	];
        $resp = $providers->query($refill_info);
    }

    public function testSuhcQuery(){
        $providers = new refill\suhctm\RefillOil([]);
        $refill_info = ['order_sn' => 950663423236726632 , 'ch_trade_no' => 499 , 'card_no' => 	1000111200005252927	];
        $resp = $providers->query($refill_info);
    }

    public function testSaihuOil()
    {
        $providers = new refill\saihu\RefillOil([]);
        $resp = $providers->add(1000111100021211884, 2, 100, ['order_sn' => $this->make_sn()]);
    }

    public function testBdtOil()
    {
        $providers = new refill\bdt\RefillOil([]);
        $resp = $providers->add(1000111100021211884,2,100,['order_sn' => '200229600556618886']);
    }

    public function testJiecPhone()
    {
        $providers = new refill\jiec\RefillPhone([]);
        $resp = $providers->add('15120035568',2,100,['order_sn' => $this->make_sn()]);
    }

    public function testBxtwtCB()
    {
        $data = '{"order_number":18219726,"shipping_status":4,"shipping_status_desc":"发货失败","shipping_status_message":"","sign":"863b4d972f2a4d39a9af7396879116c4","voucher":"","vouchertype":"","voucherurl":"","tradeNo":"100662475851197741"}';

    }

    public function testSuhcJDVerify()
    {
        $data = 'onlystr=920661883198026632&sign=533151e3f0dff5f507786aabc37b18f7&amt=100&notifyurl=https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_suhc.php&jdno&cardtype=Sinoepc&batchid=26106&cardno=1000111100020654226&orgid=1590993600&status=3';
        $url = "http://192.168.1.220/mobile/refill_suhc.php?" . $data;
        $resp = http_request($url);
    }

    public function testSuhcPDD()
    {
        $data = 'onlystr=820663525320005221&pddno&sign=4b1e8645f7541ced34855779448d9d52&amt=100&notifyurl=https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_suhcpdd.php&cardtype=Sinoepc&batchid=3&cardno=1000111100020445281&orgid=1590993600&status=2';

        $url = "https://www.xyzshops.cn/mobile/refill_suhcpdd.php?" . $data;
        $resp = http_request($url);
    }

    public function testSuhcTMVerify()
    {
        $data = 'onlystr=180662473867058221&sign=5ff5f95d54a89e78dbb49923f6b20c08&amt=100&notifyurl=https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_suhctm.php&cardtype=Sinoepc&batchid=3&cardno=1000111100020445281&orgid=1590993600&status=3';
//        $url = "http://192.168.1.220/mobile/refill_suhctm.php?" . $data;
        $url = "https://www.xyzshops.cn/mobile/refill_suhctm.php?" . $data;
        $resp = http_request($url);
    }

    public function testBeixtVerify()
    {
        $data = '{"order_number":18219726,"shipping_status":4,"shipping_status_desc":"发货失败","shipping_status_message":"","sign":"863b4d972f2a4d39a9af7396879116c4","voucher":"","vouchertype":"","voucherurl":"","tradeNo":"100662475851197741"}';
        $url = "https://www.xyzshops.cn/mobile/refill_bxtwt.php";

        $headers = ['Content-Type: application/json'];
        $resp = http_post_data($url, $data, $headers);
    }

    public function testInput()
    {
        $input = fopen("php://input", "rw");
        file_put_contents($input, 'xxxx');
        $content = file_get_contents('php://input');
    }


    public function testUrl()
    {
        $data = 'onlystr=190661874318128632&sign=9eb60765c356341fd41c9bec6526f46a&amt=1000&notifyurl=https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_suhc.php&jdno&cardtype=Sinoepc&batchid=25940&cardno=1000111100012304048&orgid=1590993600&status=2';

        $params = preg_split('/&/', $data);
        foreach ($params as $pair) {
            $kv = explode('=', $pair);
            $count = count($kv);
            if ($count === 1) {
                $key = $kv[0];
                $val = "";
            } elseif ($count === 2) {
                $key = $kv[0];
                $val = $kv[1];
            } else {
                continue;
            }

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

    public function testAddoil()
    {
        $url = $this->mReqHost . "/mobile/index.php";
        $notifyurl = 'https://www.xyzshops.cn/mobile/signature.php';
        $params = ['mchid' => 1092,
            'cardno' => '1000111100020445281',
            'amount' => "100",
            "act" => "refill",
            "op" => "add",
            'order_sn' => $this->make_sn(),
            'notifyurl' => $notifyurl];

        $resp = $this->send_md5($url, $params);
        Log::record($resp, Log::DEBUG);
    }

    public function testBalance()
    {
        $url = $this->mReqHost . "/mobile/index.php";
        $params = ['mchid' => 1092,
            "act" => "refill",
            "op" => "balance"];
        $resp = $this->send_md5($url, $params);
        Log::record($resp, Log::DEBUG);

    }

    public function testAddPhoe()
    {
        $phones = [//13911129867,
            18500608333,
            18510683168,
            18513846008,
            18518237398];
        $amount = 10;

        for ($i = 0; $i < 3; $i++) {
            foreach ($phones as $phone) {
                $url = $this->mReqHost . "/mobile/index.php";
                $params = ['mchid' => 1092,
                    'cardno' => $phone,
                    'amount' => $amount,
                    "act" => "refill",
                    "op" => "add",
                    'order_sn' => $this->make_sn(),
                    'notifyurl' => $this->mReqHost . "/mobile/refill_xyz.php"];

                $resp = $this->send_md5($url, $params);
                Log::record($resp, Log::DEBUG);
            }
        }
    }

    public function testProxyHelper()
    {
        $phone = '13911129867';
        $amount = 100;
        $url = $this->mReqHost . "/mobile/index.php";
        $params = ['mchid' => 1090,
            'cardno' => $phone,
            'amount' => $amount,
            "act"=>"refill",
            "op"=>"add",
            'order_sn' => $this->make_sn(),
            'notifyurl'=> "https://qzcz.edusahoo.com.cn/index/index/callback"];
         $proxy = new refill_proxy("ZhongFKJZhongFKJZhongFKJ");
         $resp = $proxy->send($url,$params);
    }

    public function testGoods()
    {
        $req_url = $this->mReqHost . '/mobile/index.php';
        $params = ['mchid' => $this->mMchid,
            "act" => "refill",
            "op" => "goods"];

        $resp = $this->send_md5($req_url, $params);
    }

    public function testQueryFactory()
    {
        refill\RefillFactory::instance()->query(295);
    }

    public function testQuery()
    {
        //$req_url = 'https://www.xyzshops.cn/mobile/index.php';
//        $notifyurl = 'https://www.xyzshops.cn/mobile/signature.php';

        $req_url = BASE_SITE_URL . '/mobile/index.php';
        $notifyurl = 'https://www.xyzshops.cn/mobile/signature.php';

        $params = ['mchid' => 1,
            "act" => "refill",
            "op" => "query",
            'order_sn' => "13281476"];

        $resp = $this->send_md5($req_url, $params);
    }

    public function testRemoveSession()
    {
        $resp = http_request(BASE_SITE_URL . "/mobile/signature.php", [], 'POST');
    }


    public function testSuhcCB()
    {
//        $notifyurl = BASE_SITE_URL . "/mobile/refill_suhc.php";
        $notifyurl = "https://www.xyzshops.cn/mobile/refill_suhc.php";
//        $notifyurl = "https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_suhc.php";

        $params = ['onlystr' => '920660917672249741',
            'amt' => 100,
            'jdno' => '',
            'notifyurl' => $notifyurl,
            'cardtype' => 'Sinoepc',
            'batchid' => 18512,
            'cardno' => '1000111100020445281',
            'orgid' => '1590993600',
            'status' => 2];

        $sign = $this->md5_sign($params);
        $params['sign'] = $sign;

        $resp = http_request($notifyurl, $params, 'POST');
        Log::record($resp, Log::DEBUG);
    }


    public function testBJBCB()
    {
        $params = [
            'usr' => '13699279618',
            'ord' => '710662733975412771',
            'state' => '2',
            'bz' => '',
            'sgn' => 'AC9AFD254DE682D8440A97CA68B992DA'
        ];

        $resp = http_request("https://www.xyzshops.cn/mobile/refill_bjb.php", $params, 'POST');
    }

    public function testJiecCB()
    {
        $params['result'] = 'fail';
        $params['msg'] = '0';
        $params['order'] = 'null';
        $params['phone_no'] = '18500608333';
        $params['amount'] = '30.00';
        $params['op_no'] = '800663597981819221';
        $params['sign'] = '2510046895e8e12322c8a32547905ee9';

        $resp = http_request($this->mReqHost . "/mobile/refill_jiec.php", $params, 'POST');
    }


    public function testZFKJ()
    {
        //带签名参数：mchid=1090&act=refill&op=add&cardno=100112121212212133
        //&amount=10&order_sn=PH2012261356569433&
        //notifyurl=https%3A%2F%2Fqzcz.edusahoo.com.cn%2Findex%2Findex%2Fcallback
        //&sign=4a3ac5f9706e64aa70c6cab0fc5839d3

        $params = ['mchid' => 1090,
            'cardno' => '100112121212212133',
            'amount' => '10',
            "act" => "refill",
            "op" => "add",
            'order_sn' => 'PH2012261356569433',
            'notifyurl' => 'https://qzcz.edusahoo.com.cn/index/index/callback'];

        $resp = $this->send_md5(BASE_SITE_URL . '/mobile/index.php', $params);
    }


    protected function check_empty($value)
    {
        if (!isset($value))
            return true;
        if ($value === null)
            return true;
        if (trim($value) === "")
            return true;

        return false;
    }

    private function md5_sign($params)
    {
        ksort($params);

        $body = "";
        $i = 0;
        foreach ($params as $k => $v) {
            if (false === $this->check_empty($v) && "@" != substr($v, 0, 1)) {
                if ($i == 0) {
                    $body .= "{$k}" . "=" . urldecode($v);
                } else {
                    $body .= "&" . "{$k}" . "=" . urldecode($v);
                }
                $i++;
            }
        }

        $body .= "&key=7yDCLS6S2KzSAJQOUc3vsa";

        return md5($body);
    }

    public function testCallMech()
    {
        $logic = Logic('queue');
        $logic->NotifyMerchantComplete(['order_id' => 289]);
    }

    private function send($url, $params)
    {
        $mchid = $params['mchid'];
        $pri_key = BASE_DATA_PATH . "/api/merchant/key/{$mchid}_pri.pem";

        $key = file_get_contents($pri_key);
        $pri = openssl_get_privatekey($key);

        $body = $this->body($params);

        openssl_sign($body, $signed, $pri);
        $sign = base64_encode($signed);
        $params['sign'] = $sign;

        $resp = http_request($url, $params, 'POST');
        Log::record("resp:{$resp}", Log::DEBUG);
    }

    private function send_md5($url, $params)
    {
        $body = $this->body($params);
        $body .= "&key={$this->mKey}";
        $params['sign'] = md5($body);

        $resp = http_request($url, $params, 'POST');
        Log::record("resp:{$resp}", Log::DEBUG);

        return $resp;
    }

    public function testCardType()
    {
        $cardno = '1000111100021211884';
        $ret = preg_match('/^1[0-9]{18}$/', $cardno, $matches);
    }

    public function testMtrand()
    {
    }

    public function testHttpRefill()
    {
        $mchid = '000001';
        $pri_key = BASE_DATA_PATH . "/api/merchant/key/{$mchid}_pri.pem";

        $key = file_get_contents($pri_key);
        $pri = openssl_get_privatekey($key);

        $params = ['MCHID' => $mchid, 'cardno' => '1000111100021211884', 'amt' => "100", "act" => "refill", "op" => "addoil"];
        $body = $this->body($params);

        openssl_sign($body, $signed, $pri);
        $sign = base64_encode($signed);
        $params['sign'] = $sign;

        $resp = http_request(BASE_SITE_URL . "/mobile/index.php", $params, 'POST');
    }

    private function body($params)
    {
        ksort($params);
        $body = "";
        $i = 0;
        foreach ($params as $k => $v) {
            if (false === $this->checkEmpty($v) && "@" != substr($v, 0, 1)) {
                if ($i == 0) {
                    $body .= "{$k}" . "=" . urlencode($v);
                } else {
                    $body .= "&" . "{$k}" . "=" . urlencode($v);
                }
                $i++;
            }
        }
        return $body;
    }

    private function checkEmpty($value)
    {
        if (!isset($value))
            return true;
        if ($value === null)
            return true;
        if (trim($value) === "")
            return true;

        return false;
    }

    public function testKsort()
    {
        $age = ["Peter" => "35", "Ben" => "37", "Joe" => "43"];
        ksort($age);

        foreach ($age as $x => $x_value) {
            echo "Key=" . $x . ", Value=" . $x_value;
            echo "<br>";
        }
    }

    public function testip()
    {
        $model_merchant = Model('merchant');
        $merchant_info = $model_merchant->getMerchantInfo(['mchid' => 1]);
        $ipwhitelist = unserialize($merchant_info['ip_white_list']);
        $res = json_encode($ipwhitelist);
    }

    //测试向内部店提交订单,可先屏蔽其它充值通道
    public function testAddoilToInnerStore()
    {
        $url = $this->mReqHost . "/mobile/index.php";
        $notifyurl = BASE_SITE_URL . '/mobile/signature.php';
        $params = ['mchid' => 1,
            'cardno' => '1000111100020445281',
            'amount' => "1000",
            "act" => "refill",
            "op" => "add",
            'card_name' => '江海苗',
            'order_sn' => $this->make_sn(),
            'notifyurl' => $notifyurl];

        $resp = $this->send_md5($url, $params);
        Log::record($resp, Log::DEBUG);
    }

    public function testRefillInnerCB()
    {
        $params = ['state_type' => 'order_cancel','order_id' => 311,'channel_name' => 'lx'];
        $resp = http_request(BASE_SITE_URL . '/mobile/refill_inner.php',$params,'POST');
    }

    public function testArgs()
    {
        Log::record($_SERVER['argv'],Log::DEBUG);
    }

    public function testCall()
    {
        $order_id = 14974;
        QueueClient::async_push("NotifyMerchantComplete", ['order_id' => $order_id], 10);
    }
}


//docker-compose run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestRefill::testCall)( .*)?$/" --test-suffix TestRefill.php /var/www/html/test
//docker-compose -f ./docker-compose-dev.yml run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestRefill::testCall)( .*)?$/" --test-suffix TestRefill.php /var/www/html/test