Differential D3728 Diff 10661 src/app/Console/Commands/Data/Stats/CollectorCommand.php

Changeset View

Standalone View

src/app/Console/Commands/Data/Stats/CollectorCommand.php

This file was added.

				<?php

				namespace App\Console\Commands\Data\Stats;

				use App\Http\Controllers\API\V4\Admin\StatsController;
				use App\Providers\PaymentProvider;
				use App\User;
				use Illuminate\Console\Command;
				use Illuminate\Support\Facades\DB;

				class CollectorCommand extends Command
				{
				/**
				* The name and signature of the console command.
				*
				* @var string
				*/
				protected $signature = 'data:stats:collector';

				/**
				* The console command description.
				*
				* @var string
				*/
				protected $description = 'Collects statictical data about the system (for charts)';

				/**
				* Execute the console command.
				*
				* @return mixed
				*/
				public function handle()
				{
				$this->collectPayersCount();
				}

				/**
				* Collect current payers count
				*/
				protected function collectPayersCount(): void
				{
				$tenant_id = \config('app.tenant_id');

				// A subquery to get the all wallets with a successful payment
				$payments = DB::table('payments')
				->distinct('wallet_id')
				->where('status', PaymentProvider::STATUS_PAID);

				// A subquery to get users' wallets (by entitlement) - one record per user
				$wallets = DB::table('entitlements')
				->selectRaw("min(wallet_id) as id, entitleable_id as user_id")
				->where('entitleable_type', User::class)
				->groupBy('entitleable_id');

				// Count all non-degraded and non-deleted users with any successful payment
				$count = DB::table('users')
				->joinSub($wallets, 'wallets', function ($join) {
				$join->on('users.id', '=', 'wallets.user_id');
				})
				->joinSub($payments, 'payments', function ($join) {
				$join->on('wallets.id', '=', 'payments.wallet_id');
				})
				->whereNull('users.deleted_at')
				->whereNot('users.status', '&', User::STATUS_DEGRADED)
				->whereNot('users.status', '&', User::STATUS_SUSPENDED);

				if ($tenant_id) {
				$count->where('users.tenant_id', $tenant_id);
				} else {
				$count->whereNull('users.tenant_id');
				}

				$count = $count->count();

				if ($count) {
				mollekopfUnsubmitted Not Done Inline Actions If suspended means they also don't currently pay, let's exclude them as well. (I'm not sure what degraded vs suspended vs non-active means), but I think the goal is to get an estimate for "active" users (and we use that they are paying as a proxy for that). mollekopf: If suspended means they also don't currently pay, let's exclude them as well. (I'm not sure…
				vanmeeuwenUnsubmitted Not Done Inline Actions A suspended user is suspended because of spam nowadays. There's no way for these accounts to revive themselves, IIRC. They can simply be excluded. A degraded user is a non-paying user, and should be included (stacked on top of active? could we?). vanmeeuwen: A suspended user is suspended because of spam nowadays. There's no way for these accounts to…
				DB::table('stats')->insert([
				mollekopfUnsubmitted Not Done Inline Actions Let's exclude them since we have the users separately. mollekopf: Let's exclude them since we have the users separately.
				'tenant_id' => $tenant_id,
				'type' => StatsController::TYPE_PAYERS,
				'value' => $count,
				]);
				}
				}
				}