lkddi/nexusphp
1
0
Fork 0
mirror of https://github.com/lkddi/nexusphp.git synced 2026-04-26 21:37:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

del invalid claim

Browse Source
This commit is contained in:
xiaomlove
2023-07-04 01:16:06 +08:00
parent 7186fda362
commit a7d007053b
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Repositories/ClaimRepository.php
+15
View File
@@ -184,6 +184,7 @@ class ClaimRepository extends BaseRepository
$reachedTorrentIdArr = $unReachedTorrentIdArr = $remainTorrentIdArr = $unReachedIdArr = $toUpdateIdArr = []; $reachedTorrentIdArr = $unReachedTorrentIdArr = $remainTorrentIdArr = $unReachedIdArr = $toUpdateIdArr = [];
$totalSeedTime = 0; $totalSeedTime = 0;
$seedTimeCaseWhen = $uploadedCaseWhen = []; $seedTimeCaseWhen = $uploadedCaseWhen = [];
$toDelClaimId = [];
do_log( do_log(
"uid: $uid, claim torrent count: " . $list->count() "uid: $uid, claim torrent count: " . $list->count()
. ", seedTimeRequiredHours: $seedTimeRequiredHours" . ", seedTimeRequiredHours: $seedTimeRequiredHours"
@@ -199,6 +200,16 @@ class ClaimRepository extends BaseRepository
return false; return false;
} }
} }
if (!$row->snatch) {
$toDelClaimId[$row->id] = $row->id;
do_log("No snatch, continue", 'alert');
continue;
}
if (!$row->torrent) {
$toDelClaimId[$row->id] = $row->id;
do_log("No torrent, continue", 'alert');
continue;
}
if ( if (
bcsub($row->snatch->seedtime, $row->seed_time_begin) >= $seedTimeRequiredHours * 3600 bcsub($row->snatch->seedtime, $row->seed_time_begin) >= $seedTimeRequiredHours * 3600
|| bcsub($row->snatch->uploaded, $row->uploaded_begin) >= $uploadedRequiredTimes * $row->torrent->size || bcsub($row->snatch->uploaded, $row->uploaded_begin) >= $uploadedRequiredTimes * $row->torrent->size
@@ -276,6 +287,10 @@ class ClaimRepository extends BaseRepository
//Send message //Send message
Message::add($message); Message::add($message);
}); });
if (!empty($toDelClaimId)) {
do_log("del claim: %s", json_encode($toDelClaimId));
Claim::query()->whereIn("id", array_keys($toDelClaimId))->delete();
}
do_log("[DONE], cost time: " . (time() - $now->timestamp) . " seconds"); do_log("[DONE], cost time: " . (time() - $now->timestamp) . " seconds");
return true; return true;
} }