jyps/getEs/bidding.go

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"github.com/olivere/elastic/v7"
	"github.com/xuri/excelize/v2"
	"io"
	util "jygit.jydev.jianyu360.cn/data_processing/common_utils"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
	"log"
	"strings"
)

// getBidding2 获取bidding数据
func getBidding2() {
	url := "http://172.17.4.184:19908"
	//url := "http://127.0.0.1:19908"
	username := "jybid"
	password := "Top2023_JEB01i@31"
	index := "bidding" //索引名称
	// 创建 Elasticsearch 客户端
	client, err := elastic.NewClient(
		elastic.SetURL(url),
		elastic.SetBasicAuth(username, password),
		elastic.SetSniff(false),
	)
	if err != nil {
		log.Fatalf("创建 Elasticsearch 客户端失败：%s", err)
	}
	//85 抽取库
	//Mgo := &mongodb.MongodbSim{
	//	//MongodbAddr: "127.0.0.1:27080",
	//	MongodbAddr: "172.17.4.85:27080",
	//	DbName:      "top",
	//	Size:        10,
	//	//Direct: true,
	//}
	//Mgo.InitPool()

	//2023年01-01  2023-10-01，,1-3季度
	//2024-1 - 2024-4;1704038400-1711900800
	//2023-10-1 2024-1-1;1696089600-1704038400
	//城市范围
	//areaTermsQuery := elastic.NewTermsQuery("company_city", "北京市")
	//rangeQuery := elastic.NewRangeQuery("publishtime").Gte(1704038400).Lt(1735660800)
	//query := elastic.NewBoolQuery().
	//	Must(areaTermsQuery).
	//	Must(rangeQuery)
	//---------------------------//
	//query := elastic.NewBoolQuery()
	//query.Must(elastic.NewMatchQuery("company_area", "广东"))
	////query.Must(elastic.NewTermQuery("company_type", "北京市"))

	// 构建查询条件
	//query := elastic.NewBoolQuery().
	//	MustNot(elastic.NewTermQuery("company_type", "个体工商户")). // 排除 company_type 为 "个体工商户"
	//	Filter(elastic.NewTermQuery("company_area", "广东"))      // 过滤 company_area 为 "广东"

	//rangeQuery := elastic.NewRangeQuery("comeintime").Gte("1640966400").Lt("1703952000")
	query := elastic.NewBoolQuery().
		Should(
			elastic.NewMatchQuery("subtype", "合同"),
			elastic.NewMatchQuery("toptype", "结果"),
			elastic.NewMatchQuery("toptype", "招标"),
		).
		MinimumShouldMatch("1"). // 至少满足一个Should条件                           // buyer = "中国建筑股份有限公司"
		Must(elastic.NewRangeQuery("publishtime").Gte(1704038400).Lt(1735660800))

	ctx := context.Background()
	//开始滚动搜索
	scrollID := ""
	scroll := "10m"
	searchSource := elastic.NewSearchSource().
		Query(query).
		Size(10000).
		Sort("_doc", true) //升序排序
	//Sort("_doc", false) //降序排序

	searchService := client.Scroll(index).
		Size(10000).
		Scroll(scroll).
		SearchSource(searchSource)

	res, err := searchService.Do(ctx)

	if err != nil {
		if err == io.EOF {
			fmt.Println("没有数据")
		} else {
			panic(err)
		}

	}
	//defer client.ClearScroll().ScrollId(scrollID).Do(ctx) // 在退出时清理资源
	fmt.Println("总数是：", res.TotalHits())

	total := 0
	for len(res.Hits.Hits) > 0 {
		for _, hit := range res.Hits.Hits {
			var doc map[string]interface{}
			err := json.Unmarshal(hit.Source, &doc)
			if err != nil {
				log.Printf("解析文档失败：%s", err)
				continue
			}
			//存入新表
			insert := map[string]interface{}{
				"buyer":   doc["buyer"],
				"id":      doc["id"],
				"toptype": doc["toptype"],
				"subtype": doc["subtype"],
			}

			err = MgoB.InsertOrUpdate("qfw", "wcc_20250311_bidding", insert)
			if err != nil {
				log.Println("error", doc["id"])
			}

		}

		total = total + len(res.Hits.Hits)
		scrollID = res.ScrollId
		res, err = client.Scroll().ScrollId(scrollID).Scroll(scroll).Do(ctx)
		log.Println("current count:", total)
		if err != nil {
			if err == io.EOF {
				// 滚动到最后一批数据，退出循环
				break
			}
			log.Println("滚动搜索失败：", err, res)
			break // 处理错误时退出循环
		}
	}
	// 在循环外调用 ClearScroll
	_, err = client.ClearScroll().ScrollId(scrollID).Do(ctx)
	if err != nil {
		log.Printf("清理滚动搜索失败：%s", err)
	}

	fmt.Println("结束~~~~~~~~~~~~~~~")
}

