CreatePost_Notify_Background::updateAlerts()

Complexity

Conditions	15
Paths	39

Size

Total Lines	97
Code Lines	50

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
	private function updateAlerts($msg_id)
	{
		global $smcFunc;

		// We send alerts only on the first iteration of this task.
		if (!empty($this->_details['respawns']))
			return;

		// Delete alerts about any mentions and quotes that no longer exist.
		if ($this->_details['type'] == 'edit')
		{
			$old_alerts = array();

			$request = $smcFunc['db_query']('', '
				SELECT content_action, id_member
				FROM {db_prefix}user_alerts
				WHERE content_id = {int:msg_id}
					AND content_type = {literal:msg}
					AND (content_action = {literal:quote} OR content_action = {literal:mention})',
				array(
					'msg_id' => $msg_id,
				)
			);
			if ($smcFunc['db_num_rows']($request) != 0)
			{
				while ($row = $smcFunc['db_fetch_assoc']($request))
					$old_alerts[$row['content_action']][$row['id_member']] = $row['id_member'];
			}
			$smcFunc['db_free_result']($request);

			if (!empty($old_alerts))
			{
				$request = $smcFunc['db_query']('', '
					SELECT content_type, id_mentioned
					FROM {db_prefix}mentions
					WHERE content_id = {int:msg_id}
						AND (content_type = {literal:quote} OR content_type = {literal:msg})',
					array(
						'msg_id' => $msg_id,
					)
				);
				while ($row = $smcFunc['db_fetch_assoc']($request))
				{
					$content_action = $row['content_type'] == 'quote' ? 'quote' : 'mention';
					unset($old_alerts[$content_action][$row['id_mentioned']]);
				}
				$smcFunc['db_free_result']($request);

				$conditions = array();

				if (!empty($old_alerts['quote']))
					$conditions[] = '(content_action = {literal:quote} AND id_member IN ({array_int:members_not_quoted}))';

				if (!empty($old_alerts['mention']))
					$conditions[] = '(content_action = {literal:mention} AND id_member IN ({array_int:members_not_mentioned}))';

				if (!empty($conditions))
				{
					$smcFunc['db_query']('', '
						DELETE FROM {db_prefix}user_alerts
						WHERE content_id = {int:msg_id}
							AND content_type = {literal:msg}
							AND (' . implode(' OR ', $conditions) . ')',
						array(
							'msg_id' => $msg_id,
							'members_not_quoted' => empty($old_alerts['quote']) ? array(0) : $old_alerts['quote'],
							'members_not_mentioned' => empty($old_alerts['mention']) ? array(0) : $old_alerts['mention'],
						)
					);

					foreach ($old_alerts as $member_ids)
						updateMemberData($member_ids, array('alerts' => '-'));
				}
			}
		}

		// Insert the new alerts.
		if (!empty($this->alert_rows))
		{
			$smcFunc['db_insert']('',
				'{db_prefix}user_alerts',
				array(
					'alert_time' => 'int',
					'id_member' => 'int',
					'id_member_started' => 'int',
					'member_name' => 'string',
					'content_type' => 'string',
					'content_id' => 'int',
					'content_action' => 'string',
					'is_read' => 'int',
					'extra' => 'string',
				),
				$this->alert_rows,
				array()
			);

			updateMemberData(array_column($this->alert_rows, 'id_member'), array('alerts' => '+'));
		}
?>