es升级

customerdata/src/util.go

@@ -1181,7 +1181,7 @@ func SkipData(tmp map[string]interface{}) bool {
 }
 
 func GetProjectId(id string) (string, int64, int64) {
-	query := `{"query": {"bool": {"must": [{"term": {"projectset.ids": "%s"}}],"must_not": [],"should": []}}}`
+	query := `{"query": {"bool": {"must": [{"term": {"ids": "%s"}}],"must_not": [],"should": []}}}`
 	querys := fmt.Sprintf(query, id)
 	projectId := ""
 	zbtime, yitime := int64(0), int64(0)

src/history/util_history.go

@@ -2263,7 +2263,7 @@ func PathExists(path string) (bool, error) {
 }
 
 func GetProjectId(id string) (string, int64, int64) {
-	query := `{"query": {"bool": {"must": [{"term": {"projectset.ids": "%s"}}],"must_not": [],"should": []}}}`
+	query := `{"query": {"bool": {"must": [{"term": {"ids": "%s"}}],"must_not": [],"should": []}}}`
 	querys := fmt.Sprintf(query, id)
 	projectId := ""
 	zbtime, yitime := int64(0), int64(0)

src/service/second_push.go

@@ -123,7 +123,7 @@ func (s *SecondPush) GetUserRule() {
 	}
 }
 
-//保存二次推送规则
+// 保存二次推送规则
 func (s *SecondPush) SaveSpushRule() {
 	rules_id := s.GetString("rulesid")
 	s_pushid := s.GetString("s_pushid")
@@ -333,7 +333,7 @@ func searchProjectId(l map[string]interface{}, updateMap [][]map[string]interfac
 	return updateMap
 }
 func GetProjectId(id string) string {
-	query := `{"query": {"bool": {"must": [{"term": {"projectset.ids": "%s"}}],"must_not": [],"should": []}}}`
+	query := `{"query": {"bool": {"must": [{"term": {"ids": "%s"}}],"must_not": [],"should": []}}}`
 	querys := fmt.Sprintf(query, id)
 	projectId := ""
 	projectIdArr := []string{}