diff --git a/backend/internal/modules/adminfinance/dashboard.go b/backend/internal/modules/adminfinance/dashboard.go index d80876b..7bfb933 100644 --- a/backend/internal/modules/adminfinance/dashboard.go +++ b/backend/internal/modules/adminfinance/dashboard.go @@ -109,7 +109,7 @@ func (r *Repository) pickupSummary(ctx context.Context, query DashboardQuery) (* ProfitAmountCent int64 CompletedCount int64 } - if err := db.Table("admin_pickups"). + if err := db.Table("admin_pickups USE INDEX (idx_admin_pickups_dashboard_completed)"). Select(`COALESCE(SUM(settle_amount_cent), 0) AS settled_amount_cent, COALESCE(SUM(profit_amount_cent), 0) AS profit_amount_cent, COUNT(id) AS completed_count`). Where("status = ?", "completed"). Where("completed_at >= ? AND completed_at <= ?", query.StartDate, query.EndDate). @@ -136,7 +136,7 @@ func (r *Repository) pickupSummary(ctx context.Context, query DashboardQuery) (* AmountCent int64 Count int64 } - if err := db.Table("admin_pickups"). + if err := db.Table("admin_pickups USE INDEX (idx_admin_pickups_dashboard_offline_settlement)"). Select(`COALESCE(SUM(settle_amount_cent), 0) AS amount_cent, COUNT(id) AS count`). Where("settlement_mode = ? AND offline_settlement_status = ? AND settle_amount_cent > 0", "platform_managed", "pending"). Scan(&pending).Error; err != nil { @@ -240,7 +240,7 @@ func (r *Repository) dailyItems(ctx context.Context, query DashboardQuery) (dash } pickupProfits := make([]dailyPickupProfitRow, 0) - if err := db.Table("admin_pickups"). + if err := db.Table("admin_pickups USE INDEX (idx_admin_pickups_dashboard_completed)"). Select(`DATE_FORMAT(completed_at, '%Y-%m-%d') AS date, COALESCE(SUM(profit_amount_cent), 0) AS profit_amount_cent, COUNT(id) AS completed_count`). @@ -388,7 +388,7 @@ func (r *Repository) dailyItems(ctx context.Context, query DashboardQuery) (dash func (r *Repository) dailyEstimates(ctx context.Context, query DashboardQuery) ([]dailyEstimatedRow, error) { rows := make([]dailyEstimatedRow, 0) - err := r.db.WithContext(ctx).Table("rental_orders"). + err := r.db.WithContext(ctx).Table("rental_orders USE INDEX (idx_rental_orders_dashboard_estimates)"). Select(`DATE_FORMAT(created_at, '%Y-%m-%d') AS date, COALESCE(SUM(platform_fee_cent), 0) AS estimated_income_amount_cent, COUNT(id) AS pending_settle_order_count`). @@ -561,12 +561,12 @@ func (r *Repository) dailyPaidOrders(ctx context.Context, query DashboardQuery) items := make([]dailyPaidOrderRow, 0) err := r.db.WithContext(ctx).Table(`( SELECT DATE_FORMAT(paid_at, '%Y-%m-%d') AS date, COUNT(DISTINCT order_id) AS paid_order_count - FROM payment_orders + FROM payment_orders USE INDEX (idx_payment_orders_biz_status_paid_at_order) WHERE biz_type = 'order_pay' AND status = 'paid' AND paid_at >= ? AND paid_at <= ? GROUP BY DATE_FORMAT(paid_at, '%Y-%m-%d') UNION ALL SELECT DATE_FORMAT(completed_at, '%Y-%m-%d') AS date, COUNT(id) AS paid_order_count - FROM admin_pickups + FROM admin_pickups USE INDEX (idx_admin_pickups_dashboard_completed) WHERE status = 'completed' AND completed_at >= ? AND completed_at <= ? GROUP BY DATE_FORMAT(completed_at, '%Y-%m-%d') ) AS daily_paid_orders`, query.StartDate, query.EndDate, query.StartDate, query.EndDate). diff --git a/backend/internal/modules/adminfinance/disbursement.go b/backend/internal/modules/adminfinance/disbursement.go index 41cf1b2..ffa35f7 100644 --- a/backend/internal/modules/adminfinance/disbursement.go +++ b/backend/internal/modules/adminfinance/disbursement.go @@ -27,7 +27,7 @@ func (r *Repository) disbursementSummary(ctx context.Context, query DashboardQue AmountCent int64 Count int64 } - if err := db.Table("rental_orders"). + if err := db.Table("rental_orders USE INDEX (idx_rental_orders_dashboard_offline_settlement)"). Select(`COALESCE(SUM(offline_settlement_amount_cent), 0) AS amount_cent, COUNT(id) AS count`). Where("settlement_mode = ?", "platform_managed"). Where("offline_settlement_status = ?", "settled"). @@ -39,7 +39,7 @@ func (r *Repository) disbursementSummary(ctx context.Context, query DashboardQue AmountCent int64 Count int64 } - if err := db.Table("admin_pickups"). + if err := db.Table("admin_pickups USE INDEX (idx_admin_pickups_dashboard_offline_settlement)"). Select(`COALESCE(SUM(settle_amount_cent), 0) AS amount_cent, COUNT(id) AS count`). Where("settlement_mode = ?", "platform_managed"). Where("offline_settlement_status = ?", "settled"). @@ -65,7 +65,7 @@ func (r *Repository) disbursementSummary(ctx context.Context, query DashboardQue AmountCent int64 Count int64 } - if err := db.Table("rental_orders"). + if err := db.Table("rental_orders USE INDEX (idx_rental_orders_dashboard_offline_settlement)"). Select(`COALESCE(SUM(offline_settlement_amount_cent), 0) AS amount_cent, COUNT(id) AS count`). Where("settlement_mode = ?", "platform_managed"). Where("offline_settlement_status = ?", "pending"). @@ -77,7 +77,7 @@ func (r *Repository) disbursementSummary(ctx context.Context, query DashboardQue AmountCent int64 Count int64 } - if err := db.Table("admin_pickups"). + if err := db.Table("admin_pickups USE INDEX (idx_admin_pickups_dashboard_offline_settlement)"). Select(`COALESCE(SUM(settle_amount_cent), 0) AS amount_cent, COUNT(id) AS count`). Where("settlement_mode = ?", "platform_managed"). Where("offline_settlement_status = ?", "pending"). @@ -161,7 +161,7 @@ func (r *Repository) disbursementSummary(ctx context.Context, query DashboardQue func (r *Repository) dailyDisbursements(ctx context.Context, query DashboardQuery) ([]dailyDisbursementRow, error) { db := r.db.WithContext(ctx) offlineRows := make([]dailyDisbursementSourceRow, 0) - if err := db.Table("rental_orders"). + if err := db.Table("rental_orders USE INDEX (idx_rental_orders_dashboard_offline_settlement)"). Select(`DATE_FORMAT(offline_settled_at, '%Y-%m-%d') AS date, COALESCE(SUM(offline_settlement_amount_cent), 0) AS amount_cent, COUNT(id) AS count`). @@ -173,7 +173,7 @@ func (r *Repository) dailyDisbursements(ctx context.Context, query DashboardQuer return nil, err } pickupOfflineRows := make([]dailyDisbursementSourceRow, 0) - if err := db.Table("admin_pickups"). + if err := db.Table("admin_pickups USE INDEX (idx_admin_pickups_dashboard_offline_settlement)"). Select(`DATE_FORMAT(offline_settled_at, '%Y-%m-%d') AS date, COALESCE(SUM(settle_amount_cent), 0) AS amount_cent, COUNT(id) AS count`). diff --git a/backend/migrations/000092_finance_dashboard_estimate_index.sql b/backend/migrations/000092_finance_dashboard_estimate_index.sql new file mode 100644 index 0000000..15a34ab --- /dev/null +++ b/backend/migrations/000092_finance_dashboard_estimate_index.sql @@ -0,0 +1,43 @@ +-- +goose Up +-- 预计后续利润需要扫描时间范围内的未结算订单。订单表包含较大的 JSON 字段， +-- 覆盖索引避免统计时回表读取整行订单。 +ALTER TABLE rental_orders + ADD KEY idx_rental_orders_dashboard_estimates ( + created_at, + settlement_status, + status, + platform_fee_cent, + id + ), + ADD KEY idx_rental_orders_dashboard_offline_settlement ( + settlement_mode, + offline_settlement_status, + offline_settled_at, + offline_settlement_amount_cent, + id + ); + +ALTER TABLE admin_pickups + ADD KEY idx_admin_pickups_dashboard_completed ( + status, + completed_at, + settle_amount_cent, + profit_amount_cent, + id + ), + ADD KEY idx_admin_pickups_dashboard_offline_settlement ( + settlement_mode, + offline_settlement_status, + offline_settled_at, + settle_amount_cent, + id + ); + +-- +goose Down +ALTER TABLE rental_orders + DROP KEY idx_rental_orders_dashboard_offline_settlement, + DROP KEY idx_rental_orders_dashboard_estimates; + +ALTER TABLE admin_pickups + DROP KEY idx_admin_pickups_dashboard_offline_settlement, + DROP KEY idx_admin_pickups_dashboard_completed; diff --git a/scripts/check-sql-guard.sh b/scripts/check-sql-guard.sh index 9a344e8..0d67d1e 100755 --- a/scripts/check-sql-guard.sh +++ b/scripts/check-sql-guard.sh @@ -37,9 +37,18 @@ require_pattern "backend/internal/modules/adminfinance/subquery.go" "USE INDEX ( require_pattern "backend/migrations/000091_finance_dashboard_query_indexes.sql" "idx_payment_orders_dashboard_created" "财务支付聚合时间索引" require_pattern "backend/migrations/000091_finance_dashboard_query_indexes.sql" "idx_payment_orders_dashboard_order" "财务退款原金额索引" require_pattern "backend/migrations/000091_finance_dashboard_query_indexes.sql" "idx_rental_orders_dashboard_settled" "财务结算日报覆盖索引" +require_pattern "backend/migrations/000092_finance_dashboard_estimate_index.sql" "idx_rental_orders_dashboard_estimates" "财务预计利润覆盖索引" +require_pattern "backend/migrations/000092_finance_dashboard_estimate_index.sql" "idx_rental_orders_dashboard_offline_settlement" "财务订单出款覆盖索引" +require_pattern "backend/migrations/000092_finance_dashboard_estimate_index.sql" "idx_admin_pickups_dashboard_completed" "财务提号完成覆盖索引" +require_pattern "backend/migrations/000092_finance_dashboard_estimate_index.sql" "idx_admin_pickups_dashboard_offline_settlement" "财务提号出款覆盖索引" require_pattern "backend/migrations/000091_finance_dashboard_query_indexes.sql" "idx_order_checkouts_dashboard_accepted" "财务结账行覆盖索引" require_pattern "backend/internal/modules/adminfinance/dashboard.go" "USE INDEX (idx_rental_orders_dashboard_settled)" "结算日报时间索引" +require_pattern "backend/internal/modules/adminfinance/dashboard.go" "USE INDEX (idx_rental_orders_dashboard_estimates)" "预计利润时间索引" +require_pattern "backend/internal/modules/adminfinance/dashboard.go" "USE INDEX (idx_admin_pickups_dashboard_completed)" "提号完成日报索引" +require_pattern "backend/internal/modules/adminfinance/dashboard.go" "USE INDEX (idx_admin_pickups_dashboard_offline_settlement)" "提号待出款索引" require_pattern "backend/internal/modules/adminfinance/dashboard.go" "USE INDEX (idx_order_checkouts_dashboard_accepted)" "结算日报结账索引" +require_pattern "backend/internal/modules/adminfinance/disbursement.go" "USE INDEX (idx_rental_orders_dashboard_offline_settlement)" "订单出款覆盖索引" +require_pattern "backend/internal/modules/adminfinance/disbursement.go" "USE INDEX (idx_admin_pickups_dashboard_offline_settlement)" "提号出款覆盖索引" require_pattern "backend/migrations/000060_finance_dashboard_indexes.sql" "idx_admin_pickups_status_completed_at" "财务完成索引" require_pattern "backend/migrations/000060_finance_dashboard_indexes.sql" "idx_admin_pickups_status_cancelled_at" "财务取消索引"