You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
98 lines
3.9 KiB
98 lines
3.9 KiB
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\Exceptions\ApiException;
|
|
use App\Handlers\ContractTool;
|
|
use App\Jobs\HandleContractEntrust;
|
|
use App\Jobs\HandleFlatPosition;
|
|
use App\Models\ContractEntrust;
|
|
use App\Models\ContractOrder;
|
|
use App\Models\ContractPair;
|
|
use App\Models\ContractPosition;
|
|
use App\Models\ContractWearPositionRecord;
|
|
use App\Models\SustainableAccount;
|
|
use App\Models\User;
|
|
use App\Models\UserAgreementLog;
|
|
use App\Models\UserWallet;
|
|
use App\Services\ContractService;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\Cache;
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
class FlatPosition extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'flatPosition';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = '永续合约系统强制平仓';
|
|
|
|
/**
|
|
* Create a new command instance.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function handle()
|
|
{
|
|
while (true) {
|
|
// 强制平仓风险率
|
|
$flatRiskRate = get_setting_value('flat_risk_rate', 'contract', 0.7);
|
|
|
|
SustainableAccount::query()->chunkById(1000, function ($wallets) use ($flatRiskRate) {
|
|
foreach ($wallets as $wallet) {
|
|
$user_id = $wallet['user_id'];
|
|
if (blank($wallet)) continue;
|
|
|
|
$account = [];
|
|
$totalUnrealProfit = 0;
|
|
$positions = ContractPosition::query()->where('user_id', $user_id)->where('hold_position', '>', 0)->get();
|
|
foreach ($positions as $position) {
|
|
$contract = ContractPair::query()->find($position['contract_id']);
|
|
// 获取最新一条成交记录 即实时最新价格
|
|
$realtime_price = Cache::store('redis')->get('swap:' . 'trade_detail_' . $position['symbol'])['price'] ?? null;
|
|
$unRealProfit = ContractTool::unRealProfit($position, $contract, $realtime_price);
|
|
$totalUnrealProfit += $unRealProfit;
|
|
}
|
|
|
|
$account['usable_balance'] = $wallet['usable_balance'];
|
|
$account['used_balance'] = $wallet['used_balance'];
|
|
$account['freeze_balance'] = $wallet['freeze_balance'];
|
|
$account['totalUnrealProfit'] = $totalUnrealProfit;
|
|
$account['account_equity'] = custom_number_format($account['usable_balance'] + $account['used_balance'] + $account['freeze_balance'] + $account['totalUnrealProfit'], 4); // 永续账户权益 = 账户可用余额 + 持仓保证金 + 委托冻结保证金 + 未实现盈亏
|
|
// 风险率 用以衡量当前合约账户风险程度的指标。风险率越低，账户风险越高，当风险率=10.0%时，将会被强制平仓。风险率=账户权益/（持仓保证金+委托冻结）*100%
|
|
$riskRate = ContractTool::riskRate($account);
|
|
// 风险率是衡量用户资产风险的指标，当风险率 ≤ 10%时，您的仓位将会被系统强制平仓
|
|
//echo 'user:'.$user_id . '--' .$riskRate. '--' .$flatRiskRate .'--' . $riskRate . '--' . json_encode($account) . "\r\n";
|
|
if ($riskRate != 0 && $riskRate <= $flatRiskRate) {
|
|
|
|
echo $user_id . '--' .$riskRate. '--' .$flatRiskRate .'--' . $riskRate . '--' . json_encode($account) . "\r\n";
|
|
// TODO 强制平仓
|
|
HandleFlatPosition::dispatch($positions, 1)->onQueue('HandleFlatPosition');
|
|
//var_dump($cc);
|
|
}
|
|
}
|
|
});
|
|
|
|
sleep(5);
|
|
}
|
|
}
|
|
}
|
|
|