]> git.mxchange.org Git - mailer.git/blobdiff - inc/mysql-manager.php
Mailer continued, sub-id tracking continued:
[mailer.git] / inc / mysql-manager.php
index a21023e06e62be0ddedacffaf00d1225d36f3afc..ce649cdd36ef09f474ece96e26443566451dbc95 100644 (file)
@@ -111,7 +111,7 @@ function addYouAreHereLink ($accessLevel, $FQFN, $return = false) {
                // Get access level from it
                $modCheck = getModuleFromFileName($file, $accessLevel);
 
-               // Do we have admin? Then display all
+               // Is there admin? Then display all
                $ADD = " AND `visible`='Y' AND `locked`='N'";
                if (isAdmin()) {
                        // Display all!
@@ -258,7 +258,7 @@ ORDER BY
                                        $content['action']
                                ), __FUNCTION__, __LINE__);
 
-                       // Do we have some entries?
+                       // Are there some entries?
                        if (!SQL_HASZERONUMS($result_sub)) {
                                // Init counter
                                $count = '0';
@@ -506,7 +506,7 @@ function fetchUserData ($value, $column = 'userid') {
                        $value
                ), __FUNCTION__, __LINE__);
 
-       // Do we have a record?
+       // Is there a record?
        if (SQL_NUMROWS($result) == 1) {
                // Load data from cookies
                $data = SQL_FETCHARRAY($result);
@@ -591,7 +591,7 @@ function isAdmin () {
                return false;
        } // END - if
 
-       // Do we have cache?
+       // Is there cache?
        if (!isset($GLOBALS[__FUNCTION__][$adminId])) {
                // Init it with failed
                $GLOBALS[__FUNCTION__][$adminId] = false;
@@ -896,7 +896,7 @@ function getPaymentData ($paymentsId, $lookFor = 'price') {
        // Default value...
        $data[$lookFor] = NULL;
 
-       // Do we have cache?
+       // Is there cache?
        if (isset($GLOBALS['cache_array']['payments'][$paymentsId]['id'])) {
                // Use it if found to save SQL queries
                $data[$lookFor] = $GLOBALS['cache_array']['payments'][$lookFor][$paymentsId];
@@ -1101,7 +1101,7 @@ function getAdminId ($adminLogin) {
                $result = SQL_QUERY_ESC("SELECT `id` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `login`='%s' LIMIT 1",
                        array($adminLogin), __FUNCTION__, __LINE__);
 
-               // Do we have an entry?
+               // Is there an entry?
                if (SQL_NUMROWS($result) == 1) {
                        // Get it
                        $data = SQL_FETCHARRAY($result);
@@ -1120,7 +1120,7 @@ function getCurrentAdminId () {
        // Log debug message
        //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'called!');
 
-       // Do we have cache?
+       // Is there cache?
        if (!isset($GLOBALS['current_admin_id'])) {
                // Get the admin login from session
                $adminId = getSession('admin_id');
@@ -1155,7 +1155,7 @@ function getAdminHash ($adminId) {
                $result = SQL_QUERY_ESC("SELECT `password` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1",
                        array(bigintval($adminId)), __FUNCTION__, __LINE__);
 
-               // Do we have an entry?
+               // Is there an entry?
                if (SQL_NUMROWS($result) == 1) {
                        // Fetch data
                        $data = SQL_FETCHARRAY($result);
@@ -1258,7 +1258,7 @@ function getAdminDefaultAcl ($adminId) {
                $result_admin_id = SQL_QUERY_ESC("SELECT `default_acl` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1",
                        array(bigintval($adminId)), __FUNCTION__, __LINE__);
 
-               // Do we have an entry?
+               // Is there an entry?
                if (SQL_NUMROWS($result_admin_id) == 1) {
                        // Fetch data
                        $data = SQL_FETCHARRAY($result_admin_id);
@@ -1295,7 +1295,7 @@ function getAdminMenuMode ($adminId) {
                $result_admin_id = SQL_QUERY_ESC("SELECT `la_mode` FROM `{?_MYSQL_PREFIX?}_admins` WHERE `id`=%s LIMIT 1",
                        array(bigintval($adminId)), __FUNCTION__, __LINE__);
 
-               // Do we have an entry?
+               // Is there an entry?
                if (SQL_NUMROWS($result_admin_id) == 1) {
                        // Fetch data
                        $data = SQL_FETCHARRAY($result_admin_id);
@@ -1362,7 +1362,7 @@ function generateOptions ($table, $key, $value, $default = '', $extra = '', $whe
                                $value
                        ), __FUNCTION__, __LINE__);
 
-               // Do we have rows?
+               // Is there rows?
                if (!SQL_HASZERONUMS($result)) {
                        // Found data so add them as OPTION lines
                        while ($content = SQL_FETCHARRAY($result)) {
@@ -1428,7 +1428,7 @@ WHERE
 LIMIT 1",
                array(bigintval($userid)), __FUNCTION__, __LINE__);
 
-       // Do we have an entry?
+       // Is there an entry?
        if (SQL_NUMROWS($result) == 1) {
                // Save his points to add them to the jackpot
                $data = SQL_FETCHARRAY($result);
@@ -1526,7 +1526,7 @@ function generateCategoryOptionsList ($mode, $userid = NULL) {
        $result = SQL_QUERY('SELECT `id`,`cat` FROM `{?_MYSQL_PREFIX?}_cats`' . $whereStatement . ' ORDER BY `sort` ASC',
                __FUNCTION__, __LINE__);
 
-       // Do we have entries?
+       // Are there entries?
        if (!SQL_HASZERONUMS($result)) {
                // ... and begin loading stuff
                while ($content = SQL_FETCHARRAY($result)) {
@@ -1818,7 +1818,7 @@ function doGenericListEntries ($tableTemplate, $rowTemplate, $noEntryMessageId,
        // Remove last commata and add FROM statement
        $SQL .= ' FROM `{?_MYSQL_PREFIX?}_' . $tableName[0] . '`';
 
-       // Do we have entries from whereColumns to add?
+       // Are there entries from whereColumns to add?
        if (count($whereColumns) > 0) {
                // Then add these as well
                if (count($whereColumns) == 1) {
@@ -1863,7 +1863,7 @@ function doGenericListEntries ($tableTemplate, $rowTemplate, $noEntryMessageId,
                }
        } // END - if
 
-       // Do we have entries from orderByColumns to add?
+       // Are there entries from orderByColumns to add?
        if (count($orderByColumns) > 0) {
                // Add them as well
                $SQL .= ' ORDER BY ';
@@ -1895,7 +1895,7 @@ function doListEntries ($SQL, $tableTemplate, $noEntryMessageId, $rowTemplate, $
        // Run the SQL query
        $result = SQL_QUERY($SQL, __FUNCTION__, __LINE__);
 
-       // Do we have some URLs left?
+       // Are there some URLs left?
        if (!SQL_HASZERONUMS($result)) {
                // List all URLs
                $OUT = '';
@@ -1905,7 +1905,7 @@ function doListEntries ($SQL, $tableTemplate, $noEntryMessageId, $rowTemplate, $
                                // Fill the callback arguments
                                $args = array($content[$columnName]);
 
-                               // Do we have more to add?
+                               // Is there more to add?
                                if (isset($extraParameters[$columnName])) {
                                        // Add them as well
                                        $args = merge_array($args, $extraParameters[$columnName]);
@@ -1951,7 +1951,7 @@ function doGenericAddEntries ($tableName, $columns = array(), $filterFunctions =
        // Default is that all went fine
        $GLOBALS['__XML_PARSE_RESULT'] = true;
 
-       // Do we have "time columns"?
+       // Is there "time columns"?
        if (count($timeColumns) > 0) {
                // Then "walk" through all entries
                foreach ($timeColumns as $column) {
@@ -2011,35 +2011,341 @@ function doGenericAddEntries ($tableName, $columns = array(), $filterFunctions =
        // If all values are okay, continue
        if ($sqlValues[$key] !== false) {
                // Build the SQL query
-               $SQL = 'INSERT INTO `{?_MYSQL_PREFIX?}_' . $tableName[0] . '` (`' . implode('`,`', $sqlColumns) . "`) VALUES (" . implode(',', $sqlValues) . ')';
+               $sql = 'INSERT INTO `{?_MYSQL_PREFIX?}_' . $tableName[0] . '` (`' . implode('`,`', $sqlColumns) . "`) VALUES (" . implode(',', $sqlValues) . ')';
 
                // Run the SQL query
-               SQL_QUERY($SQL, __FUNCTION__, __LINE__);
+               SQL_QUERY($sql, __FUNCTION__, __LINE__);
+
+               // Add id
+               setPostRequestElement('id', SQL_INSERTID());
+
+               // Prepare filter data array
+               $filterData = array(
+                       'mode'          => 'add',
+                       'table_name'    => $tableName,
+                       'content'       => postRequestArray(),
+                       'id'            => SQL_INSERTID(),
+                       'subject'       => '',
+                       // @TODO Used generic 'userid' here
+                       'userid_column' => array('userid'),
+                       'raw_userid'    => array('userid'),
+                       'affected'      => SQL_AFFECTEDROWS(),
+                       'sql'           => $sql,
+               );
+
+               // Send "build mail" out
+               runFilterChain('send_build_mail', $filterData);
        } // END - if
 }
 
-// Adds a given entry to the database
-function memberAddEntries ($tableName, $columns = array(), $filterFunctions = array(), $extraValues = array(), $timeColumns = array(), $columnIndex = NULL) {
-       // Is it a member?
-       if (!isMember()) {
-               // Then abort here
-               return false;
+// Edit rows by given id numbers
+function doGenericEditEntriesConfirm ($tableName, $columns = array(), $filterFunctions = array(), $extraValues = array(), $timeColumns = array(), $editNow = array(false), $idColumn = array('id'), $userIdColumn = array('userid'), $rawUserId = array('userid'), $cacheFiles = array()) {
+       // Change them all
+       $affected = '0';
+       foreach (postRequestElement($idColumn[0]) as $id => $sel) {
+               // Prepare content array (new values)
+               $content = array();
+
+               // Prepare SQL for this row
+               $sql = sprintf("UPDATE `{?_MYSQL_PREFIX?}_%s` SET",
+                       SQL_ESCAPE($tableName[0])
+               );
+
+               // "Walk" through all entries
+               foreach (postRequestArray() as $key => $entries) {
+                       // Skip raw userid which is always invalid
+                       if ($key == $rawUserId[0]) {
+                               // Continue with next field
+                               //* NOISY-DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'key=' . $key . ',idColumn[0]=' . $idColumn[0] . ',rawUserId=' . $rawUserId[0]);
+                               continue;
+                       } // END - if
+
+                       // Debug message
+                       //* NOISY-DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'key=' . $key . ',idColumn[0]=' . $idColumn[0] . ',entries=<pre>'.print_r($entries,true).'</pre>');
+
+                       // Is entries an array?
+                       if (($key != $idColumn[0]) && (is_array($entries)) && (isset($entries[$id]))) {
+                               // Add this entry to content
+                               $content[$key] = $entries[$id];
+
+                               // Send data through the filter function if found
+                               if ($key == $userIdColumn[0]) {
+                                       // Is the userid, we have to process it with convertZeroToNull()
+                                       $entries[$id] = convertZeroToNull($entries[$id]);
+                               } elseif ((isset($filterFunctions[$key])) && (isset($extraValues[$key]))) {
+                                       // Filter function set!
+                                       $entries[$id] = handleExtraValues($filterFunctions[$key], $entries[$id], $extraValues[$key]);
+                               }
+
+                               // Is the value NULL?
+                               if ($entries[$id] == 'NULL') {
+                                       // Add it directly
+                                       $sql .= sprintf(' `%s`=NULL,',
+                                               SQL_ESCAPE($key)
+                                       );
+                               } else {
+                                       // Else add the value covered
+                                       $sql .= sprintf(" `%s`='%s',",
+                                               SQL_ESCAPE($key),
+                                               SQL_ESCAPE($entries[$id])
+                                       );
+                               }
+                       } elseif (($key != $idColumn[0]) && (!is_array($entries))) {
+                               // Add normal entries as well!
+                               $content[$key] =  $entries;
+                       }
+               } // END - foreach
+
+               // Finish SQL command
+               $sql = substr($sql, 0, -1) . " WHERE `" . SQL_ESCAPE($idColumn[0]) . "`=" . bigintval($id);
+               if ((isset($rawUserId[0])) && (isPostRequestElementSet($rawUserId[0])) && (isset($userIdColumn[0]))) {
+                       // Add user id as well
+                       $sql .= ' AND `' . $userIdColumn[0] . '`=' . bigintval(postRequestElement($rawUserId[0]));
+               } // END - if
+               $sql .= " LIMIT 1";
+
+               // Run this query
+               SQL_QUERY($sql, __FUNCTION__, __LINE__);
+
+               // Add affected rows
+               $edited = SQL_AFFECTEDROWS();
+               $affected += $edited;
+
+               // Load all data from that id
+               $result = SQL_QUERY_ESC("SELECT * FROM `{?_MYSQL_PREFIX?}_%s` WHERE `%s`=%s LIMIT 1",
+                       array(
+                               $tableName[0],
+                               $idColumn[0],
+                               $id
+                       ), __FUNCTION__, __LINE__);
+
+               // Fetch the data and merge it into $content
+               $content = merge_array($content, SQL_FETCHARRAY($result));
+
+               // Prepare filter data array
+               $filterData = array(
+                       'mode'          => 'edit',
+                       'table_name'    => $tableName,
+                       'content'       => $content,
+                       'id'            => $id,
+                       'subject'       => '',
+                       'userid_column' => $userIdColumn,
+                       'raw_userid'    => $rawUserId,
+                       'affected'      => $edited,
+                       'sql'           => $sql,
+               );
+
+               // Send "build mail" out
+               runFilterChain('send_build_mail', $filterData);
+
+               // Free the result
+               SQL_FREERESULT($result);
+       } // END - foreach
+
+       // Delete cache?
+       if ((count($cacheFiles) > 0) && (!empty($cacheFiles[0]))) {
+               // Delete cache file(s)
+               foreach ($cacheFiles as $cache) {
+                       // Skip any empty entries
+                       if (empty($cache)) {
+                               // This may cause trouble in loadCacheFile()
+                               continue;
+                       } // END - if
+
+                       // Is the cache file loadable?
+                       if ($GLOBALS['cache_instance']->loadCacheFile($cache)) {
+                               // Then remove it
+                               $GLOBALS['cache_instance']->removeCacheFile();
+                       } // END - if
+               } // END - foreach
        } // END - if
 
-       // Set POST data generic userid
-       setPostRequestElement('userid', getMemberId());
+       // Return affected rows
+       return $affected;
+}
+
+// Delete rows by given id numbers
+function doGenericDeleteEntriesConfirm ($tableName, $columns = array(), $filterFunctions = array(), $extraValues = array(), $deleteNow = array(false), $idColumn = array('id'), $userIdColumn = array('userid'), $rawUserId = array('userid'), $cacheFiles = array()) {
+       // The base SQL command:
+       $sql = "DELETE LOW_PRIORITY FROM `{?_MYSQL_PREFIX?}_%s` WHERE `%s` IN (%s)";
 
-       // Call inner function
-       doGenericAddEntries($tableName, $columns, $filterFunctions, $extraValues, $timeColumns, $columnIndex);
+       // Is a user id provided?
+       if ((isset($rawUserId[0])) && (isPostRequestElementSet($rawUserId[0])) && (isset($userIdColumn[0]))) {
+               // Add user id as well
+               $sql .= ' AND `' . $userIdColumn[0] . '`=' . bigintval(postRequestElement($rawUserId[0]));
+       } // END - if
 
-       // Entry has been added?
-       if ((!SQL_HASZEROAFFECTED()) && ($GLOBALS['__XML_PARSE_RESULT'] === true)) {
-               // Display success message
-               displayMessage('{--MEMBER_ENTRY_ADDED--}');
+       // Delete them all
+       $idList = '';
+       foreach (postRequestElement($idColumn[0]) as $id => $sel) {
+               // Is there a userid?
+               if (isPostRequestElementSet($userIdColumn[0])) {
+                       // Load all data from that id
+                       $result = SQL_QUERY_ESC("SELECT * FROM `{?_MYSQL_PREFIX?}_%s` WHERE `%s`=%s LIMIT 1",
+                               array(
+                                       $tableName[0],
+                                       $idColumn[0],
+                                       $id
+                               ), __FUNCTION__, __LINE__);
+
+                       // Fetch the data
+                       $content = SQL_FETCHARRAY($result);
+
+                       // Free the result
+                       SQL_FREERESULT($result);
+
+                       // Send "build mails" out
+                       sendGenericBuildMails('delete', $tableName, $content, $id, '', $userIdColumn);
+               } // END - if
+
+               // Add id number
+               $idList .= $id . ',';
+       } // END - foreach
+
+       // Run the query
+       SQL_QUERY_ESC($sql, array($tableName[0], $idColumn[0], substr($idList, 0, -1)), __FUNCTION__, __LINE__);
+
+       // Return affected rows
+       return SQL_AFFECTEDROWS();
+}
+
+// Build a special template list
+function doGenericListBuilder ($prefix, $listType, $tableName, $columns, $filterFunctions, $extraValues, $idColumn, $userIdColumn, $rawUserId = array('userid')) {
+       // $tableName and $idColumn must bove be arrays!
+       if ((!is_array($tableName)) || (count($tableName) != 1)) {
+               // $tableName is no array
+               reportBug(__FUNCTION__, __LINE__, 'tableName[]=' . gettype($tableName) . '!=array: userIdColumn=' . $userIdColumn);
+       } elseif (!is_array($idColumn)) {
+               // $idColumn is no array
+               reportBug(__FUNCTION__, __LINE__, 'idColumn[]=' . gettype($idColumn) . '!=array: userIdColumn=' . $userIdColumn);
+       } elseif ((!is_array($userIdColumn)) || (count($userIdColumn) != 1)) {
+               // $tableName is no array
+               reportBug(__FUNCTION__, __LINE__, 'userIdColumn[]=' . gettype($userIdColumn) . '!=array: userIdColumn=' . $userIdColumn);
+       }
+
+       // Init row output
+       $OUT = '';
+
+       // "Walk" through all entries
+       //* DEBUG: */ reportBug(__FUNCTION__, __LINE__, 'listType=<pre>'.print_r($listType,true).'</pre>,tableName<pre>'.print_r($tableName,true).'</pre>,columns=<pre>'.print_r($columns,true).'</pre>,filterFunctions=<pre>'.print_r($filterFunctions,true).'</pre>,extraValues=<pre>'.print_r($extraValues,true).'</pre>,idColumn=<pre>'.print_r($idColumn,true).'</pre>,userIdColumn=<pre>'.print_r($userIdColumn,true).'</pre>,rawUserId=<pre>'.print_r($rawUserId,true).'</pre>');
+       foreach (postRequestElement($idColumn[0]) as $id => $selected) {
+               // Secure id number
+               $id = bigintval($id);
+
+               // Get result from a given column array and table name
+               $result = SQL_RESULT_FROM_ARRAY($tableName[0], $columns, $idColumn[0], $id, __FUNCTION__, __LINE__);
+
+               // Is there one entry?
+               if (SQL_NUMROWS($result) == 1) {
+                       // Load all data
+                       $content = SQL_FETCHARRAY($result);
+
+                       // Filter all data
+                       foreach ($content as $key => $value) {
+                               // Search index
+                               $idx = searchXmlArray($key, $columns, 'column');
+
+                               // Skip any missing entries
+                               if ($idx === false) {
+                                       // Skip this one
+                                       //* DEBUG: */ reportBug(__FUNCTION__, __LINE__, 'key=' . $key . ' - SKIPPED!');
+                                       continue;
+                               } // END - if
+
+                               // Is there a userid?
+                               //* NOISY-DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'key=' . $key . ',userIdColumn=' . $userIdColumn[0]);
+                               if ($key == $userIdColumn[0]) {
+                                       // Add it again as raw id
+                                       //* DEBUG: */ reportBug(__FUNCTION__, __LINE__, 'key=' . $key . ',userIdColumn=' . $userIdColumn[0]);
+                                       $content[$userIdColumn[0]] = convertZeroToNull($value);
+                                       $content[$userIdColumn[0] . '_raw'] = $content[$userIdColumn[0]];
+                               } // END - if
+
+                               // If the key matches the idColumn variable, we need to temporary remember it
+                               //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'key=' . $key . ',idColumn=' . $idColumn[0] . ',value=' . $value);
+                               if ($key == $idColumn[0]) {
+                                       /*
+                                        * Found, so remember it securely (to make sure only id
+                                        * numbers can pass, don't use alpha-numerical values!)
+                                        */
+                                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'value=' . $value . ' - set as ' . $prefix . '_list_builder_id_value!');
+                                       $GLOBALS[$prefix . '_list_builder_id_value'] = bigintval($value);
+                               } // END - if
+
+                               // Is there a call-back function and extra-value pair?
+                               if ((isset($filterFunctions[$idx])) && (isset($extraValues[$idx]))) {
+                                       // Handle the call in external function
+                                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'key=' . $key . ',fucntion=' . $filterFunctions[$idx] . ',value=' . $value);
+                                       $content[$key] = handleExtraValues(
+                                               $filterFunctions[$idx],
+                                               $value,
+                                               $extraValues[$idx]
+                                       );
+                               } elseif ((isset($columns[$idx]['name'])) && (isset($filterFunctions[$columns[$idx]['name']])) && (isset($extraValues[$columns[$idx]['name']]))) {
+                                       // Handle the call in external function
+                                       //* DEBUG: */ logDebugMessage(__FUNCTION__, __LINE__, 'key=' . $key . ',fucntion=' . $filterFunctions[$columns[$idx]['name']] . ',value=' . $value);
+                                       $content[$key] = handleExtraValues(
+                                               $filterFunctions[$columns[$idx]['name']],
+                                               $value,
+                                               $extraValues[$columns[$idx]['name']]
+                                       );
+                               }
+                       } // END - foreach
+
+                       // Then list it
+                       $OUT .= loadTemplate(sprintf("%s_%s_%s_row",
+                               $prefix,
+                               $listType,
+                               $tableName[0]
+                               ), true, $content
+                       );
+               } // END - if
+
+               // Free the result
+               SQL_FREERESULT($result);
+       } // END - foreach
+
+       // Load master template
+       loadTemplate(sprintf("%s_%s_%s",
+               $prefix,
+               $listType,
+               $tableName[0]
+               ), false, $OUT
+       );
+}
+
+// Checks whether given URL is blacklisted
+function isUrlBlacklisted ($url) {
+       // Mark it as not listed by default
+       $listed = false;
+
+       // Is black-listing enbaled?
+       if (!isUrlBlacklistEnabled()) {
+               // No, then all URLs are not in this list
+               return false;
+       } elseif (!isset($GLOBALS['blacklist_data'][$url])) {
+               // Check black-list for given URL
+               $result = SQL_QUERY_ESC("SELECT UNIX_TIMESTAMP(`timestamp`) AS `blist_timestamp` FROM `{?_MYSQL_PREFIX?}_url_blacklist` WHERE `url`='%s' LIMIT 1",
+                       array($url), __FILE__, __LINE__);
+
+               // Is there an entry?
+               if (SQL_NUMROWS($result) == 1) {
+                       // Jupp, we got one listed
+                       $GLOBALS['blacklist_data'][$url] = SQL_FETCHARRAY($result);
+
+                       // Mark it as listed
+                       $listed = true;
+               } // END - if
+
+               // Free result
+               SQL_FREERESULT($result);
        } else {
-               // Display failed message
-               displayMessage('{--MEMBER_ENTRY_NOT_ADDED--}');
+               // Is found in cache -> black-listed
+               $listed = true;
        }
+
+       // Return result
+       return $listed;
 }
 
 // [EOF]