JFIF $
d d 7
Viewing File: /home/optimaldigitaltr/public_html/src/app/Services/Trade/ActivityLogService.php
<?php
namespace App\Services\Trade;
use App\Enums\Trade\TradeOutcome;
use App\Enums\Trade\TradeParameterUnit;
use App\Enums\Trade\TradeStatus;
use App\Enums\Trade\TradeType;
use App\Enums\Trade\TradeVolume;
use App\Enums\Transaction\Source;
use App\Enums\Transaction\Type;
use App\Enums\Transaction\WalletType;
use App\Models\CryptoCurrency;
use App\Models\TradeLog;
use App\Models\TradeParameter;
use App\Models\Wallet;
use App\Services\Api\CoinGeckoService;
use App\Services\Payment\WalletService;
use App\Services\SettingService;
use Carbon\Carbon;
use Carbon\CarbonPeriod;
use GuzzleHttp\Exception\GuzzleException;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Collection;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Http\Request;
use Illuminate\Pagination\AbstractPaginator;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
class ActivityLogService
{
public function __construct(
protected WalletService $walletService,
protected CoinGeckoService $coinGeckoService,
){
}
/**
* @param TradeType $tradeType
* @param int|string|null $cryptoId
* @param int|string|null $userId
* @param array $with
* @return AbstractPaginator
*/
public function getByPaginate(TradeType $tradeType, int|string $cryptoId = null, int|string $userId = null, array $with = []): AbstractPaginator
{
$query = TradeLog::filter(request()->all())
->where('type', $tradeType->value);
if (!is_null($cryptoId)) {
$query->where('crypto_currency_id', $cryptoId);
}
if (!empty($with)) {
$query->with($with);
}
if (!is_null($userId)) {
$query->where('user_id', $userId);
}
return $query->paginate(getPaginate());
}
public function getDuration(TradeParameter $tradeParameter): float|int
{
return match ($tradeParameter->unit ?? null) {
TradeParameterUnit::MINUTES->value => $tradeParameter->time * 60,
TradeParameterUnit::HOURS->value => $tradeParameter->time * 3600,
default => $tradeParameter->time,
};
}
/**
* @param Request $request
* @param TradeParameter $tradeParameter
* @param CryptoCurrency $cryptoCurrency
* @return array
* @throws GuzzleException
*/
public function prepParams(Request $request, TradeParameter $tradeParameter, CryptoCurrency $cryptoCurrency): array
{
return [
'user_id' => Auth::id(),
'crypto_currency_id' => $cryptoCurrency->id,
'original_price' => $this->coinGeckoService->getCoinRate($cryptoCurrency),
'amount' => $request->input('amount'),
'duration' => $this->getDuration($tradeParameter),
'arrival_time' => Carbon::now()->addSeconds($this->getDuration($tradeParameter)),
'type' => $request->input('type'),
'volume' => $request->input('volume'),
'outcome' => TradeOutcome::INITIATED->value,
'status' => TradeStatus::RUNNING->value,
'meta' => null,
];
}
/**
* @param array $params
* @return TradeLog
*/
public function save(array $params): TradeLog
{
return TradeLog::create($params);
}
/**
* @param Request $request
* @param Wallet $wallet
* @param array $account
* @param Type $type
* @param TradeParameter $tradeParameter
* @param CryptoCurrency $cryptoCurrency
* @return void
*/
public function executeTrade(Request $request, Wallet $wallet, array $account, Type $type, TradeParameter $tradeParameter, CryptoCurrency $cryptoCurrency): void
{
DB::transaction(function () use ($request, $wallet, $account, $type, $tradeParameter, $cryptoCurrency) {
$trade = $this->save($this->prepParams($request, $tradeParameter, $cryptoCurrency));
$details = 'Trade BTC '.TradeVolume::getName($trade->volume).' at '.getCurrencySymbol().$trade->amount;
$this->updateTradeBalance($wallet, $account, $trade, $type, $details);
});
}
/**
* @param Wallet $wallet
* @param array $account
* @param TradeLog $tradeLog
* @param Type $type
* @param $details
* @param int $result
* @return void
*/
public function updateTradeBalance(Wallet $wallet, array $account, TradeLog $tradeLog, Type $type, $details, int $result = 55): void
{
$tradeAmount = $tradeLog->amount;
if($result == TradeOutcome::WIN->value){
$tradeAmount = $this->tradeWinCalculate($tradeLog);
}
$amount = $type->value == Type::MINUS->value ? -$tradeLog->amount : $tradeAmount;
$name = Arr::get($account, 'name', 'practice_balance');
$wallet->$name += $amount;
$wallet->save();
if($type->value == Type::PLUS->value && $result == TradeOutcome::WIN->value){
$tradeLog->winning_amount = $this->tradeWinCalculate($tradeLog) - $tradeLog->amount;
$tradeLog->save();
}
$account = $this->walletService->findBalanceByWalletType(WalletType::TRADE->value, $wallet);
if($tradeLog->type == TradeType::TRADE->value){
$this->walletService->updateTransaction(
$tradeLog->user_id,
$type->value == Type::MINUS->value ? $tradeLog->amount : $tradeAmount,
$type,
Source::TRADE,
$account,
$details
);
}
}
/**
* @throws GuzzleException
*/
public function cron(): void
{
$tradeLogs = TradeLog::where('outcome', TradeOutcome::INITIATED->value)
->where('status',TradeStatus::RUNNING->value)
->where('arrival_time', '<', Carbon::now())
->get();
foreach ($tradeLogs as $tradeLog){
$this->result($tradeLog);
}
}
/**
* @param TradeLog $tradeLog
* @return void
* @throws GuzzleException
*/
public function result(TradeLog $tradeLog): void
{
$currentCryptoRate = $this->coinGeckoService->getCoinRate($tradeLog->cryptoCurrency);
$result = $this->determineTradeOutcome($tradeLog, $currentCryptoRate);
[$balance, $details] = $this->tradeCalculate($tradeLog, $result);
if ($balance > 0) {
$wallet = $tradeLog?->user?->wallet;
$walletType = $tradeLog->type == TradeType::TRADE->value ? WalletType::TRADE->value : WalletType::PRACTICE->value;
$account = $this->walletService->findBalanceByWalletType($walletType, $wallet);
$this->updateTradeBalance($wallet, $account, $tradeLog, Type::PLUS, $details, $result);
}
$tradeLog->outcome = $result;
$tradeLog->status = TradeStatus::COMPLETE->value;
$tradeLog->meta = [
'result_price' => $currentCryptoRate,
];
$tradeLog->save();
}
private function determineTradeOutcome(TradeLog $tradeLog, float $currentCryptoRate): int
{
return match (true) {
$tradeLog->volume == TradeVolume::HIGH->value && $tradeLog->original_price < $currentCryptoRate,
$tradeLog->volume == TradeVolume::LOW->value && $tradeLog->original_price > $currentCryptoRate => TradeOutcome::WIN->value,
$tradeLog->volume == TradeVolume::HIGH->value && $tradeLog->original_price > $currentCryptoRate,
$tradeLog->volume == TradeVolume::LOW->value && $tradeLog->original_price < $currentCryptoRate => TradeOutcome::LOSE->value,
default => TradeOutcome::DRAW->value,
};
}
/**
* @param TradeLog $tradeLog
* @param int $result
* @return array
*/
private function tradeCalculate(TradeLog $tradeLog, int $result): array
{
$setting = SettingService::getSetting();
$tradeAmount = calculateCommissionPlus($tradeLog->amount, getArrayValue($setting->commissions_charge, 'binary_trade_commissions', 0));
return match ($result) {
TradeOutcome::WIN->value => [$tradeAmount, "Trade {$tradeLog->symbol} WIN"],
TradeOutcome::DRAW->value => [$tradeLog->amount, "Trade {$tradeLog->symbol} Refund"],
default => [0, ''],
};
}
/**
* @param TradeLog $tradeLog
* @return float|int|string
*/
private function tradeWinCalculate(TradeLog $tradeLog): float|int|string
{
$setting = SettingService::getSetting();
return calculateCommissionPlus($tradeLog->amount, getArrayValue($setting->commissions_charge, 'binary_trade_commissions', 0));
}
public function getByUser(int $userId, TradeType $tradeType, bool $isLimit = false): AbstractPaginator|Collection
{
$query = TradeLog::filter(request()->all())
->where('user_id', $userId)
->where('type', $tradeType->value)
->with('cryptoCurrency')
->orderBy('id', 'DESC');
if ($isLimit) {
return $query->take(10)->get();
} else {
return $query->paginate(getPaginate());
}
}
public function recentActivities(TradeType $tradeType, int $limit = 10, array $with = []): Collection
{
$query = TradeLog::where('type', $tradeType->value)
->orderBy('id', 'DESC')
->take($limit);
if(!empty($with)){
$query->with($with);
}
return $query->get();
}
/**
* @param int|string|null $userId
* @return array
*/
public function dayReport(int|string $userId = null): array
{
$report = [
'days' => collect(),
'trade_day_amount' => collect(),
];
$startOfLast90Days = Carbon::now()->subDays(89)->startOfDay();
$investmentsDay = TradeLog::where('created_at', '>=', $startOfLast90Days)
->when(!is_null($userId), fn ($query) => $query->where('user_id', $userId))
->selectRaw("DATE_FORMAT(created_at,'%Y-%m-%d') as days, SUM(amount) as amount")
->orderBy('created_at')
->groupBy('days', 'amount', 'created_at')
->get();
$last90Days = collect(CarbonPeriod::create($startOfLast90Days, '1 day', Carbon::now()->endOfDay()))
->map(function ($date) {
return $date->format('Y-m-d');
});
$last90Days->each(function ($day) use (&$report, $investmentsDay) {
$investmentDataForDay = $investmentsDay->firstWhere('days', $day);
$report['days']->push($day);
$report['trade_day_amount']->push(getAmount(optional($investmentDataForDay)->amount));
});
return [
$report['days']->values()->all(),
$report['trade_day_amount']->values()->all(),
];
}
/**
* @param int|string|null $userId
* @return Builder|Model|object|null
*/
public function getTradeReport(int|string $userId = null)
{
$completeStatus = TradeStatus::COMPLETE->value;
$query = TradeLog::query();
if (!is_null($userId)) {
$query->where('user_id', $userId);
}
return $query->selectRaw('
COALESCE(SUM(CASE WHEN status = ? THEN amount ELSE 0 END), 0) as total,
COALESCE(SUM(CASE WHEN DATE(created_at) = CURDATE() THEN amount ELSE 0 END), 0) as today,
COALESCE(SUM(CASE WHEN outcome = ? AND status = ? THEN amount ELSE 0 END), 0) as wining,
COALESCE(SUM(CASE WHEN outcome = ? AND status = ? THEN amount ELSE 0 END), 0) as loss,
COALESCE(SUM(CASE WHEN outcome = ? AND status = ? THEN amount ELSE 0 END), 0) as draw,
COALESCE(SUM(CASE WHEN volume = ? AND status = ? THEN amount ELSE 0 END), 0) as high,
COALESCE(SUM(CASE WHEN volume = ? AND status = ? THEN amount ELSE 0 END), 0) as low',
[
$completeStatus, TradeOutcome::WIN->value, $completeStatus,
TradeOutcome::LOSE->value, $completeStatus, TradeOutcome::DRAW->value, $completeStatus,
TradeVolume::HIGH->value, $completeStatus, TradeVolume::LOW->value, $completeStatus,
])->first();
}
}
Back to Directory
nL+D550H?Mx ,D"v]qv;6*Zqn)ZP 0 !1 A "#a$2Qr D8 a Ri[f\mIykIw0 cuFcRı?lO7к_f˓[C$殷WF<_W ԣs KcëIzyQy /_LKℂ;C",pFA: /]=H ~,ls/9ć:[=/#f;)x {ٛEQ )~ =𘙲r*2~ a _V=' kumF D}KYYC)({ *g&f`툪ry`=^cJ.I](*`wq 1dđ#̩͑0;H]u搂@:~וKL Nsh}OIR*8:2 !lDJVo( 3=M(zȰ+i*NA r6KnSl )!JJӁ* %݉?|D}d5:eP0R;{$X'xF@.ÊB {,WJuQɲRI;9QE琯62fT.DUJ;*cP A\ILNj!J۱+O\ ͔]ޒ SJȧc%ANolՎprULZԛerE2=XDXgVQeӓk yP7U*omQIs,K`)6\G3t?pgjrmۛجwluGtf h9uyP0D;Uڽ"OXlif$)&|ML0Zrm1[HXPlPR0'G=i2N +0e2]] 9VTPO7h(F*癈 '=QVZDF,d߬~TX
G[`le69CR(!S2!P
<0x < !1AQ "Raq02Br#SCTb
?Ζ"]mH5WR7k.ۛ!}Q~+yԏz|@T20S~Kek *zFf^2X*(@8r?CIuI|֓>^ExLgNUY+{.RѪ
τVYTD I62'8Y2 7'\TP.6d&˦@Vqi|8- OΕ]ʔ U=TL8=;6c| !qfF3aů&~$l}'NWUs$Uk^SV:U# 6w++s&r+nڐ{@29 gL
u"TÙM=6 (^"7r} =6YݾlCuhquympǦ
G jhsǜNlɻ}o7 #S6aw4!OSrD57%|?x>L
|/nD6?/8w#[)L7+6〼T ATg ! %5MmZ/c-{1_Je"|^$'O&ޱմ Trb$ w)R$&
N1EtdU3Uȉ1pM" N*(DN yd96.(jQ)X
5cQɎMyW? Q*!R>6=7)Xj5`J]e 8%t!+'!1Q 5 !1 AQaqё#2"0BRb ? Gt^## .llQT $v,,m 㵜5 ubV =sY+@d{N! dnO< .-B; _wJt6;QJd.Qc%p{ 1,sNDdFHI0ГoXшe黅XۢF:)[FGXƹ/w_cMeD,ʡcc. WDtA$j@:) -# u
c1<@ۗ9F)KJ-hpP]_x[qBlbp ʖw q"LFGd ƶ*s+ډ_Zc"? %t[IP 6J]#=ɺVvvCGsGh1 >)6|ey?Lӣm,4GWUi` ]uJVoV DG< SB 6ϏQ@ TiUly OU0kfV~~}SZ@*WUUi##; s/[ =!7}" WN]'(L! ~y5g9T̅JkbM' +s:S + B)v@Mj
e Cf jE 0Y\QnzG1д~Wo{T 9?`Rmyhsy3!HAD]mc1~2L Su7xT;j$`}4->L#vzŏ ILS ֭ T { rjGKC; bpU= -`BsK.SFw4Mq]ZdHS0)tLg