]> git.mxchange.org Git - mailer.git/blobdiff - inc/libs/refback_functions.php
Extension ext-refback continued:
[mailer.git] / inc / libs / refback_functions.php
index 92a13150aef08dfb99f2d86f48252abfc9296989..e97e063fecf43478a86c19cc26dcd096b8eb94f8 100644 (file)
@@ -38,7 +38,7 @@
 // Some security stuff...
 if (!defined('__SECURITY')) {
        die();
-}
+} // END - if
 
 // Payback refback for refid and reduce it for current user
 function addRefbackPoints ($userid, $ref, $points, $ref_points) {
@@ -47,7 +47,7 @@ function addRefbackPoints ($userid, $ref, $points, $ref_points) {
        $GLOBALS['refback_depth'][$userid][$ref] = $GLOBALS['ref_level'];
 
        // Init points
-       $return = $points;
+       $return = $ref_points;
 
        // Get all ref levels
        $result_refs = SQL_QUERY('SELECT `level`, `percents` FROM `{?_MYSQL_PREFIX?}_refdepths` WHERE `level` > 0 ORDER BY `level` ASC',
@@ -56,14 +56,15 @@ function addRefbackPoints ($userid, $ref, $points, $ref_points) {
        // "Walk" through all level
        while ($content = SQL_FETCHARRAY($result_refs)) {
                // Reset ref depths
-               // @TODO Try to rewrite the following unset()
-               unset($GLOBALS['ref_level']);
+               initReferalSystem();
 
                // "Walk" through all refids
-               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . $ref . ',level=' . $content['level'] . ',points=' . $points);
+               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . $ref . ',level=' . $content['level'] . ',percents=' . $content['refback_percents'] . ',points=' . $points . ' - LOOP START!');
                foreach (getArrayFromRefbackLevel($userid, $content['level']) as $refid) {
                        // Skip level zero or if both are the same
-                       if ($userid == $refid) continue;
+                       if ($userid == $refid) {
+                               continue;
+                       } // END - if
 
                        // Get refback percents
                        $percents = getRefbackPercents($userid, $refid);
@@ -71,23 +72,39 @@ function addRefbackPoints ($userid, $ref, $points, $ref_points) {
 
                        // Some percents given?
                        if ($percents > 0) {
-                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'points=' . $points . ',[percents]=' . $content['percents'] . ',percents=' . $percents . ',level=' . $content['level']);
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'points=' . $points . ',refback_percents=' . $content['refback_percents'] . ',percents=' . $percents . ',level=' . $content['level']);
                                // Calculate points for refback
-                               $refback = $points * ($content['percents'] / 100) * ($percents / 100);
+                               $refback = $points * ($content['refback_percents'] / 100) * ($percents / 100);
 
                                // Update refback table ('refid' and 'userid' must be exchanged!)
-                               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_refs` SET `points`=`points`+%s WHERE `userid`=%s AND `refid`=%s LIMIT 1",
-                                       array($refback, $refid, $userid), __FUNCTION__, __LINE__);
-                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'refback=' . $refback . ',userid=' . $userid . ',refid=' . $refid . ' - UPDATE! (' . SQL_AFFECTEDROWS() . ')');
+                               SQL_QUERY_ESC("UPDATE
+       `{?_MYSQL_PREFIX?}_user_refs`
+SET
+       `refback_points`=`refback_points`+%s
+WHERE
+       `userid`=%s AND
+       `refid`=%s
+LIMIT 1",
+                                       array(
+                                               $refback,
+                                               $refid,
+                                               $userid
+                                       ), __FUNCTION__, __LINE__);
+
+                               // Something must have been updated
+                               if (SQL_HASZEROAFFECTED()) {
+                                       // Please report this bug
+                                       debug_report_bug(__FUNCTION__, __LINE__, 'Nothing has been updated in user_refs,userid=' . $userid . ',refid=' . $refid . ',refback=' . $refback);
+                               } // END - if
 
                                // Add points again, but only directly
-                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'refback=' . $refback);
-                               addPointsDirectly(sprintf("refback:%s", $refid), $userid, $refback);
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'refback=' . $refback . ',userid=' . $userid . ',ref=' . $ref . ',refid=' . $refid . ' - UPDATE! (' . SQL_AFFECTEDROWS() . ')');
+                               addPointsThroughReferalSystem(sprintf("refback:%s", $refid), $userid, $refback);
 
                                // Reduce points if refid is found
                                if ($refid == $ref) {
                                        // Reduce points here!
-                                       $return = $points * ($content['percents'] / 100) - $refback;
+                                       $return = $points * ($content['refback_percents'] / 100) - $refback;
                                        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'return=' . $return . ' - REDUCED!');
                                } // END - if
                        } // END - if
@@ -101,7 +118,7 @@ function addRefbackPoints ($userid, $ref, $points, $ref_points) {
        $GLOBALS['ref_level'] = $GLOBALS['refback_depth'][$userid][$ref];
 
        // Return them
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . $ref . ',points=' . $points . ',ref_points=' . $ref_points . ',return=' . $return . ' - ENTERED!');
+       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . $ref . ',points=' . $points . ',ref_points=' . $ref_points . ',return=' . $return . ' - EXIT!');
        return $return;
 }
 
@@ -109,7 +126,9 @@ function addRefbackPoints ($userid, $ref, $points, $ref_points) {
 function getRefbackPercents ($userid, $ref) {
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . $ref . ' - ENTERED!');
        // Skip identical ids
-       if ($userid == $ref) return 0;
+       if ($userid == $ref) {
+               return 0;
+       } // END - if
 
        // Is it cached?
        if (!isset($GLOBALS['refback_percents'][$userid][$ref])) {
@@ -117,7 +136,7 @@ function getRefbackPercents ($userid, $ref) {
                $GLOBALS['refback_percents'][$userid][$ref] = '0';
 
                // Get percents from database
-               $result = SQL_QUERY_ESC("SELECT `refback` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `userid`=%s AND `refid`=%s LIMIT 1",
+               $result = SQL_QUERY_ESC("SELECT `refback_percents` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `userid`=%s AND `refid`=%s LIMIT 1",
                        array($ref, $userid), __FUNCTION__, __LINE__);
 
                // Entry found? (Should be!)
@@ -151,7 +170,8 @@ function getArrayFromRefbackLevel ($refid, $level) {
 FROM
        `{?_MYSQL_PREFIX?}_user_refs`
 WHERE
-       `refid`=%s AND `level`=%s
+       `refid`=%s AND
+       `level`=%s
 ORDER BY
        `userid` ASC",
                array($refid, $level), __FUNCTION__, __LINE__);
@@ -174,111 +194,6 @@ ORDER BY
        return $userIds;
 }
 
-// Update "refback table"
-function updateRefbackTable ($userid) {
-       // Make it sure referal level zero (member him-/herself) is at least selected
-       if (empty($GLOBALS['refback_level'])) {
-               $GLOBALS['refback_level'] = 1;
-       } // END - if
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $GLOBALS['refback_level'] . ' - ENTERED!');
-
-       // Init refid
-       $GLOBALS['refback_refid'][$GLOBALS['refback_level']] = '0';
-       $old = '0'; $minus = '0';
-
-       // Check for his referal
-       $result_refid = SQL_QUERY_ESC("SELECT `userid` FROM `{?_MYSQL_PREFIX?}_user_data` WHERE `refid`=%s ORDER BY `userid` ASC",
-               array(bigintval($userid)), __FUNCTION__, __LINE__);
-
-       // When no entry was updated then we have to create it here
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'SQL_NUMROWS()=' . SQL_NUMROWS($result_refid));
-       if (!SQL_HASZERONUMS($result_refid)) {
-               // Load all refids
-               while (list($GLOBALS['refback_refid'][$GLOBALS['refback_level']]) = SQL_FETCHROW($result_refid)) {
-                       // Remmber userid
-                       $GLOBALS['refback_userid'][$GLOBALS['refback_refid'][$GLOBALS['refback_level']]] = $userid;
-
-                       // Refid set?
-                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . $GLOBALS['refback_refid'][$GLOBALS['refback_level']]);
-                       if (($GLOBALS['refback_refid'][$GLOBALS['refback_level']] > 0) && ($GLOBALS['refback_refid'][$GLOBALS['refback_level']] != $userid) && (isset($GLOBALS['refback_refid'][$GLOBALS['refback_level']]))) {
-                               // New userid?
-                               if ((isset($GLOBALS['refback_refid'][$GLOBALS['refback_level']-1])) && (isset($GLOBALS['refback_userid'][$GLOBALS['refback_refid'][$GLOBALS['refback_level']-1]]))) {
-                                       // New userid!
-                                       $old = $userid;
-                                       $userid = $GLOBALS['refback_userid'][$GLOBALS['refback_refid'][$GLOBALS['refback_level']-1]];
-                                       $minus = 1;
-                                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',old=' . $old . ',level=' . $GLOBALS['refback_level'] . ',ref=' . $GLOBALS['refback_refid'][$GLOBALS['refback_level']] . ' - NEW UID!');
-                               } // END - if
-
-                               // Check existence
-                               $result = SQL_QUERY_ESC("SELECT `id` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `userid`=%s AND `level`=%s AND `refid`=%s LIMIT 1",
-                                       array(
-                                               bigintval($userid),
-                                               bigintval($GLOBALS['refback_level']),
-                                               bigintval($GLOBALS['refback_refid'][$GLOBALS['refback_level']])
-                                       ), __FUNCTION__, __LINE__);
-
-                               // Do we have no entry?
-                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $GLOBALS['refback_level'] . ',ref=' . $GLOBALS['refback_refid'][$GLOBALS['refback_level']] . ',minus=' . $minus . ',numRows=' . SQL_NUMROWS($result) . ' - FOUND!');
-                               if (SQL_HASZERONUMS($result)) {
-                                       // Insert this level
-                                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $GLOBALS['refback_level'] . ',ref=' . $GLOBALS['refback_refid'][$GLOBALS['refback_level']] . ' - ADD!');
-                                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_refs` (`userid`,`level`,`refid`) VALUES (%s,%s,%s)",
-                                               array(bigintval($userid), $GLOBALS['refback_level'], bigintval($GLOBALS['refback_refid'][$GLOBALS['refback_level']])), __FUNCTION__, __LINE__);
-
-                                       // Move to next referal level and count his counter one up!
-                                       $GLOBALS['refback_level']++;
-                                       updateRefbackTable($GLOBALS['refback_refid'][($GLOBALS['refback_level'] - 1)]);
-                               } // END - if
-
-                               // Do we have another level here?
-                               if ((($GLOBALS['refback_level']-$minus) > 0) && ($old > 0)) {
-                                       // Restore old one
-                                       $userid = $old;
-
-                                       // Shall we add this as well?
-                                       $result = SQL_QUERY_ESC("SELECT `id` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `userid`=%s AND `level`=%s AND `refid`=%s LIMIT 1",
-                                               array(
-                                                       bigintval($userid),
-                                                       (bigintval($GLOBALS['refback_level']) - $minus),
-                                                       bigintval($GLOBALS['refback_refid'][$GLOBALS['refback_level']])
-                                               ), __FUNCTION__, __LINE__);
-
-                                       // Do we have no entry?
-                                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . ($GLOBALS['refback_level'] - $minus) . ',minus=' . $minus . ',ref=' . $GLOBALS['refback_refid'][$GLOBALS['refback_level']] . ',numRows=' . SQL_NUMROWS($result) . ' - BACK!');
-                                       if (SQL_HASZERONUMS($result)) {
-                                               // Insert this level
-                                               SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_refs` (`userid`,`level`,`refid`) VALUES (%s,%s,%s)",
-                                                       array(bigintval($userid), ($GLOBALS['refback_level']-$minus), bigintval($GLOBALS['refback_refid'][$GLOBALS['refback_level']])), __FUNCTION__, __LINE__);
-                                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . ($GLOBALS['refback_level'] - $minus) . ',ref=' . $GLOBALS['refback_refid'][$GLOBALS['refback_level']] . ' - RETURNED!');
-                                       } // END - if
-                               } // END - if
-                       } // END - if
-               } // END - while
-
-               // Free memory
-               SQL_FREERESULT($result_refid);
-       } // END - if
-
-       // When he has a referal...
-       if ((($GLOBALS['refback_refid'][$GLOBALS['refback_level']] == $userid) || ($GLOBALS['refback_refid'][$GLOBALS['refback_level']] == '0')) && (isExtensionInstalledAndNewer('cache', '0.1.2')) && (!isset($GLOBALS['refback_cached']))) {
-               // Remove cache here
-               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . $GLOBALS['refback_refid'][$GLOBALS['refback_level']] . ' - CACHE!');
-               if ($GLOBALS['cache_instance']->loadCacheFile('refback')) $GLOBALS['cache_instance']->removeCacheFile();
-               $GLOBALS['refback_cached'] = 1;
-       } // END - if
-
-       // "Walk" back here
-       $GLOBALS['refback_level']--;
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',refback_level=' . $GLOBALS['refback_level'] .' - LEVEL!');
-
-       // Fix empty refid
-       if (!isset($GLOBALS['refback_refid'][$GLOBALS['refback_level']-1])) {
-               $GLOBALS['refback_refid'][$GLOBALS['refback_level']-1] = '0';
-       } // END - if
-       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',refback_level=' . {$GLOBALS['refback_level'] . ',ref=' . $GLOBALS['refback_refid'][$GLOBALS['refback_level']-1] . ' - EXIT!');
-}
-
 // "Getter" for array for user refs in given level
 function getArrayFromRefbackUserRefs ($userid, $level) {
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ' - ENTERED!');
@@ -289,10 +204,12 @@ function getArrayFromRefbackUserRefs ($userid, $level) {
        $result = SQL_QUERY_ESC("SELECT
        r.`id`,
        r.`refid`,
-       r.`refback`,
-       r.`points`,
+       r.`refback_percents`,
+       r.`refback_points`,
        d.`status`,
        d.`joined`,
+       d.`mails_confirmed`,
+       d.`emails_received`,
        d.`refid` AS `level_refid`
 FROM
        `{?_MYSQL_PREFIX?}_user_refs` AS r
@@ -311,6 +228,15 @@ ORDER BY
        if (!SQL_HASZERONUMS($result)) {
                // Fetch all entries
                while ($row = SQL_FETCHARRAY($result)) {
+                       // Init click rate
+                       $row['click_rate'] = '0';
+
+                       // Does he have received some mails?
+                       if ($row['emails_received'] > 0) {
+                               // Calculate click rate
+                               $row['click_rate'] = ($row['mails_confirmed'] / $row['emails_received'] * 100);
+                       } // END - if
+
                        // Add row
                        $refs[$row['id']] = $row;
                } // END - while
@@ -334,7 +260,7 @@ function getArrayFromUserRefbackData ($id) {
        $id = bigintval($id);
 
        // Get entry from database
-       $result = SQL_QUERY_ESC("SELECT `id`, `userid`, `refid`, `refback`, `level`, `points` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `id`=%s AND `userid`=%s LIMIT 1",
+       $result = SQL_QUERY_ESC("SELECT `id`, `userid`, `refid`, `refback_percents`, `level`, `refback_points` FROM `{?_MYSQL_PREFIX?}_user_refs` WHERE `id`=%s AND `userid`=%s LIMIT 1",
                array($id, getMemberId()), __FUNCTION__, __LINE__);
 
        // Is there an entry?
@@ -353,22 +279,22 @@ function getArrayFromUserRefbackData ($id) {
 
 // Update refback percents (but with some sanity-checks!
 function updateMemberRefbackPercents ($id, $percents) {
-       //* logDebugMessage(__FUNCTION__, __LINE__, 'id=' . $id . ',percents=' . $percents . ' - ENTERED!');
+       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'id=' . $id . ',percents=' . $percents . ' - ENTERED!');
        // Default status is failed
-       $status['message'] = '{--MEMBER_REFBACK_ERROR_GENERAL--}';
+       $status['message'] = 'MEMBER_REFBACK_ERROR_GENERAL';
 
        // Do some sanity-checks
        if (!isMember()) {
                // No member!
-               $status['message'] = '{--MEMBER_REFBACK_ERROR_NO_MEMBER--}';
+               $status['message'] = 'MEMBER_REFBACK_ERROR_NO_MEMBER';
                return $status;
        } elseif (''.$id.'' != ''.($id + 0).'') {
                // No number!
-               $status['message'] = '{--MEMBER_REFBACK_ERROR_INVALID_ID_NUMBER--}';
+               $status['message'] = 'MEMBER_REFBACK_ERROR_INVALID_ID_NUMBER';
                return $status;
        } elseif (($percents < 0) || ($percents > 100)) {
                // Percentage is not valid!
-               $status['message'] = '{--MEMBER_REFBACK_ERROR_INVALID_PERCENTAGE--}';
+               $status['message'] = 'MEMBER_REFBACK_ERROR_INVALID_PERCENTAGE';
                return $status;
        }
 
@@ -378,7 +304,7 @@ function updateMemberRefbackPercents ($id, $percents) {
        // Is this valid?
        if (count($dummy) == 0) {
                // id does not belong to user!
-               $status['message'] = '{--MEMBER_REFBACK_ERROR_ID_MISMATCH--}';
+               $status['message'] = 'MEMBER_REFBACK_ERROR_ID_MISMATCH';
                return $status;
        } // END - if
 
@@ -386,18 +312,22 @@ function updateMemberRefbackPercents ($id, $percents) {
        $percents = convertCommaToDot($percents);
 
        // Update entry
-       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_refs` SET `refback`='%s' WHERE `id`=%s AND `userid`=%s LIMIT 1",
-               array($percents, $id, getMemberId()), __FUNCTION__, __LINE__);
+       SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_refs` SET `refback_percents`='%s' WHERE `id`=%s AND `userid`=%s LIMIT 1",
+               array(
+                       $percents,
+                       $id,
+                       getMemberId()
+               ), __FUNCTION__, __LINE__);
 
        // Entry updated?
        if (SQL_HASZEROAFFECTED()) {
                // Entry not updated!
-               $status['message'] = '{--MEMBER_REFBACK_ERROR_NOT_UPDATED--}';
+               $status['message'] = 'MEMBER_REFBACK_ERROR_NOT_UPDATED';
                return $status;
        } // END - if
 
        // Prepare email content
-       $dummy['percents'] = $percents;
+       $dummy['refback_percents'] = $percents;
 
        // Load member email template
        $mail = loadEmailTemplate('member_refback', $dummy, $dummy['refid']);
@@ -412,7 +342,7 @@ function updateMemberRefbackPercents ($id, $percents) {
        $status['ok'] = true;
 
        // Return status array
-       //* logDebugMessage(__FUNCTION__, __LINE__, 'id=' . $id . ',percents=' . $percents . ' - EXIT!');
+       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'id=' . $id . ',percents=' . $percents . ' - EXIT!');
        return $status;
 }