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

count_peer() support custom field

Browse Source
This commit is contained in:
xiaomlove
2022-04-20 02:44:28 +08:00
parent 41ea4fd2a1
commit 7a79673669
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/functions.php
+2 -2
View File
@@ -2553,12 +2553,12 @@ else {
//// check every 60 seconds ////////////////// //// check every 60 seconds //////////////////
$activeseed = $Cache->get_value('user_'.$CURUSER["id"].'_active_seed_count'); $activeseed = $Cache->get_value('user_'.$CURUSER["id"].'_active_seed_count');
if ($activeseed == ""){ if ($activeseed == ""){
$activeseed = count_peer(sprintf("userid = %s and seeder = 'yes'", $CURUSER['id'])); $activeseed = count_peer(sprintf("userid = %s and seeder = 'yes'", $CURUSER['id']), 'torrent');
$Cache->cache_value('user_'.$CURUSER["id"].'_active_seed_count', $activeseed, 60); $Cache->cache_value('user_'.$CURUSER["id"].'_active_seed_count', $activeseed, 60);
} }
$activeleech = $Cache->get_value('user_'.$CURUSER["id"].'_active_leech_count'); $activeleech = $Cache->get_value('user_'.$CURUSER["id"].'_active_leech_count');
if ($activeleech == ""){ if ($activeleech == ""){
$activeleech = count_peer(sprintf("userid = %s and seeder = 'no'", $CURUSER['id'])); $activeleech = count_peer(sprintf("userid = %s and seeder = 'no'", $CURUSER['id']), 'torrent');
$Cache->cache_value('user_'.$CURUSER["id"].'_active_leech_count', $activeleech, 60); $Cache->cache_value('user_'.$CURUSER["id"].'_active_leech_count', $activeleech, 60);
} }
$unread = $Cache->get_value('user_'.$CURUSER["id"].'_unread_message_count'); $unread = $Cache->get_value('user_'.$CURUSER["id"].'_unread_message_count');
include/globalfunctions.php
+3 -3
View File
@@ -705,20 +705,20 @@ function isIPV6 ($ip)
return filter_var($ip,FILTER_VALIDATE_IP, FILTER_FLAG_IPV6); return filter_var($ip,FILTER_VALIDATE_IP, FILTER_FLAG_IPV6);
} }
function count_peer($whereStr) function count_peer($whereStr, $field = 'peer_id')
{ {
if (empty($whereStr)) { if (empty($whereStr)) {
throw new \InvalidArgumentException("require whereStr"); throw new \InvalidArgumentException("require whereStr");
} }
if (IN_NEXUS) { if (IN_NEXUS) {
$sql = "select count(distinct(peer_id)) as counts from peers where $whereStr"; $sql = "select count(distinct($field)) as counts from peers where $whereStr";
$res = sql_query($sql); $res = sql_query($sql);
$count = mysql_fetch_assoc($res); $count = mysql_fetch_assoc($res);
return $count['counts']; return $count['counts'];
} else { } else {
$res = \Illuminate\Support\Facades\DB::table('peers') $res = \Illuminate\Support\Facades\DB::table('peers')
->whereRaw($whereStr) ->whereRaw($whereStr)
->selectRaw("count(distinct(peer_id)) as counts") ->selectRaw("count(distinct($field)) as counts")
->first(); ->first();
return $res->counts; return $res->counts;
} }
public/getusertorrentlistajax.php
+2 -2
View File
@@ -195,7 +195,7 @@ switch ($type)
// Current Seeding // Current Seeding
case 'seeding': case 'seeding':
{ {
$res = sql_query("SELECT torrent,added,snatched.uploaded,snatched.downloaded,torrents.name as torrentname, torrents.small_descr, torrents.sp_state, categories.name as catname,size,torrents.hr,image,category,seeders,leechers FROM peers LEFT JOIN torrents ON peers.torrent = torrents.id LEFT JOIN categories ON torrents.category = categories.id LEFT JOIN snatched ON torrents.id = snatched.torrentid WHERE peers.userid=$id AND snatched.userid = $id AND peers.seeder='yes' group by peers.peer_id ORDER BY torrents.added DESC") or sqlerr(); $res = sql_query("SELECT torrent,added,snatched.uploaded,snatched.downloaded,torrents.name as torrentname, torrents.small_descr, torrents.sp_state, categories.name as catname,size,torrents.hr,image,category,seeders,leechers FROM peers LEFT JOIN torrents ON peers.torrent = torrents.id LEFT JOIN categories ON torrents.category = categories.id LEFT JOIN snatched ON torrents.id = snatched.torrentid WHERE peers.userid=$id AND snatched.userid = $id AND peers.seeder='yes' group by peers.torrent ORDER BY torrents.added DESC") or sqlerr();
$count = mysql_num_rows($res); $count = mysql_num_rows($res);
if ($count > 0){ if ($count > 0){
list($torrentlist, $total_size) = maketable ( $res, 'seeding' ); list($torrentlist, $total_size) = maketable ( $res, 'seeding' );
@@ -206,7 +206,7 @@ switch ($type)
// Current Leeching // Current Leeching
case 'leeching': case 'leeching':
{ {
$res = sql_query("SELECT torrent,snatched.uploaded,snatched.downloaded,torrents.name as torrentname, torrents.small_descr, torrents.sp_state, categories.name as catname,size,torrents.hr,image,category,seeders,leechers FROM peers LEFT JOIN torrents ON peers.torrent = torrents.id LEFT JOIN categories ON torrents.category = categories.id LEFT JOIN snatched ON torrents.id = snatched.torrentid WHERE peers.userid=$id AND snatched.userid = $id AND peers.seeder='no' group by peers.peer_id ORDER BY torrents.added DESC") or sqlerr(); $res = sql_query("SELECT torrent,snatched.uploaded,snatched.downloaded,torrents.name as torrentname, torrents.small_descr, torrents.sp_state, categories.name as catname,size,torrents.hr,image,category,seeders,leechers FROM peers LEFT JOIN torrents ON peers.torrent = torrents.id LEFT JOIN categories ON torrents.category = categories.id LEFT JOIN snatched ON torrents.id = snatched.torrentid WHERE peers.userid=$id AND snatched.userid = $id AND peers.seeder='no' group by peers.torrent ORDER BY torrents.added DESC") or sqlerr();
$count = mysql_num_rows($res); $count = mysql_num_rows($res);
if ($count > 0){ if ($count > 0){
list($torrentlist, $total_size) = maketable ( $res, 'leeching' ); list($torrentlist, $total_size) = maketable ( $res, 'leeching' );