Changeset 862

Timestamp:

08/30/08 18:02:39 (3 months ago)

Author:

ayunyan

Message:

plugin:mtimport added duplication check for comment and trackback

Files:

• plugins/mtimport/trunk/mtimport.plugin.php (modified) (7 diffs)

plugins/mtimport/trunk/mtimport.plugin.php

@@ -456 +456 @@
         $commentcount= $mtdb->get_value("SELECT count(comment_id) FROM {$db_prefix}comment WHERE comment_blog_id = '{$blog_id}';");
         $min = $commentindex * MT_IMPORT_BATCH + 1;
-        $max = min( ( $commentindex + 1 ) * MT_IMPORT_BATCH, $commentcount );
+        $max = min(($commentindex + 1) * MT_IMPORT_BATCH, $commentcount);
 
         echo sprintf(_t('<p>Importing comments %d-%d of %d.</p>'), $min, $max, $commentcount);
@@ -475 +475 @@
             comment_visible AS status,
             comment_entry_id AS mt_post_id,
+            comment_id,
             comment_junk_status
             FROM {$db_prefix}comment
@@ -480 +481 @@
             LIMIT {$min}," . MT_IMPORT_BATCH, array(), 'Comment');
 
+        $comment_map = DB::get_column("SELECT value FROM " . DB::table('commentinfo') . " WHERE name='mt_comment_id';");
+
         @reset($comments);
         while (list(, $comment) = @each($comments)) {
-            $comment->type= Comment::COMMENT;
+            // already exists skipped
+            if(in_array($comment->comment_id, $comment_map)) continue;
+
+            $comment->type = Comment::COMMENT;
 
             $carray = $comment->to_array();
             if ($carray['ip'] == '') {
-                $carray['ip']= 0;
+                $carray['ip'] = 0;
             }
 
             if ($carray['status'] == 1) {
-                $carray['status']= Comment::STATUS_APPROVED;
+                $carray['status'] = Comment::STATUS_APPROVED;
             } elseif ($carray['comment_junk_status'] != 0) {
-                $carray['status']= Comment::STATUS_SPAM;
+                $carray['status'] = Comment::STATUS_SPAM;
             } else {
-                $carray['status']= Comment::STATUS_UNAPPROVED;
+                $carray['status'] = Comment::STATUS_UNAPPROVED;
             }
             unset($carray['comment_junk_status']);
+
 
             if (!isset($post_map[$carray['mt_post_id']] ) ) {
@@ -504 +511 @@
                 unset( $carray['mt_post_id'] );
 
-                $c= new Comment( $carray );
-                //Utils::debug( $c );
+                $comment_id = $carray['comment_id'];
+                unset($carray['comment_id']);
+
+                $c = new Comment( $carray );
+                $c->info->mt_comment_id = $comment_id;
                 try{
                     $c->insert();
@@ -580 +590 @@
             trackback_created_on AS date,
             trackback_entry_id AS mt_post_id,
+            trackback_id,
             trackback_is_disabled
             FROM {$db_prefix}trackback
@@ -585 +596 @@
             LIMIT {$min}," . MT_IMPORT_BATCH, array(), 'Comment');
 
+        $comment_map = DB::get_column("SELECT value FROM " . DB::table('commentinfo') . " WHERE name='mt_trackback_id';");
+
         @reset($trackbacks);
         while (list(, $trackback) = @each($trackback)) {
+            // already exists skipped
+            if(in_array($trackback->trackback_id, $comment_map)) continue;
+
             $trackback->type= Comment::TRACKBACK;
 
@@ -605 +621 @@
                 unset( $carray['mt_post_id'] );
 
-                $c= new Comment( $carray );
-                //Utils::debug( $c );
+                $trackback_id = $carray['trackback_id'];
+                unset($carray['trackback_id']);
+
+                $c = new Comment( $carray );
+                $c->info->mt_trackback_id = $trackback_id;
                 try{
                     $c->insert();