X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;ds=sidebyside;f=inc%2Freferral-functions.php;h=26700a53061e710b70659489379f8742bb51b0d5;hb=596c8ab32594401ca84abfbfe35513ddfff31bec;hp=c66289a0e36e9c6f074445681d537ab082c52154;hpb=6f9f29d5caee60a2cceae33a7a53e1b4c7319a0c;p=mailer.git

diff --git a/inc/referral-functions.php b/inc/referral-functions.php
index c66289a0e3..26700a5306 100644
--- a/inc/referral-functions.php
+++ b/inc/referral-functions.php
@@ -16,7 +16,7 @@
  * $Author::                                                          $ *
  * -------------------------------------------------------------------- *
  * Copyright (c) 2003 - 2009 by Roland Haeder                           *
- * Copyright (c) 2009 - 2011 by Mailer Developer Team                   *
+ * Copyright (c) 2009 - 2012 by Mailer Developer Team                   *
  * For more information visit: http://mxchange.org                      *
  *                                                                      *
  * This program is free software; you can redistribute it and/or modify *
@@ -44,7 +44,7 @@ if (!defined('__SECURITY')) {
 function initReferralSystem () {
 	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, ' Referral system initialized!');
 	$GLOBALS['ref_level']  = NULL;
-	$GLOBALS['ref_system'] = true;
+	$GLOBALS['ref_system'] = TRUE;
 }
 
 // Getter fro ref level percents
@@ -52,11 +52,11 @@ function getReferralLevelPercents ($level) {
 	// Default is zero
 	$data['percents'] = '0';
 
-	// Do we have cache?
+	// Is there cache?
 	if ((isset($GLOBALS['cache_array']['refdepths']['level'])) && (isExtensionActive('cache'))) {
 		// First look for level
 		$key = array_search($level, $GLOBALS['cache_array']['refdepths']['level']);
-		if ($key !== false) {
+		if ($key !== FALSE) {
 			// Entry found
 			$data['percents'] = $GLOBALS['cache_array']['refdepths']['percents'][$key];
 
@@ -83,7 +83,7 @@ function getReferralLevelPercents ($level) {
 }
 
 /**
- * Dynamic referral and points system, can also send mails!
+ * Dynamic Referral and points system, can also send mails!
  *
  * subject       = Subject line, write in lower-case letters and underscore is allowed
  * userid        = Referral id wich should receive...
@@ -91,9 +91,9 @@ function getReferralLevelPercents ($level) {
  * refid         = inc/modules/guest/what-confirm.php need this
  */
 function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NULL) {
-	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',points=' . $points . ',refid=' . makeNullToZero($refid) . ' - ENTERED!');
+	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',points=' . $points . ',refid=' . convertNullToZero($refid) . ' - ENTERED!');
 	// By default nothing has been added
-	$added = false;
+	$added = FALSE;
 
 	// Determine payment method and notification
 	$paymentMethod = strtoupper(getPaymentMethodFromSubject($subject));
@@ -109,29 +109,29 @@ function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NU
 	setCurrentUserId($userid);
 
 	// Check user account
-	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',points=' . $points . ',paymentMethod=' . $paymentMethod . ',sendNotify=' . intval($sendNotify));
+	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',points=' . $points . ',paymentMethod=' . $paymentMethod . ',sendNotify=' . intval($sendNotify));
 	if (fetchUserData($userid)) {
-		// Determine wether the user has some mails to click before he/she gets the points
-		$locked = ifUserPointsLocked($userid);
+		// Determine whether the user has some mails to click before he/she gets the points
+		$isLocked = ifUserPointsLocked($userid);
 
 		// Detect database column
-		$pointsColumn = determinePointsColumnFromSubjectLocked($subject, $locked);
+		$pointsColumn = determinePointsColumnFromSubjectLocked($subject, $isLocked);
 
 		// Get percents
-		$per = getReferralLevelPercents($GLOBALS['ref_level']);
-		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',points=' . $points . ',depth=' . makeNullToZero($GLOBALS['ref_level']) . ',per=' . $per . ',mode=' . $paymentMethod . ',pointsColumn=' . $pointsColumn . ',locked=' . intval($locked) . ',refid=' . getUserData('refid'));
+		$percents = getReferralLevelPercents($GLOBALS['ref_level']);
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',points=' . $points . ',depth=' . convertNullToZero($GLOBALS['ref_level']) . ',percents=' . $percents . ',mode=' . $paymentMethod . ',pointsColumn=' . $pointsColumn . ',isLocked=' . intval($isLocked) . ',refid=' . getUserData('refid'));
 
 		// Some percents found?
