# 附件十三 微信推送消息接口类库源码 基类
谢谢关注
~~~
<?php
/**
* Created by PhpStorm.
* Power By Mikkle
* Email：776329498@qq.com
* Date: 2017/9/15
* Time: 17:54
*/
namespace mikkle\tp_wechat\base;
use mikkle\tp_wechat\support\Exception;
use mikkle\tp_wechat\Wechat;
use think\Hook;
use mikkle\tp_wechat\support\Log;
use mikkle\tp_wechat\support\Request;
/**
* 微信消息接口基类
* Power: Mikkle
* Email：776329498@qq.com
* Class BaseWeApi
* @package app\center\controller
*/
abstract class BaseWechatApi
{
protected $app_id;
//微信参数 建议继承覆盖此参数
protected $options;
protected $weObj;
protected $openid;
protected $type;
protected $data;
protected $fans;
//是否开启对接 建议继承覆盖此参数
protected $valid = true; //
protected $isHook = false; //是否开启钩子
public function __construct($options = [])
{
$this->request = Request::instance();
$this->options = !empty($options) ? $options : $this->options;
$this->app_id = $this->options['appid'];
$this->weObj = Wechat::receive($this->options);
}
/**
* 微信接收主方法
* Power: Mikkle
* Email：776329498@qq.com
*/
public function index()
{
try {
//是否是对接模式
if ($this->valid == true) {
$this->weObj->valid();
}
//分解数据获得常用字段
$get_rev = $this->weObj->getRev();
if (empty($get_rev)) {
$this->we_dump('false');
}
$this->openid = $get_rev->getRevFrom();
$this->type = $get_rev->getRevType();
$this->data = $get_rev->getRevData();
if (empty($this->data)) {
$this->we_dump('false');
}
//用户检测，如果有就存入data,没有则存入数据库
$fans = $this->hasSaveFans();
if (!$fans) {
throw new Exception("获取粉丝信息错误");
}
Hook::listen("wechat_receive", $this->weObj);
//补充常用相关数据到DATA
$this->data['appid'] = $this->app_id;
$this->data['openid'] = $fans['openid'];
$this->data['nickname'] = $fans['nickname'];
$this->fans = $fans;
//判断消息是否存在
if ($this->saveWeMessage() === false) {
$this->weObj->text('处理中，请稍后！')->reply();
die;
};
$reply = [];
//根据消息类型 获取不同回复内容
$message = $this->messageTypeHandleCenter();
if (!empty($message)) {
//处理兼容
if (!is_array($message)) {
$reply['message'] = $message;
} else {
$reply = $message;
}
if (!isset($reply['type'])) $reply['type'] = 'text';
$reply['message'] = isset($reply['message']) ? $reply['message'] : '知道吗!我爱你!请原谅我不知道如何回答你的问题!';
$this->weObj->$reply['type']($reply['message'])->reply();
}
die;
} catch (Exception $e) {
Log::error($e);
$this->weObj->text("本宝宝生病了,请原谅我不知道如何回答你的问题!")->reply();
die();
}
}
/**
* 默认文本消息回复内容
*
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnMessageText()
{
return '发送的是' . $this->weObj->getRevContent();
}
/**
* 默认图片信息回复内容
*
* Power: Mikkle
* Email：776329498@qq.com
* @return array
*/
protected function returnMessageImage()
{
$newsarray = [
[
'Title' => '你的图片发送成功',
'Description' => '这是你发的图片吧',
'PicUrl' => $this->data['PicUrl'],
'Url' => $this->request->domain(),
],
];
$reply = ['type' => 'news', 'message' => $newsarray];
return $reply;
}
/**
* 默认语音信息回复内容处理方法
*
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnMessageVoice()
{
if (!empty($this->data['Content'])) {
$keyword = $this->data['Content']; //TODO::语音识别 语义分析
} else {
$keyword = $this->data->type;
}
$reply = '发送的语音翻译是:' . $keyword;
return $reply;
}
/**
* 默认音乐信息回复列表处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnMessageMusic()
{
return '发送的是音乐';
}
/**
* 默认视频信息回复处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnMessageVideo()
{
return '发送的是视频';
}
/**
* 默认发送地理位置回复信息处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnMessageLocation()
{
return '发送的是地理位置';
}
/**
* 默认链接回复内容处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnMessageLink()
{
return '发送的是链接';
}
/**
* 默认关注回复处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return array
*/
protected function returnEventSubscribe()
{
return ['type' => 'text', 'message' => '感谢你的关注'];
}
/**
* 默认取消关注回复处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return array
*/
protected function returnEventUnsubscribe()
{
return ['type' => 'text', 'message' => '期待你的再次关注'];
}
/**
* 默认扫码事件处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return array
*/
protected function returnEventScan()
{
$message = $this->weObj->getRevEvent();
if (isset($message["key"])) {
return ['type' => 'text', 'message' => "你的扫码成功,扫码内容:{$message['key']}"];
}
return ['type' => 'text', 'message' => '你的扫码成功'];
}
/**
* 默认上报地理事件处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return array
*/
protected function returnEventLocation()
{
return ['type' => 'text', 'message' => '地理位置上报成功'];
}
/**
* 默认点击菜单关键字处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return array
*/
protected function returnEventClick()
{
$message = $this->weObj->getRevEvent();
if (isset($message["key"])) {
return ['type' => 'text', 'message' => "你的点击成功,点击关键字内容:{$message['key']}"];
}
return ['type' => 'text', 'message' => '你的点击成功'];
}
/**
* 菜单调用扫码事件处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @param $type
* @return array
*/
protected function returnEventMenuScan($type)
{
$message = $this->weObj->getRevEvent();
switch ($type) {
case "push": //推送
if (isset($message["key"])) {
return ['type' => 'text', 'message' => "你的点击菜单扫码,关键字内容:{$message['key']}"];
}
return ['type' => 'text', 'message' => '你的点击菜单扫码成功'];
break;
case "waitmsg":
//等候
if (isset($message["key"])) {
return ['type' => 'text', 'message' => "你的点击菜单扫码等待中,关键字内容:{$message['key']}"];
}
return ['type' => 'text', 'message' => '你的点击菜单扫码等待中'];
break;
default:
;
}
}
/**
* 通过菜单上传图片处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @param $type // sys 系统 | photo 相册 | weixin 微信相册
* @return array
*/
protected function returnEventMenuPic($type)
{
$message = $this->weObj->getRevEvent();
if (isset($message["key"])) {
return ['type' => 'text', 'message' => "你的通过菜单上传图片成功,图片方式{$type},关键字内容:{$message['key']}"];
}
return ['type' => 'text', 'message' => "你的通过菜单上传图片成功,图片方式{$type}"];
}
/**
* 菜单上报地理事件
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnEventMenuLocation()
{
return $reply['message'] = 'success';
}
/**
* 群发成功推送结果处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnEventSendMass()
{
return $reply['message'] = 'success';
}
/**
* 模版消息接收结果处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnEventSendTemplate()
{
return $reply['message'] = 'success';
}
/**
* 客服事件处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @param $type //create | close | switch
* @return string
*/
protected function returnEvenKfSession($type)
{
return $reply['message'] = 'success';
}
/**
* 卡类时间 处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @param $type //pass | notpass | user_get |user_dell
* @return string
*/
protected function returnEventCard($type)
{
return $reply['message'] = 'success';
}
/**
* wifi连一连处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnEventWifiConnected()
{
return $reply['message'] = 'success';
}
/**
* 其他未知事件处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnEventOthers()
{
return $reply['message'] = 'success';
}
/**
* 周围摇一摇事件处理方法
* Power: Mikkle
* Email：776329498@qq.com
* @return string
*/
protected function returnEventAroundUserSnake()
{
return $reply['message'] = 'success';
}
/**
* 处理微信消息总处理入口
* Power: Mikkle
* Email：776329498@qq.com
* @return array|string
*/
private function messageTypeHandleCenter()
{
switch ($this->type) {
case WeChatCode::MSGTYPE_TEXT:
if ($this->isHook) {
Hook::listen("wechat_message_text", $this->weObj);
}
return $this->returnMessageText();
break;
case WeChatCode::MSGTYPE_IMAGE:
if ($this->isHook) {
Hook::listen("wechat_message_image", $this->weObj);
}
return $this->returnMessageImage();
break;
case WeChatCode::MSGTYPE_VOICE:
if ($this->isHook) {
Hook::listen("wechat_message_voice", $this->weObj);
}
return $this->returnMessageVoice();
break;
case WeChatCode::MSGTYPE_MUSIC:
if ($this->isHook) {
Hook::listen("wechat_message_music", $this->weObj);
}
return $this->returnMessageMusic();
break;
case WeChatCode::MSGTYPE_VIDEO:
if ($this->isHook) {
Hook::listen("wechat_message_video", $this->weObj);
}
return $this->returnMessageVideo();
break;
case WeChatCode::MSGTYPE_LOCATION:
if ($this->isHook) {
Hook::listen("wechat_message_location", $this->weObj);
}
return $this->returnMessageLocation();
break;
case WeChatCode::MSGTYPE_LINK:
if ($this->isHook) {
Hook::listen("wechat_message_link", $this->weObj);
}
return $this->returnMessageLink();
break;
case WeChatCode::MSGTYPE_EVENT:
//事件处理中心
$reply = $this->messageEventHandleCenter();
break;
default:
$reply = ['type' => 'text', 'message' => 'success'];
break;
}
return $reply;
}
/**
* 处理微信事件消息处理中心
* Power: Mikkle
* Email：776329498@qq.com
* @return array|string
*/
private function messageEventHandleCenter()
{
try {
$reply = "";
switch ($this->data['Event']) {
case WeChatCode::EVENT_SUBSCRIBE:
if ($this->isHook) {
Hook::listen("wechat_event_subscribe", $this->weObj);
}
$reply = $this->returnEventSubscribe();
break;
case WeChatCode::EVENT_UNSUBSCRIBE:
if ($this->isHook) {
Hook::listen("wechat_event_unsubscribe", $this->weObj);
}
$reply = $this->returnEventUnsubscribe();
break;
case WeChatCode::EVENT_SCAN:
if ($this->isHook) {
Hook::listen("wechat_event_scan", $this->weObj);
}
$reply = $this->returnEventScan();
break;
case WeChatCode::EVENT_LOCATION:
if ($this->isHook) {
Hook::listen("wechat_event_location", $this->weObj);
}
$reply = $this->returnEventLocation();
break;
case WeChatCode::EVENT_MENU_CLICK:
if ($this->isHook) {
Hook::listen("wechat_event_click", $this->weObj);
}
$reply = $this->returnEventClick();
break;
case WeChatCode::EVENT_MENU_SCAN_PUSH:
if ($this->isHook) {
Hook::listen("wechat_event_menu_scan_push", $this->weObj);
}
$reply = $this->returnEventMenuScan("push");
break;
case WeChatCode::EVENT_MENU_SCAN_WAITMSG:
if ($this->isHook) {
Hook::listen("wechat_event_menu_scan_waitmsg", $this->weObj);
}
$reply = $this->returnEventMenuScan("waitmsg");
break;
case WeChatCode::EVENT_MENU_PIC_SYS:
if ($this->isHook) {
Hook::listen("wechat_event_menu_pic_sys", $this->weObj);
}
$reply = $this->returnEventMenuPic("sys");
break;
case WeChatCode::EVENT_MENU_PIC_PHOTO:
if ($this->isHook) {
Hook::listen("wechat_event_menu_pic_photo", $this->weObj);
}
$reply = $this->returnEventMenuPic("photo");
break;
case WeChatCode::EVENT_MENU_PIC_WEIXIN:
if ($this->isHook) {
Hook::listen("wechat_event_menu_pic_weixin", $this->weObj);
}
$reply = $this->returnEventMenuPic("weixin");
break;
case WeChatCode::EVENT_MENU_LOCATION:
if ($this->isHook) {
Hook::listen("wechat_event_menu_location", $this->weObj);
}
$reply = $this->returnEventMenuLocation();
break;
case WeChatCode::EVENT_SEND_MASS:
if ($this->isHook) {
Hook::listen("wechat_event_send_mass", $this->weObj);
}
$reply = $this->returnEventSendMass();
break;
case WeChatCode::EVENT_SEND_TEMPLATE:
if ($this->isHook) {
Hook::listen("wechat_event_send_template", $this->weObj);
}
$reply = $this->returnEventSendTemplate();
//模板消息发送成功
$reply['message'] = 'success';
break;
case WeChatCode::EVENT_KF_SESSION_CREATE:
if ($this->isHook) {
Hook::listen("wechat_event_kf_create", $this->weObj);
}
$reply = $this->returnEvenKfSession("create");
break;
case WeChatCode::EVENT_KF_SESSION_CLOSE:
if ($this->isHook) {
Hook::listen("wechat_event_kf_close", $this->weObj);
}
$reply = $this->returnEvenKfSession("close");
break;
case WeChatCode::EVENT_KF_SESSION_SWITCH:
if ($this->isHook) {
Hook::listen("wechat_event_kf_switch", $this->weObj);
}
$reply = $this->returnEvenKfSession("switch");
break;
case WeChatCode::EVENT_CARD_PASS:
if ($this->isHook) {
Hook::listen("wechat_event_card_pass", $this->weObj);
}
$reply = $this->returnEventCard("notpass");
break;
case WeChatCode::EVENT_CARD_NOTPASS:
if ($this->isHook) {
Hook::listen("wechat_event_card_notpass", $this->weObj);
}
$reply = $this->returnEventCard("notpass");
break;
case WeChatCode::EVENT_CARD_USER_GET:
if ($this->isHook) {
Hook::listen("wechat_event_card_user_get", $this->weObj);
}
$reply = $this->returnEventCard("user_get");
break;
case WeChatCode::EVENT_CARD_USER_DEL:
if ($this->isHook) {
Hook::listen("wechat_event_menu_user_del", $this->weObj);
}
$reply = $this->returnEventCard("user_dell");
break;
case WeChatCode::EVENT_WIFI_CONNECTED :
if ($this->isHook) {
Hook::listen("wechat_event_wifi_connected", $this->weObj);
}
$reply = $this->returnEventWifiConnected();
break;
case WeChatCode::EVENT_SHAKEAROUND_USER_SHAKE :
if ($this->isHook) {
Hook::listen("wechat_event_around_user_shake", $this->weObj);
}
$reply = $this->returnEventAroundUserSnake();
break;
default:
if ($this->isHook) {
Hook::listen("wechat_event_others", $this->weObj);
}
$reply = $this->returnEventOthers();
break;
break;
}
return $reply;
} catch (Exception $e) {
return "回复事件信息出错了 {$e->getMessage()}";
}
}
/**
* 保存信息方法
* 建议根据你的需求重写此方法
* Power: Mikkle
* Email：776329498@qq.com
* @return bool
*/
protected function saveWeMessage()
{
return true;
}
/**
* 获取用户信息
* 建议根据你的需求重写此方法
* Power: Mikkle
* Email：776329498@qq.com
* @param string $openid
* @return array|bool
*/
protected function hasSaveFans($openid = '')
{
try {
$openid = $openid ?: $this->openid;
if (empty($openid)) {
return false;
}
$fans = $this->weObj->getUserInfo($openid);
return $fans;
} catch (Exception $e) {
Log::error($e);
return false;
}
}
/**
* 调试内容给客户端
* Power: Mikkle
* Email：776329498@qq.com
* @param $value
*/
protected function we_dump($value)
{
ob_start();
var_dump($value);
$back = ob_get_clean();
$this->weObj->text($back)->reply();
ob_end_flush();
die;
return;
}
}
~~~
- 序言及更新日志
- 前言一 开发PHP必备的环境(你可以不看)
- LinUX系统ThinkPHP5链接MsSQL数据库的pdo_dblib扩展
- centos7.2挂载硬盘攻略
- Centos系统Redis安装及Redis的PHP扩展安装
- Centos系统增加Swap(系统交换区)的方法
- 前言二 开发PHP软件配置和介绍(你依然可以不看)
- 数据库SQL文件
- 本地Git(版本控制)的搭建
- GIT远程仓库的克隆和推送
- Git常用命令
- PHP面向对象思想实战经验领悟
- PHP面向对象实战----命名空间
- PHP面向对象实战----继承
- 基类实战--底层方法封装
- 基类实战--构造函数实战
- 基类实战--析构函数的使用
- TP5实战开发前篇---控制器(controller)
- 控制器中Request类的使用
- 控制器中基类的使用
- TP5实战开发前篇---模型篇(model)
- TP5实战开发前篇---验证器篇(Validate)
- TP5实战课程入门篇---花拳绣腿
- 模块以及类的文件的建立
- Api开发------单条信息显示
- Api开发---单条信息复杂关联显示
- Api开发---查询信息缓存Cache的应用
- TP5实战技巧---开发思路 引路造桥
- TP5实战技巧---整合基类 化繁为简
- TP5实战课程入门篇---数据操作
- Api开发---数据的添加和修改
- API开发---快速开发API通用接口
- TP5专用微信sdk使用教程
- THINKPHP5微信SDK更新记录及升级指导
- TP5专用SDK 微信参数配置方法
- 微信公众号推送接口对接教程
- 微信推送接口对接示例含扫描登录微信端部分
- TP5专用微信支付SDK使用简介
- TP5专用支付宝支付SDK使用说明
- 使用NW将开发的网站打包成桌面应用
- TP5高阶实战课程 进阶篇概述
- 进阶篇一 实战开发之习惯及要求
- 进阶篇二 实战开发之控制器
- 控制器基类之控制器基类使用方法
- 控制器基类之控制器基类常用方法分享
- 控制器基类之构造函数的使用方法
- 进阶篇三 实战开发之权限控制
- TP5实战源码 --- 全局用户信息验证类Auth
- TP5实战源码 --- 微信Auth实战开发源码
- 进阶篇四 实战开发之模型
- 模型基类之模型基类的用途
- 模型基类之常用数据处理方法
- 模型逻辑层之实战代码(含事务)
- 模型实战开发之模型常用方法
- 模型实战源码 --- 乐观锁的应用
- 模型实战技巧---Model事件功能的使用
- 模型事件实战应用---数据库操作日志
- 进阶篇五 实战开发之缓存(Cache)
- TP5实战源码---应用缓存获取城市信息
- TP5实战源码---应用缓存获取分类详情
- 进阶篇六 TP5类库的封装和使用
- DataEdit快捷操作类库
- ShowCode快捷使用类库
- 阿里大于 短信API接口 TP5专用类库
- DatabaseUpgrade数据库对比及更新类库
- AuthWeb权限类使用说明
- 进阶篇七 服务层的应用
- 服务层源码示例
- 服务层基类源码
- 进阶篇八 应用层Redis数据处理基类
- Redis服务层基类源码
- 进阶篇九 使用Redis类库处理一般的抢购(秒杀)活动示例
- 进阶篇十 某大型项目应用本Redis类源码示例(含事务 乐观锁)
- 进阶篇十一 逻辑层的应用
- 逻辑层基类源码
- 进阶篇 服务层代码示例
- 高阶实战课程 进阶篇持续新增中
- 高阶篇一 TP5命令行之守护任务源码
- TP5实战源码 --- 命令行
- TP5实战源码 --- 通过shell建立PHP守护程序
- 高阶篇二 使用Redis队列发送微信模版消息
- 高阶篇二 之 Worker队列基类源码
- 高阶篇三 TP5实战之Redis缓存应用
- Redis实战源码之Hash专用类库源码
- Redis实战源码之Model类结合
- Redis实战源码之模型Hash基类源码
- Redis实战源码之Hash查询使用技巧
- Redis实战源码之 shell脚本中redis赋值和取值
- 高阶篇四 Swoole的实战应用
- swoole基类代码
- Swoole扩展WebsocketServer专用类
- 基于Swoole的多Room聊天室的程序
- Swoole守护服务shell源码
- 高阶篇五 命令行异步多进程队列类的应用
- tp_worker类源码
- WorkerBase
- WorkerCommand
- WorkerRedis
- Redis类
- CycleWorkBase
- WorkerHookBase异步钩子
- 队列日志SQL
- 高阶篇六 定时执行队列类库以及使用方法
- 定时队列类库源码
- 高阶篇七 异步执行循环队列类库以及使用教程
- CycleWorkBase源码
- 高阶实战课程 进阶篇持续新增中
- Extend便捷类库源码库
- 阿里相关类库
- SendSms--验证码API接口文件
- 权限相关类库目录
- AuthWeb 权限验证类库
- Redis便捷操作类库(20171224更新)
- Redis
- Tools工具类库集
- Curl类库
- DataEdit
- Rand类库
- ShowCode类库
- Upload类库
- 附件集合
- 附件一:微信支付 实战开发源码
- 微信支付类库源代码
- Common_util_pub.php
- DownloadBill_pub.php
- JsApi_pub.php
- NativeCall_pub.php
- NativeLink_pub.php
- OrderQuery_pub.php
- Refund_pub.php
- RefundQuery_pub.php
- SDKRuntimeException.php
- ShortUrl_pub.php
- UnifiedOrder_pub.php
- Wxpay_client_pub.php
- Wxpay_server_pub.php
- WxPayConf_pub.php
- 微信支付回调页面源码
- 附件二 顺丰快递BSP接口实战开发源码
- 顺丰快递BSP接口实战开发源码
- 顺丰BSP基类
- 顺丰BSP基础代码
- 顺丰BSP下单接口
- 顺丰BSP查单接口
- 顺丰BSP确认/取消接口
- 附件三 APP注册登陆接口源码(含融云平台接口)
- 附件四 TP5订单Model(含事务 获取器 修改器等方法)
- 附录五 RSA加密解密
- Rsa文件源码
- 附件六 阿里大于短信接口
- 附件七 AES加解密类
- AES加解密类源码
- 附件八 TP5路由设置源码
- 附件九 TP5 Excel导入导出下载便捷类库
- Excel类库TP5源码
- 附件十 TP5便捷操作Redis类库源码
- TP5源码 Redis操作便捷类库
- 附件十一 TP5源码 上传文件入库类源码
- 上传类Upload源码
- Upload类上传配置文件
- 存储图像文件的数据库SQL文件
- 存储文件的数据库SQL文件
- 附件十二 TP5 图片处理增强类 支持缩略图在线显示
- 附件十三 微信推送消息接口类库源码
- 附件十三 微信推送消息接口类库源码 之 基类
- 附件十四 存储微信昵称的处理方法