ThinkPHP微信公众号对接实现方案-快速集成与开发指南

ThinkPHP 是一款流行的 PHP 框架，用于快速开发 Web 应用程序。将 ThinkPHP 与微信公众号对接，可以实现自动回复、菜单管理、消息推送等功能。以下是实现对接的详细步骤和注意事项：

一、准备工作

注册微信公众号
- 登录微信公众平台注册账号。
- 获取 AppID 和 AppSecret，用于接口调用。
服务器环境
- 确保服务器支持 PHP，并安装 ThinkPHP 框架。
- 配置域名（需为 HTTPS），并在微信公众号后台的“开发”->“基本配置”中设置服务器地址（URL）。
开发前知识
- 熟悉微信公众号的开发文档（官方文档）。
- 了解微信消息交互流程（XML 格式请求与响应）。

二、对接步骤

1. 配置服务器地址

在微信公众号后台的“开发”->“基本配置”中：
- 填写服务器地址（URL），例如：https://yourdomain.com/wechat
- 填写令牌（Token），用于验证服务器。
- 选择消息加解密方式（推荐“明文模式”或“兼容模式”）。

2. 验证服务器有效性

微信服务器会通过 GET 请求验证你的服务器。
在 ThinkPHP 中创建一个控制器（如 WechatController），处理验证逻辑：

namespace app\controller;

use think\facade\Request;

class WechatController
{
    public function index()
    {
        $token = 'your_token'; // 与微信公众号后台配置的 Token 一致
        $signature = Request::get('signature');
        $timestamp = Request::get('timestamp');
        $nonce = Request::get('nonce');
        $echostr = Request::get('echostr');

        // 验证签名
        $tmpArr = [$token, $timestamp, $nonce];
        sort($tmpArr, SORT_STRING);
        $tmpStr = implode($tmpArr);
        $tmpStr = sha1($tmpStr);

        if ($tmpStr == $signature) {
            return $echostr; // 验证成功，返回 echostr
        } else {
            return 'Invalid request';
        }
    }
}

配置路由，将 /wechat 指向 WechatController@index。

3. 接收并处理用户消息

微信服务器会以 POST 请求发送用户消息（XML 格式）。
在控制器中添加处理逻辑：

public function handleMessage()
{
    // 获取 XML 数据
    $xml = file_get_contents("php://input");
    if (empty($xml)) {
        return 'Invalid request';
    }

    // 将 XML 转换为数组
    libxml_disable_entity_loader(true);
    $data = json_decode(json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true);

    // 根据消息类型处理
    $fromUser = $data['FromUserName'];
    $toUser = $data['ToUserName'];
    $msgType = $data['MsgType'];

    $response = '';
    if ($msgType == 'text') {
        $content = $data['Content'];
        // 自动回复
        $response = [
            'ToUserName' => $fromUser,
            'FromUserName' => $toUser,
            'CreateTime' => time(),
            'MsgType' => 'text',
            'Content' => '你发送了：' . $content,
        ];
    } else {
        $response = [
            'ToUserName' => $fromUser,
            'FromUserName' => $toUser,
            'CreateTime' => time(),
            'MsgType' => 'text',
            'Content' => '暂不支持该类型消息',
        ];
    }

    // 将数组转换为 XML 并返回
    $xmlResponse = $this->arrayToXml($response);
    return response($xmlResponse, 200, ['Content-Type' => 'application/xml']);
}

private function arrayToXml($data)
{
    $xml = '<xml>';
    foreach ($data as $key => $value) {
        $xml .= "<$key><![CDATA[$value]]></$key>";
    }
    $xml .= '</xml>';
    return $xml;
}

配置路由，将 /wechat 的 POST 请求指向 WechatController@handleMessage。

4. 自定义菜单（可选）

使用微信公众号提供的接口创建自定义菜单。
示例代码（需获取 access_token）：

public function createMenu()
{
    $accessToken = $this->getAccessToken(); // 获取 access_token 的方法
    $url = "https://api.weixin.qq.com/cgi-bin/menu/create?access_token=$accessToken";

    $menuData = [
        'button' => [
            [
                'type' => 'click',
                'name' => '今日歌曲',
                'key' => 'V1001_TODAY_MUSIC',
            ],
            [
                'name' => '菜单',
                'sub_button' => [
                    [
                        'type' => 'view',
                        'name' => '搜索',
                        'url' => 'http://www.soso.com/',
                    ],
                    [
                        'type' => 'click',
                        'name' => '赞一下我们',
                        'key' => 'V1001_GOOD',
                    ],
                ],
            ],
        ],
    ];

    $result = $this->httpPost($url, json_encode($menuData, JSON_UNESCAPED_UNICODE));
    return $result;
}

private function httpPost($url, $data)
{
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($ch, CURLOPT_POST, 1);
    curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
    $output = curl_exec($ch);
    curl_close($ch);
    return $output;
}