root/twitter/files/lib/system/cronjob/TwitterUpdateJob.class.php @ 1335

<?php
require_once(WCF_DIR.'lib/data/cronjobs/Cronjob.class.php');
require_once(WCF_DIR.'lib/data/twitter/Twitter.class.php');

/**
 * query twitter retweets
 * 
 * @author      Torben Brodt
 * @package     de.easy-coding.wcf.twitter
 * @license     GNU General Public License <http://opensource.org/licenses/gpl-3.0.html>
 */
class TwitterUpdateJob implements Cronjob {

        /**
         * @see Cronjob::execute()
         */
        public function execute($data) {
                $sql = "SELECT          *
                        FROM            wcf".WCF_N."_twitter_feed ti
                        INNER JOIN      wcf".WCF_N."_twitter_account ta ON ti.accountID = ta.accountID
                        INNER JOIN      wcf".WCF_N."_user_to_twitter utt ON utt.accountID = ta.accountID
                        WHERE           ti.failcount < 5";
                $result = WCF::getDB()->sendQuery($sql);
                $i = 0;
                while ($row = WCF::getDB()->fetchArray($result)) {
                        $this->load($row);
                        $i++;
                }

                // try to active system user feeds
                if($i == 0) {
                        $user = $this->getSystemUser();
                        if($user) {
                                $sql = "INSERT INTO
                                                        wcf".WCF_N."_twitter_feed
                                                        (accountID, action)
                                        VALUES          (".intval($user['accountID']).", 'user_timeline'),
                                                        (".intval($user['accountID']).", 'mentions')
                                        ON DUPLICATE KEY UPDATE
                                                        failcount = IF(failcount > 1, failcount - 1, 0)";
                                $result = WCF::getDB()->sendQuery($sql);
                        }
                }
        }

        protected function getSystemUser() {
                $sql = "SELECT          *
                        FROM            wcf".WCF_N."_twitter_account ta
                        INNER JOIN      wcf".WCF_N."_user_to_twitter utt ON utt.accountID = ta.accountID
                        WHERE           ta.screen_name = '".escapeString(TWITTER_USER)."'";
                return WCF::getDB()->getFirstRow($sql);
        }

        public function updateAccount($user) {
                $sql = 'SELECT  *
                        FROM    wcf'.WCF_N.'_twitter_account
                        WHERE   accountID = '.intval($user->id);
                $row = WCF::getDB()->getFirstRow($sql);

                if($row) {
                        $update = array();
                        foreach($row as $key => $val) {
                                if($key == 'accountID') {
                                        continue;
                                }

                                if($user->$key != $val) {
                                        $update[] = $key.' = "'.escapeString($val).'"';
                                }
                        }

                        // update
                        if(count($update)) {
                                $sql = "UPDATE          wcf".WCF_N."_twitter_account
                                        SET             ".implode(",", $update)."
                                        WHERE           accountID = ".intval($user->id);
                                $result = WCF::getDB()->sendQuery($sql);
                        }
                } else {
                        // insert
                        $sql = "INSERT INTO     wcf".WCF_N."_twitter_account
                                                (accountID, name, screen_name, profile_image_url)
                                VALUES          (".intval($user->id).", '".escapeString($user->name)."', 
                                                '".escapeString($user->screen_name)."', '".escapeString($user->profile_image_url)."')";
                        $result = WCF::getDB()->sendQuery($sql);
                }
        }

        /**
         *
         */
        public function load($me) {
                $twitterObj = Twitter::getInstance();
                $twitterObj->setToken($me['userToken'], $me['userSecret']);

                $opts = array();

                if($me['since_id']) {
                        $opts['since_id'] = $me['since_id'];
                }

                try {
                        $list = $twitterObj->get('/statuses/'.$me['action'].'.json', $opts);
                } catch(Exception $e) {

                        // increase fail count and stop
                        $sql = 'UPDATE  wcf'.WCF_N.'_twitter_feed
                                SET     failcount = failcount + 1
                                WHERE   feedID = '.intval($me['feedID']);
                        WCF::getDB()->sendQuery($sql);

                        return;
                }

                $maxid = 0;
                foreach($list as $message) {
                        $maxid = max($maxid, $message->id);

                        $this->updateAccount($message->user);

                        // create message
                        $sql = 'INSERT INTO 
                                        wcf'.WCF_N.'_twitter_message
                                        (tweetID, accountID, username, message, time)
                                VALUES ('.intval($message->id).', '.intval($message->user->id).', 
                                        "'.escapeString($message->user->screen_name).'", "'.escapeString($message->text).'", 
                                        '.intval(strtotime($message->created_at)).')';

                        try  {
                                WCF::getDB()->sendQuery($sql);
                                $messageID = WCF::getDB()->getInsertID("wcf".WCF_N."_twitter_message", 'messageID');

                        } catch(Exception $e) {
                                $sql = 'SELECT  messageID
                                        FROM    wcf'.WCF_N.'_twitter_message
                                        WHERE   tweetID = '.intval($message->id);
                                $row = WCF::getDB()->getFirstRow($sql);
                                $messageID = $row['messageID'];
                        }

                        // create link to feed
                        $sql = 'INSERT IGNORE INTO 
                                        wcf'.WCF_N.'_twitter_message_to_feed
                                        (messageID, feedID)
                                VALUES ('.intval($messageID).', '.intval($me['feedID']).')';
                        WCF::getDB()->sendQuery($sql);
                }

                if($maxid) {

                        // update max id and decrease fail count
                        $sql = 'UPDATE  wcf'.WCF_N.'_twitter_feed
                                SET     since_id = '.intval($maxid + 1).',
                                        failcount = IF(failcount > 1, failcount - 1, 0)
                                WHERE   feedID = '.intval($me['feedID']);
                        WCF::getDB()->sendQuery($sql);
                }
        }
}
?>