xyzshop/rdispatcher/processor.php

<?php

require_once(BASE_CORE_PATH . '/framework/function/http.php');


class processor extends queue\ILooper
{
    private $mProxy;
    const USE_COROUTINE = 1;

    public function __construct()
    {
        parent::__construct(new queue\DispatcherServer());
        $this->mProxy = new proxy();
    }

    protected function handle($msg)
    {
        if(empty($msg)) {
            Log::record('empty body',Log::DEBUG);
            Co::resume();
        }
        else
        {
            foreach ($msg as $key => $params)
            {
                Log::record("start one", Log::DEBUG);
                $method = strtolower($key);
                if($method == 'add')
                {
//                    go(function () use ($params) {
//                        Log::record(__FUNCTION__,Log::DEBUG);
//                        $mchid = $params['mchid'];
//                        $buyer_id = $params['buyer_id'];
//                        $amount = $params['amount'];
//                        $card_no = $params['card_no'];
//                        $mch_order = $params['mch_order'];
//                        $notify_url = $params['notify_url'];
//                        $idcard = $params['idcard'] ?? '';
//                        $card_name = $params['card_name'] ?? '';
//                        $order_time = $params['order_time'] ?? 0;
//                        $commit_times = $params['commit_times'] ?? 0;
//
//                        $minfo = new member_info($buyer_id);
//                        $available = $minfo->available_predeposit();
//                        Log::record("available = {$available}",Log::DEBUG);
//
//                        $resp = http_request('https://www.xyzshops.cn/mobile/index.php?act=index&op=index&client_type=ios');
//                        Log::record("recv size=" . strlen($resp), Log::DEBUG);
//                    });

                    $proxy = new proxy();
                    go(function () use ($proxy,$params) {
                        try {
                            $proxy->add($params);
                        }
                        catch (Exception $x) {
                            Log::record($x->getMessage(),Log::ERR);
                        }
                    });

//                    Swoole\Runtime::enableCoroutine(SWOOLE_HOOK_CURL);
//                    Swoole\Coroutine\run(function () use ($proxy,$params) {
//                        $proxy->add($params);
//                    });

//                    if(processor::USE_COROUTINE) {
//                        Swoole\Coroutine\run(function () use ($proxy,$params) {
//                            $proxy->add($params);
//                        });
//                    }
//                    else {
//                        $proxy->add($params);
//                    }
                }
                elseif($method == 'notify') {

                }
                elseif($method == 'notify_mechant') {

                }
                else {
                    Log::record("Error msg",Log::DEBUG);
                }
            }
        }
    }
}