-		if ($per > 0) {
+		if ($percents > 0) {
 			// Calculate new points
-			$ref_points = $points * $per / 100;
+			$ref_points = $points * $percents / 100;
 
 			// Pay refback here if level > 0 and in ref-mode
-			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',refid=' . makeNullToZero(getUserData('refid')) . ',points=' . $points . ',paymentMethod=' . $paymentMethod);
-			if (($userid != $refid) && ($paymentMethod == 'REFERRAL') && (isValidUserId(getUserData('refid'))) && (isExtensionActive('refback'))) {
-				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',refid=' . makeNullToZero(getUserData('refid')) . ',ref_points=' . $ref_points . ',depth=' . makeNullToZero($GLOBALS['ref_level']) . ' - BEFORE!');
+			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',refid=' . convertNullToZero(getUserData('refid')) . ',points=' . $points . ',paymentMethod=' . $paymentMethod);
+			if (($userid != $refid) && (substr($subject, 0, 8) != 'refback:') &&($paymentMethod == 'REFERRAL') && (isValidUserId(getUserData('refid'))) && (isExtensionActive('refback'))) {
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',refid=' . convertNullToZero(getUserData('refid')) . ',ref_points=' . $ref_points . ',depth=' . convertNullToZero($GLOBALS['ref_level']) . ' - BEFORE!');
 				$ref_points = addRefbackPoints($userid, getUserData('refid'), $points, $ref_points);
-				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',refid=' . makeNullToZero(getUserData('refid')) . ',ref_points=' . $ref_points . ',depth=' . makeNullToZero($GLOBALS['ref_level']) . ' - AFTER!');
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',refid=' . convertNullToZero(getUserData('refid')) . ',ref_points=' . $ref_points . ',depth=' . convertNullToZero($GLOBALS['ref_level']) . ' - AFTER!');
 			} // END - if
 
 			// Update points...
@@ -155,19 +155,19 @@ function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NU
 						bigintval($GLOBALS['ref_level'])
 					), __FUNCTION__, __LINE__);
 			}
-			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'pointsColumn='.$pointsColumn.',ref_points='.$ref_points.',userid='.$userid.',depth='.makeNullToZero($GLOBALS['ref_level']).',mode='.$paymentMethod.' - UPDATE! ('.SQL_AFFECTEDROWS().')');
+			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'pointsColumn='.$pointsColumn.',ref_points='.$ref_points.',userid='.$userid.',depth='.convertNullToZero($GLOBALS['ref_level']).',mode='.$paymentMethod.' - UPDATE! ('.SQL_AFFECTEDROWS().')');
 
 			// No entry updated?
 			if (SQL_HASZEROAFFECTED()) {
 				// First ref in this level! :-)
-				SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_points` (`userid`,`ref_depth`,`%s`) VALUES (%s, %s, %s)",
+				SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_points` (`userid`, `ref_depth`, `%s`) VALUES (%s, %s, %s)",
 					array(
 						$pointsColumn,
 						bigintval($userid),
-						makeZeroToNull($GLOBALS['ref_level']),
+						convertZeroToNull($GLOBALS['ref_level']),
 						$ref_points
 					), __FUNCTION__, __LINE__);
-				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'data='.$pointsColumn.',ref_points='.$ref_points.',userid='.$userid.',depth='.makeNullToZero($GLOBALS['ref_level']).',mode='.$paymentMethod.' - INSERTED! ('.SQL_AFFECTEDROWS().')');
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'data='.$pointsColumn.',ref_points='.$ref_points.',userid='.$userid.',depth='.convertNullToZero($GLOBALS['ref_level']).',mode='.$paymentMethod.' - INSERTED! ('.SQL_AFFECTEDROWS().')');
 			} // END - if
 
 			// Check affected rows
@@ -176,17 +176,17 @@ function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NU
 
 			// Prepare data for the filter
 			$filterData = array(
-				'subject'    => $subject,
-				'userid'     => $userid,
-				'points'     => $points,
-				'ref_points' => $ref_points,
-				'column'     => $pointsColumn,
-				'notify'     => $sendNotify,
-				'refid'      => $refid,
-				'locked'     => $locked,
-				'mode'       => 'add',
-				'add_mode'   => $paymentMethod,
-				'added'      => $added
+				'subject'     => $subject,
+				'userid'      => $userid,
+				'points'      => $points,
+				'ref_points'  => $ref_points,
+				'column'      => $pointsColumn,
+				'notify'      => $sendNotify,
+				'refid'       => $refid,
+				'locked'      => $isLocked,
+				'points_mode' => 'add',
+				'add_mode'    => $paymentMethod,
+				'added'       => $added
 			);
 
 			// Filter it now
@@ -196,60 +196,102 @@ function addPointsThroughReferralSystem ($subject, $userid, $points, $refid = NU
 			$added = $filterData['added'];
 			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'added=' . intval($added) . ' - AFTER FILTER');
 
