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

announce update torrent seeders/leechers revert to only increment/decrement

Browse Source
This commit is contained in:
xiaomlove
2024-11-04 13:09:25 +08:00
parent 70dab3e8c5
commit 22671691aa
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
public/announce.php
+8 -8
View File
@@ -523,7 +523,7 @@ if (isset($self) && $event == "stopped")
sql_query("DELETE FROM peers WHERE id = {$self['id']}") or err("D Err"); sql_query("DELETE FROM peers WHERE id = {$self['id']}") or err("D Err");
if (mysql_affected_rows() && !empty($snatchInfo)) if (mysql_affected_rows() && !empty($snatchInfo))
{ {
// $updateset[] = ($self["seeder"] == "yes" ? "seeders = seeders - 1" : "leechers = leechers - 1"); $updateset[] = ($self["seeder"] == "yes" ? "seeders = seeders - 1" : "leechers = leechers - 1");
$hasChangeSeederLeecher = true; $hasChangeSeederLeecher = true;
sql_query("UPDATE snatched SET uploaded = uploaded + $trueupthis, downloaded = downloaded + $truedownthis, to_go = $left, $announcetime, last_action = ".$dt." WHERE id = {$snatchInfo['id']}") or err("SL Err 1"); sql_query("UPDATE snatched SET uploaded = uploaded + $trueupthis, downloaded = downloaded + $truedownthis, to_go = $left, $announcetime, last_action = ".$dt." WHERE id = {$snatchInfo['id']}") or err("SL Err 1");
} }
@@ -544,7 +544,7 @@ elseif(isset($self))
if (mysql_affected_rows()) if (mysql_affected_rows())
{ {
if ($seeder <> $self["seeder"]) { if ($seeder <> $self["seeder"]) {
// $updateset[] = ($seeder == "yes" ? "seeders = seeders + 1, leechers = leechers - 1" : "seeders = seeders - 1, leechers = leechers + 1"); $updateset[] = ($seeder == "yes" ? "seeders = seeders + 1, leechers = leechers - 1" : "seeders = seeders - 1, leechers = leechers + 1");
$hasChangeSeederLeecher = true; $hasChangeSeederLeecher = true;
} }
if (!empty($snatchInfo)) { if (!empty($snatchInfo)) {
@@ -566,7 +566,7 @@ else
sql_query($insertPeerSql) or err("PL Err 2"); sql_query($insertPeerSql) or err("PL Err 2");
if (mysql_affected_rows()) if (mysql_affected_rows())
{ {
// $updateset[] = ($seeder == "yes" ? "seeders = seeders + 1" : "leechers = leechers + 1"); $updateset[] = ($seeder == "yes" ? "seeders = seeders + 1" : "leechers = leechers + 1");
$hasChangeSeederLeecher = true; $hasChangeSeederLeecher = true;
// $check = @mysql_fetch_row(@sql_query("SELECT COUNT(*) FROM snatched WHERE torrentid = $torrentid AND userid = $userid")); // $check = @mysql_fetch_row(@sql_query("SELECT COUNT(*) FROM snatched WHERE torrentid = $torrentid AND userid = $userid"));
$checkSnatchedRes = mysql_fetch_assoc(sql_query("SELECT id FROM snatched WHERE torrentid = $torrentid AND userid = $userid limit 1")); $checkSnatchedRes = mysql_fetch_assoc(sql_query("SELECT id FROM snatched WHERE torrentid = $torrentid AND userid = $userid limit 1"));
@@ -626,11 +626,11 @@ if (($left > 0 || $event == "completed") && $az['class'] < \App\Models\HitAndRun
do_log("$hrLog, not match", "debug"); do_log("$hrLog, not match", "debug");
} }
} }
// revert to only increment/decrement
if (isset($event) && !empty($event)) { //if (isset($event) && !empty($event)) {
$updateset[] = 'seeders = ' . get_row_count("peers", "where torrent = $torrentid and to_go = 0"); // $updateset[] = 'seeders = ' . get_row_count("peers", "where torrent = $torrentid and to_go = 0");
$updateset[] = 'leechers = ' . get_row_count("peers", "where torrent = $torrentid and to_go > 0"); // $updateset[] = 'leechers = ' . get_row_count("peers", "where torrent = $torrentid and to_go > 0");
} //}
if (count($updateset) || $hasChangeSeederLeecher) // Update only when there is change in peer counts if (count($updateset) || $hasChangeSeederLeecher) // Update only when there is change in peer counts
{ {