admin_consumer/app/Middleware/Auth/SensitiveMiddleware.php

<?php

declare(strict_types=1);

namespace App\Middleware\Auth;

use App\Tools\PublicData;
use Hyperf\HttpServer\Contract\RequestInterface;
use Hyperf\HttpServer\Contract\ResponseInterface as HttpResponse;
use Psr\Container\ContainerInterface;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;
use Hyperf\HttpMessage\Stream\SwooleStream;
use Hyperf\Di\Annotation\Inject;
use Hyperf\Redis\Redis;
//use Swoole\Http\Request;
class SensitiveMiddleware implements MiddlewareInterface
{
    protected ContainerInterface $container;

    protected RequestInterface $request;

    protected HttpResponse $response;
    #[Inject]
    protected Redis $redis;
    const STREAM_URL = [
        '/news/addArticle',
        '/news/updateArticle'
    ];
    public function __construct( RequestInterface $request, HttpResponse $response)
    {
        $this->request = $request;
        $this->response = $response;
    }

    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $uri = $request->getUri();
        // 获取接口路径（不包含查询参数）
        $path = $uri->getPath();
        try {
            if($path && in_array($path,self::STREAM_URL)){
                $badWords = $this->redis->sMembers('black_word'); //黑名单
                $whiteWords = $this->redis->sMembers('white_word');//白名单
                // 获取所有请求参数并拼接成文本
                $params = $this->request->all();
                $concatenated = "";
                if($params){
                    foreach ($params as $value) {
                        if (is_array($value)) {
                            // 如果值是数组，将数组元素用逗号连接
                            $concatenated.= json_encode($value);
                        } else {
                            // 如果不是数组，直接拼接
                            $concatenated.= $value;
                        }
                    }
                }
                // 遍历违禁词，检查是否在文本中存在
                foreach ($badWords as $badWord) {
                    // 判断该违禁词是否在白名单中，如果在则跳过
                    if (in_array($badWord, $whiteWords)) {
                        continue;
                    }
                    if (str_contains($concatenated, $badWord)) {
                        // 处理找到违禁词的情况，例如返回错误信息
                        $message = '发现违禁词: '. $badWord;
                        return $this->response->json(
                            [
                                'code' => 0,
                                'data' => [],
                                'message' => $message
                            ]
                        );
                    }
                }
            }else{
                return $handler->handle($request);
            }
        }catch (\Exception $e){
            var_dump("错误消息：",$e->getMessage(),$e->getCode());
            return $handler->handle($request);
        }
        return false;
    }
}