107 lines
4.1 KiB
PHP
107 lines
4.1 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\AccountLog;
|
|
use App\UsersWallet;
|
|
use App\Setting;
|
|
use App\Utils\RPC;
|
|
use App\Currency;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\DB;
|
|
class CollectToken extends Command
|
|
{
|
|
protected $signature = "collect_token{currency_id : id}";
|
|
protected $description = "收集代币";
|
|
protected $contract_address = "";
|
|
protected $total_account_address = "";
|
|
protected $total_account_key = "";
|
|
protected $currency_type = "";
|
|
protected $decimal_scale = 18;
|
|
public function handle()
|
|
{
|
|
$currency_id = $this->argument('currency_id');
|
|
$currency = Currency::find($currency_id);
|
|
$contract_address = $currency->contract_address;
|
|
$total_account_address = $currency->total_account;
|
|
$total_account_key = $currency->key;
|
|
$currency_type = $currency->type;
|
|
$this->decimal_scale = $currency->decimal_scale;
|
|
if (empty($contract_address) || empty($total_account_address) || empty($total_account_key)) {
|
|
$this->comment("后台账号设置错误");
|
|
exit;
|
|
}
|
|
$this->contract_address = $contract_address;
|
|
if ($currency_type == 'erc20') {
|
|
$this->total_account_address = substr($total_account_address, 2);
|
|
} else {
|
|
$this->total_account_address = $total_account_address;
|
|
}
|
|
$this->total_account_key = $total_account_key;
|
|
$this->currency_type = $currency_type;
|
|
$datas = UsersWallet::where('currency', $currency_id)->get();
|
|
$this->comment("start");
|
|
foreach ($datas as $d) {
|
|
$this->collectToken($d);
|
|
}
|
|
$this->comment("end");
|
|
}
|
|
public function collectToken($data)
|
|
{
|
|
if ($this->currency_type == 'btc') {
|
|
return false;
|
|
}
|
|
if (empty($data->address)) {
|
|
return false;
|
|
}
|
|
$address = $data->address;
|
|
if ($this->currency_type == 'eth') {
|
|
$url = "https://api.etherscan.io/api?module=account&action=balance&address=" . $address . "&tag=latest&apikey=579R8XPDUY1SHZNEZP9GA4FEF1URNC3X45" . rand(1, 10000);
|
|
} else {
|
|
$url = "https://api.etherscan.io/api?module=account&action=tokenbalance&contractaddress=" . $this->contract_address . "&address=" . $address . "&tag=latest&apikey=579R8XPDUY1SHZNEZP9GA4FEF1URNC3X45" . rand(1, 1000);
|
|
}
|
|
$content = RPC::apihttp($url);
|
|
if (!$content) {
|
|
return false;
|
|
}
|
|
DB::beginTransaction();
|
|
try {
|
|
$content = json_decode($content, true);
|
|
if (isset($content["message"]) && $content["message"] == "OK") {
|
|
$lessen = bc_pow(10, $this->decimal_scale);
|
|
$chain_balance = bc_div($content["result"], $lessen);
|
|
if ($chain_balance > 0) {
|
|
if ($this->currency_type == 'eth') {
|
|
$content["result"] = $content["result"] / 1000000000000000000;
|
|
$content['result'] -= 0.001;
|
|
$address_url = 'http://47.92.171.137:8999/web3/transfer?toaddress=' . $this->total_account_address . '&from_address=' . $address . '&transfer_value=' . $content["result"] . '&privates=' . decrypt($data->private);
|
|
} else {
|
|
$address_url = "http://47.92.171.137:8999/web3/transfer/oec?is_new=1&toaddress=" . $this->total_account_address . "&transfer_value=" . $content["result"] . "&contract_address=" . $this->contract_address . "&fromeaddress=" . $address . "&privates=" . decrypt($data->private) . '&decimal_scale=' . $this->decimal_scale;
|
|
}
|
|
$lian = RPC::apihttp($address_url);
|
|
$lian = @json_decode($lian, true);
|
|
if ($lian["error"] == "0") {
|
|
$data->old_balance = 0;
|
|
$data->save();
|
|
AccountLog::insertLog(array("user_id" => 99999, "value" => $content["result"], "type" => AccountLog::ETH_EXCHANGE, "info" => $data->user_id . "归拢", 'currency' => $data->currency));
|
|
$this->comment($this->total_account_address . "user_id:" . $lian["content"]);
|
|
} else {
|
|
$this->comment('请求地址：');
|
|
dump($address_url);
|
|
$this->comment('请求响应：');
|
|
dump($lian);
|
|
$this->comment("请重试" . $lian["error"]);
|
|
}
|
|
} else {
|
|
$this->comment($content["result"]);
|
|
}
|
|
} else {
|
|
$this->comment($content);
|
|
}
|
|
DB::commit();
|
|
} catch (\Exception $ex) {
|
|
DB::rollback();
|
|
$this->comment($ex->getMessage());
|
|
}
|
|
}
|
|
} |