tp5-微信消息接收和處理

微信后台只能填寫一個服務器地址，所以 服務器驗證 與 消息的接收與回復，都在這一個鏈接內完成交互。

一、服務器驗證：配置地址可寫為：http://域名/openapi/wechat/wxapi

<?php

namespace Openapi;

use Api\Base;
use EasyWeChat\Factory;
use Wechat\OfficialAccount;

class Wechat extends Base
{
    var $wx_config = null;

    public function wxapi()
    {
        try {
            $wx_config = $this->config->wechat->toArray();
            $app = Factory::officialAccount($wx_config);
            $log = $this->logger;
            $redis = $this->redisDb;
            $app->server->push(function ($message) use ($app, $log, $redis) { //消息接收 $openid = $message['FromUserName']; //微信用戶信息
                $user = $app->user->get($openid); $log->info(json_encode($message)); $official_account = new OfficialAccount(); $official_account->replyMessage($message,$user); }); $response = $app->server->serve();
            $response->send();

        } catch (\Exception $e) {
            $this->logw($e->getMessage());
        }
    }
}

 

二、消息處理

<?php
namespace Wechat;

use Component\Wechat\Wechat;
use Phalcon\Di;
use Mvc\DbFilter;

class OfficialAccount{

public function replyMessage($message ,$data){
        switch ($message['MsgType']) {
            case 'event':
                switch ($message['Event']) {
                    case 'subscribe':
                        $restaurant_id = 0;
                        $restaurant_str = $message['EventKey'];
                        ....
                        //業務邏輯處理
                        break;
                    case 'unsubscribe':
                        //取消關注return "您已取消關注";
                        break;
                    case 'SCAN':
                        if ($message['EventKey']) {
                            $restaurant_id = 0;
                            $restaurant_arr = explode('_', $message['EventKey']);
                           ......
                        break;
                }
                return '歡迎關注';
                break;
            case 'text':
                return '收到，但是目前沒有接下來的動作';
                break;
            default:
                return '收到其它消息';
                break;
        }
    }
}

 三、demo

$app->server->push(function ($message) {
    switch ($message['MsgType']) {
        case 'event':
            return '收到事件消息';
            break;
        case 'text':
            return '收到文字消息';
            break;
        case 'image':
            return '收到圖片消息';
            break;
        case 'voice':
            return '收到語音消息';
            break;
        case 'video':
            return '收到視頻消息';
            break;
        case 'location':
            return '收到坐標消息';
            break;
        case 'link':
            return '收到鏈接消息';
            break;
        case 'file':
            return '收到文件消息';
        // ... 其它消息
        default:
            return '收到其它消息';
            break;
    }

    // ...
});