func getBidding() {
	url := "http://172.17.4.184:19908"
	//url := "http://127.0.0.1:19908"
	username := "jybid"
	password := "Top2023_JEB01i@31"
	index := "bidding" //索引名称
	// 创建 Elasticsearch 客户端
	client, err := elastic.NewClient(
		elastic.SetURL(url),
		elastic.SetBasicAuth(username, password),
		elastic.SetSniff(false),
	)
	if err != nil {
		log.Fatalf("创建 Elasticsearch 客户端失败：%s", err)
	}
	//85 抽取库
	//Mgo := &mongodb.MongodbSim{
	//	//MongodbAddr: "127.0.0.1:27080",
	//	MongodbAddr: "172.17.4.85:27080",
	//	DbName:      "top",
	//	Size:        10,
	//	//Direct: true,
	//}
	//Mgo.InitPool()

	MgoB := &mongodb.MongodbSim{
		MongodbAddr: "172.31.31.202:27081,172.20.45.128:27080",
		//MongodbAddr: "127.0.0.1:27083",
		Size:     10,
		DbName:   "qfw",
		UserName: "SJZY_RWbid_ES",
		Password: "SJZY@B4i4D5e6S",
		//Direct:      true,
	}
	MgoB.InitPool()

	//2023年01-01  2023-10-01，,1-3季度
	//2024-1 - 2024-4;1704038400-1711900800
	//2023-10-1 2024-1-1;1696089600-1704038400
	//城市范围
	//areaTermsQuery := elastic.NewTermsQuery("company_city", "北京市")
	//rangeQuery := elastic.NewRangeQuery("establish_date").Gte(1704038400)
	//query := elastic.NewBoolQuery().
	//	Must(areaTermsQuery).
	//	Must(rangeQuery)
	//---------------------------//
	//query := elastic.NewBoolQuery()
	//query.Must(elastic.NewMatchQuery("company_area", "广东"))
	////query.Must(elastic.NewTermQuery("company_type", "北京市"))

	// 构建查询条件
	query := elastic.NewBoolQuery().
		MustNot(elastic.NewTermQuery("company_type", "个体工商户")). // 排除 company_type 为 "个体工商户"
		Filter(elastic.NewTermQuery("company_area", "广东"))      // 过滤 company_area 为 "广东"

	//rangeQuery := elastic.NewRangeQuery("comeintime").Gte("1640966400").Lt("1703952000")
	//query := elastic.NewBoolQuery().
	//	//北京，天津，河北，上海，江苏，浙江，安徽
	//	//Must(elastic.NewTermQuery("area", "北京市")).
	//	Must(elastic.NewTermsQuery("subtype", "中标", "单一", "成交", "合同")).
	//	Must(elastic.NewTermsQuery("area", "北京", "上海", "江苏", "浙江", "广东")).
	//	Must(rangeQuery)

	ctx := context.Background()
	//开始滚动搜索
	scrollID := ""
	scroll := "10m"
	searchSource := elastic.NewSearchSource().
		Query(query).
		Size(10000).
		Sort("_doc", true) //升序排序
	//Sort("_doc", false) //降序排序

	searchService := client.Scroll(index).
		Size(10000).
		Scroll(scroll).
		SearchSource(searchSource)

	res, err := searchService.Do(ctx)

	if err != nil {
		if err == io.EOF {
			fmt.Println("没有数据")
		} else {
			panic(err)
		}

	}
	//defer client.ClearScroll().ScrollId(scrollID).Do(ctx) // 在退出时清理资源
	fmt.Println("总数是：", res.TotalHits())

	total := 0
	for len(res.Hits.Hits) > 0 {
		for _, hit := range res.Hits.Hits {
			var doc map[string]interface{}
			err := json.Unmarshal(hit.Source, &doc)
			if err != nil {
				log.Printf("解析文档失败：%s", err)
				continue
			}
			//存入新表
			insert := map[string]interface{}{
				"companyaaaaaaaaaaaaaaaaaaaaaaaaaaa_name": doc["company_name"],
				"id":           doc["id"],
				"credit_no":    doc["credit_no"],
				"company_code": doc["company_code"],
			}
			if strings.Contains(util.ObjToString(doc["company_name"]), "银行") || strings.Contains(util.ObjToString(doc["company_name"]), "保险") || strings.Contains(util.ObjToString(doc["company_name"]), "证券") {
				insert["wcc_type"] = 1
			}
			err = MgoB.InsertOrUpdate("qfw", "wcc_2025_guangdong_qyxy", insert)
			if err != nil {
				log.Println("error", doc["id"])
			}

		}

		total = total + len(res.Hits.Hits)
		scrollID = res.ScrollId
		res, err = client.Scroll().ScrollId(scrollID).Scroll(scroll).Do(ctx)
		log.Println("current count:", total)
		if err != nil {
			if err == io.EOF {
				// 滚动到最后一批数据，退出循环
				break
			}
			log.Println("滚动搜索失败：", err, res)
			break // 处理错误时退出循环
		}
	}
	// 在循环外调用 ClearScroll
	_, err = client.ClearScroll().ScrollId(scrollID).Do(ctx)
	if err != nil {
		log.Printf("清理滚动搜索失败：%s", err)
	}

	fmt.Println("结束~~~~~~~~~~~~~~~")
}

