apps/monibuca
1
0
Fork 0
mirror of https://github.com/langhuihui/monibuca.git synced 2025-10-05 22:26:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: get recordlist with out pageNum

Browse Source
This commit is contained in:
langhuihui
2025-01-10 11:01:27 +08:00
parent 2960f99b7b
commit d80dac852b
2 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
api.go
View File

@@ -812,6 +812,9 @@ func (s *Server) GetRecordList(ctx context.Context, req *pb.ReqRecordList) (resp
if req.PageSize == 0 { if req.PageSize == 0 {
req.PageSize = 10 req.PageSize = 10
} }
if req.PageNum == 0 {
req.PageNum = 1
}
offset := (req.PageNum - 1) * req.PageSize // 计算偏移量 offset := (req.PageNum - 1) * req.PageSize // 计算偏移量
var totalCount int64 //总条数 var totalCount int64 //总条数
@@ -829,15 +832,15 @@ func (s *Server) GetRecordList(ctx context.Context, req *pb.ReqRecordList) (resp
query = query.Where("type = ?", req.Type) query = query.Where("type = ?", req.Type)
} }
startTime, endTime, err := util.TimeRangeQueryParse(url.Values{"range": []string{req.Range}, "start": []string{req.Start}, "end": []string{req.End}}) startTime, endTime, err := util.TimeRangeQueryParse(url.Values{"range": []string{req.Range}, "start": []string{req.Start}, "end": []string{req.End}})
if err != nil { if err == nil {
return
}
if !startTime.IsZero() { if !startTime.IsZero() {
query = query.Where("start_time >= ?", startTime) query = query.Where("start_time >= ?", startTime)
} }
if !endTime.IsZero() { if !endTime.IsZero() {
query = query.Where("end_time <= ?", endTime) query = query.Where("end_time <= ?", endTime)
} }
}
query.Count(&totalCount) query.Count(&totalCount)
err = query.Offset(int(offset)).Limit(int(req.PageSize)).Order("start_time desc").Find(&result).Error err = query.Offset(int(offset)).Limit(int(req.PageSize)).Order("start_time desc").Find(&result).Error
if err != nil { if err != nil {

8
example/default/config.yaml
View File

@@ -27,7 +27,7 @@ mp4:
onsub: onsub:
pull: pull:
^vod\d+/(.+)$: $1 ^vod\d+/(.+)/mp4$: $1
cascadeserver: cascadeserver:
quic: quic:
listenaddr: :44944 listenaddr: :44944
@@ -41,9 +41,9 @@ flv:
# ^live/.+: # ^live/.+:
# fragment: 1m # fragment: 1m
# filepath: record/$0 # filepath: record/$0
# onsub: onsub:
# pull: pull:
# ^vod\d+/(.+)$: $1 ^vod\d+/(.+)/flv$: $1
# pull: # pull:
# live/test: https://livecb.alicdn.com/mediaplatform/afb241b3-408c-42dd-b665-04d22b64f9df.flv?auth_key=1734575216-0-0-c62721303ce751c8e5b2c95a2ec242a0&F=pc&source=34675810_null_live_detail&ali_flv_retain=2 # live/test: https://livecb.alicdn.com/mediaplatform/afb241b3-408c-42dd-b665-04d22b64f9df.flv?auth_key=1734575216-0-0-c62721303ce751c8e5b2c95a2ec242a0&F=pc&source=34675810_null_live_detail&ali_flv_retain=2
hls: hls: