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

fix removeDuplicatePeer()

Browse Source
This commit is contained in:
xiaomlove
2023-06-17 23:46:29 +08:00
parent a145509f0e
commit 1a35db1215
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Console/Commands/Test.php
+4 -2
View File
@@ -97,8 +97,10 @@ class Test extends Command
*/ */
public function handle() public function handle()
{ {
$r = executeCommand("php -r 'var_export(function_exists(\"pcntl_alarm\"));'"); $results = NexusDB::select("select torrent, peer_id, userid, group_concat(id) as ids from peers group by torrent, peer_id, userid having(count(*)) > 1 limit 20");
dd($r == 'true'); dump($results);
$rep = new ToolRepository();
$rep->removeDuplicatePeer();
} }
} }
app/Repositories/ToolRepository.php
+2 -1
View File
@@ -481,8 +481,9 @@ class ToolRepository extends BaseRepository
{ {
$size = 2000; $size = 2000;
while (true) { while (true) {
$results = NexusDB::select("select torrent, peer_id, userid, group_concat(id) as ids from peers group by torrent, peer_id, userid having(count(*)) > 1 limit $size"); $results = NexusDB::select("select torrent, userid, group_concat(id) as ids from peers group by torrent, peer_id, userid having(count(*)) > 1 limit $size");
if (empty($results)) { if (empty($results)) {
do_log("[DELETE_DUPLICATED_PEERS], no data: ". last_query());
break; break;
} }
do_log("[DELETE_DUPLICATED_PEERS], count: " . count($results)); do_log("[DELETE_DUPLICATED_PEERS], count: " . count($results));