475 lines
20 KiB
PHP
475 lines
20 KiB
PHP
<?php
|
|
|
|
namespace App\DAO;
|
|
|
|
use Illuminate\Support\Facades\DB;
|
|
use Illuminate\Support\Facades\Cache;
|
|
use Illuminate\Support\Carbon;
|
|
use GuzzleHttp\Client;
|
|
use App\AccountLog;
|
|
use App\Currency;
|
|
use App\ChainHash;
|
|
use App\LbxHash;
|
|
use App\UsersWallet;
|
|
use App\Jobs\UpdateBalance;
|
|
class BlockChain
|
|
{
|
|
|
|
public static function getChainBalance($wallet, $chain_currency = '')
|
|
{
|
|
try {
|
|
throw_unless($wallet, new \Exception('钱包不存在'));
|
|
throw_if(empty($wallet->address), new \Exception('钱包地址不存在'));
|
|
$currency = Currency::find($wallet->currency);
|
|
throw_unless($currency, new \Exception('币种不存在'));
|
|
$address = $wallet->address;
|
|
$method = 'GET';
|
|
$chain_currency == '' && $chain_currency = $currency->type;
|
|
switch ($chain_currency) {
|
|
case 'eth':
|
|
$uri = '/wallet/eth/balance';
|
|
$params = [
|
|
'query' => [
|
|
'address' => $address,
|
|
]
|
|
];
|
|
break;
|
|
case 'erc20':
|
|
$uri = '/wallet/eth/tokenbalance';
|
|
$params = [
|
|
'query' => [
|
|
'address' => $address,
|
|
'tokenaddress' => $currency->contract_address,
|
|
]
|
|
];
|
|
break;
|
|
case 'btc':
|
|
$uri = '/wallet/btc/balance';
|
|
$params = [
|
|
'query' => [
|
|
'address' => $address,
|
|
]
|
|
];
|
|
break;
|
|
case 'usdt':
|
|
$uri = '/wallet/usdt/balance';
|
|
$params = [
|
|
'query' => [
|
|
'address' => $address,
|
|
]
|
|
];
|
|
break;
|
|
default:
|
|
throw new \Exception('不支持的数字货币');
|
|
break;
|
|
}
|
|
$http_client = app('LbxChainServer');
|
|
$response = $http_client->request($method, $uri, $params);
|
|
$result = $response->getBody()->getContents();
|
|
$result = json_decode($result, true);
|
|
//echo $uri;
|
|
//var_dump($params);
|
|
//var_dump($result);
|
|
if (!isset($result['code']) || !isset($result['data'])) {
|
|
throw new \Exception('请求接口发生错误');
|
|
}
|
|
if ($result['code'] != 0) {
|
|
throw new \Exception($result['msg'] ?? $result['errorinfo']);
|
|
}
|
|
$balance_data = $result['data'];
|
|
$chain_balance = $balance_data['balance'];
|
|
$lessen = bc_pow(10, $currency->decimal_scale);
|
|
$fact_chain_balance = bc_div($chain_balance, $lessen);
|
|
return $fact_chain_balance;
|
|
} catch (\Throwable $th) {
|
|
throw $th;
|
|
}
|
|
}
|
|
|
|
public static function updateWalletBalance($wallet, $no_balance_continue = false)
|
|
{
|
|
try {
|
|
$fact_chain_balance = self::getChainBalance($wallet);
|
|
try {
|
|
DB::beginTransaction();
|
|
|
|
$wallet->refresh();
|
|
//比较现链上余额是否比原链上余额要大
|
|
$compare_result = bc_comp($fact_chain_balance, $wallet->old_balance);
|
|
if ($compare_result > 0) {
|
|
$diff_balance = bc_sub($fact_chain_balance, $wallet->old_balance);
|
|
$wallet->old_balance = $fact_chain_balance; //更新链上余额
|
|
$save_result = $wallet->save();
|
|
if (!$save_result) {
|
|
throw new \Exception('更新链上余额失败');
|
|
}
|
|
$change_result = change_wallet_balance($wallet, 4, $diff_balance, AccountLog::ETH_EXCHANGE, '链上充币增加');
|
|
if ($change_result !== true) {
|
|
throw new \Exception($change_result);
|
|
}
|
|
} elseif ($compare_result == 0) {
|
|
// throw new \Exception(
|
|
// '用户id:' . $wallet->user_id . ',币种:' . $wallet->currencyCoin->name
|
|
// . '(' . $wallet->currencyCoin->type . '):链上余额无增加'
|
|
// );
|
|
if ($no_balance_continue) {
|
|
UpdateBalance::dispatch($wallet, false)
|
|
->onQueue('update:block:balance')
|
|
->delay(Carbon::now()->addMinutes(5));
|
|
}
|
|
} else {
|
|
|
|
if ($no_balance_continue) {
|
|
UpdateBalance::dispatch($wallet, false)
|
|
->onQueue('update:block:balance')
|
|
->delay(Carbon::now()->addMinutes(5));
|
|
}
|
|
throw new \Exception(
|
|
'用户id:' . $wallet->user_id . ',币种:' . $wallet->currencyCoin->name
|
|
. '(' . $wallet->currencyCoin->type . '):链上余额小于系统链上余额'
|
|
);
|
|
}
|
|
DB::commit();
|
|
} catch (\Exception $ex) {
|
|
DB::rollBack();
|
|
throw $ex;
|
|
}
|
|
return true;
|
|
} catch (\Throwable $th) {
|
|
throw $th;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 链上转账
|
|
*
|
|
* @param string $currency_name 钱包本身对应的币种名称
|
|
* @param string $chain_currency 要转的链上币种类型,例如用usdt的钱包地址不仅可以转USDT还可以转BTC,用erc20的钱包地址不仅可以转ERC20代币还可以转ETH
|
|
* @param string $to_address 转入地址
|
|
* @param float $transfer_qty 转账数量
|
|
* @param string $from_address 转出地址
|
|
* @param string $from_private_key 转出私钥
|
|
* @param integer $type 转账类型 1 归拢，2 打入手续费，3 提币
|
|
* @param float $fee 链上手续费
|
|
* @param string $verificationcode 验证码
|
|
* @return string
|
|
* @throws \Exception
|
|
*/
|
|
public static function transfer($currency_name, $chain_currency, $to_address, $transfer_qty, $from_address, $from_private_key, $type, $fee = 0, $verificationcode = '')
|
|
{
|
|
try {
|
|
$currency = Currency::where('name', $currency_name)->first();
|
|
$chain_currency = Currency::where('name', $chain_currency)->first();
|
|
if (!$currency) {
|
|
throw new \Exception('货币不存在');
|
|
}
|
|
if (!in_array($currency->type, ['eth', 'erc20', 'usdt', 'btc'])) {
|
|
throw new \Exception('货币类型不支持');
|
|
}
|
|
if (
|
|
empty($to_address)
|
|
|| empty($transfer_qty)
|
|
|| bc_comp($transfer_qty, 0) <= 0
|
|
|| empty($from_address)
|
|
|| empty($from_private_key)
|
|
) {
|
|
throw new \Exception('参数不完整或不合法');
|
|
}
|
|
$origin_transfer_qty = $transfer_qty;
|
|
$decimal_scale = $chain_currency->decimal_scale ?? 0; //调整为按链上通道的小数位数，解决代币和主链小数位数不一致的问题
|
|
$lessen = bc_pow(10, $decimal_scale);
|
|
$transfer_qty = bc_mul($transfer_qty, $lessen, 0); //转账数量转换为区块链上的单位
|
|
$fee = bc_mul($currency->chain_fee, $lessen, 0); //手续费转换为区域链上的单位
|
|
$http_client = app('LbxChainServer');
|
|
$method = 'POST';
|
|
$result = [];
|
|
$params = [
|
|
'multipart' => [
|
|
[
|
|
'name' => 'type',
|
|
'contents' => $type,
|
|
],
|
|
[
|
|
'name' => 'fromaddress',
|
|
'contents' => $from_address,
|
|
],
|
|
[
|
|
'name' => 'privkey',
|
|
'contents' => $from_private_key,
|
|
],
|
|
[
|
|
'name' => 'toaddress',
|
|
'contents' => $to_address,
|
|
],
|
|
[
|
|
'name' => 'amount',
|
|
'contents' => $transfer_qty,
|
|
],
|
|
[
|
|
'name' => 'tokenaddress',
|
|
'contents' => $currency->contract_address ?? '',
|
|
],
|
|
[
|
|
'name' => 'fee',
|
|
'contents' => $fee,
|
|
],
|
|
[
|
|
'name' => 'verificationcode',
|
|
'contents' => $verificationcode,
|
|
],
|
|
]
|
|
];
|
|
switch ($chain_currency->type) {
|
|
case 'erc20':
|
|
$uri = '/v3/wallet/eth/tokensendto';
|
|
break;
|
|
case 'eth':
|
|
$uri = '/v3/wallet/eth/sendto';
|
|
break;
|
|
case 'btc':
|
|
$uri = '/v3/wallet/btc/sendto';
|
|
break;
|
|
case 'usdt':
|
|
$uri = '/v3/wallet/usdt/sendto';
|
|
break;
|
|
default:
|
|
throw new \Exception('暂不支持' . $chain_currency->type . '币种');
|
|
break;
|
|
}
|
|
|
|
$response = $http_client->request($method, $uri, $params);
|
|
$result = json_decode($response->getBody()->getContents(), true);
|
|
isset($result['txid']) || $result['txid'] = $result['data']['txHex'] ?? ($result['data']['txid'] ?? '');
|
|
if (isset($result['code']) && $result['code'] == 0) {
|
|
$chain_hash = [
|
|
'code' => strtoupper($currency->type),
|
|
'txid' => $result['txid'],
|
|
'amount' => $origin_transfer_qty,
|
|
'sender' => $from_address,
|
|
'recipient' => $to_address,
|
|
];
|
|
ChainHash::unguarded(function () use ($chain_hash) {
|
|
return ChainHash::create($chain_hash);
|
|
});
|
|
} else {
|
|
throw new \Exception($result['msg'] ?? var_export($result, true));
|
|
}
|
|
//dump($params);
|
|
return $result;
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 打入手续费
|
|
*
|
|
* @param UsersWallet $wallet
|
|
* @param boolean $refresh_balance
|
|
* @return void
|
|
*/
|
|
public static function transferPoundage(UsersWallet $wallet, $refresh_balance = false)
|
|
{
|
|
try {
|
|
//检测当前是否已有手续费打入的交易hash
|
|
//是否先刷新链上余额
|
|
if ($refresh_balance) {
|
|
$wallet->refresh();
|
|
self::updateWalletBalance($wallet);
|
|
}
|
|
$wallet->refresh();
|
|
if (bc_comp($wallet->old_balance, 0) <= 0) {
|
|
throw new \Exception('用户链上余额为0,无须打入手续费');
|
|
}
|
|
$fee_currency = $currency = $wallet->currencyCoin;
|
|
$currency_type = $currency->type;
|
|
$fee_name = '';
|
|
if ($currency_type == 'eth' || $currency_type == 'btc' || $currency_type == 'eos' || $currency_type == 'xrp') {
|
|
throw new \Exception($wallet->currencyCoin->name . '币种无需额外打入归拢手续费');
|
|
} elseif ($currency_type == 'erc20') {
|
|
//从总账号往钱包打入eth
|
|
$transfer_qty = $fee_currency->chain_fee;
|
|
$from_address = $fee_currency->total_account;
|
|
$from_private_key = $fee_currency->origin_key;
|
|
$fee_name = 'eth';
|
|
} elseif ($currency_type == 'usdt') {
|
|
//从总账号往钱包打入btc
|
|
$transfer_qty = bc_add($fee_currency->chain_fee, '0.00000546');
|
|
$from_address = $fee_currency->total_account;
|
|
$from_private_key = $fee_currency->origin_key;
|
|
$fee_name = 'btc';
|
|
} else {
|
|
throw new \Exception('不支持的数字货币');
|
|
}
|
|
if (empty($from_address) || empty($from_private_key)) {
|
|
throw new \Exception($fee_name . '币种总账号信息未设置');
|
|
}
|
|
$fee_balance = self::getChainBalance($wallet, $fee_name);
|
|
//当链上手续费余额大于需要转入的手续费时,提示无须再打入手续费
|
|
if (bc_comp($fee_balance, $transfer_qty) >= 0) {
|
|
throw new \Exception('钱包内' . $fee_name . '余额充足,无须打入');
|
|
} else {
|
|
//当有余额时看相差多少,只打入相差的部分
|
|
$transfer_qty = bc_sub($transfer_qty, bc_comp($fee_balance, 0) >= 0 ? $fee_balance : 0);
|
|
}
|
|
|
|
$params = [
|
|
'currency_type' => $currency_type,
|
|
'fee_name' => $fee_name,
|
|
'to_address' => $wallet->address,
|
|
'transfer_qty' => $transfer_qty,
|
|
'from_address' => $from_address,
|
|
'from_private_key' => $from_private_key,
|
|
'type' => 2,
|
|
];
|
|
$query_str = md5(http_build_query($params));
|
|
if (Cache::has($query_str)) {
|
|
throw new \Exception('当前链上已有手续费交易正在确认,请勿重复打入手续费!交易哈希:' . Cache::get($query_str));
|
|
}
|
|
|
|
// 从当日哈希表中检测是否已有未确认的打入手续费的交易
|
|
$fee_transaction = LbxHash::where('wallet_id', $wallet->id)
|
|
->where('created_at', '>=', Carbon::today())
|
|
->where('type', 2)
|
|
->where('status', 0)
|
|
->first();
|
|
if ($fee_transaction) {
|
|
throw new \Exception('当前链上已有手续费交易正在确认,请勿重复打入手续费!交易哈希:' . $fee_transaction->txid);
|
|
}
|
|
|
|
DB::beginTransaction();
|
|
$result = self::transfer($currency_type, $fee_name, $wallet->address, $transfer_qty, $from_address, $from_private_key, 2);
|
|
if ($result['code'] == 0) {
|
|
Cache::put($query_str, $result['txid'], 20);
|
|
//记录链上哈希信息
|
|
$lbx_hash_data = [
|
|
'wallet_id' => $wallet->id,
|
|
'txid' => $result['txid'],
|
|
'type' => 2, //打入手续费
|
|
'amount' => $transfer_qty,
|
|
'status' => 0,
|
|
];
|
|
LbxHash::unguarded(function () use ($lbx_hash_data) {
|
|
return LbxHash::create($lbx_hash_data);
|
|
});
|
|
}
|
|
DB::commit();
|
|
return $result;
|
|
} catch (\Exception $e) {
|
|
DB::rollBack();
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 钱包链上余额归拢到总账号
|
|
*
|
|
* @param \App\UsersWallet $wallet 要归拢的钱包
|
|
* @param bool $refresh_balance 是否从链上刷新余额
|
|
* @return string
|
|
* @throws \Exception
|
|
*/
|
|
public static function collect(UsersWallet $wallet, $refresh_balance = false)
|
|
{
|
|
$currency = $wallet->currencyCoin;
|
|
if (!$currency) {
|
|
throw new \Exception('对应币种不存在');
|
|
}
|
|
$from_address = $wallet->address;
|
|
$from_private_key = $wallet->private;
|
|
|
|
//$to_address = $currency->total_account;
|
|
$to_address = $currency->collect_account;
|
|
$contract_address = $currency->contract_address;
|
|
$currency_type = $currency->type;
|
|
if (empty($to_address)) {
|
|
throw new \Exception('归拢地址未设置');
|
|
}
|
|
if ($currency_type == 'erc20' && empty($contract_address)) {
|
|
throw new \Exception('合约地址未设置');
|
|
}
|
|
// 根据币种手续费计算
|
|
$base_transfer_use_qty = 0; //除手续费消耗主链的数量
|
|
switch ($currency_type) {
|
|
case 'eth':
|
|
$fee_currency_name = 'eth';
|
|
$transfer_fee = $currency->chain_fee ?? 0.001;
|
|
break;
|
|
case 'btc':
|
|
$fee_currency_name = 'btc';
|
|
$transfer_fee = $currency->chain_fee ?? 0.00006;
|
|
break;
|
|
case 'erc20':
|
|
$fee_currency_name = 'eth';
|
|
$transfer_fee = $currency->chain_fee ?? 0.001;
|
|
break;
|
|
case 'usdt':
|
|
$fee_currency_name = 'btc';
|
|
$base_transfer_use_qty = 0.00000546;
|
|
$transfer_fee = $currency->chain_fee ?? 0.00006;
|
|
break;
|
|
default:
|
|
$fee_currency_name = '';
|
|
$transfer_fee = 0;
|
|
}
|
|
// 查询上次归拢是否完成
|
|
$lbx_hash = LbxHash::where('status', 0)
|
|
->where('type', 0)
|
|
->where('wallet_id', $wallet->id)
|
|
->first();
|
|
if ($lbx_hash) {
|
|
throw new \Exception('当前有归拢操作未完成');
|
|
}
|
|
// 是否先刷新链上余额
|
|
if ($refresh_balance) {
|
|
self::updateWalletBalance($wallet);
|
|
}
|
|
$wallet->refresh();
|
|
if ($currency_type == 'erc20' || $currency_type == 'usdt') {
|
|
//检测手续费是否充足:erc20扣eth, usdt扣btc
|
|
$fee_balance = self::getChainBalance($wallet, $fee_currency_name);
|
|
$base_total_use_qty = bc_add($base_transfer_use_qty, $transfer_fee); //手续费+链上交易额外消耗,例如USDT要额外消耗0.00000546BTC
|
|
|
|
if (bc_comp($fee_balance, $base_total_use_qty) < 0) {
|
|
throw new \Exception('钱包内手续费可用余额(' . $fee_balance . ')不足,不能归拢');
|
|
}
|
|
$transfer_qty = $wallet->old_balance; //代币有多少归多少
|
|
} else {
|
|
$transfer_qty = bc_sub($wallet->old_balance, $transfer_fee); //主链归拢减去手续费
|
|
}
|
|
//如果链上余额为空或者只有手续费(ETH、BTC)就没必要做归拢
|
|
if (bc_comp($transfer_qty, 0) <= 0) {
|
|
throw new \Exception('余额为空或手续费不足,不能归拢');
|
|
}
|
|
|
|
try {
|
|
DB::beginTransaction();
|
|
$result = self::transfer($currency->name, $currency->type, $to_address, $transfer_qty, $from_address, $from_private_key, 1);
|
|
if (!isset($result['code']) || $result['code'] != 0) {
|
|
throw new \Exception(var_export($result, true));
|
|
}
|
|
//记录链上哈希信息
|
|
$lbx_hash_data = [
|
|
'wallet_id' => $wallet->id,
|
|
'txid' => $result['txid'],
|
|
'type' => 0,
|
|
'amount' => $transfer_qty,
|
|
'status' => 0,
|
|
];
|
|
LbxHash::unguarded(function () use ($lbx_hash_data) {
|
|
return LbxHash::create($lbx_hash_data);
|
|
});
|
|
$wallet->refresh();
|
|
$wallet->txid = $result['txid'];
|
|
$wallet->gl_time = time();
|
|
$wallet->save();
|
|
DB::commit();
|
|
return $result;
|
|
} catch (\Exception $e) {
|
|
DB::rollBack();
|
|
throw $e;
|
|
}
|
|
}
|
|
}
|