Laravel + EasyWechat开发公众号，常用功能记录，入口代码优化，希望小伙伴提出更好的解决方案和思路。

$this->server->push(TextMessageHandler::class, Message::TEXT);   // 粉丝文本
$this->server->push(EventMessageHandler::class, Message::EVENT); // 粉丝事件
$this->server->push(ImageMessageHandler::class, Message::IMAGE); // 粉丝发图片
$this->server->push(VoiceMessageHandler::class, Message::VOICE); // 粉丝发语音
$this->server->push(VideoMessageHandler::class, Message::VIDEO); // 粉丝发视频
$this->server->push(LocationMessageHandler::class, Message::LOCATION); // 粉丝发坐标
$this->server->push(LinkMessageHandler::class, Message::LINK); // 粉丝发链接
$this->server->push(FileMessageHandler::class, Message::FILE); // 粉丝发文件Copy

    public function serve(Request $request)
    {
        $config = [
            'app_id' => env('XTSDYH_WXAPP_APP_ID'),
            'secret' => env('XTSDYH_WXAPP_SECRET'),

            'token' => 'easywechat',          // Token
            'aes_key' => '2OCyK9OLpUYdEhKPEwLhIwvX3GkEaWUoAjdWRoDhIpB',                    // EncodingAESKey，兼容与安全模式下请一定要填写！
//            'log' => [
//                'level' => 'debug',
//                'file' => '/tmp/easywechat.log',
//            ],
        ];
        $app = Factory::officialAccount($config);
        $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;
            }
//            return "您好！欢迎使用 EasyWeChat!";
        });

        $response = $app->server->serve();
//        $response->send(); // Laravel 里请使用：return $response;
        return $response;
//        $this->logic->serve($request);
    }Copy

[2022-07-13T18:38:32.274379+08:00] EasyWeChat.EMERGENCY: Unable to create configured logger. Using emergency logger. {"exception":"[object] (InvalidArgumentException(code: 0): Log [] is not defined. at /www/wwwroot/xg-laravel/vendor/overtrue/wechat/src/Kernel/Log/LogManager.php:161)Copy

<?php

namespace App\Http\Services;

use App\Enums\LogEnum;
use EasyWeChat\OfficialAccount\Application;
use Illuminate\Support\Str;
use Overtrue\LaravelWeChat\EasyWeChat;
use Psr\Http\Message\ResponseInterface;

class Wechat
{
    private Application $app;
    private string $openid;

    public function __construct()
    {
        $this->app = EasyWeChat::officialAccount();
    }

    public function getApp(): Application
    {
        return $this->app;
    }

    public function serve(): ResponseInterface
    {
        $server = $this->app->getServer();
        $server->with(function ($message, \Closure $next) {
            LogChannel::wechat()->info(LogEnum::INFO_WECHAT_SERVE, ['wechatMessage' => $message]);
            $this->openid = $message['FromUserName'];
            $method = $message['MsgType'];
            return match ($method) {
                'event' => $this->event($message),
                'text' => $this->text($message),
                default => $next($message),
            };
        });
        return $server->serve();
    }

    // 事件
    private function event($message): array|string|null
    {
        $event = $message['Event'];
        return match ($event) {
            'subscribe' => $this->eventSubscribe($message),
            'unsubscribe' => $this->eventUnSubscribe($message),
            'SCAN' => $this->eventScan($message),
            default => ''
        };
    }

    // 文本
    private function text($message): string|array|null
    {
        return '文本消息';
    }

    // 订阅
    private function eventSubscribe($message): string|array|null
    {
        // 带参数二维码订阅兼容
        $code = Str::replace('qrscene_', '', $message['EventKey']);
        return '欢迎订阅';
    }


    // 取消订阅
    private function eventUnSubscribe($message): string|array|null
    {
        return '取消订阅';
    }

    // 扫描带参二维码
    private function eventScan($message): string|array|null
    {
        $code = $message['EventKey'];
        return '扫码';
    }
}Copy

<?php

namespace App\Http\Controllers;

use App\Http\Services\Wechat;
use Psr\Http\Message\ResponseInterface;
use Throwable;

class WechatController extends Controller
{
    private Wechat $easyWechat;

    public function __construct()
    {
        parent::__construct();
        $this->easyWechat = new Wechat();
    }

    /**
     *
     * @return ResponseInterface|void
     */
    public function serve()
    {
        try {
            return $this->easyWechat->serve();
        } catch (Throwable $e) {
        }
    }
}
Copy

<?php

namespace App\Services;

use EasyWeChat\Factory;
use EasyWeChat\Kernel\Messages\News;
use EasyWeChat\Kernel\Messages\NewsItem;
use EasyWeChat\Kernel\Messages\Text;

class WeChatReplayService
{
    protected $oApp;
    public function __construct()
    {
        $this->oApp = Factory::officialAccount(config('wechat.official_account.default'));
    }


    /**
     * 文本消息
     * @param $sOpenId
     * @param $sMsg
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
     * @throws \EasyWeChat\Kernel\Exceptions\RuntimeException
     */
    public function text($sOpenId,$sMsg){
        $this->oApp->customer_service->message(new Text($sMsg))->to($sOpenId)->send();
    }

    /**
     * 创建图文单项
     * @param $sTitle
     * @param $sDescription
     * @param $sLink
     * @param $sCoverImg
     * @return NewsItem
     */
    public function imgTextItem($sTitle, $sDescription, $sLink,$sCoverImg){
        return  new NewsItem([
            'title' => $sTitle,
            'description' => $sDescription,
            'url' => $sLink,
            'image' =>  $sCoverImg
        ]);
    }

    /**
     * 图文消息
     * @param $sOpenId
     * @param $imgTextItem
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidArgumentException
     * @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
     * @throws \EasyWeChat\Kernel\Exceptions\RuntimeException
     */
    public function imageText( $sOpenId, $imgTextItem){

        $items = [];
        if(is_object($imgTextItem)){
            $items[] = $imgTextItem;
        }
        if(is_array($imgTextItem)){
            $items = $imgTextItem;
        }
        $this->oApp->customer_service->message(new News($items))->to($sOpenId)->send();
    }
}
Copy

    public function reply(){
        $oApp = Factory::officialAccount(config('wechat.official_account.default'));
        $server = $oApp->getServer();

        // 使用回调作为中间件
        $server->with(function($oMsg, \Closure $next) {
                // 你的自定义逻辑1
                return $next($oMsg);
            });
        // 创建独立的类作为中间件
        $server->with(MyCustomHandler::class);


        return $oApp->server->serve();
    }Copy

<?php


namespace App\WechatRePly;


class MyCustomHandler
{
    public function __invoke($oMsg, \Closure $next)
    {
        //  处理回复逻辑
        if ($oMsg->MsgType === 'text') {
            //...
        }

        return $next($oMsg);
    }
}Copy