<?php

namespace App\Console\Commands;

use App\Currency;
use App\UserChat;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
defined('ACCOUNT_ID') || define('ACCOUNT_ID', '50154012');
defined('ACCESS_KEY') || define('ACCESS_KEY', 'c96392eb-b7c57373-f646c2ef-25a14');
defined('SECRET_KEY') || define('SECRET_KEY', '');
class GetKline extends Command
{
	protected $signature = "get_kline_data";
	protected $description = "获取K线图数据";
	private $url = "https://api.huobi.br.com";
	private $api = "";
	public $api_method = "";
	public $req_method = "";
	public function __construct()
	{
		parent::__construct();
	}
	public function handle()
	{
		while (true) {
			try {
				echo "开始推送\r\n";
				$all = DB::table('currency')->where('is_display', '1')->get();
				$all_arr = $this->object2array($all);
				$legal = DB::table('currency')->where('is_display', '1')->where('is_legal', '1')->get();
				$legal_arr = $this->object2array($legal);
				$ar = [];
				foreach ($legal_arr as $legal) {
					foreach ($all_arr as $item) {
						if ($legal['id'] != $item['id']) {
							echo "begin2";
							$ar_a = [];
							$ar_a['name'] = strtolower($item['name']) . strtolower($legal['name']);
							$ar_a['currency_id'] = $item['id'];
							$ar_a['legal_id'] = $legal['id'];
							$ar[] = $ar_a;
						}
					}
				}
				echo "开始遍历币种\r\n";
				foreach ($ar as $vv) {
					if (in_array($vv["name"], array("shibusdt", "goldusdt", "uncusdt", "grtcusdt", "tonusdt"))) {
						$ar_new[] = $vv;
					}
				}
			//	file_put_contents("ar_new.txt", json_encode($ar_new) . PHP_EOL, FILE_APPEND);
				foreach ($ar_new as $it) {
					echo "遍历币种开始\r\n";
					$data = array();
					echo "开始请求\r\n";
					$data = $this->get_history_kline($it['name'], '1min', 1);
					if ($data) {
					} else {
					   // file_put_contents("test1.txt",  $it['name']. PHP_EOL, FILE_APPEND);
						echo "重新采集\r\n";
						continue 2;
					}
					echo "请求结束\r\n";
					if ($data['status'] != 'ok') {
						echo "begin6";
						$this->error('请求失败');
						continue 2;
					}
					$info = $data['data'][0];
					$insert_instance = DB::table('market_hour')->where('currency_id', $it['currency_id'])->where('legal_id', $it['legal_id'])->where('day_time', '=', $info['id'])->where('type', 5)->where('period', '1min')->where('sign', 2)->first();
					if ($insert_instance) {
						echo "begin7";
						$this->error('指定时间行情已存在,直接跳过');
						continue 2;
					}
					$insert_Data = array();
					$insert_Data['currency_id'] = $it['currency_id'];
					$insert_Data['legal_id'] = $it['legal_id'];
					$insert_Data['start_price'] = $this->sctonum($info['open']);
					$insert_Data['end_price'] = $this->sctonum($info['close']);
					$insert_Data['mminimum'] = $this->sctonum($info['low']);
					$insert_Data['highest'] = $this->sctonum($info['high']);
					$insert_Data['type'] = 5;
					$insert_Data['sign'] = 2;
					$insert_Data['day_time'] = $info['id'];
					$insert_Data['period'] = '1min';
					$insert_Data['number'] = bcmul($info['amount'], 1, 5);
					$insert_Data['mar_id'] = $info['id'];
					DB::table('market_hour')->insert($insert_Data);
					$update_Data = [];
					$update_Data['currency_id'] = $it['currency_id'];
					$update_Data['legal_id'] = $it['legal_id'];
					$update_Data['now_price'] = $this->sctonum($info['close']);
					$update_Data['add_time'] = time();
					$update_Data['volume'] = '0.00000';
					$update_Data['change'] = '+0.00';
					$time = strtotime(date("Y-m-d"));
					$day_Data = DB::table('market_hour')->where('currency_id', $it['currency_id'])->where('legal_id', $it['legal_id'])->where('period', '1day')->where('sign', 2)->where('day_time', '<=', $time)->where('end_price', '>', '0.00000')->orderby('id', 'DESC')->first();
					if (!empty($day_Data)) {
						$_zero_price = $day_Data->end_price;
					} else {
						$_zero_price = 0;
					}
					$update_Data['volume'] = DB::table('market_hour')->where('day_time', '>', $time)->where('currency_id', $it['currency_id'])->where('legal_id', $it['legal_id'])->where('period', '1min')->where('sign', 2)->sum('number');
					switch (bccomp($update_Data['now_price'], $_zero_price, 5)) {
						case 1:
							if ($_zero_price === 0) {
								$update_Data['change'] = '+0.000';
							} else {
								$a = bcsub($update_Data['now_price'], $_zero_price, 5);
								$_pencet_num = bcdiv($a, $_zero_price, 5);
								$update_Data['change'] = '+' . bcmul($_pencet_num, 100, 3);
							}
							break 3;
						case 0:
							$update_Data['change'] = '+0.000';
							break 3;
						case -1:
							if ($_zero_price === 0) {
								$update_Data['change'] = '+0.000';
							} else {
								$a = bcsub($_zero_price, $update_Data['now_price'], 5);
								$_pencet_num = bcdiv($a, $_zero_price, 5);
								$update_Data['change'] = '-' . bcmul($_pencet_num, 100, 3);
							}
							break 3;
						default:
							$update_Data['change'] = '+0.000';
					}
					$que_data = DB::table('currency_quotation')->where('currency_id', $it['currency_id'])->where('legal_id', $it['legal_id'])->orderby('id', 'DESC')->first();
					if (!empty($que_data)) {
						DB::table('currency_quotation')->where('id', $que_data->id)->update($update_Data);
					} else {
						DB::table('currency_quotation')->insert($update_Data);
					}
					$currency = Currency::find($it['currency_id']);
					$legal = Currency::find($it['legal_id']);
					$update_Data['currency_name'] = $currency->name;
					$update_Data['legal_name'] = $legal->name;
					$update_Data['type'] = 'daymarket';
					$update_Data['high'] = $insert_Data['highest'];
					$update_Data['low'] = $this->sctonum($info['low']);
					$update_Data['symbol'] = $currency->name . '/' . $legal->name;
					echo "begin8";
					$new_data = ['type' => 'kline', 'period' => $insert_Data['period'], 'currency_id' => $insert_Data['currency_id'], 'currency_name' => $currency->name, 'legal_id' => $insert_Data['legal_id'], 'legal_name' => $legal->name, 'symbol' => $currency->name . '/' . $legal->name, 'open' => $insert_Data['start_price'], 'close' => $insert_Data['end_price'], 'high' => $insert_Data['highest'], 'low' => $insert_Data['mminimum'], 'volume' => $insert_Data['number'], 'time' => $insert_Data['day_time'] * 1000];
					echo "开始推送\r\n";
					print_r($update_Data);
					UserChat::sendChat($update_Data);
					UserChat::sendChat($new_data);
					unset($currency);
					unset($legal);
					echo "遍历币种结束\r\n";
				}
				sleep(5);
			} catch (Exception $e) {
			}
		}
	}
	public function object2array($obj)
	{
		return json_decode(json_encode($obj), true);
	}
	public function sctonum($num, $double = 8)
	{
		if (false !== stripos($num, "e")) {
			$a = explode("e", strtolower($num));
			return bcmul($a[0], bcpow(10, $a[1], $double), $double);
		} else {
			return $num;
		}
	}
	public function get_history_kline($symbol = '', $period = '', $size = 0)
	{
		echo "获取K线数据\r\n";
		$this->api_method = "/market/history/kline";
		$this->req_method = 'GET';
		$param = ['symbol' => $symbol, 'period' => $period];
		if ($size) {
			$param['size'] = $size;
		}
		$url = $this->create_sign_url($param);
		file_put_contents("log.txt", $url . PHP_EOL, FILE_APPEND);
		echo "获取K线数据结束\r\n";
		return json_decode($this->curl($url), true);
	}
	public function create_sign_url($append_param = [])
	{
		$param = ['AccessKeyId' => ACCESS_KEY, 'SignatureMethod' => 'HmacSHA256', 'SignatureVersion' => 2, 'Timestamp' => date('Y-m-d\\TH:i:s', time())];
		if ($append_param) {
			foreach ($append_param as $k => $ap) {
				$param[$k] = $ap;
			}
		}
		return $this->url . $this->api_method . '?' . $this->bind_param($param);
	}
	public function bind_param($param)
	{
		$u = [];
		$sort_rank = [];
		foreach ($param as $k => $v) {
			$u[] = $k . "=" . urlencode($v);
			$sort_rank[] = ord($k);
		}
		asort($u);
		$u[] = "Signature=" . urlencode($this->create_sig($u));
		return implode('&', $u);
	}
	public function create_sig($param)
	{
		$sign_param_1 = $this->req_method . "\r\n" . $this->api . "\r\n" . $this->api_method . "\r\n" . implode('&', $param);
		$signature = hash_hmac('sha256', $sign_param_1, SECRET_KEY, true);
		return base64_encode($signature);
	}
	public function curl($url, $postdata = [])
	{
		echo "curl开始\r\n";
		$start = microtime(true);
		$ch = curl_init();
		curl_setopt($ch, CURLOPT_URL, $url);
		if ($this->req_method == 'POST') {
			curl_setopt($ch, CURLOPT_POST, 1);
			curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($postdata));
		}
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
		curl_setopt($ch, CURLOPT_HEADER, 0);
		curl_setopt($ch, CURLOPT_TIMEOUT, 4);
		curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
		curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
		curl_setopt($ch, CURLOPT_HTTPHEADER, ["Content-Type: application/json"]);
		curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_0);
		$output = curl_exec($ch);
		$info = curl_getinfo($ch);
		curl_close($ch);
		if (empty($output)) {
			echo "curl没有采集到\r\n";
		}
		echo "curl结束\r\n";
		$end = microtime(true);
		file_put_contents("haoshi.txt", $end - $start . PHP_EOL, FILE_APPEND);
		return $output;
	}
}