mirror of
https://github.com/lkddi/nexusphp.git
synced 2026-04-27 14:17:23 +08:00
fix H&R unreach disable user duplicate
This commit is contained in:
@@ -95,6 +95,7 @@ class HitAndRunRepository extends BaseRepository
|
|||||||
$query->where('created_at', '<', Carbon::now()->subHours($setting['inspect_time']));
|
$query->where('created_at', '<', Carbon::now()->subHours($setting['inspect_time']));
|
||||||
}
|
}
|
||||||
$successCounts = 0;
|
$successCounts = 0;
|
||||||
|
$disabledUsers = [];
|
||||||
while (true) {
|
while (true) {
|
||||||
$logPrefix = "page: $page, size: $size";
|
$logPrefix = "page: $page, size: $size";
|
||||||
$rows = $query->forPage($page, $size)->get();
|
$rows = $query->forPage($page, $size)->get();
|
||||||
@@ -154,9 +155,10 @@ class HitAndRunRepository extends BaseRepository
|
|||||||
|
|
||||||
//unreached
|
//unreached
|
||||||
if ($row->created_at->addHours($setting['inspect_time'])->lte(Carbon::now())) {
|
if ($row->created_at->addHours($setting['inspect_time'])->lte(Carbon::now())) {
|
||||||
$result = $this->unreached($row);
|
$result = $this->unreached($row, !isset($disabledUsers[$row->uid]));
|
||||||
if ($result) {
|
if ($result) {
|
||||||
$successCounts++;
|
$successCounts++;
|
||||||
|
$disabledUsers[$row->uid] = true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -239,10 +241,9 @@ class HitAndRunRepository extends BaseRepository
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
private function unreached(HitAndRun $hitAndRun): bool
|
private function unreached(HitAndRun $hitAndRun, $disableUser = true): bool
|
||||||
{
|
{
|
||||||
do_log(__METHOD__);
|
do_log(sprintf('hitAndRun: %s, disableUser: %s', $hitAndRun->toJson(), var_export($disableUser, true)));
|
||||||
|
|
||||||
$comment = nexus_trans('hr.unreached_comment', [
|
$comment = nexus_trans('hr.unreached_comment', [
|
||||||
'now' => Carbon::now()->toDateTimeString(),
|
'now' => Carbon::now()->toDateTimeString(),
|
||||||
'seed_time' => bcdiv($hitAndRun->snatch->seedtime, 3600, 1),
|
'seed_time' => bcdiv($hitAndRun->snatch->seedtime, 3600, 1),
|
||||||
@@ -276,6 +277,10 @@ class HitAndRunRepository extends BaseRepository
|
|||||||
];
|
];
|
||||||
Message::query()->insert($message);
|
Message::query()->insert($message);
|
||||||
|
|
||||||
|
if (!$disableUser) {
|
||||||
|
do_log("[DO_NOT_DISABLE_USER], return");
|
||||||
|
return true;
|
||||||
|
}
|
||||||
//disable user
|
//disable user
|
||||||
/** @var User $user */
|
/** @var User $user */
|
||||||
$user = $hitAndRun->user;
|
$user = $hitAndRun->user;
|
||||||
|
|||||||
@@ -72,7 +72,7 @@ class TagRepository extends BaseRepository
|
|||||||
$value->color, $value->font_color, $value->border_radius, $value->font_size, $value->margin, $value->padding, $value->name
|
$value->color, $value->font_color, $value->border_radius, $value->font_size, $value->margin, $value->padding, $value->name
|
||||||
);
|
);
|
||||||
if ($withFilterLink) {
|
if ($withFilterLink) {
|
||||||
$html .= sprintf('<a href="torrents.php?tag_id=%s">%s</a>', $tagId, $item);
|
$html .= sprintf('<a href="?tag_id=%s">%s</a>', $tagId, $item);
|
||||||
} else {
|
} else {
|
||||||
$html .= $item;
|
$html .= $item;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user