1 files changed, 41 insertions, 0 deletions
diff --git a/setup/upgrade/0.9.9/add_duplicates.php b/setup/upgrade/0.9.9/add_duplicates.php
new file mode 100644
index 0000000..4a00a8a
--- /dev/null
+++ b/setup/upgrade/0.9.9/add_duplicates.php
@@ -0,0 +1,41 @@
+<?php
+   /**********************************************************\
+   | This script enters the relations of duplicate tasks into  |
+   | the databse.                                              |
+   \***********************************************************/
+   
+
+$check_sql = $db->query('SELECT task_id, closure_comment, resolution_reason FROM {tasks}');
+
+while ($row = $db->fetchRow($check_sql))
+{
+    if ($row['resolution_reason'] == 6) {
+        preg_match("/\b(?:FS#|bug )(\d+)\b/", $row['closure_comment'], $dupe_of);
+        if (count($dupe_of)) {
+            $existing = $db->query('SELECT * FROM {related} WHERE this_task = ? AND related_task = ? AND is_duplicate = 1',
+                                    array($row['task_id'], $dupe_of[1]));
+                               
+            if ($db->countRows($existing) == 0) {  
+                $db->query('INSERT INTO {related} (this_task, related_task, is_duplicate) VALUES(?,?,1)',
+                            array($row['task_id'], $dupe_of[1]));
+                echo $row['task_id'] . ' is a duplicate of ' . $dupe_of[1] . '.<br />';
+            }
+        }
+    }
+}
+
+$check_sql = $db->query('SELECT this_task, related_task FROM {related} WHERE is_duplicate = 0');
+$deleted = array();
+
+while ($row = $db->fetchRow($check_sql))
+{
+    $existing = $db->query('SELECT related_id FROM {related} WHERE this_task = ? AND related_task = ? AND is_duplicate = 0',
+                            array($row['related_task'], $row['this_task']));
+                              
+    if ($db->countRows($existing) == 1 && !isset($deleted[$row['related_task'].'-'.$row['this_task']])) {
+        $deleted[$row['this_task'].'-'.$row['related_task']] = true;
+        $db->query('DELETE FROM {related} WHERE related_id = ?', array($db->fetchOne($existing)));
+    }
+}
+
+?>