1 | <?php |
||
2 | |||
3 | /** |
||
4 | * This file contains the functions required to move topics from one board to |
||
5 | * another board. |
||
6 | * |
||
7 | * Simple Machines Forum (SMF) |
||
8 | * |
||
9 | * @package SMF |
||
10 | * @author Simple Machines https://www.simplemachines.org |
||
11 | * @copyright 2022 Simple Machines and individual contributors |
||
12 | * @license https://www.simplemachines.org/about/smf/license.php BSD |
||
13 | * |
||
14 | * @version 2.1.0 |
||
15 | */ |
||
16 | |||
17 | if (!defined('SMF')) |
||
18 | die('No direct access...'); |
||
19 | |||
20 | /** |
||
21 | * This function allows to move a topic, making sure to ask the moderator |
||
22 | * to give reason for topic move. |
||
23 | * It must be called with a topic specified. (that is, global $topic must |
||
24 | * be set... @todo fix this thing.) |
||
25 | * If the member is the topic starter requires the move_own permission, |
||
26 | * otherwise the move_any permission. |
||
27 | * Accessed via ?action=movetopic. |
||
28 | * |
||
29 | * Uses the MoveTopic template, main sub-template. |
||
30 | */ |
||
31 | function MoveTopic() |
||
32 | { |
||
33 | global $txt, $board, $topic, $user_info, $context, $language, $scripturl, $smcFunc, $modSettings, $sourcedir; |
||
34 | |||
35 | if (empty($topic)) |
||
36 | fatal_lang_error('no_access', false); |
||
37 | |||
38 | $request = $smcFunc['db_query']('', ' |
||
39 | SELECT t.id_member_started, ms.subject, t.approved |
||
40 | FROM {db_prefix}topics AS t |
||
41 | INNER JOIN {db_prefix}messages AS ms ON (ms.id_msg = t.id_first_msg) |
||
42 | WHERE t.id_topic = {int:current_topic} |
||
43 | LIMIT 1', |
||
44 | array( |
||
45 | 'current_topic' => $topic, |
||
46 | ) |
||
47 | ); |
||
48 | list ($id_member_started, $context['subject'], $context['is_approved']) = $smcFunc['db_fetch_row']($request); |
||
49 | $smcFunc['db_free_result']($request); |
||
50 | |||
51 | // Can they see it - if not approved? |
||
52 | if ($modSettings['postmod_active'] && !$context['is_approved']) |
||
53 | isAllowedTo('approve_posts'); |
||
54 | |||
55 | // Permission check! |
||
56 | // @todo |
||
57 | if (!allowedTo('move_any')) |
||
58 | { |
||
59 | if ($id_member_started == $user_info['id']) |
||
60 | { |
||
61 | isAllowedTo('move_own'); |
||
62 | } |
||
63 | else |
||
64 | isAllowedTo('move_any'); |
||
65 | } |
||
66 | |||
67 | $context['move_any'] = $user_info['is_admin'] || $modSettings['topic_move_any']; |
||
68 | $boards = array(); |
||
69 | |||
70 | if (!$context['move_any']) |
||
71 | { |
||
72 | $boards = array_diff(boardsAllowedTo('post_new', true), array($board)); |
||
73 | if (empty($boards)) |
||
74 | { |
||
75 | // No boards? Too bad... |
||
76 | fatal_lang_error('moveto_no_boards'); |
||
77 | } |
||
78 | } |
||
79 | |||
80 | loadTemplate('MoveTopic'); |
||
81 | |||
82 | $options = array( |
||
83 | 'not_redirection' => true, |
||
84 | 'use_permissions' => $context['move_any'], |
||
85 | ); |
||
86 | |||
87 | if (!empty($_SESSION['move_to_topic']) && $_SESSION['move_to_topic'] != $board) |
||
88 | $options['selected_board'] = $_SESSION['move_to_topic']; |
||
89 | |||
90 | if (!$context['move_any']) |
||
91 | $options['included_boards'] = $boards; |
||
92 | |||
93 | require_once($sourcedir . '/Subs-MessageIndex.php'); |
||
94 | $context['categories'] = getBoardList($options); |
||
95 | |||
96 | $context['page_title'] = $txt['move_topic']; |
||
97 | |||
98 | $context['linktree'][] = array( |
||
99 | 'url' => $scripturl . '?topic=' . $topic . '.0', |
||
100 | 'name' => $context['subject'], |
||
101 | ); |
||
102 | |||
103 | $context['linktree'][] = array( |
||
104 | 'name' => $txt['move_topic'], |
||
105 | ); |
||
106 | |||
107 | $context['back_to_topic'] = isset($_REQUEST['goback']); |
||
108 | |||
109 | if ($user_info['language'] != $language) |
||
110 | { |
||
111 | loadLanguage('index', $language); |
||
112 | $temp = $txt['movetopic_default']; |
||
113 | loadLanguage('index'); |
||
114 | |||
115 | $txt['movetopic_default'] = $temp; |
||
116 | } |
||
117 | |||
118 | $context['sub_template'] = 'move'; |
||
119 | |||
120 | moveTopicConcurrence(); |
||
121 | |||
122 | // Register this form and get a sequence number in $context. |
||
123 | checkSubmitOnce('register'); |
||
124 | } |
||
125 | |||
126 | /** |
||
127 | * Execute the move of a topic. |
||
128 | * It is called on the submit of MoveTopic. |
||
129 | * This function logs that topics have been moved in the moderation log. |
||
130 | * If the member is the topic starter requires the move_own permission, |
||
131 | * otherwise requires the move_any permission. |
||
132 | * Upon successful completion redirects to message index. |
||
133 | * Accessed via ?action=movetopic2. |
||
134 | * |
||
135 | * Uses Subs-Post.php |
||
136 | */ |
||
137 | function MoveTopic2() |
||
138 | { |
||
139 | global $txt, $topic, $scripturl, $sourcedir, $context; |
||
140 | global $board, $language, $user_info, $smcFunc; |
||
141 | |||
142 | if (empty($topic)) |
||
143 | fatal_lang_error('no_access', false); |
||
144 | |||
145 | // You can't choose to have a redirection topic and use an empty reason. |
||
146 | if (isset($_POST['postRedirect']) && (!isset($_POST['reason']) || trim($_POST['reason']) == '')) |
||
147 | fatal_lang_error('movetopic_no_reason', false); |
||
148 | |||
149 | moveTopicConcurrence(); |
||
150 | |||
151 | // Make sure this form hasn't been submitted before. |
||
152 | checkSubmitOnce('check'); |
||
153 | |||
154 | $request = $smcFunc['db_query']('', ' |
||
155 | SELECT id_member_started, id_first_msg, approved |
||
156 | FROM {db_prefix}topics |
||
157 | WHERE id_topic = {int:current_topic} |
||
158 | LIMIT 1', |
||
159 | array( |
||
160 | 'current_topic' => $topic, |
||
161 | ) |
||
162 | ); |
||
163 | list ($id_member_started, $id_first_msg, $context['is_approved']) = $smcFunc['db_fetch_row']($request); |
||
164 | $smcFunc['db_free_result']($request); |
||
165 | |||
166 | // Can they see it? |
||
167 | if (!$context['is_approved']) |
||
168 | isAllowedTo('approve_posts'); |
||
169 | |||
170 | // Can they move topics on this board? |
||
171 | if (!allowedTo('move_any')) |
||
172 | { |
||
173 | if ($id_member_started == $user_info['id']) |
||
174 | isAllowedTo('move_own'); |
||
175 | else |
||
176 | isAllowedTo('move_any'); |
||
177 | } |
||
178 | |||
179 | checkSession(); |
||
180 | require_once($sourcedir . '/Subs-Post.php'); |
||
181 | |||
182 | // The destination board must be numeric. |
||
183 | $_POST['toboard'] = (int) $_POST['toboard']; |
||
184 | |||
185 | // Make sure they can see the board they are trying to move to (and get whether posts count in the target board). |
||
186 | $request = $smcFunc['db_query']('', ' |
||
187 | SELECT b.count_posts, b.name, m.subject |
||
188 | FROM {db_prefix}boards AS b |
||
189 | INNER JOIN {db_prefix}topics AS t ON (t.id_topic = {int:current_topic}) |
||
190 | INNER JOIN {db_prefix}messages AS m ON (m.id_msg = t.id_first_msg) |
||
191 | WHERE {query_see_board} |
||
192 | AND b.id_board = {int:to_board} |
||
193 | AND b.redirect = {string:blank_redirect} |
||
194 | LIMIT 1', |
||
195 | array( |
||
196 | 'current_topic' => $topic, |
||
197 | 'to_board' => $_POST['toboard'], |
||
198 | 'blank_redirect' => '', |
||
199 | ) |
||
200 | ); |
||
201 | if ($smcFunc['db_num_rows']($request) == 0) |
||
202 | fatal_lang_error('no_board'); |
||
203 | |||
204 | list ($pcounter, $board_name, $subject) = $smcFunc['db_fetch_row']($request); |
||
205 | $smcFunc['db_free_result']($request); |
||
206 | |||
207 | // Remember this for later. |
||
208 | $_SESSION['move_to_topic'] = $_POST['toboard']; |
||
209 | |||
210 | // Rename the topic... |
||
211 | if (isset($_POST['reset_subject'], $_POST['custom_subject']) && $_POST['custom_subject'] != '') |
||
212 | { |
||
213 | $_POST['custom_subject'] = strtr($smcFunc['htmltrim']($smcFunc['htmlspecialchars']($_POST['custom_subject'])), array("\r" => '', "\n" => '', "\t" => '')); |
||
214 | // Keep checking the length. |
||
215 | if ($smcFunc['strlen']($_POST['custom_subject']) > 100) |
||
216 | $_POST['custom_subject'] = $smcFunc['substr']($_POST['custom_subject'], 0, 100); |
||
217 | |||
218 | // If it's still valid move onwards and upwards. |
||
219 | if ($_POST['custom_subject'] != '') |
||
220 | { |
||
221 | if (isset($_POST['enforce_subject'])) |
||
222 | { |
||
223 | // Get a response prefix, but in the forum's default language. |
||
224 | if (!isset($context['response_prefix']) && !($context['response_prefix'] = cache_get_data('response_prefix'))) |
||
225 | { |
||
226 | if ($language === $user_info['language']) |
||
227 | $context['response_prefix'] = $txt['response_prefix']; |
||
228 | else |
||
229 | { |
||
230 | loadLanguage('index', $language, false); |
||
231 | $context['response_prefix'] = $txt['response_prefix']; |
||
232 | loadLanguage('index'); |
||
233 | } |
||
234 | cache_put_data('response_prefix', $context['response_prefix'], 600); |
||
235 | } |
||
236 | |||
237 | $smcFunc['db_query']('', ' |
||
238 | UPDATE {db_prefix}messages |
||
239 | SET subject = {string:subject} |
||
240 | WHERE id_topic = {int:current_topic}', |
||
241 | array( |
||
242 | 'current_topic' => $topic, |
||
243 | 'subject' => $context['response_prefix'] . $_POST['custom_subject'], |
||
244 | ) |
||
245 | ); |
||
246 | } |
||
247 | |||
248 | $smcFunc['db_query']('', ' |
||
249 | UPDATE {db_prefix}messages |
||
250 | SET subject = {string:custom_subject} |
||
251 | WHERE id_msg = {int:id_first_msg}', |
||
252 | array( |
||
253 | 'id_first_msg' => $id_first_msg, |
||
254 | 'custom_subject' => $_POST['custom_subject'], |
||
255 | ) |
||
256 | ); |
||
257 | |||
258 | // Fix the subject cache. |
||
259 | updateStats('subject', $topic, $_POST['custom_subject']); |
||
260 | } |
||
261 | } |
||
262 | |||
263 | // Create a link to this in the old board. |
||
264 | // @todo Does this make sense if the topic was unapproved before? I'd just about say so. |
||
265 | if (isset($_POST['postRedirect'])) |
||
266 | { |
||
267 | // Replace tokens with links in the reason. |
||
268 | $reason_replacements = array( |
||
269 | $txt['movetopic_auto_board'] => '[url="' . $scripturl . '?board=' . $_POST['toboard'] . '.0"]' . $board_name . '[/url]', |
||
270 | $txt['movetopic_auto_topic'] => '[iurl]' . $scripturl . '?topic=' . $topic . '.0[/iurl]', |
||
271 | ); |
||
272 | |||
273 | // Should be in the boardwide language. |
||
274 | if ($user_info['language'] != $language) |
||
275 | { |
||
276 | loadLanguage('index', $language); |
||
277 | |||
278 | // Make sure we catch both languages in the reason. |
||
279 | $reason_replacements += array( |
||
280 | $txt['movetopic_auto_board'] => '[url="' . $scripturl . '?board=' . $_POST['toboard'] . '.0"]' . $board_name . '[/url]', |
||
281 | $txt['movetopic_auto_topic'] => '[iurl]' . $scripturl . '?topic=' . $topic . '.0[/iurl]', |
||
282 | ); |
||
283 | } |
||
284 | |||
285 | $_POST['reason'] = $smcFunc['htmlspecialchars']($_POST['reason'], ENT_QUOTES); |
||
286 | preparsecode($_POST['reason']); |
||
287 | |||
288 | // Insert real links into the reason. |
||
289 | $_POST['reason'] = strtr($_POST['reason'], $reason_replacements); |
||
290 | |||
291 | // auto remove this MOVED redirection topic in the future? |
||
292 | $redirect_expires = !empty($_POST['redirect_expires']) ? ((int) ($_POST['redirect_expires'] * 60) + time()) : 0; |
||
293 | |||
294 | // redirect to the MOVED topic from topic list? |
||
295 | $redirect_topic = isset($_POST['redirect_topic']) ? $topic : 0; |
||
296 | |||
297 | $msgOptions = array( |
||
298 | 'subject' => $txt['moved'] . ': ' . $subject, |
||
299 | 'body' => $_POST['reason'], |
||
300 | 'icon' => 'moved', |
||
301 | 'smileys_enabled' => 1, |
||
302 | ); |
||
303 | $topicOptions = array( |
||
304 | 'board' => $board, |
||
305 | 'lock_mode' => 1, |
||
306 | 'mark_as_read' => true, |
||
307 | 'redirect_expires' => $redirect_expires, |
||
308 | 'redirect_topic' => $redirect_topic, |
||
309 | ); |
||
310 | $posterOptions = array( |
||
311 | 'id' => $user_info['id'], |
||
312 | 'update_post_count' => empty($pcounter), |
||
313 | ); |
||
314 | createPost($msgOptions, $topicOptions, $posterOptions); |
||
315 | } |
||
316 | |||
317 | $request = $smcFunc['db_query']('', ' |
||
318 | SELECT count_posts |
||
319 | FROM {db_prefix}boards |
||
320 | WHERE id_board = {int:current_board} |
||
321 | LIMIT 1', |
||
322 | array( |
||
323 | 'current_board' => $board, |
||
324 | ) |
||
325 | ); |
||
326 | list ($pcounter_from) = $smcFunc['db_fetch_row']($request); |
||
327 | $smcFunc['db_free_result']($request); |
||
328 | |||
329 | if ($pcounter_from != $pcounter) |
||
330 | { |
||
331 | $request = $smcFunc['db_query']('', ' |
||
332 | SELECT id_member |
||
333 | FROM {db_prefix}messages |
||
334 | WHERE id_topic = {int:current_topic} |
||
335 | AND approved = {int:is_approved}', |
||
336 | array( |
||
337 | 'current_topic' => $topic, |
||
338 | 'is_approved' => 1, |
||
339 | ) |
||
340 | ); |
||
341 | $posters = array(); |
||
342 | while ($row = $smcFunc['db_fetch_assoc']($request)) |
||
343 | { |
||
344 | if (!isset($posters[$row['id_member']])) |
||
345 | $posters[$row['id_member']] = 0; |
||
346 | |||
347 | $posters[$row['id_member']]++; |
||
348 | } |
||
349 | $smcFunc['db_free_result']($request); |
||
350 | |||
351 | foreach ($posters as $id_member => $posts) |
||
352 | { |
||
353 | // The board we're moving from counted posts, but not to. |
||
354 | if (empty($pcounter_from)) |
||
355 | updateMemberData($id_member, array('posts' => 'posts - ' . $posts)); |
||
356 | // The reverse: from didn't, to did. |
||
357 | else |
||
358 | updateMemberData($id_member, array('posts' => 'posts + ' . $posts)); |
||
359 | } |
||
360 | } |
||
361 | |||
362 | // Do the move (includes statistics update needed for the redirect topic). |
||
363 | moveTopics($topic, $_POST['toboard']); |
||
364 | |||
365 | // Log that they moved this topic. |
||
366 | if (!allowedTo('move_own') || $id_member_started != $user_info['id']) |
||
367 | logAction('move', array('topic' => $topic, 'board_from' => $board, 'board_to' => $_POST['toboard'])); |
||
368 | // Notify people that this topic has been moved? |
||
369 | sendNotifications($topic, 'move'); |
||
370 | |||
371 | call_integration_hook('integrate_movetopic2_end'); |
||
372 | |||
373 | // Why not go back to the original board in case they want to keep moving? |
||
374 | if (!isset($_REQUEST['goback'])) |
||
375 | redirectexit('board=' . $board . '.0'); |
||
376 | else |
||
377 | redirectexit('topic=' . $topic . '.0'); |
||
378 | } |
||
379 | |||
380 | /** |
||
381 | * Moves one or more topics to a specific board. (doesn't check permissions.) |
||
382 | * Determines the source boards for the supplied topics |
||
383 | * Handles the moving of mark_read data |
||
384 | * Updates the posts count of the affected boards |
||
385 | * |
||
386 | * @param int|int[] $topics The ID of a single topic to move or an array containing the IDs of multiple topics to move |
||
387 | * @param int $toBoard The ID of the board to move the topics to |
||
388 | */ |
||
389 | function moveTopics($topics, $toBoard) |
||
390 | { |
||
391 | global $sourcedir, $user_info, $modSettings, $smcFunc, $cache_enable; |
||
392 | |||
393 | // Empty array? |
||
394 | if (empty($topics)) |
||
395 | return; |
||
396 | |||
397 | // Only a single topic. |
||
398 | if (is_numeric($topics)) |
||
399 | $topics = array($topics); |
||
400 | |||
401 | $fromBoards = array(); |
||
402 | |||
403 | // Destination board empty or equal to 0? |
||
404 | if (empty($toBoard)) |
||
405 | return; |
||
406 | |||
407 | // Are we moving to the recycle board? |
||
408 | $isRecycleDest = !empty($modSettings['recycle_enable']) && $modSettings['recycle_board'] == $toBoard; |
||
409 | |||
410 | // Callback for search APIs to do their thing |
||
411 | require_once($sourcedir . '/Search.php'); |
||
412 | $searchAPI = findSearchAPI(); |
||
413 | if ($searchAPI->supportsMethod('topicsMoved')) |
||
414 | $searchAPI->topicsMoved($topics, $toBoard); |
||
415 | |||
416 | // Determine the source boards... |
||
417 | $request = $smcFunc['db_query']('', ' |
||
418 | SELECT id_board, approved, COUNT(*) AS num_topics, SUM(unapproved_posts) AS unapproved_posts, |
||
419 | SUM(num_replies) AS num_replies |
||
420 | FROM {db_prefix}topics |
||
421 | WHERE id_topic IN ({array_int:topics}) |
||
422 | GROUP BY id_board, approved', |
||
423 | array( |
||
424 | 'topics' => $topics, |
||
425 | ) |
||
426 | ); |
||
427 | // Num of rows = 0 -> no topics found. Num of rows > 1 -> topics are on multiple boards. |
||
428 | if ($smcFunc['db_num_rows']($request) == 0) |
||
429 | return; |
||
430 | while ($row = $smcFunc['db_fetch_assoc']($request)) |
||
431 | { |
||
432 | if (!isset($fromBoards[$row['id_board']]['num_posts'])) |
||
433 | { |
||
434 | $fromBoards[$row['id_board']] = array( |
||
435 | 'num_posts' => 0, |
||
436 | 'num_topics' => 0, |
||
437 | 'unapproved_posts' => 0, |
||
438 | 'unapproved_topics' => 0, |
||
439 | 'id_board' => $row['id_board'] |
||
440 | ); |
||
441 | } |
||
442 | // Posts = (num_replies + 1) for each approved topic. |
||
443 | $fromBoards[$row['id_board']]['num_posts'] += $row['num_replies'] + ($row['approved'] ? $row['num_topics'] : 0); |
||
444 | $fromBoards[$row['id_board']]['unapproved_posts'] += $row['unapproved_posts']; |
||
445 | |||
446 | // Add the topics to the right type. |
||
447 | if ($row['approved']) |
||
448 | $fromBoards[$row['id_board']]['num_topics'] += $row['num_topics']; |
||
449 | else |
||
450 | $fromBoards[$row['id_board']]['unapproved_topics'] += $row['num_topics']; |
||
451 | } |
||
452 | $smcFunc['db_free_result']($request); |
||
453 | |||
454 | // Move over the mark_read data. (because it may be read and now not by some!) |
||
455 | $SaveAServer = max(0, $modSettings['maxMsgID'] - 50000); |
||
456 | $request = $smcFunc['db_query']('', ' |
||
457 | SELECT lmr.id_member, lmr.id_msg, t.id_topic, COALESCE(lt.unwatched, 0) AS unwatched |
||
458 | FROM {db_prefix}topics AS t |
||
459 | INNER JOIN {db_prefix}log_mark_read AS lmr ON (lmr.id_board = t.id_board |
||
460 | AND lmr.id_msg > t.id_first_msg AND lmr.id_msg > {int:protect_lmr_msg}) |
||
461 | LEFT JOIN {db_prefix}log_topics AS lt ON (lt.id_topic = t.id_topic AND lt.id_member = lmr.id_member) |
||
462 | WHERE t.id_topic IN ({array_int:topics}) |
||
463 | AND lmr.id_msg > COALESCE(lt.id_msg, 0)', |
||
464 | array( |
||
465 | 'protect_lmr_msg' => $SaveAServer, |
||
466 | 'topics' => $topics, |
||
467 | ) |
||
468 | ); |
||
469 | $log_topics = array(); |
||
470 | while ($row = $smcFunc['db_fetch_assoc']($request)) |
||
471 | { |
||
472 | $log_topics[] = array($row['id_topic'], $row['id_member'], $row['id_msg'], (is_null($row['unwatched']) ? 0 : $row['unwatched'])); |
||
473 | |||
474 | // Prevent queries from getting too big. Taking some steam off. |
||
475 | if (count($log_topics) > 500) |
||
476 | { |
||
477 | $smcFunc['db_insert']('replace', |
||
478 | '{db_prefix}log_topics', |
||
479 | array('id_topic' => 'int', 'id_member' => 'int', 'id_msg' => 'int', 'unwatched' => 'int'), |
||
480 | $log_topics, |
||
481 | array('id_topic', 'id_member') |
||
482 | ); |
||
483 | |||
484 | $log_topics = array(); |
||
485 | } |
||
486 | } |
||
487 | $smcFunc['db_free_result']($request); |
||
488 | |||
489 | // Now that we have all the topics that *should* be marked read, and by which members... |
||
490 | if (!empty($log_topics)) |
||
491 | { |
||
492 | // Insert that information into the database! |
||
493 | $smcFunc['db_insert']('replace', |
||
494 | '{db_prefix}log_topics', |
||
495 | array('id_topic' => 'int', 'id_member' => 'int', 'id_msg' => 'int', 'unwatched' => 'int'), |
||
496 | $log_topics, |
||
497 | array('id_topic', 'id_member') |
||
498 | ); |
||
499 | } |
||
500 | |||
501 | // Update the number of posts on each board. |
||
502 | $totalTopics = 0; |
||
503 | $totalPosts = 0; |
||
504 | $totalUnapprovedTopics = 0; |
||
505 | $totalUnapprovedPosts = 0; |
||
506 | foreach ($fromBoards as $stats) |
||
507 | { |
||
508 | $smcFunc['db_query']('', ' |
||
509 | UPDATE {db_prefix}boards |
||
510 | SET |
||
511 | num_posts = CASE WHEN {int:num_posts} > num_posts THEN 0 ELSE num_posts - {int:num_posts} END, |
||
512 | num_topics = CASE WHEN {int:num_topics} > num_topics THEN 0 ELSE num_topics - {int:num_topics} END, |
||
513 | unapproved_posts = CASE WHEN {int:unapproved_posts} > unapproved_posts THEN 0 ELSE unapproved_posts - {int:unapproved_posts} END, |
||
514 | unapproved_topics = CASE WHEN {int:unapproved_topics} > unapproved_topics THEN 0 ELSE unapproved_topics - {int:unapproved_topics} END |
||
515 | WHERE id_board = {int:id_board}', |
||
516 | array( |
||
517 | 'id_board' => $stats['id_board'], |
||
518 | 'num_posts' => $stats['num_posts'], |
||
519 | 'num_topics' => $stats['num_topics'], |
||
520 | 'unapproved_posts' => $stats['unapproved_posts'], |
||
521 | 'unapproved_topics' => $stats['unapproved_topics'], |
||
522 | ) |
||
523 | ); |
||
524 | $totalTopics += $stats['num_topics']; |
||
525 | $totalPosts += $stats['num_posts']; |
||
526 | $totalUnapprovedTopics += $stats['unapproved_topics']; |
||
527 | $totalUnapprovedPosts += $stats['unapproved_posts']; |
||
528 | } |
||
529 | $smcFunc['db_query']('', ' |
||
530 | UPDATE {db_prefix}boards |
||
531 | SET |
||
532 | num_topics = num_topics + {int:total_topics}, |
||
533 | num_posts = num_posts + {int:total_posts},' . ($isRecycleDest ? ' |
||
534 | unapproved_posts = {int:no_unapproved}, unapproved_topics = {int:no_unapproved}' : ' |
||
535 | unapproved_posts = unapproved_posts + {int:total_unapproved_posts}, |
||
536 | unapproved_topics = unapproved_topics + {int:total_unapproved_topics}') . ' |
||
537 | WHERE id_board = {int:id_board}', |
||
538 | array( |
||
539 | 'id_board' => $toBoard, |
||
540 | 'total_topics' => $totalTopics, |
||
541 | 'total_posts' => $totalPosts, |
||
542 | 'total_unapproved_topics' => $totalUnapprovedTopics, |
||
543 | 'total_unapproved_posts' => $totalUnapprovedPosts, |
||
544 | 'no_unapproved' => 0, |
||
545 | ) |
||
546 | ); |
||
547 | |||
548 | // Move the topic. Done. :P |
||
549 | $smcFunc['db_query']('', ' |
||
550 | UPDATE {db_prefix}topics |
||
551 | SET id_board = {int:id_board}' . ($isRecycleDest ? ', |
||
552 | unapproved_posts = {int:no_unapproved}, approved = {int:is_approved}' : '') . ' |
||
553 | WHERE id_topic IN ({array_int:topics})', |
||
554 | array( |
||
555 | 'id_board' => $toBoard, |
||
556 | 'topics' => $topics, |
||
557 | 'is_approved' => 1, |
||
558 | 'no_unapproved' => 0, |
||
559 | ) |
||
560 | ); |
||
561 | |||
562 | // If this was going to the recycle bin, check what messages are being recycled, and remove them from the queue. |
||
563 | if ($isRecycleDest && ($totalUnapprovedTopics || $totalUnapprovedPosts)) |
||
564 | { |
||
565 | $request = $smcFunc['db_query']('', ' |
||
566 | SELECT id_msg |
||
567 | FROM {db_prefix}messages |
||
568 | WHERE id_topic IN ({array_int:topics}) |
||
569 | AND approved = {int:not_approved}', |
||
570 | array( |
||
571 | 'topics' => $topics, |
||
572 | 'not_approved' => 0, |
||
573 | ) |
||
574 | ); |
||
575 | $approval_msgs = array(); |
||
576 | while ($row = $smcFunc['db_fetch_assoc']($request)) |
||
577 | $approval_msgs[] = $row['id_msg']; |
||
578 | |||
579 | $smcFunc['db_free_result']($request); |
||
580 | |||
581 | // Empty the approval queue for these, as we're going to approve them next. |
||
582 | if (!empty($approval_msgs)) |
||
583 | $smcFunc['db_query']('', ' |
||
584 | DELETE FROM {db_prefix}approval_queue |
||
585 | WHERE id_msg IN ({array_int:message_list}) |
||
586 | AND id_attach = {int:id_attach}', |
||
587 | array( |
||
588 | 'message_list' => $approval_msgs, |
||
589 | 'id_attach' => 0, |
||
590 | ) |
||
591 | ); |
||
592 | |||
593 | // Get all the current max and mins. |
||
594 | $request = $smcFunc['db_query']('', ' |
||
595 | SELECT id_topic, id_first_msg, id_last_msg |
||
596 | FROM {db_prefix}topics |
||
597 | WHERE id_topic IN ({array_int:topics})', |
||
598 | array( |
||
599 | 'topics' => $topics, |
||
600 | ) |
||
601 | ); |
||
602 | $topicMaxMin = array(); |
||
603 | while ($row = $smcFunc['db_fetch_assoc']($request)) |
||
604 | { |
||
605 | $topicMaxMin[$row['id_topic']] = array( |
||
606 | 'min' => $row['id_first_msg'], |
||
607 | 'max' => $row['id_last_msg'], |
||
608 | ); |
||
609 | } |
||
610 | $smcFunc['db_free_result']($request); |
||
611 | |||
612 | // Check the MAX and MIN are correct. |
||
613 | $request = $smcFunc['db_query']('', ' |
||
614 | SELECT id_topic, MIN(id_msg) AS first_msg, MAX(id_msg) AS last_msg |
||
615 | FROM {db_prefix}messages |
||
616 | WHERE id_topic IN ({array_int:topics}) |
||
617 | GROUP BY id_topic', |
||
618 | array( |
||
619 | 'topics' => $topics, |
||
620 | ) |
||
621 | ); |
||
622 | while ($row = $smcFunc['db_fetch_assoc']($request)) |
||
623 | { |
||
624 | // If not, update. |
||
625 | if ($row['first_msg'] != $topicMaxMin[$row['id_topic']]['min'] || $row['last_msg'] != $topicMaxMin[$row['id_topic']]['max']) |
||
626 | $smcFunc['db_query']('', ' |
||
627 | UPDATE {db_prefix}topics |
||
628 | SET id_first_msg = {int:first_msg}, id_last_msg = {int:last_msg} |
||
629 | WHERE id_topic = {int:selected_topic}', |
||
630 | array( |
||
631 | 'first_msg' => $row['first_msg'], |
||
632 | 'last_msg' => $row['last_msg'], |
||
633 | 'selected_topic' => $row['id_topic'], |
||
634 | ) |
||
635 | ); |
||
636 | } |
||
637 | $smcFunc['db_free_result']($request); |
||
638 | } |
||
639 | |||
640 | $smcFunc['db_query']('', ' |
||
641 | UPDATE {db_prefix}messages |
||
642 | SET id_board = {int:id_board}' . ($isRecycleDest ? ',approved = {int:is_approved}' : '') . ' |
||
643 | WHERE id_topic IN ({array_int:topics})', |
||
644 | array( |
||
645 | 'id_board' => $toBoard, |
||
646 | 'topics' => $topics, |
||
647 | 'is_approved' => 1, |
||
648 | ) |
||
649 | ); |
||
650 | $smcFunc['db_query']('', ' |
||
651 | UPDATE {db_prefix}log_reported |
||
652 | SET id_board = {int:id_board} |
||
653 | WHERE id_topic IN ({array_int:topics})', |
||
654 | array( |
||
655 | 'id_board' => $toBoard, |
||
656 | 'topics' => $topics, |
||
657 | ) |
||
658 | ); |
||
659 | $smcFunc['db_query']('', ' |
||
660 | UPDATE {db_prefix}calendar |
||
661 | SET id_board = {int:id_board} |
||
662 | WHERE id_topic IN ({array_int:topics})', |
||
663 | array( |
||
664 | 'id_board' => $toBoard, |
||
665 | 'topics' => $topics, |
||
666 | ) |
||
667 | ); |
||
668 | |||
669 | // Mark target board as seen, if it was already marked as seen before. |
||
670 | $request = $smcFunc['db_query']('', ' |
||
671 | SELECT (COALESCE(lb.id_msg, 0) >= b.id_msg_updated) AS isSeen |
||
672 | FROM {db_prefix}boards AS b |
||
673 | LEFT JOIN {db_prefix}log_boards AS lb ON (lb.id_board = b.id_board AND lb.id_member = {int:current_member}) |
||
674 | WHERE b.id_board = {int:id_board}', |
||
675 | array( |
||
676 | 'current_member' => $user_info['id'], |
||
677 | 'id_board' => $toBoard, |
||
678 | ) |
||
679 | ); |
||
680 | list ($isSeen) = $smcFunc['db_fetch_row']($request); |
||
681 | $smcFunc['db_free_result']($request); |
||
682 | |||
683 | if (!empty($isSeen) && !$user_info['is_guest']) |
||
684 | { |
||
685 | $smcFunc['db_insert']('replace', |
||
686 | '{db_prefix}log_boards', |
||
687 | array('id_board' => 'int', 'id_member' => 'int', 'id_msg' => 'int'), |
||
688 | array($toBoard, $user_info['id'], $modSettings['maxMsgID']), |
||
689 | array('id_board', 'id_member') |
||
690 | ); |
||
691 | } |
||
692 | |||
693 | // Update the cache? |
||
694 | if (!empty($cache_enable) && $cache_enable >= 3) |
||
695 | foreach ($topics as $topic_id) |
||
696 | cache_put_data('topic_board-' . $topic_id, null, 120); |
||
697 | |||
698 | require_once($sourcedir . '/Subs-Post.php'); |
||
699 | |||
700 | $updates = array_keys($fromBoards); |
||
701 | $updates[] = $toBoard; |
||
702 | |||
703 | updateLastMessages(array_unique($updates)); |
||
704 | |||
705 | // Update 'em pesky stats. |
||
706 | updateStats('topic'); |
||
707 | updateStats('message'); |
||
708 | updateSettings(array( |
||
709 | 'calendar_updated' => time(), |
||
710 | )); |
||
711 | } |
||
712 | |||
713 | /** |
||
714 | * Called after a topic is moved to update $board_link and $topic_link to point to new location |
||
715 | */ |
||
716 | function moveTopicConcurrence() |
||
717 | { |
||
718 | global $board, $topic, $smcFunc, $scripturl; |
||
719 | |||
720 | if (isset($_GET['current_board'])) |
||
721 | $move_from = (int) $_GET['current_board']; |
||
722 | |||
723 | if (empty($move_from) || empty($board) || empty($topic)) |
||
724 | return true; |
||
725 | |||
726 | if ($move_from == $board) |
||
0 ignored issues
–
show
Comprehensibility
Best Practice
introduced
by
![]() |
|||
727 | return true; |
||
728 | else |
||
729 | { |
||
730 | $request = $smcFunc['db_query']('', ' |
||
731 | SELECT m.subject, b.name |
||
732 | FROM {db_prefix}topics as t |
||
733 | LEFT JOIN {db_prefix}boards AS b ON (t.id_board = b.id_board) |
||
734 | LEFT JOIN {db_prefix}messages AS m ON (t.id_first_msg = m.id_msg) |
||
735 | WHERE t.id_topic = {int:topic_id} |
||
736 | LIMIT 1', |
||
737 | array( |
||
738 | 'topic_id' => $topic, |
||
739 | ) |
||
740 | ); |
||
741 | list($topic_subject, $board_name) = $smcFunc['db_fetch_row']($request); |
||
742 | $smcFunc['db_free_result']($request); |
||
743 | $board_link = '<a href="' . $scripturl . '?board=' . $board . '.0">' . $board_name . '</a>'; |
||
744 | $topic_link = '<a href="' . $scripturl . '?topic=' . $topic . '.0">' . $topic_subject . '</a>'; |
||
745 | fatal_lang_error('topic_already_moved', false, array($topic_link, $board_link)); |
||
746 | } |
||
747 | } |
||
748 | |||
749 | ?> |