87 lines
3.4 KiB
PHP
87 lines
3.4 KiB
PHP
<?php
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
use App\OptionOrder;
|
|
use App\OptionPair;
|
|
use App\UsersWallet;
|
|
use App\AccountLog;
|
|
use App\CurrencyMatch;
|
|
use App\Currency;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
class AutoOptionSettle extends Command
|
|
{
|
|
protected $signature = "auto_option_settle";
|
|
protected $description = "自动结算到期的期权订单";
|
|
|
|
public function handle()
|
|
{
|
|
$orderIds = OptionOrder::where('status', 0)
|
|
->where('delivery_time', '<=', now())
|
|
->pluck('id');
|
|
|
|
if ($orderIds->isEmpty()) return;
|
|
|
|
foreach ($orderIds as $orderId) {
|
|
DB::beginTransaction();
|
|
try {
|
|
$affected = OptionOrder::where('id', $orderId)->where('status', 0)
|
|
->update(['status' => 99]);
|
|
if ($affected === 0) {
|
|
DB::rollBack();
|
|
continue;
|
|
}
|
|
|
|
$order = OptionOrder::lockForUpdate()->find($orderId);
|
|
$pair = OptionPair::find($order->pair_id);
|
|
$match = $pair ? CurrencyMatch::find($pair->currency_match_id) : null;
|
|
$currency = $match ? Currency::find($match->currency_id) : null;
|
|
$close_price = $currency ? sprintf("%.6f", $currency->price) : '0';
|
|
|
|
if (bccomp($close_price, '0', 6) <= 0) {
|
|
$order->update(['status' => 0]);
|
|
DB::commit();
|
|
$this->warn("Order #{$orderId}: close_price=0, skip");
|
|
continue;
|
|
}
|
|
|
|
$cmp = bccomp($close_price, sprintf("%.6f", $order->open_price), 6);
|
|
$win = $order->direction == 'up' ? $cmp > 0 : $cmp < 0;
|
|
|
|
$income = $win
|
|
? bcmul(sprintf("%.6f", $order->amount), bcdiv(sprintf("%.6f", $order->profit_rate), '100', 8), 6)
|
|
: bcmul(sprintf("%.6f", $order->amount), '-1', 6);
|
|
|
|
$order->update([
|
|
'close_price' => $close_price,
|
|
'income' => $income,
|
|
'status' => $win ? 1 : 2,
|
|
]);
|
|
|
|
if ($win) {
|
|
$wallet = UsersWallet::where('user_id', $order->user_id)
|
|
->where('currency', 3)->lockForUpdate()->first();
|
|
if ($wallet) {
|
|
$return_amount = bcadd(sprintf("%.6f", $order->amount), $income, 6);
|
|
$before = $wallet->legal_balance;
|
|
$wallet->legal_balance = bcadd($wallet->legal_balance, $return_amount, 6);
|
|
$wallet->save();
|
|
AccountLog::insertLog(
|
|
['user_id' => $order->user_id, 'value' => $return_amount, 'info' => 'Option Win - ' . $order->symbol, 'type' => AccountLog::MICRO_TRADE_CLOSE_SETTLE, 'currency' => 3],
|
|
['balance_type' => 1, 'wallet_id' => $wallet->id, 'lock_type' => 0, 'before' => $before, 'change' => $return_amount, 'after' => $wallet->legal_balance]
|
|
);
|
|
}
|
|
}
|
|
|
|
DB::commit();
|
|
$this->info("Order #{$orderId} settled: " . ($win ? 'WIN' : 'LOSE'));
|
|
} catch (\Exception $e) {
|
|
DB::rollBack();
|
|
$this->error("Order #{$orderId} error: " . $e->getMessage());
|
|
}
|
|
}
|
|
}
|
|
}
|