lsm/mindoc
1
0
Fork 0
mirror of https://github.com/mindoc-org/mindoc.git synced 2025-09-23 04:36:49 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

1、实现文章阅读、附件功能

Browse Source 
2、实现与关联项目同步功能
3、实现附件删除功能
This commit is contained in:
lifei6671
2018-07-18 17:10:24 +08:00
parent 86637ef581
commit 2416af4528
15 changed files with 653 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

116
models/Blog.go
View File

@@ -18,10 +18,18 @@ type Blog struct {
OrderIndex int `orm:"column(order_index);type(int);default(0)" json:"order_index"`
//所属用户
MemberId int `orm:"column(member_id);type(int);default(0):index" json:"member_id"`
//用户头像
MemberAvatar string `orm:"-" json:"member_avatar"`
//文章类型:0 普通文章/1 链接文章
BlogType int `orm:"column(blog_type);type(int);default(0)" json:"blog_type"`
//链接到的项目中的文档ID
DocumentId int `orm:"column(document_id);type(int);default(0)" json:"document_id"`
//文章的标识
DocumentIdentify string `orm:"-" json:"document_identify"`
//关联文档的项目标识
BookIdentify string `orm:"-" json:"book_identify"`
//关联文档的项目ID
BookId int `orm:"-" json:"book_id"`
//文章摘要
BlogExcerpt string `orm:"column(blog_excerpt);size(1500)" json:"blog_excerpt"`
//文章内容
@@ -42,6 +50,8 @@ type Blog struct {
CreateName string `orm:"-" json:"create_name"`
//版本号
Version int64 `orm:"type(bigint);column(version)" json:"version"`
//附件列表
AttachList []*Attachment `orm:"-" json:"attach_list"`
}
// 多字段唯一键
@@ -81,7 +91,8 @@ func (b *Blog) Find(blogId int) (*Blog,error) {
return nil,err
}
return b,nil
return b.Link()
}
//查找指定用户的指定文章
func (b *Blog) FindByIdAndMemberId(blogId,memberId int) (*Blog,error) {
@@ -93,7 +104,7 @@ func (b *Blog) FindByIdAndMemberId(blogId,memberId int) (*Blog,error) {
return nil,err
}
return b,nil
return b.Link()
}
//根据文章标识查询文章
func (b *Blog) FindByIdentify(identify string) (*Blog,error) {
@@ -106,18 +117,49 @@ func (b *Blog) FindByIdentify(identify string) (*Blog,error) {
}
return b,nil
}
//获取指定文章的链接内容
func (b *Blog)Link() (*Blog,error) {
o := orm.NewOrm()
//如果是链接文章，则需要从链接的项目中查找文章内容
if b.BlogType == 1 && b.DocumentId > 0{
if b.BlogType == 1 && b.DocumentId > 0 {
doc := NewDocument()
if err := o.QueryTable(doc.TableNameWithPrefix()).Filter("document_id",b.DocumentId).One(doc,"release","markdown");err != nil {
if err := o.QueryTable(doc.TableNameWithPrefix()).Filter("document_id",b.DocumentId).One(doc,"release","markdown","identify","book_id");err != nil {
beego.Error("查询文章链接对象时出错 -> ",err)
}else{
b.DocumentIdentify = doc.Identify
b.BlogRelease = doc.Release
//目前仅支持markdown文档进行链接
b.BlogContent = doc.Markdown
book := NewBook()
if err := o.QueryTable(book.TableNameWithPrefix()).Filter("book_id",doc.BookId).One(book,"identify");err != nil {
beego.Error("查询关联文档的项目时出错 ->",err)
}else{
b.BookIdentify = book.Identify
b.BookId = doc.BookId
}
}
}
if b.ModifyAt > 0{
member := NewMember()
if err := o.QueryTable(member.TableNameWithPrefix()).Filter("member_id",b.ModifyAt).One(member,"real_name","account"); err == nil {
if member.RealName != ""{
b.ModifyRealName = member.RealName
}else{
b.ModifyRealName = member.Account
}
}
}
if b.MemberId > 0 {
member := NewMember()
if err := o.QueryTable(member.TableNameWithPrefix()).Filter("member_id",b.MemberId).One(member,"real_name","account","avatar"); err == nil {
if member.RealName != ""{
b.CreateName = member.RealName
}else{
b.CreateName = member.Account
}
b.MemberAvatar = member.Avatar
}
}
@@ -130,11 +172,12 @@ func (b *Blog) IsExist(identify string) bool {
return o.QueryTable(b.TableNameWithPrefix()).Filter("blog_identify",identify).Exist()
}
//保存文章
func (b *Blog) Save(cols ...string) error {
o := orm.NewOrm()
if b.OrderIndex == 0 {
if b.OrderIndex <= 0 {
blog := NewBlog()
if err :=o.QueryTable(b.TableNameWithPrefix()).OrderBy("-blog_id").One(blog,"blog_id");err == nil{
b.OrderIndex = b.BlogId + 1;
@@ -149,11 +192,13 @@ func (b *Blog) Save(cols ...string) error {
b.Modified = time.Now()
_,err = o.Update(b,cols...)
}else{
b.Created = time.Now()
_,err = o.Insert(b)
}
return err
}
//分页查询文章列表
func (b *Blog) FindToPager(pageIndex, pageSize int,memberId int,status string) (blogList []*Blog, totalCount int, err error) {
@@ -171,7 +216,7 @@ func (b *Blog) FindToPager(pageIndex, pageSize int,memberId int,status string) (
}
_,err = query.OrderBy("-order_index").Offset(offset).Limit(pageSize).All(&blogList)
_,err = query.OrderBy("-order_index","-blog_id").Offset(offset).Limit(pageSize).All(&blogList)
if err != nil {
if err == orm.ErrNoRows {
@@ -205,4 +250,63 @@ func (b *Blog) Delete(blogId int) error {
beego.Error("删除文章失败 ->",err)
}
return err
}
//查询下一篇文章
func (b *Blog) QueryNext(blogId int) (*Blog,error) {
o := orm.NewOrm()
blog := NewBlog()
if err := o.QueryTable(b.TableNameWithPrefix()).Filter("blog_id",blogId).One(blog,"order_index"); err != nil {
beego.Error("查询文章时出错 ->",err)
return b,err
}
err := o.QueryTable(b.TableNameWithPrefix()).Filter("order_index__gte",blog.OrderIndex).Filter("blog_id__gt",blogId).OrderBy("-order_index","-blog_id").One(blog)
if err != nil {
beego.Error("查询文章时出错 ->",err)
}
return blog,err
}
//查询下一篇文章
func (b *Blog) QueryPrevious(blogId int) (*Blog,error) {
o := orm.NewOrm()
blog := NewBlog()
if err := o.QueryTable(b.TableNameWithPrefix()).Filter("blog_id",blogId).One(blog,"order_index"); err != nil {
beego.Error("查询文章时出错 ->",err)
return b,err
}
err := o.QueryTable(b.TableNameWithPrefix()).Filter("order_index__lte",blog.OrderIndex).Filter("blog_id__lt",blogId).OrderBy("-order_index","-blog_id").One(blog)
if err != nil {
beego.Error("查询文章时出错 ->",err)
}
return blog,err
}
//关联文章附件
func (b *Blog) LinkAttach() (err error) {
o := orm.NewOrm()
var attachList []*Attachment
//当不是关联文章时，用文章ID去查询附件
if b.BlogType != 1 || b.DocumentId <= 0 {
_, err = o.QueryTable(NewAttachment().TableNameWithPrefix()).Filter("document_id", b.BlogId).Filter("book_id",0).All(&attachList)
if err != nil {
beego.Error("查询文章附件时出错 ->", err)
}
}else {
_, err = o.QueryTable(NewAttachment().TableNameWithPrefix()).Filter("document_id", b.DocumentId).Filter("book_id", b.BookId).All(&attachList)
if err != nil {
beego.Error("查询文章附件时出错 ->", err)
}
}
b.AttachList = attachList
return
}