Method processMessageToLocal

save/save.ts:895–931

(
    sourceMsg: Api.Message,
    replyMsg: Api.Message,
    sourceChatId: string,
    sourceMessageId: number,
    progress: string = "",
    options?: { groupDirName?: string; quietSuccess?: boolean }
  )

    
    // 确保startId <= endId
    const actualStart = Math.min(startId, endId);
    const actualEnd = Math.max(startId, endId);
    const totalMessages = actualEnd - actualStart + 1;
    
    await this.safeEditMessage(replyMsg, `🔄 开始处理消息范围 ${actualStart}-${actualEnd} (共${totalMessages}条)...`, true);
    
    for (let msgId = actualStart; msgId <= actualEnd; msgId++) {
      totalProcessed++;
      const progress = `[${totalProcessed}/${totalMessages}] `;
      
      try {
        await this.safeEditMessage(replyMsg, `${progress}🔍 获取消息 ${msgId}...`, true);
        const sourceMsg = await this.getMessage(chatId, msgId);
        
        if (!sourceMsg) {
          await this.safeEditMessage(replyMsg, `${progress}⏭️ 消息 ${msgId} 不存在，跳过`, true);
          continue;
        }
        
        await this.safeEditMessage(replyMsg, `${progress}🔄 处理消息 ${msgId}...`, true);
        const result = await this.processMessage(
          sourceMsg, 
          targetPeer, 
          replyMsg, 
          chatId, 
          msgId,
          progress
        );
        
        if (result.success) {
          successCount++;
          if (result.forwardedMsg) {
            lastForwardedMsg = result.forwardedMsg;
          }
          if (!startSource && result.source) {
            startSource = result.source;
          }
          if (result.source) {
            endSource = result.source;
          }