1-15志愿导入三个区

src/api/mps/mpsScoreController.js

@@ -94,7 +94,7 @@ export async function GetMPSDistrictPersonNum(ctx) {
                     list[i].PlanNum = Number(list[i].PlanNum);
                 }
 
-                if (arr[1]) {
+                if (list.length>6) {
                     arr.push({ "Name": "能上" + list[1].SchoolType2Short, "Year1": list[1].PlanNum, "Year2": list[1].PlanNum - list[0].PlanNum });
                     arr.push({ "Name": "能上" + list[5].SchoolType2Short, "Year1": list[5].PlanNum + list[3].PlanNum, "Year2": list[5].PlanNum + list[3].PlanNum - list[4].PlanNum - list[2].PlanNum });
                     arr.push({ "Name": "能上" + list[7].SchoolType2Short, "Year1": list[7].PlanNum, "Year2": list[7].PlanNum - list[6].PlanNum });

秒过分数线数据导入/README.md

@@ -1,7 +1,7 @@
 # 上海中考招生计划与成绩导入说明
 
 本文档记录本项目每年从 PDF/图片整理上海中考招生计划、成绩，并导入 MySQL 表 `kylx365_db.MPS_Score` 的需求、步骤和注意事项。  
-当前已完成 2026 年“计划”中的 1、2、3：自主招生、名额到区、名额到校。
+当前已完成 2026 年“计划”中的自主招生、名额到区、名额到校，以及黄浦、徐汇、宝山 1-15 志愿。
 
 ## 年度工作范围
 
@@ -26,7 +26,7 @@
 - 计划/自主招生：已导入
 - 计划/名额到区：已导入
 - 计划/名额到校：已导入
-- 计划/1-15 志愿：待官方文件发布后导入
+- 计划/1-15 志愿：黄浦、徐汇、宝山已导入，其他区待文件
 - 成绩四类：预计 7 月中旬后导入
 
 ## 数据库与核心表
@@ -121,6 +121,15 @@ WHERE ScoreYear = '2025'
 - `SchoolTargetRemark = ""`
 - 维度是“区 + 高中”。
 
+1-15 志愿额外规则：
+
+- 每个区的数据由“本区高中”和“外区高中”共同组成。
+- `DistrictID` 表示招生计划所属区，不是高中所在区；例如黄浦区表中的外区高中仍写 `DistrictID = 1`。
+- 维度是“招生区 + 高中 + SchoolTargetRemark”。
+- `SchoolOfGraduation = NULL`、`SchoolFullNameJunior = NULL`。
+- 艺术班等特殊计划沿用上一年 `SchoolTargetRemark` 和 `SchoolTargetRemark2`。
+- 图片没有学校代码时，必须用学校简称逐一匹配 `MPS_School`，并在写入前校验高中 ID 与全称。
+
 ## 总体操作流程
 
 每一类数据都按以下流程做：
@@ -251,6 +260,17 @@ WHERE ScoreYear = '2025'
 - 会跳过数据库中已存在的 `DistrictID + SchoolOfGraduation + SchoolTarget` 组合。
 - 会刷新 `mps_score_school_quota_2026_problems.json`，只保留仍未解决的问题。
 
+1-15 志愿：
+
+- `import_mps_score_1_15_2026.py`
+- 当前包含黄浦、徐汇、宝山两张图片的人工结构化数据。
+- 支持 `--dry-run`，写入前校验学校 ID、全称、行数、计划数和学校唯一性。
+- 使用 `--district 1`、`--district 2`、`--district 9` 选择区，可重复传入处理多个区。
+- 如果所选区已有 2026 数据会拒绝再次插入。
+- 写入后在同一事务内按学校、备注、计划数、同比差值逐行集合校验，失败自动回滚。
+- 黄浦区第二张图片、徐汇区第二张图片标题写成“2025 年”，但计划数与新增学校均为 2026 数据，按 2026 导入。
+- 某些上一年学校在本年不再出现时，不额外插入 `PlanNum = 0` 的记录。因此当前行的 `SUM(PlanNumDifferenceValue)` 可能与两年全区总计划差不同。
+
 2026 一次性补充脚本：
 
 - `import_mps_score_quota_manual_2026.py`：用于 2026 名额到区图片/OCR特殊区的手工补录，不是新年份通用入口。
@@ -294,6 +314,20 @@ WHERE ScoreYear = '2025'
 - 计划数合计 12887
 - 问题清单 `mps_score_school_quota_2026_problems.json` 已清空
 
+计划/1-15 志愿：
+
+- 黄浦、徐汇、宝山已导入
+- `ScoreYear = 2026`
+- `ScoreType = 1-15志愿`
+- 已导入 194 行
+- 计划数合计 10673
+- 黄浦区：67 行、1512 人；本区 1365、外区 147
+- 徐汇区：68 行、3839 人；本区 3529、外区 310
+- 宝山区：59 行、5322 人；本区 5091、外区 231
+- 相比 2025 年全区总计划：黄浦净增 40、徐汇净增 377、宝山净增 462
+- 重复业务 key 为 0
+- 其他 13 个区待图片文件
+
 
 修正记录：
 
@@ -386,8 +420,8 @@ WHERE SchoolType1 = '初中'
 
 计划/1-15 志愿：
 
-- 等 2026 官方文件发布后处理。
-- 需要先研究 2025 的 PDF 与数据库写入形态，再决定 `ScoreType`、字段、维度和差值计算。
+- 黄浦、徐汇、宝山已完成。
+- 等其他区 2026 图片文件后继续处理。
 
 成绩导入：
 

秒过分数线数据导入/import_mps_score_1_15_2026.py

@@ -0,0 +1,557 @@
+import argparse
+import sys
+
+sys.path.insert(0, "/private/tmp/codex_mysql_driver")
+import pymysql  # noqa: E402
+
+
+DB_CONFIG = {
+    "host": "589ae8e08493d.sh.cdb.myqcloud.com",
+    "port": 8124,
+    "user": "cdb_outerroot",
+    "password": "kylx!@#!QAZ@WSX",
+    "database": "kylx365_db",
+    "charset": "utf8mb4",
+    "connect_timeout": 10,
+    "read_timeout": 30,
+    "write_timeout": 30,
+}
+
+YEAR = "2026"
+PREVIOUS_YEAR = "2025"
+SCORE_TYPE = "1-15志愿"
+
+INSERT_COLUMNS = [
+    "ScoreYear",
+    "ScoreType",
+    "DistrictID",
+    "SchoolOfGraduation",
+    "SchoolFullNameJunior",
+    "SchoolTarget",
+    "SchoolFullName",
+    "SchoolTargetRemark",
+    "PlanNum",
+    "ScoreTotal",
+    "Score1",
+    "Score2",
+    "Score3",
+    "Score4",
+    "SchoolTargetRemark2",
+    "PlanNumDifferenceValue",
+    "ScoreTotalDifferenceValue",
+    "OrderID",
+    "SchoolNumber",
+    "SchoolNumber2",
+    "SchoolOfGraduation1",
+]
+
+DISTRICT_DATA = {
+    1: {
+        "name": "黄浦区",
+        "local": [
+            (7, "上海市格致中学", 61),
+            (14, "上海市格致中学（奉贤校区）", 11),
+            (1021, "同济大学科技中学", 5),
+            (8, "上海市大同中学", 56),
+            (9, "上海市向明中学", 52),
+            (15, "上海市向明中学（浦江校区）", 7),
+            (10, "上海外国语大学附属大境中学", 65),
+            (11, "上海市光明中学", 61),
+            (12, "上海市敬业中学", 65),
+            (13, "上海市卢湾高级中学", 64),
+            (74, "上海市第八中学", 160),
+            (76, "上海市第十中学", 144),
+            (77, "上海理工大学附属储能中学", 144),
+            (78, "上海市金陵中学", 144),
+            (79, "上海市市南中学", 144),
+            (80, "上海音乐学院附属黄浦比乐中学", 144),
+            (81, "上海市同济黄浦设计创意中学", 38),
+        ],
+        "outside": [
+            (1, "上海市上海中学", 1),
+            (4, "华东师范大学第二附属中学", 1),
+            (3, "复旦大学附属中学", 1),
+            (2, "上海交通大学附属中学", 2),
+            (87, "上海市民办西南高级中学", 2),
+            (105, "上海市久隆模范中学", 1),
+            (108, "上海田家炳中学", 2),
+            (111, "上海市民办扬波中学", 2),
+            (113, "上海市民办风范中学", 2),
+            (100, "上海戏剧学院附属高级中学", 6),
+            (122, "上海安生学校", 7),
+            (117, "上海音乐学院附属安师实验中学", 3),
+            (156, "上海市民办燎原双语高级中学", 4),
+            (157, "上海闵行区诺达双语学校", 2),
+            (162, "上海闵行区民办德闳学校", 1),
+            (851, "上海民办行中中学", 2),
+            (177, "上海存志高级中学", 1),
+            (178, "上海宝山区民办维尚高级中学", 2),
+            (179, "上海创艺高级中学", 5),
+            (180, "上海市宝山华曜高级中学", 3),
+            (175, "上海市同洲模范学校", 1),
+            (852, "上海金瑞学校", 2),
+            (176, "上海宝山区世外学校", 1),
+            (188, "上海市民办远东学校", 2),
+            (189, "上海华旭双语学校", 3),
+            (190, "上海嘉定区民办华盛怀少学校", 5),
+            (218, "上海市浦东新区民办浦实高级中学", 2),
+            (220, "上海市民办丰华高级中学", 1),
+            (223, "民办上海工商外国语职业学院附属中学", 1),
+            (228, "上海市民办金苹果学校", 1),
+            (229, "上海浦东新区民办东鼎外国语学校", 1),
+            (230, "上海市民办尚德实验学校", 7),
+            (243, "上海市民办交大南洋中学", 9),
+            (246, "上海市民办永昌中学", 8),
+            (244, "上海金山区世外学校", 3),
+            (859, "上海市松江区科德高级中学", 1),
+            (1034, "上海市松江区励滕高级中学", 1),
+            (860, "上海领科双语学校", 1),
+            (251, "上海市西外外国语学校", 10),
+            (254, "上海赫贤学校", 2),
+            (995, "上海松江区爱菊学校", 1),
+            (863, "上海青浦区世外高级中学", 1),
+            (862, "上海青浦区宏润博源高级中学", 1),
+            (259, "上海宋庆龄学校", 2),
+            (260, "上海青浦区协和双语学校", 4),
+            (267, "上海美达菲双语高级中学", 6),
+            (266, "上海奉贤区博华高级中学", 3),
+            (268, "上海市崇明区城桥中学", 4),
+            (271, "上海市崇明区堡镇中学", 1),
+            (272, "上海民办民一中学", 12),
+        ],
+        "expected_local_total": 1365,
+        "expected_outside_total": 147,
+    },
+    2: {
+        "name": "徐汇区",
+        "local": [
+            (17, "上海市南洋模范中学", 100),
+            (18, "上海市位育中学", 108),
+            (985, "上海市位育附属徐汇科技实验中学", 172),
+            (19, "上海市南洋中学", 96),
+            (16, "上海市第二中学", 64),
+            (20, "上海市第二中学（梅陇校区）", 20),
+            (21, "复旦大学附属中学徐汇分校", 40),
+            (87, "上海市民办西南高级中学", 202),
+            (83, "上海市中国中学", 376),
+            (84, "上海市第五十四中学", 352),
+            (82, "上海市徐汇中学", 309),
+            (85, "上海市第四中学", 376),
+            (88, "上海市零陵中学", 188),
+            (89, "华东理工大学附属中学", 282),
+            (86, "上海市西南位育中学", 264),
+            (90, "上海市西南模范中学", 180),
+            (1022, "上海民办位育中学", 70),
+            (91, "上海市紫竹园中学", 170),
+            (92, "上海市徐汇区董恒甫高级中学", 160),
+        ],
+        "outside": [
+            (1, "上海市上海中学", 7),
+            (4, "华东师范大学第二附属中学", 1),
+            (3, "复旦大学附属中学", 1),
+            (2, "上海交通大学附属中学", 2),
+            (5, "上海师范大学附属中学", 2),
+            (81, "上海市同济黄浦设计创意中学", 4),
+            (105, "上海市久隆模范中学", 1),
+            (111, "上海市民办扬波中学", 6),
+            (113, "上海市民办风范中学", 3),
+            (100, "上海戏剧学院附属高级中学", 12),
+            (122, "上海安生学校", 8),
+            (117, "上海音乐学院附属安师实验中学", 3),
+            (148, "上海市文来中学", 1),
+            (156, "上海市民办燎原双语高级中学", 8),
+            (157, "上海闵行区诺达双语学校", 2),
+            (162, "上海闵行区民办德闳学校", 1),
+            (851, "上海民办行中中学", 10),
+            (177, "上海存志高级中学", 2),
+            (178, "上海宝山区民办维尚高级中学", 4),
+            (179, "上海创艺高级中学", 13),
+            (180, "上海市宝山华曜高级中学", 1),
+            (852, "上海金瑞学校", 5),
+            (175, "上海市同洲模范学校", 5),
+            (188, "上海市民办远东学校", 2),
+            (189, "上海华旭双语学校", 8),
+            (190, "上海嘉定区民办华盛怀少学校", 9),
+            (229, "上海浦东新区民办东鼎外国语学校", 5),
+            (218, "上海市浦东新区民办浦实高级中学", 2),
+            (228, "上海市民办金苹果学校", 6),
+            (230, "上海市民办尚德实验学校", 1),
+            (223, "民办上海工商外国语职业学院附属中学", 1),
+            (243, "上海市民办交大南洋中学", 25),
+            (244, "上海金山区世外学校", 12),
+            (859, "上海市松江区科德高级中学", 1),
+            (1034, "上海市松江区励滕高级中学", 2),
+            (860, "上海领科双语学校", 1),
+            (251, "上海市西外外国语学校", 15),
+            (254, "上海赫贤学校", 4),
+            (995, "上海松江区爱菊学校", 4),
+            (863, "上海青浦区世外高级中学", 4),
+            (862, "上海青浦区宏润博源高级中学", 8),
+            (259, "上海宋庆龄学校", 3),
+            (260, "上海青浦区协和双语学校", 2),
+            (267, "上海美达菲双语高级中学", 3),
+            (266, "上海奉贤区博华高级中学", 20),
+            (268, "上海市崇明区城桥中学", 10),
+            (271, "上海市崇明区堡镇中学", 27),
+            (272, "上海民办民一中学", 30),
+            (1039, "上海新纪元双语学校", 3),
+        ],
+        "expected_local_total": 3529,
+        "expected_outside_total": 310,
+    },
+    9: {
+        "name": "宝山区",
+        "local": [
+            (47, "上海市行知中学", 137),
+            (48, "上海大学附属中学", 137),
+            (49, "上海市吴淞中学", 119),
+            (50, "上海师范大学附属中学宝山分校", 66),
+            (51, "华东师范大学第二附属中学（宝山校区）", 86),
+            (167, "上海师范大学附属宝山罗店中学", 544),
+            (168, "上海市宝山中学", 620),
+            (169, "上海市通河中学", 355),
+            (172, "上海市淞浦中学", 336),
+            (170, "上海市顾村中学", 616),
+            (171, "上海市行知实验中学", 355),
+            (173, "上海市高境第一中学", 352),
+            (174, "上海市宝山区海滨中学", 252),
+            (851, "上海民办行中中学", 222),
+            (177, "上海存志高级中学", 84),
+            (178, "上海宝山区民办维尚高级中学", 9),
+            (179, "上海创艺高级中学", 104),
+            (180, "上海市宝山华曜高级中学", 190),
+            (175, "上海市同洲模范学校", 370),
+            (1028, "上海民办至德实验学校", 72),
+            (852, "上海金瑞学校", 43),
+            (176, "上海宝山区世外学校", 22),
+        ],
+        "outside": [
+            (1, "上海市上海中学", 1),
+            (4, "华东师范大学第二附属中学", 1),
+            (3, "复旦大学附属中学", 1),
+            (2, "上海交通大学附属中学", 1),
+            (81, "上海市同济黄浦设计创意中学", 3),
+            (108, "上海田家炳中学", 18),
+            (105, "上海市久隆模范中学", 3),
+            (100, "上海戏剧学院附属高级中学", 6),
+            (111, "上海市民办扬波中学", 24),
+            (113, "上海市民办风范中学", 28),
+            (117, "上海音乐学院附属安师实验中学", 2),
+            (122, "上海安生学校", 8),
+            (156, "上海市民办燎原双语高级中学", 2),
+            (190, "上海嘉定区民办华盛怀少学校", 4),
+            (189, "上海华旭双语学校", 18),
+            (188, "上海市民办远东学校", 5),
+            (230, "上海市民办尚德实验学校", 5),
+            (229, "上海浦东新区民办东鼎外国语学校", 2),
+            (223, "民办上海工商外国语职业学院附属中学", 2),
+            (220, "上海市民办丰华高级中学", 5),
+            (244, "上海金山区世外学校", 2),
+            (243, "上海市民办交大南洋中学", 25),
+            (246, "上海市民办永昌中学", 8),
+            (860, "上海领科双语学校", 2),
+            (254, "上海赫贤学校", 2),
+            (251, "上海市西外外国语学校", 5),
+            (995, "上海松江区爱菊学校", 4),
+            (1034, "上海市松江区励滕高级中学", 2),
+            (863, "上海青浦区世外高级中学", 3),
+            (862, "上海青浦区宏润博源高级中学", 1),
+            (260, "上海青浦区协和双语学校", 1),
+            (266, "上海奉贤区博华高级中学", 1),
+            (267, "上海美达菲双语高级中学", 1),
+            (268, "上海市崇明区城桥中学", 5),
+            (271, "上海市崇明区堡镇中学", 8),
+            (1039, "上海新纪元双语学校", 6),
+            (272, "上海民办民一中学", 16),
+        ],
+        "expected_local_total": 5091,
+        "expected_outside_total": 231,
+    },
+}
+
+SPECIAL_REMARKS = {
+    100: ("（艺术班）", "只招收经学校艺术特长测试合格的学生。"),
+    117: ("（艺术班）", "只招收经学校艺术特长测试合格的学生。"),
+}
+
+
+def connect():
+    return pymysql.connect(
+        **DB_CONFIG,
+        cursorclass=pymysql.cursors.DictCursor,
+        autocommit=False,
+    )
+
+
+def validate_source_data(district_id, data):
+    local_total = sum(plan_num for _, _, plan_num in data["local"])
+    outside_total = sum(plan_num for _, _, plan_num in data["outside"])
+    all_ids = [school_id for school_id, _, _ in data["local"] + data["outside"]]
+
+    if local_total != data["expected_local_total"]:
+        raise ValueError(
+            f"{data['name']} local total: expected "
+            f"{data['expected_local_total']}, got {local_total}"
+        )
+    if outside_total != data["expected_outside_total"]:
+        raise ValueError(
+            f"{data['name']} outside total: expected "
+            f"{data['expected_outside_total']}, got {outside_total}"
+        )
+    if len(all_ids) != len(set(all_ids)):
+        raise ValueError(f"{data['name']} contains duplicate school IDs")
+    if district_id < 1 or district_id > 16:
+        raise ValueError(f"invalid DistrictID: {district_id}")
+
+
+def load_and_validate_schools(cursor, data):
+    source = data["local"] + data["outside"]
+    expected = {school_id: school_name for school_id, school_name, _ in source}
+    placeholders = ", ".join(["%s"] * len(expected))
+    cursor.execute(
+        f"""
+        SELECT ID, SchoolFullName, SchoolType1
+        FROM MPS_School
+        WHERE ID IN ({placeholders})
+        """,
+        tuple(expected),
+    )
+    schools = {int(row["ID"]): row for row in cursor.fetchall()}
+
+    problems = []
+    for school_id, school_name in expected.items():
+        school = schools.get(school_id)
+        if not school:
+            problems.append(f"missing school ID {school_id}: {school_name}")
+        elif school["SchoolType1"] != "高中":
+            problems.append(f"school ID {school_id} is not 高中")
+        elif school["SchoolFullName"] != school_name:
+            problems.append(
+                f"school ID {school_id} name mismatch: "
+                f"expected {school_name}, got {school['SchoolFullName']}"
+            )
+    if problems:
+        raise ValueError("; ".join(problems))
+    return schools
+
+
+def load_previous_plan_nums(cursor, district_id):
+    cursor.execute(
+        """
+        SELECT SchoolTarget, SchoolTargetRemark, PlanNum
+        FROM MPS_Score
+        WHERE ScoreYear = %s
+          AND ScoreType = %s
+          AND DistrictID = %s
+        """,
+        (PREVIOUS_YEAR, SCORE_TYPE, district_id),
+    )
+    return {
+        (int(row["SchoolTarget"]), row["SchoolTargetRemark"] or ""): int(
+            row["PlanNum"] or 0
+        )
+        for row in cursor.fetchall()
+    }
+
+
+def build_records(district_id, data, schools, previous_plan_nums):
+    records = []
+    for school_id, _, plan_num in data["local"] + data["outside"]:
+        remark, remark2 = SPECIAL_REMARKS.get(school_id, ("", None))
+        previous = previous_plan_nums.get((school_id, remark), 0)
+        records.append(
+            {
+                "ScoreYear": YEAR,
+                "ScoreType": SCORE_TYPE,
+                "DistrictID": district_id,
+                "SchoolOfGraduation": None,
+                "SchoolFullNameJunior": None,
+                "SchoolTarget": str(school_id),
+                "SchoolFullName": schools[school_id]["SchoolFullName"],
+                "SchoolTargetRemark": remark,
+                "PlanNum": plan_num,
+                "ScoreTotal": 0,
+                "Score1": 0,
+                "Score2": 0,
+                "Score3": 0,
+                "Score4": 0,
+                "SchoolTargetRemark2": remark2,
+                "PlanNumDifferenceValue": plan_num - previous,
+                "ScoreTotalDifferenceValue": 0,
+                "OrderID": 0,
+                "SchoolNumber": "",
+                "SchoolNumber2": "",
+                "SchoolOfGraduation1": "0",
+            }
+        )
+    return records
+
+
+def ensure_not_imported(cursor, district_id, district_name):
+    cursor.execute(
+        """
+        SELECT COUNT(*) AS count, COALESCE(SUM(PlanNum), 0) AS total
+        FROM MPS_Score
+        WHERE ScoreYear = %s
+          AND ScoreType = %s
+          AND DistrictID = %s
+        """,
+        (YEAR, SCORE_TYPE, district_id),
+    )
+    existing = cursor.fetchone()
+    if existing["count"]:
+        raise RuntimeError(
+            f"{YEAR} {district_name} {SCORE_TYPE} already has "
+            f"{existing['count']} rows / {existing['total']} plans"
+        )
+
+
+def insert_records(cursor, records):
+    placeholders = ", ".join(["%s"] * len(INSERT_COLUMNS))
+    columns = ", ".join(INSERT_COLUMNS)
+    sql = f"INSERT INTO MPS_Score ({columns}) VALUES ({placeholders})"
+    cursor.executemany(
+        sql,
+        [[record[column] for column in INSERT_COLUMNS] for record in records],
+    )
+
+
+def validate_inserted_records(cursor, district_id, data, expected_records):
+    cursor.execute(
+        """
+        SELECT SchoolTarget, SchoolFullName, SchoolTargetRemark, PlanNum,
+               PlanNumDifferenceValue
+        FROM MPS_Score
+        WHERE ScoreYear = %s
+          AND ScoreType = %s
+          AND DistrictID = %s
+        """,
+        (YEAR, SCORE_TYPE, district_id),
+    )
+    actual_rows = cursor.fetchall()
+    actual = {
+        (
+            int(row["SchoolTarget"]),
+            row["SchoolFullName"],
+            row["SchoolTargetRemark"] or "",
+            int(row["PlanNum"] or 0),
+            int(row["PlanNumDifferenceValue"] or 0),
+        )
+        for row in actual_rows
+    }
+    expected = {
+        (
+            int(row["SchoolTarget"]),
+            row["SchoolFullName"],
+            row["SchoolTargetRemark"] or "",
+            int(row["PlanNum"]),
+            int(row["PlanNumDifferenceValue"]),
+        )
+        for row in expected_records
+    }
+    expected_total = data["expected_local_total"] + data["expected_outside_total"]
+
+    if len(actual_rows) != len(expected_records):
+        raise ValueError(
+            f"{data['name']} inserted row count: expected "
+            f"{len(expected_records)}, got {len(actual_rows)}"
+        )
+    if sum(int(row["PlanNum"] or 0) for row in actual_rows) != expected_total:
+        raise ValueError(f"{data['name']} inserted plan total does not match images")
+    if actual != expected:
+        raise ValueError(
+            f"{data['name']} inserted detail mismatch: "
+            f"missing={expected - actual}, extra={actual - expected}"
+        )
+
+
+def print_summary(district_id, data, records):
+    print(
+        "ready",
+        district_id,
+        data["name"],
+        "rows",
+        len(records),
+        "plan",
+        sum(row["PlanNum"] for row in records),
+        "difference",
+        sum(row["PlanNumDifferenceValue"] for row in records),
+    )
+    print(
+        "local",
+        "rows",
+        len(data["local"]),
+        "plan",
+        sum(plan_num for _, _, plan_num in data["local"]),
+    )
+    print(
+        "outside",
+        "rows",
+        len(data["outside"]),
+        "plan",
+        sum(plan_num for _, _, plan_num in data["outside"]),
+    )
+    for row in records:
+        print(
+            row["SchoolTarget"],
+            row["SchoolFullName"],
+            row["PlanNum"],
+            row["PlanNumDifferenceValue"],
+            row["SchoolTargetRemark"],
+        )
+
+
+def process_district(cursor, district_id, dry_run):
+    data = DISTRICT_DATA[district_id]
+    validate_source_data(district_id, data)
+    ensure_not_imported(cursor, district_id, data["name"])
+    schools = load_and_validate_schools(cursor, data)
+    previous_plan_nums = load_previous_plan_nums(cursor, district_id)
+    records = build_records(district_id, data, schools, previous_plan_nums)
+    print_summary(district_id, data, records)
+
+    if not dry_run:
+        insert_records(cursor, records)
+        validate_inserted_records(cursor, district_id, data, records)
+    return len(records)
+
+
+def main():
+    parser = argparse.ArgumentParser()
+    parser.add_argument(
+        "--district",
+        type=int,
+        action="append",
+        choices=sorted(DISTRICT_DATA),
+        help="DistrictID to process; may be provided more than once",
+    )
+    parser.add_argument(
+        "--dry-run",
+        action="store_true",
+        help="validate and print records without inserting them",
+    )
+    args = parser.parse_args()
+    district_ids = args.district or sorted(DISTRICT_DATA)
+
+    connection = connect()
+    try:
+        with connection.cursor() as cursor:
+            inserted = 0
+            for district_id in district_ids:
+                inserted += process_district(cursor, district_id, args.dry_run)
+
+            if args.dry_run:
+                connection.rollback()
+                print("dry-run complete; no data inserted")
+            else:
+                connection.commit()
+                print(f"inserted {inserted} rows")
+    except Exception:
+        connection.rollback()
+        raise
+    finally:
+        connection.close()
+
+
+if __name__ == "__main__":
+    main()

秒过分数线数据导入/需求.md

@@ -98,7 +98,8 @@ SELECT * FROM kylx365_db.MPS_Score where ScoreYear='2025' and ScoreType='名额
 
 一共16个区。
 
-——————————————————————————现在需要你帮我处理秒过分数线的1-15志愿数据
+——————————————————————————
+现在需要你帮我处理秒过分数线的1-15志愿数据
 
 之前所有的需求与处理过程看下面
 /Users/chengjie/Documents/git/miaoguo_system_server/秒过分数线数据导入/需求.md