56 lines
1.5 KiB
PHP
56 lines
1.5 KiB
PHP
<?php
|
|
|
|
namespace ForkBB\Models\User;
|
|
|
|
use ForkBB\Models\Action;
|
|
use ForkBB\Models\User\Model as User;
|
|
use InvalidArgumentException;
|
|
|
|
class UpdateCountPosts extends Action
|
|
{
|
|
/**
|
|
* Обновляет число сообщений пользователя(ей)
|
|
*
|
|
* @param mixed ...$args
|
|
*
|
|
* @throws InvalidArgumentException
|
|
*/
|
|
public function updateCountPosts(...$args)
|
|
{
|
|
$ids = [];
|
|
foreach ($args as $arg) {
|
|
if ($arg instanceof User) {
|
|
$ids[$arg->id] = true;
|
|
} elseif (is_int($arg) && $arg > 0) {
|
|
$ids[$arg] = true;
|
|
} else {
|
|
throw new InvalidArgumentException('Expected user or positive integer id');
|
|
}
|
|
}
|
|
// сообщения гостя не считаем
|
|
unset($ids[1]);
|
|
|
|
if (empty($ids)) {
|
|
$where = 'u.id != 1';
|
|
$vars = [];
|
|
} else {
|
|
$where = 'u.id IN (?ai:ids)';
|
|
$vars = [
|
|
':ids' => \array_keys($ids),
|
|
];
|
|
}
|
|
|
|
$sql = 'UPDATE ::users AS u
|
|
SET u.num_posts = (
|
|
SELECT COUNT(p.id)
|
|
FROM ::posts AS p
|
|
INNER JOIN ::topics AS t ON t.id=p.topic_id
|
|
INNER JOIN ::forums AS f ON f.id=t.forum_id
|
|
WHERE p.poster_id=u.id AND f.no_sum_mess=0
|
|
GROUP BY p.poster_id
|
|
)
|
|
WHERE ' . $where;
|
|
|
|
$this->c->DB->exec($sql, $vars);
|
|
}
|
|
}
|