Swapped all

[mailer.git] / inc / fix_user_points.php

diff --git a/inc/fix_user_points.php b/inc/fix_user_points.php
index bcb648ced491125b4c8b075f856c7b46bdde45fd..47b00fa51af7e835a3818b460cf2776a749aa2fb 100644 (file)
--- a/inc/fix_user_points.php
+++ b/inc/fix_user_points.php
@@ -16,8 +16,8 @@
  * $Author::                                                          $ *
  * -------------------------------------------------------------------- *
  * Copyright (c) 2003 - 2009 by Roland Haeder                           *
- * Copyright (c) 2009 - 2011 by Mailer Developer Team                   *
- * For more information visit: http://www.mxchange.org                  *
+ * 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 *
  * it under the terms of the GNU General Public License as published by *
@@ -42,7 +42,11 @@ if (!defined('__SECURITY')) {
 
 // Get all user points
 $result = SQL_QUERY('SELECT
-       `userid`, `points`
+       `userid`,
+       `points`,
+       `locked_points`,
+       `order_points`,
+       `locked_order_points`
 FROM
        `{?_MYSQL_PREFIX?}_user_points`
 WHERE
@@ -50,12 +54,35 @@ WHERE
 ORDER BY
        `userid` ASC', __FILE__, __LINE__);
 
-// Do we have entries? (we should have!)
+// Are there entries? (there should be!)
 if (!SQL_HASZERONUMS($result)) {
        // Load row by row
        while ($row = SQL_FETCHARRAY($result)) {
-               // We have to fix this amount, so first pay it directly
-               addPointsDirectly('user_null_fix', $row['userid'], $row['points']);
+               // Update the database again
+               foreach (array_keys($row) as $column) {
+                       // Not userid itself
+                       if ($column != 'userid') {
+                               // Update amount
+                               SQL_QUERY_ESC("UPDATE `{?_MYSQL_PREFIX?}_user_points` SET `%s`=`%s`+%s WHERE `userid`=%s AND `ref_depth` IS NULL",
+                                       array(
+                                               $column,
+                                               $column,
+                                               $row[$column],
+                                               $row['userid']
+                                       ), __FILE__, __LINE__);
+
+                               // Nothing has been updated?
+                               if (SQL_HASZEROAFFECTED()) {
+                                       // Then insert it
+                                       SQL_QUERY_ESC("INSERT INTO `{?_MYSQL_PREFIX?}_user_points` (`userid`, `ref_depth`, `%s`) VALUES (%s,NULL,%s)",
+                                               array(
+                                                       $column,
+                                                       $row['userid'],
+                                                       $row[$column]
+                                               ), __FILE__, __LINE__);
+                               } // END - if
+                       } // END - if
+               } // END - foreach
        } // END - while
 } // END - if