ai_suggested_keywords是keyword1，keyword2，权重是priority，你都忘记了咱俩的设计了吗？我把sql文件再给你提供一次，请你仔细思考，省的我一次次给你补充背景信息。然后你再重写编码。

答：

public static function getKeywordsByOrg($orgId)
{
    return self::find()
        ->select(['id', 'keyword1', 'keyword2', 'answer_id'])
        ->where(['org_id' => $orgId])
        ->orderBy(['priority' => SORT_DESC])
        ->asArray()
        ->all();
}

public function actionSuggestedKeywords()
{
    $orgId = Yii::$app->request->get('org_id');
    if (!$orgId) {
        return ErrorCode::wsReturnData('缺少 org_id 参数', 0);
    }

    $data = AiSuggestedKeywords::getKeywordsByOrg($orgId);
    return ErrorCode::wsReturnData($data, 1);
}

namespace console\controllers;

use Yii;
use yii\console\Controller;
use PhpOffice\PhpSpreadsheet\IOFactory;
use app\modules\api\modules\v1\models\AiSuggestedKeywords;

class ImportSuggestedKeywordController extends Controller
{
    public function actionExcel($file, $orgId)
    {
        $spreadsheet = IOFactory::load($file);
        $sheet = $spreadsheet->getActiveSheet();
        $rows = $sheet->toArray();

        $count = 0;
        foreach ($rows as $index => $row) {
            if ($index === 0) continue;

            $keyword1 = trim($row[0] ?? '');
            $keyword2 = trim($row[1] ?? '');
            $priority = intval($row[2] ?? 0);
            $answerId = intval($row[3] ?? 0);

            if (!$keyword1 || !$keyword2) continue;

            $model = new AiSuggestedKeywords();
            $model->org_id = $orgId;
            $model->keyword1 = $keyword1;
            $model->keyword2 = $keyword2;
            $model->priority = $priority;
            $model->answer_id = $answerId ?: null;
            $model->created_at = date('Y-m-d H:i:s');
            $model->updated_at = date('Y-m-d H:i:s');

            if ($model->save()) {
                $count++;
            }
        }

        echo "成功导入关键词：$count 条\n";
    }
}

php yii import-suggested-keyword/excel /path/to/联想词.xlsx 123

public static function matchByText($text, $orgId)
{
    return self::find()
        ->where(['org_id' => $orgId])
        ->andWhere(['or',
            ['like', 'keyword1', $text],
            ['like', 'keyword2', $text]
        ])
        ->andWhere(['>', 'answer_id', 0])
        ->orderBy(['priority' => SORT_DESC])
        ->one();
}

问：

上面的编码有些问题： 1. 初始版本导入excel不需要咱们用程序，直接手动用navicat就行。因此不需要。 2. 获取联想词，首先是基于客户端传过来的一个关键词做的匹配，不然就会把所有词给返回去，另外还必须加created_by的限制，也就是限制在当前用户的范围内，暂定。

答：

收到，非常清晰，我立即根据你这两个要求重新修正「联想词读取接口」：

✅ 联想词读取接口（修正版）

目标更新为：

• 基于客户端传入的关键词进行模糊匹配（keyword1 或 keyword2 匹配）；

• 限定为当前用户（created_by）创建的数据；

• 同时限定当前企业（org_id）；

• 按 priority 降序排序。

🔧 模型方法（AiSuggestedKeywords）

public static function searchByKeyword($keyword, $orgId, $userId)
{
    return self::find()
        ->select(['id', 'keyword1', 'keyword2', 'answer_id'])
        ->where(['org_id' => $orgId, 'created_by' => $userId])
        ->andWhere(['or',
            ['like', 'keyword1', $keyword],
            ['like', 'keyword2', $keyword]
        ])
        ->orderBy(['priority' => SORT_DESC])
        ->asArray()
        ->all();
}

🧩 Controller 接口：actionSuggestedKeywords（最终修正）

public function actionSuggestedKeywords()
{
    $keyword = Yii::$app->request->get('keyword');
    $orgId = Yii::$app->request->get('org_id');
    $userId = Yii::$app->user->id;

    if (!$keyword || !$orgId) {
        return ErrorCode::wsReturnData('缺少 keyword 或 org_id 参数', 0);
    }

    $data = AiSuggestedKeywords::searchByKeyword($keyword, $orgId, $userId);
    return ErrorCode::wsReturnData($data, 1);
}

这个接口现在可以安全地用于客户端关键词输入框的“实时推荐”功能，每次输入都会基于当前用户和企业 ID，在 keyword1 与 keyword2 中搜索优先匹配项，并返回结构化联想词。

