kevin
50e1661c1b
流量统计从全站按日聚合升级为 per-user 维度，并引入 60 秒定时 落库机制，服务崩溃最多丢失 60 秒数据。 后端: - model/vpn.go: 新增 UserTrafficStat 模型（user_id + date 联合唯一索引） - db/db.go: AutoMigrate 注册新模型 - vpn/tunnel.go: tunnelConn 增加 flushedRx/flushedTx 快照字段 + flushDelta() 增量计算；recordTraffic 改为 per-user 双写 （user_traffic_stats + traffic_stats）；连接断开 defer 改增量落库 - vpn/service.go: 新增 flushDone 字段 + trafficFlusher（60s 定时 落库）+ flushAllTraffic；Stop() 先停 flusher 再最终 flush 全部 在线连接增量；TotalLiveTraffic 改返回未落库增量避免与 DB 重复； 新增 UserLiveTraffic(userID)；ClientInfo 增加 RxBytes/TxBytes - handler/traffic.go: 新建 5 个 handler（admin 3 个 + user 2 个） - router.go: 注册 5 条新路由 新增 API: - GET /api/admin/traffic/today 所有用户今日流量排行 - GET /api/admin/traffic/history?days=N 全站近 N 天流量历史 - GET /api/admin/traffic/users/:id?days=N 指定用户近 N 天流量 - GET /api/me/traffic/today 自己的今日流量 - GET /api/me/traffic?days=N 自己的近 N 天流量 前端: - 安装 chart.js + vue-chartjs - 新建 TrafficChart.vue 可复用柱状图组件（上行/下行双柱） - AdminView.vue: 在线客户端表格增加 RX/TX 列 + 全站 7 天流量 图表 + 用户今日流量排行表 - ProfileView.vue: 新增流量统计卡片（今日上行/下行/合计）+ 7 天 流量柱状图 - zh.ts/en.ts: 新增 traffic 相关国际化
61 lines
1.7 KiB
Go
61 lines
1.7 KiB
Go
package model
|
|
|
|
import "time"
|
|
|
|
const VpnSettingSingletonID = 1
|
|
|
|
type VpnSetting struct {
|
|
ID uint `gorm:"primaryKey"`
|
|
Enabled bool `gorm:"default:false"`
|
|
Subnet string `gorm:"size:64;not null"`
|
|
Subnet6 string `gorm:"size:64"`
|
|
MTU int `gorm:"default:1420"`
|
|
InterfaceName string `gorm:"size:16"`
|
|
AllowClientToClient bool `gorm:"default:false"`
|
|
DoLocalIPConfig bool `gorm:"default:true"`
|
|
DoRemoteIPConfig bool `gorm:"default:true"`
|
|
MaxConnsPerUser int `gorm:"default:30"`
|
|
UpdatedAt time.Time
|
|
}
|
|
|
|
func (VpnSetting) TableName() string {
|
|
return "vpn_settings"
|
|
}
|
|
|
|
type VpnReservation struct {
|
|
ID uint `gorm:"primaryKey;autoIncrement"`
|
|
UserID uint `gorm:"uniqueIndex;not null"`
|
|
IPAddress string `gorm:"size:64;uniqueIndex"`
|
|
IPAddress6 string `gorm:"size:64"`
|
|
CreatedAt time.Time `gorm:"autoCreateTime"`
|
|
}
|
|
|
|
func (VpnReservation) TableName() string {
|
|
return "vpn_reservations"
|
|
}
|
|
|
|
type TrafficStat struct {
|
|
ID uint `gorm:"primaryKey;autoIncrement"`
|
|
Date string `gorm:"uniqueIndex;size:10;not null"`
|
|
RxBytes int64 `gorm:"default:0"`
|
|
TxBytes int64 `gorm:"default:0"`
|
|
UpdatedAt time.Time
|
|
}
|
|
|
|
func (TrafficStat) TableName() string {
|
|
return "traffic_stats"
|
|
}
|
|
|
|
type UserTrafficStat struct {
|
|
ID uint `gorm:"primaryKey;autoIncrement"`
|
|
UserID uint `gorm:"uniqueIndex:idx_user_date;not null"`
|
|
Date string `gorm:"uniqueIndex:idx_user_date;size:10;not null"`
|
|
RxBytes int64 `gorm:"default:0"`
|
|
TxBytes int64 `gorm:"default:0"`
|
|
UpdatedAt time.Time
|
|
}
|
|
|
|
func (UserTrafficStat) TableName() string {
|
|
return "user_traffic_stats"
|
|
}
|