Renamed all SQL-related functions to camel-case notation
[mailer.git] / inc / libs / rallye_functions.php
index 6e349c730c0b6a5889dc11087b6902fdb0f503ab..849874be8d427c5f72fabfb86fd9f8017d1fdfe7 100644 (file)
@@ -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,9 +92,9 @@ 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 
+                       $result_ref = sqlQueryEscaped("SELECT
        SUM(`p`.`points`) AS `points`
 FROM
        `{?_MYSQL_PREFIX?}_user_points` AS `p`
@@ -113,15 +113,15 @@ WHERE
                                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,7 +167,7 @@ WHERE
        sendAdminNotification('{%message,ADMIN_RALLYE_NOTIFY_SUBJECT=' . $content['title'] . '%}', $templ, $content);
 
        // Free memory
-       SQL_FREERESULT($result_user);
+       sqlFreeResult($result_user);
 }
 
 //
@@ -179,7 +179,7 @@ function addReferralRallyePrices ($rallye, $mode = 'email') {
        } // 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 == 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,7 +210,7 @@ ORDER BY
                } // END - if
 
                // Free memory
-               SQL_FREERESULT($result_prices);
+               sqlFreeResult($result_prices);
        } else {
                // No prices???
                $prices = '{%message,RALLYE_MEMBER_NO_PRICES=' . $mode . '%}';
@@ -235,7 +235,7 @@ function addReferralRallyeTopUsers ($mode, $rallye, $default=0) {
        $prices = getTotalRallyePrices($rallye);
 
        // And load only limited users
-       $result = SQL_QUERY_ESC("SELECT DISTINCT
+       $result = sqlQueryEscaped("SELECT DISTINCT
        `u`.`userid`,
        `u`.`refs`,
        `u`.`curr_points`,
@@ -266,13 +266,13 @@ 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
+               $result_ref = sqlQueryEscaped("SELECT
        `p`.`points`
 FROM
        `{?_MYSQL_PREFIX?}_user_points` AS `p`
@@ -291,10 +291,10 @@ 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
 }
 
@@ -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';
@@ -523,7 +523,7 @@ 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)
@@ -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,12 +706,12 @@ 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
+               $result_ref = sqlQueryEscaped("SELECT
        SUM(`p`.`points`) AS `points`
 FROM
        `{?_MYSQL_PREFIX?}_user_points` AS `p`
@@ -731,10 +731,10 @@ 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);
 }
 
 //
@@ -965,7 +965,7 @@ function getReferralRallyeRefsCount ($currUserid, $oldReferralCount = '0') {
                } // END - if
        } else {
                // Load current refs from database
-               $result_ref = SQL_QUERY_ESC("SELECT
+               $result_ref = sqlQueryEscaped("SELECT
        SUM(s.counter) AS `cnt`
 FROM
        `{?_MYSQL_PREFIX?}_refsystem` AS `s`
@@ -981,10 +981,10 @@ WHERE
                        ), __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 {