下一步，我会进入你之前提到的功能点四或功能点五：

是否我可以继续进入提问接口的主流程实现？它将涉及以下关键路径：

• 会话表记录；

• 问题存入；

• 联想词命中后直接返回答案（若有）；

• 未命中则走 AI 请求逻辑，并记录到答案表；

• 敏感词自动检测与拦截。

只需你说“继续”，我就进入提问接口主战场。

问：

继续。

答：

很好，我们进入整个系统的灵魂接口：提问主流程实现。

这一步将整合你设计的数据流与判断链，形成一个清晰、高效、可扩展的问答中枢。

✅ 功能五：提问接口（联想词命中 / 敏感词检测 / 记忆开关 / AI 回答 / 数据落库）

🎯 整体逻辑图谱（根据你之前给我的数据结构设计）

1. 用户提交一个问题：包括 org_id、问题内容 question、是否开启记忆 with_memory

2. 首先在 ai_suggested_keywords 中进行模糊匹配（当前用户 + 企业 + keyword1/2）

• 如果匹配并有 answer_id，直接从 ai_answers 里取出并返回

3. 如果未命中，进行敏感词检测（在 ai_sensitive_words 中查找）

• 如命中，直接返回拦截提示，不调用 AI，不记录数据

4. 如果未命中敏感词

• 如果开启，则查询 ai_messages 表中该用户最近一条 Q&A，拼接到当前 prompt 中

• 检查是否开启记忆

• 请求 AI 接口，获取回答

5. 将问题写入 ai_messages，会话写入 ai_chat_sessions（如必要），回答写入 ai_answers

6. 最终将回答返回给用户

📦 模型支持函数准备（先补充几处）

AiSuggestedKeywords::matchByText($text, $orgId, $userId)

public static function matchByText($text, $orgId, $userId)
{
    return self::find()
        ->where(['org_id' => $orgId, 'created_by' => $userId])
        ->andWhere(['or',
            ['like', 'keyword1', $text],
            ['like', 'keyword2', $text]
        ])
        ->andWhere(['>', 'answer_id', 0])
        ->orderBy(['priority' => SORT_DESC])
        ->one();
}

AiSensitiveWords::hasSensitiveWord($text)

public static function hasSensitiveWord($text)
{
    $words = self::find()
        ->select(['word'])
        ->asArray()
        ->column();

    foreach ($words as $word) {
        if (stripos($text, $word) !== false) {
            return true;
        }
    }
    return false;
}

AiAnswers::createAnswer($orgId, $userId, $content, $source = 'ai')

public static function createAnswer($orgId, $userId, $content, $source = 'ai')
{
    $model = new self();
    $model->org_id = $orgId;
    $model->user_id = $userId;
    $model->answer = $content;
    $model->source = $source;
    $model->created_at = date('Y-m-d H:i:s');
    $model->save();
    return $model->id;
}

AiMessages::createMessage($orgId, $userId, $sessionId, $question, $answerId)

public static function createMessage($orgId, $userId, $sessionId, $question, $answerId)
{
    $model = new self();
    $model->org_id = $orgId;
    $model->user_id = $userId;
    $model->session_id = $sessionId;
    $model->question = $question;
    $model->answer_id = $answerId;
    $model->created_at = date('Y-m-d H:i:s');
    $model->save();
}

AiChatSessions::createOrGet($orgId, $userId)

public static function createOrGet($orgId, $userId)
{
    $session = self::find()
        ->where(['org_id' => $orgId, 'user_id' => $userId])
        ->orderBy(['created_at' => SORT_DESC])
        ->one();

    if ($session) {
        return $session->id;
    }

    $model = new self();
    $model->org_id = $orgId;
    $model->user_id = $userId;
    $model->created_at = date('Y-m-d H:i:s');
    $model->save();
    return $model->id;
}

🧩 Controller 实现：actionAsk()

