Files
im/check_conversation.php
T
2026-04-06 04:35:35 +08:00

53 lines
1.7 KiB
PHP

<?php
require __DIR__ . '/vendor/autoload.php';
$app = require_once __DIR__ . '/bootstrap/app.php';
$mongoConfig = config('thinkorm.connections.mongo');
$dsn = $mongoConfig['type'] . '://' . $mongoConfig['hostname'] . ':' . $mongoConfig['hostport'];
$mongo = new MongoDB\Client($dsn);
$db = $mongo->selectDatabase($mongoConfig['database']);
$conversationId = 'sg_2639473367';
$ownerUserId = '83484627';
echo "=== 检查 conversation 表记录 ===\n";
$convCollection = $db->selectCollection('conversation');
$conv = $convCollection->findOne([
'conversation_id' => $conversationId,
'owner_user_id' => $ownerUserId
]);
if ($conv) {
echo "找到记录:\n";
print_r($conv);
echo "\n";
if (isset($conv['max_seq'])) {
echo "max_seq: " . $conv['max_seq'] . "\n";
} else {
echo "max_seq 不存在\n";
}
if (isset($conv['min_seq'])) {
echo "min_seq: " . $conv['min_seq'] . "\n";
} else {
echo "min_seq 不存在\n";
}
} else {
echo "未找到记录\n";
echo "\n查找同一 conversation_id 的其他记录:\n";
$allConvs = $convCollection->find(['conversation_id' => $conversationId])->toArray();
foreach ($allConvs as $c) {
echo "owner_user_id: " . ($c['owner_user_id'] ?? 'null') . "\n";
echo " max_seq: " . ($c['max_seq'] ?? 'null') . "\n";
echo " min_seq: " . ($c['min_seq'] ?? 'null') . "\n";
}
}
echo "\n=== 检查 seq 表 ===\n";
$seqCollection = $db->selectCollection('seq');
$seq = $seqCollection->findOne(['conversation_id' => $conversationId]);
if ($seq) {
echo "conversation_id: " . $seq['conversation_id'] . "\n";
echo "max_seq: " . $seq['max_seq'] . "\n";
echo "min_seq: " . $seq['min_seq'] . "\n";
}