plugin_options = array();
add_action( 'init', array (&$this, 'init') ); // Hook on init
}
/**
* Initialize the plugin
*/
public function init() {
load_plugin_textdomain( 'fgj2wp', false, dirname( plugin_basename( __FILE__ ) ) . '/languages/' );
register_importer('fgj2wp', __('Joomla 1.5 (FG)', 'fgj2wp'), __('Import categories, articles and medias (images, attachments) from a Joomla 1.5 database into WordPress.', 'fgj2wp'), array ($this, 'dispatch'));
// Suspend the cache during the migration to avoid exhausted memory problem
wp_suspend_cache_addition(true);
wp_suspend_cache_invalidation(true);
}
/**
* Display admin notice
*/
protected function display_admin_notice( $message ) {
echo '['.__CLASS__.'] '.$message.'
['.__CLASS__.'] '.$message.'
";
die();
}
return $sections;
}
/**
* Get Joomla categories
*
* @return array of Categories
*/
private function get_categories() {
$categories = array();
try {
$db = new PDO('mysql:host=' . $this->plugin_options['hostname'] . ';port=' . $this->plugin_options['port'] . ';dbname=' . $this->plugin_options['database'], $this->plugin_options['username'], $this->plugin_options['password'], array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'UTF8\''));
$prefix = $this->plugin_options['prefix'];
$sql = "
SELECT c.title, CONCAT('c', c.id, '-', IFNULL(c.alias, c.name)) AS name, c.description, CONCAT('s', s.id, '-', IFNULL(s.alias, s.name)) AS parent
FROM ${prefix}categories c
INNER JOIN ${prefix}sections AS s ON s.id = c.section
";
$query = $db->query($sql);
if ( is_object($query) ) {
foreach ( $query as $row ) {
$categories[] = $row;
}
}
$db = null;
} catch ( PDOException $e ) {
print "Erreur !: " . $e->getMessage() . "
";
die();
}
return $categories;
}
/**
* Get Joomla posts
*
* @param int limit Number of posts max
* @return array of Posts
*/
protected function get_posts($limit=1000) {
$posts = array();
$last_id = (int)get_option('fgj2wp_last_id'); // to restore the import where it left
try {
$db = new PDO('mysql:host=' . $this->plugin_options['hostname'] . ';port=' . $this->plugin_options['port'] . ';dbname=' . $this->plugin_options['database'], $this->plugin_options['username'], $this->plugin_options['password'], array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'UTF8\''));
$prefix = $this->plugin_options['prefix'];
$sql = "
SELECT p.id, p.title, p.alias, p.introtext, p.fulltext, p.state, CONCAT('c', c.id, '-', IFNULL(c.alias, c.name)) AS category, p.modified, IF(p.publish_up, p.publish_up, p.created) AS date, p.metakey, p.metadesc
FROM ${prefix}content p
LEFT JOIN ${prefix}categories AS c ON p.catid = c.id
WHERE p.state >= 0 -- don't get the trash
AND p.id > '$last_id'
ORDER BY p.id
LIMIT $limit
";
$query = $db->query($sql);
if ( is_object($query) ) {
foreach ( $query as $row ) {
$posts[] = $row;
}
}
$db = null;
} catch ( PDOException $e ) {
print "Erreur !: " . $e->getMessage() . "
";
die();
}
return $posts;
}
/**
* Return an array with all the categories sorted by name
*
* @return array categoryname => id
*/
private function tab_categories() {
$tab_categories = array();
$categories = get_categories(array('hide_empty' => '0'));
if ( is_array($categories) ) {
foreach ( $categories as $category ) {
$tab_categories[$category->slug] = $category->term_id;
}
}
return $tab_categories;
}
/**
* Import post medias
*
* @param string $content post content
* @param date $post_date Post date (for storing media)
* @return array:
* array media: Medias imported
* int media_count: Medias count
*/
private function import_media($content, $post_date) {
$media = array();
$media_count = 0;
if ( preg_match_all('#<(img|a)(.*?)(src|href)="(.*?)"(.*?)>#', $content, $matches, PREG_SET_ORDER) > 0 ) {
if ( is_array($matches) ) {
foreach ($matches as $match ) {
$filename = $match[4];
$filename = str_replace("%20", " ", $filename); // for filenames with spaces
$other_attributes = $match[2] . $match[5];
$filetype = wp_check_filetype($filename);
if ( empty($filetype['type']) || ($filetype['type'] == 'text/html') ) { // Unrecognized file type
continue;
}
// Upload the file from the Joomla web site to WordPress upload dir
if ( preg_match('/^http/', $filename) ) {
if ( preg_match('#^' . $this->plugin_options['url'] . '#', $filename) ) {
// Local file
$old_filename = $filename;
} else {
// Don't import external file
continue;
}
} else {
$old_filename = untrailingslashit($this->plugin_options['url']) . '/' . $filename;
}
$old_filename = str_replace(" ", "%20", $old_filename); // for filenames with spaces
$date = strftime('%Y/%m', strtotime($post_date));
$uploads = wp_upload_dir($date);
$new_upload_dir = $uploads['path'];
$new_filename = $new_upload_dir . '/' . basename($filename);
// print "Copy \"$old_filename\" => $new_filename
";
if ( !@copy($old_filename, $new_filename) ) {
$error = error_get_last();
$error_message = $error['message'];
$this->display_admin_error("Can't copy $old_filename to $new_filename : $error_message");
continue;
}
$post_name = preg_replace('/\.[^.]+$/', '', basename($filename));
// If the attachment does not exist yet, insert it in the database
$attachment = $this->get_attachment_from_name($post_name);
if ( !$attachment ) {
$attachment_data = array(
'post_mime_type' => $filetype['type'],
'post_name' => $post_name,
'post_title' => $post_name,
'post_status' => 'inherit'
);
$attach_id = wp_insert_attachment($attachment_data, $new_filename);
$attachment = get_post($attach_id);
$post_name = $attachment->post_name; // Get the real post name
$media_count++;
}
$attach_id = $attachment->ID;
$media[$filename] = $post_name;
if ( preg_match('/image/', $filetype['type']) ) { // Images
// you must first include the image.php file
// for the function wp_generate_attachment_metadata() to work
require_once(ABSPATH . 'wp-admin/includes/image.php');
$attach_data = wp_generate_attachment_metadata( $attach_id, $new_filename );
wp_update_attachment_metadata( $attach_id, $attach_data );
// Image Alt
if (preg_match('#alt="(.+?)"#', $other_attributes, $alt_matches) ) {
$image_alt = wp_strip_all_tags(stripslashes($alt_matches[1]), true);
update_post_meta($attach_id, '_wp_attachment_image_alt', addslashes($image_alt)); // update_meta expects slashed
}
}
}
}
}
return array(
'media' => $media,
'media_count' => $media_count
);
}
/**
* Check if the attachment exists in the database
*
* @param string $name
* @return object Post
*/
private function get_attachment_from_name($name) {
$name = preg_replace('/\.[^.]+$/', '', basename($name));
$r = array(
'name' => $name,
'post_type' => 'attachment',
'numberposts' => 1,
);
$posts_array = get_posts($r);
if ( is_array($posts_array) && (count($posts_array) > 0) ) {
return $posts_array[0];
}
else {
return false;
}
}
/**
* Process the post content
*
* @param string $content Post content
* @param array $post_media Post medias
* @return string Processed post content
*/
private function process_content($content, $post_media) {
if ( !empty($content) ) {
// Replace media URLs with the new URLs
$content = $this->process_content_media_links($content, $post_media);
}
return $content;
}
/**
* Replace media URLs with the new URLs
*
* @param string $content Post content
* @param array $post_media Post medias
* @return string Processed post content
*/
private function process_content_media_links($content, $post_media) {
if ( is_array($post_media) ) {
foreach ( $post_media as $old_filename => $post_media_name ) {
$attachment = $this->get_attachment_from_name($post_media_name);
if ( $attachment ) {
if ( preg_match('/image/', $attachment->post_mime_type) ) {
// Image
$image_src = wp_get_attachment_image_src($attachment->ID, 'full');
$url = $image_src[0];
} else {
// Other media
$url = wp_get_attachment_url($attachment->ID);
}
$url = str_replace(" ", "%20", $url); // for filenames with spaces
$content = str_replace($old_filename, $url, $content);
$old_filename = str_replace(" ", "%20", $old_filename); // for filenames with spaces
$content = str_replace($old_filename, $url, $content);
}
}
}
return $content;
}
/**
* Add a link between a media and a post (parent id + thumbnail)
*
* @param int $post_id Post ID
* @param array $post_data Post data
* @param array $post_media Post medias
*/
private function add_post_media($post_id, $post_data, $post_media) {
$thumbnail_is_set = false;
if ( is_array($post_media) ) {
foreach ( $post_media as $old_filename => $post_media_name ) {
$attachment = $this->get_attachment_from_name($post_media_name);
$attachment->post_parent = $post_id; // Attach the post to the media
$attachment->post_date = $post_data['post_date'] ;// Define the media's date
wp_update_post($attachment);
// Set the thumbnail to be the first image
if ( !$thumbnail_is_set ) {
set_post_thumbnail($post_id, $attachment->ID);
$thumbnail_is_set = true;
}
}
}
}
/**
* Modify the internal links of all posts
*
* @return array:
* int links_count: Links count
*/
private function modify_links() {
$links_count = 0;
$step = 1000; // to limit the results
$offset = 0;
do {
$args = array(
'numberposts' => $step,
'offset' => $offset,
'orderby' => 'ID',
'order' => 'ASC',
'post_type' => 'post',
);
$posts = get_posts($args);
foreach ( $posts as $post ) {
$content = $post->post_content;
if ( preg_match_all('##', $content, $matches, PREG_SET_ORDER) > 0 ) {
if ( is_array($matches) ) {
foreach ($matches as $match ) {
$link = $match[2];
// Is it an internal link ?
if ( $this->is_internal_link($link) ) {
$old_id = $this->get_joomla_id_in_link($link);
// Can we find an ID in the link ?
if ( $old_id != 0 ) {
// Get the linked post
$linked_posts = get_posts(array(
'numberposts' => 1,
'post_type' => 'post',
'meta_key' => '_fgj2wp_old_id',
'meta_value' => $old_id,
));
if ( count($linked_posts) > 0 ) {
$new_link = get_permalink($linked_posts[0]->ID);
$content = str_replace("href=\"$link\"", "href=\"$new_link\"", $content);
// Update the post
wp_update_post(array(
'ID' => $post->ID,
'post_content' => $content,
));
$links_count++;
}
unset($linked_posts);
}
}
}
}
}
}
$offset += $step;
} while ( ($posts != null) && (count($posts) > 0) );
return array('links_count' => $links_count);
}
/**
* Test if the link is an internal link or not
*
* @param string $link
* @return bool
*/
private function is_internal_link($link) {
$result = (preg_match("#^".$this->plugin_options['url']."#", $link) > 0) ||
(preg_match("#^http#", $link) == 0);
return $result;
}
/**
* Get the Joomla ID in a link
*
* @param string $link
* @return int
*/
private function get_joomla_id_in_link($link) {
$old_id = 0;
// Without URL rewriting
if ( preg_match("#id=(\d+)#", $link, $matches) ) {
$old_id = $matches[1];
}
// With URL rewriting
elseif ( preg_match("#(.*)/(\d+)-(.*)#", $link, $matches) ) {
$old_id = $matches[2];
}
return $old_id;
}
}
}
?>