Required fix for NULL vs. 0 in user_points
[mailer.git] / inc / mysql-manager.php
index 6df2531..4b9ee0e 100644 (file)
@@ -1034,7 +1034,7 @@ function addPointsThroughReferalSystem ($subject, $userid, $points, $sendNotify
        if (!isset($GLOBALS['ref_level'])) {
                // Initialialize referal system
                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, ' Referal system initialized!');
-               $GLOBALS['ref_level'] = '0';
+               $GLOBALS['ref_level'] = NULL;
        } else {
                // Increase referal level
                $GLOBALS['ref_level']++;
@@ -1077,7 +1077,7 @@ function addPointsThroughReferalSystem ($subject, $userid, $points, $sendNotify
                                        $pointsColumn,
                                        $ref_points,
                                        bigintval($userid),
-                                       bigintval($GLOBALS['ref_level'])
+                                       makeZeroToNull($GLOBALS['ref_level'])
                                ), __FUNCTION__, __LINE__);
                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'pointsColumn='.$pointsColumn.',ref_points='.$ref_points.',userid='.$userid.',depth='.$GLOBALS['ref_level'].',mode='.$addMode.' - UPDATE! ('.SQL_AFFECTEDROWS().')');
 
@@ -1088,7 +1088,7 @@ function addPointsThroughReferalSystem ($subject, $userid, $points, $sendNotify
                                        array(
                                                $pointsColumn,
                                                bigintval($userid),
-                                               bigintval($GLOBALS['ref_level']),
+                                               makeZeroToNull($GLOBALS['ref_level']),
                                                $ref_points
                                        ), __FUNCTION__, __LINE__);
                                //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'data='.$pointsColumn.',ref_points='.$ref_points.',userid='.$userid.',depth='.$GLOBALS['ref_level'].',mode='.$addMode.' - INSERTED! ('.SQL_AFFECTEDROWS().')');
@@ -1738,7 +1738,7 @@ function generateCategoryOptionsList ($mode) {
 }
 
 // Add bonus mail to queue