// updateHrefByEs 更新mgo by es
func updateHrefByEs() {
	url := "http://172.17.4.184:19908"
	//url := "http://127.0.0.1:19908"
	//url := "http://127.0.0.1:19905"
	username := "jybid"
	password := "Top2023_JEB01i@31"
	//index := "bidding" //索引名称
	index := "biddingall" //索引名称
	// 创建 Elasticsearch 客户端
	client, err := elastic.NewClient(
		elastic.SetURL(url),
		elastic.SetBasicAuth(username, password),
		elastic.SetSniff(false),
	)
	if err != nil {
		log.Fatalf("创建 Elasticsearch 客户端失败：%s", err)
	}

	//MgoB = &mongodb.MongodbSim{
	//	//MongodbAddr: "172.17.189.140:27080",
	//	MongodbAddr: "127.0.0.1:27083",
	//	Size:        10,
	//	DbName:      "qfw",
	//	UserName:    "SJZY_RWbid_ES",
	//	Password:    "SJZY@B4i4D5e6S",
	//	Direct:      true,
	//}
	//MgoB.InitPool()

	defer util.Catch()
	sess := MgoB.GetMgoConn()
	defer MgoB.DestoryMongoConn(sess)
	where := map[string]interface{}{
		"itype": 0,
	}

	it := sess.DB("qfw").C("bidding_es_update_id").Find(where).Select(nil).Iter()
	log.Println("taskRun 开始")
	count := 0
	for tmp := make(map[string]interface{}); it.Next(&tmp); count++ {
		if count%100 == 0 {
			log.Println("current:", count)
		}

		id := mongodb.BsonIdToSId(tmp["_id"])
		res, _ := GetByID(client, index, id)
		if res == nil {
			//没有找到
			update := map[string]interface{}{
				"itype": 0,
			}
			MgoB.UpdateById("bidding_es_update_id", id, map[string]interface{}{"$set": update})

		} else {
			// 找到对应数据了
			update := map[string]interface{}{
				"href":  res["href"],
				"itype": 1,
			}
			update2 := map[string]interface{}{
				"href": res["href"],
			}
			MgoB.UpdateById("bidding_es_update_id", id, map[string]interface{}{"$set": update})
			MgoB.UpdateById("bidding", id, map[string]interface{}{"$set": update2})
		}

	}

	log.Println("over", count)
}