public function actionAsk()
{
    $orgId = Yii::$app->request->post('org_id');
    $question = trim(Yii::$app->request->post('question'));
    $withMemory = Yii::$app->request->post('with_memory', false);
    $userId = Yii::$app->user->id;

    if (!$orgId || !$question) {
        return ErrorCode::wsReturnData('缺少 org_id 或 question 参数', 0);
    }

    // Step 1: 联想词命中
    $match = AiSuggestedKeywords::matchByText($question, $orgId, $userId);
    if ($match && $match->answer_id) {
        $answer = AiAnswers::findOne($match->answer_id);
        return ErrorCode::wsReturnData(['answer' => $answer->answer], 1);
    }

    // Step 2: 敏感词拦截
    if (AiSensitiveWords::hasSensitiveWord($question)) {
        return ErrorCode::wsReturnData('问题中包含敏感词，无法处理', 0);
    }

    // Step 3: 构建 prompt（如开启记忆）
    $prompt = $question;
    if ($withMemory) {
        $lastMsg = AiMessages::find()
            ->where(['org_id' => $orgId, 'user_id' => $userId])
            ->orderBy(['created_at' => SORT_DESC])
            ->one();

        if ($lastMsg) {
            $lastAnswer = AiAnswers::findOne($lastMsg->answer_id);
            $prompt = "上次提问：" . $lastMsg->question . "\n回答：" . ($lastAnswer->answer ?? '') . "\n本次提问：" . $question;
        }
    }

    // Step 4: 请求 AI 接口（此处模拟）
    $aiReply = "（AI回复）你问的是：$question";

    // Step 5: 存入答案库
    $answerId = AiAnswers::createAnswer($orgId, $userId, $aiReply);

    // Step 6: 获取或创建会话
    $sessionId = AiChatSessions::createOrGet($orgId, $userId);

    // Step 7: 存入问题记录
    AiMessages::createMessage($orgId, $userId, $sessionId, $question, $answerId);

    return ErrorCode::wsReturnData(['answer' => $aiReply], 1);
}

这一接口写法尊重你之前的所有设计：

• 模型分层清晰；

• 逻辑顺序完整；

• 模拟 AI 部分可后续抽象；

• 可根据 token 限制、上下文更多联动进行扩展。

是否可以继续进入 功能四：客户端会话列表、后管 QA 展示接口实现？

你只需说一句“继续”，我继续撸代码。

问：

public static function getUserSessions($orgId, $userId)
{
    $sessions = self::find()
        ->where(['org_id' => $orgId, 'user_id' => $userId])
        ->orderBy(['created_at' => SORT_DESC])
        ->asArray()
        ->all();

    foreach ($sessions as &$session) {
        $lastMsg = \app\modules\api\modules\v1\models\AiMessages::find()
            ->where(['session_id' => $session['id']])
            ->orderBy(['created_at' => SORT_DESC])
            ->one();

        $session['last_question'] = $lastMsg->question ?? null;
        $session['last_answer'] = $lastMsg->answer->answer ?? null;
    }

    return $sessions;
}

public function getAnswer()
{
    return $this->hasOne(AiAnswers::class, ['id' => 'answer_id']);
}

public function actionSessionList()
{
    $orgId = Yii::$app->request->get('org_id');
    $userId = Yii::$app->user->id;

    if (!$orgId) {
        return ErrorCode::wsReturnData('缺少 org_id 参数', 0);
    }

    $data = AiChatSessions::getUserSessions($orgId, $userId);
    return ErrorCode::wsReturnData($data, 1);
}

[
  {
    "id": 102,
    "org_id": 1,
    "user_id": 12,
    "created_at": "2025-03-25 22:17:01",
    "last_question": "什么是记忆功能？",
    "last_answer": "记忆功能是指系统可以追踪你上一次的问题……"
  },
  {
    "id": 101,
    "org_id": 1,
    "user_id": 12,
    "created_at": "2025-03-24 19:42:11",
    "last_question": "什么是上下文？",
    "last_answer": "上下文是指你之前的提问和回答……"
  }]

public static function getRecentQaByOrg($orgId, $limit = 100)
{
    return self::find()
        ->with(['answer', 'session'])
        ->where(['org_id' => $orgId])
        ->orderBy(['created_at' => SORT_DESC])
        ->limit($limit)
        ->asArray()
        ->all();
}

public function getAnswer()
{
    return $this->hasOne(AiAnswers::class, ['id' => 'answer_id']);
}

public function getSession()
{
    return $this->hasOne(AiChatSessions::class, ['id' => 'session_id']);
}

public function actionQaList()
{
    $orgId = Yii::$app->request->get('org_id');
    if (!$orgId) {
        return ErrorCode::wsReturnData('缺少 org_id 参数', 0);
    }

    $qaList = AiMessages::getRecentQaByOrg($orgId);

    $result = [];
    foreach ($qaList as $item) {
        $result[] = [
            'question' => $item['question'],
            'answer' => $item['answer']['answer'] ?? '',
            'user_id' => $item['user_id'],
            'session_id' => $item['session_id'],
            'created_at' => $item['created_at'],
        ];
    }

    return ErrorCode::wsReturnData($result, 1);
}

