From a9f8373ec302cb716c80bd315429b1456a1c68d5 Mon Sep 17 00:00:00 2001
From: zzh <1368735060@qq.com>
Date: Wed, 7 Oct 2026 18:42:41 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=88=86=E5=8C=BA=E6=98=8E=E7=BB=86?=
 =?UTF-8?q?=E5=85=A8=E9=87=8F=E6=9F=A5=E8=AF=A2=E5=8E=BB=E6=8E=89=20ORDER?=
 =?UTF-8?q?=20BY=EF=BC=8C=E9=81=BF=E5=85=8D=E6=9F=A5=E4=BB=B7=20sort=5Fbuf?=
 =?UTF-8?q?fer=20=E6=BA=A2=E5=87=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

大分区表全量 ORDER BY Id 会打满 MySQL sort_buffer；组包仍在内存排序，并补充 (AreaId, Id) 索引脚本。

Co-authored-by: Cursor <cursoragent@cursor.com>
---
 sql/migrate_kpi_area_info_area_id_index.sql    | 18 ++++++++++++++++++
 .../Channels/KpiAreaRepository.cs              |  6 ++++--
 2 files changed, 22 insertions(+), 2 deletions(-)
 create mode 100644 sql/migrate_kpi_area_info_area_id_index.sql

diff --git a/sql/migrate_kpi_area_info_area_id_index.sql b/sql/migrate_kpi_area_info_area_id_index.sql
new file mode 100644
index 0000000..da86588
--- /dev/null
+++ b/sql/migrate_kpi_area_info_area_id_index.sql
@@ -0,0 +1,18 @@
+-- 分区明细按 AreaId 全量/分页查询时避免 filesort 打满 sort_buffer（查价 LIVE 路径易踩）
+SET @db := DATABASE();
+
+SET @idx := (
+  SELECT COUNT(1)
+  FROM information_schema.STATISTICS
+  WHERE TABLE_SCHEMA = @db
+    AND TABLE_NAME = 't_kpi_area_info'
+    AND INDEX_NAME = 'idx_kpi_info_area_id'
+);
+SET @sql := IF(
+  @idx = 0,
+  'ALTER TABLE `t_kpi_area_info` ADD KEY `idx_kpi_info_area_id` (`AreaId`, `Id`)',
+  'SELECT ''idx_kpi_info_area_id already exists'' AS info'
+);
+PREPARE stmt FROM @sql;
+EXECUTE stmt;
+DEALLOCATE PREPARE stmt;
diff --git a/src/Oms.SqlSugarCore/Channels/KpiAreaRepository.cs b/src/Oms.SqlSugarCore/Channels/KpiAreaRepository.cs
index b06e0e4..c887260 100644
--- a/src/Oms.SqlSugarCore/Channels/KpiAreaRepository.cs
+++ b/src/Oms.SqlSugarCore/Channels/KpiAreaRepository.cs
@@ -21,9 +21,10 @@ public class KpiAreaRepository : OmsSqlSugarRepository<KpiArea>, IKpiAreaReposit
     public async Task<List<KpiAreaInfo>> GetInfosAsync(int areaId, int pageIndex, int pageSize, CancellationToken cancellationToken = default)
     {
         var db = await GetDbContextAsync(cancellationToken);
+        // 依赖 idx_kpi_info_area_id (AreaId, Id)，避免大分区 filesort
         return await db.Queryable<KpiAreaInfo>()
             .Where(x => x.AreaId == areaId)
-            .OrderBy(x => x.Id, SqlSugar.OrderByType.Desc)
+            .OrderBy(x => x.Id, OrderByType.Desc)
             .ToPageListAsync(pageIndex, pageSize, cancellationToken);
     }
 
@@ -66,9 +67,10 @@ public class KpiAreaRepository : OmsSqlSugarRepository<KpiArea>, IKpiAreaReposit
     public async Task<List<KpiAreaInfo>> GetAllInfosByAreaIdAsync(int areaId, CancellationToken cancellationToken = default)
     {
         var db = await GetDbContextAsync(cancellationToken);
+        // 大分区表（如美区邮编）全量 ORDER BY 会打满 MySQL sort_buffer 导致 500；
+        // 需要稳定顺序的调用方在内存中排序（如 EnsurePackAsync）。
         return await db.Queryable<KpiAreaInfo>()
             .Where(x => x.AreaId == areaId)
-            .OrderBy(x => x.Id)
             .ToListAsync(cancellationToken);
     }