class.dc.import.wp.php @ 270:48858be15bda

Visit:

Revision 270:48858be15bda, 23.1 KB checked in by Franck <carnet.franck.paul@…>, 14 years ago (diff)
Changement d'année

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

Note: See TracBrowser for help on using the repository browser.

Dotclear

Context Navigation

source: plugins/importExport/inc/class.dc.import.wp.php @ 270:48858be15bda

Download in other formats:

Sites map