Go语言encoding/csv包：解决数据写入文件后不显示的常见问题

func (w *Writer) Flush()
// Flush writes any buffered data to the underlying io.Writer.

package main

import (
    "encoding/csv"
    "fmt"
    "log"
    "os"
)

// 模拟一些需要写入CSV的数据结构
type ErrorRecord struct {
    GroupID         string
    AccountID       string
    LocationID      string
    PaymentRating   string
    RecordsWithError string
}

func main() {
    // 示例数据
    errorRecords := []ErrorRecord{
        {"GRP001", "ACC001", "LOC001", "A", "Record 1, Record 2"},
        {"GRP002", "ACC002", "LOC002", "B", "Record 3"},
        {"GRP001", "ACC003", "LOC003", "C", "Record 4, Record 5, Record 6"},
    }

    // 调用写入函数
    if err := writeRecordsToCSV("output.csv", errorRecords); err != nil {
        log.Fatalf("写入CSV文件失败: %v\n", err)
    } else {
        fmt.Println("数据成功写入 output.csv")
    }
}

// writeRecordsToCSV 函数负责将错误记录写入CSV文件
func writeRecordsToCSV(filename string, records []ErrorRecord) error {
    // os.O_APPEND: 如果文件存在则追加，os.O_CREATE: 如果文件不存在则创建
    // os.O_WRONLY: 以只写模式打开文件
    // 0666: 文件权限，所有者、组、其他人都有读写权限
    file, err := os.OpenFile(filename, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0666)
    if err != nil {
        return fmt.Errorf("无法打开或创建文件 %s: %w", filename, err)
    }
    defer file.Close() // 确保文件在函数结束时关闭

    writer := csv.NewWriter(file)

    // 写入CSV头
    headers := []string{"group_id", "account_id", "location_id", "payment_rating", "records_with_error"}
    if err := writer.Write(headers); err != nil {
        return fmt.Errorf("写入CSV头失败: %w", err)
    }

    // 写入数据行
    for _, record := range records {
        row := []string{
            record.GroupID,
            record.AccountID,
            record.LocationID,
            record.PaymentRating,
            record.RecordsWithError,
        }
        if err := writer.Write(row); err != nil {
            // 记录错误但尝试继续写入其他行，或者根据需求选择panic/return
            fmt.Printf("警告: 写入数据行失败 (%v): %v\n", row, err)
            continue
        }
        fmt.Printf("正在写入: %v\n", row)
    }

    // !!! 关键步骤: 刷新缓冲区，确保所有数据写入文件 !!!
    writer.Flush()
    // 检查 Flush() 过程中是否发生错误
    if err := writer.Error(); err != nil {
        return fmt.Errorf("刷新CSV写入器缓冲区失败: %w", err)
    }

    return nil
}