<?php
declare(strict_types=0);

define('MOBILE_SERVER', true);
define('USE_COROUTINE', true);
define('SUPPORT_PTHREAD', false);

define('APP_ID', 'comysqli');
define('BASE_ROOT_PATH', str_replace('/server', '', dirname(__FILE__)));
define('BASE_PATH', BASE_ROOT_PATH . '/server');
define('COROUTINE_HOOK_TCP',true);

require_once(BASE_ROOT_PATH . '/global.php');
require_once(BASE_ROOT_PATH . '/fooder.php');
require_once(BASE_HELPER_PATH . '/refill_proxy.php');
require_once(BASE_CORE_PATH . '/framework/function/http.php');
require_once(BASE_CORE_PATH . '/framework/libraries/CoRefPool.php');
require_once(BASE_CORE_PATH . '/framework/libraries/CoMysqliPool.php');
require_once(BASE_CORE_PATH . '/framework/libraries/CoPool.php');
require_once(BASE_CORE_PATH . '/framework/libraries/CoRedisPool.php');

Co::set(['hook_flags' => SWOOLE_HOOK_NATIVE_CURL | SWOOLE_HOOK_SLEEP | SWOOLE_HOOK_TCP]);

class MysqliPoolTest
{
    public function setval()
    {
        for ($i = 0; $i < 2000; $i++)
        {
            Log::record("setval index = {$i}",Log::DEBUG);
            go(function ()
            {
                $mod_order = Model('vr_order');
                $order_info = $mod_order->getOrderInfo(['order_sn' => '4694820679086133084177']);

                $mod_orderx = Model('vr_order');
                $order_info = $mod_orderx->getOrderInfo(['order_sn' => '4694820679086133084177']);
            });
        }
    }

    public function readval()
    {
        for ($i = 0; $i < 2000; $i++)
        {
            Log::record("readval index = {$i}",Log::DEBUG);
            go(function ()
            {
                $mod_order = Model('vr_order');
                $order_info = $mod_order->getOrderInfo(['order_sn' => '4694820679086133084177']);

                $mod_orderx = Model('vr_order');
                $order_info = $mod_orderx->getOrderInfo(['order_sn' => '4694820679086133084177']);
            });
        }
    }
}

Swoole\Coroutine::set(['max_coroutine' => 500]);

go(function ()
{
    Base::run_util();

    $test = new MysqliPoolTest();
    go(function () use($test)
    {
        for ($i = 0; $i < 10; $i++)
        {
            Log::record("cur index = {$i}",Log::DEBUG);
            go(function () use($test)
            {
                $test->setval();
            });
            sleep(1);
        }
    });

    go(function () use($test)
    {
        for ($i = 0; $i < 10; $i++)
        {
            go(function () use($test)
            {
                $test->readval();
            });
            sleep(1);
        }
    });

    sleep(20);
    CoRedisPool::instance()->stop();
    CoMysqliPool::instance()->stop();
});

//docker-compose run phpswoole php /var/www/html/server/comysqli.php