root/taggingreloaded/optionals/de.easy-coding.wbb.taggingreloaded/files/lib/acp/action/UpdateTaggingReloaded.class.php @ 68

<?php
require_once(WBB_DIR.'lib/acp/action/UpdateCounterAction.class.php');

// tagging imports
require_once(WCF_DIR.'lib/util/TaggingReloadedUtil.class.php');

/**
 * Updates the board tags.
 * 
 * @author      Torben Brodt
 * @package     de.easy-coding.wbb.taggingreloaded
 * @license     GNU General Public License <http://opensource.org/licenses/gpl-license.php>
 */
class UpdateTaggingReloadedAction extends UpdateCounterAction {
        public $action = 'UpdateTaggingReloaded';
        public $everything = true;
        
        protected function buildQuery() {
                if($this->everything) {
                        $sql = "SELECT          postID,
                                                threadID, 
                                                message
                                FROM            wbb".WBB_N."_post
                                ORDER BY        threadID ASC,
                                                postID DESC
                                LIMIT           ".$this->limit."
                                OFFSET          ".($this->limit * $this->loop);
                } else {
                        $sql = "SELECT          p2.postID,
                                                p2.threadID, 
                                                p2.message
                                FROM            wbb".WBB_N."_post p
                                JOIN            wbb".WBB_N."_thread t
                                ON              p.threadID = p.threadID
                                JOIN            wbb".WBB_N."_post p2
                                ON              t.threadID = p2.threadID
                                WHERE           p.systemTagged = 0
                                ORDER BY        p2.threadID ASC,
                                                p2.postID DESC";
                }
                
                return $sql;
        }
        
        /**
         * @see Action::execute()
         */
        public function execute() {
                parent::execute();
                $threadIDs = array();
                $systemTaggerUserID = -1;
                
                // get all posts
                $sql = $this->buildQuery();
                $result = WCF::getDB()->sendQuery($sql);
                while ($row = WCF::getDB()->fetchArray($result)) {
                        // group by thread to get relevant keywords
                        if(!isset($threadID) || $threadID == $row['threadID']) {
                                $threadID = $row['threadID'];
                                $threadIDs[] = $threadID;

                                $msg = TaggingReloadedUtil::bbcode2text($row['message']);
                                $text .= $msg;
                        } else {
                                // but store them in the first posting
                                $tags = TaggingReloadedUtil::text2tags($text);
                                $first_post = $row['postID'];
                                
                                // CLEANUP system tags
                                $sql = "DELETE FROM     wbb".WBB_N."_taggingreloaded, 
                                                        wcf".WCF_N."_taggingreloaded
                                        USING           wbb".WBB_N."_taggingreloaded wbb
                                        NATURAL JOIN    wcf".WCF_N."_taggingreloaded wcf
                                        JOIN            wbb".WBB_N."_post p
                                        ON              wbb.postID = p.postID
                                        WHERE           userID = {$systemTaggerUserID}
                                        AND             p.threadID = {$threadID};";

                                WBBCore::getDB()->sendQuery($sql);

                                if(count($tags) > 0) {
                                        $sql = "SELECT          taggingID
                                                FROM            wbb".WBB_N."_taggingreloaded
                                                WHERE           postID = {$first_post};";
                                        $row = WCF::getDB()->getFirstRow($sql);
                                        
                                        // is there an tagging entry?
                                        if(isset($row['taggingID'])) {
                                                $taggingID = $row['taggingID'];
                                        } else {
                                                // INSERT tagging<->post
                                                $sql = "INSERT INTO     wbb".WBB_N."_taggingreloaded
                                                                        (postID) 
                                                        VALUES          ({$first_post});";

                                                WBBCore::getDB()->sendQuery($sql);
                                                $taggingID = WBBCore::getDB()->getInsertID();
                                        }

                                        // save tags
                                        TaggingReloadedUtil::tags2db($taggingID, $tags, $systemTaggerUserID);
                                }
                                $text = '';
                        }
                }

                $sql = "UPDATE          wbb1_1_post 
                        SET     
                                        systemTagged = 1 
                        WHERE           threadID IN (".implode(',', $threadIDs)."); ";
                WBBCore::getDB()->sendQuery($sql);

                $this->executed();
                
                if($this->everything) {
                        $this->calcProgress(($this->limit * $this->loop), $count);
                        $this->nextLoop();
                }
        }
}
?>