952 lines
38 KiB
PHP
952 lines
38 KiB
PHP
<?php
|
|
|
|
namespace App;
|
|
|
|
use Illuminate\Database\Eloquent\Model;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Redis;
|
|
use Elasticsearch\ClientBuilder;
|
|
use App\Jobs\SendMarket;
|
|
|
|
class MarketHour extends Model
|
|
{
|
|
protected $table = 'market_hour';
|
|
public $timestamps = false;
|
|
|
|
protected static $esClient = null;
|
|
|
|
protected static $period = [
|
|
5 => "1min",
|
|
6 => "5min",
|
|
1 => "15min",
|
|
7 => "30min",
|
|
2 => "60min",
|
|
3 => "1hour",
|
|
4 => "1day",
|
|
8 => "1week",
|
|
9 => "1mon",
|
|
10 => "1year",
|
|
];
|
|
|
|
/**
|
|
* 获得一个ElasticsearchClient实例
|
|
*
|
|
* @return \Elasticsearch\Client
|
|
*/
|
|
public static function getEsearchClient()
|
|
{
|
|
if (is_null(self::$esClient)) {
|
|
// $hosts = config('elasticsearch.hosts');
|
|
$hosts = array("localhost", "9200");
|
|
self::$esClient = ClientBuilder::create()
|
|
->setHosts($hosts)
|
|
->build();
|
|
}
|
|
return self::$esClient;
|
|
}
|
|
|
|
/**
|
|
* 批量写入行情数据
|
|
*
|
|
* @param integer $currency_id 币种ID
|
|
* @param integer $legal_id 法币ID
|
|
* @param float $num 成交数量
|
|
* @param float $price 成交价
|
|
* @param integer $sign 来源标记[0.默认,1.交易更新,2.接口,3.后台添加
|
|
* @param integer|null $time 时间戳
|
|
* @param bool $cumulation 是否累计交易量,默认累计
|
|
* @return void
|
|
*/
|
|
public static function batchWriteMarketData($currency_id, $legal_id, $num, $price, $sign = 0, $time = null, $cumulation = true)
|
|
{
|
|
//$type类型:1.15分钟,2.1小时,3.4小时,4.一天,5.分时,6.5分钟，7.30分钟,8.一周,9.一月,10.一年
|
|
empty($time) && $time = time();
|
|
$types = [5, 6, 1, 7, 2, 3, 4, 8, 9, 10];
|
|
$start = microtime(true);
|
|
//写入行情数据
|
|
DB::beginTransaction();
|
|
foreach ($types as $key => $value) {
|
|
$data = [];
|
|
$timeline = self::getTimelineInstance($value, $currency_id, $legal_id, $sign, $time);
|
|
bc_comp($timeline->start_price, 0) <= 0 && $data['start_price'] = $price;
|
|
$data['end_price'] = $price;
|
|
bc_comp($timeline->highest, $price) < 0 && $data['highest'] = $price;
|
|
if (bc_comp($timeline->mminimum, 0) <= 0 || bc_comp($timeline->mminimum, $price) > 0) {
|
|
$data['mminimum'] = $price;
|
|
}
|
|
$data['number'] = $cumulation ? bc_add($timeline->number, $num, 5) : $num;
|
|
$result = $timeline->updateTimelineData($data);
|
|
unset($timeline);
|
|
unset($data);
|
|
}
|
|
DB::commit();
|
|
$end = microtime(true);
|
|
// echo '本次插入执行'. ($end - $start) . '秒';
|
|
}
|
|
|
|
|
|
/**
|
|
* 批量写入行情数据
|
|
*
|
|
* @param integer $currency_id 币种ID
|
|
* @param integer $legal_id 法币ID
|
|
* @param array $market_data 行情数据
|
|
* @param integer $sign 来源标记[0.默认,1.交易更新,2.接口,3.后台添加
|
|
* @param integer|null $time 时间戳
|
|
* @return void
|
|
*/
|
|
public static function batchWriteKlineMarket($currency_id, $legal_id, $market_data, $sign = 0, $time = null)
|
|
{
|
|
//$type类型:1.15分钟,2.1小时,3.4小时,4.一天,5.分时,6.5分钟，7.30分钟,8.一周,9.一月,10.一年
|
|
empty($time) && $time = time();
|
|
$types = [5, 6, 1, 7, 2, 3, 4, 8, 9, 10];
|
|
$start = microtime(true);
|
|
//写入行情数据
|
|
DB::beginTransaction();
|
|
foreach ($types as $key => $value) {
|
|
$data = [];
|
|
$timeline = self::getTimelineInstance($value, $currency_id, $legal_id, $sign, $time);
|
|
if ($value == 5) {
|
|
//1分钟的只要传了就更新
|
|
isset($market_data['open']) && $data['start_price'] = $market_data['open'];
|
|
isset($market_data['close']) && $data['end_price'] = $market_data['close'];
|
|
isset($market_data['high']) && $data['highest'] = $market_data['high'];
|
|
isset($market_data['low']) && $data['mminimum'] = $market_data['low'];
|
|
isset($market_data['amount']) && $data['number'] = $market_data['amount'];
|
|
} else {
|
|
if (isset($market_data['open']) && bc_comp($timeline->start_price, 0) <= 0) {
|
|
$data['start_price'] = $market_data['open'];
|
|
}
|
|
if (isset($market_data['close'])) {
|
|
$data['end_price'] = $market_data['close'];
|
|
}
|
|
if (isset($market_data['high']) && bc_comp($timeline->highest, $market_data['high']) < 0) {
|
|
$data['highest'] = $market_data['high'];
|
|
}
|
|
if (isset($market_data['low']) && (bc_comp($timeline->mminimum, 0) <= 0 || bc_comp($timeline->mminimum, $market_data['low']) > 0)) {
|
|
$data['mminimum'] = $market_data['low'];
|
|
}
|
|
if (isset($market_data['amount'])) {
|
|
$sum = self::where('type', 5)
|
|
->where('currency_id', $currency_id)
|
|
->where('legal_id', $legal_id)
|
|
->where('day_time', '>=', $timeline->day_time)
|
|
->sum('number');
|
|
$sum || $sum = 0;
|
|
$data['number'] = $sum;
|
|
}
|
|
}
|
|
$result = $timeline->updateTimelineData($data);
|
|
unset($timeline);
|
|
unset($data);
|
|
}
|
|
DB::commit();
|
|
$end = microtime(true);
|
|
//echo '本次插入执行'. ($end - $start) . '秒';
|
|
}
|
|
|
|
/**
|
|
* 更新当前时间线实例数据
|
|
*
|
|
* @param array $data 包含:start_price,end_price,highest,mminimum,number中任意键的数组
|
|
* @return bool
|
|
*/
|
|
public function updateTimelineData($data)
|
|
{
|
|
if (isset($this->day_time) && isset($this->type) && isset($this->currency_id) && isset($this->legal_id)) {
|
|
isset($data['start_price']) && $this->start_price = $data['start_price'];
|
|
isset($data['end_price']) && $this->end_price = $data['end_price'];
|
|
isset($data['highest']) && $this->highest = $data['highest'];
|
|
isset($data['mminimum']) && $this->mminimum = $data['mminimum'];
|
|
isset($data['number']) && $this->number = $data['number'];
|
|
isset($data['period']) || $this->period = self::$period[$this->type];
|
|
$result = $this->save();
|
|
return $result;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 设置时间线数据
|
|
*
|
|
* @param integer $type 类型:1.15分钟,2.1小时,3.4小时,4.一天,5.分时,6.5分钟，7.30分钟,8.一周,9.一月
|
|
* @param integer $currency_id 币种id
|
|
* @param integer $legal_id 法币id
|
|
* @param array $data 包含:start_price,end_price,highest,mminimum,number中任意键的数组
|
|
* @param integer $sign 来源标记[0.默认,1.交易更新,2.接口,3.后台添加
|
|
* @param integer $day_time 时间戳
|
|
* @return bool
|
|
*/
|
|
public static function setTimelineData($type, $currency_id, $legal_id, $data, $sign = 0, $day_time = null)
|
|
{
|
|
empty($day_time) && $day_time = time();
|
|
$timeline = self::getTimelineInstance($type, $currency_id, $legal_id, $sign, $day_time);
|
|
if (empty($data) || !is_array($data)) {
|
|
return false;
|
|
}
|
|
isset($data['start_price']) && $timeline->start_price = $data['start_price'];
|
|
isset($data['end_price']) && $timeline->end_price = $data['end_price'];
|
|
isset($data['highest']) && $timeline->highest = $data['highest'];
|
|
isset($data['mminimum']) && $timeline->mminimum = $data['mminimum'];
|
|
isset($data['number']) && $timeline->number = $data['number'];
|
|
isset($data['period']) || $timeline->period = self::$period[$type];
|
|
$result = $timeline->save();
|
|
return $result;
|
|
}
|
|
|
|
/**
|
|
* 取指定类型时间线实例,如果没有自动创建
|
|
*
|
|
* @param integer $type 类型:[1.15分钟,2.1小时,3.4小时,4.一天,5.分时,6.5分钟，7.30分钟,8.一周,9.一月]
|
|
* @param integer $currency_id 币种id
|
|
* @param integer $legal_id 法币id
|
|
* @param integer $sign 来源标记[0.默认,1.交易更新,2.接口,3.后台添加
|
|
* @param integer $day_time 时间戳
|
|
* @return void
|
|
*/
|
|
public static function getTimelineInstance($type, $currency_id, $legal_id, $sign = 0, $day_time = null)
|
|
{
|
|
empty($day_time) && $day_time = time();
|
|
$time = self::formatTimeline($type, $day_time);
|
|
$timeline = self::where('type', $type)
|
|
->where('day_time', $time)
|
|
->where('currency_id', $currency_id)
|
|
->where('legal_id', $legal_id)
|
|
->first();
|
|
if (!$timeline) {
|
|
$timeline = self::makeTimelineData($type, $currency_id, $legal_id, $sign, $day_time);
|
|
} else {
|
|
$timeline->sign = $sign;
|
|
}
|
|
return $timeline;
|
|
}
|
|
|
|
/**
|
|
* 生成一条时间线数据
|
|
*
|
|
* @param integer $type 类型:1.15分钟,2.1小时,3.4小时,4.一天,5.分时,6.5分钟，7.30分钟,8.一周,9.一月
|
|
* @param integer $currency_id 币种id
|
|
* @param integer $legal_id 法币id
|
|
* @param integer $sign 来源标记[0.默认,1.交易更新,2.接口,3.后台添加
|
|
* @param integer $day_time 时间戳
|
|
* @return App\MarketHour 返回一个行情模型实例
|
|
*/
|
|
private static function makeTimelineData($type, $currency_id, $legal_id, $sign = 0, $day_time = null)
|
|
{
|
|
empty($day_time) && $day_time = time();
|
|
$time = self::formatTimeline($type, $day_time);
|
|
$timeline = new self();
|
|
$timeline->type = $type;
|
|
$timeline->day_time = $time;
|
|
$timeline->currency_id = $currency_id;
|
|
$timeline->legal_id = $legal_id;
|
|
$timeline->start_price = 0;
|
|
$timeline->end_price = 0;
|
|
$timeline->highest = 0;
|
|
$timeline->mminimum = 0;
|
|
$timeline->number = 0;
|
|
$timeline->sign = $sign;
|
|
$timeline->period = self::$period[$type];
|
|
$result = $timeline->save();
|
|
return $timeline;
|
|
}
|
|
|
|
/**
|
|
* 按类型格式化时间线
|
|
*
|
|
* @param integer $type 类型:1.15分钟,2.1小时,3.一年,4.一天,5.分时,6.5分钟，7.30分钟,8.一周,9.一月,10.4小时
|
|
* @param integer $day_time 时间戳,不传将默认采用当前时间
|
|
* @return void
|
|
*/
|
|
private static function formatTimeline($type, $day_time = null)
|
|
{
|
|
empty($day_time) && $day_time = time();
|
|
switch ($type) {
|
|
//15分钟
|
|
case 1:
|
|
$start_time = strtotime(date('Y-m-d H:00:00', $day_time));
|
|
$minute = intval(date('i', $day_time));
|
|
$multiple = floor($minute / 15);
|
|
$minute = $multiple * 15;
|
|
$time = $start_time + $minute * 60;
|
|
break;
|
|
//1小时
|
|
case 2:
|
|
$time = strtotime(date('Y-m-d H:00:00', $day_time));
|
|
break;
|
|
//4小时
|
|
case 3:
|
|
$start_time = strtotime(date('Y-m-d', $day_time));
|
|
$hours = intval(date('H', $day_time));
|
|
$multiple = floor($hours / 4);
|
|
$hours = $multiple * 4;
|
|
$time = $start_time + $hours * 3600;
|
|
break;
|
|
//一天
|
|
case 4:
|
|
$time = strtotime(date('Y-m-d', $day_time));
|
|
break;
|
|
//分时
|
|
case 5:
|
|
$time_string = date('Y-m-d H:i', $day_time);
|
|
$time = strtotime($time_string);
|
|
break;
|
|
//5分钟
|
|
case 6:
|
|
$start_time = strtotime(date('Y-m-d H:00:00', $day_time));
|
|
$minute = intval(date('i', $day_time));
|
|
$multiple = floor($minute / 5);
|
|
$minute = $multiple * 5;
|
|
$time = $start_time + $minute * 60;
|
|
break;
|
|
//30分钟
|
|
case 7:
|
|
$start_time = strtotime(date('Y-m-d H:00:00', $day_time));
|
|
$minute = intval(date('i', $day_time));
|
|
$multiple = floor($minute / 30);
|
|
$minute = $multiple * 30;
|
|
$time = $start_time + $minute * 60;
|
|
break;
|
|
//一周
|
|
case 8:
|
|
$start_time = strtotime(date('Y-m-d', $day_time));
|
|
$week = intval(date('w', $day_time));
|
|
$diff_day = $week;
|
|
$time = $start_time - $diff_day * 86400;
|
|
break;
|
|
//一月
|
|
case 9:
|
|
$time_string = date('Y-m', $day_time);
|
|
$time = strtotime($time_string);
|
|
break;
|
|
//一年
|
|
case 10:
|
|
$time = strtotime(date('Y-01-01', $day_time));
|
|
break;
|
|
default:
|
|
$time = $day_time;
|
|
break;
|
|
}
|
|
return $time;
|
|
}
|
|
|
|
public static function getHuobiLeverMarket()
|
|
{
|
|
$currency_match = CurrencyMatch::where('market_from', 2)
|
|
->where('open_lever', 1)
|
|
->get();
|
|
if (count($currency_match) <= 0) {
|
|
return false;
|
|
}
|
|
return $currency_match;
|
|
}
|
|
|
|
|
|
public static function setEsearchMarket($market_data)
|
|
{
|
|
$es_client = self::getEsearchClient();
|
|
$type = $market_data['base-currency'] . '.' . $market_data['quote-currency'] . '.' . $market_data['period'];
|
|
// $market_data['close']>6600&&var_dump($market_data);
|
|
$params = [
|
|
'index' => 'market.kline',
|
|
'type' => 'doc',
|
|
'id' => $type . '.' . $market_data['id'],
|
|
'body' => $market_data,
|
|
];
|
|
$response = $es_client->index($params);
|
|
return $response;
|
|
}
|
|
|
|
public static function getAndSetEsearchMarket($market_data)
|
|
{
|
|
$result = self::getEsearchMarketById($market_data['base-currency'], $market_data['quote-currency'], $market_data['period'], $market_data['id']);
|
|
if (isset($result['_source'])) {
|
|
$data = $result['_source'];
|
|
$price = $market_data['close'];
|
|
|
|
//当前价格和原最高价最低价对比
|
|
bc_comp($data['high'], $price) < 0 && $market_data['high'] = $price; //更新最高价
|
|
bc_comp($data['low'], $price) > 0 && $market_data['low'] = $price; //更新最低价
|
|
|
|
bc_comp($market_data['high'], $data['high']) < 0 && $market_data['high'] = $data['high']; //新过来的价格如果不高于原最高价则不更新
|
|
bc_comp($market_data['low'], $data['low']) > 0 && $market_data['low'] = $data['low']; //新过来的价格如果不低于原最低价则不更新
|
|
}
|
|
if ($market_data['close'] > 6600) {
|
|
echo 'get and set ' . json_encode($market_data);
|
|
}
|
|
$response = self::setEsearchMarket($market_data);
|
|
return $response;
|
|
}
|
|
|
|
public static function getEsearchMarketById($base_currency, $quote_currency, $peroid, $id)
|
|
{
|
|
try {
|
|
$es_client = self::getEsearchClient();
|
|
$type = $base_currency . '.' . $quote_currency . '.' . $peroid;
|
|
$params = [
|
|
'index' => 'market.kline',
|
|
'type' => 'doc',
|
|
'id' => $type . '.' . $id,
|
|
];
|
|
$result = $es_client->get($params);
|
|
} catch (\Throwable $th) {
|
|
$result = [];
|
|
}
|
|
|
|
|
|
return $result;
|
|
}
|
|
|
|
|
|
public static function getEsearchMarketBySina($base_currency, $quote_currency, $peroid, $id)
|
|
{
|
|
try {
|
|
$es_client = self::getEsearchClient();
|
|
$type = $base_currency . '.' . $quote_currency . '.' . $peroid;
|
|
$params = [
|
|
'index' => 'market.daymarket',
|
|
'type' => 'doc',
|
|
'id' => $type . '.' . $id,
|
|
];
|
|
$result = $es_client->get($params);
|
|
} catch (\Throwable $th) {
|
|
$result = [];
|
|
}
|
|
|
|
|
|
return $result;
|
|
}
|
|
|
|
public static function getKline($name, $peroid, $limit)
|
|
{
|
|
|
|
$host = "http://finance.market.alicloudapi.com";
|
|
$path = "/waihui/kline";
|
|
$method = "GET";
|
|
$appcode = "38e9f1ff393246c6b9f3569512e1e5c4";
|
|
$headers = array();
|
|
array_push($headers, "Authorization:APPCODE " . $appcode);
|
|
// $querys = "symbol=".$name;
|
|
$querys = "symbol=".$name."&type=".$peroid."&limit=".$limit;
|
|
$bodys = "";
|
|
$url = $host . $path . "?" . $querys;
|
|
|
|
$curl = curl_init();
|
|
curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
|
|
curl_setopt($curl, CURLOPT_URL, $url);
|
|
curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
|
|
curl_setopt($curl, CURLOPT_FAILONERROR, false);
|
|
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($curl, CURLOPT_HEADER, 0);
|
|
if (1 == strpos("$".$host, "https://"))
|
|
{
|
|
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
|
|
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
|
|
}
|
|
return curl_exec($curl);
|
|
|
|
}
|
|
|
|
public static function getwaipanKline($name, $peroid, $limit)
|
|
{
|
|
|
|
$host = "http://finance.market.alicloudapi.com";
|
|
$path = "/waipan/kline";
|
|
$method = "GET";
|
|
$appcode = "38e9f1ff393246c6b9f3569512e1e5c4";
|
|
$headers = array();
|
|
array_push($headers, "Authorization:APPCODE " . $appcode);
|
|
// $querys = "symbol=".$name;
|
|
$querys = "symbol=".$name."&type=".$peroid."&limit=".$limit;
|
|
$bodys = "";
|
|
$url = $host . $path . "?" . $querys;
|
|
|
|
$curl = curl_init();
|
|
curl_setopt($curl, CURLOPT_CUSTOMREQUEST, $method);
|
|
curl_setopt($curl, CURLOPT_URL, $url);
|
|
curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
|
|
curl_setopt($curl, CURLOPT_FAILONERROR, false);
|
|
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($curl, CURLOPT_HEADER, 0);
|
|
if (1 == strpos("$".$host, "https://"))
|
|
{
|
|
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
|
|
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
|
|
}
|
|
return curl_exec($curl);
|
|
|
|
}
|
|
|
|
|
|
/**
|
|
* 从ElasticSearch取行情
|
|
*
|
|
* @param string $base_currency 基础币种，即交易币
|
|
* @param string $quote_currency 计价币种，即法币
|
|
* @param string $peroid 行情时间分辨率
|
|
* @param integer $from 开始时间戳
|
|
* @param integer $to 结束时间戳
|
|
* @return array
|
|
*/
|
|
public static function getEsearchMarket($base_currency, $quote_currency, $peroid, $from, $to)
|
|
{
|
|
|
|
// file_put_contents('/www/wwwroot/crypto/public/t1.txt',$peroid."--".$base_currency."---".$quote_currency.PHP_EOL,FILE_APPEND);
|
|
|
|
$size = 0;
|
|
$base_currencys = $base_currency;
|
|
$base_currency = strtoupper($base_currency);
|
|
$currency_model = Currency::where(['name' => $base_currency])->first();
|
|
$match = CurrencyMatch::where(['currency_id' => $currency_model->id, 'legal_id' => 3])->first();
|
|
|
|
|
|
$quote_currencys = $quote_currency;
|
|
$quote_currency = strtoupper($quote_currency);
|
|
$interval_list = [
|
|
"1min" => 60,
|
|
"5min" => 300,
|
|
"15min" => 900,
|
|
"30min" => 1800,
|
|
"60min" => 3600,
|
|
"1hour" => 3600,
|
|
"1day" => 86400,
|
|
"1week" => 604808,
|
|
"1mon" => 2592000,
|
|
"1year" => 31536000,
|
|
];
|
|
$interval = $interval_list[$peroid];
|
|
$size = intval(($to - $from) / $interval) + 100;
|
|
$size > 10000 && $size = 10000;
|
|
$type = $base_currency . '.' . $quote_currency . '.' . $peroid;
|
|
|
|
// file_put_contents('/www/wwwroot/crypto/public/t.txt',$peroid."--".$base_currency."---".$match->market_from.PHP_EOL,FILE_APPEND);
|
|
|
|
if ($match->market_from == 0) {
|
|
|
|
if($peroid=="1day") $types=0;
|
|
if($peroid=="1min") $types=1;
|
|
if($peroid=="5min") $types=5;
|
|
if($peroid=="15min") $types=15;
|
|
if($peroid=="30min") $types=30;
|
|
if($peroid=="60min") $types=60;
|
|
if($peroid=="1hour") $types=60;
|
|
if($peroid=="1week") $types=120;
|
|
if($peroid=="1mon") $types=240;
|
|
if($peroid=="1year") $types=240;
|
|
$res = self::getKline($base_currency,$types,300);
|
|
|
|
$res = json_decode($res, true);
|
|
$data_arr = [];
|
|
if (!isset($res['data']['lines'])) {
|
|
return [];
|
|
}
|
|
|
|
foreach ($res['data']['lines'] as $key => $item) {
|
|
$data_arr[] = [
|
|
"id" => $item[7],
|
|
"period" => $peroid,
|
|
"base-currency" => strtolower($base_currency),
|
|
"quote-currency" =>$quotecurrency,
|
|
"open" => $item[0],
|
|
"close" => $item[1],
|
|
"high" => $item[2],
|
|
"low" => $item[3],
|
|
"vol" => 0,
|
|
"amount" => $item[0]
|
|
];
|
|
|
|
$res = array_reverse($data_arr);
|
|
}
|
|
|
|
}
|
|
|
|
if ($match->market_from == 3) {
|
|
|
|
if($peroid=="1day") $types=0;
|
|
if($peroid=="1min") $types=1;
|
|
if($peroid=="5min") $types=5;
|
|
if($peroid=="15min") $types=15;
|
|
if($peroid=="30min") $types=30;
|
|
if($peroid=="60min") $types=60;
|
|
if($peroid=="1hour") $types=60;
|
|
if($peroid=="1week") $types=120;
|
|
if($peroid=="1mon") $types=240;
|
|
if($peroid=="1year") $types=240;
|
|
$res = self::getwaipanKline($base_currency,$types,300);
|
|
|
|
$res = json_decode($res, true);
|
|
$data_arr = [];
|
|
if (!isset($res['data']['lines'])) {
|
|
return [];
|
|
}
|
|
|
|
foreach ($res['data']['lines'] as $key => $item) {
|
|
$data_arr[] = [
|
|
"id" => $item[7],
|
|
"period" => $peroid,
|
|
"base-currency" => strtolower($base_currency),
|
|
"quote-currency" =>$quotecurrency,
|
|
"open" => $item[0],
|
|
"close" => $item[1],
|
|
"high" => $item[2],
|
|
"low" => $item[3],
|
|
"vol" => 0,
|
|
"amount" => $item[0]
|
|
];
|
|
|
|
$res = array_reverse($data_arr);
|
|
}
|
|
|
|
}
|
|
|
|
if ($match->market_from == 2) {
|
|
// if ($match->market_from == 1) {
|
|
// $base_currencys = $currency_model->type;
|
|
// }
|
|
$res = file_get_contents("https://api.huobi.pro/market/history/kline?symbol=" . strtolower($base_currencys . $quote_currencys) . "&period={$peroid}&size=100");
|
|
// dd($res);
|
|
$res = json_decode($res, true);
|
|
$data_arr = [];
|
|
if (!isset($res['data'])) {
|
|
return [];
|
|
}
|
|
foreach ($res['data'] as $key => $item) {
|
|
$item['change']=(($item['close']-$item['open'])/$item['open'])*100;
|
|
$dass=DB::table('currency_contact')->where('currency_id',$currency_model->id)->where('time',date('YmdHi',$item['id']))->first();
|
|
|
|
if($dass){
|
|
$sisValue =$dass->oncontact;
|
|
if($sisValue != 0){
|
|
$item['high'] = round($item['high'] + $sisValue,8);
|
|
$item['close'] = round($item['close'] + $sisValue,8);
|
|
$item['low'] = round($item['low'] + $sisValue,8);
|
|
$item['open'] = round($item['open'] + $sisValue,8);
|
|
|
|
$item['change'] = ($item['close'] - $item['open'])/$item['open']*100;
|
|
|
|
|
|
}
|
|
}
|
|
$item['change'] = round($item['change'],4);
|
|
|
|
|
|
$data_arr[] = [
|
|
"id" => $item['id'],
|
|
"period" => $peroid,
|
|
"base-currency" => strtolower($currency_model->currency_name),
|
|
"quote-currency" => $quote_currency,
|
|
"open" => $item['open'],
|
|
"change" => $item['change'],
|
|
"close" => $item['close'],
|
|
"high" => $item['high'],
|
|
"low" => $item['low'],
|
|
"vol" => $item['vol'],
|
|
'market_from'=>$match->market_from,
|
|
"amount" => $item['amount']
|
|
];
|
|
}
|
|
|
|
|
|
$res = array_reverse($data_arr);
|
|
|
|
}
|
|
|
|
|
|
if($match->market_from == 1){
|
|
|
|
$to = time();
|
|
$from = $to-7200;
|
|
if ($peroid === '1min') {
|
|
$list = MyQuotation::whereBetween('itime', [$from, $to])->where("base",$base_currency)->orderby('id','ASC')->get()->toArray();
|
|
|
|
$res = [];
|
|
foreach ($list as $item) {
|
|
$res[] = [
|
|
"id" => strtotime($item['itime']),
|
|
"period" => $peroid,
|
|
"base-currency" => $base_currency,
|
|
"quote-currency" => $quote_currency,
|
|
"open" => $item['open'],
|
|
"close" => $item['close'],
|
|
"high" => $item['high'],
|
|
"low" => $item['low'],
|
|
"vol" => $item['vol'],
|
|
'market_from'=>$match->market_from,
|
|
"amount" => $item['vol'],
|
|
"time" => strtotime($item['itime']) * 1000
|
|
];
|
|
}
|
|
// $adt2=getConfig("../config/daymarket_".strtolower($base_currency).".php");
|
|
/*
|
|
$adt2= MyQuotation::where('itime','<=', $to)->where("base",$base_currency)->where('period','1min')->orderby('id','DESC')->first();
|
|
|
|
|
|
|
|
|
|
$res[] = [
|
|
"id" => $to,
|
|
"period" => $adt2->period,
|
|
"base-currency" => $adt2->base,
|
|
"quote-currency" => $adt2->target,
|
|
"open" => $adt2->open,
|
|
"close" => $adt2->close,
|
|
"high" => $adt2->high,
|
|
"low" => $adt2->low,
|
|
"vol" => $adt2->vol,
|
|
"amount" =>$adt2->vol,
|
|
"time" => $adt2->itime
|
|
];
|
|
|
|
|
|
unset($res[count($res)]);
|
|
*/
|
|
|
|
|
|
}
|
|
|
|
if($match->market_from == 3) {
|
|
// (in_array($peroid, ['5min', '15min', '30min', '60min', '1day', '1week', '1mon'])) {
|
|
$base_s = 300;
|
|
if ($peroid === '5min') {
|
|
$base_s = 300;
|
|
}
|
|
if ($peroid === '15min') {
|
|
$base_s = 900;
|
|
}
|
|
if ($peroid === '30min') {
|
|
$base_s = 1800;
|
|
}
|
|
if ($peroid === '60min') {
|
|
$base_s = 3600;
|
|
}
|
|
if ($peroid === '1day') {
|
|
$base_s = 86400;
|
|
}
|
|
|
|
if ($peroid === '1week') {
|
|
$base_s = 86400 * 7;
|
|
}
|
|
if ($peroid === '1mon') {
|
|
$base_s = 86400 * 30;
|
|
}
|
|
$diff = 0;
|
|
$nowtime=time();
|
|
if($peroid=='5min' || $peroid=='15min' || $peroid=='30min' || $peroid=='60min'){
|
|
$where=[];
|
|
if($peroid=='5min'){
|
|
$where["period5"]=1;
|
|
|
|
|
|
//$where='period="1min,5min" or period="1min,5min,15min"';
|
|
}
|
|
if($peroid=='15min'){
|
|
$where["period15"]=1;
|
|
}
|
|
if($peroid=='30min'){
|
|
$where["period30"]=1;
|
|
}
|
|
if($peroid=='60min'){
|
|
$where["period60"]=1;
|
|
}
|
|
$list = MyQuotation::whereBetween('itime', [$from + $diff, $to + $diff])->where($where)->where("base",$base_currency)->limit(100)->get()->toArray();
|
|
// echo json_encode($list);
|
|
//$list = MyQuotation::whereBetween('itime', [$from + $diff, $to + $diff])->where("base",$base_currency)->where("period","like","%,".$peroid."%")->get()->toArray();
|
|
}else{
|
|
$list = MyQuotation::whereBetween('itime', [$from + $diff, $to + $diff])->whereRaw('itime % ' . $base_s . '=0')->where("base",$base_currency)->limit(100)->get()->toArray();
|
|
}
|
|
|
|
$res = [];
|
|
$index = 0;
|
|
foreach ($list as $item) {
|
|
//echo $item["itime"].PHP_EOL;// 1617811200 是2021年4月8日0时
|
|
if(strtotime($item["itime"])>1617811200){
|
|
|
|
}
|
|
//var_dump($item);
|
|
$high = MyQuotation::whereBetween('itime', [strtotime($item['itime']) - 1, strtotime($item['itime']) + ($base_s - 59)])->where("base",$base_currency)->max('high');
|
|
$low = MyQuotation::whereBetween('itime', [strtotime($item['itime']) - 1, strtotime($item['itime']) + ($base_s - 59)])->where("base",$base_currency)->min('low');
|
|
$vol = MyQuotation::whereBetween('itime', [strtotime($item['itime']) - 1, strtotime($item['itime']) + ($base_s - 59)])->where("base",$base_currency)->sum('vol');
|
|
|
|
//in_array($peroid, ['5min', '15min', '30min', '60min', '1day', '1week', '1mon'])
|
|
//print_r($item["itime"]);$peroid=="1day"
|
|
if(in_array($peroid, ['1day', '1week', '1mon'])){
|
|
$date=date("Y-m-d",strtotime($item['itime']));
|
|
$start=MyQuotation::where('itime', strtotime($date." 00:00:00"))->where("base",$base_currency)->first(['open']);
|
|
$last = MyQuotation::where('itime', strtotime($date." 23:59:00"))->where("base",$base_currency)->first(['close']);
|
|
}else{
|
|
$last = MyQuotation::where('itime', strtotime($item['itime']) + ($base_s - 60))->where("base",$base_currency)->first(['close']);
|
|
$start = "";
|
|
}
|
|
// echo $item['itime'];
|
|
// print_r($item['close']."比".$last ->close.PHP_EOL);
|
|
$close=$last?$last->close:$item['close'];
|
|
$newopen=$start?$start->open:$item['open'];
|
|
|
|
$res[] = [
|
|
"id" => strtotime($item['itime']) - $diff,
|
|
"period" => $peroid,
|
|
"base-currency" => $base_currency,
|
|
"quote-currency" => $quote_currency,
|
|
"open" => $newopen,
|
|
"close" => $close,
|
|
"high" => $high,
|
|
"low" => $low,
|
|
"vol" => $vol,
|
|
'market_from'=>$match->market_from,
|
|
"amount" => $vol,
|
|
"time" => (strtotime($item['itime']) - $diff) * 1000
|
|
];
|
|
|
|
/*$res[] = [
|
|
"id" => strtotime($item['itime']) - $diff,
|
|
"period" => $item['itime'],
|
|
"base-currency" => $base_currency,
|
|
"quote-currency" => $quote_currency,
|
|
"open" => $item['open'],
|
|
"close" => $item['close'],
|
|
"high" => $item['high'],
|
|
"low" => $item['low'],
|
|
"vol" =>$item['vol'],
|
|
"amount" =>$item['vol'],
|
|
"time" => (strtotime($item['itime']) - $diff) * 1000
|
|
];*/
|
|
$index++;
|
|
|
|
//
|
|
}
|
|
}
|
|
|
|
return $res;
|
|
}
|
|
|
|
|
|
return $res;
|
|
|
|
|
|
}
|
|
|
|
public static function batchEsearchMarket($base_currency, $quote_currency, $price, $time)
|
|
{
|
|
if ($price > 6600) echo json_encode([$base_currency, $quote_currency, $price]);
|
|
$currency = Currency::where('name', $base_currency)->first();
|
|
$legal = Currency::where('name', $quote_currency)->first();
|
|
$currency_match = CurrencyMatch::where('currency_id', $currency->id)
|
|
->where('legal_id', $legal->id)
|
|
->first();
|
|
$types = [
|
|
'1min' => 5,
|
|
'5min' => 6,
|
|
'15min' => 1,
|
|
'30min' => 7,
|
|
'60min' => 2,
|
|
'1day' => 4,
|
|
'1mon' => 9,
|
|
'1week' => 8,
|
|
'1year' => 10,
|
|
];
|
|
$periods = ['1min', '5min', '15min', '30min', '60min', '1day', '1mon', '1week', '1year'];
|
|
foreach ($periods as $key => $period) {
|
|
$type = $types[$period];
|
|
$convert_time = self::formatTimeline($type, $time);
|
|
$result = self::getEsearchMarketById($base_currency, $quote_currency, $period, $convert_time);
|
|
if (isset($result['_source'])) {
|
|
$data = $result['_source'];
|
|
$data['close'] = $price; //更新下最新价格
|
|
bc_comp($data['high'], $price) < 0 && $data['high'] = $price; //更新最高价
|
|
bc_comp($data['low'], $price) > 0 && $data['low'] = $price; //更新最低价
|
|
|
|
// unset($data['vol'], $data['amount']); //不影响成交数量
|
|
|
|
// self::setEsearchMarket($data);
|
|
} else {
|
|
//dd($result);
|
|
//拿不到数据,可能是还没有也有可能是程序错误,为了保险建议不处理
|
|
$data = [
|
|
'id' => $convert_time,
|
|
'period' => $period,
|
|
'base-currency' => $base_currency,
|
|
'quote-currency' => $quote_currency,
|
|
'open' => $price,
|
|
'close' => $price,
|
|
'high' => $price,
|
|
'low' => $price,
|
|
'vol' => 0,
|
|
'amount' => 0,
|
|
];
|
|
//self::setEsearchMarket($data);
|
|
}
|
|
//dump($data);
|
|
if ($period == '1min') {
|
|
|
|
$sisValue =$currency->oncontact;
|
|
if($sisValue>0){
|
|
$data['high'] = round($data['high'] + $sisValue,8);
|
|
$data['close'] = round($data['close'] + $sisValue,8);
|
|
$data['low'] = $data['low'] + $sisValue;
|
|
|
|
}
|
|
|
|
|
|
$kline_data = [
|
|
'type' => 'kline',
|
|
'period' => '1min',
|
|
'match_id' => $currency_match->id,
|
|
'currency_id' => $currency->id,
|
|
'currency_name' => $base_currency,
|
|
'legal_id' => $legal->id,
|
|
'legal_name' => $quote_currency,
|
|
'open' => $data['open'],
|
|
'close' => $data['close'],
|
|
'high' => $data['high'],
|
|
'low' => $data['low'],
|
|
'symbol' => $currency_match->currency_name . '/' . $currency_match->legal_name,
|
|
'volume' => $data['amount'] ?? 0,
|
|
'time' => $convert_time * 1000,
|
|
'market_form' => 'risk',
|
|
];
|
|
if ($kline_data['close'] > 6600) {
|
|
// var_dump($data);
|
|
// var_dump($kline_data);
|
|
}
|
|
}
|
|
SendMarket::dispatch($kline_data)->onQueue('kline.1min');
|
|
// self::setEsearchMarket($data);
|
|
}
|
|
}
|
|
|
|
public static function getLastEsearchMarket($base_currency, $quote_currency, $peroid = '1min')
|
|
{
|
|
$es_client = self::getEsearchClient();
|
|
$params = [
|
|
'index' => 'market.kline',
|
|
'type' => 'doc',
|
|
'body' => [
|
|
'query' => [
|
|
'bool' => [
|
|
'must' => [
|
|
['match' => ['period' => $peroid]],
|
|
['match' => ['base-currency' => $base_currency]],
|
|
['match' => ['quote-currency' => $quote_currency]],
|
|
],
|
|
],
|
|
],
|
|
'sort' => [
|
|
'id' => [
|
|
'order' => 'desc',
|
|
],
|
|
],
|
|
'size' => 1,
|
|
],
|
|
];
|
|
$result = $es_client->search($params);
|
|
if (isset($result['hits'])) {
|
|
$data = array_column($result['hits']['hits'], '_source');
|
|
$data = reset($data);
|
|
} else {
|
|
$data = [];
|
|
}
|
|
return $data;
|
|
}
|
|
}
|