X-Git-Url: https://git.mxchange.org/?p=mailer.git;a=blobdiff_plain;f=inc%2Flibs%2Frallye_functions.php;h=b599a0f1cdd5f05e494eb56bf39946a0e14d4726;hp=baf0bdef927ec3a9a7a302eaea8cb7a9349df94b;hb=e70440e1164db8bbeeccd90df305bfa0efb641e1;hpb=f11431f9a9e4eef095057af4e3f0c2a3971488da diff --git a/inc/libs/rallye_functions.php b/inc/libs/rallye_functions.php index baf0bdef92..b599a0f1cd 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 - 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 * @@ -40,10 +40,10 @@ if (!defined('__SECURITY')) { die(); } // END - if -// Auto-start referal rallyes -function autostartReferalRallyes ($result) { +// Auto-start referral rallyes +function autostartReferralRallyes ($result) { // Load all rallyes (usally we have only one rallye active per time! - list($id, $title, $start, $end, $notify, $min_users, $min_prices) = SQL_FETCHROW($result); + $content = SQL_FETCHARRAY($result); // Free result SQL_FREERESULT($result); @@ -56,22 +56,7 @@ SET WHERE `id`=%s LIMIT 1", - array(bigintval($id)), __FUNCTION__, __LINE__); - - // Transfer all neccessary data to the $content array - $content['userid_cnt'] = getTotalConfirmedUser(); - $content['start'] = generateDateTime($start, 2); - $content['end'] = generateDateTime($end , 2); - $content['now_t'] = generateDateTime(time(), 2); - $content['title'] = $title; - $content['id'] = $id; // id for the rallye details link - - // Determine min_users and min_prices - $content['min_users'] = determineReferalRallyeMinimumUsers($min_users); - $content['min_prices'] = determineReferalRallyeMinimumPrices($min_prices); - - // Load prices - $content['prices'] = addReferalRallyePrices($id); + array(bigintval($content['id'])), __FUNCTION__, __LINE__); // Query all users $result_user = SQL_QUERY("SELECT @@ -80,6 +65,7 @@ FROM `{?_MYSQL_PREFIX?}_user_data` WHERE `status`='CONFIRMED' + " . runFilterChain('user_exclusion_sql', ' ') . " ORDER BY `userid` ASC", __FUNCTION__, __LINE__); @@ -88,10 +74,10 @@ ORDER BY // Merge both arrays $content = merge_array($content, $row); - $un = false; + $un = FALSE; // Get refs by userid - $count = getReferalRallyeRefsCount($content['userid']); + $count = getReferralRallyeRefsCount($content['userid']); if (empty($count)) $count = '0'; // Added prevent some unknown troubles... :-? // Check if line is already included... @@ -103,25 +89,27 @@ WHERE `rallye_id`=%s AND `userid`=%s LIMIT 1", - array(bigintval($id), bigintval($content['userid'])), __FUNCTION__, __LINE__); - if (SQL_HASZERONUMS($result_ref)) { + array(bigintval($content['id']), bigintval($content['userid'])), __FUNCTION__, __LINE__); + // Is there an entry? + if (SQL_HASZERONUMS($result_ref)) { // Add userid and his ref count to table $result_ref = SQL_QUERY_ESC("SELECT - SUM(p.points) AS `points` + 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' 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`.`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", array(bigintval($content['userid'])), __FUNCTION__, __LINE__); // Get points @@ -135,16 +123,24 @@ WHERE // Add info line SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_rallye_users` -(`rallye_id`,`userid`,`refs`,`curr_points`) - VALUES -(%s, %s, %s, %s)", +( + `rallye_id`, + `userid`, + `refs`, + `curr_points` +) VALUES ( + %s, + %s, + %s, + %s +)", array( - bigintval($id), + bigintval($content['id']), bigintval($content['userid']), bigintval($count), $cpoints ), __FUNCTION__, __LINE__); - $un = true; + $un = TRUE; } // END - if // Free memory @@ -154,35 +150,39 @@ WHERE $content['refs'] = $count; // Shall I notify this member? - if (($notify == 'Y') && ($un)) { + if (($content['send_notify'] == 'Y') && ($un === TRUE)) { // Load email template and send it to the user $message = loadEmailTemplate('member_rallye_notify', $content, $content['userid']); - sendEmail($content['userid'], '{%message,RALLYE_MEMBER_NOTIFY=' . $title . '%}', $message); + sendEmail($content['userid'], '{%message,MEMBER_RALLYE_NOTIFY_SUBJECT=' . $content['title'] . '%}', $message); } // END - if } // END - while // Choose the right admin template $templ = 'admin_rallye_no_notify'; - if ($notify == 'Y') $templ = 'admin_rallye_notify'; + if ($content['send_notify'] == 'Y') { + $templ = 'admin_rallye_notify'; + } // END - if // Send email to admin - sendAdminNotification('{%message,RALLYE_ADMIN_NOTIFY=' . $title . '%}', $templ, $prices); + sendAdminNotification('{%message,ADMIN_RALLYE_NOTIFY_SUBJECT=' . $content['title'] . '%}', $templ, $content); // Free memory SQL_FREERESULT($result_user); } // -function addReferalRallyePrices ($rallye, $mode = 'email') { +function addReferralRallyePrices ($rallye, $mode = 'email') { // Output mode switch($mode) { - case 'email': $mode = "\n"; break; + case 'email': $mode = PHP_EOL; break; case 'html' : $mode = '
'; break; } // END - switch // Load prices $result_prices = SQL_QUERY_ESC("SELECT - `price_level`,`points`,`info` + `price_level`, + `points`, + `info` FROM `{?_MYSQL_PREFIX?}_rallye_prices` WHERE @@ -194,15 +194,17 @@ ORDER BY // Entries found? if (!SQL_HASZERONUMS($result_prices)) { // Load prices - if ($mode == "\n") $prices = '{--RALLYE_MEMBER_PRICES_ADDED--}:' . $mode . '------------------------------' . $mode; - $prices = ''; + if ($mode == PHP_EOL) { + $prices = '{--RALLYE_MEMBER_PRICES_ADDED--}:' . $mode . '------------------------------' . $mode; + } // END - if + while ($content = SQL_FETCHARRAY($result_prices)) { - $prices .= $content['price_level']. '{--RALLYE_PRICE--}: '; + $prices .= $content['price_level']. '{--RALLYE_PRICE--}:'; if (!empty($content['info'])) { $prices .= $content['info']; } else { - $prices .= $content['points'] . ' {?POINTS?}'; + $prices .= '{%pipe,translateComma=' . $content['points'] . '%} {?POINTS?}'; } $prices .= '' . $mode; } // END - if @@ -215,36 +217,43 @@ ORDER BY } // Add last line for email mode - if ($mode == "\n") $prices .= '------------------------------'; + if ($mode == PHP_EOL) { + $prices .= '------------------------------'; + } // END - if // Return price list return $prices; } // -function addReferalRallyeTopUsers ($mode, $rallye, $default=0) { +function addReferralRallyeTopUsers ($mode, $rallye, $default=0) { // Init variables - $min_users = 0; $min_prices = 0; + $min_users = 0; + $min_prices = 0; // First check how many prices are set - $prices = countSumTotalData($rallye, 'rallye_prices', 'id', 'rallye_id', true); + $prices = getTotalRallyePrices($rallye); // And load only limited users - $result = SQL_QUERY_ESC("SELECT - u.userid, u.refs, u.curr_points, rd.min_users, rd.min_prices + $result = SQL_QUERY_ESC("SELECT DISTINCT + `u`.`userid`, + `u`.`refs`, + `u`.`curr_points`, + `rd`.`min_users`, + `rd`.`min_prices` FROM - `{?_MYSQL_PREFIX?}_rallye_users` AS u -LEFT JOIN - `{?_MYSQL_PREFIX?}_refsystem` AS r + `{?_MYSQL_PREFIX?}_rallye_users` AS `u` +INNER JOIN + `{?_MYSQL_PREFIX?}_refsystem` AS `r` ON u.userid=r.userid -LEFT JOIN - `{?_MYSQL_PREFIX?}_rallye_data` AS rd +INNER JOIN + `{?_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__); @@ -257,27 +266,29 @@ ORDER BY ); // Load all users - while ($content = SQL_FETCHARRAY($result)) { + while ($row = SQL_FETCHARRAY($result)) { + //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'userid=' . $row['userid'] . ',refs=' . $row['refs']); // Get current refs - $count = getReferalRallyeRefsCount($content['userid'], $content['refs']); + $count = getReferralRallyeRefsCount($row['userid'], $row['refs']); // Points of ref's $result_ref = SQL_QUERY_ESC("SELECT - p.points + `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' AND - p.ref_depth=1 AND - d.max_mails > 0 AND - d.mails_confirmed >= {?ref_payout?} + `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?} LIMIT 1", - array(bigintval($content['userid'])), __FUNCTION__, __LINE__); + array(bigintval($row['userid'])), __FUNCTION__, __LINE__); // Get points list($refpoints) = SQL_FETCHROW($result_ref); @@ -285,15 +296,18 @@ LIMIT 1", // Free result SQL_FREERESULT($result_ref); - if (empty($refpoints)) $refpoints = '0'; + // Fix empty values (ugly code again) + if (empty($refpoints)) { + $refpoints = '0'; + } // END - if // Init userid for list $userid = '---'; // List only users with at least one ref! - //* DEBUG: */ debugOutput('*'.$count.'/'.$content['userid'].'/'.$content['curr_points'].'/'.$refpoints.'*'); - if (($count > 0) && ($refpoints > $content['curr_points'])) { - $userid = $content['userid']; + //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'count=' . $count . ',userid=' . $userid . ',refpoints=' . $refpoints . ',curr_points=' . $row['curr_points']); + if (($count > 0) && ($refpoints > $row['curr_points'])) { + $userid = $row['userid']; } else { $count = ''; } @@ -301,23 +315,23 @@ LIMIT 1", // Save values to array $content['userid'][] = $userid; $content['ref'][] = $count; - $content['cpoints'][] = $content['curr_points']; - $min_users = $content['min_users']; - $min_prices = $content['min_prices']; + $content['cpoints'][] = $row['curr_points']; + $min_users = $row['min_users']; + $min_prices = $row['min_prices']; } // END - while // Free memory SQL_FREERESULT($result); // Sort whole array - array_pk_sort($content, array('ref', 'cpoints'), 0, 1, true); + array_pk_sort($content, array('cpoints', 'ref'), 0, 1, TRUE); // Generate table $OUT = ''; - for ($idx = '0'; $idx < $prices; $idx++) { + for ($idx = 0; $idx < $prices; $idx++) { // Prepare marking of default (maybe current user's) id $start = ''; $end = ''; - if (($content['userid'][$idx] == $default) && ($default > 0)) { + if (($default > 0) && (isset($content['userid'][$idx])) && ($content['userid'][$idx] == $default)) { $start = ''; $end = ''; } // END - if @@ -327,13 +341,12 @@ LIMIT 1", 'idx' => ($idx + 1), 'start' => $start, 'end' => $end, - 'userid' => $content['userid'][$idx], - 'ref' => $content['ref'][$idx], - 'infos' => '' + 'userid' => (isset($content['userid'][$idx])) ? $content['userid'][$idx] : '---', + 'ref' => (isset($content['ref'][$idx])) ? $content['ref'][$idx] : '---' ); // Load row template and switch color - $OUT .= loadTemplate($mode . '_list_rallye_row', true, $row); + $OUT .= loadTemplate($mode . '_list_rallye_row', TRUE, $row); } // END - for // Add min_prices/users @@ -342,21 +355,40 @@ LIMIT 1", $content['min_users'] = bigintval($min_users); // And finnally return the output - return loadTemplate($mode . '_list_rallye', true, $content); + return loadTemplate($mode . '_list_rallye', TRUE, $content); +} + +// Sends out a notification about the rallye +function sendRallyeNotification ($userid, $content) { + // Translate more data + $content['start_time'] = generateDateTime($content['start_time'], 2); + $content['end_time'] = generateDateTime($content['end_time'] , 2); + $content['now_time'] = generateDateTime(time(), 2); + $content['ref'] = '0'; + $content['refs'] = getUsersTotalReferrals($userid); + + // Send notification to member + $message = loadEmailTemplate('member_rallye_notify', $content, $userid); + sendEmail($userid, '{%message,MEMBER_RALLYE_NOTIFY_SUBJECT=' . $content['title'] . '%}', $message); } // Run this function only when a new member has confirmed his email address! -function addUserToReferalRallye ($userid, $content = array()) { +function addUserToReferralRallye ($userid, $content = array()) { $add = ''; // Updated extension? if (isExtensionInstalledAndNewer('rallye', '0.2.0')) { - $add .= ', `min_users`,`min_prices`'; + $add .= ',`min_users`, `min_prices`'; } // END - if // Check for an auto-add rallye $result = SQL_QUERY("SELECT - `id`,`title`,`start_time`,`end_time`,`send_notify`".$add." + `id`, + `title`, + `start_time`, + `end_time`, + `send_notify` + ".$add." FROM `{?_MYSQL_PREFIX?}_rallye_data` WHERE @@ -367,38 +399,19 @@ WHERE LIMIT 1", __FUNCTION__, __LINE__); if (SQL_NUMROWS($result) == 1) { // Init variables - $min_users = '0'; $min_prices = '0'; + $min_users = '0'; + $min_prices = '0'; - // Load data - if (isExtensionInstalledAndNewer('rallye', '0.2.0')) { - list($id, $title, $start, $end, $notify, $min_users, $min_prices) = SQL_FETCHROW($result); - } else { - list($id, $title, $start, $end, $notify) = SQL_FETCHROW($result); - } + // Load and merge data + $content = merge_array($content, SQL_FETCHARRAY($result)); // Free result SQL_FREERESULT($result); - if ($notify == 'Y') { + // Notify the user? + if ($content['send_notify'] == 'Y') { // Transfer all neccessary data to $content array - $content['start'] = generateDateTime($start, 2); - $content['end'] = generateDateTime($end , 2); - $content['now_t'] = generateDateTime(time(), 2); - $content['title'] = $title; - $content['id'] = $id; // id for the rallye details link - $content['ref'] = '0'; - $content['refs'] = countSumTotalData($userid, 'user_data', 'userid', 'refid', true); - - // Load prices - $content['prices'] = addReferalRallyePrices($id); - - // Determine min_users/prices tring - $content['min_users'] = determineReferalRallyeMinimumUsers($min_users); - $content['min_prices'] = determineReferalRallyeMinimumPrices($min_prices); - - // Send notification to member - $message = loadEmailTemplate('member_rallye_notify', $content, $userid); - sendEmail($userid, '{%message,RALLYE_MEMBER_NOTIFY=' . $title . '%}', $message); + sendRallyeNotification($userid, $content); } // END - if // Check if line is already included... @@ -411,7 +424,7 @@ WHERE `userid`=%s LIMIT 1", array( - bigintval($id), + bigintval($content['id']), bigintval($userid) ), __FUNCTION__, __LINE__); @@ -420,11 +433,17 @@ LIMIT 1", // Add userid and his ref count to table SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_rallye_users` -(`rallye_id`,`userid`,`refs`) - VALUES -(%s,%s,0)", +( + `rallye_id`, + `userid`, + `refs` +) VALUES ( + %s, + %s, + 0 +)", array( - bigintval($id), + bigintval($content['id']), bigintval($userid) ), __FUNCTION__, __LINE__); } // END - if @@ -434,56 +453,83 @@ LIMIT 1", } // END - if } -// -function markReferalRallyesAsExpired ($result) { +// "Getter" for total rallye winners +function getTotalRallyeWinners ($rallyeId) { + // Is cache set? + if (!isset($GLOBALS[__FUNCTION__][$rallyeId])) { + // Default total is zero + $GLOBALS[__FUNCTION__][$rallyeId] = '0'; + + // Get prices + $prices = getArrayFromReferralRallyeUsers($rallyeId); + + // "Walk" through all entries + foreach ($prices['userid'] as $key => $userid) { + // Check for userid + $active = countSumTotalData($userid, 'user_data', 'userid', 'userid', TRUE, runFilterChain('user_exclusion_sql', " AND `status`='CONFIRMED'")); + + // 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 ((isValidId($userid)) && ($prices['ref'][$key] > 0) && ($active == 1) && ($prices['cpoints'][$key] > 0)) { + $GLOBALS[__FUNCTION__][$rallyeId]++; + } // END - if + } // END - foreach + } // END - if + + // Return it + return $GLOBALS[__FUNCTION__][$rallyeId]; +} + +// Stops the given rallye result (from SQL layer) by marking it as expirced +function stopRallyeByResult ($result) { // Load rallye data - list($id, $title, $start, $end, $notify, $min_users, $min_prices) = SQL_FETCHROW($result); + $content = SQL_FETCHARRAY($result); // Free result SQL_FREERESULT($result); // Init array - $content = array(); $count = '0'; $users = array(); - $content['title'] = $title; - $content['start'] = generateDateTime($start, 1); - $content['end'] = generateDateTime($end , 1); - $content['now_t'] = generateDateTime(time(), 1); + $content['start_time'] = generateDateTime($content['start_time'], 1); + $content['end_time'] = generateDateTime($content['end_time'] , 1); + $content['now_time'] = generateDateTime(time(), 1); // Load users array (!) with assigned prices - $prices = getArrayFromReferalRallyeUsers($id); + $prices = getArrayFromReferralRallyeUsers($content['id']); // Just count... $total = '0'; foreach ($prices['userid'] as $key => $userid) { - // Check status - // active = 1: account is still confirmed - // active = 0: account is deleted or locked - $active = countSumTotalData($userid, 'user_data', 'userid', 'userid', true, " AND `status`='CONFIRMED'"); + /* + * Check status + * active = 1: account is still confirmed + * active = 0: account is deleted or locked + */ + $active = countSumTotalData($userid, 'user_data', 'userid', 'userid', TRUE, runFilterChain('user_exclusion_sql', " AND `status`='CONFIRMED'")); $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 - if (($total < $min_prices) || ($total == '0')) { + // Check on 'min_prices' condition + if (($total < $content['min_prices']) || (getTotalConfirmedUser() < $content['min_users'])) { // Do not end this rallye! - unset($content); return; } // END - if // Expire rallye SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_rallye_data` SET `expired`='Y' WHERE `id`=%s LIMIT 1", - array(bigintval($id)), __FUNCTION__, __LINE__); + 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]; @@ -507,11 +553,11 @@ function markReferalRallyesAsExpired ($result) { if ($content['points'] > 0) { // Add points directly to user's account - initReferalSystem(); - addPointsThroughReferalSystem('rallye_winner:' . $winnerLevel, $userid, $content['points']); + initReferralSystem(); + addPointsThroughReferralSystem('rallye_winner:' . $winnerLevel, $userid, $content['points']); } // END - if - if ($notify == 'Y') { + if ($content['send_notify'] == 'Y') { // Prepare infos for the mail template if (!empty($content['info'])) { // Take direct infos @@ -537,25 +583,25 @@ function markReferalRallyesAsExpired ($result) { } // END - foreach // Select template depending on notfication is switch on / off - if ($notify == 'Y') { + if ($content['send_notify'] == 'Y') { $templ = 'admin_rallye_expired'; } elseif (is_array($users['userid'])) { $templ = 'admin_rallye_expired_no'; - $count = getReferalRallyeUserDataFromArray($users); + $count = getReferralRallyeUserDataFromArray($users); } // Add count $content['count'] = $count; // Send mail to admin - sendAdminNotification('{%message,RALLYE_ADMIN_EXPIRED_SUBJECT=' . $title . '%}', $templ, $content); + sendAdminNotification('{%message,ADMIN_RALLYE_EXPIRED_SUBJECT=' . $content['title'] . '%}', $templ, $content); // Add task (we ignore the task id here) - createNewTask('{--RALLYE_ADMIN_EXPIRED--}: ' . $title, '{--RALLYE_ADMIN_EXPIRED_TEXT--}', 'RALLYE_EXPIRED'); + createNewTask('{--ADMIN_RALLYE_EXPIRED_TASK--}: ' . $content['title'], '{--ADMIN_RALLYE_EXPIRED_TEXT--}', 'RALLYE_EXPIRED'); } // -function getReferalRallyeUserDataFromArray ($userIds) { +function getReferralRallyeUserDataFromArray ($userIds) { // Implode user ids $userid_string = implode(',', $userIds['userid']); @@ -564,12 +610,13 @@ function getReferalRallyeUserDataFromArray ($userIds) { // Load users $result = SQL_QUERY_ESC("SELECT - `userid`,`gender`,`surname`,`family`,`email` + `userid`, `gender`, `surname`, `family`, `email` FROM `{?_MYSQL_PREFIX?}_user_data` WHERE `userid` IN(%s) AND `status`='CONFIRMED' + " . runFilterChain('user_exclusion_sql', ' ' ) . " ORDER BY `userid` ASC LIMIT %s", @@ -593,7 +640,7 @@ LIMIT %s", } // -function getArrayFromReferalRallyePrices ($rallye) { +function getArrayFromReferralRallyePrices ($rallye) { // Init multi array $prices = array( 'level' => array(), @@ -603,7 +650,9 @@ function getArrayFromReferalRallyePrices ($rallye) { // Load prices $result = SQL_QUERY_ESC("SELECT - `price_level`,`points`,`info` + `price_level`, + `points`, + `info` FROM `{?_MYSQL_PREFIX?}_rallye_prices` WHERE @@ -615,8 +664,8 @@ ORDER BY // Transfer elements while ($content = SQL_FETCHARRAY($result)) { $prices['level'][] = $content['price_level']; - $prices['points'][] = $content['points']; - $prices['info'][] = $content['info']; + array_push($prices['points'], $content['points']); + array_push($prices['info'], $content['info']); } // END - while // Free memory @@ -627,9 +676,11 @@ ORDER BY } // -function getArrayFromReferalRallyeUsers ($rallye) { +function getArrayFromReferralRallyeUsers ($rallye) { // Fix zero points to 0.00000 - if (getConfig('ref_payout') == '0') setConfigEntry('ref_payout', '0.00000'); + if (getRefPayout() == '0') { + setConfigEntry('ref_payout', '0.00000'); + } // END - if // Init multi array $users = array( @@ -638,29 +689,44 @@ function getArrayFromReferalRallyeUsers ($rallye) { 'cpoints' => array(), ); - // Load users userid old points earned - $result_user = SQL_QUERY_ESC("SELECT `userid`,`refs`,`curr_points` FROM `{?_MYSQL_PREFIX?}_rallye_users` WHERE `rallye_id`=%s ORDER BY `userid` ASC", + /* + * Load users: + * - userid = User's id number + * - refs = Old amount of referrals (before the rallye has started) + * - curr_points = Current amount of total points + */ + $result_user = SQL_QUERY_ESC("SELECT + `userid`, + `refs`, + `curr_points` +FROM + `{?_MYSQL_PREFIX?}_rallye_users` +WHERE + `rallye_id`=%s +ORDER BY + `userid` ASC", array(bigintval($rallye)), __FUNCTION__, __LINE__); while ($content = SQL_FETCHARRAY($result_user)) { // Load current ref count - $count = getReferalRallyeRefsCount($content['userid'], $content['refs']); + $count = getReferralRallyeRefsCount($content['userid'], $content['refs']); // Points of ref's $result_ref = SQL_QUERY_ESC("SELECT - SUM(p.points) AS `points` + 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' 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`.`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 LIMIT 1", array(bigintval($content['userid'])), __FUNCTION__, __LINE__); @@ -674,19 +740,19 @@ LIMIT 1", if (empty($refpoints)) $refpoints = '0'; // Store calculated new refs to array - $users['userid'][] = $content['userid']; - $users['ref'][] = abs($count - $content['refs']); - $users['cpoints'][] = $refpoints - $content['curr_points']; + array_push($users['userid'], $content['userid']); + array_push($users['ref'], abs($count - $content['refs'])); + array_push($users['cpoints'], $refpoints - $content['curr_points']); } // END - while // Free memory SQL_FREERESULT($result_user); // Sort array for refs (descending) - array_pk_sort($users, array('ref', 'cpoints'), 0, 1, true); + array_pk_sort($users, array('cpoints', 'ref'), 0, 1, TRUE); // Load prices array (!) - $prices = getArrayFromReferalRallyePrices($rallye); + $prices = getArrayFromReferralRallyePrices($rallye); // Merge users into prices foreach ($prices['level'] as $k => $level) { @@ -703,25 +769,27 @@ LIMIT 1", } // @TODO This function does not load min_users, min_prices, please encapsulate loading rallye data with e.g. getRallyeDataFromId() -function addReferalRallyeWinners ($mode, $rallye, $default=0) { +function addReferralRallyeWinners ($mode, $rallye, $default=0) { // First check how many prices are set - $prices = countSumTotalData(bigintval($rallye), 'rallye_prices', 'id', 'rallye_id', true); + $prices = getTotalRallyePrices($rallye); // Load data - $content = getArrayFromReferalRallyeUsers($rallye); + $content = getArrayFromReferralRallyeUsers($rallye); // Generate table $OUT = ''; - for ($idx = '0'; $idx < $prices; $idx++) { - // Check status - // active = 1: account is still confirmed - // active = 0: account is deleted or locked - $active = countSumTotalData($content['userid'][$idx], 'user_data', 'userid', 'userid', true, " AND `status`='CONFIRMED'"); + for ($idx = 0; $idx < $prices; $idx++) { + /* + * Check status + * active = 1: account is still confirmed + * active = 0: account is deleted or locked + */ + $active = countSumTotalData($content['userid'][$idx], 'user_data', 'userid', 'userid', TRUE, runFilterChain('user_exclusion_sql', " AND `status`='CONFIRMED'")); if ((empty($content['ref'][$idx])) || ($content['ref'][$idx] == '0') || ($active == '0') || ('' . round($content['cpoints'][$idx]) . '' == '0') || (empty($content['cpoints'][$idx]))) { // Allow valid and active users with at least one ref to get points - $content['ref'][$idx] = '---'; - $content['userid'][$idx] = '---'; + $content['ref'][$idx] = '---'; + $content['userid'][$idx] = '---'; } // END - if if (!empty($content['info'][$idx])) { @@ -750,7 +818,7 @@ function addReferalRallyeWinners ($mode, $rallye, $default=0) { ); // Load row template - $OUT .= loadTemplate($mode . '_list_rallye_row', true, $row); + $OUT .= loadTemplate($mode . '_list_rallye_row', TRUE, $row); } // END - for // Prepare content @@ -761,15 +829,18 @@ function addReferalRallyeWinners ($mode, $rallye, $default=0) { ); // Load main template and finnally return the output - return loadTemplate($mode . '_list_rallye', true, $content); + return loadTemplate($mode . '_list_rallye', TRUE, $content); } // -function purgeExpiredReferalRallyes () { +function purgeExpiredReferralRallyes () { // Check for expired rallyes $EXPIRE = 3; // @TODO The hard-coded value... $result_rallye = SQL_QUERY_ESC("SELECT - `id`,`title`,`start_time`,`end_time` + `id`, + `title`, + `start_time`, + `end_time` FROM `{?_MYSQL_PREFIX?}_rallye_data` WHERE @@ -789,18 +860,18 @@ WHERE $content['now_time'] = generateDateTime(time(), 1); // Send mail to admin - sendAdminNotification('{%message,RALLYE_ADMIN_PURGED_SUBJECT=' . $content['title'] . '%}', 'admin_rallye_purged', $content); + 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", - array(bigintval($content['id'])), __FUNCTION__, __LINE__, false)); + 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", - array(bigintval($content['id'])), __FUNCTION__, __LINE__, false)); + 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", - array(bigintval($content['id'])), __FUNCTION__, __LINE__, false)); + array(bigintval($content['id'])), __FUNCTION__, __LINE__, FALSE)); // Add task (we ignore the task id here - createNewTask('{--RALLYE_ADMIN_PURGED--}: ' . $content['title'], '{--RALLYE_ADMIN_PURGED_TEXT--}', 'RALLYE_PURGED'); + createNewTask('{--ADMIN_RALLYE_PURGED_TASK--}: ' . $content['title'], '{--ADMIN_RALLYE_PURGED_TEXT--}', 'RALLYE_PURGED'); } // END - while // Run all SQLs @@ -812,7 +883,7 @@ WHERE } // -function addReferalRallyeTemplateSelection ($name = 'template', $default = '') { +function addReferralRallyeTemplateSelection ($name = 'template', $default = '') { // Init variables $OUT = ''; $ral = array(); @@ -821,7 +892,7 @@ function addReferalRallyeTemplateSelection ($name = 'template', $default = '') { $basePath = sprintf("templates/%s/html/rallye/", getLanguage()); // Read the directory - $templates = getArrayFromDirectory($basePath, 'rallye_', false, true, array(), '.tpl'); + $templates = getArrayFromDirectory($basePath, 'rallye_', FALSE, TRUE, array(), '.tpl'); // And walk through foreach ($templates as $read) { @@ -838,15 +909,15 @@ function addReferalRallyeTemplateSelection ($name = 'template', $default = '') { } } // END - foreach - // Do we have found templates which we can link with the new rallye? + // Is there found templates which we can link with the new rallye? if (!empty($ral[0])) { // Generate selection box for all found templates $OUT = ''; } else { // No rallye templates found - $OUT = '{--RALLYE_NO_TEMPLATES_FOUND--}'; + $OUT = '{--ADMIN_RALLYE_TEMPLATES_404--}'; } // Return selection @@ -854,13 +925,13 @@ function addReferalRallyeTemplateSelection ($name = 'template', $default = '') { } // @TODO Please document this function -function getReferalRallyeRefsCount ($currUserid, $oldReferralCount = '0') { +function getReferralRallyeRefsCount ($currUserid, $oldReferralCount = '0') { // Check current refs if (isExtensionInstalledAndNewer('cache', '0.1.2')) { // Get refs from cache $count = '0'; foreach ($GLOBALS['cache_array']['refsystem']['userid'] as $id => $userid) { - // Do we have a ref for this user? + // Is there a ref for this user? //* DEBUG: */ debugOutput('id='.$id.',userid='.$userid.',userid='.$userid.',oldReferralCount='.$oldReferralCount.',level='.$GLOBALS['cache_array']['refsystem']['level'][$id]); if (($currUserid == $userid) && ($GLOBALS['cache_array']['refsystem']['level'][$id] == 1)) { //* DEBUG: */ debugOutput('userid matches!'); @@ -881,8 +952,8 @@ function getReferalRallyeRefsCount ($currUserid, $oldReferralCount = '0') { } // END - if } // END - foreach - //* DEBUG: */ debugOutput('
'.print_r($GLOBALS['cache_array']['refsystem'], true).'
'); - //* DEBUG: */ shutdown(); + //* DEBUG: */ debugOutput('
'.print_r($GLOBALS['cache_array']['refsystem'], TRUE).'
'); + //* DEBUG: */ doShutdown(); if ($count > 0) { // Count cache hits @@ -895,16 +966,16 @@ function getReferalRallyeRefsCount ($currUserid, $oldReferralCount = '0') { } else { // Load current refs from database $result_ref = SQL_QUERY_ESC("SELECT - SUM(s.counter) AS cnt + 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__); @@ -927,7 +998,7 @@ WHERE } // Determines the right language string for min_users -function determineReferalRallyeMinimumUsers ($min_users) { +function determineReferralRallyeMinimumUsers ($min_users) { // Rallye ends without user limitation is the default $return = '{--RALLYE_END_NO_USER_LIMITATION--}'; @@ -941,7 +1012,7 @@ function determineReferalRallyeMinimumUsers ($min_users) { } // Determines the right language string for min_prices -function determineReferalRallyeMinimumPrices ($min_prices) { +function determineReferralRallyeMinimumPrices ($min_prices) { // Rallye ends without user limitation is the default $return = '{--RALLYE_END_NO_PRICE_LIMITATION--}'; @@ -954,5 +1025,17 @@ function determineReferalRallyeMinimumPrices ($min_prices) { return $return; } +// "Getter" for total rallye prices by given id +function getTotalRallyePrices ($rallyeId) { + // Is there cache? + if (!isset($GLOBALS[__FUNCTION__][$rallyeId])) { + // Determine it + $GLOBALS[__FUNCTION__][$rallyeId] = countSumTotalData($rallyeId, 'rallye_prices', 'id', 'rallye_id', TRUE); + } // END - if + + // Return it + return $GLOBALS[__FUNCTION__][$rallyeId]; +} + // [EOF] ?>