Client/server
5
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix(log): update sorting logic for server and user subscribe traffic logs

Browse Source
This commit is contained in:
Chang lue Tsen 2025-09-02 14:29:50 -04:00
parent fe629e59dd
commit 3e5284c4ec
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/logic/admin/log/filterServerTrafficLogLogic.go
View File

@ -43,7 +43,7 @@ func (l *FilterServerTrafficLogLogic) FilterServerTrafficLog(req *types.FilterSe
Select("server_id, SUM(download + upload) AS total, SUM(download) AS download, SUM(upload) AS upload").
Where("timestamp BETWEEN ? AND ?", start, end).
Group("server_id").
Order("id DESC").
Order("SUM(download + upload) DESC").
Scan(&serverTraffic).Error
if err != nil {
l.Errorw("[FilterServerTrafficLog] Query Database Error", logger.Field("error", err.Error()))

9
internal/logic/admin/log/filterUserSubscribeTrafficLogLogic.go
View File

@ -29,6 +29,13 @@ func NewFilterUserSubscribeTrafficLogLogic(ctx context.Context, svcCtx *svc.Serv
}
func (l *FilterUserSubscribeTrafficLogLogic) FilterUserSubscribeTrafficLog(req *types.FilterSubscribeTrafficRequest) (resp *types.FilterSubscribeTrafficResponse, err error) {
if req.Size <= 0 {
req.Size = 10
}
if req.Page <= 0 {
req.Page = 1
}
today := time.Now().Format("2006-01-02")
var list []types.UserSubscribeTrafficLog
var total int64
@ -44,7 +51,7 @@ func (l *FilterUserSubscribeTrafficLogLogic) FilterUserSubscribeTrafficLog(req *
Select("user_id, subscribe_id, SUM(download + upload) AS total, SUM(download) AS download, SUM(upload) AS upload").
Where("timestamp BETWEEN ? AND ?", start, end).
Group("user_id, subscribe_id").
Order("id DESC").
Order("SUM(download + upload) DESC").
Scan(&userTraffic).Error
if err != nil {
l.Errorw("[FilterUserSubscribeTrafficLog] Query Database Error", logger.Field("error", err.Error()))