mirror of
https://github.com/NNTmux/newznab-tmux.git
synced 2026-08-29 01:08:56 +00:00
Merge branch 'dev' into dev-release_groups
This commit is contained in:
@@ -1282,22 +1282,18 @@ class ProcessReleases
|
||||
|
||||
if ($this->crossPostTime != 0) {
|
||||
// Crossposted releases.
|
||||
do {
|
||||
$releases = $this->pdo->queryDirect(
|
||||
sprintf(
|
||||
'SELECT id, guid FROM releases WHERE adddate > (NOW() - INTERVAL %d HOUR) GROUP BY name HAVING COUNT(name) > 1',
|
||||
$this->crossPostTime
|
||||
)
|
||||
);
|
||||
$total = 0;
|
||||
if ($releases && $releases->rowCount()) {
|
||||
$total = $releases->rowCount();
|
||||
foreach ($releases as $release) {
|
||||
$this->releases->deleteSingle(['g' => $release['guid'], 'i' => $release['id']], $this->nzb, $this->releaseImage);
|
||||
$duplicateDeleted++;
|
||||
}
|
||||
$releases = $this->pdo->queryDirect(
|
||||
sprintf(
|
||||
'SELECT SQL_NO_CACHE id, guid FROM releases WHERE adddate > (NOW() - INTERVAL %d HOUR) GROUP BY name HAVING COUNT(name) > 1',
|
||||
$this->crossPostTime
|
||||
)
|
||||
);
|
||||
if ($releases instanceof \Traversable) {
|
||||
foreach ($releases as $release) {
|
||||
$this->releases->deleteSingle(['g' => $release['guid'], 'i' => $release['id']], $this->nzb, $this->releaseImage);
|
||||
$duplicateDeleted++;
|
||||
}
|
||||
} while ($total > 0);
|
||||
}
|
||||
}
|
||||
|
||||
if ($this->completion > 0) {
|
||||
|
||||
Reference in New Issue
Block a user