码农笔录博客源码
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

252 lines
5.7 KiB

преди 6 години
package service
import (
"github.com/astaxie/beego/orm"
"beeblog/models"
преди 6 години
"beeblog/utils"
преди 6 години
)
преди 6 години
type BlogService struct {
}
func (this *BlogService) count(num int, size int, cat int64) (*utils.Page, error) {
преди 6 години
o := orm.NewOrm()
qs := o.QueryTable(&models.Blog{})
qs.Filter("Delflag", 0)
if cat != -1 {
qs = qs.Filter("CategoryId", cat)
}
totalCount, err := qs.Count()
if err != nil {
return nil, err
}
return utils.PageUtil(totalCount, num, size), nil
}
преди 6 години
func (this *BlogService) countByUser(num int, size int, uid int64) (*utils.Page, error) {
преди 6 години
o := orm.NewOrm()
qs := o.QueryTable(&models.Blog{})
totalCount, err := qs.Filter("Delflag", 0).Filter("UserId", uid).Count()
if err != nil {
return nil, err
}
return utils.PageUtil(totalCount, num, size), nil
}
преди 6 години
func (this *BlogService) EditBlogBrows(id int64) {
преди 6 години
o := orm.NewOrm()
blog := &models.Blog{Id: id}
err := o.Read(blog)
if err == nil {
blog.Browses += 1
o.Update(blog, "Browses")
}
}
преди 6 години
func (this *BlogService) TopBlogByUser(uid int64) ([]*models.Blog, error) {
преди 6 години
o := orm.NewOrm()
var blogs []*models.Blog
преди 6 години
o.QueryTable(models.Blog{}).Filter("Delflag", 0).Filter("UserId", uid).Limit(12, 0).OrderBy("-Browses").All(&blogs)
преди 6 години
return blogs, nil
}
преди 6 години
func (this *BlogService) ReadBlog(id int64) (*models.Blog, error) {
преди 6 години
o := orm.NewOrm()
blog := &models.Blog{Id: id}
преди 6 години
if err := o.Read(blog); err != nil {
преди 6 години
return nil, err
}
return blog, nil
}
преди 6 години
func (this *BlogService) GetBlog(id int64) (*models.Blog, error) {
commentService := CommentService{}
преди 6 години
o := orm.NewOrm()
преди 6 години
blog := &models.Blog{Id: id}
преди 6 години
err := o.Read(blog)
if err != nil {
return nil, err
}
преди 6 години
user := &models.User{Id: blog.UserId}
err = o.Read(user)
if err == nil {
blog.User = user
преди 6 години
}
var labels []*models.NLabel
qs := o.QueryTable(&models.NLabel{})
преди 6 години
_, err = qs.Filter("BlogId", id).All(&labels)
преди 6 години
if err == nil {
blog.Lables = labels
}
преди 6 години
comms, berr := commentService.FindCommentByBlog(id)
преди 6 години
if berr == nil {
преди 6 години
blog.Comms = comms
}
преди 6 години
return blog, nil
}
преди 6 години
func (this *BlogService) DelBlog(blog *models.Blog) error {
преди 6 години
o := orm.NewOrm()
_, err := o.Update(blog, "Delflag")
return err
}
преди 6 години
func (this *BlogService) FindBlogs(num int, size int, cat int64, flag int) (*utils.Page, error) {
page, err := this.count(num, size, cat)
преди 6 години
if err != nil {
return nil, err
}
var blogs []*models.Blog
преди 6 години
o := orm.NewOrm()
qs := o.QueryTable(&models.Blog{})
преди 6 години
qs = qs.Filter("Delflag", 0)
if cat != -1 {
qs = qs.Filter("CategoryId", cat)
}
if flag == 0 {
qs = qs.OrderBy("-Ctime")
} else {
qs = qs.OrderBy("-Browses")
}
преди 6 години
qs = qs.Limit(size, (page.PageNo-1)*size)
преди 6 години
_, err = qs.All(&blogs)
преди 6 години
if err != nil {
return nil, err
}
преди 6 години
if len(blogs) > 0 {
for i := 0; i < len(blogs); i++ {
user := &models.User{Id: blogs[i].UserId}
err = o.Read(user)
if err == nil {
blogs[i].UserName = user.UserName
blogs[i].HeadImg = user.Headimg
}
category := &models.Category{Id: blogs[i].CategoryId}
err = o.Read(category)
if err == nil {
blogs[i].CateName = category.Title
}
}
}
преди 6 години
page.List = blogs
return page, nil
преди 6 години
}
преди 5 години
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
}
преди 6 години
func (this *BlogService) SaveBlog(blog *models.Blog, strs []string) error {
преди 6 години
o := orm.NewOrm()
преди 6 години
o.Begin()
преди 6 години
id, eror := o.Insert(blog)
if eror != nil {
преди 6 години
o.Rollback()
преди 6 години
return eror
} else {
blog.Id = id
преди 6 години
if strs != nil && len(strs) > 0 {
преди 6 години
nlabels := make([]*models.NLabel, len(strs))
преди 6 години
for i := 0; i < len(strs); i++ {
преди 6 години
nlabels[i] = &models.NLabel{Title: strs[i], BlogId: id, UserId: blog.UserId}
}
if _, err := o.InsertMulti(len(nlabels), nlabels); err != nil {
o.Rollback()
return err
преди 6 години
}
}
преди 6 години
o.Commit()
}
return nil
}
преди 6 години
преди 6 години
func (this *BlogService) EditBlog(blog *models.Blog, strs []string) error {
преди 6 години
o := orm.NewOrm()
o.Begin()
преди 6 години
_, eror := o.Update(blog)
преди 6 години
if eror != nil {
o.Rollback()
return eror
} else {
преди 6 години
o.QueryTable(models.NLabel{}).Filter("BlogId", blog.Id).Delete()
преди 6 години
if strs != nil && len(strs) > 0 {
nlabels := make([]*models.NLabel, len(strs))
for i := 0; i < len(strs); i++ {
преди 6 години
nlabels[i] = &models.NLabel{Title: strs[i], BlogId: blog.Id, UserId: blog.UserId}
преди 6 години
}
if _, err := o.InsertMulti(len(nlabels), nlabels); err != nil {
o.Rollback()
return err
}
}
o.Commit()
}
return nil
}
преди 6 години
func (this *BlogService) MeBlogs(num int, size int, flag int, uid int64) (*utils.Page, error) {
page, err := this.countByUser(num, size, uid)
преди 6 години
if err != nil {
return nil, err
}
var blogs []*models.Blog
o := orm.NewOrm()
qs := o.QueryTable(&models.Blog{})
qs = qs.Filter("Delflag", 0)
qs = qs.Filter("UserId", uid)
if flag == 0 {
qs = qs.OrderBy("-Ctime")
} else {
qs = qs.OrderBy("-Browses")
}
qs = qs.Limit(size, (page.PageNo-1)*size)
_, err = qs.All(&blogs)
if err != nil {
return nil, err
}
page.List = blogs
return page, nil
}
преди 6 години
преди 6 години
func (this *BlogService) IndexBlogs(size int, flag int) ([]*models.Blog, error) {
преди 6 години
var blogs []*models.Blog
o := orm.NewOrm()
qs := o.QueryTable(&models.Blog{})
qs = qs.Filter("Delflag", 0)
switch flag {
case 0:
qs = qs.OrderBy("-Ctime") //最新
case 1:
qs = qs.OrderBy("-Browses") //浏览量
case 2:
qs = qs.OrderBy("-Likes") // 收藏量
case 3:
qs = qs.OrderBy("-Comments") // 评论量
}
qs = qs.Limit(size, 0)
_, err := qs.All(&blogs)
return blogs, err
}
преди 6 години
func (this *BlogService) GetNLabel(id int64) ([]*models.NLabel, error) {
преди 6 години
var labels []*models.NLabel
o := orm.NewOrm()
_, err := o.QueryTable(&models.NLabel{}).Filter("BlogId", id).All(&labels)
if err != nil {
return labels, err
}
return labels, nil
}