77 lines
3.3 KiB
PHP
77 lines
3.3 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\DB;
|
|
use App\LeverTransaction;
|
|
use App\UsersWallet;
|
|
use App\AccountLog;
|
|
class OvernightFee extends Command
|
|
{
|
|
protected $signature = "lever:overnight";
|
|
protected $description = "杠杆交易隔夜费";
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
public function handle()
|
|
{
|
|
$today = strtotime(date('Y-m-d'));
|
|
$count = LeverTransaction::where('create_time', '<', $today)->where('status', LeverTransaction::TRANSACTION)->count();
|
|
if ($count <= 0) {
|
|
$this->info(date('Y-m-d H:i:s') . ' 没有要执行的任务');
|
|
return;
|
|
}
|
|
$this->info(date('Y-m-d H:i:s') . ' 共' . $count . '个任务');
|
|
$current = 0;
|
|
LeverTransaction::where('create_time', '<', $today)->where('status', LeverTransaction::TRANSACTION)->chunk(100, function ($lever_transactions) use(&$current) {
|
|
try {
|
|
foreach ($lever_transactions as $key => $trade) {
|
|
$current = $current + 1;
|
|
$this->info('正在执行第' . $current . '个任务');
|
|
DB::transaction(function () use($trade) {
|
|
$trade->refresh();
|
|
if ($trade->status != LeverTransaction::TRANSACTION) {
|
|
throw \Exception('交易状态异常');
|
|
}
|
|
$profit = $trade->profits;
|
|
$overnight_rate = bc_div($trade->overnight, 100);
|
|
$trade_money = bc_mul($trade->price, $trade->number);
|
|
$overnight_fee = bc_mul($trade_money, $overnight_rate);
|
|
$caution_money = $trade->caution_money;
|
|
$wallet_money = 0;
|
|
$user_wallet = UsersWallet::where('user_id', $trade->user_id)->where('currency', $trade->legal)->lockForUpdate()->first();
|
|
$user_wallet && ($wallet_money = $user_wallet->lever_balance);
|
|
$subtotal = bc_add($wallet_money, $caution_money);
|
|
if (bc_comp($subtotal, $overnight_fee) < 0) {
|
|
if (bc_comp($profit, $overnight_fee) < 0) {
|
|
}
|
|
}
|
|
if (bc_comp($trade->caution_money, $overnight_fee) >= 0) {
|
|
$caution_should_deduct = $overnight_fee;
|
|
$balance_should_deduct = 0;
|
|
} else {
|
|
$caution_should_deduct = $caution_money;
|
|
$balance_should_deduct = bc_sub($overnight_fee, $caution_should_deduct);
|
|
}
|
|
$extra_data = serialize(['trade_id' => $trade->id, 'trade_money' => $trade_money, 'overnight_rate' => $overnight_rate, 'overnight_fee' => $overnight_fee, 'caution_deduct' => $caution_should_deduct, 'balance_deduct' => $balance_should_deduct]);
|
|
$result = change_wallet_balance($user_wallet, 4, -1 * $balance_should_deduct, AccountLog::LEVER_TRANSACTION_OVERNIGHT, '杠杆交易id:' . $trade->id . ',收取隔夜费:' . $overnight_fee . '(从保证金扣除:' . $caution_should_deduct . ',从余额扣除:' . $balance_should_deduct . ')', false, 0, 0, $extra_data, true, true);
|
|
if ($result !== true) {
|
|
throw new \Exception($result);
|
|
}
|
|
$trade->caution_money = bc_sub($caution_money, $caution_should_deduct);
|
|
$trade->overnight_money = bc_add($trade->overnight_money, $overnight_fee);
|
|
$result = $trade->save();
|
|
if (!$result) {
|
|
throw new \Exception('从交易保证金扣除隔夜费失败');
|
|
}
|
|
});
|
|
}
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
});
|
|
$this->info(date('Y-m-d H:i:s') . ' 全部执行完成');
|
|
}
|
|
} |