-			// Points updated, maybe I shall send him an email?
-			if (($sendNotify === true) && (isValidUserId(getUserData('refid'))) && ($locked === false)) {
+			// Debug message
+			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',refid=' . $refid . ',paymentMethod=' . $paymentMethod . ',sendNotify=' . intval($sendNotify) . ',isLocked=' . intval($isLocked));
+
+			// Send "referral confirmed" mails out?
+			if ((isValidUserid($refid)) && ($refid != $userid) && ($sendNotify === TRUE)) {
+				// Calculate the referral's points and percents
+				$percentsReferral = getReferralLevelPercents($GLOBALS['ref_level'] + 1);
+
+				// Calculate new points
+				$ref_points = $ref_points * $percentsReferral / 100;
+
 				// Prepare content
 				$content = array(
-					'percents' => $per,
-					'level'    => bigintval($GLOBALS['ref_level']),
-					'points'   => $ref_points,
+					'userid'         => bigintval($userid),
+					'refid'          => $refid,
+					'level'          => bigintval($GLOBALS['ref_level'] + 1),
+					'percents'       => $percentsReferral,
+					'points'         => ($paymentMethod == 'REFERRAL' ? $ref_points : '0'),
+					'payment_method' => $paymentMethod,
+					'subject'        => $subject,
 				);
 
 				// Load email template
 				$message = loadEmailTemplate('guest_user_confirmed_referral', $content, bigintval($userid));
 
 				// Send email
-				sendEmail($userid, '{--THANX_REFERRAL_ONE_SUBJECT--}', $message);
-			} elseif (($sendNotify === true) && (!isValidUserId(getUserData('refid'))) && ($locked === false) && ($paymentMethod == 'DIRECT')) {
-				// Prepare content
+				sendEmail($userid, '{--THANKS_REFERRAL_ONE_SUBJECT--}', $message);
+			} // END - if
+
+			// Points updated, maybe I shall send him an email?
+			if (($sendNotify === TRUE) && ($isLocked === FALSE)) {
+				// "Explode" subject
+				$subjectArray = explode(':', $subject);
+				$subjectUserid = (isset($subjectArray[1])) ? $subjectArray[1] : '0';
+
+				// Generic delivery of mails, so prepare data
 				$content = array(
-					'reason'  => '{--REASON_DIRECT_PAYMENT--}',
-					'subject' => $subject,
-					'points'  => $ref_points
+					'userid'         => $userid,
+					'percents'       => $percents,
+					'level'          => bigintval($GLOBALS['ref_level']),
+					'points'         => $ref_points,
+					'column'         => $pointsColumn,
+					'subject'        => $subjectArray[0],
+					'subject_userid' => $subjectUserid,
+					'payment_method' => $paymentMethod,
 				);
 
-				// Load message
-				$message = loadEmailTemplate('member_add_points', $content, $userid);
+				// Load email template
+				$message = loadEmailTemplate('member_' . $subjectArray[0] . '_' . strtolower($paymentMethod), $content, $userid);
 
-				// And sent it away
-				sendEmail($userid, '{--DIRECT_PAYMENT_SUBJECT--}', $message);
-				if (!isGetRequestElementSet('mid')) {
-					// Output message to admin
-					displayMessage('{--ADMIN_POINTS_ADDED--}');
-				} // END - if
-			}
+				// Send email
+				sendEmail($userid, '{%message,MEMBER_' . $paymentMethod . '_' . strtoupper($subjectArray[0]) . '_SUBJECT=' . $subjectUserid . '%}', $message);
+
+				// Also send admin notification
+				sendAdminNotification(
+					// Subject
+					'{%message,ADMIN_' . $paymentMethod . '_' . strtoupper($subjectArray[0]) . '_SUBJECT=' . $subjectUserid . '%}',
+					// Template name
+					'admin_' . $subjectArray[0] . '_' . strtolower($paymentMethod),
+					// Template content (data array)
+					$content,
+					// User id
+					$userid
+				);
+			} // END - if
 
-			// Increase referral level, if payment method is REFERRAL
+			// Increase referral level, if payment method is 'REFERRAL'
 			if ($paymentMethod == 'REFERRAL') {
 				// Increase it
 				$GLOBALS['ref_level']++;
-				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Referral level increased, ref_level=' . makeNullToZero($GLOBALS['ref_level']) . ',points=' . $points . ',refid=' . makeNullToZero(getUserData('refid')) . ',userid=' . $userid . ',paymentMethod=' . $paymentMethod);
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Referral level increased, ref_level=' . convertNullToZero($GLOBALS['ref_level']) . ',points=' . $points . ',refid=' . convertNullToZero(getUserData('refid')) . ',userid=' . $userid . ',paymentMethod=' . $paymentMethod);
 			} elseif (isDebugModeEnabled()) {
 				// Not increasing referral level, DIRECT payment method
-				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Referral level *NOT* increased, ref_level=' . makeNullToZero($GLOBALS['ref_level']) . ',points=' . $points . ',refid=' . makeNullToZero(getUserData('refid')) . ',userid=' . $userid . ',paymentMethod=' . $paymentMethod);
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Referral level *NOT* increased, ref_level=' . convertNullToZero($GLOBALS['ref_level']) . ',points=' . $points . ',refid=' . convertNullToZero(getUserData('refid')) . ',userid=' . $userid . ',paymentMethod=' . $paymentMethod);
 			}
 
+			// Remove any :x
+			$subject = removeDoubleDotFromSubject($subject);
+
 			// Maybe there's another ref?
