QuantumNous · gladhu · Apr 12, 2026 · Apr 13, 2026 · Apr 26, 2026 · Apr 28, 2026
diff --git a/Dockerfile b/Dockerfile
@@ -1,26 +1,46 @@
+# Build parallelism: reserve RESERVE_CPU_CORES for the host (default 1). Example:
+#   docker build --build-arg RESERVE_CPU_CORES=2 .
+# Default/classic frontend stages may run in parallel; each uses roughly
+# floor((nproc - RESERVE) / 2) via GOMAXPROCS so the pair is less likely to
+# saturate all CPUs. The final Go compile stage uses (nproc - RESERVE).
 FROM oven/bun:1@sha256:0733e50325078969732ebe3b15ce4c4be5082f18c4ac1a0f0ca4839c2e4e42a7 AS builder
+ARG RESERVE_CPU_CORES=1
 
 WORKDIR /build
 COPY web/default/package.json .
 COPY web/default/bun.lock .
 RUN bun install
 COPY ./web/default .
 COPY ./VERSION .
-RUN DISABLE_ESLINT_PLUGIN='true' VITE_REACT_APP_VERSION=$(cat VERSION) bun run build
+RUN RESERVE="${RESERVE_CPU_CORES:-1}"; \
+    TOTAL=$(nproc); \
+    if [ "$TOTAL" -gt "$RESERVE" ]; then AVAIL=$((TOTAL - RESERVE)); else AVAIL=1; fi; \
+    USE=$((AVAIL / 2)); \
+    if [ "$USE" -lt 1 ]; then USE=1; fi; \
+    export GOMAXPROCS="$USE"; \
+    DISABLE_ESLINT_PLUGIN='true' VITE_REACT_APP_VERSION=$(cat VERSION) bun run build
 
 FROM oven/bun:1@sha256:0733e50325078969732ebe3b15ce4c4be5082f18c4ac1a0f0ca4839c2e4e42a7 AS builder-classic
+ARG RESERVE_CPU_CORES=1
 
 WORKDIR /build
 COPY web/classic/package.json .
 COPY web/classic/bun.lock .
 RUN bun install
 COPY ./web/classic .
 COPY ./VERSION .
-RUN VITE_REACT_APP_VERSION=$(cat VERSION) bun run build
+RUN RESERVE="${RESERVE_CPU_CORES:-1}"; \
+    TOTAL=$(nproc); \
+    if [ "$TOTAL" -gt "$RESERVE" ]; then AVAIL=$((TOTAL - RESERVE)); else AVAIL=1; fi; \
+    USE=$((AVAIL / 2)); \
+    if [ "$USE" -lt 1 ]; then USE=1; fi; \
+    export GOMAXPROCS="$USE"; \
+    VITE_REACT_APP_VERSION=$(cat VERSION) bun run build
 
 FROM golang:1.26.1-alpine@sha256:2389ebfa5b7f43eeafbd6be0c3700cc46690ef842ad962f6c5bd6be49ed82039 AS builder2
 ENV GO111MODULE=on CGO_ENABLED=0
 
+ARG RESERVE_CPU_CORES=1
 ARG TARGETOS
 ARG TARGETARCH
 ENV GOOS=${TARGETOS:-linux} GOARCH=${TARGETARCH:-amd64}
@@ -34,7 +54,11 @@ RUN go mod download
 COPY . .
 COPY --from=builder /build/dist ./web/default/dist
 COPY --from=builder-classic /build/dist ./web/classic/dist
-RUN go build -ldflags "-s -w -X 'github.com/QuantumNous/new-api/common.Version=$(cat VERSION)'" -o new-api
+RUN RESERVE="${RESERVE_CPU_CORES:-1}"; \
+    TOTAL=$(nproc); \
+    if [ "$TOTAL" -gt "$RESERVE" ]; then USE=$((TOTAL - RESERVE)); else USE=1; fi; \
+    export GOMAXPROCS="$USE"; \
+    go build -ldflags "-s -w -X 'github.com/QuantumNous/new-api/common.Version=$(cat VERSION)'" -o new-api
 
 FROM debian:bookworm-slim@sha256:f06537653ac770703bc45b4b113475bd402f451e85223f0f2837acbf89ab020a
 

diff --git a/Dockerfile.dev b/Dockerfile.dev
@@ -1,9 +1,12 @@
 # Backend-only build for frontend development
 # Skips frontend build, uses a placeholder for //go:embed web/dist
+#
+# Reserve RESERVE_CPU_CORES CPUs for the host during compile (default 1).
 
 FROM golang:1.26.1-alpine AS builder
 
 ENV GO111MODULE=on CGO_ENABLED=0
+ARG RESERVE_CPU_CORES=1
 ARG TARGETOS
 ARG TARGETARCH
 ENV GOOS=${TARGETOS:-linux} GOARCH=${TARGETARCH:-amd64}
@@ -20,7 +23,11 @@ RUN mkdir -p web/default/dist web/classic/dist && \
     echo '<!doctype html><html><head><title>dev</title></head><body>use frontend dev server</body></html>' > web/default/dist/index.html && \
     echo '<!doctype html><html><head><title>dev</title></head><body>use frontend dev server</body></html>' > web/classic/dist/index.html
 
