cache_dir = EMLOG_ROOT.'/content/cache/';
$rssparser->cache_time = $lastRSS_cache_time;
$rssparser->items_limit = $lastRSS_item_num > 3 ? 3 : $lastRSS_item_num;
$rssparser->CDATA = 'content';
$rssparser->cp = 'UTF-8';
$rssparser->channeltags = array ('title');
$rssparser->itemtags = array ('title','link');
$rssparser->imagetags = array ();
$rssparser->textinputtags = array ();
$DB = MySql::getInstance();
function urlShort($url){
global $rssparser, $lastRSS_urlshort_domain;
$api = 'http://json.so/api/short.htm?d='.$lastRSS_urlshort_domain.'&u='.$url;
$results = $rssparser->getRemoteFile($api);
if (empty($results)) {
return $url;
} else {
$results = json_decode($results, true);
if(isset($results['state']) && $results['state'] == 'success'){
return $results['msg'];
}
return $url;
}
}
function getRssFeeds(){
global $DB;
$sql = "SELECT * FROM ".DB_PREFIX."rssfeeds ORDER BY id ASC";
$result = $DB->query($sql);
return $result;
}
function isLogExists($rssid, $hash){
global $DB;
$sql = "SELECT id FROM ".DB_PREFIX."rsslogs WHERE rssid = $rssid AND hash = '$hash'";
$result = $DB->query($sql);
$rows = $DB->num_rows($result);
return $rows;
}
function isFeedExists($url){
global $DB;
$sql = "SELECT id FROM ".DB_PREFIX."rssfeeds WHERE url = '$url'";
$result = $DB->query($sql);
$rows = $DB->num_rows($result);
return $rows;
}
function insertLog($rssid, $log ,$hash){
global $DB;
if (isLogExists($rssid, $hash) == 0) {
$DB->query("INSERT INTO ".DB_PREFIX."rsslogs (rssid, log, hash) VALUES($rssid, '$log', '$hash')");
}
}
function insertFeed($url, $title){
global $DB;
if (isFeedExists($url) == 0) {
$DB->query("INSERT INTO ".DB_PREFIX."rssfeeds (url, title) VALUES('$url', '$title')");
} elseif (!getTitle($url)) {
emMsg("RSS导入失败，RSS地址{$url}解析失败，请确定RSS地址及XML文件格式正确");
} else {
emMsg("RSS导入失败，数据库中已存在{$url}");
}
}
function deleteFeed($id){
global $DB;
$rssurl = $DB->fetch_array($DB->query("SELECT url FROM ".DB_PREFIX."rssfeeds WHERE id = $id"));
$rssurl = $rssurl['url'];
$cache_file = EMLOG_ROOT.'/content/cache/rsscache_'.md5($rssurl);
$DB->query("DELETE FROM ".DB_PREFIX."rssfeeds WHERE id = $id");
$DB->query("DELETE FROM ".DB_PREFIX."rsslogs WHERE rssid = $id");
unlink($cache_file);
}
function updateFeed($id, $url, $title){
global $DB;
$DB->query("UPDATE ".DB_PREFIX."rssfeeds SET url = '$url', title = '$title' WHERE id = $id");
}
function getTitle($rss_url){
global $rssparser;
$rss = $rssparser->Get($rss_url);
return $rss['title'];
}
function updateLogs(){
global $rssparser, $DB, $lastRSS_is_urlshort, $lastRSS_is_blank;
$feeds = getRssFeeds();
while ($item = $DB->fetch_array($feeds)) {
$rss = $rssparser->Get($item['url']);
if(!empty($rss['items'])) {
foreach ($rss['items'] as $key => $data) {
$rssid = $item['id'];
$hash = md5($data['title']);
$checklog = isLogExists($rssid, $hash);
if ($checklog == 0) {
if (trim($data['title']) != '') {
$link = $lastRSS_is_urlshort ? urlShort($data['link']) : $data['link'];
$target = $lastRSS_is_blank ? ' target="_blank"' : '';
$log = ''.strip_tags($data['title']).'';
insertLog($rssid, $log ,$hash);
}
}
}
}
}
}
function displayLog(){
global $DB, $lastRSS_item_num;
$sql = "SELECT ".DB_PREFIX."rsslogs.log,".DB_PREFIX."rssfeeds.title FROM ".DB_PREFIX."rsslogs INNER JOIN ".DB_PREFIX."rssfeeds ON ".DB_PREFIX."rsslogs.rssid = ".DB_PREFIX."rssfeeds.id ORDER BY ".DB_PREFIX."rsslogs.id DESC limit $lastRSS_item_num";
$result = $DB->query($sql);
$output = '';
while ($row = $DB->fetch_array($result)) {
$output .= ''.$row['log'].' 来自 《'.$row["title"].'》';
}
$output = empty($output) ? '暂无Rss文章 ^_^' : $output;
$output = '';
return $output;
}
function displayLogIndex(){
echo '';
}
function lastRSS_css(){
echo ''."\n";
}
function lastRSS_ajax(){
echo ''."\n";
echo ''."\n";
}
function lastRSS_adminUpdate(){
echo ''."\n";
}
function lastRSS_menu(){
echo '';
}
function lastRSS_backup(){
global $DB, $tables;
$is_exist_rssfeeds_query = $DB->query('show tables like "'.DB_PREFIX.'rssfeeds"');
$is_exist_rsslogs_query = $DB->query('show tables like "'.DB_PREFIX.'rsslogs"');
if($DB->num_rows($is_exist_rssfeeds_query) != 0) array_push($tables, 'rssfeeds');
if($DB->num_rows($is_exist_rsslogs_query) != 0) array_push($tables, 'rsslogs');
}
emLoadJQuery();
addAction('data_prebakup', 'lastRSS_backup');
addAction('index_head', 'lastRSS_css');
addAction('index_loglist_top', 'displayLogIndex');
addAction('index_footer', 'lastRSS_ajax');
addAction('adm_head', 'lastRSS_adminUpdate');
addAction('adm_sidebar_ext', 'lastRSS_menu');
?>