90 lines
2.4 KiB
Go
90 lines
2.4 KiB
Go
package impl
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/infraboard/mcube/v2/ioc/config/datasource"
|
|
"gitlab.com/go-course-project/go17/vblog/apps/blog"
|
|
"gitlab.com/go-course-project/go17/vblog/middleware"
|
|
)
|
|
|
|
var BlogService blog.Service = &BlogServiceImpl{}
|
|
|
|
// 定义一个struct, 用于实现 UserService就是刚才定义的接口
|
|
// 怎么才能判断这个结构体没有实现这个接口
|
|
type BlogServiceImpl struct {
|
|
}
|
|
|
|
// CreateBlog implements blog.Service.
|
|
func (b *BlogServiceImpl) CreateBlog(ctx context.Context, in *blog.CreateBlogRequest) (*blog.Blog, error) {
|
|
ins, err := blog.NewBook(in)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// 冲上下文中补充 创建人
|
|
tk := middleware.GetTokenFromCtx(ctx)
|
|
ins.CreateBy = tk.RefUserName
|
|
|
|
err = datasource.DBFromCtx(ctx).Create(ins).Error
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return ins, nil
|
|
}
|
|
|
|
// QueryBlog implements blog.Service.
|
|
func (b *BlogServiceImpl) QueryBlog(ctx context.Context, in *blog.QueryBlogRequest) (*blog.BlogSet, error) {
|
|
query := datasource.DBFromCtx(ctx).Model(&blog.Blog{})
|
|
if in.Keywords != "" {
|
|
query = query.Where("title LIKE ?", "%"+in.Keywords+"%")
|
|
}
|
|
if in.Stage != nil {
|
|
query = query.Where("stage = ?", in.Stage)
|
|
}
|
|
if in.CreateBy != "" {
|
|
query = query.Where("create_by = ?", in.CreateBy)
|
|
}
|
|
if in.Category != "" {
|
|
query = query.Where("category = ?", in.Category)
|
|
}
|
|
for k, v := range in.Tags {
|
|
query = query.Where(fmt.Sprintf("tags->>'$.%s' = ?", k), v)
|
|
}
|
|
set := blog.NewBlogSet()
|
|
|
|
// COUNT
|
|
if err := query.Count(&set.Total).Error; err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// 处理分页
|
|
err := query.Order("created_at DESC").Offset(int(in.Offset())).Limit(int(in.PageSize)).Find(&set.Items).Error
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return set, nil
|
|
}
|
|
|
|
// DeleteBlog implements blog.Service.
|
|
func (b *BlogServiceImpl) DeleteBlog(context.Context, *blog.DeleteBlogRequest) error {
|
|
panic("unimplemented")
|
|
}
|
|
|
|
// DescribeBlog implements blog.Service.
|
|
func (b *BlogServiceImpl) DescribeBlog(context.Context, *blog.DescribeBlogRequest) (*blog.Blog, error) {
|
|
panic("unimplemented")
|
|
}
|
|
|
|
// PublishBlog implements blog.Service.
|
|
func (b *BlogServiceImpl) PublishBlog(context.Context, *blog.PublishBlogRequest) (*blog.Blog, error) {
|
|
panic("unimplemented")
|
|
}
|
|
|
|
// UpdateBlog implements blog.Service.
|
|
func (b *BlogServiceImpl) UpdateBlog(context.Context, *blog.UpdateBlogRequest) (*blog.Blog, error) {
|
|
panic("unimplemented")
|
|
}
|