-			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'points=' . $points . ',refid(var|data)=' . makeNullToZero($refid) . '|' . makeNullToZero(getUserData('refid')) . ',userid=' . $userid . ',paymentMethod=' . $paymentMethod);
+			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'points=' . $points . ',refid(var|data)=' . convertNullToZero($refid) . '|' . convertNullToZero(getUserData('refid')) . ',userid=' . $userid . ',paymentMethod=' . $paymentMethod . ',subject=' . $subject . ',ref_level=' . $GLOBALS['ref_level']);
 			if ((isValidUserId(getUserData('refid'))) && ($points > 0) && (getUserData('refid') != $userid) && ($paymentMethod == 'REFERRAL')) {
+				// Is _ref there?
+				if (substr($subject, -4, 4) == '_ref') {
+					// Then remove it, no double _ref suffix!
+					$subject = substr($subject, 0, -4);
+				} // END - if
+
 				// Then let's credit him here...
-				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',refid=' . makeNullToZero(getUserData('refid')) . ',points=' . $points . ',ref_points=' . $ref_points . ',added[' . gettype($added) . ']=' . intval($added) . ' - ADVANCE!');
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',refid=' . convertNullToZero(getUserData('refid')) . ',points=' . $points . ',ref_points=' . $ref_points . ',added[' . gettype($added) . ']=' . intval($added) . ',ref_level=' . $GLOBALS['ref_level'] . ' - ADVANCE!');
 				$added = ($added && addPointsThroughReferralSystem(sprintf("%s_ref:%s", $subject, $GLOBALS['ref_level']), getUserData('refid'), $points, getFetchedUserData('userid', getUserData('refid'), 'refid')));
 			} // END - if
 		} // END - if
 	} // END - if
 
-	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',points=' . $points . ',sendNotify=' . intval($sendNotify) . ',refid=' . makeNullToZero($refid) . ',paymentMethod=' . $paymentMethod . ' - EXIT!');
+	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'subject=' . $subject . ',userid=' . $userid . ',points=' . $points . ',sendNotify=' . intval($sendNotify) . ',refid=' . convertNullToZero($refid) . ',paymentMethod=' . $paymentMethod . ' - EXIT!');
 	return $added;
 }
 
@@ -263,7 +305,7 @@ function updateReferralCounter ($userid) {
 	if (fetchUserData($userid)) {
 		// Get it
 		$ref = getUserData('refid');
-		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . makeZeroToNull($ref) . ' - FETCHED!');
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . convertZeroToNull($ref) . ' - FETCHED!');
 	} // END - if
 
 	// Init entries
@@ -274,7 +316,7 @@ function updateReferralCounter ($userid) {
 		$GLOBALS['cache_array']['ref_level'][$ref] = NULL;
 	} // END - if
 
-	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . makeZeroToNull($ref));
+	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . convertZeroToNull($ref));
 
 	// When he has a referral...
 	if (($ref > 0) && ($ref != $userid)) {
@@ -293,10 +335,10 @@ function updateReferralCounter ($userid) {
 		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ref=' . $ref . ',level=' . $GLOBALS['cache_array']['ref_level'][$ref] . ',updated=' . SQL_AFFECTEDROWS());
 		if (SQL_HASZEROAFFECTED()) {
 			// First count!
-			SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_refsystem` (`userid`,`level`,`counter`) VALUES (%s,%s,1)",
+			SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_refsystem` (`userid`, `level`, `counter`) VALUES (%s,%s,1)",
 				array(
 					bigintval($ref),
-					makeZeroToNull($GLOBALS['cache_array']['ref_level'][$ref])
+					convertZeroToNull($GLOBALS['cache_array']['ref_level'][$ref])
 				), __FUNCTION__, __LINE__);
 			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ref=' . $ref . ',level=' . $GLOBALS['cache_array']['ref_level'][$ref] . ',SQL_AFFECTEDROWS()=' . SQL_AFFECTEDROWS());
 		} // END - if
@@ -305,14 +347,14 @@ function updateReferralCounter ($userid) {
 		updateReferralCounter($ref);
 	} elseif ((($ref == $userid) || ($ref == '0')) && (isExtensionInstalledAndNewer('cache', '0.1.2'))) {
 		// Remove cache here
-		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ref=' . makeZeroToNull($ref) . ' - CACHE!');
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'ref=' . convertZeroToNull($ref) . ' - CACHE!');
 		rebuildCache('refsystem', 'refsystem');
 	}
 
 	// Update the referral table
 	updateReferralTable($userid);
 
-	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . makeZeroToNull($ref) . ',level=' . makeZeroToNull($GLOBALS['cache_array']['ref_level'][$ref]) . ' - EXIT!');
+	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',ref=' . convertZeroToNull($ref) . ',level=' . convertZeroToNull($GLOBALS['cache_array']['ref_level'][$ref]) . ' - EXIT!');
 }
 
 // Subtract points from database and mediadata cache
