wanwu/sub2api
1
0
Fork 0
mirror of https://gitee.com/wanwujie/sub2api synced 2026-04-12 19:04:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

Revert "fix: 并发/排队面板支持 platform/group 过滤"

Browse Source 
This reverts commit 86e600aa52.
This commit is contained in:
liuxiongfeng
2026-02-11 23:26:20 +08:00
parent a03c361b04
commit 51e903c34e
4 changed files with 6 additions and 103 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
backend/internal/handler/admin/ops_realtime_handler.go
View File

@@ -65,10 +65,6 @@ func (h *OpsHandler) GetConcurrencyStats(c *gin.Context) {
// GetUserConcurrencyStats returns real-time concurrency usage for all active users.
// GET /api/v1/admin/ops/user-concurrency
//
// Query params:
// - platform: optional, filter users by allowed platform
// - group_id: optional, filter users by allowed group
func (h *OpsHandler) GetUserConcurrencyStats(c *gin.Context) {
if h.opsService == nil {
response.Error(c, http.StatusServiceUnavailable, "Ops service not available")
@@ -88,18 +84,7 @@ func (h *OpsHandler) GetUserConcurrencyStats(c *gin.Context) {
return
}
platformFilter := strings.TrimSpace(c.Query("platform"))
var groupID *int64
if v := strings.TrimSpace(c.Query("group_id")); v != "" {
id, err := strconv.ParseInt(v, 10, 64)
if err != nil || id <= 0 {
response.BadRequest(c, "Invalid group_id")
return
}
groupID = &id
}
users, collectedAt, err := h.opsService.GetUserConcurrencyStats(c.Request.Context(), platformFilter, groupID)
users, collectedAt, err := h.opsService.GetUserConcurrencyStats(c.Request.Context())
if err != nil {
response.ErrorFrom(c, err)
return