You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
352 lines
18 KiB
352 lines
18 KiB
<?php
|
|
require "../index.php";
|
|
|
|
use Carbon\Carbon;
|
|
use Illuminate\Support\Arr;
|
|
use Illuminate\Support\Str;
|
|
use Illuminate\Support\Facades\Cache;
|
|
use Illuminate\Support\Facades\Redis;
|
|
use Workerman\Connection\AsyncTcpConnection;
|
|
use Workerman\Lib\Timer;
|
|
use Workerman\Worker;
|
|
use GatewayWorker\Lib\Gateway;
|
|
|
|
$worker = new Worker();
|
|
$worker->count = 1;
|
|
|
|
|
|
$worker->onWorkerStart = function ($worker) {
|
|
|
|
// 每2.5秒执行一次
|
|
$time_interval = 2;
|
|
Timer::add($time_interval, function () {
|
|
echo "task 1min run\n";
|
|
//$day_kline = Cache::store('redis')->get('swap:' . 'BTC' . '_kline_' . '1min');
|
|
//$day_kline = Cache::store('redis')->get('swap:BTC_kline_1min');
|
|
|
|
//所有交易对
|
|
// $symbols = \App\Models\ContractPair::query()->where('status', 1)->pluck('symbol');
|
|
//
|
|
// foreach ($symbols as $symbol) {
|
|
// // Kline数据
|
|
// if ($symbol != "CKL" || $symbol != "NYI" || $symbol != "GFTL" || $symbol != "HNA" || $symbol != "PVR") {
|
|
// $subaa = 'swap:' . $symbol . '_kline_' . '1min';
|
|
// $sendsub = 'swapKline_' . $symbol . '_1min';
|
|
// //echo $sendsub;
|
|
// $min_kline = Cache::store('redis')->get($subaa);
|
|
// $zhangdie = mt_rand(1000, 3000);
|
|
// if ($zhangdie >= 2000) {
|
|
// $min_kline['close'] += sprintf("%.3f", ($min_kline['close'] * (mt_rand(1000, 1050) / 10000000)));
|
|
// } else {
|
|
// $min_kline['close'] -= sprintf("%.3f", ($min_kline['close'] * (mt_rand(1000, 1050) / 10000000)));
|
|
// }
|
|
// \App\Jobs\TriggerStrategy::dispatch(['symbol' => $symbol, 'realtime_price' => $min_kline['close']])->onQueue('triggerStrategy');
|
|
// //var_dump($min_kline);
|
|
// // Done 所有k先历史数据为GMT -4
|
|
// // $min_kline['time'] = $min_kline['time'] - 43200;
|
|
// Gateway::sendToGroup($sendsub, json_encode(['code' => 0, 'msg' => 'success', 'data' => $min_kline, 'sub' => $sendsub, 'type' => 'dynamic']));
|
|
//
|
|
// }
|
|
// }
|
|
|
|
|
|
//var_dump($day_kline);
|
|
//$aa = "swapKline_BTC_1min";
|
|
//Gateway::sendToGroup($group_id2, json_encode(['code'=>0,'msg'=>'success','data'=>11111,'sub'=>$aa,'type'=>'dynamic']));
|
|
});
|
|
|
|
Gateway::$registerAddress = '127.0.0.1:1238';
|
|
|
|
// $con = new AsyncTcpConnection('ws://api.btcgateway.pro/swap-ws');
|
|
|
|
|
|
// $con = new AsyncTcpConnection('ws://api.btcgateway.pro/linear-swap-ws');
|
|
// $con = new AsyncTcpConnection('ws://fstream.binance.com/ws/btcusdt@kline_1m');
|
|
$con = new AsyncTcpConnection('ws://fstream.binance.com:443/ws');
|
|
|
|
// 设置以ssl加密方式访问，使之成为wss
|
|
$con->transport = 'ssl';
|
|
|
|
$con->onConnect = function ($con) {
|
|
|
|
//所有交易对
|
|
// $symbols = \App\Models\ContractPair::query()->where('status', 1)->pluck('symbol');
|
|
// todo: 修改获取当前行情配置
|
|
$period = '5m'; //3m-5m-15m-30m-1h-2h-4h-6h-8h-12h-1d-3d-1w-1M
|
|
$seconds = 300; //60 300 900 1800 3600 86400 604800 2592000
|
|
|
|
$symbols = \App\Models\ContractPair::query()->where('status', 1)->pluck('symbol');
|
|
$airCoins = \App\Models\Klike::query()->pluck('like_coin');
|
|
$arr1 = array_collapse([$symbols, $airCoins]);
|
|
$symbols = array_values(array_unique($arr1));
|
|
foreach ($symbols as $symbol) {
|
|
$symbol = strtolower($symbol);
|
|
$symbol_list[] = $symbol . "usdt@kline_" . $period;
|
|
}
|
|
$msg1 = ["method" => "SUBSCRIBE", "params" => $symbol_list, "id" => intval(rand(100000, 999999) . time())];
|
|
$send = json_encode($msg1);
|
|
// echo $send;
|
|
$con->send($send);
|
|
|
|
|
|
};
|
|
|
|
$con->onMessage = function ($con, $data) {
|
|
// echo $data;
|
|
// $data = json_decode(gzdecode($data), true);
|
|
$data = json_decode($data, true);
|
|
|
|
if (isset($data['ping'])) {
|
|
$msg = ["pong" => $data['ping']];
|
|
$con->send(json_encode($msg));
|
|
} else {
|
|
if (isset($data['s'])) {
|
|
$ch = $data['s'];
|
|
$symbol = str_before($ch, 'USDT');
|
|
|
|
// if ($ch) {
|
|
if ($ch) {
|
|
// todo: 修改获取当前行情配置
|
|
$period = '5min'; //1min 5min 15min 30min 60min 1day 1week 1mon
|
|
$now = $data['k'];
|
|
$kklinekey = 'swap:' . $symbol . '_kline_' . $period;
|
|
$oneminopen = json_decode(Redis::get($kklinekey), true);
|
|
if ($oneminopen['last_now'] == strtotime(date("Y-m-d H:i:00", time()))) {
|
|
$now['o'] = $oneminopen['open'];
|
|
}
|
|
$now['t'] = substr($now['t'], 0, 10);
|
|
// echo json_encode($cache_data) . "\r\n";
|
|
$cache_data = [
|
|
"id" => $now['t'] * 1,
|
|
"open" => $now['o'] * 1,
|
|
"close" => $now['c'] * 1,
|
|
"low" => $now['l'] * 1,
|
|
"high" => $now['h'] * 1,
|
|
"amount" => $now['V'] * 1,
|
|
'vol' => $now['V'] * 1000,
|
|
'trade_turnover' => $now['Q'] * 1,
|
|
'count' => round($now['V'] * 100, 0),
|
|
];
|
|
// echo json_encode($cache_data) . "\r\n";
|
|
// $cache_data['time'] = time();
|
|
|
|
$kline_book_key = 'swap:' . $symbol . '_kline_book_' . $period;
|
|
$kline_book = Cache::store('redis')->get($kline_book_key);
|
|
|
|
// 获取风控任务
|
|
$risk_key = 'fkJson:' . $symbol . '/USDT';
|
|
//echo $risk_key;
|
|
$risk = json_decode(Redis::get($risk_key), true);
|
|
$minUnit = $risk['minUnit'] ?? 0;
|
|
$count = $risk['count'] ?? 0;
|
|
$enabled = $risk['enabled'] ?? 0;
|
|
$seconds = 60;
|
|
// 当前一分钟 开盘对接
|
|
if (!blank($risk) && $enabled == 1) {
|
|
// 修改价格
|
|
$change = $minUnit * $count;
|
|
$cache_data['close'] = PriceCalculate($cache_data['close'], '+', $change, 8);
|
|
// $cache_data['open'] = PriceCalculate($cache_data['open'], '+', $change, 8);
|
|
$cache_data['high'] = PriceCalculate($cache_data['high'], '+', $change, 8);
|
|
$cache_data['low'] = PriceCalculate($cache_data['low'], '+', $change, 8);
|
|
|
|
// 当前一分钟 开盘对接
|
|
if(($now['t']==$risk['hold']['5min']['time'])){
|
|
// $cache_data['open'] = PriceCalculate($cache_data['open'], '+', $change, 8);
|
|
$cache_data['open'] = $risk['hold']['5min']['price'];
|
|
}else{
|
|
$cache_data['open'] = PriceCalculate($cache_data['open'], '+', $change, 8);
|
|
}
|
|
}
|
|
|
|
if(!empty($risk['hold'])){
|
|
if (!blank($risk) && $enabled == 0 && $count != 0 && $minUnit != 0 && $now['t'] == $risk['hold']['5min']['time']) {
|
|
// $change = $minUnit * $count;
|
|
// $cache_data['open'] = PriceCalculate($cache_data['open'], '+', $change, 8);
|
|
$cache_data['open'] = $risk['hold']['5min']['price'];
|
|
}
|
|
}
|
|
// 1分钟基线
|
|
if (!blank($kline_book)) {
|
|
|
|
$prev_id = $cache_data['id'] - $seconds;
|
|
$prev_item = array_last($kline_book, function ($value, $key) use ($prev_id) {
|
|
return $value['id'] == $prev_id;
|
|
});
|
|
// $cache_data['open'] = $prev_item['close'];
|
|
}
|
|
// echo json_encode($cache_data) . "\r\n";
|
|
if (blank($kline_book)) {
|
|
Cache::store('redis')->put($kline_book_key, [$cache_data]);
|
|
} else {
|
|
$last_item1 = array_pop($kline_book);
|
|
if ($last_item1['id'] == $cache_data['id']) {
|
|
array_push($kline_book, $cache_data);
|
|
} else {
|
|
array_push($kline_book, $last_item1, $cache_data);
|
|
}
|
|
|
|
if (count($kline_book) > 3000) {
|
|
array_shift($kline_book);
|
|
}
|
|
Cache::store('redis')->put($kline_book_key, $kline_book);
|
|
}
|
|
|
|
Cache::store('redis')->put('swap:' . $symbol . '_kline_' . $period, $cache_data);
|
|
|
|
$group_id2 = 'swapKline_' . $symbol . '_' . $period;
|
|
//var_dump($group_id2);
|
|
//echo Gateway::getClientIdCountByGroup($group_id2);
|
|
if (Gateway::getClientIdCountByGroup($group_id2) > 0) {
|
|
// $cache_data['time'] = $cache_data['time'] - 43200;
|
|
Gateway::sendToGroup($group_id2, json_encode(['code' => 0, 'msg' => 'success', 'data' => $cache_data, 'sub' => $group_id2, 'type' => 'dynamic']));
|
|
|
|
}
|
|
|
|
}
|
|
$airCoins = \App\Models\Klike::query()->where('like_coin', $symbol)->get()->toArray();
|
|
foreach ($airCoins as $item) {
|
|
if ($ch) {
|
|
if ($item['like_coin'] == $symbol) {
|
|
$symbolNew = $item['air_coin'];
|
|
}
|
|
// todo: 修改获取当前行情配置
|
|
$period = '5min'; //1min 5min 15min 30min 60min 1day 1week 1mon
|
|
$now = $data['k'];
|
|
$kklinekey = 'swap:' . $symbolNew . '_kline_' . $period;
|
|
$oneminopen = json_decode(Redis::get($kklinekey), true);
|
|
if ($oneminopen['last_now'] == strtotime(date("Y-m-d H:i:00", time()))) {
|
|
$now['o'] = $oneminopen['open'];
|
|
}
|
|
$now['t'] = substr($now['t'], 0, 10);
|
|
if ($item['calculation'] == '*') {
|
|
// $cache_data['price'] = bcmul($cache_data['price'],$item['percent']);
|
|
$now['o'] = $now['o'] * $item['percent'];
|
|
$now['c'] = $now['c'] * $item['percent'];
|
|
$now['h'] = $now['h'] * $item['percent'];
|
|
$now['l'] = $now['l'] * $item['percent'];
|
|
// $data['o'] = $data['o'] * $item['percent'];
|
|
// $data['o'] = $data['o'] * $item['percent'];
|
|
}
|
|
if ($item['calculation'] == '/') {
|
|
// $cache_data['price'] = bcdiv($cache_data['price'],$item['percent']);
|
|
$now['o'] = $now['o'] / $item['percent'];
|
|
$now['c'] = $now['c'] / $item['percent'];
|
|
$now['h'] = $now['h'] / $item['percent'];
|
|
$now['l'] = $now['l'] / $item['percent'];
|
|
// $data['o'] = $data['o'] * $item['percent'];
|
|
// $data['o'] = $data['o'] * $item['percent'];
|
|
}
|
|
// echo json_encode($cache_data) . "\r\n";
|
|
$cache_data = [
|
|
"id" => $now['t'] * 1,
|
|
"open" => $now['o'] * 1,
|
|
"close" => $now['c'] * 1,
|
|
"low" => $now['l'] * 1,
|
|
"high" => $now['h'] * 1,
|
|
"amount" => $now['V'] * 1,
|
|
'vol' => $now['V'] * 1000,
|
|
'trade_turnover' => $now['Q'] * 1,
|
|
'count' => round($now['V'] * 100, 0),
|
|
];
|
|
// \Log::info(json_encode($cache_data).'------'.$symbolNew);
|
|
// echo json_encode($cache_data) . "\r\n";
|
|
// $cache_data['time'] = time();
|
|
|
|
$kline_book_key = 'swap:' . $symbolNew . '_kline_book_' . $period;
|
|
$kline_book = Cache::store('redis')->get($kline_book_key);
|
|
|
|
// 获取风控任务
|
|
$risk_key = 'fkJson:' . $symbolNew . '/USDT';
|
|
//echo $risk_key;
|
|
$risk = json_decode(Redis::get($risk_key), true);
|
|
$minUnit = $risk['minUnit'] ?? 0;
|
|
$count = $risk['count'] ?? 0;
|
|
$enabled = $risk['enabled'] ?? 0;
|
|
$seconds = 60;
|
|
|
|
// 当前一分钟 开盘对接
|
|
if (!blank($risk) && $enabled == 1) {
|
|
// 修改价格
|
|
$change = $minUnit * $count;
|
|
$cache_data['close'] = PriceCalculate($cache_data['close'], '+', $change, 8);
|
|
// $cache_data['open'] = PriceCalculate($cache_data['open'], '+', $change, 8);
|
|
$cache_data['high'] = PriceCalculate($cache_data['high'], '+', $change, 8);
|
|
$cache_data['low'] = PriceCalculate($cache_data['low'], '+', $change, 8);
|
|
|
|
// 当前一分钟 开盘对接
|
|
if(($now['t']==$risk['hold']['5min']['time'])){
|
|
// $cache_data['open'] = PriceCalculate($cache_data['open'], '+', $change, 8);
|
|
$cache_data['open'] = $risk['hold']['5min']['price'];
|
|
}else{
|
|
$cache_data['open'] = PriceCalculate($cache_data['open'], '+', $change, 8);
|
|
}
|
|
}
|
|
|
|
if(!empty($risk['hold'])){
|
|
if (!blank($risk) && $enabled == 0 && $count != 0 && $minUnit != 0 && $now['t'] == $risk['hold']['5min']['time']) {
|
|
// $change = $minUnit * $count;
|
|
// $cache_data['open'] = PriceCalculate($cache_data['open'], '+', $change, 8);
|
|
$cache_data['open'] = $risk['hold']['5min']['price'];
|
|
}
|
|
}
|
|
|
|
// 1分钟基线
|
|
if (!blank($kline_book)) {
|
|
|
|
$prev_id = $cache_data['id'] - $seconds;
|
|
$prev_item = array_last($kline_book, function ($value, $key) use ($prev_id) {
|
|
return $value['id'] == $prev_id;
|
|
});
|
|
// $cache_data['open'] = $prev_item['close'];
|
|
}
|
|
// echo json_encode($cache_data) . "\r\n";
|
|
if (blank($kline_book)) {
|
|
Cache::store('redis')->put($kline_book_key, [$cache_data]);
|
|
} else {
|
|
$last_item1 = array_pop($kline_book);
|
|
if ($last_item1['id'] == $cache_data['id']) {
|
|
array_push($kline_book, $cache_data);
|
|
} else {
|
|
array_push($kline_book, $last_item1, $cache_data);
|
|
}
|
|
|
|
if (count($kline_book) > 3000) {
|
|
array_shift($kline_book);
|
|
}
|
|
Cache::store('redis')->put($kline_book_key, $kline_book);
|
|
}
|
|
$cache_data['close'] = floatval(number_format($cache_data['close'], $item['point'], '.', ''));
|
|
$cache_data['open'] = floatval(number_format($cache_data['open'], $item['point'], '.', ''));
|
|
$cache_data['high'] = floatval(number_format($cache_data['high'], $item['point'], '.', ''));
|
|
$cache_data['low'] = floatval(number_format($cache_data['low'], $item['point'], '.', ''));
|
|
Cache::store('redis')->put('swap:' . $symbolNew . '_kline_' . $period, $cache_data);
|
|
|
|
$group_id2 = 'swapKline_' . $symbolNew . '_' . $period;
|
|
//var_dump($group_id2);
|
|
//echo Gateway::getClientIdCountByGroup($group_id2);
|
|
if (Gateway::getClientIdCountByGroup($group_id2) > 0) {
|
|
// $cache_data['time'] = $cache_data['time'] - 43200;
|
|
Gateway::sendToGroup($group_id2, json_encode(['code' => 0, 'msg' => 'success', 'data' => $cache_data, 'sub' => $group_id2, 'type' => 'dynamic']));
|
|
|
|
}
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
};
|
|
|
|
$con->onClose = function ($con) {
|
|
//这个是延迟断线重连，当服务端那边出现不确定因素，比如宕机，那么相对应的socket客户端这边也链接不上，那么可以吧1改成适当值，则会在多少秒内重新，我也是1，也就是断线1秒重新链接
|
|
$con->reConnect(1);
|
|
};
|
|
|
|
$con->onError = function ($con, $code, $msg) {
|
|
echo "error $code $msg\n";
|
|
};
|
|
|
|
$con->connect();
|
|
};
|
|
|
|
Worker::runAll();
|
|
|