|
@@ -0,0 +1,509 @@
|
|
|
|
+<?php
|
|
|
|
+/*
|
|
|
|
+|--------------------------------------------------------------------------
|
|
|
|
+| receive.php 用于接收微信发过来的信息
|
|
|
|
+|--------------------------------------------------------------------------
|
|
|
|
+*/
|
|
|
|
+namespace Component\Service;
|
|
|
|
+
|
|
|
|
+use Dever;
|
|
|
|
+use Main\Lib\Wechat;
|
|
|
|
+
|
|
|
|
+class Receive
|
|
|
|
+{
|
|
|
|
+ const TYPE = 5;
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * wechat
|
|
|
|
+ *
|
|
|
|
+ * @var Wechat
|
|
|
|
+ */
|
|
|
|
+ private $wechat;
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * result
|
|
|
|
+ *
|
|
|
|
+ * @var array
|
|
|
|
+ */
|
|
|
|
+ private $result;
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * output
|
|
|
|
+ *
|
|
|
|
+ * @var string
|
|
|
|
+ */
|
|
|
|
+ private $output;
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 构造函数 初始化
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ public function __construct()
|
|
|
|
+ {
|
|
|
|
+ $appid = Dever::input('appid');
|
|
|
|
+ $project = false;
|
|
|
|
+ if ($appid) {
|
|
|
|
+ $info = Dever::db('main/project')->one(array('option_type' => self::TYPE, 'option_appid' => $appid));
|
|
|
|
+ if ($info) {
|
|
|
|
+ $project = $info['id'];
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ $this->wechat = new Wechat('component', $project);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 业务推送接口 微信服务器会将所有请求都推送到这里
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ public function main()
|
|
|
|
+ {
|
|
|
|
+ $this->output = '';
|
|
|
|
+
|
|
|
|
+ # 获取微信消息
|
|
|
|
+ $this->request();
|
|
|
|
+
|
|
|
|
+ # 对消息进行验证,并根据类型得到本平台的配置数据
|
|
|
|
+ //$this->response();
|
|
|
|
+
|
|
|
|
+ # 输出
|
|
|
|
+ $this->output();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 输出
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function output()
|
|
|
|
+ {
|
|
|
|
+ if (!$this->output) {
|
|
|
|
+ $this->output = 'success';
|
|
|
|
+ }
|
|
|
|
+ echo $this->output;die;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 据类型得到本平台的配置数据
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function response()
|
|
|
|
+ {
|
|
|
|
+ if ($this->output) {
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if ($this->result && isset($this->result['add_type'])) {
|
|
|
|
+ if (isset($this->result['subscribe'])) {
|
|
|
|
+ if ($this->result['subscribe'] == true) {
|
|
|
|
+ # 订阅成功 发送消息
|
|
|
|
+ $this->msg('msg1');
|
|
|
|
+ # 发送消息之后,往用户表更新信息
|
|
|
|
+ $this->user();
|
|
|
|
+ $this->setSubscribe(1);
|
|
|
|
+ }
|
|
|
|
+ if ($this->result['subscribe'] == false) {
|
|
|
|
+ # 取消订阅 不发送消息
|
|
|
|
+ //$this->msg('msg1');
|
|
|
|
+ # 改变当前用户的订阅状态
|
|
|
|
+ $this->setSubscribe(2);
|
|
|
|
+ }
|
|
|
|
+ } elseif (isset($this->result['add_content'][0]['Content'])) {
|
|
|
|
+ $this->match($this->result['add_content'][0]['Content']);
|
|
|
|
+ } else {
|
|
|
|
+ # 如果没有匹配到,则直接返回默认回复消息
|
|
|
|
+ $this->msg('msg2');
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 获取微信发送的内容
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function request()
|
|
|
|
+ {
|
|
|
|
+ $post = isset($GLOBALS["HTTP_RAW_POST_DATA"]) ? $GLOBALS["HTTP_RAW_POST_DATA"] : false;
|
|
|
|
+
|
|
|
|
+/*
|
|
|
|
+ $post = ' <xml>
|
|
|
|
+ <ToUserName><![CDATA[toUser]]></ToUserName>
|
|
|
|
+ <FromUserName><![CDATA[ow29VvzICifpOTq_9EDGT3AhYpqg]]></FromUserName>
|
|
|
|
+ <CreateTime>1442067297</CreateTime>
|
|
|
|
+ <MsgType><![CDATA[text]]></MsgType>
|
|
|
|
+ <Content><![CDATA[dfd]]></Content>
|
|
|
|
+ <MsgId>1311112322222222</MsgId>
|
|
|
|
+ </xml>';
|
|
|
|
+
|
|
|
|
+ /*
|
|
|
|
+ $post = '<xml>
|
|
|
|
+<ToUserName><![CDATA[toUser]]></ToUserName>
|
|
|
|
+<FromUserName><![CDATA[FromUser]]></FromUserName>
|
|
|
|
+<CreateTime>123456789</CreateTime>
|
|
|
|
+<MsgType><![CDATA[event]]></MsgType>
|
|
|
|
+<Event><![CDATA[subscribe]]></Event>
|
|
|
|
+</xml>';
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ $post = ' <xml>
|
|
|
|
+ <ToUserName><![CDATA[toUser]]></ToUserName>
|
|
|
|
+ <FromUserName><![CDATA[ow29VvzICifpOTq_9EDGT3AhYpqg]]></FromUserName>
|
|
|
|
+ <CreateTime>1442067297</CreateTime>
|
|
|
|
+ <MsgType><![CDATA[image]]></MsgType>
|
|
|
|
+ <PicUrl><![CDATA[http://mmbiz.qpic.cn/mmbiz/OxUBpiaYgpHiaDaiccrsX3MrFEVtjIfEAZk8zoJDZ4gXWWW2CIFic6Dicqndu23wMgA4Icg3yE4SRZg6L5jqanu9kvQ/0]]></PicUrl>
|
|
|
|
+ <MediaId><![CDATA[media_id]]></MediaId>
|
|
|
|
+ <MsgId>111</MsgId>
|
|
|
|
+ </xml>';
|
|
|
|
+
|
|
|
|
+ $post = '<xml>
|
|
|
|
+<ToUserName><![CDATA[toUser]]></ToUserName>
|
|
|
|
+<FromUserName><![CDATA[ow29VvzICifpOTq_9EDGT3AhYpqg]]></FromUserName>
|
|
|
|
+<CreateTime>1442067297</CreateTime>
|
|
|
|
+<MsgType><![CDATA[voice]]></MsgType>
|
|
|
|
+<MediaId><![CDATA[media_id]]></MediaId>
|
|
|
|
+<Format><![CDATA[Format]]></Format>
|
|
|
|
+<MsgId>23123213</MsgId>
|
|
|
|
+</xml>';
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ $post = '<xml>
|
|
|
|
+<ToUserName><![CDATA[toUser]]></ToUserName>
|
|
|
|
+<FromUserName><![CDATA[FromUser]]></FromUserName>
|
|
|
|
+<CreateTime>123456789</CreateTime>
|
|
|
|
+<MsgType><![CDATA[event]]></MsgType>
|
|
|
|
+<Event><![CDATA[CLICK]]></Event>
|
|
|
|
+<EventKey><![CDATA[EVENTKEY]]></EventKey>
|
|
|
|
+</xml>';
|
|
|
|
+*/
|
|
|
|
+ Dever::log(time());
|
|
|
|
+ if (!empty($post)) {
|
|
|
|
+ Dever::log($post);
|
|
|
|
+ libxml_disable_entity_loader(true);
|
|
|
|
+ $result = (array) simplexml_load_string($post, 'SimpleXMLElement', LIBXML_NOCDATA);
|
|
|
|
+
|
|
|
|
+ $this->handle($result);
|
|
|
|
+ } else {
|
|
|
|
+ return false;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 对微信的内容做处理,得到最终结果
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function handle($result)
|
|
|
|
+ {
|
|
|
|
+ return;
|
|
|
|
+ $config = array
|
|
|
|
+ (
|
|
|
|
+ 'AppId' => 'add_appid',
|
|
|
|
+ 'CreateTime' => 'add_create_date',
|
|
|
|
+ 'InfoType' => 'add_type',
|
|
|
|
+ 'ComponentVerifyTicket' => 'add_ticket',
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+ foreach ($config as $k => $v) {
|
|
|
|
+ $this->result($k, $v, $result);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ # 事件处理
|
|
|
|
+ $this->event();
|
|
|
|
+
|
|
|
|
+ $this->save();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 事件处理
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function event()
|
|
|
|
+ {
|
|
|
|
+ if ($this->result['add_type'] == 'component_verify_ticket') {
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 入库
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function save()
|
|
|
|
+ {
|
|
|
|
+ $this->result['add_info'] = is_array($this->result['add_info']) ? implode(',', $this->result['add_info']) : $this->result['add_info'];
|
|
|
|
+ $this->result['add_site'] = $this->core->site();
|
|
|
|
+
|
|
|
|
+ # 入库 使用mid排重
|
|
|
|
+ $info = array();
|
|
|
|
+ if (isset($this->result['add_mid'])) {
|
|
|
|
+ $info = Dever::load('weixin/usermsg-getOne', array('where_mid' => $this->result['add_mid'], 'where_site' => $this->result['add_site']));
|
|
|
|
+ $this->result['id'] = $info['id'];
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if (!$info) {
|
|
|
|
+ $this->result['id'] = Dever::load('weixin/usermsg-insert', $this->result);
|
|
|
|
+
|
|
|
|
+ # 记录点对点聊天记录 暂时不记录了
|
|
|
|
+ /*
|
|
|
|
+ if($this->result['add_type'] == 'text')
|
|
|
|
+ {
|
|
|
|
+ $update['add_state'] = 1;
|
|
|
|
+ $update['add_openid'] = $this->result['add_from'];
|
|
|
|
+ $update['add_usermsg_id'] = $this->result['id'];
|
|
|
|
+ $update['add_account'] = -1;
|
|
|
|
+ $update['add_type'] = $this->result['add_type'];
|
|
|
|
+ $update['add_info'] = Dever::load('weixin/user.msg', $this->result['id']);
|
|
|
|
+
|
|
|
|
+ Dever::load('weixin/usermsg_log-insert', $update);
|
|
|
|
+ }
|
|
|
|
+ */
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 得到最终结果
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function result($key, $index, $result, $name = '')
|
|
|
|
+ {
|
|
|
|
+ if (isset($result[$key])) {
|
|
|
|
+ $value = trim($result[$key]);
|
|
|
|
+ if ($index == 'add_type') {
|
|
|
|
+ $this->type($value, $result);
|
|
|
|
+ }
|
|
|
|
+ if ($index == 'add_content') {
|
|
|
|
+ //$key = $name ? $name : $key;
|
|
|
|
+ $this->result[$index][0][$key] = $value;
|
|
|
|
+ $this->info($key, $value);
|
|
|
|
+ } elseif ($index == 'add_ctime') {
|
|
|
|
+ $this->result[$index] = $value ? $value : time();
|
|
|
|
+ } else {
|
|
|
|
+ $this->result[$index] = $value;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 根据状态得到用户发送的具体内容,为了响应及时,这里不做解析。
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function info($key, $value)
|
|
|
|
+ {
|
|
|
|
+ $this->result['add_info'][] = $value;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 得到type的值
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function type($index, $result)
|
|
|
|
+ {
|
|
|
|
+ $type = $this->config($index);
|
|
|
|
+ if (is_array($type)) {
|
|
|
|
+ foreach ($type as $k => $v) {
|
|
|
|
+ if (is_numeric($k)) {
|
|
|
|
+ $k = $v;
|
|
|
|
+ }
|
|
|
|
+ $this->result($k, 'add_content', $result, $v);
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ $this->result($type, 'add_content', $result);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 得到对应关系
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function keywords($type)
|
|
|
|
+ {
|
|
|
|
+ # 根据keywords的type设定来设置对应关系
|
|
|
|
+ $config = array
|
|
|
|
+ (
|
|
|
|
+ 1 => 'text',
|
|
|
|
+ 2 => 'news',
|
|
|
|
+ //3 => 'news',
|
|
|
|
+ 4 => 'voice',
|
|
|
|
+ 5 => 'video',
|
|
|
|
+ 6 => 'image',
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+ if (!isset($config[$type])) {
|
|
|
|
+ return false;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ $this->result['type'] = $config[$type];
|
|
|
|
+
|
|
|
|
+ return $config[$type];
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 配置type类型
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function config($key, $type = 'get')
|
|
|
|
+ {
|
|
|
|
+ $config = array
|
|
|
|
+ (
|
|
|
|
+ # 文本
|
|
|
|
+ 'text' => array
|
|
|
|
+ (
|
|
|
|
+ # 设置获取的key 应答
|
|
|
|
+ 'get' => 'Content',
|
|
|
|
+ # 设置赋值的key 回复
|
|
|
|
+ 'set' => 'Content',
|
|
|
|
+ ),
|
|
|
|
+ # 图片
|
|
|
|
+ 'image' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => array('PicUrl', 'MediaId'),
|
|
|
|
+ 'set' => array
|
|
|
|
+ (
|
|
|
|
+ 'Image' => array('MediaId' => 'pic')
|
|
|
|
+ ),
|
|
|
|
+ ),
|
|
|
|
+ # 语音
|
|
|
|
+ 'voice' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => array('MediaId', 'Format'),
|
|
|
|
+ 'set' => array
|
|
|
|
+ (
|
|
|
|
+ 'Voice' => array('MediaId' => 'mp3')
|
|
|
|
+ ),
|
|
|
|
+ ),
|
|
|
|
+ # 视频
|
|
|
|
+ 'video' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => array('MediaId', 'ThumbMediaId'),
|
|
|
|
+ 'set' => array
|
|
|
|
+ (
|
|
|
|
+ 'Voice' => array('MediaId' => 'mp4', 'Title' => 'title', 'Description' => 'info')
|
|
|
|
+ ),
|
|
|
|
+ ),
|
|
|
|
+ # 小视频
|
|
|
|
+ 'shortvideo' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => array('MediaId', 'ThumbMediaId'),
|
|
|
|
+ 'set' => false,
|
|
|
|
+ ),
|
|
|
|
+ # 地理位置
|
|
|
|
+ 'location' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => array('Location_X', 'Location_Y', 'Scale', 'Label'),
|
|
|
|
+ 'set' => false,
|
|
|
|
+ ),
|
|
|
|
+ # 链接消息
|
|
|
|
+ 'link' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => array('Title', 'Description', 'Url', 'Label'),
|
|
|
|
+ 'set' => false,
|
|
|
|
+ ),
|
|
|
|
+ # 单图文消息
|
|
|
|
+ 'new' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => false,
|
|
|
|
+ 'set' => array
|
|
|
|
+ (
|
|
|
|
+ 'ArticleCount' => 1,
|
|
|
|
+ 'Articles' => array
|
|
|
|
+ (
|
|
|
|
+ 'item' => array('Title' => 'title', 'Description' => 'info', 'PicUrl' => 'pic', 'Url' => 'link')
|
|
|
|
+ )
|
|
|
|
+ ),
|
|
|
|
+ ),
|
|
|
|
+ # 多图文消息
|
|
|
|
+ 'news' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => false,
|
|
|
|
+ 'set' => array
|
|
|
|
+ (
|
|
|
|
+ 'ArticleCount' => 'total',
|
|
|
|
+ 'Articles' => array
|
|
|
|
+ (
|
|
|
|
+ 'item' => array('Title' => 'title', 'Description' => 'info', 'PicUrl' => 'pic', 'Url' => 'link')
|
|
|
|
+ )
|
|
|
|
+ ),
|
|
|
|
+ ),
|
|
|
|
+ # 音乐消息
|
|
|
|
+ 'music' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => false,
|
|
|
|
+ 'set' => false,
|
|
|
|
+ ),
|
|
|
|
+
|
|
|
|
+ # 事件消息,所有事件返回的字段都在此做说明
|
|
|
|
+ 'event' => array
|
|
|
|
+ (
|
|
|
|
+ 'get' => array
|
|
|
|
+ (
|
|
|
|
+ 'Event' => '事件',
|
|
|
|
+ 'EventKey' => '事件ID',
|
|
|
|
+ 'Latitude' => '纬度',
|
|
|
|
+ 'Longitude' => '经度',
|
|
|
|
+ 'Precision' => '精度',
|
|
|
|
+ 'Ticket' => '二维码',
|
|
|
|
+ 'MsgID' => '消息ID',
|
|
|
|
+ 'Status' => '状态',
|
|
|
|
+ 'TotalCount' => '粉丝数',
|
|
|
|
+ 'FilterCount' => '过滤数',
|
|
|
|
+ 'SentCount' => '成功数',
|
|
|
|
+ 'ErrorCount' => '失败数',
|
|
|
|
+ ),
|
|
|
|
+ 'set' => false,
|
|
|
|
+ ),
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+ return $config[$key][$type];
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 获取当前时间
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function time()
|
|
|
|
+ {
|
|
|
|
+ return time();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 拼装xml相应代码
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function xml($content)
|
|
|
|
+ {
|
|
|
|
+ $xml = "<xml>\r\n"
|
|
|
|
+ .$this->tag('ToUserName', $this->result['add_from']) . "\r\n"
|
|
|
|
+ .$this->tag('FromUserName', $this->result['add_to']) . "\r\n"
|
|
|
|
+ .$this->tag('CreateTime', $this->time()) . "\r\n"
|
|
|
|
+ .$this->tag('MsgType', $this->result['type']) . "\r\n"
|
|
|
|
+ .$content . "\r\n"
|
|
|
|
+ .'</xml>';
|
|
|
|
+
|
|
|
|
+ return $xml;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /**
|
|
|
|
+ * 生成tag
|
|
|
|
+ *
|
|
|
|
+ * @return mixed
|
|
|
|
+ */
|
|
|
|
+ private function tag($tag, $value = '')
|
|
|
|
+ {
|
|
|
|
+ if (!is_numeric($value) && strpos($value, '<') === false) {
|
|
|
|
+ $value = '<![CDATA['.$value.']]>';
|
|
|
|
+ }
|
|
|
|
+ return '<'.$tag.'>'.$value.'</'.$tag.'>';
|
|
|
|
+ }
|
|
|
|
+}
|