PHP自定义类示例(Weixin消息解析类)

技术文档网 2021-04-15

PHP自定义类示例(Weixin消息解析类)

/**
 * Created by Qingger.
 * User: jsspf
 * Date: 2017/3/24
 * Time: 10:50
 */

namespace App\Service;

use App\Exception\TPException;
use App\Library\VarDefines\GlobalErrCode;

/**
 * 微信公众号消息的接收与回复
 * @desc : 消息加解密指引参考 https://open.weixin.qq.com/cgi-bin/showdocument?action=dir_list&t=resource/res_list&verify=1&id=open1419318611&lang=zh_CN
 * Class WXMPEventMessageParser
 * @package App\Services\WeixinFunc
 */
class WeixinMPEventMessageParser extends WeixinBaseFuncService
{

    /**
     * @var object
     * 接收消息的消息体结构 (text | image | voice | video | shortvideo | location | link)
     */
    private $_messageReceiveBody = null;

    /**
     * @var string
     * 接收消息的发送方帐号
     */
    private $_messageReceiveFrom = null;

    /**
     * @var string
     * 接收消息的接收方帐号
     */
    private $_messageReceiveTo   = null;

    /**
     * @var string
     * 接收消息的消息体类型 (text | image | voice | video | shortvideo | location | link)
     */
    private $_messageReceiveType = null;


    /**
     * @var string
     * 接收消息时,Request请求中的nonce信息
     */
    private $_messageNonce = '';

    /**
     * @var WXBizMsgCrypt
     * 微信消息体加解密对象
     */
    private $_wxBizMsgCrypt = null;

   /**
     * @var array
     * 公众号消息回复的模板
     */
    private $_replyMessageTemplate = [
        // 文本消息的回复模板
        'text'  => "<xml>
                    <ToUserName><![CDATA[%s]]></ToUserName>
                    <FromUserName><![CDATA[%s]]></FromUserName>
                    <CreateTime>%s</CreateTime>
                    <MsgType><![CDATA[text]]></MsgType>
                    <Content><![CDATA[%s]]></Content>
                    </xml>",

        // 图片消息的回复模板
        'image' => "<xml>
                    <ToUserName><![CDATA[%s]]></ToUserName>
                    <FromUserName><![CDATA[%s]]></FromUserName>
                    <CreateTime>%s</CreateTime>
                    <MsgType><![CDATA[image]]></MsgType>
                    <Image><MediaId><![CDATA[%s]]></MediaId></Image>
                    </xml>",
    ];


    public function __construct($tpSuiteName,$messageNonce='')
    {
        parent::__construct();
        $this->_messageNonce     = $messageNonce;
        $this->_wxBizMsgCrypt = new WXBizMsgCrypt(
            $this->getWxTpConfigParser()->getConfigToken($tpSuiteName),
            $this->getWxTpConfigParser()->getConfigEncodingAesKey($tpSuiteName),
            $this->getWxTpConfigParser()->getConfigId($tpSuiteName)
        );
    }

    /**
     * 对消息体进行微信的加密
     * @param $replyMsgStr
     * @return string
     */
    private function _encryptMessage($replyMsgStr) {
        $replyMessageEncrypt = '';
        $this->_wxBizMsgCrypt->encryptMsg($replyMsgStr,time(),$this->_messageNonce,$replyMessageEncrypt);
        return $replyMessageEncrypt;
    }

    /**
     * 生成文本消息的回复结构
     * @param $content
     * @return string
     */
    public function textMessageReply($content) {
        $replyMessageType = 'text';
        $replyMsgStr = sprintf($this->_replyMessageTemplate[$replyMessageType],
            $this->_messageReceiveFrom,
            $this->_messageReceiveTo,
            time(),
            $content);
        return $this->_encryptMessage($replyMsgStr);
    }

    /**
     * 生成图片消息的回复
     * @param $imageMediaId
     * @return string
     */
    public function imageMessageReply($imageMediaId) {
        $replyMessageType = 'image';
        $replyMsgStr = sprintf($this->_replyMessageTemplate[$replyMessageType],
            $this->_messageReceiveFrom,
            $this->_messageReceiveTo,
            time(),
            $imageMediaId);
        return $this->_encryptMessage($replyMsgStr);
    }

