add quota renewal
This commit is contained in:
parent
9b7fb75eec
commit
4c47de3fc5
|
@ -180,4 +180,14 @@ namespace controllers\internals;
|
|||
$internal_quota = new \controllers\internals\Quota($bdd);
|
||||
$internal_quota->alerting_for_limit_close_and_reached();
|
||||
}
|
||||
|
||||
/**
|
||||
* Do quota renewal
|
||||
*/
|
||||
public function renew_quotas()
|
||||
{
|
||||
$bdd = \descartes\Model::_connect(DATABASE_HOST, DATABASE_NAME, DATABASE_USER, DATABASE_PASSWORD, 'UTF8');
|
||||
$internal_quota = new \controllers\internals\Quota($bdd);
|
||||
$internal_quota->renew_quotas();
|
||||
}
|
||||
}
|
||||
|
|
|
@ -59,21 +59,21 @@ class Quota extends StandardController
|
|||
* @param \DateTime $start_date : Starting date for the quota
|
||||
* @param ?\DateTime $expiration_date (optional) : Ending date for the quota
|
||||
* @param bool $auto_renew (optional) : Should the quota be automatically renewed after expiration_date
|
||||
* @param ?\DateInterval $renew_interval (optional) : Period to use for setting expiration_date on renewal
|
||||
* @param ?string $renew_interval (optional) : Period to use for setting expiration_date on renewal
|
||||
* @param int $additional (optional) : Additionals credits
|
||||
* @param int $consumed (optional) : Number of consumed credits
|
||||
*
|
||||
* @return mixed bool|int : False if cannot create smsstop, id of the new smsstop else
|
||||
*/
|
||||
public function update_for_user(int $id_user, int $id_quota, int $credit, bool $report_unused, bool $report_unused_additional, \DateTime $start_date, ?\DateTime $expiration_date = null, bool $auto_renew= false, ?\DateInterval $renew_interval = null, int $additional = 0, int $consumed = 0)
|
||||
public function update_for_user(int $id_user, int $id_quota, int $credit, bool $report_unused, bool $report_unused_additional, \DateTime $start_date, ?\DateTime $expiration_date = null, bool $auto_renew= false, ?string $renew_interval = null, int $additional = 0, int $consumed = 0)
|
||||
{
|
||||
$expiration_date = $expiration_date === null ? $expiration_date : $expiration_date->format('Y-m-d H:i:s');
|
||||
|
||||
$quota = [
|
||||
'id_user' => $id_user,
|
||||
'id_quota' => $id_quota,
|
||||
'credit' => $credit,
|
||||
'report_unused' => $report_unused,
|
||||
'report_unused_additional' => $report_unused_additional,
|
||||
'start_date' => $start_date,
|
||||
'start_date' => $start_date->format('Y-m-d H:i:s'),
|
||||
'expiration_date' => $expiration_date,
|
||||
'auto_renew' => $auto_renew,
|
||||
'renew_interval' => $renew_interval,
|
||||
|
@ -81,7 +81,7 @@ class Quota extends StandardController
|
|||
'consumed' => $consumed,
|
||||
];
|
||||
|
||||
return $this->get_model()->insert($quota);
|
||||
return $this->get_model()->update_for_user($id_user, $id_quota, $quota);
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -229,6 +229,56 @@ class Quota extends StandardController
|
|||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Do quota renewing
|
||||
*/
|
||||
public function renew_quotas ()
|
||||
{
|
||||
$internal_user = new User($this->bdd);
|
||||
$internal_event = new Event($this->bdd);
|
||||
$quotas = $this->get_model()->get_quotas_to_be_renewed(new \DateTime());
|
||||
|
||||
foreach ($quotas as $quota)
|
||||
{
|
||||
$user = $internal_user->get($quota['id_user']);
|
||||
|
||||
if (!$user)
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
$unused_credit = $quota['credit'] - $quota['consumed'];
|
||||
$unused_additional = $unused_credit > 0 ? $quota['additional'] : $quota['additional'] + $unused_credit;
|
||||
|
||||
$renew_interval = $quota['renew_interval'] ?? 'P0D';
|
||||
$new_start_date = new \DateTime($quota['expiration_date']);
|
||||
$new_expiration_date = clone $new_start_date;
|
||||
$new_expiration_date->add(new \DateInterval($quota['renew_interval']));
|
||||
|
||||
$report = 0;
|
||||
if ($quota['report_unused'] && $unused_credit > 0)
|
||||
{
|
||||
$report += $unused_credit;
|
||||
}
|
||||
|
||||
if ($quota['report_unused_additional'] && $unused_additional > 0)
|
||||
{
|
||||
$report += $unused_additional;
|
||||
}
|
||||
|
||||
$success = $this->update_for_user($user['id'], $quota['id'], $quota['credit'], $quota['report_unused'], $quota['report_unused_additional'], $new_start_date, $new_expiration_date, $quota['auto_renew'], $quota['renew_interval'], $report, 0);
|
||||
|
||||
if (!$success)
|
||||
{
|
||||
echo "Cannot update quota : " . $quota['id'] . "\n";
|
||||
continue;
|
||||
}
|
||||
|
||||
echo "Update quota : " . $quota['id'] . "\n";
|
||||
$internal_event->create($quota['id_user'], 'QUOTA_RENEWAL', 'Renew quota ' . $quota['id'] . ' report ' . $report . ' credits.');
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Get the model for the Controller.
|
||||
*/
|
||||
|
|
|
@ -89,6 +89,7 @@ namespace models;
|
|||
|
||||
/**
|
||||
* Get all quotas we need to send an alert for close limit to users they belongs to
|
||||
* do not return quotas when user already had an event QUOTA_LIMIT_CLOSE since quota start_date
|
||||
* @return array
|
||||
*/
|
||||
public function get_quotas_for_limit_close() : array
|
||||
|
@ -124,6 +125,7 @@ namespace models;
|
|||
|
||||
/**
|
||||
* Get all quotas we need to send an alert for limit reached to users they belongs to
|
||||
* do not return quotas when user already had an event QUOTA_LIMIT_REACHED since quota start_date
|
||||
* @return array
|
||||
*/
|
||||
public function get_quotas_for_limit_reached() : array
|
||||
|
@ -157,6 +159,23 @@ namespace models;
|
|||
return $this->_run_query($query, $params);
|
||||
}
|
||||
|
||||
/**
|
||||
* Get list of quotas to be renewed as to a date
|
||||
* @param \DateTime $at : Date to get quotas to be renewed before
|
||||
* @return array
|
||||
*/
|
||||
public function get_quotas_to_be_renewed (\DateTime $at): array
|
||||
{
|
||||
$at = $at->format('Y-m-d H:i:s');
|
||||
$where = [
|
||||
'!=expiration_date' => null,
|
||||
'<=expiration_date' => $at,
|
||||
'auto_renew' => true,
|
||||
];
|
||||
|
||||
return $this->_select('quota', $where);
|
||||
}
|
||||
|
||||
/**
|
||||
* Return table name.
|
||||
*/
|
||||
|
|
Loading…
Reference in New Issue