Compare commits
merge into: majun:master
majun:dev
majun:master
majun:zzn
pull from: majun:dev
majun:dev
majun:master
majun:zzn
2 Commits
| Author | SHA1 | Message | Date |
|---|---|---|---|
ZHANGZENGNING
|
cfcb706b15 |
初版
|
1 month ago |
|
ZHANGZENGNING
|
b2f18aad31 |
电子书全部查询
|
1 month ago |
41 changed files with 846 additions and 72 deletions
-
15api/hello/hello.go
-
12api/hello/v1/hello.go
-
8api/v1/ebooks/ebooks.go
-
9api/v1/live_streams/live_streams.go
-
11api/v1/shows/shows.go
-
4go.mod
-
56go.sum
-
4hack/config.yaml
-
21internal/cmd/cmd.go
-
23internal/controller/ebooks/ebooks.go
-
5internal/controller/hello/hello.go
-
15internal/controller/hello/hello_new.go
-
13internal/controller/hello/hello_v1_hello.go
-
23internal/controller/live_streams/live_streams.go
-
25internal/controller/shows/shows.go
-
27internal/dao/ebooks.go
-
81internal/dao/internal/ebooks.go
-
85internal/dao/internal/live_streams.go
-
95internal/dao/internal/shows.go
-
27internal/dao/live_streams.go
-
27internal/dao/shows.go
-
25internal/logic/ebooks.go
-
37internal/logic/live_streams.go
-
57internal/logic/shows.go
-
19internal/model/do/ebooks.go
-
22internal/model/do/live_streams.go
-
27internal/model/do/shows.go
-
14internal/model/entity/ebooks.go
-
20internal/model/entity/live_streams.go
-
25internal/model/entity/shows.go
-
27internal/service/ebooks.go
-
27internal/service/live_streams.go
-
26internal/service/shows.go
-
6main.go
-
BINresource/public/resource/image/ebook1.png
-
BINresource/public/resource/image/ebook2.png
-
BINresource/public/resource/image/ebook3.png
-
BINresource/public/resource/image/ebook4.png
-
BINresource/public/resource/image/live/p1.png
-
BINresource/public/resource/image/shows/t1.png
-
BINresource/public/resource/image/shows/v1.png
@ -1,15 +0,0 @@ |
|||||
// =================================================================================
|
|
||||
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
|
||||
// =================================================================================
|
|
||||
|
|
||||
package hello |
|
||||
|
|
||||
import ( |
|
||||
"context" |
|
||||
|
|
||||
"practice_Go/api/hello/v1" |
|
||||
) |
|
||||
|
|
||||
type IHelloV1 interface { |
|
||||
Hello(ctx context.Context, req *v1.HelloReq) (res *v1.HelloRes, err error) |
|
||||
} |
|
||||
@ -1,12 +0,0 @@ |
|||||
package v1 |
|
||||
|
|
||||
import ( |
|
||||
"github.com/gogf/gf/v2/frame/g" |
|
||||
) |
|
||||
|
|
||||
type HelloReq struct { |
|
||||
g.Meta `path:"/hello" tags:"Hello" method:"get" summary:"You first hello api"` |
|
||||
} |
|
||||
type HelloRes struct { |
|
||||
g.Meta `mime:"text/html" example:"string"` |
|
||||
} |
|
||||
@ -0,0 +1,8 @@ |
|||||
|
package ebooks |
||||
|
|
||||
|
import "practice_Go/internal/model/entity" |
||||
|
|
||||
|
type GetEbooksListReq struct{} |
||||
|
type GetEbooksListRes struct { |
||||
|
List []*entity.Ebooks `json:"list" dc:"ebooks list"` |
||||
|
} |
||||
@ -0,0 +1,9 @@ |
|||||
|
package live_streams |
||||
|
|
||||
|
import "practice_Go/internal/model/entity" |
||||
|
|
||||
|
type GetLiveListReq struct { |
||||
|
} |
||||
|
type GetLiveListRes struct { |
||||
|
List []*entity.LiveStreams `json:"list" dc:"LiveStreams list"` |
||||
|
} |
||||
@ -0,0 +1,11 @@ |
|||||
|
package shows |
||||
|
|
||||
|
import "practice_Go/internal/model/entity" |
||||
|
|
||||
|
type ShowReq struct { |
||||
|
QueryType int `v:"required|in:1,2,3,4" p:"queryType"` // 验证参数有效性
|
||||
|
} |
||||
|
|
||||
|
type GetShowsListRes struct { |
||||
|
List []*entity.Shows `json:"list" dc:"shows list"` |
||||
|
} |
||||
@ -0,0 +1,23 @@ |
|||||
|
package ebooks |
||||
|
|
||||
|
import ( |
||||
|
"github.com/gogf/gf/v2/net/ghttp" |
||||
|
"practice_Go/api/v1/ebooks" |
||||
|
ebook "practice_Go/internal/service" |
||||
|
) |
||||
|
|
||||
|
type cEbooks struct{} |
||||
|
|
||||
|
var Ebooks = cEbooks{} |
||||
|
|
||||
|
func (c *cEbooks) GetEbooksList(r *ghttp.Request) { |
||||
|
var req *ebooks.GetEbooksListReq |
||||
|
if err := r.Parse(&req); err != nil { |
||||
|
r.Response.WriteJsonExit(err.Error()) |
||||
|
} |
||||
|
res, err := ebook.Ebooks().GetEbooksList(r.Context(), req) |
||||
|
if err != nil { |
||||
|
r.Response.WriteJsonExit(err.Error()) |
||||
|
} |
||||
|
r.Response.WriteJsonExit(res) |
||||
|
} |
||||
@ -1,5 +0,0 @@ |
|||||
// =================================================================================
|
|
||||
// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
|
|
||||
// =================================================================================
|
|
||||
|
|
||||
package hello |
|
||||
@ -1,15 +0,0 @@ |
|||||
// =================================================================================
|
|
||||
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
|
||||
// =================================================================================
|
|
||||
|
|
||||
package hello |
|
||||
|
|
||||
import ( |
|
||||
"practice_Go/api/hello" |
|
||||
) |
|
||||
|
|
||||
type ControllerV1 struct{} |
|
||||
|
|
||||
func NewV1() hello.IHelloV1 { |
|
||||
return &ControllerV1{} |
|
||||
} |
|
||||
@ -1,13 +0,0 @@ |
|||||
package hello |
|
||||
|
|
||||
import ( |
|
||||
"context" |
|
||||
"github.com/gogf/gf/v2/frame/g" |
|
||||
|
|
||||
"practice_Go/api/hello/v1" |
|
||||
) |
|
||||
|
|
||||
func (c *ControllerV1) Hello(ctx context.Context, req *v1.HelloReq) (res *v1.HelloRes, err error) { |
|
||||
g.RequestFromCtx(ctx).Response.Writeln("Hello World!") |
|
||||
return |
|
||||
} |
|
||||
@ -0,0 +1,23 @@ |
|||||
|
package live_streams |
||||
|
|
||||
|
import ( |
||||
|
"github.com/gogf/gf/v2/net/ghttp" |
||||
|
"practice_Go/api/v1/live_streams" |
||||
|
live "practice_Go/internal/service" |
||||
|
) |
||||
|
|
||||
|
type cLive struct{} |
||||
|
|
||||
|
var Live = cLive{} |
||||
|
|
||||
|
func (c *cLive) GetLiveList(r *ghttp.Request) { |
||||
|
var req *live_streams.GetLiveListReq |
||||
|
if err := r.Parse(&req); err != nil { |
||||
|
r.Response.WriteJsonExit(err.Error()) |
||||
|
} |
||||
|
res, err := live.Live().GetLiveList(r.Context(), req) |
||||
|
if err != nil { |
||||
|
r.Response.WriteJsonExit(err.Error()) |
||||
|
} |
||||
|
r.Response.WriteJsonExit(res) |
||||
|
} |
||||
@ -0,0 +1,25 @@ |
|||||
|
package shows |
||||
|
|
||||
|
import ( |
||||
|
"github.com/gogf/gf/v2/errors/gcode" |
||||
|
"github.com/gogf/gf/v2/net/ghttp" |
||||
|
"practice_Go/api/v1/shows" |
||||
|
"practice_Go/internal/service" |
||||
|
) |
||||
|
|
||||
|
type cShows struct{} |
||||
|
|
||||
|
var Shows = cShows{} |
||||
|
|
||||
|
func (c *cShows) GetShowList(r *ghttp.Request) { |
||||
|
var req *shows.ShowReq |
||||
|
if err := r.Parse(&req); err != nil { |
||||
|
r.Response.WriteJsonExit(gcode.New(400, "参数错误", nil)) |
||||
|
} |
||||
|
|
||||
|
res, err := service.Shows().GetShowsList(r.Context(), req) |
||||
|
if err != nil { |
||||
|
r.Response.WriteJsonExit(gcode.New(500, err.Error(), nil)) |
||||
|
} |
||||
|
r.Response.WriteJson(res) |
||||
|
} |
||||
@ -0,0 +1,27 @@ |
|||||
|
// =================================================================================
|
||||
|
// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package dao |
||||
|
|
||||
|
import ( |
||||
|
"practice_Go/internal/dao/internal" |
||||
|
) |
||||
|
|
||||
|
// internalEbooksDao is internal type for wrapping internal DAO implements.
|
||||
|
type internalEbooksDao = *internal.EbooksDao |
||||
|
|
||||
|
// ebooksDao is the data access object for table ebooks.
|
||||
|
// You can define custom methods on it to extend its functionality as you wish.
|
||||
|
type ebooksDao struct { |
||||
|
internalEbooksDao |
||||
|
} |
||||
|
|
||||
|
var ( |
||||
|
// Ebooks is globally public accessible object for table ebooks operations.
|
||||
|
Ebooks = ebooksDao{ |
||||
|
internal.NewEbooksDao(), |
||||
|
} |
||||
|
) |
||||
|
|
||||
|
// Fill with you ideas below.
|
||||
@ -0,0 +1,81 @@ |
|||||
|
// ==========================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// ==========================================================================
|
||||
|
|
||||
|
package internal |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
|
||||
|
"github.com/gogf/gf/v2/database/gdb" |
||||
|
"github.com/gogf/gf/v2/frame/g" |
||||
|
) |
||||
|
|
||||
|
// EbooksDao is the data access object for table ebooks.
|
||||
|
type EbooksDao struct { |
||||
|
table string // table is the underlying table name of the DAO.
|
||||
|
group string // group is the database configuration group name of current DAO.
|
||||
|
columns EbooksColumns // columns contains all the column names of Table for convenient usage.
|
||||
|
} |
||||
|
|
||||
|
// EbooksColumns defines and stores column names for table ebooks.
|
||||
|
type EbooksColumns struct { |
||||
|
Id string // 主键
|
||||
|
Cover string // 封面图URL
|
||||
|
Title string // 书名（唯一约束）
|
||||
|
Description string // 简介
|
||||
|
ViewCount string // 观看人数
|
||||
|
} |
||||
|
|
||||
|
// ebooksColumns holds the columns for table ebooks.
|
||||
|
var ebooksColumns = EbooksColumns{ |
||||
|
Id: "id", |
||||
|
Cover: "cover", |
||||
|
Title: "title", |
||||
|
Description: "description", |
||||
|
ViewCount: "view_count", |
||||
|
} |
||||
|
|
||||
|
// NewEbooksDao creates and returns a new DAO object for table data access.
|
||||
|
func NewEbooksDao() *EbooksDao { |
||||
|
return &EbooksDao{ |
||||
|
group: "default", |
||||
|
table: "ebooks", |
||||
|
columns: ebooksColumns, |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
// DB retrieves and returns the underlying raw database management object of current DAO.
|
||||
|
func (dao *EbooksDao) DB() gdb.DB { |
||||
|
return g.DB(dao.group) |
||||
|
} |
||||
|
|
||||
|
// Table returns the table name of current dao.
|
||||
|
func (dao *EbooksDao) Table() string { |
||||
|
return dao.table |
||||
|
} |
||||
|
|
||||
|
// Columns returns all column names of current dao.
|
||||
|
func (dao *EbooksDao) Columns() EbooksColumns { |
||||
|
return dao.columns |
||||
|
} |
||||
|
|
||||
|
// Group returns the configuration group name of database of current dao.
|
||||
|
func (dao *EbooksDao) Group() string { |
||||
|
return dao.group |
||||
|
} |
||||
|
|
||||
|
// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
|
||||
|
func (dao *EbooksDao) Ctx(ctx context.Context) *gdb.Model { |
||||
|
return dao.DB().Model(dao.table).Safe().Ctx(ctx) |
||||
|
} |
||||
|
|
||||
|
// Transaction wraps the transaction logic using function f.
|
||||
|
// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
|
||||
|
// It commits the transaction and returns nil if function f returns nil.
|
||||
|
//
|
||||
|
// Note that, you should not Commit or Rollback the transaction in function f
|
||||
|
// as it is automatically handled by this function.
|
||||
|
func (dao *EbooksDao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) { |
||||
|
return dao.Ctx(ctx).Transaction(ctx, f) |
||||
|
} |
||||
@ -0,0 +1,85 @@ |
|||||
|
// ==========================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// ==========================================================================
|
||||
|
|
||||
|
package internal |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
|
||||
|
"github.com/gogf/gf/v2/database/gdb" |
||||
|
"github.com/gogf/gf/v2/frame/g" |
||||
|
) |
||||
|
|
||||
|
// LiveStreamsDao is the data access object for table live_streams.
|
||||
|
type LiveStreamsDao struct { |
||||
|
table string // table is the underlying table name of the DAO.
|
||||
|
group string // group is the database configuration group name of current DAO.
|
||||
|
columns LiveStreamsColumns // columns contains all the column names of Table for convenient usage.
|
||||
|
} |
||||
|
|
||||
|
// LiveStreamsColumns defines and stores column names for table live_streams.
|
||||
|
type LiveStreamsColumns struct { |
||||
|
Id string // 主键
|
||||
|
Cover string // 直播封面URL
|
||||
|
Title string // 直播标题
|
||||
|
Avatar string // 主播头像URL
|
||||
|
PublisherName string // 主播名字
|
||||
|
StartTime string // 计划开播时间
|
||||
|
Status string // 开播状态（0=未开播，1=直播中）
|
||||
|
} |
||||
|
|
||||
|
// liveStreamsColumns holds the columns for table live_streams.
|
||||
|
var liveStreamsColumns = LiveStreamsColumns{ |
||||
|
Id: "id", |
||||
|
Cover: "cover", |
||||
|
Title: "title", |
||||
|
Avatar: "avatar", |
||||
|
PublisherName: "publisher_name", |
||||
|
StartTime: "start_time", |
||||
|
Status: "status", |
||||
|
} |
||||
|
|
||||
|
// NewLiveStreamsDao creates and returns a new DAO object for table data access.
|
||||
|
func NewLiveStreamsDao() *LiveStreamsDao { |
||||
|
return &LiveStreamsDao{ |
||||
|
group: "default", |
||||
|
table: "live_streams", |
||||
|
columns: liveStreamsColumns, |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
// DB retrieves and returns the underlying raw database management object of current DAO.
|
||||
|
func (dao *LiveStreamsDao) DB() gdb.DB { |
||||
|
return g.DB(dao.group) |
||||
|
} |
||||
|
|
||||
|
// Table returns the table name of current dao.
|
||||
|
func (dao *LiveStreamsDao) Table() string { |
||||
|
return dao.table |
||||
|
} |
||||
|
|
||||
|
// Columns returns all column names of current dao.
|
||||
|
func (dao *LiveStreamsDao) Columns() LiveStreamsColumns { |
||||
|
return dao.columns |
||||
|
} |
||||
|
|
||||
|
// Group returns the configuration group name of database of current dao.
|
||||
|
func (dao *LiveStreamsDao) Group() string { |
||||
|
return dao.group |
||||
|
} |
||||
|
|
||||
|
// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
|
||||
|
func (dao *LiveStreamsDao) Ctx(ctx context.Context) *gdb.Model { |
||||
|
return dao.DB().Model(dao.table).Safe().Ctx(ctx) |
||||
|
} |
||||
|
|
||||
|
// Transaction wraps the transaction logic using function f.
|
||||
|
// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
|
||||
|
// It commits the transaction and returns nil if function f returns nil.
|
||||
|
//
|
||||
|
// Note that, you should not Commit or Rollback the transaction in function f
|
||||
|
// as it is automatically handled by this function.
|
||||
|
func (dao *LiveStreamsDao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) { |
||||
|
return dao.Ctx(ctx).Transaction(ctx, f) |
||||
|
} |
||||
@ -0,0 +1,95 @@ |
|||||
|
// ==========================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// ==========================================================================
|
||||
|
|
||||
|
package internal |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
|
||||
|
"github.com/gogf/gf/v2/database/gdb" |
||||
|
"github.com/gogf/gf/v2/frame/g" |
||||
|
) |
||||
|
|
||||
|
// ShowsDao is the data access object for table shows.
|
||||
|
type ShowsDao struct { |
||||
|
table string // table is the underlying table name of the DAO.
|
||||
|
group string // group is the database configuration group name of current DAO.
|
||||
|
columns ShowsColumns // columns contains all the column names of Table for convenient usage.
|
||||
|
} |
||||
|
|
||||
|
// ShowsColumns defines and stores column names for table shows.
|
||||
|
type ShowsColumns struct { |
||||
|
Id string // 主键
|
||||
|
Cover string // 封面图URL
|
||||
|
Title string // 标题
|
||||
|
PublisherName string // 发布人名字
|
||||
|
PublisherAvatar string // 发布人头像URL
|
||||
|
PublishTime string // 发布时间
|
||||
|
ViewCount string // 观看人数
|
||||
|
CommentCount string // 评论数
|
||||
|
LikeCount string // 点赞数
|
||||
|
Type string // 类型（1=文章，2=视频）
|
||||
|
ClubId string // 所属俱乐部（0=无，1=博古）
|
||||
|
VideoDuration string // 视频时长（秒）
|
||||
|
} |
||||
|
|
||||
|
// showsColumns holds the columns for table shows.
|
||||
|
var showsColumns = ShowsColumns{ |
||||
|
Id: "id", |
||||
|
Cover: "cover", |
||||
|
Title: "title", |
||||
|
PublisherName: "publisher_name", |
||||
|
PublisherAvatar: "publisher_avatar", |
||||
|
PublishTime: "publish_time", |
||||
|
ViewCount: "view_count", |
||||
|
CommentCount: "comment_count", |
||||
|
LikeCount: "like_count", |
||||
|
Type: "type", |
||||
|
ClubId: "club_id", |
||||
|
VideoDuration: "video_duration", |
||||
|
} |
||||
|
|
||||
|
// NewShowsDao creates and returns a new DAO object for table data access.
|
||||
|
func NewShowsDao() *ShowsDao { |
||||
|
return &ShowsDao{ |
||||
|
group: "default", |
||||
|
table: "shows", |
||||
|
columns: showsColumns, |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
// DB retrieves and returns the underlying raw database management object of current DAO.
|
||||
|
func (dao *ShowsDao) DB() gdb.DB { |
||||
|
return g.DB(dao.group) |
||||
|
} |
||||
|
|
||||
|
// Table returns the table name of current dao.
|
||||
|
func (dao *ShowsDao) Table() string { |
||||
|
return dao.table |
||||
|
} |
||||
|
|
||||
|
// Columns returns all column names of current dao.
|
||||
|
func (dao *ShowsDao) Columns() ShowsColumns { |
||||
|
return dao.columns |
||||
|
} |
||||
|
|
||||
|
// Group returns the configuration group name of database of current dao.
|
||||
|
func (dao *ShowsDao) Group() string { |
||||
|
return dao.group |
||||
|
} |
||||
|
|
||||
|
// Ctx creates and returns the Model for current DAO, It automatically sets the context for current operation.
|
||||
|
func (dao *ShowsDao) Ctx(ctx context.Context) *gdb.Model { |
||||
|
return dao.DB().Model(dao.table).Safe().Ctx(ctx) |
||||
|
} |
||||
|
|
||||
|
// Transaction wraps the transaction logic using function f.
|
||||
|
// It rollbacks the transaction and returns the error from function f if it returns non-nil error.
|
||||
|
// It commits the transaction and returns nil if function f returns nil.
|
||||
|
//
|
||||
|
// Note that, you should not Commit or Rollback the transaction in function f
|
||||
|
// as it is automatically handled by this function.
|
||||
|
func (dao *ShowsDao) Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) (err error) { |
||||
|
return dao.Ctx(ctx).Transaction(ctx, f) |
||||
|
} |
||||
@ -0,0 +1,27 @@ |
|||||
|
// =================================================================================
|
||||
|
// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package dao |
||||
|
|
||||
|
import ( |
||||
|
"practice_Go/internal/dao/internal" |
||||
|
) |
||||
|
|
||||
|
// internalLiveStreamsDao is internal type for wrapping internal DAO implements.
|
||||
|
type internalLiveStreamsDao = *internal.LiveStreamsDao |
||||
|
|
||||
|
// liveStreamsDao is the data access object for table live_streams.
|
||||
|
// You can define custom methods on it to extend its functionality as you wish.
|
||||
|
type liveStreamsDao struct { |
||||
|
internalLiveStreamsDao |
||||
|
} |
||||
|
|
||||
|
var ( |
||||
|
// LiveStreams is globally public accessible object for table live_streams operations.
|
||||
|
LiveStreams = liveStreamsDao{ |
||||
|
internal.NewLiveStreamsDao(), |
||||
|
} |
||||
|
) |
||||
|
|
||||
|
// Fill with you ideas below.
|
||||
@ -0,0 +1,27 @@ |
|||||
|
// =================================================================================
|
||||
|
// This is auto-generated by GoFrame CLI tool only once. Fill this file as you wish.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package dao |
||||
|
|
||||
|
import ( |
||||
|
"practice_Go/internal/dao/internal" |
||||
|
) |
||||
|
|
||||
|
// internalShowsDao is internal type for wrapping internal DAO implements.
|
||||
|
type internalShowsDao = *internal.ShowsDao |
||||
|
|
||||
|
// showsDao is the data access object for table shows.
|
||||
|
// You can define custom methods on it to extend its functionality as you wish.
|
||||
|
type showsDao struct { |
||||
|
internalShowsDao |
||||
|
} |
||||
|
|
||||
|
var ( |
||||
|
// Shows is globally public accessible object for table shows operations.
|
||||
|
Shows = showsDao{ |
||||
|
internal.NewShowsDao(), |
||||
|
} |
||||
|
) |
||||
|
|
||||
|
// Fill with you ideas below.
|
||||
@ -0,0 +1,25 @@ |
|||||
|
package logic |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
"practice_Go/api/v1/ebooks" |
||||
|
"practice_Go/internal/dao" |
||||
|
ebook "practice_Go/internal/service" |
||||
|
) |
||||
|
|
||||
|
type sEbooks struct{} |
||||
|
|
||||
|
func init() { |
||||
|
ebook.RegisterEbooks(New()) |
||||
|
} |
||||
|
func New() *sEbooks { |
||||
|
return &sEbooks{} |
||||
|
} |
||||
|
|
||||
|
func (c *sEbooks) GetEbooksList(ctx context.Context, req *ebooks.GetEbooksListReq) (res ebooks.GetEbooksListRes, err error) { |
||||
|
err = dao.Ebooks.Ctx(ctx).Scan(&res.List) |
||||
|
if err != nil { |
||||
|
return |
||||
|
} |
||||
|
return |
||||
|
} |
||||
@ -0,0 +1,37 @@ |
|||||
|
package logic |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
"github.com/gogf/gf/v2/errors/gerror" |
||||
|
"github.com/gogf/gf/v2/frame/g" |
||||
|
"practice_Go/api/v1/live_streams" |
||||
|
"practice_Go/internal/dao" |
||||
|
"practice_Go/internal/model/entity" |
||||
|
live "practice_Go/internal/service" |
||||
|
) |
||||
|
|
||||
|
type sLives struct{} |
||||
|
|
||||
|
func init() { |
||||
|
live.RegisterLives(NewLive()) |
||||
|
} |
||||
|
func NewLive() *sLives { |
||||
|
return &sLives{} |
||||
|
} |
||||
|
|
||||
|
// 实现接口 ILive 的方法
|
||||
|
func (s *sLives) GetLiveList(ctx context.Context, req *live_streams.GetLiveListReq) (res live_streams.GetLiveListRes, err error) { |
||||
|
var list []*entity.LiveStreams |
||||
|
err = dao.LiveStreams.Ctx(ctx). |
||||
|
OrderAsc("start_time"). // 按开播时间升序
|
||||
|
Limit(8). // 取前8条
|
||||
|
Scan(&list) |
||||
|
if err != nil { |
||||
|
g.Log().Errorf(ctx, "直播数据获取失败:%v", err) |
||||
|
return res, gerror.Wrap(err, "直播数据服务异常") |
||||
|
} |
||||
|
|
||||
|
// 将 list 转换为 live_streams.GetLiveListRes 的结构
|
||||
|
res.List = list |
||||
|
return res, nil |
||||
|
} |
||||
@ -0,0 +1,57 @@ |
|||||
|
package logic |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
"github.com/gogf/gf/v2/errors/gcode" |
||||
|
"github.com/gogf/gf/v2/errors/gerror" |
||||
|
"github.com/gogf/gf/v2/frame/g" |
||||
|
v1 "practice_Go/api/v1/shows" |
||||
|
"practice_Go/internal/dao" |
||||
|
"practice_Go/internal/model/entity" |
||||
|
show "practice_Go/internal/service" |
||||
|
) |
||||
|
|
||||
|
type sShows struct{} |
||||
|
|
||||
|
func init() { |
||||
|
show.RegisterShows(NewShows()) |
||||
|
} |
||||
|
|
||||
|
func NewShows() *sShows { |
||||
|
return &sShows{} |
||||
|
} |
||||
|
|
||||
|
const ( |
||||
|
QueryRecommend = iota + 1 // 推荐界面
|
||||
|
QueryVideo // 精选视频
|
||||
|
QueryClub // 博股俱乐部
|
||||
|
QueryChannel // homilyLink频道
|
||||
|
) |
||||
|
|
||||
|
// 实现 IShows 接口中的 GetShowsList 方法
|
||||
|
func (s *sShows) GetShowsList(ctx context.Context, req *v1.ShowReq) (res v1.GetShowsListRes, err error) { |
||||
|
model := dao.Shows.Ctx(ctx) |
||||
|
|
||||
|
// 根据请求类型动态调整查询条件
|
||||
|
switch req.QueryType { |
||||
|
case QueryVideo: |
||||
|
model = model.Where("type", 2).OrderAsc("publish_time") // 视频类型正序
|
||||
|
case QueryClub: |
||||
|
model = model.Where("club_id", 1).OrderDesc("publish_time") // 俱乐部倒序
|
||||
|
case QueryChannel: |
||||
|
model = model.Where("publisher_name", "homilyLink").OrderDesc("publish_time") |
||||
|
default: |
||||
|
model = model.OrderDesc("publish_time") // 默认推荐倒序
|
||||
|
} |
||||
|
|
||||
|
// 查询数据并填充到结果列表
|
||||
|
var list []*entity.Shows |
||||
|
if err := model.Scan(&list); err != nil { |
||||
|
g.Log().Errorf(ctx, "内容查询异常|类型:%d|错误:%v", req.QueryType, err) |
||||
|
return res, gerror.WrapCode(gcode.CodeDbOperationError, err, "数据获取失败") |
||||
|
} |
||||
|
|
||||
|
// 将查询结果赋值给返回值
|
||||
|
res.List = list |
||||
|
return res, nil |
||||
|
} |
||||
@ -0,0 +1,19 @@ |
|||||
|
// =================================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package do |
||||
|
|
||||
|
import ( |
||||
|
"github.com/gogf/gf/v2/frame/g" |
||||
|
) |
||||
|
|
||||
|
// Ebooks is the golang structure of table ebooks for DAO operations like Where/Data.
|
||||
|
type Ebooks struct { |
||||
|
g.Meta `orm:"table:ebooks, do:true"` |
||||
|
Id interface{} // 主键
|
||||
|
Cover interface{} // 封面图URL
|
||||
|
Title interface{} // 书名（唯一约束）
|
||||
|
Description interface{} // 简介
|
||||
|
ViewCount interface{} // 观看人数
|
||||
|
} |
||||
@ -0,0 +1,22 @@ |
|||||
|
// =================================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package do |
||||
|
|
||||
|
import ( |
||||
|
"github.com/gogf/gf/v2/frame/g" |
||||
|
"github.com/gogf/gf/v2/os/gtime" |
||||
|
) |
||||
|
|
||||
|
// LiveStreams is the golang structure of table live_streams for DAO operations like Where/Data.
|
||||
|
type LiveStreams struct { |
||||
|
g.Meta `orm:"table:live_streams, do:true"` |
||||
|
Id interface{} // 主键
|
||||
|
Cover interface{} // 直播封面URL
|
||||
|
Title interface{} // 直播标题
|
||||
|
Avatar interface{} // 主播头像URL
|
||||
|
PublisherName interface{} // 主播名字
|
||||
|
StartTime *gtime.Time // 计划开播时间
|
||||
|
Status interface{} // 开播状态（0=未开播，1=直播中）
|
||||
|
} |
||||
@ -0,0 +1,27 @@ |
|||||
|
// =================================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package do |
||||
|
|
||||
|
import ( |
||||
|
"github.com/gogf/gf/v2/frame/g" |
||||
|
"github.com/gogf/gf/v2/os/gtime" |
||||
|
) |
||||
|
|
||||
|
// Shows is the golang structure of table shows for DAO operations like Where/Data.
|
||||
|
type Shows struct { |
||||
|
g.Meta `orm:"table:shows, do:true"` |
||||
|
Id interface{} // 主键
|
||||
|
Cover interface{} // 封面图URL
|
||||
|
Title interface{} // 标题
|
||||
|
PublisherName interface{} // 发布人名字
|
||||
|
PublisherAvatar interface{} // 发布人头像URL
|
||||
|
PublishTime *gtime.Time // 发布时间
|
||||
|
ViewCount interface{} // 观看人数
|
||||
|
CommentCount interface{} // 评论数
|
||||
|
LikeCount interface{} // 点赞数
|
||||
|
Type interface{} // 类型（1=文章，2=视频）
|
||||
|
ClubId interface{} // 所属俱乐部（0=无，1=博古）
|
||||
|
VideoDuration interface{} // 视频时长（秒）
|
||||
|
} |
||||
@ -0,0 +1,14 @@ |
|||||
|
// =================================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package entity |
||||
|
|
||||
|
// Ebooks is the golang structure for table ebooks.
|
||||
|
type Ebooks struct { |
||||
|
Id uint64 `json:"id" orm:"id" description:"主键"` // 主键
|
||||
|
Cover string `json:"cover" orm:"cover" description:"封面图URL"` // 封面图URL
|
||||
|
Title string `json:"title" orm:"title" description:"书名（唯一约束）"` // 书名（唯一约束）
|
||||
|
Description string `json:"description" orm:"description" description:"简介"` // 简介
|
||||
|
ViewCount uint `json:"viewCount" orm:"view_count" description:"观看人数"` // 观看人数
|
||||
|
} |
||||
@ -0,0 +1,20 @@ |
|||||
|
// =================================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package entity |
||||
|
|
||||
|
import ( |
||||
|
"github.com/gogf/gf/v2/os/gtime" |
||||
|
) |
||||
|
|
||||
|
// LiveStreams is the golang structure for table live_streams.
|
||||
|
type LiveStreams struct { |
||||
|
Id uint64 `json:"id" orm:"id" description:"主键"` // 主键
|
||||
|
Cover string `json:"cover" orm:"cover" description:"直播封面URL"` // 直播封面URL
|
||||
|
Title string `json:"title" orm:"title" description:"直播标题"` // 直播标题
|
||||
|
Avatar string `json:"avatar" orm:"avatar" description:"主播头像URL"` // 主播头像URL
|
||||
|
PublisherName string `json:"publisherName" orm:"publisher_name" description:"主播名字"` // 主播名字
|
||||
|
StartTime *gtime.Time `json:"startTime" orm:"start_time" description:"计划开播时间"` // 计划开播时间
|
||||
|
Status int `json:"status" orm:"status" description:"开播状态（0=未开播，1=直播中）"` // 开播状态（0=未开播，1=直播中）
|
||||
|
} |
||||
@ -0,0 +1,25 @@ |
|||||
|
// =================================================================================
|
||||
|
// Code generated and maintained by GoFrame CLI tool. DO NOT EDIT.
|
||||
|
// =================================================================================
|
||||
|
|
||||
|
package entity |
||||
|
|
||||
|
import ( |
||||
|
"github.com/gogf/gf/v2/os/gtime" |
||||
|
) |
||||
|
|
||||
|
// Shows is the golang structure for table shows.
|
||||
|
type Shows struct { |
||||
|
Id uint64 `json:"id" orm:"id" description:"主键"` // 主键
|
||||
|
Cover string `json:"cover" orm:"cover" description:"封面图URL"` // 封面图URL
|
||||
|
Title string `json:"title" orm:"title" description:"标题"` // 标题
|
||||
|
PublisherName string `json:"publisherName" orm:"publisher_name" description:"发布人名字"` // 发布人名字
|
||||
|
PublisherAvatar string `json:"publisherAvatar" orm:"publisher_avatar" description:"发布人头像URL"` // 发布人头像URL
|
||||
|
PublishTime *gtime.Time `json:"publishTime" orm:"publish_time" description:"发布时间"` // 发布时间
|
||||
|
ViewCount uint `json:"viewCount" orm:"view_count" description:"观看人数"` // 观看人数
|
||||
|
CommentCount uint `json:"commentCount" orm:"comment_count" description:"评论数"` // 评论数
|
||||
|
LikeCount uint `json:"likeCount" orm:"like_count" description:"点赞数"` // 点赞数
|
||||
|
Type int `json:"type" orm:"type" description:"类型（1=文章，2=视频）"` // 类型（1=文章，2=视频）
|
||||
|
ClubId int `json:"clubId" orm:"club_id" description:"所属俱乐部（0=无，1=博古）"` // 所属俱乐部（0=无，1=博古）
|
||||
|
VideoDuration uint `json:"videoDuration" orm:"video_duration" description:"视频时长（秒）"` // 视频时长（秒）
|
||||
|
} |
||||
@ -0,0 +1,27 @@ |
|||||
|
package service |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
"practice_Go/api/v1/ebooks" |
||||
|
) |
||||
|
|
||||
|
type ( |
||||
|
IEbooks interface { |
||||
|
GetEbooksList(ctx context.Context, req *ebooks.GetEbooksListReq) (res ebooks.GetEbooksListRes, err error) |
||||
|
} |
||||
|
) |
||||
|
|
||||
|
var ( |
||||
|
localBooks IEbooks |
||||
|
) |
||||
|
|
||||
|
func Ebooks() IEbooks { |
||||
|
if localBooks == nil { |
||||
|
panic("implement not found for interface IUser, forgot register?") |
||||
|
} |
||||
|
return localBooks |
||||
|
} |
||||
|
|
||||
|
func RegisterEbooks(i IEbooks) { |
||||
|
localBooks = i |
||||
|
} |
||||
@ -0,0 +1,27 @@ |
|||||
|
package service |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
"practice_Go/api/v1/live_streams" |
||||
|
) |
||||
|
|
||||
|
type ( |
||||
|
ILive interface { |
||||
|
GetLiveList(ctx context.Context, req *live_streams.GetLiveListReq) (res live_streams.GetLiveListRes, err error) |
||||
|
} |
||||
|
) |
||||
|
|
||||
|
var ( |
||||
|
localLive ILive |
||||
|
) |
||||
|
|
||||
|
func Live() ILive { |
||||
|
if localLive == nil { |
||||
|
panic("implement not found for interface IUser, forgot register?") |
||||
|
} |
||||
|
return localLive |
||||
|
} |
||||
|
|
||||
|
func RegisterLives(i ILive) { |
||||
|
localLive = i |
||||
|
} |
||||
@ -0,0 +1,26 @@ |
|||||
|
package service |
||||
|
|
||||
|
import ( |
||||
|
"context" |
||||
|
"practice_Go/api/v1/shows" |
||||
|
) |
||||
|
|
||||
|
type ( |
||||
|
IShows interface { |
||||
|
GetShowsList(ctx context.Context, req *shows.ShowReq) (res shows.GetShowsListRes, err error) |
||||
|
} |
||||
|
) |
||||
|
|
||||
|
var ( |
||||
|
localShows IShows |
||||
|
) |
||||
|
|
||||
|
func Shows() IShows { |
||||
|
if localShows == nil { |
||||
|
panic("implement not found for interface IShows") |
||||
|
} |
||||
|
return localShows |
||||
|
} |
||||
|
func RegisterShows(i IShows) { |
||||
|
localShows = i |
||||
|
} |
||||
|
After Width: 119 | Height: 169 | Size: 40 KiB |
|
After Width: 123 | Height: 170 | Size: 43 KiB |
|
After Width: 116 | Height: 166 | Size: 48 KiB |
|
After Width: 122 | Height: 170 | Size: 52 KiB |
|
After Width: 228 | Height: 106 | Size: 36 KiB |
|
After Width: 145 | Height: 92 | Size: 20 KiB |
|
After Width: 191 | Height: 121 | Size: 64 KiB |
Write
Preview
Loading…
Cancel
Save
Reference in new issue