()
| 173 | |
| 174 | // 保存当前消息 |
| 175 | const saveCurrentMessage = () => { |
| 176 | if (currentMessage) { |
| 177 | const content = currentMessage.contentLines.join('\n').trim() |
| 178 | const type = detectMessageType(content) |
| 179 | |
| 180 | messages.push({ |
| 181 | senderPlatformId: currentMessage.platformId, |
| 182 | senderAccountName: currentMessage.nickname, // QQ TXT 格式只有一个昵称,作为账号名称追踪历史 |
| 183 | // 不设置 senderGroupNickname,避免同一昵称被重复追踪 |
| 184 | timestamp: currentMessage.timestamp, |
| 185 | type, |
| 186 | content: content || null, |
| 187 | }) |
| 188 | |
| 189 | // 更新成员信息(保留最新昵称) |
| 190 | memberMap.set(currentMessage.platformId, { |
| 191 | platformId: currentMessage.platformId, |
| 192 | nickname: currentMessage.nickname, |
| 193 | }) |
| 194 | |
| 195 | messagesProcessed++ |
| 196 | } |
| 197 | } |
| 198 | |
| 199 | // 逐行读取文件 |
| 200 | const fileStream = fs.createReadStream(filePath, { encoding: 'utf-8' }) |
no test coverage detected