Dotclear

source: plugins/importExport/inc/class.dc.import.wp.php @ 1719:b8c48f380463

Revision 1719:b8c48f380463, 23.6 KB checked in by Dsls, 12 years ago (diff)

Added dcAdminCombos utility class, lots of combos available from everywhere now. Closes #1599
Line 
1<?php
2# -- BEGIN LICENSE BLOCK ---------------------------------------
3#
4# This file is part of importExport, a plugin for DotClear2.
5#
6# Copyright (c) 2003-2012 Olivier Meunier & Association Dotclear
7# Licensed under the GPL version 2.0 license.
8# See LICENSE file or
9# http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
10#
11# -- END LICENSE BLOCK -----------------------------------------
12if (!defined('DC_RC_PATH')) { return; }
13
14class dcImportWP extends dcIeModule
15{
16     protected $con;
17     protected $prefix;
18     protected $blog_id;
19     
20     protected $action = null;
21     protected $step = 1;
22     
23     protected $post_offset = 0;
24     protected $post_limit = 20;
25     protected $post_count = 0;
26     
27     protected $has_table = array();
28     
29     protected $vars;
30     protected $base_vars = array(
31          'db_host' => '',
32          'db_name' => '',
33          'db_user' => '',
34          'db_pwd' => '',
35          'db_prefix' => 'wp_',
36          'ignore_first_cat' => 1,
37          'cat_import' => 1,
38          'cat_as_tags' => '',
39          'cat_tags_prefix' => 'cat: ',
40          'post_limit' => 20,
41          'post_formater' => 'xhtml',
42          'comment_formater' => 'xhtml',
43          'user_ids' => array(),
44          'cat_ids' => array(),
45          'permalink_template' => 'p=%post_id%',
46          'permalink_tags' => array(
47               '%year%', 
48               '%monthnum%', 
49               '%day%', 
50               '%hour%', 
51               '%minute%', 
52               '%second%', 
53               '%postname%', 
54               '%post_id%', 
55               '%category%', 
56               '%author%'
57          )
58     );
59     protected $formaters;
60     
61     protected function setInfo()
62     {
63          $this->type = 'import';
64          $this->name = __('WordPress import');
65          $this->description = __('Import a WordPress installation into your current blog.');
66     }
67     
68     public function init()
69     {
70          $this->con =& $this->core->con;
71          $this->prefix = $this->core->prefix;
72          $this->blog_id = $this->core->blog->id;
73         
74          if (!isset($_SESSION['wp_import_vars'])) {
75               $_SESSION['wp_import_vars'] = $this->base_vars;
76          }
77          $this->vars =& $_SESSION['wp_import_vars'];
78         
79          if ($this->vars['post_limit'] > 0) {
80               $this->post_limit = $this->vars['post_limit'];
81          }
82
83          $this->formaters = dcAdminCombos::getFormatersCombo();
84     }
85     
86     public function resetVars()
87     {
88          $this->vars = $this->base_vars;;
89          unset($_SESSION['wp_import_vars']);
90     }
91     
92     public function process($do)
93     {
94          $this->action = $do;
95     }
96     
97     # We handle process in another way to always display something to
98     # user
99     protected function guiprocess($do)
100     {
101          switch ($do)
102          {
103               case 'step1':
104                    $this->vars['db_host'] = $_POST['db_host'];
105                    $this->vars['db_name'] = $_POST['db_name'];
106                    $this->vars['db_user'] = $_POST['db_user'];
107                    $this->vars['db_pwd'] = $_POST['db_pwd'];
108                    $this->vars['db_prefix'] = $_POST['db_prefix'];
109                    $this->vars['ignore_first_cat'] = isset($_POST['ignore_first_cat']);
110                    $this->vars['cat_import'] = isset($_POST['cat_import']);
111                    $this->vars['cat_as_tags'] = isset($_POST['cat_as_tags']);
112                    $this->vars['cat_tags_prefix'] = $_POST['cat_tags_prefix'];
113                    $this->vars['post_limit'] = abs((integer) $_POST['post_limit']) > 0 ? $_POST['post_limit'] : 0;
114                    $this->vars['post_formater'] = isset($this->formaters[$_POST['post_formater']]) ? $_POST['post_formater'] : 'xhtml';
115                    $this->vars['comment_formater'] = isset($this->formaters[$_POST['comment_formater']]) ? $_POST['comment_formater'] : 'xhtml';
116                    $db = $this->db();
117                    $db->close();
118                    $this->step = 2;
119                    echo $this->progressBar(1);
120                    break;
121               case 'step2':
122                    $this->step = 2;
123                    $this->importUsers();
124                    $this->step = 3;
125                    echo $this->progressBar(3);
126                    break;
127               case 'step3':
128                    $this->step = 3;
129                    $this->importCategories();
130                    if ($this->core->plugins->moduleExists('blogroll')) {
131                         $this->step = 4;
132                         echo $this->progressBar(5);
133                    } else {
134                         $this->step = 5;
135                         echo $this->progressBar(7);
136                    }
137                    break;
138               case 'step4':
139                    $this->step = 4;
140                    $this->importLinks();
141                    $this->step = 5;
142                    echo $this->progressBar(7);
143                    break;
144               case 'step5':
145                    $this->step = 5;
146                    $this->post_offset = !empty($_REQUEST['offset']) ? abs((integer) $_REQUEST['offset']) : 0;
147                    if ($this->importPosts($percent) === -1) {
148                         http::redirect($this->getURL().'&do=ok');
149                    } else {
150                         echo $this->progressBar(ceil($percent*0.93)+7);
151                    }
152                    break;
153               case 'ok':
154                    $this->resetVars();
155                    $this->core->blog->triggerBlog();
156                    $this->step = 6;
157                    echo $this->progressBar(100);
158                    break;
159          }
160     }
161     
162     public function gui()
163     {
164          try {
165               $this->guiprocess($this->action);
166          } catch (Exception $e) {
167               $this->error($e);
168          }
169         
170          switch ($this->step)
171          {
172               case 1:
173                    echo
174                    '<p>'.sprintf(__('This will import your WordPress content as new content in the current blog: %s.'),
175                    '<strong>'.html::escapeHTML($this->core->blog->name).'</strong>').'</p>'.
176                    '<p class="warning">'.__('Please note that this process '.
177                    'will empty your categories, blogroll, entries and comments on the current blog.').'</p>';
178                   
179                    printf($this->imForm(1,__('General information'),__('Import my blog now')),
180                    '<p>'.__('We first need some information about your old WordPress installation.').'</p>'.
181                    '<p><label for="db_host">'.__('Database Host Name:').'</label> '.
182                    form::field('db_host',30,255,html::escapeHTML($this->vars['db_host'])).'</p>'.
183                    '<p><label for="db_name">'.__('Database Name:',html::escapeHTML($this->vars['db_name'])).'</label> '.
184                    form::field('db_name',30,255,html::escapeHTML($this->vars['db_name'])).'</p>'.
185                    '<p><label for="db_user">'.__('Database User Name:').'</label> '.
186                    form::field('db_user',30,255,html::escapeHTML($this->vars['db_user'])).'</p>'.
187                    '<p><label for="db_pwd">'.__('Database Password:').'</label> '.
188                    form::password('db_pwd',30,255).'</p>'.
189                    '<p><label for="db_prefix">'.__('Database Tables Prefix:').'</label> '.
190                    form::field('db_prefix',30,255,html::escapeHTML($this->vars['db_prefix'])).'</p>'.
191
192                    '<h3 class="vertical-separator">'.__('Entries import options').'</h3>'.
193                    '<div class="two-cols">'.
194
195                    '<div class="col">'.
196                    '<p>'.__('WordPress and Dotclear\'s handling of categories are quite different. '.
197                    'You can assign several categories to a single post in WordPress. In the Dotclear world, '.
198                    'we see it more like "One category, several tags." Therefore Dotclear can only import one '.
199                    'category per post and will chose the lowest numbered one. If you want to keep a trace of '.
200                    'every category, you can import them as tags, with an optional prefix.').'</p>'.
201                    '<p>'.__('On the other hand, in WordPress, a post can not be uncategorized, and a '.
202                    'default installation has a first category labelised <i>"Uncategorized"</i>.'.
203                    'If you did not change that category, you can just ignore it while '.
204                    'importing your blog, as Dotclear allows you to actually keep your posts '.
205                    'uncategorized.').'</p>'.
206                    '</div>'.
207
208                    '<div class="col">'.
209                    '<p><label for="ignore_first_cat" class="classic">'.form::checkbox('ignore_first_cat',1,$this->vars['ignore_first_cat']).' '.
210                    __('Ignore the first category:').'</label></p>'.
211                    '<p><label for="cat_import" class="classic">'.form::checkbox('cat_import',1,$this->vars['cat_import']).' '.
212                    __('Import lowest numbered category on posts:').'</label></p>'.
213                    '<p><label for="cat_as_tags" class="classic">'.form::checkbox('cat_as_tags',1,$this->vars['cat_as_tags']).' '.
214                    __('Import all categories as tags:').'</label></p>'.
215                    '<p><label for="cat_tags_prefix">'.__('Prefix such tags with:').'</label> '.
216                    form::field('cat_tags_prefix',10,20,html::escapeHTML($this->vars['cat_tags_prefix'])).'</p>'.
217                    '<p><label for="post_limit">'.__('Number of entries to import at once:').'</label> '.
218                    form::field('post_limit',3,3,html::escapeHTML($this->vars['post_limit'])).'</p>'.
219                    '</div>'.
220                   
221                    '</div>'.
222
223                    '<h3 class="clear vertical-separator">'.__('Content filters').'</h3>'.
224                    '<p>'.__('You may want to process your post and/or comment content with the following filters.').'</p>'.
225                    '<p><label for="post_formater">'.__('Post content formatter:').'</label> '.
226                    form::combo('post_formater',$this->formaters,$this->vars['post_formater']).'</p>'.
227                    '<p><label for="comment_formater">'.__('Comment content formatter:').'</label> '
228                    .form::combo('comment_formater',$this->formaters,$this->vars['comment_formater']).'</p>'
229                    );
230                    break;
231               case 2:
232                    printf($this->imForm(2,__('Importing users')),
233                         $this->autoSubmit()
234                    );
235                    break;
236               case 3:
237                    printf($this->imForm(3,__('Importing categories')),
238                         $this->autoSubmit()
239                    );
240                    break;
241               case 4:
242                    printf($this->imForm(4,__('Importing blogroll')),
243                         $this->autoSubmit()
244                    );
245                    break;
246               case 5:
247                    $t = sprintf(__('Importing entries from %d to %d / %d'),$this->post_offset,
248                         min(array($this->post_offset+$this->post_limit,$this->post_count)),$this->post_count);
249                    printf($this->imForm(5,$t),
250                         form::hidden(array('offset'),$this->post_offset).
251                         $this->autoSubmit()
252                    );
253                    break;
254               case 6:
255                    echo 
256                    '<p class="message">'.__('Every newly imported user has received a random password '.
257                    'and will need to ask for a new one by following the "I forgot my password" link on the login page '.
258                    '(Their registered email address has to be valid.)').'</p>'.
259                    $this->congratMessage();
260                    break;
261          }
262     }
263     
264     # Simple form for step by step process
265     protected function imForm($step,$legend,$submit_value=null)
266     {
267          if (!$submit_value) {
268               $submit_value = __('next step').' >';
269          }
270         
271          return
272          '<form action="'.$this->getURL(true).'" method="post">'.
273          '<h3 class="vertical-separator">'.$legend.'</h3>'.
274          '<div>'.$this->core->formNonce().
275          form::hidden(array('do'),'step'.$step).
276          '%s'.'</div>'.
277          '<p><input type="submit" value="'.$submit_value.'" /></p>'.
278          '<p class="form-note info">'.__('Depending on the size of your blog, it could take a few minutes.').'</p>'.
279          '</form>';
280     }
281     
282     # Error display
283     protected function error($e)
284     {
285          echo '<div class="error"><strong>'.__('Errors:').'</strong>'.
286          '<p>'.$e->getMessage().'</p></div>';
287     }
288     
289     # Database init
290     protected function db()
291     {
292          $db = dbLayer::init('mysql',$this->vars['db_host'],$this->vars['db_name'],$this->vars['db_user'],$this->vars['db_pwd']);
293         
294          $rs = $db->select("SHOW TABLES LIKE '".$this->vars['db_prefix']."%'");
295          if ($rs->isEmpty()) {
296               throw new Exception(__('WordPress tables not found'));
297          }
298         
299          while ($rs->fetch()) {
300               $this->has_table[$rs->f(0)] = true;
301          }
302         
303          # Set this to read data as they were written
304          try {
305               $db->execute('SET NAMES DEFAULT');
306          } catch (Exception $e) {}
307         
308          $db->execute('SET CHARACTER SET DEFAULT');
309          $db->execute("SET COLLATION_CONNECTION = DEFAULT");
310          $db->execute("SET COLLATION_SERVER = DEFAULT");
311          $db->execute("SET CHARACTER_SET_SERVER = DEFAULT");
312          $db->execute("SET CHARACTER_SET_DATABASE = DEFAULT");
313         
314          $this->post_count = $db->select(
315               'SELECT COUNT(ID) FROM '.$this->vars['db_prefix'].'posts '.
316               'WHERE post_type = \'post\' OR post_type = \'page\''
317          )->f(0);
318         
319          return $db;
320     }
321     
322     protected function cleanStr($str)
323     {
324          return text::cleanUTF8(@text::toUTF8($str));
325     }
326     
327     # Users import
328     protected function importUsers()
329     {
330          $db = $this->db();
331          $prefix = $this->vars['db_prefix'];
332          $rs = $db->select('SELECT * FROM '.$prefix.'users');
333         
334          try
335          {
336               $this->con->begin();
337               
338               while ($rs->fetch())
339               {
340                    $user_login = preg_replace('/[^A-Za-z0-9@._-]/','-',$rs->user_login);
341                    $this->vars['user_ids'][$rs->ID] = $user_login;
342                    if (!$this->core->userExists($user_login))
343                    {
344                         $cur = $this->con->openCursor($this->prefix.'user');
345                         $cur->user_id          = $user_login;
346                         $cur->user_pwd         = crypt::createPassword();
347                         $cur->user_displayname = $rs->user_nicename;
348                         $cur->user_email       = $rs->user_email;
349                         $cur->user_url         = $rs->user_url;
350                         $cur->user_creadt      = $rs->user_registered;
351                         $cur->user_lang        = $this->core->blog->settings->system->lang;
352                         $cur->user_tz          = $this->core->blog->settings->system->blog_timezone;
353                         $permissions           = array();
354                         
355                         $rs_meta = $db->select('SELECT * FROM '.$prefix.'usermeta WHERE user_id = '.$rs->ID);
356                         while ($rs_meta->fetch())
357                         {
358                              switch ($rs_meta->meta_key)
359                              {
360                                   case 'first_name':
361                                        $cur->user_firstname     = $this->cleanStr($rs_meta->meta_value);
362                                        break;
363                                   case 'last_name':
364                                        $cur->user_name     = $this->cleanStr($rs_meta->meta_value);
365                                        break;
366                                   case 'description':
367                                        $cur->user_desc     = $this->cleanStr($rs_meta->meta_value);
368                                        break;
369                                   case 'rich_editing':
370                                        $cur->user_options  = new ArrayObject(array(
371                                             'enable_wysiwyg' => $rs_meta->meta_value == 'true' ? true : false
372                                             ));
373                                        break;
374                                   case 'wp_user_level':
375                                        switch ($rs_meta->meta_value)
376                                        {
377                                             case '0': # Subscriber
378                                                  $cur->user_status = 0;
379                                                  break;
380                                             case '1': # Contributor
381                                                  $permissions['usage'] = true;
382                                                  $permissions['publish'] = true;
383                                                  $permissions['delete'] = true;
384                                                  break;
385                                             case '2': # Author
386                                             case '3':
387                                             case '4':
388                                                  $permissions['contentadmin'] = true;
389                                                  $permissions['media'] = true;
390                                                  break;
391                                             case '5': # Editor
392                                             case '6':
393                                             case '7':
394                                                  $permissions['contentadmin'] = true;
395                                                  $permissions['categories'] = true;
396                                                  $permissions['media_admin'] = true;
397                                                  $permissions['pages'] = true;
398                                                  $permissions['blogroll'] = true;
399                                                  break;
400                                             case '8':  # Administrator
401                                             case '9':
402                                             case '10':
403                                                  $permissions['admin'] = true;
404                                                  break;
405                                        }
406                                        break;
407                              }
408                         }
409                         $this->core->addUser($cur);
410                         $this->core->setUserBlogPermissions(
411                              $cur->user_id,
412                              $this->blog_id,
413                              $permissions
414                         );
415                    }
416               }
417               $this->con->commit();
418               $db->close();
419          }
420          catch (Exception $e)
421          {
422               $this->con->rollback();
423               $db->close();
424               throw $e;
425          }
426     }
427     
428     # Categories import
429     protected function importCategories()
430     {
431          $db = $this->db();
432          $prefix = $this->vars['db_prefix'];
433          $rs = $db->select(
434               'SELECT * FROM '.$prefix.'terms AS t, '.$prefix.'term_taxonomy AS x '.
435               'WHERE x.taxonomy = \'category\' '.
436               'AND t.term_id = x.term_id '.
437               ($this->vars['ignore_first_cat'] ? 'AND t.term_id <> 1 ' : '').
438               'ORDER BY t.term_id ASC'
439          );
440         
441          try
442          {
443               $this->con->execute(
444                    'DELETE FROM '.$this->prefix.'category '.
445                    "WHERE blog_id = '".$this->con->escape($this->blog_id)."' "
446               );
447               
448               $ord = 2;
449               while ($rs->fetch())
450               {
451                    $cur = $this->con->openCursor($this->prefix.'category');
452                    $cur->blog_id      = $this->blog_id;
453                    $cur->cat_title    = $this->cleanStr($rs->name);
454                    $cur->cat_desc     = $this->cleanStr($rs->description);
455                    $cur->cat_url      = $this->cleanStr($rs->slug);
456                    $cur->cat_lft      = $ord++;
457                    $cur->cat_rgt      = $ord++;
458                   
459                    $cur->cat_id = $this->con->select(
460                         'SELECT MAX(cat_id) FROM '.$this->prefix.'category'
461                         )->f(0) + 1;
462                    $this->vars['cat_ids'][$rs->term_id] = $cur->cat_id;
463                    $cur->insert();
464               }
465               
466               $db->close();
467          }
468          catch (Exception $e)
469          {
470               $db->close();
471               throw $e;
472          }
473     }
474     
475     # Blogroll import
476     protected function importLinks()
477     {
478          $db = $this->db();
479          $prefix = $this->vars['db_prefix'];
480          $rs = $db->select('SELECT * FROM '.$prefix.'links ORDER BY link_id ASC');
481         
482          try
483          {
484               $this->con->execute(
485                    'DELETE FROM '.$this->prefix.'link '.
486                    "WHERE blog_id = '".$this->con->escape($this->blog_id)."' "
487               );
488               
489               while ($rs->fetch())
490               {
491                    $cur = $this->con->openCursor($this->prefix.'link');
492                    $cur->blog_id       = $this->blog_id;
493                    $cur->link_href     = $this->cleanStr($rs->link_url);
494                    $cur->link_title    = $this->cleanStr($rs->link_name);
495                    $cur->link_desc     = $this->cleanStr($rs->link_description);
496                    $cur->link_xfn      = $this->cleanStr($rs->link_rel);
497                   
498                    $cur->link_id = $this->con->select(
499                         'SELECT MAX(link_id) FROM '.$this->prefix.'link'
500                         )->f(0) + 1;
501                    $cur->insert();
502               }
503               
504               $db->close();
505          }
506          catch (Exception $e)
507          {
508               $db->close();
509               throw $e;
510          }
511     }
512     
513     # Entries import
514     protected function importPosts(&$percent)
515     {
516          $db = $this->db();
517          $prefix = $this->vars['db_prefix'];
518         
519          $plink = $db->select(
520                    'SELECT option_value FROM '.$prefix.'options '.
521                    "WHERE option_name = 'permalink_structure'"
522               )->option_value;
523          if ($plink) {
524               $this->vars['permalink_template'] = substr($plink,1);
525          }
526         
527          $rs = $db->select(
528               'SELECT * FROM '.$prefix.'posts '.
529               'WHERE post_type = \'post\' OR post_type = \'page\' '.
530               'ORDER BY ID ASC '.
531               $db->limit($this->post_offset,$this->post_limit)
532          );
533         
534          try
535          {
536               if ($this->post_offset == 0)
537               {
538                    $this->con->execute(
539                         'DELETE FROM '.$this->prefix.'post '.
540                         "WHERE blog_id = '".$this->con->escape($this->blog_id)."' "
541                    );
542               }   
543               
544               while ($rs->fetch()) {
545                    $this->importPost($rs,$db);
546               }
547               
548               $db->close();
549          }
550          catch (Exception $e)
551          {
552               $db->close();
553               throw $e;
554          }
555         
556          if ($rs->count() < $this->post_limit) {
557               return -1;
558          } else {
559               $this->post_offset += $this->post_limit;
560          }
561         
562          if ($this->post_offset > $this->post_count) {
563               $percent = 100;
564          } else {
565               $percent = $this->post_offset * 100 / $this->post_count;
566          }
567     }
568     
569     protected function importPost($rs,$db)
570     {
571          $post_date = !@strtotime($rs->post_date) ? '1970-01-01 00:00' : $rs->post_date;
572          if (!isset($this->vars['user_ids'][$rs->post_author])) {
573               $user_id = $this->core->auth->userID();
574          } else {
575               $user_id = $this->vars['user_ids'][$rs->post_author];
576          }
577         
578          $cur = $this->con->openCursor($this->prefix.'post');
579          $cur->blog_id     = $this->blog_id;
580          $cur->user_id     = $user_id;
581          $cur->post_dt     = $post_date;
582          $cur->post_creadt = $post_date;
583          $cur->post_upddt  = $rs->post_modified;
584          $cur->post_title  = $this->cleanStr($rs->post_title);
585         
586          if (!$cur->post_title) {
587               $cur->post_title = 'No title';
588          }
589         
590          if ($this->vars['cat_import'] || $this->vars['cat_as_tags'])
591          {
592               $old_cat_ids = $db->select(
593                    'SELECT * FROM '.$this->vars['db_prefix'].'terms AS t, '.
594                    $this->vars['db_prefix'].'term_taxonomy AS x, '.
595                    $this->vars['db_prefix'].'term_relationships AS r '.
596                    'WHERE t.term_id = x.term_id '.
597                    ($this->vars['ignore_first_cat'] ? 'AND t.term_id <> 1 ' : '').
598                    'AND x.taxonomy = \'category\' '.
599                    'AND t.term_id = r.term_taxonomy_id '.
600                    'AND r.object_id ='.$rs->ID.
601                    ' ORDER BY t.term_id ASC '
602                    );
603               if (!$old_cat_ids->isEmpty() && $this->vars['cat_import']) 
604               {
605                    $cur->cat_id = $this->vars['cat_ids'][(integer) $old_cat_ids->term_id];
606               }
607          }
608         
609          $permalink_infos = array(
610               date('Y',strtotime($cur->post_dt)), 
611               date('m',strtotime($cur->post_dt)), 
612               date('d',strtotime($cur->post_dt)), 
613               date('H',strtotime($cur->post_dt)), 
614               date('i',strtotime($cur->post_dt)), 
615               date('s',strtotime($cur->post_dt)), 
616               $rs->post_name, 
617               $rs->ID, 
618               $cur->cat_id, 
619               $cur->user_id
620          );
621          $cur->post_url = str_replace(
622               $this->vars['permalink_tags'],
623               $permalink_infos,
624               $rs->post_type== 'post' ? $this->vars['permalink_template'] : '%postname%'
625          );
626          $cur->post_url = substr($cur->post_url,0,255);
627         
628          if (!$cur->post_url) {
629               $cur->post_url = $rs->ID;
630          }
631         
632          $cur->post_format = $this->vars['post_formater'];
633          $_post_content = explode('<!--more-->',$rs->post_content,2);
634          if (count($_post_content) == 1) {
635               $cur->post_excerpt = NULL;
636               $cur->post_content = $this->cleanStr(array_shift($_post_content));
637          } else {
638               $cur->post_excerpt = $this->cleanStr(array_shift($_post_content));
639               $cur->post_content = $this->cleanStr(array_shift($_post_content));
640          }
641         
642          $cur->post_content_xhtml = $this->core->callFormater($this->vars['post_formater'],$cur->post_content);
643          $cur->post_excerpt_xhtml = $this->core->callFormater($this->vars['post_formater'],$cur->post_excerpt);
644         
645          switch ($rs->post_status)
646          {
647               case 'publish':
648                    $cur->post_status = 1;
649                    break;
650               case 'draft':
651                    $cur->post_status = 0;
652                    break;
653               case 'pending':
654                    $cur->post_status = -2;
655                    break;
656               default:
657                    $cur->post_status = -2;
658          }
659          $cur->post_type         = $rs->post_type;
660          $cur->post_password     = $rs->post_password ? $rs->post_password : NULL;
661          $cur->post_open_comment = $rs->comment_status == 'open' ? 1 : 0;
662          $cur->post_open_tb      = $rs->ping_status == 'open' ? 1 : 0;
663         
664          $cur->post_words = implode(' ',text::splitWords(
665               $cur->post_title.' '.
666               $cur->post_excerpt_xhtml.' '.
667               $cur->post_content_xhtml
668          ));
669         
670          $cur->post_id = $this->con->select(
671               'SELECT MAX(post_id) FROM '.$this->prefix.'post'
672               )->f(0) + 1;
673         
674          $cur->post_url = $this->core->blog->getPostURL($cur->post_url,$cur->post_dt,$cur->post_title,$cur->post_id);
675         
676          $cur->insert();
677          $this->importComments($rs->ID,$cur->post_id,$db);
678          $this->importPings($rs->ID,$cur->post_id,$db);
679         
680          # Create tags
681          $this->importTags($rs->ID,$cur->post_id,$db);
682         
683          if (isset($old_cat_ids))
684          {
685               if (!$old_cat_ids->isEmpty() && $this->vars['cat_as_tags']) 
686               {
687                    $old_cat_ids->moveStart();
688                    while ($old_cat_ids->fetch()) {
689                         $this->core->meta->setPostMeta($cur->post_id,'tag',$this->cleanStr($this->vars['cat_tags_prefix'].$old_cat_ids->name));
690                    }
691               }
692          }
693     }
694     
695     # Comments import
696     protected function importComments($post_id,$new_post_id,$db)
697     {
698          $count_c = $count_t = 0;
699         
700          $rs = $db->select(
701               'SELECT * FROM '.$this->vars['db_prefix'].'comments '.
702               'WHERE comment_post_ID = '.(integer) $post_id.' '
703               );
704         
705          while ($rs->fetch())
706          {
707               $cur = $this->con->openCursor($this->prefix.'comment');
708               $cur->post_id           = (integer) $new_post_id;
709               $cur->comment_author    = $this->cleanStr($rs->comment_author);
710               $cur->comment_status    = (integer) $rs->comment_approved ;
711               $cur->comment_dt        = $rs->comment_date;
712               $cur->comment_email     = $this->cleanStr($rs->comment_author_email);
713               $cur->comment_content   = $this->core->callFormater($this->vars['comment_formater'],$this->cleanStr($rs->comment_content));
714               $cur->comment_ip        = $rs->comment_author_IP;
715               $cur->comment_trackback       = $rs->comment_type == 'trackback' ? 1 : 0;
716               $cur->comment_site = substr($this->cleanStr($rs->comment_author_url),0,255);
717               if ($cur->comment_site == '') $cur->comment_site = NULL;
718               
719               if ($rs->comment_approved == 'spam') {
720                    $cur->comment_status = -2;
721               }
722               
723               $cur->comment_words = implode(' ',text::splitWords($cur->comment_content));
724               
725               $cur->comment_id = $this->con->select(
726                    'SELECT MAX(comment_id) FROM '.$this->prefix.'comment'
727               )->f(0) + 1;
728               
729               $cur->insert();
730               
731               if ($cur->comment_trackback && $cur->comment_status == 1) {
732                    $count_t++;
733               } elseif ($cur->comment_status == 1) {
734                    $count_c++;
735               }
736          }
737         
738          if ($count_t > 0 || $count_c > 0)
739          {
740               $this->con->execute(
741                    'UPDATE '.$this->prefix.'post SET '.
742                    'nb_comment = '.$count_c.', '.
743                    'nb_trackback = '.$count_t.' '.
744                    'WHERE post_id = '.(integer) $new_post_id.' '
745               );
746          }
747     }
748     
749     # Pings import
750     protected function importPings($post_id,$new_post_id,$db)
751     {
752          $urls = array();
753          $pings = array();
754         
755          $rs = $db->select(
756               'SELECT pinged FROM '.$this->vars['db_prefix'].'posts '.
757               'WHERE ID = '.(integer) $post_id
758               );
759          $pings = explode ("\n",$rs->pinged);
760          unset ($pings[0]);
761         
762          foreach($pings as $ping_url)
763          {
764               $url = $this->cleanStr($ping_url);
765               if (isset($urls[$url])) {
766                    continue;
767               }
768               
769               $cur = $this->con->openCursor($this->prefix.'ping');
770               $cur->post_id = (integer) $new_post_id;
771               $cur->ping_url = $url;
772               $cur->insert();
773               
774               $urls[$url] = true;
775          }
776     }
777     
778     # Meta import
779     protected function importTags($post_id,$new_post_id,$db)
780     {
781          $rs = $db->select(
782               'SELECT * FROM '.$this->vars['db_prefix'].'terms AS t, '.
783               $this->vars['db_prefix'].'term_taxonomy AS x, '.
784               $this->vars['db_prefix'].'term_relationships AS r '.
785               'WHERE t.term_id = x.term_id '.
786               'AND x.taxonomy = \'post_tag\' '.
787               'AND t.term_id = r.term_taxonomy_id '.
788               'AND r.object_id ='.$post_id.
789               ' ORDER BY t.term_id ASC'
790          );
791         
792          if ($rs->isEmpty()) {
793               return;
794          }
795         
796          while ($rs->fetch()) {
797               $this->core->meta->setPostMeta($new_post_id,'tag',$this->cleanStr($rs->name));
798          }
799     }
800}
801?>
Note: See TracBrowser for help on using the repository browser.

Sites map