From 5bdb50d4a6bbf8835e62777e8dc9dc41eda06cc9 Mon Sep 17 00:00:00 2001 From: lijikun Date: Thu, 5 Dec 2024 11:13:20 +0800 Subject: [PATCH] =?UTF-8?q?12.5=E6=97=A5=E4=BC=A0=E5=8F=82=E9=94=99?= =?UTF-8?q?=E8=AF=AF=E5=88=A4=E6=96=AD=E3=80=81=E8=BF=94=E5=9B=9E=E7=9A=84?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/controller/clubPage/clubPage.go | 53 ++++++++---- internal/controller/mainPage/mainPage.go | 142 ++++++++----------------------- internal/logic/shows/shows.go | 4 +- 3 files changed, 72 insertions(+), 127 deletions(-) diff --git a/internal/controller/clubPage/clubPage.go b/internal/controller/clubPage/clubPage.go index a55230f..1a58b00 100644 --- a/internal/controller/clubPage/clubPage.go +++ b/internal/controller/clubPage/clubPage.go @@ -1,6 +1,7 @@ package clubPage import ( + "github.com/gogf/gf/v2/frame/g" "github.com/gogf/gf/v2/net/ghttp" "practice_Go/internal/model/dto" "practice_Go/internal/service" @@ -14,36 +15,52 @@ func NewClubPage() *ClubPage { // GetClub 获取俱乐部信息 func (c ClubPage) GetClub(req *ghttp.Request) { + i := ghttp.RequestFromCtx(req.Context()).Get("id").Int() - club, err := service.GetClubs().GetClubs(req.Context()) - if err == nil { - req.Response.WriteJson(dto.Result{ - Code: 200, - Message: "success", - Data: club, - }) + if i > 0 && i <= 4 { + club, err := service.GetClubs().GetClubs(req.Context()) + if err == nil { + req.Response.WriteJson(dto.Result{ + Code: 200, + Message: "success", + Data: club, + }) + } else { + req.Response.WriteJson(dto.Result{ + Code: 500, + Message: "error", + Data: err, + }) + } } else { req.Response.WriteJson(dto.Result{ Code: 500, - Message: "error", - Data: err, + Message: "传来俱乐部id信息不对", }) } } func (c ClubPage) GetClubShows(req *ghttp.Request) { - shows, err := service.GetClubs().GetClubShows(req.Context()) - if err == nil { - req.Response.WriteJson(dto.Result{ - Code: 200, - Message: "success", - Data: shows, - }) + i := g.RequestFromCtx(req.Context()).Get("id").Int() + if i > 0 && i <= 4 { + shows, err := service.GetClubs().GetClubShows(req.Context()) + if err == nil { + req.Response.WriteJson(dto.Result{ + Code: 200, + Message: "success", + Data: shows, + }) + } else { + req.Response.WriteJson(dto.Result{ + Code: 500, + Message: "error", + Data: err, + }) + } } else { req.Response.WriteJson(dto.Result{ Code: 500, - Message: "error", - Data: err, + Message: "传来俱乐部id信息不对", }) } } diff --git a/internal/controller/mainPage/mainPage.go b/internal/controller/mainPage/mainPage.go index 7e3cd1d..39f27f0 100644 --- a/internal/controller/mainPage/mainPage.go +++ b/internal/controller/mainPage/mainPage.go @@ -5,7 +5,6 @@ import ( "github.com/gogf/gf/v2/net/ghttp" "practice_Go/internal/model/dto" "practice_Go/internal/service" - "time" ) // 定义一个MainPage结构体 @@ -18,124 +17,53 @@ func NewMainPage() *MainPage { // 获取文章,视频 func (c *MainPage) GetShows(req *ghttp.Request) { - shows, err := service.GetShows().GetShows(req.Context()) - if err == nil { - req.Response.WriteJson(dto.Result{ - Code: 200, - Message: "success", - Data: shows, - }) + i := g.RequestFromCtx(req.Context()).Get("flagType").Int() + if i >= 0 && i <= 2 { + + shows, err := service.GetShows().GetShows(req.Context()) + if err == nil { + req.Response.WriteJson(dto.Result{ + Code: 200, + Message: "success", + Data: shows, + }) + } else { + req.Response.WriteJson(dto.Result{ + Code: 500, + Message: "error", + Data: err, + }) + } } else { req.Response.WriteJson(dto.Result{ Code: 500, - Message: "error", - Data: err, + Message: "传参不对", }) } } // 获取视频 func (c *MainPage) GetVideos(req *ghttp.Request) { - shows, err := service.GetShows().GetVideos(req.Context()) - if err == nil { - req.Response.WriteJson(dto.Result{ - Code: 200, - Message: "success", - Data: shows, - }) + i := g.RequestFromCtx(req.Context()).Get("flagType").Int() + if i == 0 || i == 1 || i == 2 { + shows, err := service.GetShows().GetVideos(req.Context()) + if err == nil { + req.Response.WriteJson(dto.Result{ + Code: 200, + Message: "success", + Data: shows, + }) + } else { + req.Response.WriteJson(dto.Result{ + Code: 500, + Message: "error", + Data: err, + }) + } } else { req.Response.WriteJson(dto.Result{ Code: 500, - Message: "error", - Data: err, + Message: "传参不对", }) } } - -// 新增数据 -func (c *MainPage) AddShow(req *ghttp.Request) { - - type Show struct { - Id int `json:"id"` - Name string `json:"name"` - Cover string `json:"cover"` - UserId int `json:"userId"` - ReleaseTime time.Time `json:"releaseTime"` - VideoDuration time.Duration `json:"videoDuration"` - ViewCount int `json:"viewCount"` - Comments int `json:"comments"` - Likes int `json:"likes"` - FlagType int `json:"flagType"` - ChannelId int `json:"channelId"` - } - - ////通过map - //data := g.Map{ - // "name": "视频1", - // "userId": 1, - // "likes": 6, - // "comments": 3, - // "viewCount": 10, - //} - // - ////通过结构体对象 - //data := Show{ - // Name: "视频1", - // UserId: 1, - // Likes: 6, - // Comments: 3, - // ReleaseTime: gtime.New("2024/10/23"), - //} - // - md := g.Model("show") - // - - //批量插入多条数据 - ////通过map - //data := g.List{ - // g.Map{ - // "name": "视频1", - // "userId": 1, - // "likes": 6, - // "comments": 3, - // "viewCount": 23, - // }, - // g.Map{ - // "name": "视频2", - // "userId": 2, - // "likes": 6, - // "comments": 3, - // "viewCount": 20, - // }, - // g.Map{ - // "name": "文章1", - // "userId": 3, - // "likes": 6, - // "comments": 3, - // "viewCount": 15, - // }, - //} - - //通过结构体对象 - data := g.Array{ - //里边是结构体集合 - } - - ////写法一 插入 - ////result, err := md.Data(data).Insert() - ////写法二 插入 主键冲突,报错 - ////result, err := md.Insert(data) //insert into ... - ////写法三 主键冲突,就新数据 替换 旧数据 - ////result, err := md.Replace(data) //replace into ... - ////写法四 主键冲突,就根据主键 更新 数据 - //result, err := md.Save(data) //insert into into ... on duplicate key update ... - - //插入并获取id - result, err := md.InsertAndGetId(data) - - if err == nil { - req.Response.WriteJson(result) - } else { - req.Response.WriteJson(err) - } -} diff --git a/internal/logic/shows/shows.go b/internal/logic/shows/shows.go index b2c14e8..f4eb473 100644 --- a/internal/logic/shows/shows.go +++ b/internal/logic/shows/shows.go @@ -20,7 +20,7 @@ type sShow struct{} // 定义一个方法,用于获取所有节目 func (s sShow) GetShows(ctx context.Context) (shows []entity.GoShows, err error) { // 使用dao包中的GoShows结构体,在指定的上下文中扫描数据,并将结果存储在shows变量中 - flagType := g.RequestFromCtx(ctx).Get("flag_type").Int() + flagType := g.RequestFromCtx(ctx).Get("flagType").Int() if flagType != 0 { err = dao.GoShows.Ctx(ctx).With(entity.GoUsers{}, entity.GoClubs{}).Where("flag_type", flagType).Scan(&shows) //err用于存储过程中可能出现的错误,结果直接存到shows中了 } else { @@ -33,7 +33,7 @@ func (s sShow) GetShows(ctx context.Context) (shows []entity.GoShows, err error) // 定义一个方法,用于获取视频列表 func (s sShow) GetVideos(ctx context.Context) (videos []entity.GoShows, err error) { // 使用dao包中的GoShows结构体,在指定的上下文中扫描视频列表 - flagType := g.RequestFromCtx(ctx).Get("flag_type").Int() + flagType := g.RequestFromCtx(ctx).Get("flagType").Int() if flagType != 0 { err = dao.GoShows.Ctx(ctx).With(entity.GoUsers{}, entity.GoClubs{}).Where("flag_type", flagType).OrderDesc("release_time").Scan(&videos) //err用于存储过程中可能出现的错误,结果直接存到shows中了 } else {