xyzshop/crontab/control/vendor.php

<?php

defined('InShopNC') or exit('Access Invalid!');

require_once (BASE_ROOT_PATH . '/helper/message/publisher.php');
require_once(BASE_HELPER_PATH . '/refill/util.php');
require_once(BASE_HELPER_PATH . '/refill/divert_account.php');
require_once(BASE_HELPER_PATH . '/refill/RefillFactory.php');
require_once(BASE_CORE_PATH . '/framework/function/http.php');
require_once(BASE_HELPER_PATH . '/PHPExcel/PHPExcel.php');


class vendorControl
{
    public function __construct(){
        Log::short_name('vendor');
    }

    //中石化电子券token获取
    public function token_refreshOp()
    {
        Log::record(__METHOD__,Log::DEBUG);
        require_once(BASE_HELPER_RAPI_PATH . "/gdsinopec/config.php");

        $worker = function (&$period) : bool
        {
            $token_req = new refill\gdsinopec\config();
            [$state, $result] = $token_req->get_access_token();
            if ($state === false) {
                Log::record("get token fail msg:$result", Log::ERR);
                return false;
            } else {
                $period = $result;
                return true;
            }
        };

        $next_time = 0;
        $period = 7000;

        while (true)
        {
            try
            {
                if($next_time > time()) {
                    sleep(1);
                }
                elseif($worker($period)) {
                    $next_time = time() + $period;
                }
                else {
                    Log::record("token_refresh",Log::ERR);
                }
            }
            catch (Exception $ex) {
                Log::record($ex->getMessage(),Log::ERR);
            }
        }
    }
}