php workerman定时任务

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2018/11/29
 * Time: 16:59
 */

use Workerman\Worker;
use \Workerman\Lib\Timer;

require_once "Workerman/Autoloader.php";


require_once "Connection.php";

$task = new Worker();

$task->onWorkerStart = function ($task) {

    global $db, $redis;
    $db    = new \Workerman\MySQL\Connection(‘127.0.0.1‘, ‘3306‘, ‘root‘, ‘root‘, ‘test‘);
    $redis = new Redis();
    $redis->connect(‘127.0.0.1‘, 6379);
    $redis->auth("qqq123123.");
    $time_interval = 0.1;
    Timer::add($time_interval, function () {
        global $db, $redis;
        
        $insert[‘name‘] = 123;
        
        $db->insert(‘shipments‘)->cols($insert)->query();

//        sleep(100);
    });

};


function curlGet($url = ‘‘, $options = [])
{
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($ch, CURLOPT_TIMEOUT, 30);
    if (!empty($options)) {
        curl_setopt_array($ch, $options);
    }
    //https请求 不验证证书和host
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
    $data = curl_exec($ch);
    curl_close($ch);
    return $data;
}

function newGetOrderInfo($taobao, $orderId)
{
    $taobao = urlencode($taobao);
    $url    = "http://114.55.144.79/taobao/TradeFullinfoGetRequest.php?shop=$taobao&tid=$orderId";
    $json   = curlGet($url);
    return json_decode($json, true)[‘trade‘];
}

Worker::runAll();