es index

conf/app.conf

@@ -13,7 +13,7 @@ host = aiprose.com
 httpport = 8082
 uploadDir = "static/upload/"
 imgUrlPrefix = "http://localhost:8082/static/upload/"
-dburl = "booszy@tcp(47.98.109.5:3306)"
+dburl = "booszy@tcp(localhost:3306)"
 
 [prod]
 httpport = 8082

controllers/BlogController.go

@@ -130,8 +130,7 @@ func (this *BlogController) Get() {
 	if blogs, err := blogService.TopBlogByUser(blog.UserId); err == nil {
 		this.Data["Top"] = blogs
 	}
-	//utils.Index()
-	utils.ESSave(blog)
+
 	this.Data["Blog"] = blog
 	this.Data["UserId"] = this.GetSession("userid")
 	this.Data["HeadImg"] = this.GetSession("headimg")
@@ -236,3 +235,20 @@ func (this *BlogController) Search() {
 	this.Data["json"] = models.ReurnData("", blog)
 	this.ServeJSON()
 }
+
+func (this *BlogController) SyncBlog() {
+	utils.Index()
+	blogService := service.BlogService{}
+	list, err := blogService.AllBlogs()
+	var i = 0
+	if err != nil {
+		this.Data["json"] = models.ReurnError(500,"");
+		this.ServeJSON()
+	}
+	for index := range list {
+		utils.ESSave(list[index])
+		i++
+	}
+	this.Data["json"] = models.ReurnData("",i)
+	this.ServeJSON()
+}

routers/BlogRouter.go

@@ -14,4 +14,5 @@ func init() {
 	beego.Router("/blogs", &controllers.BlogController{}, "get:BlogsPage")
 	beego.Router("/blog/new", &controllers.BlogController{}, "get:New")
 	beego.Router("/open/blog/search", &controllers.BlogController{}, "get:Search")
+	beego.Router("/es/blog/index", &controllers.BlogController{}, "put:SyncBlog")
 }

service/BlogService.go

@@ -133,6 +133,21 @@ func (this *BlogService) FindBlogs(num int, size int, cat int64, flag int) (*uti
 	return page, nil
 }
 
+
+func (this *BlogService) AllBlogs() ([]*models.Blog, error) {
+
+	var blogs []*models.Blog
+	o := orm.NewOrm()
+	qs := o.QueryTable(&models.Blog{})
+	qs = qs.Filter("Delflag", 0)
+	_, err := qs.All(&blogs)
+	if err != nil {
+		return nil, err
+	}
+	return blogs, nil
+}
+
+
 func (this *BlogService) SaveBlog(blog *models.Blog, strs []string) error {
 	o := orm.NewOrm()
 	o.Begin()