113 lines
3.6 KiB
PHP
113 lines
3.6 KiB
PHP
<?php
|
|
|
|
namespace App\Utils\Workerman;
|
|
|
|
use Workerman\Lib\Timer;
|
|
use App\MarketHour;
|
|
use App\Jobs\LeverUpdate;
|
|
use App\Jobs\LeverPushPrice;
|
|
|
|
class WorkerCallback
|
|
{
|
|
protected $events = [
|
|
'onWorkerStart',
|
|
'onConnect',
|
|
'onMessage',
|
|
'onClose',
|
|
'onError',
|
|
'onBufferFull',
|
|
'onBufferDrain',
|
|
'onWorkerStop',
|
|
'onWorkerReload'
|
|
];
|
|
|
|
protected $interval = 1; //行情处理时间间隔，单位秒，支持小数
|
|
protected $wsConnection; //websocket client连接
|
|
protected $worker;
|
|
|
|
public function __construct()
|
|
{
|
|
$this->registerEvent();
|
|
}
|
|
|
|
public function registerEvent()
|
|
{
|
|
foreach ($this->events as $key => $event) {
|
|
method_exists($this, $event) && $this->$event = [$this, $event];
|
|
}
|
|
}
|
|
|
|
public function onWorkerStart($worker)
|
|
{
|
|
$this->worker = $worker;
|
|
$period = '';
|
|
echo '进程' . $worker->id .'启动'. PHP_EOL;
|
|
if ($worker->id < 8) {
|
|
$periods = ['1min', '5min', '15min', '30min', '60min', '1day', '1mon', '1week']; //['1day', '1min'];
|
|
$period = $periods[$worker->id];
|
|
$worker->name = 'huobi.ws:' . 'market.kline.' . $period;
|
|
} else {
|
|
$worker->name = 'huobi.ws:' . 'market.depth.step0';
|
|
}
|
|
$ws_con = new WsConnection($worker->id);
|
|
$this->wsConnection = $ws_con;
|
|
$ws_con->connect();
|
|
|
|
if ($period == '1day') {
|
|
|
|
Timer::add($this->interval, function () {
|
|
$data = MarketHour::getHuobiLeverMarket();
|
|
echo date('Y-m-d H:i:s') . '定时器取价格' . PHP_EOL;
|
|
$now = microtime(true);
|
|
$master_start = microtime(true);
|
|
echo str_repeat('=', 80) . PHP_EOL;
|
|
echo date('Y-m-d H:i:s') . '开始发送价格到杠杆交易系统' . PHP_EOL;
|
|
echo '{' . PHP_EOL;
|
|
foreach ($data as $key => $value) {
|
|
$start = microtime(true);
|
|
echo "\t" . date('Y-m-d H:i:s') . ' 发送' . $value->symbol . ',价格:' . $value->now_price . PHP_EOL;
|
|
$params = [
|
|
'legal_id' => $value->legal_id,
|
|
'legal_name' => $value->legal_name,
|
|
'currency_id' => $value->currency_id,
|
|
'currency_name' => $value->currency_name,
|
|
'now_price' => $value->now_price,
|
|
'now' => $now
|
|
];
|
|
//价格大于0才进行任务推送
|
|
if (bc_comp($value->now_price, 0) > 0) {
|
|
// LeverUpdate::dispatch($params)->onQueue('lever:update');
|
|
// LeverPushPrice::dispatch($params)->onQueue('lever:push:price');
|
|
}
|
|
$end = microtime(true);
|
|
echo "\t" . date('Y-m-d H:i:s') . $value->symbol . '处理完成,耗时' .($end - $start) . '秒' . PHP_EOL;
|
|
}
|
|
$master_end = microtime(true);
|
|
echo '}' . PHP_EOL;
|
|
echo date('Y-m-d H:i:s') .'杠杆交易系统处理完成,耗时' .($master_end - $master_start) . '秒' . PHP_EOL;
|
|
echo str_repeat('=', 80) . PHP_EOL;
|
|
});
|
|
}
|
|
|
|
}
|
|
|
|
public function onWorkerReload($worker)
|
|
{
|
|
}
|
|
|
|
public function onConnect($connection)
|
|
{
|
|
}
|
|
|
|
public function onClose($connection)
|
|
{
|
|
}
|
|
|
|
public function onError($connection, $code, $msg)
|
|
{
|
|
}
|
|
|
|
public function onMessage($connection, $data)
|
|
{
|
|
}
|
|
} |