    /**
     * Todo : 需要实现,使用XML对象操作字符串模板
     * 生成音乐消息的回复
     * @param array $musicInfo
     * [
     *      'title'         : 标题 / 可选
     *      'description'   : 描述 / 可选
     *      'musicURL'      : 音乐链接 / 可选
     *      'hqMusicUrl'    : 高质量音乐链接,WIFI环境优先使用该链接播放音乐 / 可选
     *      'ThumbMediaId'  : 缩略图的媒体id,通过素材管理接口上传多媒体文件,得到的id / 可选
     *  ]
     * @throws TPException
     * @return string
     */
    public function musicMessageReply(array $musicInfo) {
        throw new TPException('Music Message Reply Not Support',GlobalErrCode::ERR_FUNCTION_NOT_IMPLEMENT);
    }

    /**
     * 解析Weixin Message消息,并根据相应的消息,进行回复
     * @desc 具体解密参考:https://open.weixin.qq.com/cgi-bin/showdocument?action=dir_list&t=resource/res_list&verify=1&id=open1419318479&lang=zh_CN
     * @param $messageEventObj
     * @param Closure $doEvent
     * @return mixed
     * @throws TPException
     */
    public function parseEvent($messageEventObj,Closure $doEvent) {
        if(isset($messageEventObj->MsgType)) {
            $this->_messageReceiveBody   = $messageEventObj;
            $this->_messageReceiveFrom   = isset($messageEventObj->FromUserName)?$messageEventObj->FromUserName:null;
            $this->_messageReceiveTo     = isset($messageEventObj->ToUserName)?$messageEventObj->ToUserName:null;
            $this->_messageReceiveType   = $messageEventObj->MsgType;

            $messageReply = $doEvent($messageEventObj);

            return $messageReply;
        } else {
            throw new TPException('MP Message Body Parse Error',GlobalErrCode::ERR_WEIXIN_MESSAGE_INFO_ERROR);
        }


}

相关文章

  1. 如何通过xhprof分析性能

    使用方法 xhprof_enable(); /** ... 要检查的php代码 ... **/ $xhprof_data = xhprof_disable(); // 引入xhprof_lib i

  2. LUMEN API Controller 规范

    1. 第三方依赖库规范 在使用LUMEN实现API接口时,以下库必须需要包含在composer包依赖中,以实现代码编写的一些规范 dingo/api : 实现API接口库 vlucas/phpdo

  3. PHP文件锁

    共享锁(LOCK_SH) 什么时候加共享锁? 当在读取数据的时候同时进行着其他的写操作,这个时候需要对文件加共享锁,否则无论有没有对写操作加写锁都会写入成功,导致数据不一致 当文件获得共享锁时,其他

  4. Hello-Risen-程序

    首先需要说明的是,您下载到的文件包含两部分,其中src中是开发源码,用于对Risen框架本身的开发,risen 目录中是通过源码生成的包含debug和release版本的框架程序,用于您应用程序的开发

  5. PHP自定义类示例(Weixin消息解析类)

    PHP自定义类示例(Weixin消息解析类) /** * Created by Qingger. * User: jsspf * Date: 2017/3/24 * Time: 10:50

随机推荐

  1. 如何通过xhprof分析性能

    使用方法 xhprof_enable(); /** ... 要检查的php代码 ... **/ $xhprof_data = xhprof_disable(); // 引入xhprof_lib i

  2. LUMEN API Controller 规范

    1. 第三方依赖库规范 在使用LUMEN实现API接口时,以下库必须需要包含在composer包依赖中,以实现代码编写的一些规范 dingo/api : 实现API接口库 vlucas/phpdo

  3. PHP文件锁

    共享锁(LOCK_SH) 什么时候加共享锁? 当在读取数据的时候同时进行着其他的写操作,这个时候需要对文件加共享锁,否则无论有没有对写操作加写锁都会写入成功,导致数据不一致 当文件获得共享锁时,其他

  4. Hello-Risen-程序

    首先需要说明的是,您下载到的文件包含两部分,其中src中是开发源码,用于对Risen框架本身的开发,risen 目录中是通过源码生成的包含debug和release版本的框架程序,用于您应用程序的开发

  5. PHP自定义类示例(Weixin消息解析类)

    PHP自定义类示例(Weixin消息解析类) /** * Created by Qingger. * User: jsspf * Date: 2017/3/24 * Time: 10:50