mirror of
https://github.com/yangjian102621/geekai.git
synced 2026-04-12 14:14:25 +08:00
230 lines
8.4 KiB
Go
230 lines
8.4 KiB
Go
package admin
|
|
|
|
// * +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
|
|
// * Copyright 2023 The Geek-AI Authors. All rights reserved.
|
|
// * Use of this source code is governed by a Apache-2.0 license
|
|
// * that can be found in the LICENSE file.
|
|
// * @Author yangjian102621@163.com
|
|
// * +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
|
|
|
|
import (
|
|
"geekai/core"
|
|
"geekai/core/types"
|
|
"geekai/handler"
|
|
"geekai/store/model"
|
|
"geekai/utils/resp"
|
|
"time"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/shopspring/decimal"
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
type DashboardHandler struct {
|
|
handler.BaseHandler
|
|
}
|
|
|
|
func NewDashboardHandler(app *core.AppServer, db *gorm.DB) *DashboardHandler {
|
|
return &DashboardHandler{BaseHandler: handler.BaseHandler{App: app, DB: db}}
|
|
}
|
|
|
|
// RegisterRoutes 注册路由
|
|
func (h *DashboardHandler) RegisterRoutes() {
|
|
group := h.App.Engine.Group("/api/admin/dashboard/")
|
|
group.GET("stats", h.Stats)
|
|
}
|
|
|
|
// statsVo 增加 recentOrders、recentUsers 字段
|
|
// 最近订单
|
|
type OrderBrief struct {
|
|
OrderNo string `json:"order_no"`
|
|
Amount float64 `json:"amount"`
|
|
CreatedAt time.Time `json:"created_at"`
|
|
}
|
|
|
|
// 最近用户
|
|
type UserBrief struct {
|
|
Nickname string `json:"nickname"`
|
|
Avatar string `json:"avatar"`
|
|
LastActive time.Time `json:"last_active"`
|
|
}
|
|
|
|
type statsVo struct {
|
|
Users int64 `json:"users"`
|
|
Chats int64 `json:"chats"`
|
|
Tokens int `json:"tokens"`
|
|
Income float64 `json:"income"`
|
|
Chart map[string]map[string]float64 `json:"chart"`
|
|
TodayUsers int64 `json:"today_users"`
|
|
TodayChats int64 `json:"today_chats"`
|
|
TodayTokens int `json:"today_tokens"`
|
|
TodayIncome float64 `json:"today_income"`
|
|
TodayOrders int64 `json:"today_orders"`
|
|
TodayImageJobs int64 `json:"today_image_jobs"`
|
|
TodayVideoJobs int64 `json:"today_video_jobs"`
|
|
TodayMusicJobs int64 `json:"today_music_jobs"`
|
|
Orders int64 `json:"orders"`
|
|
ImageJobs int64 `json:"image_jobs"`
|
|
VideoJobs int64 `json:"video_jobs"`
|
|
MusicJobs int64 `json:"music_jobs"`
|
|
RecentOrders []OrderBrief `json:"recentOrders"`
|
|
RecentUsers []UserBrief `json:"recentUsers"`
|
|
}
|
|
|
|
func (h *DashboardHandler) Stats(c *gin.Context) {
|
|
stats := statsVo{}
|
|
now := time.Now()
|
|
zeroTime := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location())
|
|
|
|
// 总用户数
|
|
h.DB.Model(&model.User{}).Count(&stats.Users)
|
|
|
|
// 今日新增用户
|
|
h.DB.Model(&model.User{}).Where("created_at > ?", zeroTime).Count(&stats.TodayUsers)
|
|
|
|
// 总对话数
|
|
h.DB.Model(&model.ChatItem{}).Count(&stats.Chats)
|
|
|
|
// 今日新增对话
|
|
h.DB.Model(&model.ChatItem{}).Where("created_at > ?", zeroTime).Count(&stats.TodayChats)
|
|
|
|
// 总Token消耗
|
|
var historyMessages []model.ChatMessage
|
|
h.DB.Find(&historyMessages)
|
|
for _, item := range historyMessages {
|
|
stats.Tokens += item.Tokens
|
|
}
|
|
|
|
// 今日Token消耗
|
|
var todayMessages []model.ChatMessage
|
|
h.DB.Where("created_at > ?", zeroTime).Find(&todayMessages)
|
|
for _, item := range todayMessages {
|
|
stats.TodayTokens += item.Tokens
|
|
}
|
|
|
|
// 总收入
|
|
var allOrders []model.Order
|
|
h.DB.Where("status = ?", types.OrderPaidSuccess).Find(&allOrders)
|
|
for _, item := range allOrders {
|
|
stats.Income += item.Amount
|
|
}
|
|
|
|
// 今日收入
|
|
var todayOrders []model.Order
|
|
h.DB.Where("status = ?", types.OrderPaidSuccess).Where("created_at > ?", zeroTime).Find(&todayOrders)
|
|
for _, item := range todayOrders {
|
|
stats.TodayIncome += item.Amount
|
|
}
|
|
|
|
// 订单总数
|
|
h.DB.Model(&model.Order{}).Where("status = ?", types.OrderPaidSuccess).Count(&stats.Orders)
|
|
|
|
// 今日订单数
|
|
h.DB.Model(&model.Order{}).Where("status = ?", types.OrderPaidSuccess).Where("created_at > ?", zeroTime).Count(&stats.TodayOrders)
|
|
|
|
// 图片生成任务统计
|
|
var mjJobs, sdJobs, dallJobs, jimengImageJobs int64
|
|
h.DB.Model(&model.MidJourneyJob{}).Count(&mjJobs)
|
|
h.DB.Model(&model.SdJob{}).Count(&sdJobs)
|
|
h.DB.Model(&model.DallJob{}).Count(&dallJobs)
|
|
h.DB.Model(&model.JimengJob{}).Where("type IN ?", []string{"text_to_image", "image_to_image", "image_edit", "image_effects"}).Count(&jimengImageJobs)
|
|
stats.ImageJobs = mjJobs + sdJobs + dallJobs + jimengImageJobs
|
|
|
|
// 今日图片生成任务统计
|
|
var todayMjJobs, todaySdJobs, todayDallJobs, todayJimengImageJobs int64
|
|
h.DB.Model(&model.MidJourneyJob{}).Where("created_at > ?", zeroTime).Count(&todayMjJobs)
|
|
h.DB.Model(&model.SdJob{}).Where("created_at > ?", zeroTime).Count(&todaySdJobs)
|
|
h.DB.Model(&model.DallJob{}).Where("created_at > ?", zeroTime).Count(&todayDallJobs)
|
|
h.DB.Model(&model.JimengJob{}).Where("type IN ?", []string{"text_to_image", "image_to_image", "image_edit", "image_effects"}).Where("created_at > ?", zeroTime).Count(&todayJimengImageJobs)
|
|
stats.TodayImageJobs = todayMjJobs + todaySdJobs + todayDallJobs + todayJimengImageJobs
|
|
|
|
// 视频生成任务统计
|
|
var videoJobs, jimengVideoJobs int64
|
|
h.DB.Model(&model.VideoJob{}).Count(&videoJobs)
|
|
h.DB.Model(&model.JimengJob{}).Where("type IN ?", []string{"text_to_video", "image_to_video"}).Count(&jimengVideoJobs)
|
|
stats.VideoJobs = videoJobs + jimengVideoJobs
|
|
|
|
// 今日视频生成任务统计
|
|
var todayVideoJobs, todayJimengVideoJobs int64
|
|
h.DB.Model(&model.VideoJob{}).Where("created_at > ?", zeroTime).Count(&todayVideoJobs)
|
|
h.DB.Model(&model.JimengJob{}).Where("type IN ?", []string{"text_to_video", "image_to_video"}).Where("created_at > ?", zeroTime).Count(&todayJimengVideoJobs)
|
|
stats.TodayVideoJobs = todayVideoJobs + todayJimengVideoJobs
|
|
|
|
// 音乐生成任务统计
|
|
h.DB.Model(&model.SunoJob{}).Count(&stats.MusicJobs)
|
|
|
|
// 今日音乐生成任务统计
|
|
h.DB.Model(&model.SunoJob{}).Where("created_at > ?", zeroTime).Count(&stats.TodayMusicJobs)
|
|
|
|
// recentOrders: 最近10条已支付订单
|
|
var orderList []model.Order
|
|
h.DB.Model(&model.Order{}).Where("status = ?", types.OrderPaidSuccess).Order("created_at desc").Limit(10).Find(&orderList)
|
|
for _, o := range orderList {
|
|
stats.RecentOrders = append(stats.RecentOrders, OrderBrief{
|
|
OrderNo: o.OrderNo,
|
|
Amount: o.Amount,
|
|
CreatedAt: o.CreatedAt,
|
|
})
|
|
}
|
|
// recentUsers: 最近10个注册用户
|
|
var userList []model.User
|
|
h.DB.Model(&model.User{}).Order("created_at desc").Limit(10).Find(&userList)
|
|
for _, u := range userList {
|
|
lastActive := u.UpdatedAt
|
|
if lastActive.IsZero() {
|
|
lastActive = u.CreatedAt
|
|
}
|
|
stats.RecentUsers = append(stats.RecentUsers, UserBrief{
|
|
Nickname: u.Nickname,
|
|
Avatar: u.Avatar,
|
|
LastActive: lastActive,
|
|
})
|
|
}
|
|
|
|
// 统计7天的订单的图表
|
|
startDate := now.Add(-7 * 24 * time.Hour).Format("2006-01-02")
|
|
var statsChart = make(map[string]map[string]float64)
|
|
//// 初始化
|
|
var userStatistic, historyMessagesStatistic, incomeStatistic = make(map[string]float64), make(map[string]float64), make(map[string]float64)
|
|
for i := 0; i < 7; i++ {
|
|
var initTime = time.Date(now.Year(), now.Month(), now.Day()-i, 0, 0, 0, 0, now.Location()).Format("2006-01-02")
|
|
userStatistic[initTime] = float64(0)
|
|
historyMessagesStatistic[initTime] = float64(0)
|
|
incomeStatistic[initTime] = float64(0)
|
|
}
|
|
|
|
// 统计用户7天增加的曲线
|
|
var users []model.User
|
|
err := h.DB.Model(&model.User{}).Where("created_at > ?", startDate).Find(&users).Error
|
|
if err == nil {
|
|
for _, item := range users {
|
|
userStatistic[item.CreatedAt.Format("2006-01-02")] += 1
|
|
}
|
|
}
|
|
|
|
// 统计7天Token 消耗
|
|
err = h.DB.Where("created_at > ?", startDate).Find(&historyMessages).Error
|
|
if err == nil {
|
|
for _, item := range historyMessages {
|
|
historyMessagesStatistic[item.CreatedAt.Format("2006-01-02")] += float64(item.Tokens)
|
|
}
|
|
}
|
|
|
|
// 统计最近7天的订单
|
|
var orders []model.Order
|
|
err = h.DB.Where("status = ?", types.OrderPaidSuccess).Where("created_at > ?", startDate).Find(&orders).Error
|
|
if err == nil {
|
|
for _, item := range orders {
|
|
incomeStatistic[item.CreatedAt.Format("2006-01-02")], _ = decimal.NewFromFloat(incomeStatistic[item.CreatedAt.Format("2006-01-02")]).Add(decimal.NewFromFloat(item.Amount)).Float64()
|
|
}
|
|
}
|
|
|
|
statsChart["users"] = userStatistic
|
|
statsChart["historyMessage"] = historyMessagesStatistic
|
|
statsChart["orders"] = incomeStatistic
|
|
|
|
stats.Chart = statsChart
|
|
|
|
resp.SUCCESS(c, stats)
|
|
}
|