View file upload/src/addons/XenCentral/Feedback/Repository/ImportSource/ImportMybb.php

<?php
/**
 * @package XenCentral Feedback System
 * @author DNF Technology
 * @copyright Drnoyan & Nalyan LDA, Portugal, EU
 * @license http://dnf.technology/terms/
 * @link http://customers.dnf.technology
 * @version 2.0.0 Beta 10
 * @revision 12
 */

namespace XenCentral\Feedback\Repository\ImportSource;


class ImportMybb extends ImportAbstract
{
    /**
     * @var Array
     * Handles user ID cache for imported users
     */
    protected $_dataCache;

    public function getImporterTitle()
    {
        return 'MyBB Reputations';
    }

    /**
     * @param $db Zend_Db_Adapter_Abstract
     * @param $prefix String
     * Throws exception if table prefix is not valid for the system
     */
    public function assertTablePrefix($db, $prefix)
    {
        $db->query('
                SELECT rid
                FROM ' . $prefix . 'reputation
                LIMIT 1
        ');
    }

    /**
     * @param $db Zend_Db_Adapter_Abstract
     * @param $config
     * @param $errors
     */
    public function preImport($db, &$config, &$errors)
    {
        if (empty($config['charset'])) {
            $config['charset'] = 'utf8';
        }

        $this->_config=$config;
    }

    public function getAllFeedback($start, $perpage)
    {
        return $this->_sourceDb->fetchAll("
			SELECT rid AS originalId, reputation.* FROM
			{$this->_config['prefix']}reputation AS reputation
			ORDER BY rid ASC
			LIMIT $start, $perpage
		");
    }

    public function getForUserId($feedback)
    {
        return $this->_getFromCache('userid', $feedback['uid']);
    }

    public function getFromUserId($feedback)
    {
        return $this->_getFromCache('userid', $feedback['adduid']);
    }

    public function getAmount($feedback)
    {
        if($feedback['reputation']>0) {
            return 1;
        } else if($feedback['reputation'] < 0) {
            return -1;
        }

        return 0;
    }

    public function getType($feedback)
    {
        return 'trade';
    }

    public function getDealUrl($feedback)
    {
        return '';
    }

    public function getThreadId($feedback)
    {
        return 0;
    }

    public function getDateline($feedback)
    {
        return $feedback['dateline'];
    }

    public function getOriginalId($feedback)
    {
        return $feedback['originalId'];
    }

    public function getFeedbackText($feedback)
    {
        return $feedback['comments'];
    }

    public function getIPAddress($feedback)
    {
        return '';
    }

    public function getAllComments($originalId)
    {
        return array();
    }

    protected function _getRateIdFromOriginalId($originalId)
    {
        return $originalId;
    }

    public function getCommentUserId($comment)
    {
        return 0;
    }

    public function getCommentText($comment)
    {
        return '';
    }


    protected function _getFromCache($type, $oldid)
    {
        if (isset($this->_dataCache[$type][$oldid])) {
            return $this->_dataCache[$type][$oldid];
        }

        switch ($type)
        {
            case 'userid':
                {
                $data = $this->db()->fetchOne("
						SELECT new_id FROM ".$this->_config['archive_table']."
						WHERE content_type='user'
						AND old_id=$oldid
					");
                }
                break;
        }

        $this->_dataCache[$type][$oldid] = $data;

        return $data;
    }

    public function getCommentDateline($comment)
    {
        return 0;
    }
}