-RUN go build -ldflags "-s -w -X 'github.com/QuantumNous/new-api/common.Version=$(cat VERSION)'" -o new-api
+RUN RESERVE="${RESERVE_CPU_CORES:-1}"; \
+    TOTAL=$(nproc); \
+    if [ "$TOTAL" -gt "$RESERVE" ]; then USE=$((TOTAL - RESERVE)); else USE=1; fi; \
+    export GOMAXPROCS="$USE"; \
+    go build -ldflags "-s -w -X 'github.com/QuantumNous/new-api/common.Version=$(cat VERSION)'" -o new-api
 
 FROM debian:bookworm-slim
 

diff --git a/VERSION b/VERSION
@@ -0,0 +1 @@
+0.0.1
diff --git a/common/constants.go b/common/constants.go
@@ -46,7 +46,7 @@ var DrawingEnabled = true
 var TaskEnabled = true
 var DataExportEnabled = true
 var DataExportInterval = 5         // unit: minute
-var DataExportDefaultTime = "hour" // unit: minute
+var DataExportDefaultTime = "day"
 var DefaultCollapseSidebar = false // default value of collapse sidebar
 
 // Any options with "Secret", "Token" in its key won't be return by GetOptions

diff --git a/controller/channel_consumption.go b/controller/channel_consumption.go
@@ -0,0 +1,109 @@
+package controller
+
+import (
+	"errors"
+	"net/http"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/QuantumNous/new-api/common"
+	"github.com/QuantumNous/new-api/model"
+
+	"github.com/gin-gonic/gin"
+)
+
+func parseChannelConsumptionTimeRange(c *gin.Context) (startTimestamp, endTimestamp int64, err error) {
+	startTimestamp, _ = strconv.ParseInt(c.Query("start_timestamp"), 10, 64)
+	endTimestamp, _ = strconv.ParseInt(c.Query("end_timestamp"), 10, 64)
+	if startTimestamp == 0 && endTimestamp == 0 {
+		now := time.Now()
+		loc := now.Location()
+		monthStart := time.Date(now.Year(), now.Month(), 1, 0, 0, 0, 0, loc)
+		startTimestamp = monthStart.Unix()
+		endTimestamp = now.Unix()
+		return startTimestamp, endTimestamp, nil
+	}
+	if startTimestamp == 0 || endTimestamp == 0 {
+		return 0, 0, errors.New("start_timestamp and end_timestamp are required")
+	}
+	if endTimestamp < startTimestamp {
+		return 0, 0, errors.New("end_timestamp must be greater than or equal to start_timestamp")
+	}
+	return startTimestamp, endTimestamp, nil
+}
+
+// GetChannelConsumption returns consume quota aggregated for a channel in [start_timestamp, end_timestamp].
+// Optional filters: user_id or username (for per-user consumption on this channel).
+func GetChannelConsumption(c *gin.Context) {
+	channelId, err := strconv.Atoi(c.Param("id"))
+	if err != nil || channelId <= 0 {
+		common.ApiError(c, errors.New("invalid channel id"))
+		return
+	}
+
+	channel, err := model.GetChannelById(channelId, false)
+	if err != nil {
+		common.ApiError(c, err)
+		return
+	}
+
+	startTimestamp, endTimestamp, err := parseChannelConsumptionTimeRange(c)
+	if err != nil {
+		c.JSON(http.StatusOK, gin.H{
+			"success": false,
+			"message": err.Error(),
+		})
+		return
+	}
+
+	userId, _ := strconv.Atoi(c.Query("user_id"))
+	username := strings.TrimSpace(c.Query("username"))
+	if userId > 0 {
+		if _, err := model.GetUserById(userId, false); err != nil {
+			common.ApiError(c, errors.New("user not found"))
+			return
+		}
+		username = ""
+	} else if username != "" {
+		if _, err := model.GetUserByUsername(username); err != nil {
+			common.ApiError(c, errors.New("user not found"))
+			return
+		}
+	}
+
+	stat, err := model.SumChannelConsumption(channelId, userId, username, startTimestamp, endTimestamp)
+	if err != nil {
+		common.ApiError(c, err)
+		return
+	}
+
+	resp := gin.H{
+		"channel_id":          channel.Id,
+		"channel_name":        channel.Name,
+		"start_timestamp":     startTimestamp,
+		"end_timestamp":       endTimestamp,
+		"quota":               stat.Quota,
+		"request_count":       stat.RequestCount,
+		"prompt_tokens":       stat.PromptTokens,
+		"completion_tokens":   stat.CompletionTokens,
+		"lifetime_used_quota": channel.UsedQuota,
+	}
+	if userId > 0 {
+		resp["user_id"] = userId
+		if user, uerr := model.GetUserById(userId, false); uerr == nil && user != nil {
+			resp["username"] = user.Username
+		}
+	} else if username != "" {
+		resp["username"] = username
+		if user, uerr := model.GetUserByUsername(username); uerr == nil && user != nil {
+			resp["user_id"] = user.Id
+		}
+	}
+
+	c.JSON(http.StatusOK, gin.H{
+		"success": true,
+		"message": "",
+		"data":    resp,
+	})
+}