Replace `->prepareStatement()` in importer

[GitHub/WoltLab/com.woltlab.wcf.conversation.git] / files / lib / system / importer / ConversationUserImporter.class.php

<?php

namespace wcf\system\importer;

use wcf\system\WCF;

/**
 * Imports conversation users.
 *
 * @author  Marcel Werk
 * @copyright   2001-2019 WoltLab GmbH
 * @license GNU Lesser General Public License <http://opensource.org/licenses/lgpl-license.php>
 */
class ConversationUserImporter extends AbstractImporter
{
    /**
     * @inheritDoc
     */
    public function import($oldID, array $data, array $additionalData = [])
    {
        $data['conversationID'] = ImportHandler::getInstance()
            ->getNewID('com.woltlab.wcf.conversation', $data['conversationID']);
        if (!$data['conversationID']) {
            return 0;
        }
        $data['participantID'] = ImportHandler::getInstance()->getNewID('com.woltlab.wcf.user', $data['participantID']);

        $sql = "INSERT INTO             wcf1_conversation_to_user
                                        (conversationID, participantID, username, hideConversation, isInvisible, lastVisitTime)
                VALUES                  (?, ?, ?, ?, ?, ?)
                ON DUPLICATE KEY UPDATE hideConversation = IF(hideConversation > 0 AND hideConversation = VALUES(hideConversation),hideConversation,0),
                                        isInvisible = IF(isInvisible AND VALUES(isInvisible),1,0),
                                        lastVisitTime = GREATEST(lastVisitTime,VALUES(lastVisitTime))";
        $statement = WCF::getDB()->prepare($sql);
        $statement->execute([
            $data['conversationID'],
            $data['participantID'],
            $data['username'],
            $data['hideConversation'],
            $data['isInvisible'],
            $data['lastVisitTime'],
        ]);

        // save labels
        if ($data['participantID'] && !empty($additionalData['labelIDs'])) {
            $sql = "INSERT IGNORE INTO  wcf1_conversation_label_to_object
                                        (labelID, conversationID)
                    VALUES              (?, ?)";
            $statement = WCF::getDB()->prepare($sql);
            foreach ($additionalData['labelIDs'] as $labelID) {
                $labelID = ImportHandler::getInstance()->getNewID('com.woltlab.wcf.conversation.label', $labelID);
                if ($labelID) {
                    $statement->execute([$labelID, $data['conversationID']]);
                }
            }
        }

        return 1;
    }
}