feat: ✨ Add open payments cleanup to schedule
This commit is contained in:
parent
c1a2c34a06
commit
62358aec4e
|
@ -67,7 +67,7 @@ class ChargeCreditsCommand extends Command
|
||||||
$server->suspend();
|
$server->suspend();
|
||||||
|
|
||||||
//add user to notify list
|
//add user to notify list
|
||||||
if (! in_array($user, $this->usersToNotify)) {
|
if (!in_array($user, $this->usersToNotify)) {
|
||||||
array_push($this->usersToNotify, $user);
|
array_push($this->usersToNotify, $user);
|
||||||
}
|
}
|
||||||
} catch (\Exception $exception) {
|
} catch (\Exception $exception) {
|
||||||
|
@ -85,7 +85,7 @@ class ChargeCreditsCommand extends Command
|
||||||
*/
|
*/
|
||||||
public function notifyUsers()
|
public function notifyUsers()
|
||||||
{
|
{
|
||||||
if (! empty($this->usersToNotify)) {
|
if (!empty($this->usersToNotify)) {
|
||||||
/** @var User $user */
|
/** @var User $user */
|
||||||
foreach ($this->usersToNotify as $user) {
|
foreach ($this->usersToNotify as $user) {
|
||||||
$this->line("<fg=yellow>Notified user:</> <fg=blue>{$user->name}</>");
|
$this->line("<fg=yellow>Notified user:</> <fg=blue>{$user->name}</>");
|
||||||
|
|
42
app/Console/Commands/CleanupPayments.php
Normal file
42
app/Console/Commands/CleanupPayments.php
Normal file
|
@ -0,0 +1,42 @@
|
||||||
|
<?php
|
||||||
|
|
||||||
|
namespace App\Console\Commands;
|
||||||
|
|
||||||
|
use App\Models\Payment;
|
||||||
|
use Illuminate\Console\Command;
|
||||||
|
|
||||||
|
class CleanupPayments extends Command
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* The name and signature of the console command.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $signature = 'payments:clear';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The console command description.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $description = 'Clears all payments from the database that have state "open"';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Execute the console command.
|
||||||
|
*
|
||||||
|
* @return int
|
||||||
|
*/
|
||||||
|
public function handle()
|
||||||
|
{
|
||||||
|
// delete all payments that have state "open" and are older than 1 hour
|
||||||
|
try {
|
||||||
|
Payment::where('status', 'open')->where('updated_at', '<', now()->subHour())->delete();
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
$this->error('Could not delete payments: ' . $e->getMessage());
|
||||||
|
return 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
$this->info('Successfully deleted all open payments');
|
||||||
|
return Command::SUCCESS;
|
||||||
|
}
|
||||||
|
}
|
|
@ -18,10 +18,11 @@ class Kernel extends ConsoleKernel
|
||||||
{
|
{
|
||||||
$schedule->command('credits:charge')->hourly();
|
$schedule->command('credits:charge')->hourly();
|
||||||
$schedule->command('cp:versioncheck:get')->daily();
|
$schedule->command('cp:versioncheck:get')->daily();
|
||||||
|
$schedule->command('payments:clear')->daily();
|
||||||
|
|
||||||
//log cronjob activity
|
//log cronjob activity
|
||||||
$schedule->call(function () {
|
$schedule->call(function () {
|
||||||
Storage::disk('logs')->put('cron.log', 'Last activity from cronjobs - '.now());
|
Storage::disk('logs')->put('cron.log', 'Last activity from cronjobs - ' . now());
|
||||||
})->everyMinute();
|
})->everyMinute();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -32,7 +33,7 @@ class Kernel extends ConsoleKernel
|
||||||
*/
|
*/
|
||||||
protected function commands()
|
protected function commands()
|
||||||
{
|
{
|
||||||
$this->load(__DIR__.'/Commands');
|
$this->load(__DIR__ . '/Commands');
|
||||||
|
|
||||||
require base_path('routes/console.php');
|
require base_path('routes/console.php');
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue