datatools/esUpdate/main.go

package main

import (
	"log"
	"net/url"

	elastic "es"
	common "qfw/util"
)

var (
	Es  elastic.Es
	cfg = new(Config)
)

func init() {
	common.ReadConfig(&cfg)
	Es = elastic.NewEs(cfg.Es.Version, cfg.Es.Address, cfg.Es.DbSize, cfg.Es.UserName, cfg.Es.Password)
}

func main() {
	var dataType = 1 //1-修改 2-删除
	if dataType == 1 {
		updateData()
	} else if dataType == 2 {
		delData()
	}
}

func updateData() {
	count := Es.Count("bidding", "bidding", `{"query":{"bool":{"must":[{"range":{"publishtime":{"gte":1700409600,"lt":1700496000}}}]}}}`)
	log.Println("数量 ", count)
	return
	data := Es.GetById("bidding", "bidding", "5c1bcdd1a5cb26b9b77912f6")
	if data != nil && len(*data) > 0 {
		dataMap := (*data)[0]
		dataMap["title"] = `中国水泥厂有限公司孔山水泥用灰岩矿闭坑地质报告编制项目`
		ok := Es.UpdateNewDoc("bidding", "bidding", dataMap)
		if ok {
			log.Println("修改成功")
		}
	}
}

func delData() {
	a := []string{
		"ABCY1xBdDwOLyo7Ent1c3IJIjMCCj10V3dgKw4gPy8eeFZwGAFUCRI%3D",
		"ABCY1xBdDIvIyMsM391c3IJIjMCCj10V3dgK1gsPyEeVX1zZ1JUChs%3D",
		"ABCY1xBdDIvIyMsM391c3IJIjMCCj10V3dgK1gsPyEeUX1zZ15UCiM%3D",
		"ABCY1xBdDIvIyMsM391c3IJIjMCCj10V3dgK1gsPyEeWlVzYS9UCc8%3D",
		"ABCY1xBdDIvIy04NH91c3IJIjMCCj10V3dgK1gsNj0gUXlzdjNUCi8%3D",
		"ABCY1xBdSlYUTYsJFV1c3IJIjMCCj10V3dgK1gjJiEdfFNzfgVUCeg%3D",
		"ABCY1xBdSlYLDksJFl1c3IJIjMCCj10V3dgK1gjKTogeFVzcRlUCe4%3D",
		"ABCY1xBdSkFKDYvRGN1c3IJIjMCCj10V3dgK1gjKDoge3xzcQlUCdo%3D",
		"ABCY1xBdSkFODk7JGd1c3IJIjMCCj10V3dgK1gjKDoNZFFwDlpUCXM%3D",
		"ABCY1xBdTIvOD8vGXxlc08oMCcoSCd3XHx2KDgjKi4neFVzYidUCjI%3D",
	}
	for _, v := range a {
		vv, _ := url.QueryUnescape(v)
		vid := common.CommonDecodeArticle("content", vv)[0]
		log.Println(vid)
		// ok := Es.DelById("bidding", "bidding", vid)
		// if ok {
		// 	log.Println("删除成功")
		// }
	}
}