使用Golang调用Google Sheets API时表头更新被覆盖而非追加的问题

问题原因 #

当前代码使用Spreadsheets.Values.Update方法更新A1:Z1范围，该方法会直接替换指定范围内的所有单元格内容，导致原有表头被完全覆盖，无法实现新增列的需求。

解决方案 #

需要先读取现有表头，对比新表头找出新增字段，再将新增表头写入现有表头的右侧空白列，而非覆盖整个表头范围。同时对应的数据也需要写入到匹配的列位置。

修改后的代码示例 #

func SendDataToSheet(formResponse *models.FormResponse, integration models.Integration) error {
    var sheetIntegration models.SheetIntegration
    if err := json.Unmarshal([]byte(integration.Integration), &sheetIntegration); err != nil {
        return err
    }

    decToken, err := utils.Decrypt(integration.Token)
    if err != nil {
        return err
    }

    tokenSource := oauth2.Token{}
    err = json.Unmarshal([]byte(decToken), &tokenSource)
    if err != nil {
        return err
    }

    ctx := context.Background()

    if !tokenSource.Valid() {
        config := utils.ConfigGoogleSheets()
        tokenConfig := config.TokenSource(ctx, &tokenSource)
        newTokenSource, _ := tokenConfig.Token()

        encToken, err := json.Marshal(newTokenSource)
        if err != nil {
            return err
        }

        encTokenString, err := utils.Encrypt(string(encToken))
        if err != nil {
            return err
        }

        integration.Token = encTokenString
        tokenSource = *newTokenSource

        if err := initializers.DB.Save(&integration).Error; err != nil {
            return err
        }
    }

    sheetsService, err := sheets.NewService(ctx, option.WithTokenSource(oauth2.StaticTokenSource(&tokenSource)))
    if err != nil {
        integration.Error = err.Error()
        integration.Connected = utils.Bool(false)
        if err := initializers.DB.Save(&integration).Error; err != nil {
            return err
        }
    }

    dataMap := linkedhashmap.New()
    if err := json.Unmarshal([]byte(formResponse.Response), &dataMap); err != nil {
        return err
    }

    // 1. 读取现有表头
    existingHeadersRange := "!A1:Z1"
    existingHeadersResp, err := sheetsService.Spreadsheets.Values.Get(sheetIntegration.SheetId, existingHeadersRange).Do()
    if err != nil {
        integration.Error = err.Error()
        integration.Connected = utils.Bool(false)
        if err := initializers.DB.Save(&integration).Error; err != nil {
            return err
        }
    }

    // 整理现有表头列表（过滤空值）
    existingHeaders := []interface{}{}
    if len(existingHeadersResp.Values) > 0 {
        for _, header := range existingHeadersResp.Values[0] {
            if header != "" {
                existingHeaders = append(existingHeaders, header)
            }
        }
    }

    // 2. 生成新表头和对应数据（保留原有过滤逻辑）
    newHeaders := []interface{}{}
    newValues := []interface{}{}
    for _, key := range dataMap.Keys() {
        if key != "redirect" && key != "password" {
            newHeaders = append(newHeaders, key)
            val, _ := dataMap.Get(key)
            newValues = append(newValues, val)
        }
    }

    // 3. 找出新增的表头字段
    addedHeaders := []interface{}{}
    addedValues := []interface{}{}
    headerMap := make(map[interface{}]int)
    for idx, h := range existingHeaders {
        headerMap[h] = idx
    }

    for idx, h := range newHeaders {
        if _, exists := headerMap[h]; !exists {
            addedHeaders = append(addedHeaders, h)
            addedValues = append(addedValues, newValues[idx])
        }
    }

    // 4. 写入新增表头（如果有新增字段）
    if len(addedHeaders) > 0 {
        // 计算新增表头的起始列：现有表头数量+1，转换为列字母（如A=1，B=2...）
        startCol := len(existingHeaders) + 1
        colLetter := getColumnLetter(startCol)
        headersRange := fmt.Sprintf("!%s1:%s1", colLetter, colLetter)
        headersValueRange := &sheets.ValueRange{
            Values: [][]interface{}{addedHeaders},
        }
        _, err = sheetsService.Spreadsheets.Values.Update(sheetIntegration.SheetId, headersRange, headersValueRange).ValueInputOption("RAW").Do()
        if err != nil {
            integration.Error = err.Error()
            integration.Connected = utils.Bool(false)
            if err := initializers.DB.Save(&integration).Error; err != nil {
                return err
            }
        }
    }

    // 5. 准备完整数据行：对齐现有表头，补充新增字段
    fullDataRow := make([]interface{}, len(existingHeaders)+len(addedHeaders))
    // 填充现有字段的数据
    for idx, h := range existingHeaders {
        for newIdx, newH := range newHeaders {
            if newH == h {
                fullDataRow[idx] = newValues[newIdx]
                break
            }
        }
    }
    // 填充新增字段的数据
    for idx, val := range addedValues {
        fullDataRow[len(existingHeaders)+idx] = val
    }

    // 6. 追加数据行到表格
    valueRange := &sheets.ValueRange{
        Values: [][]interface{}{fullDataRow},
    }
    _, err = sheetsService.Spreadsheets.Values.Append(sheetIntegration.SheetId, "!A:A", valueRange).ValueInputOption("RAW").InsertDataOption("INSERT_ROWS").Do()
    if err != nil {
        integration.Error = err.Error()
        integration.Connected = utils.Bool(false)
        if err := initializers.DB.Save(&integration).Error; err != nil {
            return err
        }
    }

    return nil
}

// 辅助函数：将列索引转换为Excel列字母（如1->A，26->Z，27->AA）
func getColumnLetter(col int) string {
    var result string
    for col > 0 {
        col--
        result = string(rune('A'+col%26)) + result
        col /= 26
    }
    return result
}

关键修改点说明 #

• 读取现有表头：通过Spreadsheets.Values.Get获取当前表头内容，避免覆盖原有数据
• 对比表头：找出新表头中不存在于现有表头的字段，仅处理新增部分
• 精准写入新增表头：计算新增表头的起始列，只更新空白列的单元格，不影响原有表头
• 对齐数据行：确保新数据行的每个字段对应正确的列位置，包括新增列
• 优化数据追加：使用Append方法并指定INSERT_ROWS，确保数据插入到下一行而非覆盖

内容的提问来源于stack exchange，提问作者Siddo