Skip to content

Instantly share code, notes, and snippets.

@jkjoy

jkjoy/xiuno2flarum.php

Created April 16, 2024 06:41
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save jkjoy/505d7e4a47a7aae691fbf00d08fc9ddc to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save jkjoy/505d7e4a47a7aae691fbf00d08fc9ddc to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. Skiy Chan revised this gist Sep 16, 2021. 1 changed file with 6 additions and 4 deletions.
    10 changes: 6 additions & 4 deletions xiuno2flarum.php
    View file
    Original file line number Diff line number Diff line change
    @@ -9,7 +9,7 @@
    * 2. 复制 xiunobbs 下的 conf/conf.php 到本目录，或者自己修改以下的引入路径
    * 3. 复制 flarum 下的 config.php 到本目录，或者自己修改以下的引入路径
    * 4. 执行 composer require s9e/text-formatter 安装转换的扩展
    * 5. 再执行 php index.php 命令行进行转换即可
    * 5. 再执行 php xiuno2flarum.php 命令行进行转换即可
    *
    * 注意：由于 Flarum 程序与 Markdown 兼容问题，本程序转换的数据支持不完美。
    *
    @@ -24,9 +24,10 @@
    define('XIUNO_PATH', '');
    define('FLARUM_PATH', '');

    $xn_cfg = include 'conf.php';
    $xb_cfg = include 'conf.php';
    $fl_cfg = include 'config.php';

    $xn_cfg = $xb_cfg['db']['mysql']['master'];
    $dsn_xn = sprintf('mysql:dbname=%s;host=%s;charset=%s', $xn_cfg['name'], $xn_cfg['host'], $xn_cfg['charset']);
    $dbh_xn = new PDO($dsn_xn, $xn_cfg['user'], $xn_cfg['password']);

    @@ -96,7 +97,7 @@ function insert_discussions()
    while($row = $sth->fetch(PDO::FETCH_ASSOC))
    {
    // print_r($row);
    $stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'discussions` (id,title,participant_count,created_at,user_id,first_post_id,last_posted_at,last_posted_user_id,last_post_id,slug) VALUES (?,?,1,FROM_UNIXTIME(?),?,?,FROM_UNIXTIME(?),?,?,"")');
    $stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'discussions` (id,title,participant_count,created_at,user_id,first_post_id,last_posted_at,last_posted_user_id,last_post_id,slug,is_sticky) VALUES (?,?,1,FROM_UNIXTIME(?),?,?,FROM_UNIXTIME(?),?,?,"",?)');

    try {
    $data = [
    @@ -108,6 +109,7 @@ function insert_discussions()
    $row['last_date'],
    $row['lastuid'],
    $row['lastpid'],
    $row['top'] > 0 ? 1 : 0,
    ];

    $dbh_fl->beginTransaction();
    @@ -242,7 +244,7 @@ function fix_discussion_count()
    $data = [
    $row['counts'],
    $row['counts'],
    $row['counts'],
    1,
    $row['discussion_id'],
    ];

  2. Skiy Chan renamed this gist Sep 16, 2021. 1 changed file with 0 additions and 0 deletions.
    0 php → xiuno2flarum.php
    View file
    File renamed without changes.
  3. Skiy Chan renamed this gist Sep 16, 2021. 1 changed file with 0 additions and 0 deletions.
    0 X → php
    View file
    File renamed without changes.
  4. Skiy Chan created this gist Sep 16, 2021.
    310 changes: 310 additions & 0 deletions X
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,310 @@
    <?php

    /**
    * # XiunoBBS 转 Flarum
    * ## 使用说明
    * ### 注意：本程序只转移 主题、帖子和版块，不转会员
    *
    * 1. 将本文件上传到两个网站共同的服务器（只要支持两个站的数据库连接均可）
    * 2. 复制 xiunobbs 下的 conf/conf.php 到本目录，或者自己修改以下的引入路径
    * 3. 复制 flarum 下的 config.php 到本目录，或者自己修改以下的引入路径
    * 4. 执行 composer require s9e/text-formatter 安装转换的扩展
    * 5. 再执行 php index.php 命令行进行转换即可
    *
    * 注意：由于 Flarum 程序与 Markdown 兼容问题，本程序转换的数据支持不完美。
    *
    */

    // Get the autoloader
    include __DIR__ . '/vendor/autoload.php';

    // Use the Forum bundle. It supports BBCodes, emoticons and autolinking
    use s9e\TextFormatter\Bundles\Forum as TextFormatter;

    define('XIUNO_PATH', '');
    define('FLARUM_PATH', '');

    $xn_cfg = include 'conf.php';
    $fl_cfg = include 'config.php';

    $dsn_xn = sprintf('mysql:dbname=%s;host=%s;charset=%s', $xn_cfg['name'], $xn_cfg['host'], $xn_cfg['charset']);
    $dbh_xn = new PDO($dsn_xn, $xn_cfg['user'], $xn_cfg['password']);

    $fm_cfg = $fl_cfg['database'];
    $dsn_fl = sprintf('mysql:dbname=%s;host=%s;charset=%s', $fm_cfg['database'], $fm_cfg['host'], $fm_cfg['charset']);
    $dbh_fl = new PDO($dsn_fl, $fm_cfg['username'], $fm_cfg['password']);

    $dbh_fl->exec('set @@foreign_key_checks=OFF');

    function date_at(string $time): string
    {
    return date('Y-m-s h:i:s', $time);
    }

    function insert_tags()
    {
    global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl;

    $sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'forum`');
    $sth->execute();
    // $result = $sth->fetchAll(PDO::FETCH_ASSOC);

    $dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'tags`');
    // $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'tags`');

    while($row = $sth->fetch(PDO::FETCH_ASSOC))
    {
    //print_r($row);
    $stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'tags` (id,name,slug,description,position) VALUES (?,?,?,?,?)');

    try {
    $data = [
    $row['fid'],
    $row['name'],
    'tag_' . $row['fid'],
    $row['brief'],
    $row['fid'],
    ];

    $dbh_fl->beginTransaction();
    $stmt->execute($data);
    $dbh_fl->commit();
    // print $dbh_fl->lastInsertId();
    } catch(PDOExecption $e) {
    $dbh_fl->rollback();
    print "Error!: " . $e->getMessage() . "\n";
    exit;
    }
    }

    print 'Insert table ' . $fm_cfg['prefix'] . "tags\n";
    }

    function insert_discussions()
    {
    global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl;

    $sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'thread`');
    $sth->execute();
    // $result = $sth->fetchAll(PDO::FETCH_ASSOC);

    $dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'discussions`');
    // $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussions`');
    $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussion_tag`');
    $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'discussion_user`');

    while($row = $sth->fetch(PDO::FETCH_ASSOC))
    {
    // print_r($row);
    $stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'discussions` (id,title,participant_count,created_at,user_id,first_post_id,last_posted_at,last_posted_user_id,last_post_id,slug) VALUES (?,?,1,FROM_UNIXTIME(?),?,?,FROM_UNIXTIME(?),?,?,"")');

    try {
    $data = [
    $row['tid'],
    $row['subject'],
    $row['create_date'],
    $row['uid'],
    $row['firstpid'],
    $row['last_date'],
    $row['lastuid'],
    $row['lastpid'],
    ];

    $dbh_fl->beginTransaction();
    $stmt->execute($data);
    $dbh_fl->commit();
    // print $dbh_fl->lastInsertId();
    } catch(PDOExecption $e) {
    $dbh_fl->rollback();
    print "Error!: " . $e->getMessage() . "\n";
    exit;
    }

    $tag_sql = 'INSERT INTO `' . $fm_cfg['prefix'] . 'discussion_tag` (discussion_id,tag_id) VALUES (?,?)';
    $stmt = $dbh_fl->prepare($tag_sql);
    try {
    $data = [
    $row['tid'],
    $row['fid'],
    ];

    $dbh_fl->beginTransaction();
    $stmt->execute($data);
    $dbh_fl->commit();
    // print $dbh_fl->lastInsertId();
    } catch(PDOExecption $e) {
    $dbh_fl->rollback();
    print "Error!: " . $e->getMessage() . "\n";
    exit;
    }

    $tag_sql = 'INSERT INTO `' . $fm_cfg['prefix'] . 'discussion_user` (user_id,discussion_id,last_read_at,last_read_post_number) VALUES (?,?,FROM_UNIXTIME(?),1)';
    $stmt = $dbh_fl->prepare($tag_sql);
    try {
    $data = [
    $row['uid'],
    $row['tid'],
    $row['last_date'],
    ];

    $dbh_fl->beginTransaction();

    $stmt->execute($data);
    $dbh_fl->commit();
    // print $dbh_fl->lastInsertId();
    } catch(PDOExecption $e) {
    $dbh_fl->rollback();
    print "Error!: " . $e->getMessage() . "\n";
    exit;
    }
    }

    print 'Insert table ' . $fm_cfg['prefix'] . "discussions\n";
    }

    function insert_posts()
    {
    global $xn_cfg,$fm_cfg,$dbh_xn,$dbh_fl;

    $sth = $dbh_xn->prepare('SELECT * FROM `' . $xn_cfg['tablepre'] . 'post` ORDER BY `create_date` ASC');
    $sth->execute();
    // $result = $sth->fetchAll(PDO::FETCH_ASSOC);

    $dbh_fl->exec('DELETE FROM `' . $fm_cfg['prefix'] . 'posts`');
    // $dbh_fl->exec('TRUNCATE TABLE`' . $fm_cfg['prefix'] . 'posts`');

    $totals = [];
    while($row = $sth->fetch(PDO::FETCH_ASSOC))
    {
    // print_r($row);
    $stmt = $dbh_fl->prepare('INSERT INTO `' . $fm_cfg['prefix'] . 'posts` (id,discussion_id,number,created_at,user_id,type,content,ip_address) VALUES (?,?,?,FROM_UNIXTIME(?),?,"comment",?,?)');

    try {
    if (! isset($totals[$row['tid']])) {
    $totals[$row['tid']] = [];
    }
    $totals[$row['tid']][] = 1;

    // if ($row['isfirst'] === 1) {
    // $number_id = 1;
    // } else {
    // $totals[$row['tid']][] = 1;
    // }
    $number_id = count($totals[$row['tid']]);

    // XML representation, that's what you should store in your database
    $xml = TextFormatter::parse($row['message']);

    // HTML rendering, that's what you display to the user
    $html = TextFormatter::render($xml);

    $data = [
    $row['pid'],
    $row['tid'],
    $number_id,
    $row['create_date'],
    $row['uid'],
    // '<r>' . $row['message'] . '</r>',
    // '<t>' . $row['message_fmt'] . '</t>',
    '<t>' . $html . '</t>',
    // $html,
    long2ip($row['userip']),
    ];

    $dbh_fl->beginTransaction();
    $stmt->execute($data);
    $dbh_fl->commit();
    // print $dbh_fl->lastInsertId();
    } catch(PDOExecption $e) {
    $dbh_fl->rollback();
    print "Error!: " . $e->getMessage() . "\n";
    exit;
    }
    }

    print 'Insert table ' . $fm_cfg['prefix'] . "posts\n";
    }

    function fix_discussion_count()
    {
    global $fm_cfg,$dbh_fl;

    $sql = 'SELECT count(*) AS counts, `discussion_id` FROM `' . $fm_cfg['prefix'] . 'posts` GROUP BY `discussion_id`';
    $sth = $dbh_fl->prepare($sql);
    $sth->execute();

    while($row = $sth->fetch(PDO::FETCH_ASSOC))
    {
    // print_r($row);
    $stmt = $dbh_fl->prepare('UPDATE `' . $fm_cfg['prefix'] . 'discussions` SET `comment_count` = ?, post_number_index = ?, last_post_number = ? WHERE id = ?');

    try {
    $data = [
    $row['counts'],
    $row['counts'],
    $row['counts'],
    $row['discussion_id'],
    ];

    $dbh_fl->beginTransaction();
    $stmt->execute($data);
    $dbh_fl->commit();
    // print $dbh_fl->lastInsertId();
    } catch(PDOExecption $e) {
    $dbh_fl->rollback();
    print "Error!: " . $e->getMessage() . "\n";
    exit;
    }
    }

    print 'Update table ' . $fm_cfg['prefix'] . "discussions counts\n";
    }


    function fix_tag_stat()
    {
    global $fm_cfg,$dbh_fl;

    $sql = 'SELECT *, count(*) AS counts FROM `'. $fm_cfg['prefix'] . 'discussions` GROUP BY `slug` DESC;';
    $sth = $dbh_fl->prepare($sql);
    $sth->execute();

    while($row = $sth->fetch(PDO::FETCH_ASSOC))
    {
    // print_r($row);
    $stmt = $dbh_fl->prepare('UPDATE `' . $fm_cfg['prefix'] . 'tags` SET `discussion_count` = ?, last_posted_at = ? , last_posted_discussion_id = ?, last_posted_user_id = ? WHERE slug = ?');

    $last_uid = $row['last_posted_user_id'];
    if ($last_uid == 0)
    {
    $last_uid = $row['user_id'];
    }

    try {
    $data = [
    $row['counts'],
    $row['last_posted_at'],
    $row['id'],
    $last_uid,
    $row['slug'],
    ];

    $dbh_fl->beginTransaction();
    $stmt->execute($data);
    $dbh_fl->commit();
    // print $dbh_fl->lastInsertId();
    } catch(PDOExecption $e) {
    $dbh_fl->rollback();
    print "Error!: " . $e->getMessage() . "\n";
    exit;
    }
    }

    print 'Update table ' . $fm_cfg['prefix'] . "tags stat\n";
    }

    insert_tags();
    insert_discussions();
    insert_posts();
    fix_discussion_count();
    fix_tag_stat();