当前仓库属于关闭状态,部分功能使用受限,详情请查阅 仓库状态说明
408 Star 1.6K Fork 646

微擎 / 开源版微擎系统
关闭

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
api.php 31.43 KB
一键复制 编辑 Web IDE 原始数据 按行查看 历史
brjun 提交于 2022-04-22 12:06 . 2.7.53版本
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989
<?php
/**
* 接口文件
*
* [WeEngine System] Copyright (c) 2013 W7.CC
* $sn: pro/api.php : v 24db125c5a0f : 2015/09/14 10:42:33 : RenChao $
*/
define('IN_API', true);
require_once './framework/bootstrap.inc.php';
load()->model('reply');
load()->model('attachment');
load()->model('visit');
load()->app('common');
load()->classs('wesession');
$hash = $_GPC['hash'];
if (!empty($hash)) {
$id = pdo_fetchcolumn("SELECT acid FROM " . tablename('account') . " WHERE hash = :hash", array(':hash' => $hash));
}
if (!empty($_GPC['appid'])) {
$appid = ltrim($_GPC['appid'], '/');
if ($appid == 'wx570bc396a51b8ff8') {
$_W['account'] = array(
'type' => '3',
'key' => 'wx570bc396a51b8ff8',
'level' => 4,
'token' => 'platformtestaccount'
);
} else {
$id = pdo_fetchcolumn("SELECT acid FROM " . tablename('account_wechats') . " WHERE `key` = :appid", array(':appid' => $appid));
if (empty($id)) {
$id = table('account_wxapp')->where('key', $appid)->getcolumn('acid');
}
}
}
if (empty($id)) {
$id = intval($_GPC['id']);
}
if (!empty($id)) {
$uniacid = pdo_getcolumn('account', array('acid' => $id), 'uniacid');
if (visit_app_pass_visit_limit($uniacid)) {
exit('success');
}
$_W['account'] = $_W['uniaccount'] = uni_fetch($uniacid);
}
if (empty($_W['account'])) {
exit('initial error hash or id');
}
if (empty($_W['account']['token'])) {
exit('initial missing token');
}
$_W['debug'] = intval($_GPC['debug']);
$_W['emulator'] = intval($_GPC['emulator']);
$_W['acid'] = $_W['account']['acid'];
$_W['uniacid'] = $_W['account']['uniacid'];
$_W['account']['groupid'] = $_W['uniaccount']['groupid'];
$_W['account']['qrcode'] = $_W['attachurl'] . 'qrcode_' . $_W['acid'] . '.jpg?time=' . $_W['timestamp'];
$_W['account']['avatar'] = $_W['attachurl'] . 'headimg_' . $_W['acid'] . '.jpg?time=' . $_W['timestamp'];
$_W['attachurl'] = attachment_set_attach_url();
register_shutdown_function('visit_update_today', 'app', 'we7_api');
$engine = new WeEngine();
if (!empty($_W['setting']['copyright']['status'])) {
$engine->died('抱歉,站点已关闭,关闭原因:' . $_W['setting']['copyright']['reason']);
}
if (!empty($_W['uniaccount']['endtime']) && TIMESTAMP > $_W['uniaccount']['endtime'] && !in_array($_W['uniaccount']['endtime'], array(USER_ENDTIME_GROUP_EMPTY_TYPE, USER_ENDTIME_GROUP_UNLIMIT_TYPE))) {
$engine->died('抱歉,您的公众号已过期,请及时联系管理员');
}
//flag==1对消息加密,并生成签名
if ($_W['isajax'] && $_W['ispost'] && $_GPC['flag'] == 1) {
$engine->encrypt();
}
//flag==2对消息解密,并验证签名,返回解密后xml
if ($_W['isajax'] && $_W['ispost'] && $_GPC['flag'] == 2) {
$engine->decrypt();
}
$_W['isajax'] = false;
$engine->start();
/**
* 公众号消息解析引擎
*/
class WeEngine {
/**
* 公众号操作对象
* @var WeAccount
*/
private $account = null;
/**
* 可用模块名称标识的集合
* @var array
*/
private $modules = array();
/**
* 关键字 - ??
* @var array
*/
public $keyword = array();
/**
* 粉丝消息
* @var array
*/
public $message = array();
/**
* WeEngine 构造方法
*/
public function __construct() {
global $_W;
$this->account = WeAccount::create($_W['account']);
if (strtolower($_SERVER['REQUEST_METHOD']) == 'post') {
$_W['modules'] = uni_modules();
$this->modules = array_keys($_W['modules']);
$this->modules[] = 'cover';
$this->modules[] = 'default';
$this->modules[] = 'reply';
$this->modules = array_unique($this->modules);
}
}
/**
* 对消息进行加密,并生成签名,返回签名
*/
public function encrypt() {
global $_W;
if (empty($this->account)) {
exit('Miss Account.');
}
$timestamp = TIMESTAMP;
$nonce = random(5);
$token = $_W['account']['token'];
$signkey = array($token, TIMESTAMP, $nonce);
sort($signkey, SORT_STRING);
$signString = implode($signkey);
$signString = sha1($signString);
$_GET['timestamp'] = $timestamp;
$_GET['nonce'] = $nonce;
$_GET['signature'] = $signString;
$postStr = file_get_contents('php://input');
if (!empty($_W['account']['encodingaeskey']) && strlen($_W['account']['encodingaeskey']) == 43 && !empty($_W['account']['key']) && !DEVELOPMENT) {
$data = $this->account->encryptMsg($postStr);
$array = array('encrypt_type' => 'aes', 'timestamp' => $timestamp, 'nonce' => $nonce, 'signature' => $signString, 'msg_signature' => $data[0], 'msg' => $data[1]);
} else {
$data = array('', '');
$array = array('encrypt_type' => '', 'timestamp' => $timestamp, 'nonce' => $nonce, 'signature' => $signString, 'msg_signature' => $data[0], 'msg' => $data[1]);
}
exit(json_encode($array));
}
/**
* 对消息进行解密,并验证签名,返回解密后的信息
*/
public function decrypt() {
global $_W;
if (empty($this->account)) {
exit('Miss Account.');
}
$postStr = file_get_contents('php://input');
if (!empty($_W['account']['encodingaeskey']) && strlen($_W['account']['encodingaeskey']) == 43 && !empty($_W['account']['key']) && !DEVELOPMENT) {
$resp = $this->account->local_decryptMsg($postStr);
} else {
$resp = $postStr;
}
exit($resp);
}
/**
* 启动消息分析引擎
*/
public function start() {
global $_W;
if (empty($this->account)) {
exit('Miss Account.');
}
if (!$this->account->checkSign()) {
exit('Check Sign Fail.');
}
if (strtolower($_SERVER['REQUEST_METHOD']) == 'get') {
$row = array();
$row['isconnect'] = 1;
pdo_update('account', $row, array('uniacid' => $_W['uniacid']));
cache_delete(cache_system_key('uniaccount', array('uniacid' => $_W['uniacid'])));
exit(htmlspecialchars($_GET['echostr']));
}
if (strtolower($_SERVER['REQUEST_METHOD']) == 'post') {
$postStr = file_get_contents('php://input');
//如果是加密方式,则先解密
if (!empty($_GET['encrypt_type']) && $_GET['encrypt_type'] == 'aes') {
$postStr = $this->account->decryptMsg($postStr);
}
WeUtility::logging('trace', $postStr);
$message = $this->account->parse($postStr);
$this->message = $message;
if (empty($message)) {
WeUtility::logging('waring', 'Request Failed');
exit('Request Failed');
}
if (in_array($message['event'], array('weapp_audit_success', 'weapp_audit_fail', 'weapp_audit_delay'))) {
$this->weapp_audit();
exit('success');
}
if ('MASSSENDJOBFINISH' == $message['event']) {
$this->mass_send_job();
exit('success');
}
if ('PUBLISHJOBFINISH' == $message['event']) {
$this->draft_publish_job();
exit('success');
}
$_W['openid'] = $message['from'];
$_W['fans'] = array('from_user' => $_W['openid']);
$this->booking($message);
if ($message['event'] == 'unsubscribe') {
$this->receive(array(), array(), array());
exit();
}
$sessionid = md5($message['from'] . $message['to'] . $_W['uniacid']);
session_id($sessionid);
WeSession::start($_W['uniacid'], $_W['openid']);
$_SESSION['openid'] = $_W['openid'];
$pars = $this->analyze($message);
$pars[] = array(
'message' => $message,
'module' => 'default',
'rule' => '-1',
);
$hitParam['rule'] = -2;
$hitParam['module'] = '';
$hitParam['message'] = $message;
$hitKeyword = array();
$response = array();
foreach ($pars as $par) {
if (empty($par['module'])) {
continue;
}
$par['message'] = $message;
$response = $this->process($par);
if ($this->isValidResponse($response)) {
$hitParam = $par;
if (!empty($par['keyword'])) {
$hitKeyword = $par['keyword'];
}
break;
}
}
$response_debug = $response;
$pars_debug = $pars;
if ($hitParam['module'] == 'default' && is_array($response) && is_array($response['params'])) {
foreach ($response['params'] as $par) {
if (empty($par['module'])) {
continue;
}
$response = $this->process($par);
if ($this->isValidResponse($response)) {
$hitParam = $par;
if (!empty($par['keyword'])) {
$hitKeyword = $par['keyword'];
}
break;
}
}
}
WeUtility::logging('params', var_export($hitParam, true));
WeUtility::logging('response', $response);
$resp = $this->account->response($response);
//如果是加密方式,则先加密
if (!empty($_GET['encrypt_type']) && $_GET['encrypt_type'] == 'aes') {
$resp = $this->account->encryptMsg($resp);
$resp = $this->account->xmlDetract($resp);
}
if ($_W['debug']) {
$_W['debug_data'] = array(
'resp' => $resp,
'is_default' => 0
);
if (count($pars_debug) == 1) {
$_W['debug_data']['is_default'] = 1;
$_W['debug_data']['params'] = $response_debug['params'];
} else {
array_pop($pars_debug);
$_W['debug_data']['params'] = $pars_debug;
}
$_W['debug_data']['hitparam'] = $hitParam;
$_W['modules']['cover'] = array('title' => '入口封面', 'name' => 'cover');
load()->web('template');
$process = template('utility/emulator', TEMPLATE_FETCH);
echo json_encode(array('resp' => $resp, 'process' => $process));
exit();
}
if ($resp !== 'success') {
$mapping = array(
'[from]' => $this->message['from'],
'[to]' => $this->message['to'],
'[rule]' => $this->params['rule']
);
$resp = str_replace(array_keys($mapping), array_values($mapping), $resp);
}
$reply_times_info = (array)$_SESSION['__reply_times'];
if ($reply_times_info['content'] == $message['content']) {
$new_times = intval($reply_times_info['times']) + 1;
} else {
$new_times = 1;
}
$_SESSION['__reply_times'] = array('content' => $message['content'], 'date' => date('Y-m-d'), 'times' => $new_times);
ob_start();
echo $resp;
ob_start();
$this->receive($hitParam, $hitKeyword, $response);
ob_end_clean();
exit();
}
WeUtility::logging('waring', 'Request Failed');
exit('Request Failed');
}
private function isValidResponse($response) {
if ($response === 'success') {
return true;
}
if (is_array($response)) {
if ($response['type'] == 'text' && !empty($response['content'])) {
return true;
}
if ($response['type'] == 'news' && !empty($response['items'])) {
return true;
}
if (!in_array($response['type'], array('text', 'news', 'image'))) {
return true;
}
}
return false;
}
/**
* 粉丝关注或取消关注
* @param $message array 统一消息结构
*/
private function booking($message) {
global $_W;
if ($message['event'] == 'unsubscribe' || $message['event'] == 'subscribe') {
$todaystat = pdo_get('stat_fans', array('date' => date('Ymd'), 'uniacid' => $_W['uniacid']));
if ($message['event'] == 'unsubscribe') {
if (empty($todaystat)) {
$updatestat = array(
'new' => 0,
'uniacid' => $_W['uniacid'],
'cancel' => 1,
'cumulate' => 0,
'date' => date('Ymd'),
);
pdo_insert('stat_fans', $updatestat);
} else {
$updatestat = array(
'cancel' => $todaystat['cancel'] + 1,
);
pdo_update('stat_fans', $updatestat, array('id' => $todaystat['id']));
}
} elseif ($message['event'] == 'subscribe') {
if (empty($todaystat)) {
$updatestat = array(
'new' => 1,
'uniacid' => $_W['uniacid'],
'cancel' => 0,
'cumulate' => 0,
'date' => date('Ymd'),
);
pdo_insert('stat_fans', $updatestat);
} else {
$updatestat = array(
'new' => $todaystat['new'] + 1,
);
pdo_update('stat_fans', $updatestat, array('id' => $todaystat['id']));
}
}
}
load()->model('mc');
$setting = uni_setting($_W['uniacid'], array('passport'));
$fans = mc_fansinfo($message['from']);
$default_groupid = cache_load(cache_system_key('defaultgroupid', array('uniacid' => $_W['uniacid'])));
if (empty($default_groupid)) {
$default_groupid = pdo_fetchcolumn('SELECT groupid FROM ' . tablename('mc_groups') . ' WHERE uniacid = :uniacid AND isdefault = 1', array(':uniacid' => $_W['uniacid']));
cache_write(cache_system_key('defaultgroupid', array('uniacid' => $_W['uniacid'])), $default_groupid);
}
if (!empty($fans)) {
if ($message['event'] == 'unsubscribe') {
cache_build_memberinfo($fans['uid']);
pdo_update('mc_mapping_fans', array('follow' => 0, 'unfollowtime' => TIMESTAMP), array('fanid' => $fans['fanid']));
pdo_delete('mc_fans_tag_mapping', array('fanid' => $fans['fanid']));
} elseif ($message['event'] != 'ShakearoundUserShake' && $message['type'] != 'trace') {
$rec = array();
if (empty($fans['follow'])) {
$rec['follow'] = 1;
$rec['followtime'] = $message['time'];
}
$member = array();
if (!empty($fans['uid'])) {
$member = mc_fetch($fans['uid']);
}
if (empty($member)) {
if (!isset($setting['passport']) || empty($setting['passport']['focusreg'])) {
$data = array(
'uniacid' => $_W['uniacid'],
'email' => md5($message['from']) . '@we7.cc',
'salt' => random(8),
'groupid' => $default_groupid,
'createtime' => TIMESTAMP,
);
$data['password'] = md5($message['from'] . $data['salt'] . $_W['config']['setting']['authkey']);
pdo_insert('mc_members', $data);
$rec['uid'] = pdo_insertid();
}
}
if (!empty($rec)) {
pdo_update('mc_mapping_fans', $rec, array('openid' => $message['from']));
}
}
} else {
if ($message['event'] == 'subscribe' || $message['type'] == 'text' || $message['type'] == 'image') {
load()->model('mc');
$force_init_member = false;
if (!isset($setting['passport']) || empty($setting['passport']['focusreg'])) {
$force_init_member = true;
}
mc_init_fans_info($message['from'], $force_init_member);
}
}
}
private function receive($par, $keyword, $response) {
global $_W;
fastcgi_finish_request();
$subscribe = cache_load(cache_system_key('module_receive_enable'));
if (empty($subscribe)) {
$subscribe = cache_build_module_subscribe_type();
}
$modules = uni_modules();
$obj = WeUtility::createModuleReceiver('core');
$obj->message = $this->message;
$obj->params = $par;
$obj->response = $response;
$obj->keyword = $keyword;
$obj->module = 'core';
$obj->uniacid = $_W['uniacid'];
$obj->acid = $_W['acid'];
if (method_exists($obj, 'receive')) {
@$obj->receive();
}
load()->func('communication');
if ((empty($subscribe[$this->message['type']]) || $this->message['type'] == 'event') && !empty($this->message['event'])) {
$subscribe[$this->message['type']] = $subscribe[strtolower($this->message['event'])];
}
if (!empty($subscribe[$this->message['type']])) {
foreach ($subscribe[$this->message['type']] as $modulename) {
if (!in_array($modulename, array_keys($modules))) {
continue;
}
//fsockipen可用时,设置timeout为0可以无需等待高效请求
//部分nginx+apache的服务器由于Nginx设置不支持为0的写法,故兼容为10秒
//发现部分用户请求127.0.0.1无法请求,报错误或其他,故再增加完整URL兼容写法
$params = array(
'i' => $GLOBALS['uniacid'],
'modulename' => $modulename,
'request' => json_encode($par),
'response' => json_encode($response),
'message' => json_encode($this->message),
);
$response = ihttp_request(wurl('utility/subscribe/receive', [], true), $params, array(), 10);
if (is_error($response) || $response['code'] != 200) {
$response = ihttp_request($_W['siteroot'] . 'web/' . wurl('utility/subscribe/receive', [], true), $params, array(), 10);
}
}
}
}
/**
* 分析消息包, 返回处理器列表
* 处理器格式:
* &nbsp;&nbsp;&nbsp;module => 处理这个消息要使用的模块名称
* &nbsp;&nbsp;&nbsp;rule => 处理这个消息关联的回复规则编号
* &nbsp;&nbsp;&nbsp;priority => 处理这个消息的优先级别
* &nbsp;&nbsp;&nbsp;context => 处理这个消息是否在上下文中
* 处理方式:
* 消息到达时
* 1. 关注 / 点击菜单操作 / 扫描二维码操作 --&gt; 返回重定向的文本匹配到的【处理器列表】
* 2. 文本消息并且在上下文中 --&gt; 取得优先级在当前锁定的上下文优先级之上的 匹配到的 【处理器列表】, 附加上 上下文中锁定的【处理器】
* 3. 其他情况 --&gt; 返回 匹配到的【处理器列表】
*
* 其中 subscribe, qr, click, 将会被重定向为 text 消息, 原来的数据保存在 source 中, 并将 redirection 设置为 true
*
* @param $message array 统一消息结构
* @return array 处理器列表
*/
private function analyze(&$message) {
global $_W;
$params = array();
if (in_array($message['type'], array('event', 'qr'))) {
$params = call_user_func_array(array($this, 'analyze' . $message['type']), array(&$message));
if (!empty($params)) {
return (array)$params;
}
}
if (!empty($_SESSION['__contextmodule']) && in_array($_SESSION['__contextmodule'], $this->modules)) {
if ($_SESSION['__contextexpire'] > TIMESTAMP) {
$params[] = array(
'message' => $message,
'module' => $_SESSION['__contextmodule'],
'rule' => $_SESSION['__contextrule'],
'priority' => $_SESSION['__contextpriority'],
'context' => true
);
return $params;
} else {
unset($_SESSION);
session_destroy();
}
}
$reply_times_info = (array)$_SESSION['__reply_times'];
if (!empty($_W['account']['setting']) && !empty($reply_times_info) && intval($_W['account']['setting']['reply_setting']) > 0 && strtotime($reply_times_info['date']) >= strtotime(date('Y-m-d')) && $reply_times_info['times'] >= $_W['account']['setting']['reply_setting'] && $reply_times_info['content'] == $message['content']) {
exit('success');
}
if (method_exists($this, 'analyze' . $message['type'])) {
$temp = call_user_func_array(array($this, 'analyze' . $message['type']), array(&$message));
if (!empty($temp) && is_array($temp)) {
$params += $temp;
}
} else {
$params += $this->handler($message['type']);
}
return $params;
}
private function analyzeSubscribe(&$message) {
global $_W;
$params = array();
$message['type'] = 'text';
$message['redirection'] = true;
if (!empty($message['scene'])) {
$message['source'] = 'qr';
$sceneid = trim($message['scene']);
if (is_numeric($sceneid)) {
$scene_condition = " `qrcid` = :sceneid";
} else {
$scene_condition = " `scene_str` = :sceneid";
}
$condition = array(':sceneid' => $sceneid, ':uniacid' => $_W['uniacid']);
$qr = pdo_fetch("SELECT `id`, `keyword` FROM " . tablename('qrcode') . " WHERE {$scene_condition} AND `uniacid` = :uniacid", $condition);
if (!empty($qr)) {
$message['content'] = $qr['keyword'];
if (!empty($qr['type']) && $qr['type'] == 'scene') {
$message['msgtype'] = 'text';
}
$params += $this->analyzeText($message);
return $params;
}
}
$message['source'] = 'subscribe';
$setting = uni_setting($_W['uniacid'], array('welcome'));
if (!empty($setting['welcome'])) {
$message['content'] = $setting['welcome'];
$params += $this->analyzeText($message);
}
return $params;
}
private function analyzeQR(&$message) {
global $_W;
$params = array();
$default_message = $message;
$message['type'] = 'text';
$message['redirection'] = true;
if (!empty($message['scene'])) {
$message['source'] = 'qr';
$sceneid = trim($message['scene']);
if (is_numeric($sceneid)) {
$scene_condition = " `qrcid` = :sceneid";
} else {
$scene_condition = " `scene_str` = :sceneid";
}
$condition_params = array(':sceneid' => $sceneid, ':uniacid' => $_W['uniacid']);
$qr = pdo_fetch("SELECT `id`, `keyword` FROM " . tablename('qrcode') . " WHERE {$scene_condition} AND `uniacid` = :uniacid AND `type` = 'scene'", $condition_params);
}
if (empty($qr) && !empty($message['ticket'])) {
$message['source'] = 'qr';
$ticket = trim($message['ticket']);
if (!empty($ticket)) {
$qr = pdo_fetchall("SELECT `id`, `keyword` FROM " . tablename('qrcode') . " WHERE `uniacid` = :uniacid AND ticket = :ticket", array(':uniacid' => $_W['uniacid'], ':ticket' => $ticket));
if (!empty($qr)) {
if (count($qr) != 1) {
$qr = array();
} else {
$qr = $qr[0];
}
}
}
}
if (!empty($qr)) {
$message['content'] = $qr['keyword'];
if (!empty($qr['type']) && $qr['type'] == 'scene') {
$message['msgtype'] = 'text';
}
$params += $this->analyzeText($message);
}
if (empty($qr)) {
$params = $this->handler($default_message['type']);
if (!empty($params)) {
$message = $default_message;
return $params;
}
}
if (empty($params)) {
$params = $this->handler($message['type']);
}
return $params;
}
public function analyzeText(&$message, $order = 0) {
global $_W;
$pars = array();
$order = intval($order);
if (!isset($message['content'])) {
return $pars;
}
//关键字先查缓存有没有匹配规则,缓存超时为5分钟
$cachekey = cache_system_key('keyword', array('content' => md5($message['content']), 'uniacid' => $_W['uniacid']));
$keyword_cache = cache_load($cachekey);
if (!empty($keyword_cache) && $keyword_cache['expire'] > TIMESTAMP) {
//计入缓存的时候可能是另一个粉丝的openid信息,故此处再换回当前粉丝信息message
foreach ($keyword_cache['data'] as $key => &$value) {
$value['message'] = $message;
}
unset($value);
return $keyword_cache['data'];
}
$condition = <<<EOF
`uniacid` IN ( 0, {$_W['uniacid']} )
AND
(
( `type` = 1 AND `content` = :c1 )
or
( `type` = 2 AND instr(:c2, `content`) )
or
( `type` = 3 AND :c3 REGEXP `content`)
or
( `type` = 4 )
)
AND `status`=1
EOF;
$params = array();
$params[':c1'] = $message['content'];
$params[':c2'] = $message['content'];
$params[':c3'] = $message['content'];
if (intval($order) > 0) {
$condition .= " AND `displayorder` > :order";
$params[':order'] = $order;
}
$keywords = reply_keywords_search($condition, $params);
if (empty($keywords)) {
return $pars;
}
//系统模块处理回复,则走缓存机制;其他模块不走缓存(可能有动态处理)
$system_module_reply = true;
foreach ($keywords as $keyword) {
if (!in_array($keyword['module'], array('defalut', 'cover', 'reply'))) {
$system_module_reply = false;
}
$params = array(
'message' => $message,
'module' => $keyword['module'],
'rule' => $keyword['rid'],
'priority' => $keyword['displayorder'],
'keyword' => $keyword,
'reply_type' => $keyword['reply_type']
);
$pars[] = $params;
}
if (!empty($system_module_reply)) {
$cache = array(
'data' => $pars,
'expire' => TIMESTAMP + 5 * 60,
);
cache_write($cachekey, $cache);
}
return $pars;
}
private function analyzeEvent(&$message) {
$event = strtolower($message['event']);
if ($event == 'subscribe') {
return $this->analyzeSubscribe($message);
}
if ($event == 'click') {
$message['content'] = strval($message['eventkey']);
return $this->analyzeClick($message);
}
if (in_array($event, array('pic_photo_or_album', 'pic_weixin', 'pic_sysphoto'))) {
pdo_delete('menu_event', array('createtime <' => $GLOBALS['_W']['timestamp'] - 100, 'openid' => $message['from']), 'OR');
if (!empty($message['sendpicsinfo']['count'])) {
foreach ($message['sendpicsinfo']['piclist'] as $item) {
pdo_insert('menu_event', array(
'uniacid' => $GLOBALS['_W']['uniacid'],
'keyword' => $message['eventkey'],
'type' => $message['event'],
'picmd5' => $item,
'openid' => $message['from'],
'createtime' => TIMESTAMP,
));
}
} else {
pdo_insert('menu_event', array(
'uniacid' => $GLOBALS['_W']['uniacid'],
'keyword' => $message['eventkey'],
'type' => $message['event'],
'picmd5' => $item,
'openid' => $message['from'],
'createtime' => TIMESTAMP,
));
}
$message['content'] = strval($message['eventkey']);
$message['source'] = $message['event'];
return $this->analyzeText($message);
}
if (!empty($message['eventkey'])) {
$message['content'] = strval($message['eventkey']);
$message['type'] = 'text';
$message['redirection'] = true;
$message['source'] = $message['event'];
return $this->analyzeText($message);
}
return $this->handler($message['event']);
}
private function analyzeClick(&$message) {
if (!empty($message['content']) || $message['content'] !== '') {
$message['type'] = 'text';
$message['redirection'] = true;
$message['source'] = 'click';
return $this->analyzeText($message);
}
return array();
}
private function analyzeImage(&$message) {
load()->func('communication');
if (!empty($message['picurl'])) {
$response = ihttp_get($message['picurl']);
if (!empty($response)) {
$md5 = md5($response['content']);
$event = pdo_get('menu_event', array('picmd5' => $md5), array('keyword', 'type'));
if (!empty($event['keyword'])) {
pdo_delete('menu_event', array('picmd5' => $md5));
} else {
$event = pdo_get('menu_event', array('openid' => $message['from']), array('keyword', 'type'));
}
if (!empty($event)) {
$message['content'] = $event['keyword'];
$message['eventkey'] = $event['keyword'];
$message['type'] = 'text';
$message['event'] = $event['type'];
$message['redirection'] = true;
$message['source'] = $event['type'];
return $this->analyzeText($message);
}
}
return $this->handler('image');
}
}
private function analyzeVoice(&$message) {
$params = $this->handler('voice');
if (empty($params) && !empty($message['recognition'])) {
$message['type'] = 'text';
$message['redirection'] = true;
$message['source'] = 'voice';
$message['content'] = $message['recognition'];
return $this->analyzeText($message);
} else {
return $params;
}
}
/**
* 处理特殊消息类型包括, video, location, link, unsubscribe, trace, view, enter
*
* @param $type
* @return array
*/
private function handler($type) {
if (empty($type)) {
return array();
}
global $_W;
$params = array();
$setting = uni_setting($_W['uniacid'], array('default_message'));
$default_message = $setting['default_message'];
if (is_array($default_message) && !empty($default_message[$type]['type'])) {
if ($default_message[$type]['type'] == 'keyword') {
$message = $this->message;
$message['type'] = 'text';
$message['redirection'] = true;
$message['source'] = $type;
$message['content'] = $default_message[$type]['keyword'];
return $this->analyzeText($message);
} else {
$params[] = array(
'message' => $this->message,
'module' => is_array($default_message[$type]) ? $default_message[$type]['module'] : $default_message[$type],
'rule' => '-1',
);
return $params;
}
}
return array();
}
/**
* 调用模块的消息处理器
*
* @param $param
* @return bool | array false |$response
*/
private function process($param) {
global $_W;
if (empty($param['module']) || !in_array($param['module'], $this->modules)) {
return false;
}
if ($param['module'] == 'reply') {
$processor = WeUtility::createModuleProcessor('core');
} else {
$processor = WeUtility::createModuleProcessor($param['module']);
}
$processor->message = $param['message'];
$processor->rule = $param['rule'];
$processor->reply_type = $param['reply_type'];
$processor->priority = intval($param['priority']);
$processor->inContext = $param['context'] === true;
$response = $processor->respond();
if (empty($response)) {
return false;
}
return $response;
}
/**
* checkauth处理
*/
public function died($content = '') {
global $_W, $engine;
if (empty($content)) {
exit('');
}
$response['FromUserName'] = $engine->message['to'];
$response['ToUserName'] = $engine->message['from'];
$response['MsgType'] = 'text';
$response['Content'] = htmlspecialchars_decode($content);
$response['CreateTime'] = TIMESTAMP;
$response['FuncFlag'] = 0;
$xml = array2xml($response);
if (!empty($_GET['encrypt_type']) && $_GET['encrypt_type'] == 'aes') {
$resp = $engine->account->encryptMsg($xml);
$resp = $engine->account->xmlDetract($resp);
} else {
$resp = $xml;
}
exit($resp);
}
public function weapp_audit() {
$wxapp_register_version_table = table('wxapp_register_version');
$wxapp_register_version = $wxapp_register_version_table->getWithAccountWxappOriginal($this->message['to']);
if (empty($wxapp_register_version)) {
return false;
}
switch ($this->message['event']) {
case 'weapp_audit_success':
$data = array('status' => WXAPP_REGISTER_VERSION_STATUS_CHECKSUCCESS, 'reason' => '');
break;
case 'weapp_audit_fail':
$data = array('status' => WXAPP_REGISTER_VERSION_STATUS_CHECKFAIL, 'reason' => $this->message['reason']);
break;
default:
$data = array();
break;
}
if ($data) {
$wxapp_register_version_table->where('id', $wxapp_register_version['id'])->fill($data)->save();
}
return true;
}
public function mass_send_job() {
$record_info = pdo_get('mc_mass_record', array('msg_id' => $this->message['msgid']), array('id'));
if (!empty($record_info) && $this->message['event'] == 'MASSSENDJOBFINISH') {
switch ($this->message['status']) {
case 'send success':
$data = array('status' => 0);
break;
case 'send fail':
$data = array('status' => 2);
break;
default:
$error_msg = array(
'err(10001)' => '涉嫌广告',
'err(20001)' => '涉嫌政治',
'err(20004)' => '涉嫌社会',
'err(20002)' => '涉嫌色情',
'err(20006)' => '涉嫌违法犯罪',
'err(20008)' => '涉嫌欺诈',
'err(20013)' => '涉嫌版权',
'err(22000)' => '涉嫌互推(互相宣传)',
'err(21000)' => '涉嫌其他',
'err(30001)' => '原创校验出现系统错误且用户选择了被判为转载就不群发',
'err(30002)' => '原创校验被判定为不能群发',
'err(30003)' => '原创校验被判定为转载文且用户选择了被判为转载就不群发',
'err(40001)' => '管理员拒绝',
'err(40002)' => '管理员30分钟内无响应,超时',
);
$status_msg = $this->message['status'] . ':' . $error_msg[$this->message['status']];
$data = array('status' => 3, 'status_msg' => $status_msg);
break;
}
pdo_update('mc_mass_record', $data, array('id' => $record_info['id']));
return true;
}
return false;
}
public function draft_publish_job() {
$publish_info = $this->message['publisheventinfo'];
$draft_info = pdo_get('wechat_attachment', array('publish_id' => $publish_info['publish_id']));
if (!empty($draft_info)) {
switch ($publish_info['publish_status']) {
case '0':
$material_info = pdo_getall('wechat_news', array('attach_id' => $draft_info['id']), array(), 'displayorder');
if (1 == $publish_info['article_detail']['count']) {
$article = $publish_info['article_detail']['item'];
pdo_update('wechat_news', array('url' => $article['article_url']), array('id' => $material_info[$article['idx'] - 1]['id']));
} else {
foreach ($publish_info['article_detail']['item'] as $article) {
if (!empty($material_info[$article['idx'] - 1])) {
pdo_update('wechat_news', array('url' => $article['article_url']), array('id' => $material_info[$article['idx'] - 1]['id']));
}
}
}
$wechat_attachment = array(
'publish_status' => $publish_info['publish_status'],
'article_id' => $publish_info['article_id'],
);
break;
case '1':
case '2':
case '3':
case '4':
case '5':
case '6':
$wechat_attachment = array('publish_status' => $publish_info['publish_status']);
break;
default:
$wechat_attachment = array();
break;
}
if (empty($wechat_attachment)) {
return false;
}
pdo_update('wechat_attachment', $wechat_attachment, array('id' => $draft_info['id']));
return true;
}
return false;
}
}
PHP
1
https://gitee.com/we7coreteam/pros.git
git@gitee.com:we7coreteam/pros.git
we7coreteam
pros
开源版微擎系统
master

搜索帮助

14c37bed 8189591 565d56ea 8189591