]> git.mxchange.org Git - mailer.git/blobdiff - inc/mysql-manager.php
Mailer continued, sub-id tracking continued:
[mailer.git] / inc / mysql-manager.php
index 0513795fb2c3df80a613772120c50b56a8ce684e..ce649cdd36ef09f474ece96e26443566451dbc95 100644 (file)
@@ -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)";
+
+       // 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
+
+       // 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
+       );
+}
 
-       // Call inner function
-       doGenericAddEntries($tableName, $columns, $filterFunctions, $extraValues, $timeColumns, $columnIndex);
+// Checks whether given URL is blacklisted
+function isUrlBlacklisted ($url) {
+       // Mark it as not listed by default
+       $listed = false;
 
-       // Entry has been added?
-       if ((!SQL_HASZEROAFFECTED()) && ($GLOBALS['__XML_PARSE_RESULT'] === true)) {
-               // Display success message
-               displayMessage('{--MEMBER_ENTRY_ADDED--}');
+       // 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]