CAllRatings::ChangeRatingVote

static function ChangeRatingVote($arParam)
{
	global $DB, $CACHE_MANAGER;
	$connection = BitrixMainApplication::getConnection();
	$helper = $connection->getSqlHelper();

	$arParam['ENTITY_TYPE_ID'] = mb_substr($arParam['ENTITY_TYPE_ID'], 0, 50);
	$arParam['REACTION'] = ($arParam['REACTION'] <> '' ? $arParam['REACTION'] : self::REACTION_DEFAULT);
	$userData = CAllRatings::getUserData((int)$arParam['USER_ID'], (float)$arParam['VALUE']);

	$err_mess = (CRatings::err_mess())."
Function: ChangeRatingVote
Line: ";

	$sqlStr = "
		SELECT
			RVG.ID,
			RV.ID AS VOTE_ID,
			RV.REACTION AS REACTION,
			RV.VALUE AS VOTE_VALUE,
			RVG.TOTAL_POSITIVE_VOTES
		FROM
			b_rating_voting RVG,
			b_rating_vote RV
		WHERE
			RVG.ENTITY_TYPE_ID = '".$DB->ForSql($arParam['ENTITY_TYPE_ID'])."'
		and RVG.ENTITY_ID = ".(int)$arParam['ENTITY_ID']."
		and RVG.ID = RV.RATING_VOTING_ID
		and RV.USER_ID = ".(int)$arParam['USER_ID'];

	$res = $DB->Query($sqlStr, false, $err_mess.__LINE__);
	if ($arVote = $res->Fetch())
	{
		// GetOwnerDocument
		$arParam['OWNER_ID'] = 0;
		foreach(GetModuleEvents("main", "OnGetRatingContentOwner", true) as $arEvent)
		{
			$result = ExecuteModuleEventEx($arEvent, array($arParam));
			if ($result !== false)
				$arParam['OWNER_ID'] = (int)$result;
		}

		$votePlus = $arVote['VOTE_VALUE'] >= 0 ? true : false;
		$arVote['REACTION_OLD'] = ($arVote['REACTION'] <> '' ? $arVote['REACTION'] : self::REACTION_DEFAULT);

		if (!$votePlus)
		{
			return false;
		}

		$rsRV = $DB->Query("SELECT ID, TOTAL_POSITIVE_VOTES FROM b_rating_voting WHERE ENTITY_TYPE_ID='".$DB->ForSql($arParam['ENTITY_TYPE_ID'])."' AND ENTITY_ID='".(int)$arParam['ENTITY_ID']."'", false, $err_mess.__LINE__);
		if ($arRV = $rsRV->Fetch())
		{
			$arParam['RATING_VOTING_ID'] = $arRV['ID'];
			$arParam['TOTAL_POSITIVE_VOTES'] = $arRV['TOTAL_POSITIVE_VOTES'];
			$arParam['REACTIONS_LIST'] = array(
				self::REACTION_DEFAULT => (int)$arParam['TOTAL_POSITIVE_VOTES']
			);
		}
		else
		{
			return false;
		}

		$rsRVR = $DB->Query("SELECT TOTAL_VOTES FROM b_rating_voting_reaction WHERE ENTITY_TYPE_ID='".$DB->ForSql($arParam['ENTITY_TYPE_ID'])."' AND ENTITY_ID='".(int)$arParam['ENTITY_ID']."'", false, $err_mess.__LINE__);
		if (!($arRVR = $rsRVR->fetch())) // reactions not initialized
		{
			$merge = $helper->prepareMerge('b_rating_voting_reaction', ['ENTITY_TYPE_ID', 'ENTITY_ID', 'REACTION'], [
				'ENTITY_TYPE_ID' => $arParam['ENTITY_TYPE_ID'],
				'ENTITY_ID' => $arParam['ENTITY_ID'],
				'REACTION' => self::REACTION_DEFAULT,
				'TOTAL_VOTES' => $arRV['TOTAL_POSITIVE_VOTES'],
			], [
				'TOTAL_VOTES' => $arRV['TOTAL_POSITIVE_VOTES'],
			]);
			if ($merge[0])
			{
				$DB->query($merge[0]);
			}
		}

		$merge = $helper->prepareMerge('b_rating_voting_reaction', ['ENTITY_TYPE_ID', 'ENTITY_ID', 'REACTION'], [
			'ENTITY_TYPE_ID' => $arParam['ENTITY_TYPE_ID'],
			'ENTITY_ID' => $arParam['ENTITY_ID'],
			'REACTION' => $arParam['REACTION'],
			'TOTAL_VOTES' => 1,
		], [
			'TOTAL_VOTES' => new BitrixMainDBSqlExpression('b_rating_voting_reaction.TOTAL_VOTES + 1'),
		]);
		if ($merge[0])
		{
			$DB->query($merge[0]);
		}

		if (!empty($arVote['REACTION_OLD']))
		{
			$DB->Query("UPDATE b_rating_voting_reaction SET TOTAL_VOTES = TOTAL_VOTES - 1 WHERE ENTITY_TYPE_ID = '".$DB->ForSql($arParam['ENTITY_TYPE_ID'])."' AND ENTITY_ID = '".(int)$arParam['ENTITY_ID']."' AND REACTION = '".$DB->ForSql($arVote['REACTION_OLD'])."'", false, $err_mess.__LINE__);
		}

		$rsRVR = $DB->Query("SELECT REACTION, TOTAL_VOTES FROM b_rating_voting_reaction WHERE ENTITY_TYPE_ID='".$DB->ForSql($arParam['ENTITY_TYPE_ID'])."' AND ENTITY_ID='".(int)$arParam['ENTITY_ID']."'", false, $err_mess.__LINE__);
		while($arRVR = $rsRVR->fetch())
		{
			$arParam['REACTIONS_LIST'][$arRVR['REACTION']] = $arRVR['TOTAL_VOTES'];
		}

		$arFields = array(
			"CREATED" => $DB->GetNowFunction(),
			"USER_IP" => "'".$DB->ForSql($arParam["USER_IP"])."'",
			"REACTION" => "'".$DB->ForSql($arParam["REACTION"])."'"
		);

		$ID = $DB->Update("b_rating_vote", $arFields, "WHERE RATING_VOTING_ID=".(int)$arParam['RATING_VOTING_ID']." AND USER_ID=".(int)$arParam['USER_ID'], $err_mess.__LINE__);
		if (!$ID)
		{
			return false;
		}

		foreach(GetModuleEvents("main", "OnChangeRatingVote", true) as $arEvent)
		{
			ExecuteModuleEventEx($arEvent, array((int)$ID, $arParam));
		}

		if (CModule::IncludeModule('pull'))
		{
			CPullStack::AddShared(Array(
				'module_id' => 'main',
				'command' => 'rating_vote',
				'params' => Array(
					"TYPE" => "CHANGE",
					"USER_ID" => (int)$arParam['USER_ID'],
					"ENTITY_TYPE_ID" => $arParam["ENTITY_TYPE_ID"],
					"ENTITY_ID" => (int)$arParam['ENTITY_ID'],
					"TOTAL_POSITIVE_VOTES" => $arParam['TOTAL_POSITIVE_VOTES'],
					"RESULT" => 'CHANGE',
					"USER_DATA" => $userData,
					"REACTION" => $arParam['REACTION'],
					"REACTION_OLD" => $arVote['REACTION'],
					"REACTIONS_LIST" => $arParam['REACTIONS_LIST']
				)
			));
		}

		if (CACHED_b_rating_vote!==false)
		{
			$bucket_size = (int)CACHED_b_rating_bucket_size;
			if($bucket_size <= 0)
			{
				$bucket_size = 100;
			}
			$bucket = (int)((int)$arParam['ENTITY_ID'] / $bucket_size);
			$CACHE_MANAGER->Clean("b_rvg_".$DB->ForSql($arParam["ENTITY_TYPE_ID"]).$bucket, "b_rating_voting");
		}
	}

	return $userData;
}