no message

services/es_comprehensive.go

@@ -47,7 +47,7 @@ type ElasticComprehensiveDetail struct {
 
 //func init() {
 //	AddComprehensiveIndustrialSource("Hz", 0)
-//	// AddComprehensiveArticle(0)
+//	//AddComprehensiveChart(0)
 //	// AddComprehensiveMeetingreviewchapt()
 //}
 
@@ -106,6 +106,7 @@ func AddComprehensiveArticle(articleId int) {
 	}
 	//indexName := utils.IndexNameComprehensive
 	for _, v := range articleList {
+		time.Sleep(200 * time.Millisecond)
 		content := html.UnescapeString(v.Body)
 		doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
 		if err != nil {
@@ -155,6 +156,7 @@ func AddComprehensiveChart(chartId int) {
 	}
 	//indexName := utils.IndexNameComprehensive
 	for _, v := range list {
+		time.Sleep(200 * time.Millisecond)
 		item := new(ElasticComprehensiveDetail)
 		item.SourceId = v.ChartId
 		item.Source = "newchart"
@@ -210,6 +212,7 @@ func AddComprehensiveIndustrialSource(sourceType string, articleId int) {
 	}
 	//indexName := utils.IndexNameComprehensive
 	for _, v := range list {
+		time.Sleep(200 * time.Millisecond)
 		item := new(ElasticComprehensiveDetail)
 		item.SourceId = v.IndustrialManagementId
 		item.Source = industrialsource
@@ -241,6 +244,7 @@ func AddComprehensiveMeetingreviewchapt() {
 	}
 	//indexName := utils.IndexNameComprehensive
 	for _, v := range list {
+		time.Sleep(200 * time.Millisecond)
 		content := html.UnescapeString(v.Content)
 		doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
 		if err != nil {
@@ -303,6 +307,7 @@ func AddComprehensiveActivity() {
 
 	//return
 	for _, v := range list {
+		time.Sleep(200 * time.Millisecond)
 		item := new(ElasticComprehensiveDetail)
 		item.SourceId = v.ActivityId
 		//item.IsSummary = v.IsSummary
@@ -364,6 +369,7 @@ func AddComprehensiveActivitySpecial() {
 		mapActivitySubject[v.ActivityId] = append(mapActivitySubject[v.ActivityId], IndustrialSubjectMap[v.IndustrialSubjectId])
 	}
 	for _, v := range list {
+		time.Sleep(200 * time.Millisecond)
 		item := new(ElasticComprehensiveDetail)
 		item.SourceId = v.ActivityId
 		item.Source = "activityspecial"
@@ -453,6 +459,7 @@ func AddComprehensiveActivityVideo() {
 
 	//indexName := utils.IndexNameComprehensive
 	for _, v := range list {
+		time.Sleep(200 * time.Millisecond)
 		item := new(ElasticComprehensiveDetail)
 		item.SourceId = v.Id
 		item.Source = "activityvideo"
@@ -539,6 +546,7 @@ func AddComprehensiveActivityVoice() {
 	}
 	//indexName := utils.IndexNameComprehensive
 	for _, v := range list {
+		time.Sleep(200 * time.Millisecond)
 		item := new(ElasticComprehensiveDetail)
 		item.SourceId = v.ActivityVoiceId
 		item.Source = "activityvoice"
@@ -564,6 +572,7 @@ func AddComprehensiveRoadshow() {
 	}
 	//indexName := utils.IndexNameComprehensive
 	for _, v := range list {
+		time.Sleep(200 * time.Millisecond)
 		item := new(ElasticComprehensiveDetail)
 		item.SourceId = v.VideoId
 		item.Source = "roadshow"