修复观点库es

main.go

@@ -25,7 +25,8 @@ func main() {
 		web.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
 	}
 
-	MigrateKnowledgeResource()
+	//MigrateKnowledgeResource()
+	FixKnowledgeEs()
 	// go services.Task()
 
 	// 初始化表数据入库
@@ -209,3 +210,30 @@ func MigrateKnowledgeResource() {
 
 	}
 }
+
+func FixKnowledgeEs() {
+	fmt.Println("开始修复")
+	var err error
+	defer func() {
+		if err != nil {
+			fmt.Printf("修复ES失败, %v\n", err)
+		}
+		fmt.Println("修复完成")
+	}()
+
+	condition := " AND resource_type = 4"
+	list, e := knowledge.GetBatchKnowledgeResourceByCondition(condition, make([]interface{}, 0), 10000)
+	if e != nil {
+		err = fmt.Errorf("get list err: %v", e)
+		return
+	}
+
+	for _, v := range list {
+		fmt.Printf("fixing, id: %d, title: %s\n", v.KnowledgeResourceId, v.Title)
+		e = knowledgeSrv.EsAddOrEditKnowledgeResource(v)
+		if e != nil {
+			fmt.Printf("write err, id: %d, title: %s\n", v.KnowledgeResourceId, v.Title)
+			continue
+		}
+	}
+}