figmar
81115dc23d
微信自动回复机器人，基于截图+OCR识别消息，支持关键词规则和 AI（OpenAI/DeepSeek/Dify）自动回复。 技术栈：PySide6 + Flask + Vue3 + RapidOCR + SQLite 注：OCR大模型文件（.onnx / .pdiparams）不纳入版本控制，需单独下载。 🤖 Generated with [Qoder][https://qoder.com]
98 lines
2.9 KiB
PHP
98 lines
2.9 KiB
PHP
<?php
|
|
// Python 客户端调用此接口，将微信新消息传进来
|
|
require_once __DIR__ . '/config.php';
|
|
require_once __DIR__ . '/db.php';
|
|
require_once __DIR__ . '/ai_helper.php';
|
|
|
|
if ($_SERVER['REQUEST_METHOD'] !== 'POST') {
|
|
json_response(['error' => 'Method not allowed'], 405);
|
|
}
|
|
|
|
$raw = file_get_contents('php://input');
|
|
$data = json_decode($raw, true);
|
|
if (!is_array($data)) {
|
|
$data = $_POST; // 兼容表单
|
|
}
|
|
|
|
$content = trim((string)($data['content'] ?? ''));
|
|
$wxUserId = trim((string)($data['wx_user_id'] ?? ''));
|
|
$wxNickname = trim((string)($data['wx_nickname'] ?? ''));
|
|
$isFriendRequest = (int)($data['is_friend_request'] ?? 0);
|
|
|
|
if ($content === '' && !$isFriendRequest) {
|
|
json_response(['error' => 'content is empty'], 400);
|
|
}
|
|
|
|
try {
|
|
$pdo = get_pdo();
|
|
$pdo->beginTransaction();
|
|
|
|
// 记录收到的消息
|
|
$stmt = $pdo->prepare("
|
|
INSERT INTO messages (wx_user_id, wx_nickname, direction, content, is_friend_request, created_at)
|
|
VALUES (:uid, :nick, 'in', :content, :fr, NOW())
|
|
");
|
|
$stmt->execute([
|
|
':uid' => $wxUserId,
|
|
':nick' => $wxNickname,
|
|
':content' => $content,
|
|
':fr' => $isFriendRequest,
|
|
]);
|
|
$inMsgId = (int)$pdo->lastInsertId();
|
|
|
|
$autoOn = get_setting('auto_reply_enabled', '1') === '1';
|
|
$replyText = '';
|
|
$usedRuleId = null;
|
|
|
|
if ($autoOn) {
|
|
// 先规则匹配
|
|
$rule = find_rule_reply($content);
|
|
if ($rule) {
|
|
$replyText = (string)$rule['reply_text'];
|
|
$usedRuleId = (int)$rule['id'];
|
|
// 调试信息
|
|
error_log("匹配到规则ID: {$usedRuleId}, 关键词: {$rule['keyword']}, 回复: {$replyText}");
|
|
} else {
|
|
// 没有规则就走 AI
|
|
error_log("未匹配到规则，调用AI，用户消息: {$content}");
|
|
$replyText = call_ai($content, $wxUserId);
|
|
error_log("AI返回: {$replyText}");
|
|
}
|
|
}
|
|
|
|
$shouldReply = $autoOn && $replyText !== '';
|
|
$replyMsgId = null;
|
|
|
|
if ($shouldReply) {
|
|
$stmt2 = $pdo->prepare("
|
|
INSERT INTO messages (wx_user_id, wx_nickname, direction, content, is_ai_reply, rule_id, created_at)
|
|
VALUES (:uid, :nick, 'out', :content, :is_ai, :rule_id, NOW())
|
|
");
|
|
$stmt2->execute([
|
|
':uid' => $wxUserId,
|
|
':nick' => $wxNickname,
|
|
':content' => $replyText,
|
|
':is_ai' => 1,
|
|
':rule_id' => $usedRuleId,
|
|
]);
|
|
$replyMsgId = (int)$pdo->lastInsertId();
|
|
}
|
|
|
|
$pdo->commit();
|
|
|
|
json_response([
|
|
'success' => true,
|
|
'should_reply' => $shouldReply,
|
|
'reply_text' => $replyText,
|
|
'in_message_id' => $inMsgId,
|
|
'reply_message_id' => $replyMsgId,
|
|
]);
|
|
} catch (Throwable $e) {
|
|
if (isset($pdo) && $pdo->inTransaction()) {
|
|
$pdo->rollBack();
|
|
}
|
|
json_response(['error' => 'server_error', 'message' => $e->getMessage()], 500);
|
|
}
|
|
|
|
|