es创建索引保存数据成功

controllers/BlogController.go

@@ -3,6 +3,7 @@ package controllers
 import (
 	"beeblog/models"
 	"beeblog/service"
+	"beeblog/utils"
 	"github.com/astaxie/beego"
 	"strconv"
 	"time"
@@ -103,6 +104,8 @@ func (this *BlogController) Get() {
 	idStr := this.Ctx.Input.Param(":id")
 	id, _ := strconv.ParseInt(idStr, 10, 64)
 	blog, err := blogService.GetBlog(id)
+	blog.User.Salt = ""
+	blog.User.UserPwd = ""
 	if err != nil {
 		this.Redirect("/404", 302)
 		return
@@ -118,6 +121,8 @@ func (this *BlogController) Get() {
 	if blogs, err := blogService.TopBlogByUser(blog.UserId); err == nil {
 		this.Data["Top"] = blogs
 	}
+	//utils.Index()
+	utils.Save(blog)
 	this.Data["Blog"] = blog
 	this.Data["UserId"] = this.GetSession("userid")
 	this.Data["HeadImg"] = this.GetSession("headimg")

main.go

@@ -8,30 +8,8 @@ import (
 	"github.com/astaxie/beego/logs"
 	"github.com/astaxie/beego/orm"
 	"github.com/astaxie/beego/plugins/cors"
-	"github.com/olivere/elastic"
-	"log"
-	"os"
-	"time"
 )
 
-
-var host = "http://47.98.109.5:8209/"
-
-func connect() *elastic.Client {
-	client, err := elastic.NewClient(
-		elastic.SetURL(host),
-		elastic.SetSniff(false),
-		elastic.SetHealthcheckInterval(10*time.Second),
-		elastic.SetGzip(true),
-		elastic.SetErrorLog(log.New(os.Stderr, "ELASTIC ", log.LstdFlags)),
-		elastic.SetInfoLog(log.New(os.Stdout, "", log.LstdFlags)))
-
-	if err != nil {
-		panic(err)
-	}
-	return client
-}
-
 func init() {
 	models.RegistDB()
 	beego.InsertFilter("/*", beego.BeforeRouter, filter.LogFilter)
@@ -50,8 +28,6 @@ func main() {
 		ExposeHeaders:    []string{"Content-Length", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},
 		AllowCredentials: true,
 	}))
-	//client := connect()
-	//fmt.Println("client", client)
 	beego.Run()
 }