0ct0pu5/forkbb
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Update Post\View

Browse source
This commit is contained in:
Visman 2020-06-06 22:42:59 +07:00
parent 702a925ae4
commit fed6a640cd
1 changed files with 9 additions and 131 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

140
app/Models/Post/View.php
View file

@ -3,69 +3,15 @@
namespace ForkBB\Models\Post;
use ForkBB\Models\Action;
use ForkBB\Models\Post\Model as Post;
use ForkBB\Models\Search\Model as Search;
use ForkBB\Models\Topic\Model as Topic;
use ForkBB\Models\User\Model as User;
use PDO;
use InvalidArgumentException;
use RuntimeException;
class View extends Action
{
protected $aliases;
protected function queryFields(array $args): string
{
$result = [];
$fields = [];
$aliases = [];
foreach ($args as $alias => $rawFields) {
$aliases[$alias] = [];
foreach ($rawFields as $originalName => $replName) {
if (null === $replName || false === $replName) {
continue;
}
$name = $alias . '.' . $originalName;
if (true === $replName && isset($fields[$originalName])) {
$replName = "alias_{$alias}_{$originalName}";
$result[] = $name . ' AS '. $replName;
$aliases[$alias][$replName] = $originalName;
$fields[$replName] = $alias;
} elseif (true === $replName) {
$result[] = $name;
$aliases[$alias][$originalName] = true;
$fields[$originalName] = $alias;
} else {
$result[] = $name . ' AS '. $replName;
$aliases[$alias][$replName] = $replName; //???? $originalName;
$fields[$replName] = $alias;
}
}
}
$this->aliases = $aliases;
return \implode(', ', $result);
}
protected function setData(array $args, array $data): void
{
foreach ($args as $aliases => $model) {
$attrs = [];
foreach (\explode('.', $aliases) as $alias) {
if (empty($this->aliases[$alias])) {
continue;
}
foreach ($this->aliases[$alias] as $key => $repl) {
$name = true === $repl ? $key : $repl;
$attrs[$name] = $data[$key];
}
}
$model->setAttrs($attrs);
}
}
/**
* Возвращает список сообщений
*
@ -98,87 +44,18 @@ class View extends Action
}
$userIds = [];
$result = \array_flip($arg->idsList);
$result = $this->manager->loadByIds($arg->idsList, ! $arg instanceof Topic);
if ($arg instanceof Topic) {
$vars = [
':ids' => $arg->idsList,
];
$sql = 'SELECT p.*
FROM ::posts AS p
WHERE p.id IN (?ai:ids)';
$stmt = $this->c->DB->query($sql, $vars);
while ($row = $stmt->fetch()) {
$post = $this->manager->create($row);
if (isset($warnings[$row['id']])) {
$post->__warnings = $warnings[$row['id']];
}
$userIds[$post->poster_id] = true;
$result[$post->id] = $post;
}
} else {
if ($this->c->user->isGuest) {
$vars = [
':ids' => $arg->idsList,
':fields' => $this->queryFields([
'p' => \array_map(function($val) {return true;}, $this->c->dbMap->posts), // все поля в true
't' => \array_map(function($val) {return true;}, $this->c->dbMap->topics), // все поля в true
]),
];
$sql = 'SELECT ?p:fields
FROM ::posts AS p
INNER JOIN ::topics AS t ON t.id=p.topic_id
WHERE p.id IN (?ai:ids)';
} else {
$vars = [
':ids' => $arg->idsList,
':uid' => $this->c->user->id,
':fields' => $this->queryFields([
'p' => \array_map(function($val) {return true;}, $this->c->dbMap->posts), // все поля в true
't' => \array_map(function($val) {return true;}, $this->c->dbMap->topics), // все поля в true
# 's' => ['user_id' => 'is_subscribed'],
'mof' => ['mf_mark_all_read' => true],
'mot' => ['mt_last_visit' => true, 'mt_last_read' => true],
]),
];
$sql = 'SELECT ?p:fields
FROM ::posts AS p
INNER JOIN ::topics AS t ON t.id=p.topic_id
LEFT JOIN ::mark_of_forum AS mof ON (mof.uid=?i:uid AND t.forum_id=mof.fid)
LEFT JOIN ::mark_of_topic AS mot ON (mot.uid=?i:uid AND t.id=mot.tid)
WHERE p.id IN (?ai:ids)';
# LEFT JOIN ::topic_subscriptions AS s ON (t.id=s.topic_id AND s.user_id=?i:uid)
}
$stmt = $this->c->DB->query($sql, $vars);
while ($row = $stmt->fetch()) {
$post = $this->manager->create();
$topic = $this->c->topics->create();
$this->setData(['p' => $post, 't.s.mof.mot' => $topic], $row);
if (isset($warnings[$row['id']])) {
$post->__warnings = $warnings[$row['id']];
}
$userIds[$post->poster_id] = true;
$result[$post->id] = $post;
if (! $this->c->topics->get($topic->id)) {
$this->c->topics->set($topic->id, $topic);
foreach ($result as $post) {
if ($post instanceof Post) {
if (isset($warnings[$post->id])) {
$post->__warnings = $warnings[$post->id];
}
$userIds[$post->poster_id] = $post->poster_id;
}
}
$ids = \array_keys($userIds);
$this->c->users->loadByIds($ids);
$this->c->users->loadByIds($userIds);
$offset = ($arg->page - 1) * $this->c->user->disp_posts;
$timeMax = 0;
@ -220,6 +97,7 @@ class View extends Action
$post->__postNumber = $offset + $postCount; //????
}
}
return $result;
}
}