修复 索引预处理 按 天 处理时的索引名称错误

pre_extract/es.go

@@ -425,6 +425,8 @@ func dealAlias() {
 	username := GF.ES.Username
 	password := GF.ES.Password
 
+	preBiddingIndex := "" //下一个索引名称
+	currIndex := ""       //当前索引名称
 	// 创建 Elasticsearch 客户端
 	client, err := elastic.NewClient(
 		elastic.SetURL(url),
@@ -439,23 +441,36 @@ func dealAlias() {
 	monthStr := strconv.Itoa(month)
 	year := next.Year()
 	yearStr := strconv.Itoa(year)
-	//下一个月的索引名称
-	preBiddingIndex := "bidding_" + yearStr + monthStr
+	dayStr := strconv.Itoa(next.Day())
+	if GF.Env.SpecType == "month" {
+		//下一个月的索引名称
+		preBiddingIndex = "bidding_" + yearStr + monthStr
+	} else if GF.Env.SpecType == "day" {
+		//下一天的索引名称
+		preBiddingIndex = "bidding_" + yearStr + monthStr + dayStr
+	}
 
 	month2 := int(now.Month())
 	monthStr2 := strconv.Itoa(month2)
 	year2 := now.Year()
 	yearStr2 := strconv.Itoa(year2)
-	//当前；的索引名称
-	currIndex := "bidding_" + yearStr2 + monthStr2
+	if GF.Env.SpecType == "month" {
+		//当前；的索引名称
+		currIndex = "bidding_" + yearStr2 + monthStr2
+	} else if GF.Env.SpecType == "day" {
+		//当前；的索引名称
+		currIndex = "bidding_" + yearStr2 + monthStr2 + strconv.Itoa(now.Day())
+	}
 
 	_, err = client.Alias().Add(preBiddingIndex, GF.Env.Alias).Do(context.Background())
 	if err != nil {
 		log.Error("添加别名失败：", zap.Error(err))
+		SendMail("添加别名失败", "添加别名失败，请检查")
 	}
 	_, err = client.Alias().Remove(currIndex, GF.Env.Alias).Do(context.Background())
 	if err != nil {
 		log.Error("删除别名失败：", zap.Error(err))
+		SendMail("删除别名失败", "删除别名失败，请检查")
 	}
 }