cleanup charge credits command

This commit is contained in:
AVMG20 2021-06-25 23:42:53 +02:00
parent 3047f6b458
commit eeee4fffb0
3 changed files with 29 additions and 29 deletions

View file

@ -3,9 +3,12 @@
namespace App\Console\Commands;
use App\Classes\Pterodactyl;
use App\Models\Product;
use App\Models\Server;
use App\Models\User;
use Carbon\Carbon;
use Illuminate\Console\Command;
use Illuminate\Support\Collection;
class ChargeCreditsCommand extends Command
{
@ -40,42 +43,23 @@ class ChargeCreditsCommand extends Command
*/
public function handle()
{
Server::chunk(10, function ($servers) {
return Server::whereNull('suspended')->chunk(10, function ($servers) {
/** @var Server $server */
foreach ($servers as $server) {
//ignore suspended servers
if ($server->isSuspended()) {
echo Carbon::now()->isoFormat('LLL') . " Ignoring suspended server";
continue;
}
//vars
/** @var Product $product */
$product = $server->product;
/** @var User $user */
$user = $server->user;
$price = ($server->product->price / 30) / 24;
//remove credits or suspend server
if ($user->credits >= $price) {
$user->decrement('credits', $price);
//log
echo Carbon::now()->isoFormat('LLL') . " [CREDIT DEDUCTION] Removed " . number_format($price, 2, '.', '') . " from user (" . $user->name . ") for server (" . $server->name . ")\n";
#charge credits / suspend server
if ($user->credits >= $product->getHourlyPrice()){
$this->line("<fg=blue>{$user->name}</> Current credits: <fg=green>{$user->credits}</> Credits to be removed: <fg=red>{$product->getHourlyPrice()}</>");
$user->decrement('credits', $product->getHourlyPrice());
} else {
$response = Pterodactyl::client()->post("/application/servers/{$server->pterodactyl_id}/suspend");
if ($response->successful()) {
echo Carbon::now()->isoFormat('LLL') . " [CREDIT DEDUCTION] Suspended server (" . $server->name . ") from user (" . $user->name . ")\n";
$server->update(['suspended' => now()]);
} else {
echo Carbon::now()->isoFormat('LLL') . " [CREDIT DEDUCTION] CRITICAL ERROR! Unable to suspend server (" . $server->name . ") from user (" . $user->name . ")\n";
dump($response->json());
}
$this->line("server <fg=blue>{$server->name}</> <fg=red>has been suspended! </>");
$server->suspend();
}
}
});
return 'Charged credits for existing servers!\n';
}
}

View file

@ -27,6 +27,21 @@ class Product extends Model
});
}
public function getHourlyPrice()
{
return ($this->price / 30) / 24;
}
public function getDailyPrice()
{
return ($this->price / 30);
}
public function getWeeklyPrice()
{
return ($this->price / 4);
}
/**
* @return BelongsTo
*/

View file

@ -124,6 +124,7 @@ class Server extends Model
return $this;
}
/**
* @return HasOne
*/