X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=inc%2Flibs%2Fsurfbar_functions.php;h=972b196dad52074f3c117c631fb6e10a343c0f66;hb=32acd59740388a0e8faf9ee0efc27ff9d733d63f;hp=bdc6cd749c177e0cced6d370078b6194327d633e;hpb=777553ad962957b53a4dc71cbf5cddfad9c4d1fa;p=mailer.git diff --git a/inc/libs/surfbar_functions.php b/inc/libs/surfbar_functions.php index bdc6cd749c..972b196dad 100644 --- a/inc/libs/surfbar_functions.php +++ b/inc/libs/surfbar_functions.php @@ -42,7 +42,7 @@ if (!defined('__SECURITY')) { // ----------------------------------------------------------------------------- // // Admin has added an URL with given user id and so on -function SURFBAR_ADMIN_ADD_URL ($url) { +function SURFBAR_ADMIN_ADD_URL ($url, $limit) { // Do some pre-checks if (!IS_ADMIN()) { // Not an admin @@ -56,10 +56,13 @@ function SURFBAR_ADMIN_ADD_URL ($url) { } elseif (!SURFBAR_IF_USER_BOOK_MORE_URLS()) { // No more allowed! return false; + } elseif ("".($limit + 0)."" != "".$limit."") { + // Invalid amount entered + return false; } // Register the new URL - return SURFBAR_REGISTER_URL($url, "0", "ACTIVE", "unlock"); + return SURFBAR_REGISTER_URL($url, "0", "ACTIVE", "unlock", $limit); } // Admin unlocked an email so we can migrate the URL function SURFBAR_ADMIN_MIGRATE_URL ($url, $uid) { @@ -139,7 +142,7 @@ function SURFBAR_ADMIN_REJECT_URL_IDS ($IDs) { // ----------------------------------------------------------------------------- // // Member has added an URL -function SURFBAR_MEMBER_ADD_URL ($url) { +function SURFBAR_MEMBER_ADD_URL ($url, $limit) { global $_CONFIG; // Do some pre-checks @@ -155,10 +158,13 @@ function SURFBAR_MEMBER_ADD_URL ($url) { } elseif (!SURFBAR_IF_USER_BOOK_MORE_URLS($GLOBALS['userid'])) { // No more allowed! return false; + } elseif ("".($limit + 0)."" != "".$limit."") { + // Invalid amount entered + return false; } // Register the new URL - return SURFBAR_REGISTER_URL($url, $GLOBALS['userid']); + return SURFBAR_REGISTER_URL($url, $GLOBALS['userid'], "PENDING", "reg", $limit); } // Create list of actions depending on status for the user function SURFBAR_MEMBER_ACTIONS ($urlId, $status) { @@ -219,8 +225,17 @@ function SURFBAR_MEMBER_DO_FORM ($formData, $URLs) { return false; } + // Secure action + $action = SQL_ESCAPE(htmlentities(strip_tags($formData['action']), ENT_QUOTES)); + + // Has it changed? + if ($action != $formData['action']) { + // Invalid data in action found + return false; + } // END - if + // Create the function name for selected action - $functionName = sprintf("SURFBAR_MEMBER_%s_ACTION", strtoupper(SQL_ESCAPE($formData['action']))); + $functionName = sprintf("SURFBAR_MEMBER_%s_ACTION", strtoupper($action)); // Is the function there? if (function_exists($functionName)) { @@ -228,13 +243,14 @@ function SURFBAR_MEMBER_DO_FORM ($formData, $URLs) { $URLs[$formData['id']]['new_status'] = $SURFBAR_CACHE['new_status']; // Extract URL data for call-back - $urlData = array($URLs[$formData['id']]); + $urlData = array(array_merge($URLs[$formData['id']], array($action => $formData))); // Action found so execute it $performed = call_user_func_array($functionName, $urlData); } else { // Log invalid request - DEBUG_LOG(__FUNCTION__.": action={$formData['action']},id={$formData['id']},function={$functionName}"); + DEBUG_LOG(__FUNCTION__, __LINE__, " action={$formData['action']},id={$formData['id']},function={$functionName}"); + ADD_FATAL(sprintf("Invalid member action! action=%s,id=%s,function=%s", $formData['action'], $formData['id'], $functionName)); } // Return status @@ -253,6 +269,7 @@ function SURFBAR_VALIDATE_MEMBER_ACTION_STATUS ($action, $status) { // Fetch the new status if found if ($isValid) { + // Load new status list($SURFBAR_CACHE['new_status']) = SQL_FETCHROW($result); } // END - if @@ -267,7 +284,7 @@ function SURFBAR_VALIDATE_MEMBER_ACTION_STATUS ($action, $status) { // Member actions // ----------------------------------------------------------------------------- // -// Retreat an URL +// Retreat a booked URL function SURFBAR_MEMBER_RETREAT_ACTION ($urlData) { // Create the data array for next function call $data = array( @@ -287,21 +304,207 @@ function SURFBAR_MEMBER_BOOKNOW_ACTION ($urlData) { // Simply change the status here return SURFBAR_CHANGE_STATUS ($urlData['id'], $urlData['status'], $urlData['new_status'], $data); } +// Show edit form or do the changes +function SURFBAR_MEMBER_EDIT_ACTION ($urlData) { + // Is the "execute" flag there? + if (isset($urlData['edit']['execute'])) { + // Execute the changes + return SURFBAR_MEMBER_EXECUTE_ACTION("edit", $urlData); + } // END - if + + // Display form + return SURFBAR_MEMBER_DISPLAY_ACTION_FORM("edit", $urlData); +} +// Show delete form or do the changes +function SURFBAR_MEMBER_DELETE_ACTION ($urlData) { + // Is the "execute" flag there? + if (isset($urlData['delete']['execute'])) { + // Execute the changes + return SURFBAR_MEMBER_EXECUTE_ACTION("delete", $urlData); + } // END - if + + // Display form + return SURFBAR_MEMBER_DISPLAY_ACTION_FORM("delete", $urlData); +} +// Display selected "action form" +function SURFBAR_MEMBER_DISPLAY_ACTION_FORM ($action, $urlData) { + // Translate some data + $urlData['registered'] = MAKE_DATETIME($urlData['registered'], "2"); + $urlData['views_total'] = TRANSLATE_COMMA($urlData['views_total']); + $urlData['views_max'] = TRANSLATE_COMMA($urlData['views_max']); + $urlData['views_allowed'] = TRANSLATE_COMMA($urlData['views_allowed']); + $urlData['last_locked'] = MAKE_DATETIME($urlData['last_locked'], "2"); + + // Is the lock reason empty? + if (empty($urlData['lock_reason'])) { + // Fix it to three dashes + $urlData['lock_reason'] = "---"; + } // END - if + + // Include fields only for action 'edit' + if ($action == "edit") { + // Default is not limited + $urlData['limited_yes'] = ""; + $urlData['limited_no'] = " checked=\"checked\""; + $urlData['limited'] = "false"; + + // Is this URL limited? + if ($urlData['views_max'] > 0) { + // Then rewrite form data + $urlData['limited_yes'] = " checked=\"checked\""; + $urlData['limited_no'] = ""; + $urlData['limited'] = "true"; + } // END - if + } // END - if + + // Load the form and display it + LOAD_TEMPLATE(sprintf("member_surfbar_%s_action_form", $action), false, $urlData); + + // All fine by default ... ;-) + return true; +} +// Execute choosen action +function SURFBAR_MEMBER_EXECUTE_ACTION ($action, $urlData) { + // By default nothing is executed + $executed = false; + + // Is limitation "no" and "limit" is > 0? + if ((isset($urlData[$action]['limited'])) && ($urlData[$action]['limited'] == "N") && ((isset($urlData[$action]['limit'])) && ($urlData[$action]['limit'] > 0)) || (!isset($urlData[$action]['limit']))) { + // Set it to unlimited + $urlData[$action]['limit'] = 0; + } // END - if + + // Construct function name + $functionName = sprintf("SURFBAR_MEMBER_EXECUTE_%s_ACTION", strtoupper($action)); + + // Is 'userid' set and not 'uid' ? + if ((!isset($urlData['uid'])) && (isset($urlData['userid']))) { + // Auto-fix this + $urlData['uid'] = $urlData['userid']; + } // END - if + + // Is that function there? + if (function_exists($functionName)) { + // Execute the function + if (call_user_func_array($functionName, array($urlData)) == true) { + // Update status as well + $executed = SURFBAR_CHANGE_STATUS($urlData['id'], $urlData['status'], $urlData['new_status'], array($urlData['id'] => $urlData)); + } // END - if + } else { + // Not found! + ADD_FATAL(sprintf(MEMBER_SURFBAR_EXECUTE_ACTION_404, $functionName)); + } + + // Return status + return $executed; +} +// "Execute edit" function: Update changed data +function SURFBAR_MEMBER_EXECUTE_EDIT_ACTION ($urlData) { + // Translate URLs for testing + $url1 = COMPILE_CODE($urlData['url']); + $url2 = COMPILE_CODE($urlData['edit']['url']); + + // Has the URL or limit changed? + if (($urlData['views_allowed'] != $urlData['edit']['limit']) || ($url1 != $url2)) { + // Run the query + SQL_QUERY_ESC("UPDATE "._MYSQL_PREFIX."_surfbar_urls SET url='%s', views_allowed=%s, views_max=%s WHERE id=%s AND status='%s' LIMIT 1", + array($urlData['url'], $urlData['edit']['limit'], $urlData['edit']['limit'], $urlData['id'], $urlData['status']), __FILE__, __LINE__); + + // Prepare new data + $urlData['new_url'] = $urlData['edit']['url']; + $urlData['new_limit'] = $urlData['edit']['limit']; + unset($urlData['edit']); + + // Send admin notification + SURFBAR_NOTIFY_ADMIN("url_edited", $urlData); + + // Send user notification + SURFBAR_NOTIFY_USER("url_edited", $urlData); + + // All fine + return true; + } + + // Not updated + return false; +} +// +// ----------------------------------------------------------------------------- +// Self-maintenance functions +// ----------------------------------------------------------------------------- +// +// Main function +function SURFBAR_HANDLE_SELF_MAINTENANCE () { + // Handle URLs which limit has depleted so we can stop them + SURFBAR_HANDLE_DEPLETED_VIEWS(); + + // Handle low-points amounts + SURFBAR_HANDLE_LOW_POINTS(); +} +// Handle URLs which limit has depleted +function SURFBAR_HANDLE_DEPLETED_VIEWS () { + // Get all URLs + $urlArray = SURFBAR_GET_URL_DATA("0", "views_max", "id", "ASC", "id", " AND views_allowed>0 AND status='ACTIVE'"); + + // Do we have some entries? + if (count($urlArray) > 0) { + // Then handle all! + foreach ($urlArray as $id => $urlData) { + // Backup data + $data = $urlData; + + // Rewrite array for next call + $urlData[$id] = $data; + + // Handle the status + SURFBAR_CHANGE_STATUS($id, "ACTIVE", "DEPLETED", $urlData); + } // END - foreach + } // END - if +} +// Alert users which have URLs booked and are low on points amount +function SURFBAR_HANDLE_LOW_POINTS () { + global $_CONFIG; + + // Get all userids + $UIDs = SURFBAR_DETERMINE_DEPLETED_USERIDS($_CONFIG['surfbar_warn_low_points']); + + // "Walk" through all URLs + foreach ($UIDs['uid'] as $uid => $dummy) { + // Is the last notification far enougth away to notify again? + if ((time() - $UIDs['notified'][$uid]) >= $_CONFIG['surfbar_low_interval']) { + // Prepare content + $content = array( + 'uid' => $uid, + 'low' => TRANSLATE_COMMA($_CONFIG['surfbar_warn_low_points']), + 'points' => TRANSLATE_COMMA($UIDs['points'][$uid]), + 'notified' => MAKE_DATETIME($UIDs['notified'][$uid]), + 'interval' => CREATE_FANCY_TIME($_CONFIG['surfbar_low_interval']) + ); + + // Notify this user + SURFBAR_NOTIFY_USER("low_points", $content); + + // Update last notified + SQL_QUERY_ESC("UPDATE "._MYSQL_PREFIX."_user_data SET surfbar_low_notified=NOW() WHERE userid=%s LIMIT 1", + array($uid), __FILE__, __LINE__); + } // END - if + } // END - foreach +} // // ----------------------------------------------------------------------------- // Generic functions // ----------------------------------------------------------------------------- // // Looks up by an URL -function SURFBAR_LOOKUP_BY_URL ($url) { +function SURFBAR_LOOKUP_BY_URL ($url, $uid) { // Now lookup that given URL by itself - $urlArray = SURFBAR_GET_URL_DATA($url, "url"); + $urlArray = SURFBAR_GET_URL_DATA($url, "url", "id", "ASC", "id", sprintf(" AND userid=%s", bigintval($uid))); // Was it found? return (count($urlArray) > 0); } // Load URL data by given search term and column -function SURFBAR_GET_URL_DATA ($searchTerm, $column="id", $order="id", $sort="ASC", $group="id") { +function SURFBAR_GET_URL_DATA ($searchTerm, $column="id", $order="id", $sort="ASC", $group="id", $add="") { global $lastUrlData; // By default nothing is found @@ -320,9 +523,9 @@ function SURFBAR_GET_URL_DATA ($searchTerm, $column="id", $order="id", $sort="AS } // END - if // Look up the record - $result = SQL_QUERY_ESC("SELECT id, userid, url, views_total, status, registered, last_locked, lock_reason + $result = SQL_QUERY_ESC("SELECT id, userid, url, views_total, views_max, views_allowed, status, registered, last_locked, lock_reason, views_max, views_allowed FROM "._MYSQL_PREFIX."_surfbar_urls -WHERE %s='%s' +WHERE %s='%s'".$add." ORDER BY %s %s %s", array($column, $searchTerm, $order, $sort, $limit), __FILE__, __LINE__); @@ -349,7 +552,7 @@ ORDER BY %s %s return $lastUrlData; } // Registers an URL with the surfbar. You should have called SURFBAR_LOOKUP_BY_URL() first! -function SURFBAR_REGISTER_URL ($url, $uid, $status="PENDING", $addMode="reg") { +function SURFBAR_REGISTER_URL ($url, $uid, $status="PENDING", $addMode="reg", $limit=0) { global $_CONFIG; // Make sure by the user registered URLs are always pending @@ -360,14 +563,21 @@ function SURFBAR_REGISTER_URL ($url, $uid, $status="PENDING", $addMode="reg") { 'url' => $url, 'frametester' => FRAMETESTER($url), 'uid' => $uid, - 'status' => $status + 'status' => $status, + 'limit' => $limit ); // Insert the URL into database $content['insert_id'] = SURFBAR_INSERT_URL_BY_ARRAY($content); - // Translate status, reward and costs - $content['status'] = SURFBAR_TRANSLATE_STATUS($content['status']); + // Is this ID valid? + if ($content['insert_id'] == 0) { + // INSERT did not insert any data! + return false; + } // END - if + + // Translate status and limit + $content['limit'] = SURFBAR_TRANSLATE_LIMIT($content['limit']); // If in reg-mode we notify admin if (($addMode == "reg") || ($_CONFIG['surfbar_notify_admin_unlock'] == "Y")) { @@ -390,11 +600,13 @@ function SURFBAR_INSERT_URL_BY_ARRAY ($urlData) { if (empty($uid)) $uid = 0; // Just run the insert query for now - SQL_QUERY_ESC("INSERT INTO "._MYSQL_PREFIX."_surfbar_urls (userid, url, status) VALUES(%s, '%s', '%s')", + SQL_QUERY_ESC("INSERT INTO "._MYSQL_PREFIX."_surfbar_urls (userid,url,status,views_max,views_allowed) VALUES (%s,'%s','%s',%s,%s)", array( $uid, $urlData['url'], - $urlData['status'] + $urlData['status'], + $urlData['limit'], + $urlData['limit'] ), __FILE__, __LINE__ ); @@ -409,11 +621,25 @@ function SURFBAR_NOTIFY_ADMIN ($messageType, $content) { // Set default subject if following eval() wents wrong $subject = ADMIN_SURFBAR_NOTIFY_DEFAULT_SUBJECT; - // Prepare subject - $eval = sprintf("\$subject = ADMIN_SURFBAR_NOTIFY_%s_SUBJECT;", + // Create constant name + $constantName = sprintf("ADMIN_SURFBAR_NOTIFY_%s_SUBJECT", strtoupper($messageType) ); - @eval($eval); + + // Prepare subject + if (defined($constantName)) { + $subject = constant($constantName); + } else { + ADD_FATAL(ADMIN_SURFBAR_NOTIFY_SUBJECT_404, $constantName); + } + + // Translate some data if present + if (isset($content['status'])) $content['status'] = SURFBAR_TRANSLATE_STATUS($content['status']); + if (isset($content['registered'])) $content['registered'] = MAKE_DATETIME($content['registered'], "2"); + if (isset($content['last_locked'])) $content['last_locked'] = MAKE_DATETIME($content['last_locked'], "2"); + if (isset($content['views_total'])) $content['views_total'] = TRANSLATE_COMMA($content['views_total']); + if (isset($content['views_allowed'])) $content['views_allowed'] = TRANSLATE_COMMA($content['views_allowed']); + if (isset($content['views_max'])) $content['views_max'] = TRANSLATE_COMMA($content['views_max']); // Send the notification out return SEND_ADMIN_NOTIFICATION($subject, $templateName, $content, $content['uid']); @@ -431,11 +657,17 @@ function SURFBAR_NOTIFY_USER ($messageType, $content) { // Set default subject if following eval() wents wrong $subject = MEMBER_SURFBAR_NOTIFY_DEFAULT_SUBJECT; - // Prepare subject - $eval = sprintf("\$subject = MEMBER_SURFBAR_NOTIFY_%s_SUBJECT;", + // Create constant name + $constantName = sprintf("MEMBER_SURFBAR_NOTIFY_%s_SUBJECT", strtoupper($messageType) ); - @eval($eval); + + // Prepare subject + if (defined($constantName)) { + $subject = constant($constantName); + } else { + ADD_FATAL(MEMBER_SURFBAR_NOTIFY_SUBJECT_404, $constantName); + } // Load template $mailText = LOAD_EMAIL_TEMPLATE($templateName, $content, $content['uid']); @@ -443,6 +675,20 @@ function SURFBAR_NOTIFY_USER ($messageType, $content) { // Send the email return SEND_EMAIL($content['uid'], $subject, $mailText); } +// Translates the limit +function SURFBAR_TRANSLATE_LIMIT ($limit) { + // Is this zero? + if ($limit == 0) { + // Unlimited! + $return = MEMBER_SURFBAR_UNLIMITED_VIEWS; + } else { + // Translate comma + $return = TRANSLATE_COMMA($limit); + } + + // Return value + return $return; +} // Translate the URL status function SURFBAR_TRANSLATE_STATUS ($status) { // Create constant name @@ -451,10 +697,10 @@ function SURFBAR_TRANSLATE_STATUS ($status) { // Set default translated status $statusTranslated = "!".$constantName."!"; - // Generate eval() command + // Is the constant there? if (defined($constantName)) { - $eval = "\$statusTranslated = ".$constantName.";"; - eval($eval); + // Then get it's value + $statusTranslated = constant($constantName); } // END - if // Return result @@ -535,7 +781,7 @@ function SURFBAR_CHECK_RELOAD_FULL() { // Cache static reload lock $SURFBAR_CACHE['surf_lock'] = $_CONFIG['surfbar_static_lock']; - //DEBUG_LOG(__FUNCTION__.":Fixed surf lock is ".$_CONFIG['surfbar_static_lock'].""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "Fixed surf lock is ".$_CONFIG['surfbar_static_lock']."", false); // Do we have dynamic model? if ($_CONFIG['surfbar_pay_model'] == "DYNAMIC") { @@ -566,27 +812,27 @@ LIMIT 1", $total = SURFBAR_GET_TOTAL_URLS(); // Do we have some URLs in lock? Admins can always surf on own URLs! - //DEBUG_LOG(__FUNCTION__.":userLocks=".SURFBAR_GET_DATA('user_locks').",total={$total}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "userLocks=".SURFBAR_GET_DATA('user_locks').",total={$total}", false); $isFull = ((SURFBAR_GET_DATA('user_locks') == $total) && ($total > 0)); // Return result return $isFull; } // Get total amount of URLs of given status for current user or of ACTIVE URLs by default -function SURFBAR_GET_TOTAL_URLS ($status="ACTIVE", $excludeUserId="") { +function SURFBAR_GET_TOTAL_URLS ($status="ACTIVE", $excludeUserId=0) { // Determine depleted user account $UIDs = SURFBAR_DETERMINE_DEPLETED_USERIDS(); // Is the exlude userid set? - if ($excludeUserId !== "") { + if ($excludeUserId > 0) { // Then add it - $UIDs[] = $excludeUserId; + $UIDs['uid'][$excludeUserId] = $excludeUserId; } // END - if // Get amount from database $result = SQL_QUERY_ESC("SELECT COUNT(id) AS cnt FROM "._MYSQL_PREFIX."_surfbar_urls -WHERE userid NOT IN (".implode(",", $UIDs).") AND status='%s'", +WHERE userid NOT IN (".implode(",", $UIDs['uid']).") AND status='%s'", array($status), __FILE__, __LINE__ ); @@ -674,16 +920,16 @@ function SURFBAR_GENERATE_VALIDATION_CODE ($urlId, $salt="") { if (empty($salt)) { // Generate random hashed string $SURFBAR_CACHE['salt'] = sha1(GEN_PASS(255)); - //DEBUG_LOG(__FUNCTION__.":newSalt=".SURFBAR_GET_SALT().""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "newSalt=".SURFBAR_GET_SALT()."", false); } else { // Use this as salt! $SURFBAR_CACHE['salt'] = $salt; - //DEBUG_LOG(__FUNCTION__.":oldSalt=".SURFBAR_GET_SALT().""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "oldSalt=".SURFBAR_GET_SALT()."", false); } // ... and now the validation code $valCode = GEN_RANDOM_CODE($length, sha1(SURFBAR_GET_SALT().":".$urlId), $GLOBALS['userid']); - //DEBUG_LOG(__FUNCTION__.":valCode={$valCode}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "valCode={$valCode}", false); } // END - while // Hash it with md5() and salt it with the random string @@ -691,7 +937,9 @@ function SURFBAR_GENERATE_VALIDATION_CODE ($urlId, $salt="") { // Finally encrypt it PGP-like and return it $valHashedCode = generatePassString($hashedCode); - //DEBUG_LOG(__FUNCTION__.":finalValCode={$valHashedCode}"); + + // Return hashed value + //DEBUG_LOG(__FUNCTION__, __LINE__, "finalValCode={$valHashedCode}", false); return $valHashedCode; } // Check validation code @@ -705,16 +953,16 @@ function SURFBAR_CHECK_VALIDATION_CODE ($urlId, $check, $salt) { $code = SURFBAR_GENERATE_VALIDATION_CODE($urlId, $salt); // Return result of checking hashes and salts - //DEBUG_LOG(__FUNCTION__.":---".$code."|".$check."---"); - //DEBUG_LOG(__FUNCTION__.":+++".$salt."|".SURFBAR_GET_DATA('last_salt')."+++"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "---".$code."|".$check."---", false); + //DEBUG_LOG(__FUNCTION__, __LINE__, "+++".$salt."|".SURFBAR_GET_DATA('last_salt')."+++", false); return (($code == $check) && ($salt == SURFBAR_GET_DATA('last_salt'))); } // Lockdown the userid/id combination (reload lock) function SURFBAR_LOCKDOWN_ID ($urlId) { - //* //DEBUG: */ print "LOCK!"); - ///* //DEBUG: */ return; + //* DEBUG: */ print "LOCK!"); + ///* DEBUG: */ return; // Just add it to the database - SQL_QUERY_ESC("INSERT INTO "._MYSQL_PREFIX."_surfbar_locks (userid, url_id) VALUES(%s, %s)", + SQL_QUERY_ESC("INSERT INTO "._MYSQL_PREFIX."_surfbar_locks (userid, url_id) VALUES (%s, %s)", array($GLOBALS['userid'], bigintval($urlId)), __FILE__, __LINE__); // Remove the salt from database @@ -724,21 +972,33 @@ function SURFBAR_LOCKDOWN_ID ($urlId) { // Pay points to the user and remove it from the sender function SURFBAR_PAY_POINTS ($urlId) { // Remove it from the URL owner - //DEBUG_LOG(__FUNCTION__.":uid=".SURFBAR_GET_USERID().",costs=".SURFBAR_GET_COSTS().""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "uid=".SURFBAR_GET_USERID().",costs=".SURFBAR_GET_COSTS()."", false); if (SURFBAR_GET_USERID() > 0) { - SUB_POINTS(SURFBAR_GET_USERID(), SURFBAR_GET_COSTS()); + SUB_POINTS("surfbar", SURFBAR_GET_USERID(), SURFBAR_GET_COSTS()); } // END - if // Book it to the user - //DEBUG_LOG(__FUNCTION__.":uid=".$GLOBALS['userid'].",reward=".SURFBAR_GET_REWARD().""); - ADD_POINTS_REFSYSTEM($GLOBALS['userid'], SURFBAR_GET_DATA('reward')); + //DEBUG_LOG(__FUNCTION__, __LINE__, "uid=".$GLOBALS['userid'].",reward=".SURFBAR_GET_REWARD()."", false); + ADD_POINTS_REFSYSTEM("surfbar", $GLOBALS['userid'], SURFBAR_GET_DATA('reward')); } // Updates the statistics of current URL/userid function SURFBAR_UPDATE_INSERT_STATS_RECORD () { global $_CONFIG; - // Update views_total - SQL_QUERY_ESC("UPDATE "._MYSQL_PREFIX."_surfbar_urls SET views_total=views_total+1 WHERE id=%s LIMIT 1", + // Init add + $ADD = ""; + + // Get allowed views + $allowed = SURFBAR_GET_ALLOWED_VIEWS(); + + // Do we have a limit? + if ($allowed > 0) { + // Then count views_max down! + $ADD .= ",views_max=views_max-1"; + } // END - if + + // Update URL stats + SQL_QUERY_ESC("UPDATE "._MYSQL_PREFIX."_surfbar_urls SET views_total=views_total+1".$ADD." WHERE id=%s LIMIT 1", array(SURFBAR_GET_ID()), __FILE__, __LINE__); // Update the stats entry @@ -746,9 +1006,9 @@ function SURFBAR_UPDATE_INSERT_STATS_RECORD () { array($GLOBALS['userid'], SURFBAR_GET_ID()), __FILE__, __LINE__); // Was that update okay? - if (SQL_AFFECTEDROWS() == 0) { + if (SQL_AFFECTEDROWS() < 1) { // No, then insert entry - SQL_QUERY_ESC("INSERT INTO "._MYSQL_PREFIX."_surfbar_stats (userid,url_id,count) VALUES(%s,%s,1)", + SQL_QUERY_ESC("INSERT INTO "._MYSQL_PREFIX."_surfbar_stats (userid,url_id,count) VALUES (%s,%s,1)", array($GLOBALS['userid'], SURFBAR_GET_ID()), __FILE__, __LINE__); } // END - if @@ -771,24 +1031,24 @@ function SURFBAR_UPDATE_SALT_STATS () { array(SURFBAR_GET_SALT(), SURFBAR_GET_ID(), $GLOBALS['userid']), __FILE__, __LINE__); // Debug message - //DEBUG_LOG(__FUNCTION__.":salt=".SURFBAR_GET_SALT().",id=".SURFBAR_GET_ID().",uid=".$GLOBALS['userid'].""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "salt=".SURFBAR_GET_SALT().",id=".SURFBAR_GET_ID().",uid=".$GLOBALS['userid']."", false); // Was that okay? - if (SQL_AFFECTEDROWS() == 0) { + if (SQL_AFFECTEDROWS() < 1) { // Insert missing entry! - SQL_QUERY_ESC("INSERT INTO "._MYSQL_PREFIX."_surfbar_salts (url_id,userid,last_salt) VALUES(%s, %s, '%s')", + SQL_QUERY_ESC("INSERT INTO "._MYSQL_PREFIX."_surfbar_salts (url_id,userid,last_salt) VALUES (%s, %s, '%s')", array(SURFBAR_GET_ID(), $GLOBALS['userid'], SURFBAR_GET_SALT()), __FILE__, __LINE__); } // END - if // Debug message - //DEBUG_LOG(__FUNCTION__.":affectedRows=".SQL_AFFECTEDROWS().""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "affectedRows=".SQL_AFFECTEDROWS()."", false); // Return if the update was okay return (SQL_AFFECTEDROWS() == 1); } // Check if the reload lock is active for given id function SURFBAR_CHECK_RELOAD_LOCK ($urlId) { - //DEBUG_LOG(__FUNCTION__.":id={$urlId}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "id={$urlId}", false); // Ask the database $result = SQL_QUERY_ESC("SELECT COUNT(id) AS cnt FROM "._MYSQL_PREFIX."_surfbar_locks @@ -805,44 +1065,58 @@ LIMIT 1", SQL_FREERESULT($result); // Return check - //DEBUG_LOG(__FUNCTION__.":cnt={$cnt},".SURFBAR_GET_DATA('surf_lock').""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "cnt={$cnt},".SURFBAR_GET_DATA('surf_lock')."", false); return ($cnt == 1); } // Determine which user hash no more points left -function SURFBAR_DETERMINE_DEPLETED_USERIDS() { +function SURFBAR_DETERMINE_DEPLETED_USERIDS ($limit=0) { // Init array - $UIDs = array(); + $UIDs = array( + 'uid' => array(), + 'points' => array(), + 'notified' => array(), + ); // Do we have a current user id? - if (IS_MEMBER()) { + if ((IS_MEMBER()) && ($limit == 0)) { // Then add this as well - $UIDs[] = $GLOBALS['userid']; + $UIDs['uid'][$GLOBALS['userid']] = $GLOBALS['userid']; + $UIDs['points'][$GLOBALS['userid']] = GET_TOTAL_DATA($GLOBALS['userid'], "user_points", "points") - GET_TOTAL_DATA($GLOBALS['userid'], "user_data", "used_points"); + $UIDs['notified'][$GLOBALS['userid']] = 0; // Get all userid except logged in one - $result = SQL_QUERY_ESC("SELECT userid FROM "._MYSQL_PREFIX."_surfbar_urls -WHERE userid NOT IN (%s,0) AND status='ACTIVE' -GROUP BY userid -ORDER BY userid ASC", + $result = SQL_QUERY_ESC("SELECT u.userid, UNIX_TIMESTAMP(d.surfbar_low_notified) AS notified +FROM "._MYSQL_PREFIX."_surfbar_urls AS u +INNER JOIN "._MYSQL_PREFIX."_user_data AS d +ON u.userid=d.userid +WHERE u.userid NOT IN (%s,0) AND u.status='ACTIVE' +GROUP BY u.userid +ORDER BY u.userid ASC", array($GLOBALS['userid']), __FILE__, __LINE__); } else { // Get all userid - $result = SQL_QUERY_ESC("SELECT userid FROM "._MYSQL_PREFIX."_surfbar_urls -WHERE status='ACTIVE' -GROUP BY userid -ORDER BY userid ASC", __FILE__, __LINE__); + $result = SQL_QUERY("SELECT u.userid, UNIX_TIMESTAMP(d.surfbar_low_notified) AS notified +FROM "._MYSQL_PREFIX."_surfbar_urls AS u +INNER JOIN "._MYSQL_PREFIX."_user_data AS d +ON u.userid=d.userid +WHERE u.status='ACTIVE' +GROUP BY u.userid +ORDER BY u.userid ASC", __FILE__, __LINE__); } // Load all userid - while (list($uid) = SQL_FETCHROW($result)) { + while (list($uid, $notified) = SQL_FETCHROW($result)) { // Get total points $points = GET_TOTAL_DATA($uid, "user_points", "points") - GET_TOTAL_DATA($uid, "user_data", "used_points"); - //DEBUG_LOG(__FUNCTION__.":uid={$uid},points={$points}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "uid={$uid},points={$points}", false); // Shall we add this to ignore? - if ($points <= 0) { + if ($points <= $limit) { // Ignore this one! - //DEBUG_LOG(__FUNCTION__.":uid={$uid} has depleted points amount!"); - $UIDs[] = $uid; + //DEBUG_LOG(__FUNCTION__, __LINE__, "uid={$uid} has depleted points amount!", false); + $UIDs['uid'][$uid] = $uid; + $UIDs['points'][$uid] = $points; + $UIDs['notified'][$uid] = $notified; } // END - if } // END - while @@ -850,7 +1124,7 @@ ORDER BY userid ASC", __FILE__, __LINE__); SQL_FREERESULT($result); // Debug message - //DEBUG_LOG(__FUNCTION__.":UIDs::count=".count($UIDs)." (with own userid=".$GLOBALS['userid'].")"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "UIDs::count=".count($UIDs)." (with own userid=".$GLOBALS['userid'].")", false); // Return result return $UIDs; @@ -895,11 +1169,21 @@ function SURFBAR_DETERMINE_WAIT_TIME () { function SURFBAR_CHANGE_STATUS ($urlId, $prevStatus, $newStatus, $data=array()) { global $_CONFIG; + // Make new status always lower-case + $newStatus = strtolower($newStatus); + // Get URL data for status comparison if missing - if (count($data) == 0) { + if ((!is_array($data)) || (count($data) == 0)) { + // Fetch missing URL data $data = SURFBAR_GET_URL_DATA($urlId); } // END - if + // Is the new status set? + if ((!is_string($newStatus)) || (empty($newStatus))) { + // Abort here, but fine! + return true; + } // END - if + // Is the status like prevStatus is saying? if ($data[$urlId]['status'] != $prevStatus) { // No, then abort here @@ -908,10 +1192,10 @@ function SURFBAR_CHANGE_STATUS ($urlId, $prevStatus, $newStatus, $data=array()) // Update the status now - // ---------------------- Commented out for debugging member actions! ----------------------- + // ---------- Comment out for debugging/developing member actions! --------- //SQL_QUERY_ESC("UPDATE "._MYSQL_PREFIX."_surfbar_urls SET status='%s' WHERE id=%s LIMIT 1", // array($newStatus, bigintval($urlId)), __FILE__, __LINE__); - // ---------------------- Commented out for debugging member actions! ----------------------- + // ---------- Comment out for debugging/developing member actions! --------- // Was that fine? if (SQL_AFFECTEDROWS() != 1) { @@ -924,9 +1208,6 @@ function SURFBAR_CHANGE_STATUS ($urlId, $prevStatus, $newStatus, $data=array()) $data[$urlId]['frametester'] = FRAMETESTER($data[$urlId]['url']); $data[$urlId]['reward'] = TRANSLATE_COMMA($_CONFIG['surfbar_static_reward']); $data[$urlId]['costs'] = TRANSLATE_COMMA($_CONFIG['surfbar_static_costs']); - $data[$urlId]['status'] = SURFBAR_TRANSLATE_STATUS($newStatus); - $data[$urlId]['registered'] = MAKE_DATETIME($data[$urlId]['registered'], "2"); - $newStatus = strtolower($newStatus); // Send admin notification SURFBAR_NOTIFY_ADMIN("url_{$newStatus}", $data[$urlId]); @@ -1036,17 +1317,17 @@ ORDER BY // Load all entries while (list($lid, $url, $last) = SQL_FETCHROW($result)) { // Debug message - //DEBUG_LOG(__FUNCTION__.":next - lid={$lid},url={$url},rest=".(time() - $last)."/".SURFBAR_GET_DATA('surf_lock').""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "next - lid={$lid},url={$url},rest=".(time() - $last)."/".SURFBAR_GET_DATA('surf_lock')."", false); // Skip entries that are too old if (($last > (time() - SURFBAR_GET_DATA('surf_lock'))) && (!in_array($url, $ignored))) { // Debug message - //DEBUG_LOG(__FUNCTION__.":okay - lid={$lid},url={$url},last={$last}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "okay - lid={$lid},url={$url},last={$last}", false); // Add only if missing or bigger if ((!isset($IDs[$url])) || ($IDs[$url] > $last)) { // Debug message - //DEBUG_LOG(__FUNCTION__.":ADD - lid={$lid},url={$url},last={$last}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "ADD - lid={$lid},url={$url},last={$last}", false); // Add this ID $IDs[$url] = $last; @@ -1054,7 +1335,7 @@ ORDER BY } // END - if } else { // Debug message - //DEBUG_LOG(__FUNCTION__.":ignore - lid={$lid},url={$url},last={$last}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "ignore - lid={$lid},url={$url},last={$last}", false); // Ignore these old entries! $ignored[] = $url; @@ -1083,7 +1364,7 @@ WHERE sbu.userid NOT IN (".implode(",", $UIDs).") AND (sbu.views_allowed=0 OR (s GROUP BY sbu.id", __FILE__, __LINE__); // Log last query - //DEBUG_LOG(__FUNCTION__.":lastQuery=".$_CONFIG['db_last_query']."|numRows=".SQL_NUMROWS($result)."|Affected=".SQL_AFFECTEDROWS().""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "lastQuery=".$_CONFIG['db_last_query']."|numRows=".SQL_NUMROWS($result)."|Affected=".SQL_AFFECTEDROWS()."", false); // Fetch max rand $maxRand = SQL_NUMROWS($result); @@ -1100,7 +1381,7 @@ function SURFBAR_GET_USER_URLS () { $URLs = array(); // Begin the query - $result = SQL_QUERY_ESC("SELECT u.id, u.userid, u.url, u.views_total, u.status, UNIX_TIMESTAMP(u.registered) AS registered, UNIX_TIMESTAMP(u.last_locked) AS last_locked, u.lock_reason AS lock_reason + $result = SQL_QUERY_ESC("SELECT u.id, u.userid, u.url, u.views_total, u.views_max, u.views_allowed, u.status, UNIX_TIMESTAMP(u.registered) AS registered, UNIX_TIMESTAMP(u.last_locked) AS last_locked, u.lock_reason AS lock_reason FROM "._MYSQL_PREFIX."_surfbar_urls AS u WHERE u.userid=%s AND u.status != 'DELETED' ORDER BY u.id ASC", @@ -1190,7 +1471,7 @@ function SURFBAR_DETERMINE_NEXT_ID ($urlId = 0) { $UIDs = SURFBAR_DETERMINE_DEPLETED_USERIDS(); // Get maximum randomness factor - $maxRand = SURFBAR_GET_MAX_RANDOM($UIDs, $ADD); + $maxRand = SURFBAR_GET_MAX_RANDOM($UIDs['uid'], $ADD); // If more than one URL can be called generate the random number! if ($maxRand > 1) { @@ -1199,14 +1480,14 @@ function SURFBAR_DETERMINE_NEXT_ID ($urlId = 0) { } // END - if // And query the database - //DEBUG_LOG(__FUNCTION__.":randNum={$randNum},maxRand={$maxRand},surfLock=".SURFBAR_GET_DATA('surf_lock').""); - $result = SQL_QUERY_ESC("SELECT sbu.id, sbu.userid, sbu.url, sbs.last_salt, sbu.reward, sbu.costs, sbu.views_total, UNIX_TIMESTAMP(l.last_surfed) AS last_surfed + //DEBUG_LOG(__FUNCTION__, __LINE__, "randNum={$randNum},maxRand={$maxRand},surfLock=".SURFBAR_GET_DATA('surf_lock')."", false); + $result = SQL_QUERY_ESC("SELECT sbu.id, sbu.userid, sbu.url, sbs.last_salt, sbu.views_total, sbu.views_max, sbu.views_allowed, UNIX_TIMESTAMP(l.last_surfed) AS last_surfed FROM "._MYSQL_PREFIX."_surfbar_urls AS sbu LEFT JOIN "._MYSQL_PREFIX."_surfbar_salts AS sbs ON sbu.id=sbs.url_id LEFT JOIN "._MYSQL_PREFIX."_surfbar_locks AS l ON sbu.id=l.url_id -WHERE sbu.userid NOT IN (".implode(",", $UIDs).") AND sbu.status='ACTIVE' AND (sbu.views_allowed=0 OR (sbu.views_allowed > 0 AND sbu.views_max > 0))".$ADD." +WHERE sbu.userid NOT IN (".implode(",", $UIDs['uid']).") AND sbu.status='ACTIVE' AND (sbu.views_allowed=0 OR (sbu.views_allowed > 0 AND sbu.views_max > 0))".$ADD." GROUP BY sbu.id ORDER BY l.last_surfed ASC, sbu.id ASC LIMIT %s,1", @@ -1214,7 +1495,7 @@ LIMIT %s,1", ); } else { // Get data from specified id number - $result = SQL_QUERY_ESC("SELECT sbu.id, sbu.userid, sbu.url, sbs.last_salt, sbu.reward, sbu.costs, sbu.views_total, UNIX_TIMESTAMP(l.last_surfed) AS last_surfed + $result = SQL_QUERY_ESC("SELECT sbu.id, sbu.userid, sbu.url, sbs.last_salt, sbu.views_total, sbu.views_max, sbu.views_allowed, UNIX_TIMESTAMP(l.last_surfed) AS last_surfed FROM "._MYSQL_PREFIX."_surfbar_urls AS sbu LEFT JOIN "._MYSQL_PREFIX."_surfbar_salts AS sbs ON sbu.id=sbs.url_id @@ -1227,12 +1508,12 @@ LIMIT 1", } // Is there an id number? - //DEBUG_LOG(__FUNCTION__.":lastQuery=".$_CONFIG['db_last_query']."|numRows=".SQL_NUMROWS($result)."|Affected=".SQL_AFFECTEDROWS().""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "lastQuery=".$_CONFIG['db_last_query']."|numRows=".SQL_NUMROWS($result)."|Affected=".SQL_AFFECTEDROWS()."", false); if (SQL_NUMROWS($result) == 1) { // Load/cache data - //DEBUG_LOG(__FUNCTION__.":count(".count($SURFBAR_CACHE).") - BEFORE"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "count(".count($SURFBAR_CACHE).") - BEFORE", false); $SURFBAR_CACHE = merge_array($SURFBAR_CACHE, SQL_FETCHARRAY($result)); - //DEBUG_LOG(__FUNCTION__.":count(".count($SURFBAR_CACHE).") - AFTER"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "count(".count($SURFBAR_CACHE).") - AFTER", false); // Determine waiting time $SURFBAR_CACHE['time'] = SURFBAR_DETERMINE_WAIT_TIME(); @@ -1240,28 +1521,28 @@ LIMIT 1", // Is the last salt there? if (is_null($SURFBAR_CACHE['last_salt'])) { // Then repair it wit the static! - //DEBUG_LOG(__FUNCTION__.":last_salt - FIXED!"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "last_salt - FIXED!", false); $SURFBAR_CACHE['last_salt'] = ""; } // END - if // Fix missing last_surfed if ((!isset($SURFBAR_CACHE['last_surfed'])) || (is_null($SURFBAR_CACHE['last_surfed']))) { // Fix it here - //DEBUG_LOG(__FUNCTION__.":last_surfed - FIXED!"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "last_surfed - FIXED!", false); $SURFBAR_CACHE['last_surfed'] = 0; } // END - if // Get base/fixed reward and costs $SURFBAR_CACHE['reward'] = SURFBAR_DETERMINE_REWARD(); $SURFBAR_CACHE['costs'] = SURFBAR_DETERMINE_COSTS(); - //DEBUG_LOG(__FUNCTION__.":BASE/STATIC - reward=".SURFBAR_GET_REWARD()."|costs=".SURFBAR_GET_COSTS().""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "BASE/STATIC - reward=".SURFBAR_GET_REWARD()."|costs=".SURFBAR_GET_COSTS()."", false); // Only in dynamic model add the dynamic bonus! if ($_CONFIG['surfbar_pay_model'] == "DYNAMIC") { // Calculate dynamic reward/costs and add it $SURFBAR_CACHE['reward'] += SURFBAR_CALCULATE_DYNAMIC_ADD(); $SURFBAR_CACHE['costs'] += SURFBAR_CALCULATE_DYNAMIC_ADD(); - //DEBUG_LOG(__FUNCTION__.":DYNAMIC+ - reward=".SURFBAR_GET_REWARD()."|costs=".SURFBAR_GET_COSTS().""); + //DEBUG_LOG(__FUNCTION__, __LINE__, "DYNAMIC+ - reward=".SURFBAR_GET_REWARD()."|costs=".SURFBAR_GET_COSTS()."", false); } // END - if // Now get the id @@ -1272,7 +1553,7 @@ LIMIT 1", SQL_FREERESULT($result); // Return result - //DEBUG_LOG(__FUNCTION__.":nextId={$nextId}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "nextId={$nextId}", false); return $nextId; } // ----------------------------------------------------------------------------- @@ -1282,7 +1563,7 @@ LIMIT 1", // Private getter for data elements function SURFBAR_GET_DATA ($element) { global $SURFBAR_CACHE; - //DEBUG_LOG(__FUNCTION__.":element={$element}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "element={$element}", false); // Default is null $data = null; @@ -1299,7 +1580,7 @@ function SURFBAR_GET_DATA ($element) { } // Return result - //DEBUG_LOG(__FUNCTION__.":element[$element]={$data}"); + //DEBUG_LOG(__FUNCTION__, __LINE__, "element[$element]={$data}", false); return $data; } // Getter for reward from cache @@ -1342,5 +1623,10 @@ function SURFBAR_GET_RELOAD_TIME () { // Get data element and return its contents return SURFBAR_GET_DATA('time'); } +// Getter for allowed views +function SURFBAR_GET_ALLOWED_VIEWS () { + // Get data element and return its contents + return SURFBAR_GET_DATA('views_allowed'); +} // ?>