59 lines
1.8 KiB
PHP
59 lines
1.8 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Market;
|
|
use App\Utils\RPC;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Log;
|
|
class GetMarket extends Command
|
|
{
|
|
protected $signature = "get_market";
|
|
protected $description = "获取行情";
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
public function handle()
|
|
{
|
|
$opts = ["http" => ["method" => "GET", "header" => "Accepts: application/json\r\n" . "X-CMC_PRO_API_KEY: 8c89b9cf-8fcb-4f2a-bac1-c93295b72074\r\n"]];
|
|
$context = stream_context_create($opts);
|
|
$file = file_get_contents('https://pro-api.coinmarketcap.com/v1/cryptocurrency/quotes/latest?id=1,2', false, $context);
|
|
$coin_list = json_decode($file, true);
|
|
DB::beginTransaction();
|
|
try {
|
|
if (!empty($coin_list['data'])) {
|
|
foreach ($coin_list['data'] as $row) {
|
|
$market = Market::find($row['id']);
|
|
if (empty($market)) {
|
|
$market = new Market();
|
|
}
|
|
$market->id = $row['id'];
|
|
$market->name = $row['name'];
|
|
$market->symbol = $row['symbol'];
|
|
$market->rank = $row['cmc_rank'];
|
|
$market->circulating_supply = $row['circulating_supply'];
|
|
$market->total_supply = $row['total_supply'];
|
|
$market->max_supply = $row['max_supply'];
|
|
$market->quotes = serialize($row['quote']);
|
|
$market->last_updated = $row['last_updated'];
|
|
$market->save();
|
|
}
|
|
DB::commit();
|
|
echo 111;
|
|
$message = '请求接口成功，并更新数据库->' . date('Y-m-d H:i:s');
|
|
$this->info($message);
|
|
} else {
|
|
echo 222;
|
|
$message = '请求数据接口失败，无数据->' . date('Y-m-d H:i:s');
|
|
$this->info($message);
|
|
}
|
|
} catch (\Exception $exception) {
|
|
DB::rollback();
|
|
echo 333;
|
|
$message = $exception->getMessage() . '->' . date('Y-m-d H:i:s');
|
|
$this->info($message);
|
|
}
|
|
}
|
|
} |