[
  {
    "question": "如何提升写作能力？",
    "answer": "可以通过每日写作练习、模仿优秀作品、使用AI工具来提升……",
    "user_id": 12,
    "session_id": 101,
    "created_at": "2025-03-24 20:01:03"
  },
  {
    "question": "什么是联想词？",
    "answer": "联想词是指系统预设的关键词触发机制……",
    "user_id": 12,
    "session_id": 102,
    "created_at": "2025-03-24 21:15:43"
  }]

public static function getSessionQa($orgId, $userId, $sessionId)
{
    return self::find()
        ->with('answer')
        ->where([
            'org_id' => $orgId,
            'user_id' => $userId,
            'session_id' => $sessionId
        ])
        ->orderBy(['created_at' => SORT_ASC])
        ->asArray()
        ->all();
}

public function actionSessionQaDetail()
{
    $orgId = Yii::$app->request->get('org_id');
    $sessionId = Yii::$app->request->get('session_id');
    $userId = Yii::$app->user->id;

    if (!$orgId || !$sessionId) {
        return ErrorCode::wsReturnData('缺少 org_id 或 session_id 参数', 0);
    }

    $list = AiMessages::getSessionQa($orgId, $userId, $sessionId);

    $data = [];
    foreach ($list as $item) {
        $data[] = [
            'question' => $item['question'],
            'answer' => $item['answer']['answer'] ?? '',
            'created_at' => $item['created_at']
        ];
    }

    return ErrorCode::wsReturnData($data, 1);
}

[
  {
    "question": "什么是上下文？",
    "answer": "上下文是你前后提问与回答构成的语境……",
    "created_at": "2025-03-24 21:01:04"
  },
  {
    "question": "开启记忆后会保存到哪里？",
    "answer": "会保存在你的会话记录中，系统可自动引用上一次问题。",
    "created_at": "2025-03-24 21:05:18"
  }
]

public static function requestAiAnswer($orgId, $userId, $question)
{
    /** @var $client \yii\httpclient\Client */
    $client = Yii::$app->HttpClient;
    $client->contentLoggingMaxSize = 2000000;
    $client->setTransport('yii\httpclient\StreamTransport');

    $uri = Yii::$app->params['AiModelServerBaseUrl'] .
           Yii::$app->params['AiModelServerApi']['GetAnswer'];

    $headers = ['content-type' => 'application/json'];

    $requestBody = [
        'org_id' => $orgId,
        'user_id' => $userId,
        'question' => $question,
    ];

    $res = $client->createRequest()
        ->setUrl($uri)
        ->setMethod('POST')
        ->setOptions([
            'timeout' => 30,
            'userAgent' => 'ZPY2.0-AI',
            'sslVerifyPeer' => false,
            'sslCafile' => '',
            'sslCapath' => '',
            CURLOPT_CONNECTTIMEOUT => 10,
            CURLOPT_TIMEOUT => 20,
        ])
        ->setFormat(\yii\httpclient\Client::FORMAT_JSON)
        ->setData($requestBody)
        ->addHeaders($headers)
        ->send();

    if ($res->statusCode != 200 || !isset($res->data['answer'])) {
        Yii::error("AI接口请求失败：" . json_encode($res->data, JSON_UNESCAPED_UNICODE), __METHOD__);
        file_put_contents(
            Yii::$app->basePath . '/runtime/logs/ai_request_fail_' . date('Ymd') . '.log',
            date('Y-m-d H:i:s') . ' 发送问题失败：' . $question . PHP_EOL .
            '响应内容：' . json_encode($res->data, JSON_UNESCAPED_UNICODE) . PHP_EOL . PHP_EOL,
            FILE_APPEND
        );
        return false;
    }

    Yii::info("AI接口返回成功：" . json_encode($res->data, JSON_UNESCAPED_UNICODE), __METHOD__);
    return $res->data['answer'];
}

$aiReply = AiApiService::requestAiAnswer($orgId, $userId, $prompt);
if ($aiReply === false) {
    return ErrorCode::wsReturnData('AI接口请求失败，请稍后再试', 0);
}

public static function updateAnswerId($id, $answerId)
{
    $model = self::findOne($id);
    if (!$model) {
        Yii::error("联想词未找到，ID: $id", __METHOD__);
        return false;
    }

    $model->answer_id = $answerId;
    return $model->save(false); // 跳过验证保存
}

// 假设你已经完成 AI 请求，并获取到返回的 $answerId
// 并且 $matchedKeyword 是你提问时命中的联想词记录（含 id）

AiSuggestedKeywords::updateAnswerId($matchedKeyword['id'], $answerId);