updateGroupLogic = $updateGroupLogic; } /** * Execute the console command. * * @return int */ public function handle() { // update group to include transfer fee $groups = Group::where('created_at', '>=', '2024-06-01')->get(); foreach ($groups as $group) { $group_transfer_fee = 0; $morph_transaction = $group->morphTransactions()->where('type', TransactionType::TRANSFER_FEE)->first(); if ($morph_transaction) { $group_transfer_fee = $morph_transaction->original_amount; } $originalTransferFees = (float)Transaction::where('type', TransactionType::TRANSFER_FEE)->whereIn('owner_id', $group->transactions->pluck('id'))->sum('service_charge'); $correctOriginalAmount = $group->transactions()->sum('original_amount'); $correctOriginalAmount = $correctOriginalAmount + $originalTransferFees + $group_transfer_fee; $correctAmount = $group->transactions()->sum('amount'); $transferFees = $originalTransferFees / $group->currency_rate; $correctAmount = $correctAmount + $transferFees + ($group_transfer_fee / $group->currency_rate) + $group->service_charge; if ($group->original_amount != $correctOriginalAmount || $group->amount != $correctAmount) { $group->original_amount = $correctOriginalAmount; $group->amount = $correctAmount; $group->save(); $this->info("updated group id: {$group->id}, added transfer fee CNY {$correctOriginalAmount}"); } } // update group calculation to include individual group transfer fee // $groups = Group::whereHas('morphTransactions', function ($q) { // $q->where('type', TransactionType::TRANSFER_FEE); // })->get(); // foreach ($groups as $group) { // $route = FacadesRoute::getRoutes()->getByName('api.transaction.group.update'); // $request = Request::create(route('api.transaction.group.update', $group->id)); // $uri = $route->uri; // $request->setRouteResolver(function () use ($request, $uri) { // // Associate Route to request so we can access route parameters. // return (new Route('PUT', $uri, []))->bind($request); // }); // $request['rate'] = $group->currency_rate; // $request['supplier_id'] = $group->issuer; // $this->updateGroupLogic->execute($request); // $group_transfer_fee = $group->morphTransactions()->where('type', TransactionType::TRANSFER_FEE)->first(); // $this->info("updated group id: {$group->id}, added transfer fee to individual white form CNY {$group_transfer_fee->original_amount}"); // } // update bill group calculation to include individual group transfer fee $billGroups = BillGroup::all(); foreach ($billGroups as $billGroup) { // ignore those has bill group refund if ($billGroup->billRefunds()->count() > 0) { continue; } $totalOriginal = round($billGroup->groups()->sum('original_amount'), 2); $total = round($billGroup->groups()->sum('amount') + $billGroup->service_charge, 2); // update bill group payment transaction amount if there is only 1 payment transaction $payment_transactions = $billGroup->transactions()->whereIn('status', [ApprovalStatus::PENDING_SUBMISSION, ApprovalStatus::PENDING_VERIFICATION, ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED])->get(); if ($payment_transactions->count() === 1) { $payment_transaction = $payment_transactions->first(); if ($payment_transaction->amount - ($billGroup->amount + $billGroup->service_charge) < 0.01) { $payment_transaction->original_amount = $total; $payment_transaction->amount = $total; $payment_transaction->save(); $this->info("updated bill group payment transaction id: {$payment_transaction->id}, update original amount to CNY {$totalOriginal}"); } } // update bill group amount and original amount $billGroup->original_amount = $totalOriginal; $billGroup->amount = $total; $billGroup->save(); $this->info("updated bill group id: {$billGroup->id}, added transfer fee, final original amount is CNY {$totalOriginal}"); } } }