@@ -326,11 +368,11 @@ function subtractPoints ($subject, $userid, $points) {
 
 	// Prepare filter data
 	$filterData = array(
-		'subject' => $subject,
-		'userid'  => $userid,
-		'points'  => $points,
-		'mode'    => 'sub',
-		'added'   => (!SQL_HASZEROAFFECTED())
+		'subject'     => $subject,
+		'userid'      => $userid,
+		'points'      => $points,
+		'points_mode' => 'sub',
+		'added'       => (!SQL_HASZEROAFFECTED())
 	);
 
 	// Insert booking record
@@ -346,8 +388,14 @@ function getUserReferralPoints ($userid, $level) {
 	$refs = array();
 
 	// Get refs from database
-	$result = SQL_QUERY_ESC("SELECT
-	ur.`id`, ur.`refid`, ud.`status`, ud.`last_online`, ud.`mails_confirmed`, ud.`emails_received`
+	$result = SQL_QUERY_ESC('SELECT
+	ur.`id`,
+	ur.`refid`,
+	ud.`status`,
+	ud.`last_online`,
+	ud.`mails_confirmed`,
+	ud.`emails_received`,
+	ud.`subid`
 FROM
 	`{?_MYSQL_PREFIX?}_user_refs` AS `ur`
 LEFT JOIN
@@ -363,7 +411,7 @@ WHERE
 	ur.`userid`=%s AND
 	ur.`level`=%s
 ORDER BY
-	ur.`refid` ASC",
+	ur.`refid` ASC',
 		array(
 			bigintval($userid),
 			bigintval($level)
@@ -414,25 +462,29 @@ function getPointsDataArrayFromSubject ($subject) {
 	// Extension ext-sql_patches must be up-to-date
 	if (isExtensionInstalledAndOlder('sql_patches', '0.8.2')) {
 		// Please update ext-sql_patches
-		debug_report_bug(__FUNCTION__, __LINE__, 'sql_patches is out-dated. Please update to at least 0.8.2 to continue. subject=' . $subject);
-	} // END - if
+		reportBug(__FUNCTION__, __LINE__, 'sql_patches is out-dated. Please update to at least 0.8.2 to continue. subject=' . $subject);
+	} elseif (substr($subject, -8, 8) == '_ref_ref') {
+		// Please report ALL finiding
+		reportBug(__FUNCTION__, __LINE__, 'subject=' . $subject . ' contains invalid double-suffix _ref.');
+	}
 
 	// Remove any double-dot from it
-	$subjectArray = explode(':', $subject);
-	$subject = $subjectArray[0];
-	unset($subjectArray);
+	$subject = removeDoubleDotFromSubject($subject);
 
 	// If we have cache, shortcut it here
 	if (isset($GLOBALS['cache_array']['points_data'][$subject])) {
+		// Count cache hit
+		incrementStatsEntry('cache_hits');
+
 		// Return it
 		return $GLOBALS['cache_array']['points_data'][$subject];
 	} // END - if
 
 	// Now checkout the entry in database table
-	$result = SQL_QUERY_ESC("SELECT `id`,`subject`,`column_name`,`locked_mode`,`payment_method`,`notify_recipient` FROM `{?_MYSQL_PREFIX?}_points_data` WHERE `subject`='%s' LIMIT 1",
+	$result = SQL_QUERY_ESC("SELECT `id`, `subject`, `column_name`, `locked_mode`, `payment_method`, `notify_recipient` FROM `{?_MYSQL_PREFIX?}_points_data` WHERE `subject`='%s' LIMIT 1",
 		array($subject), __FUNCTION__, __LINE__);
 
-	// Do we have an entry?
+	// Is there an entry?
 	if (SQL_NUMROWS($result) == 1) {
 		// Then load it
 		$pointsData = SQL_FETCHARRAY($result);
@@ -443,7 +495,7 @@ function getPointsDataArrayFromSubject ($subject) {
 		} // END - foreach
 	} else {
 		// Register this automatically
-		SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_points_data` (`subject`,`column_name`,`locked_mode`,`payment_method`,`notify_recipient`) VALUES ('%s','points','LOCKED','REFERRAL','N')",
+		SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_points_data` (`subject`, `column_name`, `locked_mode`, `payment_method`, `notify_recipient`) VALUES ('%s','points','LOCKED','REFERRAL','N')",
 			array($subject), __FUNCTION__, __LINE__);
 
 		// Re-request it
@@ -466,7 +518,7 @@ function getPointsColumnNameFromSubjectLocked ($subject, $isLocked) {
 	$columnName = $pointsData['column_name'];
 
 	// Are the points locked?
-	if (($isLocked === true) && ($pointsData['locked_mode'] == 'LOCKED')) {
+	if (($isLocked === TRUE) && ($pointsData['locked_mode'] == 'LOCKED')) {
 		// Locked points, so prefix it
 		$columnName = 'locked_' . $pointsData['column_name'];
 	} // END - if
@@ -487,7 +539,7 @@ function getPaymentMethodFromSubject ($subject) {
 	return $paymentMethod;
 }
 
-// Checks wether notification of points recipient is enabled
+// Checks whether notification of points recipient is enabled
 function isPaymentRecipientNotificationEnabled ($subject) {
 	// Get the points_data entry
 	$pointsData = getPointsDataArrayFromSubject($subject);
@@ -524,14 +576,14 @@ function loadReferralTable ($userid) {
 	$GLOBALS['referral_refid'][$userid] = array();
 
 	// Get all level entries from the refsystem table
-	$result = SQL_QUERY_ESC('SELECT `level` FROM `{?_MYSQL_PREFIX?}_refsystem` WHERE `userid`=%s ORDER BY `level` ASC',
+	$GLOBALS['referral_result'][$userid] = SQL_QUERY_ESC('SELECT `level` FROM `{?_MYSQL_PREFIX?}_refsystem` WHERE `userid`=%s ORDER BY `level` ASC',
 		array($userid), __FUNCTION__, __LINE__);
 
-	// Do we have entries?
-	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',SQL_NUMROWS()=' . SQL_NUMROWS($result));
-	if (SQL_NUMROWS($result) > 0) {
+	// Are there entries?
+	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',SQL_NUMROWS()=' . SQL_NUMROWS($GLOBALS['referral_result'][$userid]));
+	if (SQL_NUMROWS($GLOBALS['referral_result'][$userid]) > 0) {
 		// Then walk through all levels
-		while (list($level) = SQL_FETCHROW($result)) {
+		while (list($level) = SQL_FETCHROW($GLOBALS['referral_result'][$userid])) {
 			// Init array
 			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level);
 			$GLOBALS['referral_refid'][$userid][$level] = array();
@@ -539,30 +591,31 @@ function loadReferralTable ($userid) {
 			// Level is = 1?
 			if ($level == 1) {
 				// Load all referrals of this user
-				$result_refs = SQL_QUERY_ESC('SELECT `userid` FROM `{?_MYSQL_PREFIX?}_user_data` WHERE `refid`=%s ORDER BY `userid` ASC',
+				$GLOBALS['referral_result_refs'][$userid] = SQL_QUERY_ESC('SELECT `userid` FROM `{?_MYSQL_PREFIX?}_user_data` WHERE `refid`=%s ORDER BY `userid` ASC',
 					array($userid), __FUNCTION__, __LINE__);
 
-				// Do we have entries?
-				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',SQL_NUMROWS()=' . SQL_NUMROWS($result_refs));
-				if (SQL_NUMROWS($result_refs) > 0) {
+				// Are there entries?
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',SQL_NUMROWS()=' . SQL_NUMROWS($GLOBALS['referral_result_refs'][$userid]));
+				if (SQL_NUMROWS($GLOBALS['referral_result_refs'][$userid]) > 0) {
 					// Then again walk through all
-					while (list($refid) = SQL_FETCHROW($result_refs)) {
+					while (list($refid) = SQL_FETCHROW($GLOBALS['referral_result_refs'][$userid])) {
 						// Add this refid
-						$GLOBALS['referral_refid'][$userid][$level][] = $refid;
-						//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . $refid);
+						array_push($GLOBALS['referral_refid'][$userid][$level], $refid);
+						//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . $refid . ' - ADDED!');
+
 						// Load the refid's array as well
 						loadReferralTable($refid);
 					} // END - while
 				} // END - if
 
 				// Free result
-				SQL_FREERESULT($result_refs);
+				SQL_FREERESULT($GLOBALS['referral_result_refs'][$userid]);
 			} // END - if
 		} // END - while
 	} // END - if
 
 	// Free result
-	SQL_FREERESULT($result);
+	SQL_FREERESULT($GLOBALS['referral_result'][$userid]);
 	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ' - EXIT!');
 }
 
@@ -572,10 +625,13 @@ function addMissingReferralLevels ($userid) {
 	// If the array is gone, you have called this function without calling loadReferralTable()
 	if (!isset($GLOBALS['referral_refid'][$userid])) {
 		// Please fix your code
-		debug_report_bug(__FUNCTION__, __LINE__, 'Called without calling loadReferralTable() before! userid=' . $userid);
+		reportBug(__FUNCTION__, __LINE__, 'Called without calling loadReferralTable() before! userid=' . $userid);
 	} // END - if
 	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',count()=' . count($GLOBALS['referral_refid'][$userid]));
 
+	// Sort the array reversed
+	krsort($GLOBALS['referral_refid']);
+
 	// Now walk through the array, first levels
 	foreach ($GLOBALS['referral_refid'][$userid] as $level => $levelArray) {
 		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',count()=' . count($levelArray));
@@ -584,26 +640,33 @@ function addMissingReferralLevels ($userid) {
 			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . $refid);
 			// Does the refid have an array?
 			if (isset($GLOBALS['referral_refid'][$refid])) {
-				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . makeNullToZero($refid) . ',count()=' . count($GLOBALS['referral_refid'][$refid]));
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . convertNullToZero($refid) . ',count()=' . count($GLOBALS['referral_refid'][$refid]));
+				// Add also this user's (maybe) missing levels
+				addMissingReferralLevels($refid);
+
 				// Okay, then walk through here, too
 				foreach ($GLOBALS['referral_refid'][$refid] as $refLevel => $refArray) {
-					//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . makeNullToZero($refid) . ',refLevel=' . $refLevel . ',count()=' . count($refArray));
+					//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . convertNullToZero($refid) . ',refLevel=' . $refLevel . ',count()=' . count($refArray));
 					// Also walk through this one
 					foreach ($refArray as $refRefid) {
 						// Calculate new level
 						$newLevel =  $level + $refLevel;
-						//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . makeNullToZero($refid) . ',refLevel=' . $refLevel . ',refRefid=' . $refRefid . ',newLevel=' . $newLevel);
+						//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',level=' . $level . ',refid=' . convertNullToZero($refid) . ',refLevel=' . $refLevel . ',refRefid=' . $refRefid . ',newLevel=' . $newLevel);
 						// Is the refRefid not in?
 						if ((!isset($GLOBALS['referral_refid'][$userid][$newLevel])) || (!in_array($refRefid, $GLOBALS['referral_refid'][$userid][$newLevel]))) {
 							// Then we must add this ref's refid to the userid's next level
 							//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',newLevel=' . $newLevel . ',refRefid=' . $refRefid . ' - ADDED!');
-							$GLOBALS['referral_refid'][$userid][$newLevel][] = $refRefid;
+							array_push($GLOBALS['referral_refid'][$userid][$newLevel], $refRefid);
+
+							// Add also this user's (maybe) missing levels
+							addMissingReferralLevels($refRefid);
 						} // END - if
 					} // END - foreach
 				} // END - foreach
 			} // END - foreach
 		} // END - foreach
 	} // END - foreach
+	//die('<pre>'.print_r($GLOBALS['referral_refid'][$userid],TRUE).'</pre>');
 	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ' - EXIT!');
 }
 
@@ -613,7 +676,7 @@ function flushReferralTableToDatabase ($userid) {
 	// If the array is gone, you have called this function without calling loadReferralTable()
 	if (!isset($GLOBALS['referral_refid'][$userid])) {
 		// Please fix your code
-		debug_report_bug(__FUNCTION__, __LINE__, 'Called without calling loadReferralTable() before! userid=' . $userid);
+		reportBug(__FUNCTION__, __LINE__, 'Called without calling loadReferralTable() before! userid=' . $userid);
 	} // END - if
 	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',count()=' . count($GLOBALS['referral_refid'][$userid]));
 
@@ -625,8 +688,8 @@ function flushReferralTableToDatabase ($userid) {
 	} // END - if
 
 	// Prepare SQL
-	$SQL = 'INSERT INTO `{?_MYSQL_PREFIX?}_user_refs` (`userid`,`level`,`refid`) VALUES ';
-	$executeSql = false;
+	$SQL = 'INSERT INTO `{?_MYSQL_PREFIX?}_user_refs` (`userid`, `level`, `refid`) VALUES ';
+	$executeSql = FALSE;
 
 	// Now walk through the array, first levels
 	foreach ($GLOBALS['referral_refid'][$userid] as $level => $levelArray) {
@@ -642,13 +705,13 @@ function flushReferralTableToDatabase ($userid) {
 					$refid
 				), __FUNCTION__, __LINE__));
 
-			// Do we have no entry?
+			// Is there no entry?
 			if ($count == 0) {
 				// Then add it to the SQL
 				$SQL .= '(' . $userid . ',' . $level . ',' . $refid . '),';
 
 				// Some has been added, so execute the query
-				$executeSql = true;
+				$executeSql = TRUE;
 			} // END - if
 		} // END - foreach
 	} // END - foreach
@@ -658,12 +721,195 @@ function flushReferralTableToDatabase ($userid) {
 
 	// And run it
 	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ',SQL=' . $SQL);
-	if ($executeSql === true) {
+	if ($executeSql === TRUE) {
 		SQL_QUERY($SQL, __FUNCTION__, __LINE__);
 	} // END - if
 
 	//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $userid . ' - EXIT!');
 }
 
+// Generator (somewhat getter) for points_data, locked_mode
+function generatePointsLockedModeOptions ($lockedMode =  NULL) {
+	// Is this cached?
+	if (!isset($GLOBALS[__FUNCTION__][$lockedMode])) {
+		// Generate output and cache it
+		$GLOBALS[__FUNCTION__][$lockedMode] = generateOptions(
+			'/ARRAY/',
+			array(
+				'LOCKED',
+				'UNLOCKED'
+			),
+			array(),
+			$lockedMode,
+			'', '',
+			array(),
+			'translatePointsLockedMode'
+		);
+	} // END - if
+
+	// Return content
+	return $GLOBALS[__FUNCTION__][$lockedMode];
+}
+
+// Generator (somewhat getter) for points_data, payment_method
+function generatePointsPaymentMethodOptions ($paymentMethod =  NULL) {
+	// Is this cached?
+	if (!isset($GLOBALS[__FUNCTION__][$paymentMethod])) {
+		// Generate output and cache it
+		$GLOBALS[__FUNCTION__][$paymentMethod] = generateOptions(
+			'/ARRAY/',
+			array(
+				'DIRECT',
+				'REFERRAL'
+			),
+			array(),
+			$paymentMethod,
+			'', '',
+			array(),
+			'translatePointsPaymentMethod'
+		);
+	} // END - if
+
+	// Return content
+	return $GLOBALS[__FUNCTION__][$paymentMethod];
+}
+
+// Generator (somewhat getter) for points_data, notify_recipient
+function generatePointsNotifyRecipientOptions ($notifyRecipient =  NULL) {
+	// Is this cached?
+	if (!isset($GLOBALS[__FUNCTION__][$notifyRecipient])) {
+		// Generate output and cache it
+		$GLOBALS[__FUNCTION__][$notifyRecipient] = generateOptions(
+			'/ARRAY/',
+			array(
+				'Y',
+				'N'
+			),
+			array(),
+			$notifyRecipient,
+			'', '',
+			array(),
+			'translatePointsNotifyRecipient'
+		);
+	} // END - if
+
+	// Return content
+	return $GLOBALS[__FUNCTION__][$notifyRecipient];
+}
+
+// Setter for referral id (no bigintval, or nicknames will fail!)
+function setReferralId ($refid) {
+	$GLOBALS['__refid'] = $refid;
+}
+
+// Checks if 'refid' is valid
+function isReferralIdValid () {
+	return ((isset($GLOBALS['__refid'])) && (getReferralId() !== NULL) && (getReferralId() > 0));
+}
+
+// Getter for referral id
+function getReferralId () {
+	return $GLOBALS['__refid'];
+}
+
+// Determines referral id and sets it
+function determineReferralId () {
+	// Is it already detected?
+	if (isReferralIdValid()) {
+		// Do not determine it, just return it
+		return getReferralId();
+	} elseif ((!isHtmlOutputMode()) && (basename($_SERVER['PHP_SELF']) != 'ref.php')) {
+		// Skip this in non-html-mode and outside ref.php
+		return FALSE;
+	}
+
+	// Check if refid is set
+	if (isReferralIdValid()) {
+		// This is fine...
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using refid from GLOBALS (' . getReferralId() . ')');
+	} elseif (isPostRequestElementSet('refid')) {
+		// Get referral id from POST element refid
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using refid from POST data (' . postRequestElement('refid') . ')');
+		setReferralId(secureString(postRequestElement('refid')));
+	} elseif (isGetRequestElementSet('refid')) {
+		// Get referral id from GET parameter refid
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using refid from GET data (' . getRequestElement('refid') . ')');
+		setReferralId(secureString(getRequestElement('refid')));
+	} elseif (isGetRequestElementSet('ref')) {
+		// Set refid=ref (the referral link uses such variable)
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using ref from GET data (' . getRequestElement('ref') . ')');
+		setReferralId(secureString(getRequestElement('ref')));
+	} elseif ((isGetRequestElementSet('user')) && (basename($_SERVER['PHP_SELF']) == 'click.php')) {
+		// The variable user comes from  click.php
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using user from GET data (' . getRequestElement('user') . ')');
+		setReferralId(bigintval(getRequestElement('user')));
+	} elseif ((isSessionVariableSet('refid')) && (isValidUserId(getSession('refid')))) {
+		// Set session refid as global
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using refid from SESSION data (' . getSession('refid') . ')');
+		setReferralId(bigintval(getSession('refid')));
+	} elseif ((isExtensionInstalledAndNewer('user', '0.3.4')) && (isRandomReferralIdEnabled())) {
+		// Select a random user which has confirmed enougth mails
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Checking random referral id');
+		setReferralId(determineRandomReferralId());
+	} elseif ((isExtensionInstalledAndNewer('sql_patches', '0.1.2')) && (isValidUserId(getDefRefid()))) {
+		// Set default refid as refid in URL
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using default refid (' . getDefRefid() . ')');
+		setReferralId(getDefRefid());
+	} else {
+		// No default id when sql_patches is not installed or none set
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using NULL as refid');
+		setReferralId(NULL);
+	}
+
+	// Set cookie when default refid > 0
+	if ((!isSessionVariableSet('refid')) || (!isValidUserId(getReferralId())) || ((!isValidUserId(getSession('refid'))) && (isExtensionInstalledAndNewer('sql_patches', '0.1.2')) && (isValidUserId(getDefRefid())))) {
+		// Default is not found
+		$found = FALSE;
+
+		// Is there nickname or userid set?
+		if ((isExtensionActive('nickname')) && (isNicknameUsed(getReferralId()))) {
+			// Nickname in URL, so load the id
+			$found = fetchUserData(getReferralId(), 'nickname');
+
+			// If we found it, use the userid as referral id
+			if ($found === TRUE) {
+				// Set the userid as 'refid'
+				//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using refid from user account by nickname (' . getUserData('userid') . ')');
+				setReferralId(getUserData('userid'));
+			} // END - if
+		} elseif (isValidUserId(getReferralId())) {
+			// Direct userid entered
+			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using direct userid (' . getReferralId() . ')');
+			$found = fetchUserData(getReferralId());
+		}
+
+		// Is the record valid?
+		if ((($found === FALSE) || (!isUserDataValid())) && (isExtensionInstalledAndNewer('sql_patches', '0.1.2'))) {
+			// No, then reset referral id
+			//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Using default refid (' . getDefRefid() . ')');
+			setReferralId(getDefRefid());
+		} // END - if
+
+		// Set cookie
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Saving refid to session (' . getReferralId() . ') #1');
+		setSession('refid', getReferralId());
+	} elseif ((!isReferralIdValid()) || (!fetchUserData(getReferralId()))) {
+		// Not valid!
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Not valid referral id (' . getReferralId() . '), setting NULL in session');
+		setReferralId(NULL);
+		setSession('refid', NULL);
+	} else {
+		// Set it from GLOBALS array in session
+		//* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'Saving refid to session (' . getReferralId() . ') #2');
+		setSession('refid', getReferralId());
+	}
+
+	// Run post validation filter chain
+	runFilterChain('post_refid_validation');
+
+	// Return determined refid
+	return getReferralId();
+}
+
 // [EOF]
 ?>