chatroom/app/Console/Commands/ConsumeWechatMessages.php

<?php

/**
 * 文件功能：微信机器人 Kafka 消费命令
 *
 * @author   ChatRoom Laravel
 *
 * @version  1.0.0
 */

namespace App\Console\Commands;

use App\Models\User;
use App\Services\WechatBot\KafkaConsumerService;
use App\Services\WechatBot\WechatBotApiService;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Log;

class ConsumeWechatMessages extends Command
{
    /**
     * @var string
     */
    protected $signature = 'wechat-bot:consume';

    /**
     * @var string
     */
    protected $description = '消费 Kafka 微信机器人消息（守护进程）';

    protected KafkaConsumerService $kafkaService;

    public function __construct(KafkaConsumerService $kafkaService)
    {
        parent::__construct();
        $this->kafkaService = $kafkaService;
    }

    public function handle(): int
    {
        $this->info('正在启动微信机器人 Kafka 消费者...');

        $consumer = $this->kafkaService->createConsumer();
        if (! $consumer) {
            $this->error('Kafka 配置不完整或加载失败，请在后台检查机器人设置。');

            return self::FAILURE;
        }

        $this->info('消费者已启动，等待消息...');

        $apiService = new WechatBotApiService;

        while (true) {
            try {
                $messageJson = $consumer->consume();
                if ($messageJson) {
                    $rawJson = $messageJson->getValue();
                    $this->info('--> 收到新的 Kafka 消息 (Raw Length: '.strlen($rawJson).')');

                    $messages = $this->kafkaService->parseKafkaMessage($rawJson);

                    if (empty($messages)) {
                        $this->info('--> 解析后：无匹配的 AddMsgs 内容');
                    }

                    foreach ($messages as $msg) {
                        try {
                            $this->processMessage($msg, $apiService);
                        } catch (\Exception $e) {
                            Log::error('处理单条微信消息失败', [
                                'error' => $e->getMessage(),
                                'msg' => $msg,
                            ]);
                        }
                    }

                    $consumer->ack($messageJson);
                }
            } catch (\Exception $e) {
                Log::error('Kafka 消费异常', ['error' => $e->getMessage()]);
                // 延迟重试避免死循环 CPU 空转
                sleep(2);
            }
        }

        return self::SUCCESS;
    }

    /**
     * 处理单条消息逻辑
     */
    protected function processMessage(array $msg, WechatBotApiService $apiService): void
    {
        // 仅处理文本消息 (msg_type = 1)
        if ($msg['msg_type'] != 1) {
            return;
        }

        $content = trim($msg['content']);
        $fromUser = $msg['from_user'];
        $isChatroom = $msg['is_chatroom'];

        // 绑定逻辑：必须是私聊（防止在群内绑定导致未来系统无法直接通过私聊推送个人通知）
        if (! $isChatroom && preg_match('/^BD-\d{6}$/i', $content)) {
            $this->info("收到潜在绑定请求: {$content} from {$fromUser}");
            $this->handleBindRequest(strtoupper($content), $fromUser, $apiService);
        }

        // 微信密码重置逻辑：必须是私聊
        if (! $isChatroom && str_contains($content, '重置密码')) {
            $this->info("收到微信密码重置请求 from {$fromUser}");
            $this->handlePasswordResetRequest($fromUser, $apiService);
        }
    }

    /**
     * 处理微信端的自助密码重置请求
     */
    protected function handlePasswordResetRequest(string $wxid, WechatBotApiService $apiService): void
    {
        // 检索绑定了该微信号的聊天室用户
        $user = User::where('wxid', $wxid)->first();

        if (! $user) {
            $apiService->sendTextMessage(
                $wxid,
                "❌ 密码重置失败：您当前的微信号尚未绑定任何聊天室账号。\n\n"
                .'请先登录聊天室大厅，在个人设置中获取 6 位绑定码，然后再在微信中向我发送“BD-绑定码”（例如: BD-123456）进行绑定。'
            );

            return;
        }

        // 随机生成 8 位新随机密码并更新
        $newPassword = \Illuminate\Support\Str::random(8);
        $user->password = \Illuminate\Support\Facades\Hash::make($newPassword);
        $user->save();

        $successMsg = "🎉 密码重置成功！\n"
                    ."本小助手已为您绑定的聊天室账号 [{$user->username}] 重新生成了密码：\n\n"
                    ."【{$newPassword}】\n\n"
                    .'温馨提示：请使用此随机密码登录聊天室，并尽快在个人偏好设置中将其修改为您的常用密码。';

        $apiService->sendTextMessage($wxid, $successMsg);
        $this->info("微信用户 [{$user->username}] 已通过微信机器人成功重置了密码");
    }

    /**
     * 处理账号绑定请求
     */
    protected function handleBindRequest(string $code, string $wxid, WechatBotApiService $apiService): void
    {
        $cacheKey = 'wechat_bind_code:'.$code;
        $username = Cache::get($cacheKey);

        if (! $username) {
            $apiService->sendTextMessage($wxid, '❌ 绑定失败：该验证码无效或已过有效期（5分钟）。请在个人中心重新生成。');

            return;
        }

        $user = User::where('username', $username)->first();
        if (! $user) {
            $apiService->sendTextMessage($wxid, '❌ 绑定失败：找不到对应的用户账号。');

            return;
        }

        // 判断该微信号是否已经被其他用户绑定（防止碰撞或安全隐患）
        $existing = User::where('wxid', $wxid)->where('id', '!=', $user->id)->first();
        if ($existing) {
            $apiService->sendTextMessage($wxid, "❌ 绑定失败：当前微信号已经被其他账号 [{$existing->username}] 绑定。请先解绑后再试。");

            return;
        }

        $user->wxid = $wxid;
        $user->save();

        // 验证成功后立即销毁验证码
        Cache::forget($cacheKey);

        $this->info("用户 [{$username}] 成功绑定微信: {$wxid}");

        $successMsg = "🎉 绑定成功！\n"
                    ."您已成功绑定聊天室账号：[{$username}]。\n"
                    .'现在您可以接收重要系统通知了。';

        $apiService->sendTextMessage($wxid, $successMsg);
    }
}