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 stassmess

Browse Source
This commit is contained in:
xiaomlove
2022-08-11 23:41:11 +08:00
parent 1d5d53a123
commit 4652b3395b
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
public/takestaffmess.php
+3 -5
View File
@@ -30,18 +30,16 @@ $page = 1;
set_time_limit(300); set_time_limit(300);
$classStr = implode(",", $updateset); $classStr = implode(",", $updateset);
while (true) { while (true) {
$msgValues = $idArr = []; $msgValues = [];
$offset = ($page - 1) * $size; $offset = ($page - 1) * $size;
$query = sql_query("SELECT id FROM users WHERE class IN (".implode(",", $updateset).") and `enabled` = 'yes' and `status` = 'confirmed'"); $query = sql_query("SELECT id FROM users WHERE class IN ($classStr) and `enabled` = 'yes' and `status` = 'confirmed' limit $offset, $size");
while($dat=mysql_fetch_assoc($query)) while($dat=mysql_fetch_assoc($query))
{ {
$idArr[] = $dat['id'];
$msgValues[] = sprintf('(%s, %s, %s, %s, %s)', $sender_id, $dat['id'], $dt, sqlesc($subject), sqlesc($msg)); $msgValues[] = sprintf('(%s, %s, %s, %s, %s)', $sender_id, $dat['id'], $dt, sqlesc($subject), sqlesc($msg));
} }
if (empty($idArr)) { if (empty($msgValues)) {
break; break;
} }
$idStr = implode(', ', $idArr);
$sql = "INSERT INTO messages (sender, receiver, added, subject, msg) VALUES " . implode(', ', $msgValues); $sql = "INSERT INTO messages (sender, receiver, added, subject, msg) VALUES " . implode(', ', $msgValues);
sql_query($sql); sql_query($sql);
$page++; $page++;