DiscuzX/upload/source/plugin/qqconnect/spacecp.inc.php

372 lines
14 KiB
PHP
Raw Normal View History

2016-12-15 08:20:54 -05:00
<?php
/**
* [Discuz! X] (C)2001-2099 Comsenz Inc.
* This is NOT a freeware, use is subject to license terms
*
* $Id: spacecp.inc.php 33645 2013-07-25 01:32:20Z nemohou $
*/
if(!defined('IN_DISCUZ')) {
exit('Access Denied');
}
if(!$_G['uid']) {
showmessage('not_loggedin', NULL, array(), array('login' => 1));
}
$pluginop = !empty($_GET['pluginop']) ? $_GET['pluginop'] : 'config';
if (!in_array($pluginop, array('config', 'share', 'new', 'sync_tthread'))) {
showmessage('undefined_action');
}
$sh_type = trim(intval($_GET['sh_type']));
$tid = trim(intval($_GET['thread_id']));
$connectService = Cloud::loadClass('Service_Connect');
if ($pluginop == 'config') {
$connectService->connectMergeMember();
$_G['connect']['is_oauth_user'] = true;
if (empty($_G['member']['conuinsecret'])) {
$_G['connect']['is_oauth_user'] = false;
}
$referer = str_replace($_G['siteurl'], '', dreferer());
if(!empty($_GET['connect_autoshare'])) {
if(strpos($referer, '?') !== false) {
$referer .= '&connect_autoshare=1';
} else {
$referer .= '?connect_autoshare=1';
}
}
$_G['connect']['loginbind_url'] = $_G['siteurl'].'connect.php?mod=login&op=init&type=loginbind&referer='.urlencode($_G['connect']['referer'] ? $_G['connect']['referer'] : 'index.php');
} elseif ($pluginop == 'share') {
$_GET['share_url'] = $_G['connect']['discuz_new_share_url'];
$post = C::t('forum_post')->fetch_threadpost_by_tid_invisible($tid, 0);
$thread = C::t('forum_thread')->fetch_by_tid_displayorder($tid, 0);
require_once libfile('function/post');
$post['message'] = messagesafeclear($post['message']);
$html_content = $connectService->connectParseBbcode($post['message'], $thread['fid'], $post['pid'], $post['htmlon'], $attach_images);
if ($_G['group']['allowgetimage'] && $thread['price'] == 0 && $post['pid']) {
if ($attach_images && is_array($attach_images)) {
$_GET['share_images'] = array_slice($attach_images, 0, 3);
$attach_images = array();
foreach ($_GET['share_images'] as $image) {
$attach_images[] = $image['big'];
}
$_GET['attach_image'] = implode('|', $attach_images);
unset($attach_images);
}
}
if($_GET['sh_type'] == 4){
if($_G['setting']['rewritestatus'] && in_array('forum_viewthread', $_G['setting']['rewritestatus'])) {
$url = rewriteoutput('forum_viewthread', 1, $_G['siteurl'], $tid);
} else {
$url = $_G['siteurl'].'forum.php?mod=viewthread&tid='.$tid;
}
$shareqq_params = array(
'url' => $url,
'title' => diconv($thread['subject'], CHARSET, 'UTF-8'),
'summary' => diconv(cutstr(strip_tags(str_replace('&nbsp;', ' ', $html_content)), 80), CHARSET, 'UTF-8'),
'desc' => diconv(lang('plugin/qqconnect', 'connect_spacecp_share_qq_default'), CHARSET, 'UTF-8'),
'site' => 'discuz|',
'style' => '103',
'width' => 50,
'height' => 16
);
$s = '';
foreach($shareqq_params as $key => $val) {
$s .= ($s ? '&' : '').$key.'='.urlencode($val);
}
header('Location: http://connect.qq.com/widget/shareqq/index.html?'.$s);
} else {
$share_message = lang('plugin/qqconnect', 'connect_spacecp_share_a_post', array('bbname' => cutstr($_G['setting']['bbname'], 20,''), 'subject' => cutstr($thread['subject'], 120), 'message' => cutstr(strip_tags(str_replace('&nbsp;', ' ', $html_content)), 80)));
$share_message = str_replace(array('\'', "\r\n", "\r", "\n"), array('"', '', '', ''), $share_message);
}
} elseif ($pluginop == 'new') {
if (trim($_GET['formhash']) != formhash()) {
showmessage('submit_invalid');
}
$sh_type = intval(trim($_POST['sh_type']));
$tid = intval(trim($_POST['thread_id']));
$dialog_id = $_POST['dialog_id'];
$connectService->connectMergeMember();
if($_G['setting']['rewritestatus'] && in_array('forum_viewthread', $_G['setting']['rewritestatus'])) {
$url = rewriteoutput('forum_viewthread', 1, $_G['siteurl'], $tid);
} else {
$url = $_G['siteurl'].'forum.php?mod=viewthread&tid='.$tid;
}
$connectOAuthClient = Cloud::loadClass('Service_Client_ConnectOAuth');
$connectService = Cloud::loadClass('Service_Connect');
if($sh_type == 3) {
$firstpost = C::t('forum_post')->fetch_threadpost_by_tid_invisible($tid, 0);
require_once libfile('function/post');
$firstpost['message'] = messagesafeclear($firstpost['message']);
$summary = $connectService->connectParseBbcode($firstpost['message'], $firstpost['fid'], $firstpost['pid'], $firstpost['htmlon'], $attach_images);
$qzone_params = array(
'title' => $_POST['share_subject'],
'url' => $url,
'comment' => $_POST['reason'],
'summary' => strip_tags($summary),
'images' => $_POST['attach_image'],
'nswb' => '1',
);
if(!$_G['setting']['connect']['oauth2'] || !$_G['member']['conuintoken']) {
try {
$response = $connectOAuthClient->connectAddShare($_G['member']['conopenid'], $_G['member']['conuin'], $_G['member']['conuinsecret'], $qzone_params);
} catch(Exception $e) {
$errorCode = $e->getCode();
}
} else {
try {
$response = $connectOAuthClient->connectAddShare_V2($_G['member']['conopenid'], $_G['member']['conuintoken'], $qzone_params);
} catch(Exception $e) {
$errorCode = $e->getCode();
}
}
if($errorCode) {
$code = $errorCode;
if($errorCode == 41001) {
$message = lang('plugin/qqconnect', 'connect_user_unauthorized', array('login_url' => $_G['connect']['login_url'].'&reauthorize=yes&formhash='.FORMHASH));
} elseif($errorCode == 41003 || $errorCode == 40006) { // access token失效或非法
$message = lang('plugin/qqconnect', 'connect_share_token_outofdate', array('login_url' => $_G['connect']['login_url']));
} elseif ($errorCode == 3021) {
$message = lang('plugin/qqconnect', 'connect_qzone_share_same_url');
} else {
$code = 100;
$message = lang('plugin/qqconnect', 'connect_server_busy');
$connectService->connectErrlog($code, lang('plugin/qqconnect', 'connect_errlog_server_no_response'));
}
} else {
$code = $response['ret'];
$message = lang('plugin/qqconnect', 'connect_share_success');
}
} elseif($sh_type == 2) {
$t_params = array(
'content' => $_POST['reason'],
);
$aid = intval($_POST['attach_image_id']);
if ($aid) {
$method = 'connectAddPicT';
$attach = C::t('forum_attachment_n')->fetch('aid:'.$aid, $aid);
if($attach['remote']) {
$t_params['pic'] = $_G['setting']['ftp']['attachurl'].'forum/'.$attach['attachment'];
$t_params['remote'] = true;
} else {
$t_params['pic'] = $_G['setting']['attachdir'].'forum/'.$attach['attachment'];
}
} else {
$method = 'connectAddT';
}
if(!$_G['setting']['connect']['oauth2'] || !$_G['member']['conuintoken']) {
try {
$response = $connectOAuthClient->$method($_G['member']['conopenid'], $_G['member']['conuin'], $_G['member']['conuinsecret'], $t_params);
} catch(Exception $e) {
$errorCode = $e->getCode();
}
} else {
try {
$method = $method.'_V2';
$response = $connectOAuthClient->$method($_G['member']['conopenid'], $_G['member']['conuintoken'], $t_params);
} catch(Exception $e) {
$errorCode = $e->getCode();
}
}
if($errorCode) {
$code = $errorCode;
if($errorCode == 41001) {
$message = lang('plugin/qqconnect', 'connect_user_unauthorized', array('login_url' => $_G['connect']['login_url'].'&reauthorize=yes&formhash='.FORMHASH));
} elseif($errorCode == 41003 || $errorCode == 40006) { // access token失效或非法
$message = lang('plugin/qqconnect', 'connect_share_token_outofdate', array('login_url' => $_G['connect']['login_url']));
} elseif ($errorCode == 3013) {
$message = lang('plugin/qqconnect', 'connect_qzone_weibo_same_content');
} else if($errorCode == 3020) {
$message = lang('plugin/qqconnect', 'connect_weibo_account_not_signup');
} else {
$code = 100;
$message = lang('plugin/qqconnect', 'connect_server_busy');
$connectService->connectErrlog($code, lang('plugin/qqconnect', 'connect_errlog_server_no_response'));
}
} else {
$thread = C::t('forum_thread')->fetch($tid);
if($response['data']['id'] && $_G['setting']['connect']['t']['reply'] && $thread['tid'] && !$thread['closed'] && !getstatus($thread['status'], 3) && empty($_G['forum']['replyperm'])) {
C::t('#qqconnect#connect_tthreadlog')->insert(array(
'twid' => $response['data']['id'],
'tid' => $tid,
'conopenid' => $_G['member']['conopenid'],
'pagetime' => 0,
'lasttwid' => '0',
'nexttime' => $_G['timestamp'] + 30 * 60,
'updatetime' => 0,
'dateline' => $_G['timestamp'],
));
}
if(!getstatus($thread['status'], 8)) {
C::t('forum_thread')->update($tid, array('status' => setstatus(8, 1, $thread['status'])));
}
$code = $response['ret'];
$message = lang('plugin/qqconnect', 'connect_broadcast_success');
}
}
} elseif($pluginop == 'sync_tthread') {
if (trim($_GET['formhash']) != formhash()) {
showmessage('submit_invalid');
}
if(!$_G['setting']['connect']['t']['reply']) {
exit;
}
$tid = $_GET['tid'];
$processname = 'connect_tthread_'.$tid.'_cache';
if(discuz_process::islocked($processname, 600)) {
exit;
}
$thread = C::t('forum_thread')->fetch($tid);
if(!$thread || $thread['closed'] == 1 || getstatus($thread['status'], 3) || $thread['displayorder'] < 0 || !empty($_G['forum']['replyperm'])) {
discuz_process::unlock($processname);
exit;
}
$updatetime = C::t('#qqconnect#connect_tthreadlog')->fetch_max_updatetime_by_tid($tid);
if($_G['timestamp'] < $updatetime + 10 * 60) {
discuz_process::unlock($processname);
exit;
}
$tthread = C::t('#qqconnect#connect_tthreadlog')->fetch_min_nexttime_by_tid($tid);
if(empty($tthread)) {
discuz_process::unlock($processname);
exit;
}
$connectOAuthClient = Cloud::loadClass('Service_Client_ConnectOAuth');
$connectmember = C::t('#qqconnect#common_member_connect')->fetch_fields_by_openid($tthread['conopenid']);
$param = array();
$param['format'] = 'xml';
$param['flag'] = '2';
$param['rootid'] = $tthread['twid'];
$param['pageflag'] = 2;
$param['pagetime'] = $tthread['pagetime'];
$param['reqnum'] = 20;
$param['twitterid'] = $tthread['lasttwid'];
try {
$response = $connectOAuthClient->connectGetRepostList($tthread['conopenid'], $connectmember['conuin'], $connectmember['conuinsecret'], $param);
} catch(Exception $e) {
showmessage('qqconnect:server_busy');
}
if($response && $response['ret'] == 0 && $response['data']['info']) {
include_once libfile('function/forum');
$forum = C::t('forum_forum')->fetch($thread['fid']);
$pinvisible = $forum['modnewposts'] ? -2 : 0;
$pids = array();
$i = 0;
$responseinfo = array();
if(!isset($response['data']['info'][0])) {
$responseinfo[] = $response['data']['info'];
} else {
$responseinfo = $response['data']['info'];
krsort($responseinfo);
}
foreach($responseinfo as $post) {
$message = trim($post['text']);
$post['username'] = trim($post['name']);
$post['nick'] = trim($post['nick']);
$message = preg_replace("/((https?|ftp|gopher|news|telnet|rtsp|mms|callto):\/\/|www\.)([a-z0-9\/\-_+=.~!%@?#%&;:$\\()|]+\s*)/i", '', $message);
$message = str_replace(explode(' ', lang('plugin/qqconnect', 'connect_reply_filter_smiley')), '', $message);
if($message) {
$newmessage = censor($message, null, true);
if($message != $newmessage) {
continue;
}
} else {
$message = lang('plugin/qqconnect', 'connect_tthread_broadcast');
}
if($_G['setting']['connect']['t']['reply_showauthor']) {
$message .= '[tthread='.$post['username'].', '.$post['nick'].']'.$post['head'].'[/tthread]';
}
$pid = insertpost(array(
'fid' => $thread['fid'],
'tid' => $thread['tid'],
'first' => '0',
'author' => '',
'authorid' => '0',
'subject' => '',
'dateline' => $_G['timestamp'] + $i,
'message' => $message,
'useip' => '',
'invisible' => $pinvisible,
'anonymous' => '0',
'usesig' => '0',
'htmlon' => '1',
'bbcodeoff' => '0',
'smileyoff' => '0',
'parseurloff' => '0',
'attachment' => '0',
'status' => 16,
));
if($pid) {
$pids[] = $pid;
}
$i++;
}
if($pinvisible) {
updatemoderate('pid', $pids);
C::t('forum_forum')->update_forum_counter($thread['fid'], 0, 0, count($pids), 1);
} else {
$fieldarr = array(
'lastposter' => array(''),
'replies' => count($pids),
);
if($thread['lastpost'] < $_G['timestamp']) {
$fieldarr['lastpost'] = array($_G['timestamp']);
}
C::t('forum_thread')->increase($tid, $fieldarr);
$postionid = C::t('forum_post')->fetch_maxposition_by_tid($thread['posttableid'], $tid);
C::t('forum_thread')->update($tid, array('maxposition' => $postionid));
$lastpost = "$thread[tid]\t$thread[subject]\t$_G[timestamp]\t".'';
C::t('forum_forum')->update($thread['fid'], array('lastpost' => $lastpost));
C::t('forum_forum')->update_forum_counter($thread['fid'], 0, count($pids), count($pids));
if($forum['type'] == 'sub') {
C::t('forum_forum')->update($forum['fup'], array('lastpost' => $lastpost));
}
}
$setarr['pagetime'] = $post['timestamp'];
$setarr['lasttwid'] = $post['id'];
if(count($responseinfo) < $param['reqnum']) {
$setarr['nexttime'] = $_G['timestamp'] + 2 * 3600;
} else {
$setarr['nexttime'] = $_G['timestamp'] + 30 * 60;
}
} else {
$setarr['nexttime'] = $_G['timestamp'] + 3 * 3600;
}
$setarr['updatetime'] = $_G['timestamp'];
C::t('#qqconnect#connect_tthreadlog')->update($tthread['twid'], $setarr);
discuz_process::unlock($processname);
exit;
}