Hass/Message-Push-Nest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: dashboard statistic

Browse Source
This commit is contained in:
engigu
2025-12-06 18:54:12 +08:00
parent 850e52fce8
commit 8d61ace06a
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
models/send_tasks_logs.go
+4 -3
View File
@@ -339,17 +339,18 @@ func GetTrendStatisticData() (TrendStatisticData, error) {
return statistic, nil return statistic, nil
} }
// GetChannelStatisticData 获取渠道统计数据 // GetChannelStatisticData 获取渠道统计数据（包含任务实例和模板实例）
func GetChannelStatisticData() (ChannelStatisticData, error) { func GetChannelStatisticData() (ChannelStatisticData, error) {
var statistic ChannelStatisticData var statistic ChannelStatisticData
var wayCateData []WayCateData var wayCateData []WayCateData
inst := GetSchema(SendTasksIns{}) inst := GetSchema(SendTasksIns{})
wayst := GetSchema(SendWays{}) wayst := GetSchema(SendWays{})
// 消息实例分类数目 // 统计所有实例的渠道分布（包含任务实例和模板实例）
// 不区分 task_id 和 template_id，统计所有关联到渠道的实例
db. db.
Table(inst). Table(inst).
Select(fmt.Sprintf("%s.name as way_name, count(%s.id) as count_num", wayst, wayst)). Select(fmt.Sprintf("%s.name as way_name, count(%s.id) as count_num", wayst, inst)).
Joins(fmt.Sprintf("JOIN %s ON %s.way_id = %s.id", wayst, inst, wayst)). Joins(fmt.Sprintf("JOIN %s ON %s.way_id = %s.id", wayst, inst, wayst)).
Group(fmt.Sprintf("%s.id", wayst)). Group(fmt.Sprintf("%s.id", wayst)).
Scan(&wayCateData) Scan(&wayCateData)