X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=inc%2Flibs%2Frallye_functions.php;h=5aa2cdb91fa3294872712c707269f852d4ffd4bf;hb=1c878f804eeafc5f73ad84953506f0506e1f9fa6;hp=3e3bbadb9f9488442f00dee8cde3dc5e41b56b24;hpb=596c8ab32594401ca84abfbfe35513ddfff31bec;p=mailer.git

diff --git a/inc/libs/rallye_functions.php b/inc/libs/rallye_functions.php
index 3e3bbadb9f..5aa2cdb91f 100644
--- a/inc/libs/rallye_functions.php
+++ b/inc/libs/rallye_functions.php
@@ -16,7 +16,7 @@
  * $Author::                                                          $ *
  * -------------------------------------------------------------------- *
  * Copyright (c) 2003 - 2009 by Roland Haeder                           *
- * Copyright (c) 2009 - 2012 by Mailer Developer Team                   *
+ * Copyright (c) 2009 - 2013 by Mailer Developer Team                   *
  * For more information visit: http://mxchange.org                      *
  *                                                                      *
  * This program is free software; you can redistribute it and/or modify *
@@ -43,13 +43,13 @@ if (!defined('__SECURITY')) {
 // Auto-start referral rallyes
 function autostartReferralRallyes ($result) {
 	// Load all rallyes (usally we have only one rallye active per time!
-	$content = SQL_FETCHARRAY($result);
+	$content = sqlFetchArray($result);
 
 	// Free result
-	SQL_FREERESULT($result);
+	sqlFreeResult($result);
 
 	// Set notified to Y
-	SQL_QUERY_ESC("UPDATE
+	sqlQueryEscaped("UPDATE
 	`{?_MYSQL_PREFIX?}_rallye_data`
 SET
 	`notified`='Y'
@@ -59,7 +59,7 @@ LIMIT 1",
 		array(bigintval($content['id'])), __FUNCTION__, __LINE__);
 
 	// Query all users
-	$result_user = SQL_QUERY("SELECT
+	$result_user = sqlQuery("SELECT
 	`userid`
 FROM
 	`{?_MYSQL_PREFIX?}_user_data`
@@ -70,7 +70,7 @@ ORDER BY
 	`userid` ASC", __FUNCTION__, __LINE__);
 
 	// Let's begin with the userids...
-	while ($row = SQL_FETCHARRAY($result_user)) {
+	while ($row = sqlFetchArray($result_user)) {
 		// Merge both arrays
 		$content = merge_array($content, $row);
 
@@ -81,7 +81,7 @@ ORDER BY
 		if (empty($count)) $count = '0'; // Added prevent some unknown troubles... :-?
 
 		// Check if line is already included...
-		$result_ref = SQL_QUERY_ESC("SELECT
+		$result_ref = sqlQueryEscaped("SELECT
 	`id`
 FROM
 	`{?_MYSQL_PREFIX?}_rallye_users`
@@ -92,36 +92,36 @@ LIMIT 1",
 			array(bigintval($content['id']), bigintval($content['userid'])), __FUNCTION__, __LINE__);
 
 		// Is there an entry?
-		if (SQL_HASZERONUMS($result_ref)) {
+		if (ifSqlHasZeroNums($result_ref)) {
 			// Add userid and his ref count to table
-			$result_ref = SQL_QUERY_ESC("SELECT 
-	SUM(p.`points`) AS `points`
+			$result_ref = sqlQueryEscaped("SELECT
+	SUM(`p`.`points`) AS `points`
 FROM
-	`{?_MYSQL_PREFIX?}_user_points` AS p
+	`{?_MYSQL_PREFIX?}_user_points` AS `p`
 LEFT JOIN
-	`{?_MYSQL_PREFIX?}_user_data` AS d
+	`{?_MYSQL_PREFIX?}_user_data` AS `d`
 ON
 	p.userid=d.userid
 WHERE
-	d.`status`='CONFIRMED'
+	`d`.`status`='CONFIRMED'
 	" . runFilterChain('user_exclusion_sql', ' ') . " AND
-	d.`max_mails` > 0 AND
-	d.`mails_confirmed` >= {?ref_payout?} AND
-	p.`ref_depth`=1 AND
-	p.`points` > 0 AND
-	d.`userid`=%s",
+	`d`.`max_mails` > 0 AND
+	`d`.`mails_confirmed` >= {?ref_payout?} AND
+	`p`.`ref_depth`=1 AND
+	`p`.`points` > 0 AND
+	`d`.`userid`=%s",
 				array(bigintval($content['userid'])), __FUNCTION__, __LINE__);
 
 			// Get points
-			list($cpoints) = SQL_FETCHROW($result_ref);
+			list($cpoints) = sqlFetchRow($result_ref);
 
 			// Free result
-			SQL_FREERESULT($result_ref);
+			sqlFreeResult($result_ref);
 
 			if (empty($cpoints)) $cpoints = '0.00000';
 
 			// Add info line
-			SQL_QUERY_ESC("INSERT INTO
+			sqlQueryEscaped("INSERT INTO
 	`{?_MYSQL_PREFIX?}_rallye_users`
 (
 	`rallye_id`,
@@ -144,7 +144,7 @@ WHERE
 		} // END - if
 
 		// Free memory
-		SQL_FREERESULT($result_ref);
+		sqlFreeResult($result_ref);
 
 		// Ignored but for the template required refs (made before start of rallye)
 		$content['refs']  = $count;
@@ -167,19 +167,19 @@ WHERE
 	sendAdminNotification('{%message,ADMIN_RALLYE_NOTIFY_SUBJECT=' . $content['title'] . '%}', $templ, $content);
 
 	// Free memory
-	SQL_FREERESULT($result_user);
+	sqlFreeResult($result_user);
 }
 
 //
 function addReferralRallyePrices ($rallye, $mode = 'email') {
 	// Output mode
 	switch($mode) {
-		case 'email': $mode = chr(10);  break;
+		case 'email': $mode = PHP_EOL;  break;
 		case 'html' : $mode = '<br />'; break;
 	} // END - switch
 
 	// Load prices
-	$result_prices = SQL_QUERY_ESC("SELECT
+	$result_prices = sqlQueryEscaped("SELECT
 	`price_level`,
 	`points`,
 	`info`
@@ -192,14 +192,14 @@ ORDER BY
 		array($rallye), __FUNCTION__, __LINE__);
 
 	// Entries found?
-	if (!SQL_HASZERONUMS($result_prices)) {
+	if (!ifSqlHasZeroNums($result_prices)) {
 		// Load prices
 		$prices = '';
-		if ($mode == chr(10)) {
+		if ($mode == PHP_EOL) {
 			$prices = '{--RALLYE_MEMBER_PRICES_ADDED--}:' . $mode . '------------------------------' . $mode;
 		} // END - if
 
-		while ($content = SQL_FETCHARRAY($result_prices)) {
+		while ($content = sqlFetchArray($result_prices)) {
 			$prices .= $content['price_level']. '{--RALLYE_PRICE--}:';
 			if (!empty($content['info'])) {
 				$prices .= $content['info'];
@@ -210,14 +210,14 @@ ORDER BY
 		} // END - if
 
 		// Free memory
-		SQL_FREERESULT($result_prices);
+		sqlFreeResult($result_prices);
 	} else {
 		// No prices???
 		$prices = '{%message,RALLYE_MEMBER_NO_PRICES=' . $mode . '%}';
 	}
 
 	// Add last line for email mode
-	if ($mode == chr(10)) {
+	if ($mode == PHP_EOL) {
 		$prices .= '------------------------------';
 	} // END - if
 
@@ -235,25 +235,25 @@ function addReferralRallyeTopUsers ($mode, $rallye, $default=0) {
 	$prices = getTotalRallyePrices($rallye);
 
 	// And load only limited users
-	$result = SQL_QUERY_ESC("SELECT DISTINCT
-	u.`userid`,
-	u.`refs`,
-	u.`curr_points`,
-	rd.`min_users`,
-	rd.`min_prices`
+	$result = sqlQueryEscaped("SELECT DISTINCT
+	`u`.`userid`,
+	`u`.`refs`,
+	`u`.`curr_points`,
+	`rd`.`min_users`,
+	`rd`.`min_prices`
 FROM
-	`{?_MYSQL_PREFIX?}_rallye_users` AS u
+	`{?_MYSQL_PREFIX?}_rallye_users` AS `u`
 INNER JOIN
-	`{?_MYSQL_PREFIX?}_refsystem` AS r
+	`{?_MYSQL_PREFIX?}_refsystem` AS `r`
 ON
 	u.userid=r.userid
 INNER JOIN
-	`{?_MYSQL_PREFIX?}_rallye_data` AS rd
+	`{?_MYSQL_PREFIX?}_rallye_data` AS `rd`
 ON
-	u.`rallye_id`=rd.`id`
+	`u`.`rallye_id`=r`d`.`id`
 WHERE
-	u.`rallye_id`=%s AND
-	r.`counter` > 0
+	`u`.`rallye_id`=%s AND
+	`r`.`counter` > 0
 ORDER BY
 	u.refs DESC",
 		array(bigintval($rallye)), __FUNCTION__, __LINE__);
@@ -266,35 +266,35 @@ ORDER BY
 	);
 
 	// Load all users
-	while ($row = SQL_FETCHARRAY($result)) {
+	while ($row = sqlFetchArray($result)) {
 		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $row['userid'] . ',refs=' . $row['refs']);
 		// Get current refs
 		$count = getReferralRallyeRefsCount($row['userid'], $row['refs']);
 
 		// Points of ref's
-		$result_ref = SQL_QUERY_ESC("SELECT
-	p.`points`
+		$result_ref = sqlQueryEscaped("SELECT
+	`p`.`points`
 FROM
-	`{?_MYSQL_PREFIX?}_user_points` AS p
+	`{?_MYSQL_PREFIX?}_user_points` AS `p`
 LEFT JOIN
-	`{?_MYSQL_PREFIX?}_user_data` AS d
+	`{?_MYSQL_PREFIX?}_user_data` AS `d`
 ON
-	p.`userid`=d.`userid`
+	`p`.`userid`=`d`.`userid`
 WHERE
-	d.`userid`=%s AND
-	d.`status`='CONFIRMED'
+	`d`.`userid`=%s AND
+	`d`.`status`='CONFIRMED'
 	" . runFilterChain('user_exclusion_sql', ' ') . " AND
-	p.`ref_depth`=1 AND
-	d.`max_mails` > 0 AND
-	d.`mails_confirmed` >= {?ref_payout?}
+	`p`.`ref_depth`=1 AND
+	`d`.`max_mails` > 0 AND
+	`d`.`mails_confirmed` >= {?ref_payout?}
 LIMIT 1",
 			array(bigintval($row['userid'])), __FUNCTION__, __LINE__);
 
 		// Get points
-		list($refpoints) = SQL_FETCHROW($result_ref);
+		list($refpoints) = sqlFetchRow($result_ref);
 
 		// Free result
-		SQL_FREERESULT($result_ref);
+		sqlFreeResult($result_ref);
 
 		// Fix empty values (ugly code again)
 		if (empty($refpoints)) {
@@ -321,7 +321,7 @@ LIMIT 1",
 	} // END - while
 
 	// Free memory
-	SQL_FREERESULT($result);
+	sqlFreeResult($result);
 
 	// Sort whole array
 	array_pk_sort($content, array('cpoints', 'ref'), 0, 1, TRUE);
@@ -382,7 +382,7 @@ function addUserToReferralRallye ($userid, $content = array()) {
 	} // END - if
 
 	// Check for an auto-add rallye
-	$result = SQL_QUERY("SELECT
+	$result = sqlQuery("SELECT
 	`id`,
 	`title`,
 	`start_time`,
@@ -397,16 +397,16 @@ WHERE
 	`auto_add_new_user`='Y' AND
 	`expired`='N'
 LIMIT 1", __FUNCTION__, __LINE__);
-	if (SQL_NUMROWS($result) == 1) {
+	if (sqlNumRows($result) == 1) {
 		// Init variables
 		$min_users = '0';
 		$min_prices = '0';
 
 		// Load and merge data
-		$content = merge_array($content, SQL_FETCHARRAY($result));
+		$content = merge_array($content, sqlFetchArray($result));
 
 		// Free result
-		SQL_FREERESULT($result);
+		sqlFreeResult($result);
 
 		// Notify the user?
 		if ($content['send_notify'] == 'Y') {
@@ -415,7 +415,7 @@ LIMIT 1", __FUNCTION__, __LINE__);
 		} // END - if
 
 		// Check if line is already included...
-		$result = SQL_QUERY_ESC("SELECT
+		$result = sqlQueryEscaped("SELECT
 	`id`
 FROM
 	`{?_MYSQL_PREFIX?}_rallye_users`
@@ -429,9 +429,9 @@ LIMIT 1",
 			), __FUNCTION__, __LINE__);
 
 		// Is this user added?
-		if (SQL_HASZERONUMS($result)) {
+		if (ifSqlHasZeroNums($result)) {
 			// Add userid and his ref count to table
-			SQL_QUERY_ESC("INSERT INTO
+			sqlQueryEscaped("INSERT INTO
 	`{?_MYSQL_PREFIX?}_rallye_users`
 (
 	`rallye_id`,
@@ -449,7 +449,7 @@ LIMIT 1",
 		} // END - if
 
 		// Free memory
-		SQL_FREERESULT($result);
+		sqlFreeResult($result);
 	} // END - if
 }
 
@@ -470,7 +470,7 @@ function getTotalRallyeWinners ($rallyeId) {
 
 			// Allow valid and active users with at least one ref
 			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'rallyeId=' . $rallyeId . ',userid=' . $userid . ',ref=' . $prices['ref'][$key] . ',cpoints=' . $prices['cpoints'][$key]);
-			if ((isValidUserId($userid)) && ($prices['ref'][$key] > 0) && ($active == 1) && ($prices['cpoints'][$key] > 0)) {
+			if ((isValidId($userid)) && ($prices['ref'][$key] > 0) && ($active == 1) && ($prices['cpoints'][$key] > 0)) {
 				$GLOBALS[__FUNCTION__][$rallyeId]++;
 			} // END - if
 		} // END - foreach
@@ -483,10 +483,10 @@ function getTotalRallyeWinners ($rallyeId) {
 // Stops the given rallye result (from SQL layer) by marking it as expirced
 function stopRallyeByResult ($result) {
 	// Load rallye data
-	$content = SQL_FETCHARRAY($result);
+	$content = sqlFetchArray($result);
 
 	// Free result
-	SQL_FREERESULT($result);
+	sqlFreeResult($result);
 
 	// Init array
 	$count = '0';
@@ -511,7 +511,7 @@ function stopRallyeByResult ($result) {
 		$prices['active'][$key] = $active;
 
 		// Allow valid and active users with at least one ref to get points
-		if ((isValidUserId($userid)) && ($prices['ref'][$key] > 0) && ($active == 1) && ($prices['cpoints'][$key] > 0)) {
+		if ((isValidId($userid)) && ($prices['ref'][$key] > 0) && ($active == 1) && ($prices['cpoints'][$key] > 0)) {
 			$total++;
 		} // END - if
 	} // END - foreach
@@ -523,13 +523,13 @@ function stopRallyeByResult ($result) {
 	} // END - if
 
 	// Expire rallye
-	SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_rallye_data` SET `expired`='Y' WHERE `id`=%s LIMIT 1",
+	sqlQueryEscaped("UPDATE `{?_MYSQL_PREFIX?}_rallye_data` SET `expired`='Y' WHERE `id`=%s LIMIT 1",
 		array(bigintval($content['id'])), __FUNCTION__, __LINE__);
 
 	// Run array through (by userid is the most important 2nd-level-array)
 	foreach ($prices['userid'] as $key => $userid) {
 		// Allow valid and active users with at least one ref to get points
-		if ((isValidUserId($userid)) && ($prices['ref'][$key] > 0) && ($prices['active'][$key] == 1) && ($prices['cpoints'][$key] > 0)) {
+		if ((isValidId($userid)) && ($prices['ref'][$key] > 0) && ($prices['active'][$key] == 1) && ($prices['cpoints'][$key] > 0)) {
 			// Transfer data to array for the mail template
 			$content['level']  = $prices['level'][$key];
 			$content['points'] = $prices['points'][$key];
@@ -609,7 +609,7 @@ function getReferralRallyeUserDataFromArray ($userIds) {
 	$ret = '';
 
 	// Load users
-	$result = SQL_QUERY_ESC("SELECT
+	$result = sqlQueryEscaped("SELECT
 	`userid`, `gender`, `surname`, `family`, `email`
 FROM
 	`{?_MYSQL_PREFIX?}_user_data`
@@ -624,7 +624,7 @@ LIMIT %s",
 			$userid_string,
 			count($userIds)
 		), __FUNCTION__, __LINE__);
-	while ($content = SQL_FETCHARRAY($result)) {
+	while ($content = sqlFetchArray($result)) {
 		// Construct the message masked and add it
 		$ret .= sprintf("{%%pipe,translateGender=%s%} %s %s (%s) - %s\n",
 			$content['gender'],
@@ -649,7 +649,7 @@ function getArrayFromReferralRallyePrices ($rallye) {
 	);
 
 	// Load prices
-	$result = SQL_QUERY_ESC("SELECT
+	$result = sqlQueryEscaped("SELECT
 	`price_level`,
 	`points`,
 	`info`
@@ -662,14 +662,14 @@ ORDER BY
 		array(bigintval($rallye)), __FUNCTION__, __LINE__);
 
 	// Transfer elements
-	while ($content = SQL_FETCHARRAY($result)) {
+	while ($content = sqlFetchArray($result)) {
 		$prices['level'][]  = $content['price_level'];
 		array_push($prices['points'], $content['points']);
 		array_push($prices['info'], $content['info']);
 	} // END - while
 
 	// Free memory
-	SQL_FREERESULT($result);
+	sqlFreeResult($result);
 
 	// Return array
 	return $prices;
@@ -695,7 +695,7 @@ function getArrayFromReferralRallyeUsers ($rallye) {
 	 *  - refs        = Old amount of referrals (before the rallye has started)
 	 *  - curr_points = Current amount of total points
 	 */
-	$result_user = SQL_QUERY_ESC("SELECT
+	$result_user = sqlQueryEscaped("SELECT
 	`userid`,
 	`refs`,
 	`curr_points`
@@ -706,35 +706,35 @@ WHERE
 ORDER BY
 	`userid` ASC",
 		array(bigintval($rallye)), __FUNCTION__, __LINE__);
-	while ($content = SQL_FETCHARRAY($result_user)) {
+	while ($content = sqlFetchArray($result_user)) {
 		// Load current ref count
 		$count = getReferralRallyeRefsCount($content['userid'], $content['refs']);
 
 		// Points of ref's
-		$result_ref = SQL_QUERY_ESC("SELECT
-	SUM(p.`points`) AS `points`
+		$result_ref = sqlQueryEscaped("SELECT
+	SUM(`p`.`points`) AS `points`
 FROM
-	`{?_MYSQL_PREFIX?}_user_points` AS p
+	`{?_MYSQL_PREFIX?}_user_points` AS `p`
 LEFT JOIN
-	`{?_MYSQL_PREFIX?}_user_data` AS d
+	`{?_MYSQL_PREFIX?}_user_data` AS `d`
 ON
-	p.`userid`=d.`userid`
+	`p`.`userid`=`d`.`userid`
 WHERE
-	d.`status`='CONFIRMED'
+	`d`.`status`='CONFIRMED'
 	" . runFilterChain('user_exclusion_sql', ' ' ) . " AND
-	d.`max_mails` > 0 AND
-	d.`mails_confirmed` >= {?ref_payout?} AND
-	p.`ref_depth`=1 AND
-	p.`points` > 0 AND
-	d.`userid`=%s
+	`d`.`max_mails` > 0 AND
+	`d`.`mails_confirmed` >= {?ref_payout?} AND
+	`p`.`ref_depth`=1 AND
+	`p`.`points` > 0 AND
+	`d`.`userid`=%s
 LIMIT 1",
 			array(bigintval($content['userid'])), __FUNCTION__, __LINE__);
 
 		// Get points
-		list($refpoints) = SQL_FETCHROW($result_ref);
+		list($refpoints) = sqlFetchRow($result_ref);
 
 		// Free result
-		SQL_FREERESULT($result_ref);
+		sqlFreeResult($result_ref);
 
 		// Fix empty refpoints
 		if (empty($refpoints)) $refpoints = '0';
@@ -746,7 +746,7 @@ LIMIT 1",
 	} // END - while
 
 	// Free memory
-	SQL_FREERESULT($result_user);
+	sqlFreeResult($result_user);
 
 	// Sort array for refs (descending)
 	array_pk_sort($users, array('cpoints', 'ref'), 0, 1, TRUE);
@@ -836,7 +836,7 @@ function addReferralRallyeWinners ($mode, $rallye, $default=0) {
 function purgeExpiredReferralRallyes () {
 	// Check for expired rallyes
 	$EXPIRE = 3; // @TODO The hard-coded value...
-	$result_rallye = SQL_QUERY_ESC("SELECT
+	$result_rallye = sqlQueryEscaped("SELECT
 	`id`,
 	`title`,
 	`start_time`,
@@ -848,12 +848,12 @@ WHERE
 	`expired`='Y'",
 		array($EXPIRE), __FUNCTION__, __LINE__);
 
-	if (!SQL_HASZERONUMS($result_rallye)) {
+	if (!ifSqlHasZeroNums($result_rallye)) {
 		// Init SQLs
 		initSqls();
 
 		// Expire found rallyes and notify admin
-		while ($content = SQL_FETCHARRAY($result_rallye)) {
+		while ($content = sqlFetchArray($result_rallye)) {
 			// Prepare data for mail template
 			$content['start_time'] = generateDateTime($content['start_time'], 1);
 			$content['end_time']   = generateDateTime($content['end_time']  , 1);
@@ -863,11 +863,11 @@ WHERE
 			sendAdminNotification('{%message,ADMIN_RALLYE_PURGED_SUBJECT=' . $content['title'] . '%}', 'admin_rallye_purged', $content);
 
 			// Purge whole rallye
-			addSql(SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_data` WHERE `id`=%s LIMIT 1",
+			addSql(sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_data` WHERE `id`=%s LIMIT 1",
 				array(bigintval($content['id'])), __FUNCTION__, __LINE__, FALSE));
-			addSql(SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_prices` WHERE `rallye_id`=%s LIMIT 1",
+			addSql(sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_prices` WHERE `rallye_id`=%s LIMIT 1",
 				array(bigintval($content['id'])), __FUNCTION__, __LINE__, FALSE));
-			addSql(SQL_QUERY_ESC("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_users` WHERE `rallye_id`=%s LIMIT 1",
+			addSql(sqlQueryEscaped("DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_rallye_users` WHERE `rallye_id`=%s LIMIT 1",
 				array(bigintval($content['id'])), __FUNCTION__, __LINE__, FALSE));
 
 			// Add task (we ignore the task id here
@@ -879,7 +879,7 @@ WHERE
 	} // END - if
 
 	// Free memory
-	SQL_FREERESULT($result_rallye);
+	sqlFreeResult($result_rallye);
 }
 
 //
@@ -889,7 +889,7 @@ function addReferralRallyeTemplateSelection ($name = 'template', $default = '')
 	$ral = array();
 
 	// Check templates directory
-	$basePath = sprintf("templates/%s/html/rallye/", getLanguage());
+	$basePath = sprintf('templates/%s/html/rallye/', getLanguage());
 
 	// Read the directory
 	$templates = getArrayFromDirectory($basePath, 'rallye_', FALSE, TRUE, array(), '.tpl');
@@ -905,7 +905,7 @@ function addReferralRallyeTemplateSelection ($name = 'template', $default = '')
 			$ral[$read] = $read;
 		} else {
 			// Log invalid
-			logDebugMessage(__FUNCTION__, __LINE__, sprintf("WARNING: Template %s not used.", $read));
+			logDebugMessage(__FUNCTION__, __LINE__, sprintf('WARNING: Template %s not used.', $read));
 		}
 	} // END - foreach
 
@@ -965,26 +965,26 @@ function getReferralRallyeRefsCount ($currUserid, $oldReferralCount = '0') {
 		} // END - if
 	} else {
 		// Load current refs from database
-		$result_ref = SQL_QUERY_ESC("SELECT
-	SUM(s.counter) AS cnt
+		$result_ref = sqlQueryEscaped("SELECT
+	SUM(s.counter) AS `cnt`
 FROM
-	`{?_MYSQL_PREFIX?}_refsystem` AS s
+	`{?_MYSQL_PREFIX?}_refsystem` AS `s`
 LEFT JOIN
-	`{?_MYSQL_PREFIX?}_refdepths` AS d
+	`{?_MYSQL_PREFIX?}_refdepths` AS `d`
 ON
-	s.level=d.level
+	`s`.`level`=`d`.`level`
 WHERE
-	s.userid=%s AND
-	s.level=1",
+	`s`.`userid`=%s AND
+	`s`.`level`=1",
 			array(
 				bigintval($userid)
 			), __FUNCTION__, __LINE__);
 
 		// Load count @TODO Can't we rewrite this to our API?
-		list($count) = SQL_FETCHROW($result_ref);
+		list($count) = sqlFetchRow($result_ref);
 
 		// Free result
-		SQL_FREERESULT($result_ref);
+		sqlFreeResult($result_ref);
 		if (empty($count)) {
 			$count = '0';
 		} else {