-function addBonusMailToQueue ($subject, $text, $receiverList, $points, $seconds, $url, $cat, $mode='normal', $receiver=0) {
+function addBonusMailToQueue ($subject, $text, $receiverList, $points, $seconds, $url, $categoryId, $mode='normal', $receiver=0) {
        // Is admin or bonus extension there?
        if (!isAdmin()) {
                // Abort here
@@ -1759,27 +1759,21 @@ function addBonusMailToQueue ($subject, $text, $receiverList, $points, $seconds,
 
        // HTML extension active?
        if (isExtensionActive('html_mail')) {
-               // No HTML by default
-               $HTML = 'N';
-
-               // HTML mode?
-               if ($mode == 'html') {
-                       // Yes, please
-                       $HTML = 'Y';
-               } // END - if
+               // Determine if we have HTML mode active
+               $HTML = convertBooleanToYesNo($mode == 'html');
 
                // Add HTML mail
                SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_bonus`
 (`subject`, `text`, `receivers`, `points`, `time`, `data_type`, `timestamp`, `url`, `cat_id`, `target_send`, `mails_sent`, `html_msg`)
-VALUES ('%s','%s','%s','%s','%s','NEW', UNIX_TIMESTAMP(),'%s','%s','%s','%s','%s')",
+VALUES ('%s','%s','%s',%s,%s,'NEW', UNIX_TIMESTAMP(),'%s',%s,%s,%s,'%s')",
                array(
                        $subject,
                        $text,
                        $receiverList,
                        $points,
-                       $seconds,
+                       bigintval($seconds),
                        $url,
-                       $cat,
+                       bigintval($categoryId),
                        $target,
                        bigintval($receiver),
                        $HTML
@@ -1788,15 +1782,15 @@ VALUES ('%s','%s','%s','%s','%s','NEW', UNIX_TIMESTAMP(),'%s','%s','%s','%s','%s
                // Add regular mail
                SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_bonus`
 (`subject`, `text`, `receivers`, `points`, `time`, `data_type`, `timestamp`, `url`, `cat_id`, `target_send`, `mails_sent`)
-VALUES ('%s','%s','%s','%s','%s','NEW', UNIX_TIMESTAMP(),'%s','%s','%s','%s')",
+VALUES ('%s','%s','%s',%s,%s,'NEW', UNIX_TIMESTAMP(),'%s',%s,%s,%s)",
                array(
                        $subject,
                        $text,
                        $receiverList,
                        $points,
-                       $seconds,
+                       bigintval($seconds),
                        $url,
-                       $cat,
+                       bigintval($categoryId),
                        $target,
                        bigintval($receiver),
                ), __FUNCTION__, __LINE__);
@@ -1804,7 +1798,7 @@ VALUES ('%s','%s','%s','%s','%s','NEW', UNIX_TIMESTAMP(),'%s','%s','%s','%s')",
 }
 
 // Generate a receiver list for given category and maximum receivers
-function generateReceiverList ($cat, $receiver, $mode = '') {
+function generateReceiverList ($categoryId, $receiver, $mode = '') {
        // Init variables
        $CAT_TABS     = '';
        $CAT_WHERE    = '';
@@ -1812,8 +1806,8 @@ function generateReceiverList ($cat, $receiver, $mode = '') {
        $result       = false;
 
        // Secure data
-       $cat      = bigintval($cat);
-       $receiver = bigintval($receiver);
+       $categoryId = bigintval($categoryId);
+       $receiver   = bigintval($receiver);
 
        // Is the receiver zero and mode set?
        if (($receiver == '0') && (!empty($mode))) {
@@ -1822,10 +1816,10 @@ function generateReceiverList ($cat, $receiver, $mode = '') {
        } // END - if
 
        // Category given?
-       if ($cat > 0) {
+       if ($categoryId > 0) {
                // Select category
                $CAT_TABS  = "LEFT JOIN `{?_MYSQL_PREFIX?}_user_cats` AS c ON d.`userid`=c.`userid`";
-               $CAT_WHERE = sprintf(" AND c.`cat_id`=%s", $cat);
+               $CAT_WHERE = sprintf(" AND c.`cat_id`=%s", $categoryId);
        } // END - if
 
        // Exclude users in holiday?
@@ -1836,13 +1830,13 @@ function generateReceiverList ($cat, $receiver, $mode = '') {
 
        if ((isExtensionActive('html_mail')) && ($mode == 'html')) {
                // Only include HTML receivers
-               $result = SQL_QUERY_ESC("SELECT d.userid FROM `{?_MYSQL_PREFIX?}_user_data` AS d ".$CAT_TABS." WHERE d.`status`='CONFIRMED' AND d.`html`='Y'".$CAT_WHERE." ORDER BY d.{?order_select?} {?order_mode?} LIMIT %s",
+               $result = SQL_QUERY_ESC("SELECT d.`userid` FROM `{?_MYSQL_PREFIX?}_user_data` AS d ".$CAT_TABS." WHERE d.`status`='CONFIRMED' AND d.`html`='Y'".$CAT_WHERE." ORDER BY d.`{?order_select?}` {?order_mode?} LIMIT %s",
                        array(
                                $receiver
                        ), __FUNCTION__, __LINE__);
        } else {
                // Include all
-               $result = SQL_QUERY_ESC("SELECT d.userid FROM `{?_MYSQL_PREFIX?}_user_data` AS d ".$CAT_TABS." WHERE d.`status`='CONFIRMED'".$CAT_WHERE." ORDER BY d.{?order_select?} {?order_mode?} LIMIT %s",
+               $result = SQL_QUERY_ESC("SELECT d.`userid` FROM `{?_MYSQL_PREFIX?}_user_data` AS d ".$CAT_TABS." WHERE d.`status`='CONFIRMED'".$CAT_WHERE." ORDER BY d.`{?order_select?}` {?order_mode?} LIMIT %s",
                        array(
                                $receiver
                        ), __FUNCTION__, __LINE__);
@@ -2017,5 +2011,83 @@ function updateLastActivity($userid) {
                ), __FUNCTION__, __LINE__);
 }
 
+// Get points data for given extension's name
+function getPointsDataArrayFromExtensionName ($ext_name) {
+       // If we have cache, shortcut it here
+       if (isset($GLOBALS['cache_array']['points_data'][$ext_name])) {
+               // Return it
+               return $GLOBALS['cache_array']['points_data'][$ext_name];
+       } // END - if
+
+       // Now checkout the entry in database table
+       $result = SQL_QUERY_ESC("SELECT `id`, `ext_name`, `column_name`, `locked_mode`, `payment_method` FROM `{?_MYSQL_PREFIX?}_points_data` WHERE `ext_name`='%s' LIMIT 1",
+               array($ext_name), __FUNCTION__, __LINE__);
+
+       // Do we have an entry?
+       if (SQL_NUMROWS($result) == 1) {
+               // Then load it
+               $pointsData = SQL_FETCHARRAY($result);
+
+               // Add all remaining entries
+               foreach ($pointsData as $key=>$value) {
+                       $GLOBALS['cache_array']['points_data'][$ext_name][$key] = $value;
+               } // END - foreach
+       } else {
+               /*
+                * Having no entry is not bad but it means that all points will go to
+                * the general account which the user can let payout.
+                */
+               logDebugMessage(__FUNCTION__, __LINE__, 'ext_name=' . $ext_name . ' - No entry found, switching to general points account.');
+       }
+
+       // Free result
+       SQL_FREERESULT($result);
+
+       // Return it
+       return $GLOBALS['cache_array']['points_data'][$ext_name];
+}
+
+// Determines the right points column name for given extension and 'locked'
+function getPointsColumnNameFromExtensionNameLocked ($ext_name, $isLocked) {
+       // Extension sql_patches must be up-to-date
+       if (isExtensionInstalledAndOlder('sql_patches', '0.8.0')) {
+               // Please update ext-sql_patches
+               debug_report_bug(__FUNCTION__, __LINE__, 'sql_patches is out-dated. Please update to at least 0.8.0 to continue. ext_name=' . $ext_name . ',isLocked=' . intval($isLocked));
+       } // END - if
+
+       // Get the points_data entry
+       $pointsData = getPointsDataArrayFromExtensionName($ext_name);
+
+       // Regular points by default
+       $columnName = $pointsData['column_name'];
+
+       // Are the points locked?
+       if (($isLocked === true) && ($pointsData['locked_mode'] == 'LOCKED')) {
+               // Locked points, so prefix it
+               $columnName = 'locked_' . $pointsData['column_name'];
+       } // END - if
+
+       // Return the result
+       return $columnName;
+}
+
+// Determines the payment method for given extension and 'locked'
+function getPaymentMethodFromExtensionName ($ext_name) {
+       // Extension sql_patches must be up-to-date
+       if (isExtensionInstalledAndOlder('sql_patches', '0.8.0')) {
+               // Please update ext-sql_patches
+               debug_report_bug(__FUNCTION__, __LINE__, 'sql_patches is out-dated. Please update to at least 0.8.0 to continue. ext_name=' . $ext_name . ',isLocked=' . intval($isLocked));
+       } // END - if
+
+       // Get the points_data entry
+       $pointsData = getPointsDataArrayFromExtensionName($ext_name);
+
+       // Regular points by default
+       $paymentMethod = $pointsData['payment_method'];
+
+       // Return the result
+       return $paymentMethod;
+}
+
 // [EOF]
 ?>