diff --git a/src/Goteo/Console/Command/CertificateCommand.php b/src/Goteo/Console/Command/CertificateCommand.php
index d34a514057..b7104f0053 100644
--- a/src/Goteo/Console/Command/CertificateCommand.php
+++ b/src/Goteo/Console/Command/CertificateCommand.php
@@ -20,53 +20,59 @@
use Symfony\Component\Console\Output\OutputInterface;
-class CertificateCommand extends AbstractCommand {
+class CertificateCommand extends AbstractCommand
+{
protected function configure()
{
$this->setName("certificate")
- ->setDescription("Manages donors data")
- ->setDefinition(array(
- new InputOption('update', 'u', InputOption::VALUE_NONE, 'Actually does the job. If not specified, nothing is done, readonly process.'),
- new InputOption('update_donors', 'c', InputOption::VALUE_NONE, "If specified, checks all donor's data"),
- new InputOption('donor', 'd', InputOption::VALUE_OPTIONAL, "If specified, checks donor's data"),
- new InputOption('update_amounts', 'a', InputOption::VALUE_NONE, "If specified calculates new amounts for donors"),
- new InputOption('update_status', 's', InputOption::VALUE_NONE, "If specified updates the status of the donors"),
- new InputOption('user', 'usr', InputOption::VALUE_OPTIONAL, "If specified used to search donations from a user" ),
- new InputOption('year', 'y', InputOption::VALUE_OPTIONAL, "If specified used to search for donors of the selected year, if not current year is used"),
- new InputOption('unify', '', InputOption::VALUE_NONE, "If specified unifies donors certificates for the given year")
- ))
- ->setHelp(<<<EOT
+ ->setDescription("Manages donors data")
+ ->setDefinition(array(
+ new InputOption('update', 'u', InputOption::VALUE_NONE, 'Actually does the job. If not specified, nothing is done, readonly process.'),
+ new InputOption('update_donors', 'c', InputOption::VALUE_NONE, "If specified, checks all donor's data"),
+ new InputOption('donor', 'd', InputOption::VALUE_OPTIONAL, "If specified, checks donor's data"),
+ new InputOption('update_amounts', 'a', InputOption::VALUE_NONE, "If specified calculates new amounts for donors"),
+ new InputOption('update_invests', 'i', InputOption::VALUE_NONE, "If specified updates the invests for the certificates"),
+ new InputOption('update_status', 's', InputOption::VALUE_NONE, "If specified updates the status of the donors"),
+ new InputOption('user', 'usr', InputOption::VALUE_OPTIONAL, "If specified used to search donations from a user"),
+ new InputOption('year', 'y', InputOption::VALUE_OPTIONAL, "If specified used to search for donors of the selected year, if not current year is used"),
+ new InputOption('unify', '', InputOption::VALUE_NONE, "If specified unifies donors certificates for the given year")
+ ))
+ ->setHelp(
+ <<<EOT
This command checks the valid fields for donors.
Usage:
Update donors summary data
-<info>./console donor --update_donors --update </info>
+<info>./console certificate --update_donors --update </info>
Update the provided donor's summary data
-<info>./console donor --update_donors --donor donor_id --update </info>
+<info>./console certificate --update_donors --donor donor_id --update </info>
Update the donors amount
-<info>./console donor --update_amounts </info>
+<info>./console certificate --update_amounts </info>
Update the provided user's donor amount
-<info>./console donor --update_amounts --user user_id --update </info>
+<info>./console certificate --update_amounts --user user_id --update </info>
Update the donors amounts for a given year
-<info>./console donor --update_amounts --year 2020 --update </info>
+<info>./console certificate --update_amounts --year 2020 --update </info>
Update the provided user's donor status
-<info>./console donor --update_status --user user_id --update </info>
+<info>./console certificate --update_status --user user_id --update </info>
Update the provided user's donor status
-<info>./console donor --update_status --user user_id --update </info>
+<info>./console certificate --update_status --user user_id --update </info>
Update the donors status for a year
-<info>./console donor --update_status --year 2020 --update </info>
+<info>./console certificate --update_status --year 2020 --update </info>
+
+Update the invests for the certificates
+<info>./console certificate --update_invests --year 2024 --update </info>
EOT
-);
+ );
}
protected function execute(InputInterface $input, OutputInterface $output)
@@ -80,14 +86,15 @@ protected function execute(InputInterface $input, OutputInterface $output)
$update_donors = $input->getOption('update_donors');
$update_amounts = $input->getOption('update_amounts');
$update_status = $input->getOption('update_status');
+ $update_invests = $input->getOption('update_invests');
$unify = $input->getOption('unify');
- if(!$update_donors && !$update_amounts && !$update_status && !$unify) {
+ if (!$update_donors && !$update_amounts && !$update_status && !$unify && !$update_invests) {
throw new InvalidArgumentException('No action defined. Please define any action with --update_donors, --update_amounts or --update_status');
}
$user = $input->getOption('user');
- $year = $input->getOption('year')? $input->getOption('year') : date('Y');
+ $year = $input->getOption('year') ? $input->getOption('year') : date('Y');
$output->writeln("<info>Update donors thrown</info>");
@@ -115,7 +122,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
}
}
- if(isset($errors['nif'])) {
+ if (isset($errors['nif'])) {
if ($valid_nif && $nif_type != Donor::VAT) {
$donor->legal_document_type = $nif_type;
$error_save = array();
@@ -131,7 +138,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
}
}
}
-
} else {
$output->writeln("<info>The donor has no errors in its data</info>");
}
@@ -159,7 +165,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
$invalid_nif = 0;
$cant_update = 0;
- foreach($donors as $donor) {
+ foreach ($donors as $donor) {
if ($verbose) {
$progress_bar->clear();
$output->writeln("<info>Update {$donor->id} - {$donor->name} - {$donor->nif} donor</info>");
@@ -181,11 +187,11 @@ protected function execute(InputInterface $input, OutputInterface $output)
$invalid_donors++;
$valid_nif = Check::nif($donor->nif, $nif_type);
- if(isset($errors['nif'])) {
+ if (isset($errors['nif'])) {
if ($valid_nif && $nif_type != Donor::VAT) {
$donor->legal_document_type = $nif_type;
- if ($nif_type == Donor::CIF) {
+ if ($nif_type == Donor::CIF) {
$donor->legal_entity = Donor::LEGAL_PERSON;
} else {
$donor->legal_entity = Donor::NATURAL_PERSON;
@@ -261,7 +267,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
$updated_donors++;
} else if ($can_be_updated && !$valid) {
$could_not_update++;
- } else{
+ } else {
$cant_update++;
}
@@ -282,7 +288,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
}
}
}
-
} else {
$valid_donors++;
}
@@ -300,7 +305,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
$output->writeln("<info>Can NOT update {$could_not_update} invalid donors that have changes due to validation</info>");
$output->writeln("<info>Can NOT make changes to {$cant_update} invalid donors </info>");
$output->writeln("<info>{$updated} invalid donors HAVE been updated</info>");
-
}
} else if ($update_amounts) {
@@ -340,7 +344,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
$progress_bar->start();
$donors = Donor::getList($filter, 0, $total);
- foreach($donors as $donor) {
+ foreach ($donors as $donor) {
$user_invests = Donor::getPendingInvestionsAmount($donor->user, $year);
$donor_amount = $user_invests['amount'] + $user_invests['donations_amount'];
@@ -379,7 +383,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
} else {
$output->writeln("<info>A total of {$can_be_updated} out of {$total_donors} can be updated using --update");
}
-
} else if ($update_status) {
$filter = [
@@ -418,7 +421,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
while ($donors = Donor::getList($filter, $offset, $limit)) {
- foreach($donors as $donor) {
+ foreach ($donors as $donor) {
++$donors_treated;
if ($donor->status != Donor::PENDING)
@@ -434,7 +437,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
$output->writeln("<info>Update {$donor->id} - {$donor->name} - {$donor->nif} can change it's status .</info>");
$progress_bar->display();
}
-
} else {
$donors_with_errors++;
if ($verbose_debug) {
@@ -462,7 +464,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
} else {
if ($verbose || $verbose_debug) {
$progress_bar->clear();
- $output->writeln("<error> {$donor->id} - {$donor->name} - {$donor->nif}. ". implode(',', $errors) . "</error>");
+ $output->writeln("<error> {$donor->id} - {$donor->name} - {$donor->nif}. " . implode(',', $errors) . "</error>");
$progress_bar->display();
}
}
@@ -480,7 +482,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
$progress_bar->advance();
}
- $offset+=$limit;
+ $offset += $limit;
}
$progress_bar->finish();
$total_donors += $total;
@@ -491,7 +493,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
$output->writeln("<info>A total of {$updated_donors} out of {$total_donors} have been updated.</info>");
$output->writeln("<info>A total of {$donors_with_errors} out of {$total_donors} have errors.</info>");
$output->writeln("<info>A total of {$donor_without_amount} out of {$total_donors} have no amount.</info>");
-
} else {
$output->writeln("<info>A total of {$donors_treated} out of {$total_donors} have been treated");
$output->writeln("<info>A total of {$can_be_updated} out of {$total_donors} can be updated using --update");
@@ -503,11 +504,81 @@ protected function execute(InputInterface $input, OutputInterface $output)
} else if ($unify) {
$this->info("Starting unification of certificates");
$this->unifyCertificates($input, $output);
+ } else if ($update_invests) {
+ return $this->update_invests($input, $output);
}
+ }
+
+ private function update_invests(InputInterface $input, OutputInterface $output): void
+ {
+
+ $year = $input->getOption('year');
+ $user = $input->getOption('user');
+ $donor = $input->getOption('donor');
+ $update = $input->getOption('update');
+
+ if (!$update)
+ throw new InvalidArgumentException('This command can only be executed with the update option');
+
+ $filters = [
+ 'show_empty' => true
+ ];
+
+ if ($year)
+ $filters['year'] = $year;
+
+ if ($user) {
+ $user = User::get($user);
+ $filters['user'] = $user;
+ }
+
+ if ($donor) {
+ $donor = Donor::get($donor);
+
+ $output->writeln("<info>Going to update certificate {$donor->id}</info>");
+
+ $valid = $donor->updateInvestions();
+ if (!$valid)
+ $output->writeln("<error>Could not update certificate {$donor->id}</error>");
+ else
+ $output->writeln("Certificate updated!");
+ return;
+ }
+
+ $certificatesToTreat = Donor::getList($filters, 0, 0, true);
+
+ $progress_bar = new ProgressBar($output, $certificatesToTreat);
+ $progress_bar->start();
+
+ $certificatesUpdated = 0;
+
+ $page = 0;
+ $limit = 500;
+
+
+ while ($donors = Donor::getList($filters, $page * $limit, $limit)) {
+ foreach ($donors as $donor) {
+ $this->writeToOutputWithProgressBar($output, $progress_bar, "<info>Going to update the investions for certificate {$donor->id}, {$donor->user->id}</info>");
+ $valid = $donor->updateInvestions();
+ if ($valid) {
+ $certificatesUpdated++;
+ } else {
+ $this->writeToOutputWithProgressBar($output, $progress_bar, "<error>Could not update certificate {$donor->id}</error>");
+ }
+
+ $progress_bar->advance();
+ }
+ ++$page;
+ }
+ $progress_bar->finish();
+ $output->writeln('');
+
+ $output->writeln("<info>A total of $certificatesUpdated out of $certificatesToTreat donors that have been treated");
}
- private function unifyCertificates(InputInterface $input, OutputInterface $output) {
+ private function unifyCertificates(InputInterface $input, OutputInterface $output)
+ {
$year = $input->getOption('year');
if (!$year)
throw new InvalidArgumentException('If you want to unify certificates you have to specify a year');
@@ -529,7 +600,7 @@ private function unifyCertificates(InputInterface $input, OutputInterface $outpu
$certificatesCreated = 0;
- while($donors = Donor::getList(['year' => $year, 'donor_status' => Donor::PENDING], $page * $limit - $certificatesCreated, $limit)) {
+ while ($donors = Donor::getList(['year' => $year, 'donor_status' => Donor::PENDING], $page * $limit - $certificatesCreated, $limit)) {
foreach ($donors as $donor) {
if ($this->unifyUserCertificates($donor->user, $year, $input, $output))
$certificatesCreated++;
@@ -650,4 +721,11 @@ private function supersedeOldCertificates(array $certificates, Donor $newCertifi
}
}
}
+
+ private function writeToOutputWithProgressBar(OutputInterface $output, ProgressBar $progress_bar, string $text)
+ {
+ $progress_bar->clear();
+ $output->writeln($text);
+ $progress_bar->display();
+ }
}