// GetByID 根据索引和 ID 获取数据
func GetByID(ec *elastic.Client, index string, id string) (map[string]interface{}, error) {
	ctx := context.Background()
	// 执行 Get 请求
	res, err := ec.Get().
		Index(index).
		Id(id).
		Do(ctx)
	if err != nil {
		if elastic.IsNotFound(err) {
			return nil, fmt.Errorf("document not found for index '%s' and id '%s'", index, id)
		}
		return nil, fmt.Errorf("failed to get document: %w", err)
	}

	// 解析文档源
	if !res.Found {
		return nil, fmt.Errorf("document not found for index '%s' and id '%s'", index, id)
	}

	// 解析 JSON 数据到 map[string]interface{}
	var source map[string]interface{}
	if err := json.Unmarshal(res.Source, &source); err != nil {
		return nil, fmt.Errorf("failed to unmarshal document source: %w", err)
	}

	return source, nil
}

// updateXlsxDa 更新中标金额
func updateXlsxDa() {
	f, err := excelize.OpenFile("202502项目2.xlsx")
	if err != nil {
		log.Fatal("❌ 无法打开 Excel 文件:", err)
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows("Sheet1") // 替换为正确的 Sheet 名称
	if err != nil {
		log.Fatal("❌ 无法读取 Excel:", err)
	}

	//
	for i := 1; i < len(rows); i++ {
		row := rows[i]
		// 确保 E 列（索引 4）不为空
		if len(row) < 5 || row[4] == "" {
			continue
		}
		//
		log.Println("项目名称-------------", row[3])
		// 从 F 列（索引 5）开始，每 4 列为一组
		for colIndex := 5; colIndex+1 < len(row); colIndex += 4 {
			// 提取中标金额（第 1 列）和标题（第 2 列）
			//bidAmount := row[colIndex] // F、J、N...列
			title := row[colIndex+1] // G、K、O...列
			if title == "" {
				continue
			}

			where := map[string]interface{}{
				"title": title,
			}
			bidd, _ := MgoB.FindOne("wcc_biddind_20250318", where)
			if len(*bidd) > 0 {
				bidamount := (*bidd)["bidamount"]
				sss := getColumnLetter(colIndex + 1)
				f.SetCellValue("Sheet1", fmt.Sprintf("%s%d", sss, i+1), bidamount) // 中标金额
			}

			// 只打印非空数据
			//if bidAmount != "" && title != "" {
			//	fmt.Printf("中标金额: %s, 标题: %s\n", bidAmount, title)
			//}
		}
	}
}

// getDataFromFile getDataFromFile
func getDataFromFile() {
	url := "http://172.17.4.184:19908"
	//url := "http://127.0.0.1:19908"
	username := "jybid"
	password := "Top2023_JEB01i@31"
	//index := "bidding" //索引名称
	// 创建 Elasticsearch 客户端
	client, err := elastic.NewClient(
		elastic.SetURL(url),
		elastic.SetBasicAuth(username, password),
		elastic.SetSniff(false),
	)
	if err != nil {
		log.Fatalf("创建 Elasticsearch 客户端失败：%s", err)
	}

	// 2. 读取 Excel
	f, err := excelize.OpenFile("202502项目3_人工验证版.xlsx")
	if err != nil {
		log.Fatal("❌ 无法打开 Excel 文件:", err)
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	// 3. 读取 B 列（项目名称）
	rows, err := f.GetRows("Sheet1") // 替换为正确的 Sheet 名称
	if err != nil {
		log.Fatal("❌ 无法读取 Excel:", err)
	}

	for i := 1; i < len(rows); i++ {
		row := rows[i]
		if i == 0 || len(row) < 4 { // 跳过表头或无效数据
			continue
		}

		//已经有数据，跳过
		if len(row) > 7 {
			continue
		}
		projectName := row[3] // B 列数据
		if projectName == "" {
			continue
		}

		buyer2 := row[2] //单位明细
		log.Println("projectName", projectName)
		// 查询 ES，获取最相似的前 6 个完整文档
		results, err := searchES(client, projectName, buyer2)
		if err != nil {
			log.Printf("⚠ 查询失败: %s, 错误: %v\n", projectName, err)
			continue
		}

		//
		if len(results) > 0 {
			startCol := 8 // C列对应索引3 := 3 // C 列开始
			for _, result := range results {
				//f.SetCellValue("Sheet1", fmt.Sprintf("%s%d", getColumnLetter(startCol), i+1), result["bidamount"]) // 中标金额
				f.SetCellValue("Sheet1", fmt.Sprintf("%s%d", getColumnLetter(startCol), i+1), result["budget"]) // 中标金额
				//f.SetCellValue("Sheet1", fmt.Sprintf("%s%d", getColumnLetter(startCol), i+1), result["total_investment"]) // 预算金额
				f.SetCellValue("Sheet1", fmt.Sprintf("%s%d", getColumnLetter(startCol+1), i+1), result["title"])  // 标题
				f.SetCellValue("Sheet1", fmt.Sprintf("%s%d", getColumnLetter(startCol+2), i+1), result["jyhref"]) // 标讯链接
				f.SetCellValue("Sheet1", fmt.Sprintf("%s%d", getColumnLetter(startCol+3), i+1), result["score"])  // 相似度
				startCol += 4                                                                                     // **向右移动 4 列，防止数据覆盖**
			}
			f.SetCellValue("Sheet1", fmt.Sprintf("%s%d", "G", i+1), "拟建") // 相似度

		}
	}

	log.Println("over  over")
}

func searchES(client *elastic.Client, projectName, buyer2 string) ([]map[string]interface{}, error) {
	query := elastic.NewBoolQuery().
		Must(
			elastic.NewMatchQuery("projectname.pname", projectName), // 模糊匹配 projectname
			//elastic.NewMatchQuery("title", projectName), // 模糊匹配 projectname
			//elastic.NewMatchQuery("detail", projectName), // 模糊匹配 projectname
			elastic.NewTermQuery("area", "安徽"), // 过滤区域
			//elastic.NewTermsQuery("subtype", "中标", "成交", "合同", "单一"), // 过滤 subtype
			//elastic.NewTermsQuery("toptype", "招标", "预告", "采购意向"), // 过滤 subtype
			elastic.NewTermsQuery("toptype", "拟建"), // 过滤 subtype
		)

	searchResult, err := client.Search().
		Index("bidding").
		Query(query).
		Size(70). // 先取 12 条，确保足够数据
		Do(context.Background())

	if err != nil {
		return nil, err
	}

	// 结果集
	var results []map[string]interface{}
	seenProjectNames := make(map[string]bool) // 用于去重
	seenProjectCode := make(map[string]bool)  // 用于去重
	bidamountMap := make(map[string]float64)
	for _, hit := range searchResult.Hits.Hits {
		var doc map[string]interface{}
		err := json.Unmarshal(hit.Source, &doc)
		if err != nil {
			log.Printf("解析文档失败：%s", err)
			continue
		}

		// 获取 `projectname`，防止 key 不存在时的错误
		projectNameValue, ok := doc["projectname"].(string)

		bidamount := util.Float64All(doc["bidamount"])
		if !ok {
			log.Printf("⚠️ 缺少 projectname 字段，跳过：%v", doc)
			continue
		}

		projectCodeValue := util.ObjToString(doc["projectcode"])

		if seenProjectCode[projectCodeValue] {
			continue
		}
		if projectCodeValue != "" {
			seenProjectCode[projectCodeValue] = true
		}

		// **处理额外字段**
		id := util.ObjToString(doc["id"])
		bidData, _ := MgoB.FindById("bidding", id, nil)
		if util.Float64All((*bidData)["total_investment"]) > 0 {
			doc["total_investment"] = (*bidData)["total_investment"]
		}
		doc["jyhref"] = GetJyURLByID(id)
		score := *hit.Score

		site := util.ObjToString(doc["site"])
		if site == "中华人民共和国自然资源部" {
			doc["title"] = "土地出让" + "-" + util.ObjToString(doc["title"])
		}
		doc["score"] = score //相似度

		detail := util.ObjToString(doc["detail"])
		if !strings.Contains(detail, projectName) {
			continue
		}
		//detail := util.ObjToString(doc["detail"])
		//if !strings.Contains(detail, buyer2) {
		//	continue
		//}
		// **去重逻辑**：如果 `projectname` 已经出现过，则跳过
		if seenProjectNames[projectNameValue] && bidamount == bidamountMap[projectNameValue] {
			continue
		}

		// **记录该 `projectname`，避免重复**
		seenProjectNames[projectNameValue] = true
		bidamountMap[projectNameValue] = bidamount

		// **存入 MongoDB**
		//err = MgoB.InsertOrUpdate("qfw", "wcc_20250312_bidding", doc)
		//if err != nil {
		//	log.Println("MongoDB 插入失败:", doc["id"])
		//}

		// **加入结果集**
		results = append(results, doc)

		// **如果已经找到 6 条不同 `projectname`，就跳出循环**
		if len(results) >= 10 {
			break
		}
	}

	//2、判断正文包含采购单位
	for _, hit := range searchResult.Hits.Hits {
		var doc map[string]interface{}
		err := json.Unmarshal(hit.Source, &doc)
		if err != nil {
			log.Printf("解析文档失败：%s", err)
			continue
		}

		// 获取 `projectname`，防止 key 不存在时的错误
		projectNameValue, ok := doc["projectname"].(string)
		bidamount := util.Float64All(doc["bidamount"])
		if !ok {
			log.Printf("⚠️ 缺少 projectname 字段，跳过：%v", doc)
			continue
		}

		// **处理额外字段**
		id := util.ObjToString(doc["id"])
		doc["jyhref"] = GetJyURLByID(id)
		score := *hit.Score
		doc["score"] = score //相似度
		site := util.ObjToString(doc["site"])
		if site == "中华人民共和国自然资源部" {
			doc["title"] = "土地出让" + "-" + util.ObjToString(doc["title"])
		}
		//detail := util.ObjToString(doc["detail"])
		//if !strings.Contains(detail, projectName) {
		//	continue
		//}
		//判断正文包含采购单位
		detail := util.ObjToString(doc["detail"])
		if !strings.Contains(detail, buyer2) {
			continue
		}
		// **去重逻辑**：如果 `projectname` 已经出现过，则跳过
		if seenProjectNames[projectNameValue] && bidamount == bidamountMap[projectNameValue] {
			continue
		}

		// **记录该 `projectname`，避免重复**
		seenProjectNames[projectNameValue] = true
		bidamountMap[projectNameValue] = bidamount

		// **存入 MongoDB**
		//err = MgoB.InsertOrUpdate("qfw", "wcc_20250312_bidding", doc)
		//if err != nil {
		//	log.Println("MongoDB 插入失败:", doc["id"])
		//}

		// **加入结果集**
		results = append(results, doc)

		// **如果已经找到 6 条不同 `projectname`，就跳出循环**
		if len(results) >= 10 {
			break
		}
	}

	//for _, vv := range results {
	//	id := util.ObjToString(vv["id"])
	//	bidData, _ := MgoB.FindById("bidding", id, nil)
	//	MgoB.SaveByOriID("wcc_biddind_20250318", bidData)
	//}
	return results, nil
}

// searchES 查询 ES，返回前 6 个相似 `projectname`
func searchES222(client *elastic.Client, projectName string) ([]map[string]interface{}, error) {
	//query := elastic.NewMatchQuery("projectname", projectName)
	query := elastic.NewBoolQuery().
		Must(
			elastic.NewMatchQuery("projectname.pname", projectName), // 匹配 projectname
			elastic.NewMatchQuery("area", "安徽"),                     // 匹配 projectname
			elastic.NewTermsQuery("subtype", "中标", "成交", "合同"),      // 过滤 subtype
		)

	searchResult, err := client.Search().
		Index("bidding").
		Query(query).
		Size(12). // 取前 6 条数据
		Do(context.Background())

	if err != nil {
		return nil, err
	}

	var results []map[string]interface{}
	for _, hit := range searchResult.Hits.Hits {
		var doc map[string]interface{}
		err := json.Unmarshal(hit.Source, &doc)
		if err != nil {
			log.Printf("解析文档失败：%s", err)
			continue
		}
		id := util.ObjToString(doc["id"])
		doc["jyhref"] = GetJyURLByID(id)
		score := *hit.Score
		doc["score"] = score //相似度

		err = MgoB.InsertOrUpdate("qfw", "wcc_20250312_bidding", doc)
		//if err != nil {
		//	log.Println("error", doc["id"])
		//}

		results = append(results, doc)
	}
	return results, nil
}

func getColumnLetter(index int) string {
	col := ""
	for index > 0 {
		index--
		col = string(rune('A'+index%26)) + col
		index /= 26
	}
	return col
}