feat: Phase 4 配分规则修正与雷达大屏优化

- LedgerSyncServiceImpl: 修正全部指标 ID（1001+ → 11~1522），移除无台账同步类型（reward_penalty/leave_special/banner_letter），添加 L3 级别路由
- ScoreRadarServiceImpl: 修复逗号分隔人名、无记录成员不显示、dept_type 改为 TEAMS、team_name 层级不匹配导致全员 80 分问题
- indicator_init.sql: 完整重写，与 score.sql ID 体系对齐（11~1522，共 128 条）
- 新增 fix_sync_indicator_ids.sql、truncate_ledger.sql 工具脚本
- pom.xml: 补充 airport-ledger 模块依赖声明

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

airport-admin/pom.xml

@@ -73,6 +73,12 @@
             <artifactId>airport-check</artifactId>
         </dependency>
 
+        <!-- 台账管理模块-->
+        <dependency>
+            <groupId>com.sundot.airport</groupId>
+            <artifactId>airport-ledger</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>

airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/LedgerSyncServiceImpl.java

@@ -16,21 +16,23 @@ import java.util.*;
 /**
  * 台账 → score_event 同步引擎
  *
- * 映射规则（indicator ID 固定，与 indicator_init.sql 一致）：
+ * 映射规则（indicator ID 与 score.sql 保持一致）：
  * ─────────────────────────────────────────────────────────
- * supervision_problem   → dim1 / 1001(L2) / 1101(L3, -1)
- * realtime_interception → dim1 / 1002(L2) / 1104(L3, -1)
- * security_test(未通过) → dim1 / 1004(L2) / 1113(L3, -0.5)
- * unsafe_event          → dim1 / 1003(L2) / 1110(L3, -2)
- * seizure_stats         → dim1 / 1005(L2) / 1114~1116(L3, +)
- * reward_approval       → dim1 / 1005(L2) / 1114~1116(L3, +)
- * service_patrol        → dim2 / 1011(L2) / 1123(L3, -0.8)
- * complaint             → dim2 / 1010(L2) / 1120(L3, -2)
- * terminal_bonus        → dim2 / 1012(L2)  (使用台账 add_score)
- * banner_letter         → dim2 / 1012(L2) / 1126锦旗 | 1124感谢信
- * exam_score(≥98)       → dim3 / 1024(L2) / 1146(L3, +5)
- * reward_penalty        → dim4 / 1033减|1035加(L2) / score_change
- * leave_special         → dim6 / 1050(L2) / 1220(L3, 0, 仅记录)
+ * supervision_problem   → dim1 / 11(L2) / 111~113(L3, 按层级区分)
+ * realtime_interception → dim1 / 12(L2) / 121~122(L3, 按层级区分)
+ * security_test(未通过) → dim1 / 14(L2) / 141~143(L3, 按层级区分, 均-0.5)
+ * unsafe_event          → dim1 / 13(L2) / 131~135(L3, 按类别区分)
+ * seizure_stats         → dim1 / 15(L2) / 151~153(L3, 按类别区分)
+ * reward_approval       → dim1 / 15(L2) / 151~153(L3, 按类别区分)
+ * service_patrol        → dim2 / 22(L2) / 221~223(L3, 按层级区分)
+ * complaint             → dim2 / 21(L2) / 无L3（叶子节点）
+ * terminal_bonus        → dim2 / 23(L2) / 231(L3, 使用台账add_score)
+ * exam_score(≥98)       → dim3 / 35(L2) / 351理论 | 352开机员(L3)
+ *
+ * 以下类型暂无台账，不同步（配分表分析.csv 标注"暂无台账，不考虑导入规则"）：
+ *   banner_letter  → 锦旗及感谢信（服务响应/典型服务案例）
+ *   reward_penalty → 部门奖惩记录（作风践行能力全部暂无台账）
+ *   leave_special  → 请休假记录（身心调节能力全部暂无台账）
  */
 @Service
 public class LedgerSyncServiceImpl implements ILedgerSyncService {
@@ -45,10 +47,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
     @Autowired private LedgerServicePatrolMapper servicePatrolMapper;
     @Autowired private LedgerComplaintMapper complaintMapper;
     @Autowired private LedgerTerminalBonusMapper terminalBonusMapper;
-    @Autowired private LedgerBannerLetterMapper bannerLetterMapper;
     @Autowired private LedgerExamScoreMapper examScoreMapper;
-    @Autowired private LedgerRewardPenaltyMapper rewardPenaltyMapper;
-    @Autowired private LedgerLeaveSpecialMapper leaveSpecialMapper;
 
     // ── Score Mappers ─────────────────────────────────────────
     @Autowired private ScoreEventMapper scoreEventMapper;
@@ -58,38 +57,41 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
     // ── Dimension ID cache (loaded once) ─────────────────────
     private final Map<String, Long> dimCache = new HashMap<>();
 
-    // ── Constants: Indicator IDs (from indicator_init.sql) ───
+    // ── Constants: Indicator IDs（与 score.sql 中的显式 ID 对应）─
     // dim1 安全防控能力
-    private static final long IND_SUPERVISION_L2   = 1001L; // 员工规范化操作
-    private static final long IND_SUPERVISION_L3   = 1101L; // 站层级质控 -1
-    private static final long IND_INTERCEPT_L2     = 1002L; // 后台实时质控
-    private static final long IND_INTERCEPT_L3     = 1104L; // 站层级（实时拦截）-1
-    private static final long IND_UNSAFE_L2        = 1003L; // 不安全事件
-    private static final long IND_UNSAFE_L3        = 1110L; // 禁带锐器等 -2 (default)
-    private static final long IND_SECTEST_L2       = 1004L; // 安保测试未通过
-    private static final long IND_SECTEST_L3       = 1113L; // 站层级 -0.5
-    private static final long IND_SEIZURE_L2       = 1005L; // 典型案例查获
-    private static final long IND_SEIZURE_L3_A     = 1114L; // 一类查获 +1
-    private static final long IND_SEIZURE_L3_B     = 1115L; // 二类查获 +0.5
-    private static final long IND_SEIZURE_L3_C     = 1116L; // 特殊物品 +0.15
+    private static final long IND_SUPERVISION_L2   = 11L;  // 员工规范化操作
+    private static final long IND_SUPERVISION_L3_STATION  = 111L; // 站层级质控 -1.0
+    private static final long IND_SUPERVISION_L3_DEPT     = 112L; // 部门层级质控 -0.8
+    private static final long IND_SUPERVISION_L3_LEADER   = 113L; // 上级领导巡查 -1.2
+    private static final long IND_INTERCEPT_L2     = 12L;  // 后台实时质控拦截
+    private static final long IND_INTERCEPT_L3_STATION    = 121L; // 站层级 -1.0
+    private static final long IND_INTERCEPT_L3_DEPT       = 122L; // 部门层级 -0.8
+    private static final long IND_UNSAFE_L2        = 13L;  // 不安全事件
+    private static final long IND_UNSAFE_L3_CAT1   = 131L; // 一类 -10
+    private static final long IND_UNSAFE_L3_CAT2   = 132L; // 二类 -8
+    private static final long IND_UNSAFE_L3_CAT3   = 133L; // 三类 -5
+    private static final long IND_UNSAFE_L3_CAT4   = 134L; // 四类 -3
+    private static final long IND_UNSAFE_L3_CAT5   = 135L; // 五类 -2 (默认)
+    private static final long IND_SECTEST_L2       = 14L;  // 安保测试未通过
+    private static final long IND_SECTEST_L3_GOV   = 141L; // 局方层级 -0.5
+    private static final long IND_SECTEST_L3_CORP  = 142L; // 公司层级 -0.5
+    private static final long IND_SECTEST_L3_STA   = 143L; // 站层级 -0.5
+    private static final long IND_SEIZURE_L2       = 15L;  // 典型案例查获
+    private static final long IND_SEIZURE_L3_A     = 151L; // 一类查获 +1.0
+    private static final long IND_SEIZURE_L3_B     = 152L; // 二类查获 +0.5
+    private static final long IND_SEIZURE_L3_C     = 153L; // 特殊查获 +0.15
     // dim2 服务响应能力
-    private static final long IND_COMPLAINT_L2     = 1010L; // 旅客服务投诉
-    private static final long IND_COMPLAINT_L3     = 1120L; // 未按服务质量手册 -2
-    private static final long IND_SVCPATROL_L2     = 1011L; // 服务监察
-    private static final long IND_SVCPATROL_L3     = 1123L; // 部门层级 -0.8
-    private static final long IND_TYPCASE_L2       = 1012L; // 典型服务案例
-    private static final long IND_TYPCASE_LETTER   = 1124L; // 表扬信/感谢信 +0.7
-    private static final long IND_TYPCASE_BANNER   = 1126L; // 锦旗 +1
+    private static final long IND_COMPLAINT_L2     = 21L;  // 旅客服务投诉（叶子节点，无L3）
+    private static final long IND_SVCPATROL_L2     = 22L;  // 服务监察
+    private static final long IND_SVCPATROL_L3_TERMINAL = 221L; // 航站楼及以上 -1.2
+    private static final long IND_SVCPATROL_L3_STATION  = 222L; // 站层级 -1.0
+    private static final long IND_SVCPATROL_L3_DEPT     = 223L; // 部门层级 -0.8
+    private static final long IND_TYPCASE_L2       = 23L;  // 典型服务案例
+    private static final long IND_TYPCASE_L3       = 231L; // 航站楼加分（分值取台账add_score）
     // dim3 业务实操能力
-    private static final long IND_EXAM_L2          = 1024L; // 考试成绩
-    private static final long IND_EXAM_L3_THEORY   = 1146L; // 季度理论≥98 +5
-    private static final long IND_EXAM_L3_MACHINE  = 1147L; // 季度开机员≥98 +5
-    // dim4 作风践行能力
-    private static final long IND_PENALTY_L2       = 1033L; // 形象维护（减）
-    private static final long IND_REWARD_L2        = 1035L; // 形象维护（加）
-    // dim6 身心调节能力
-    private static final long IND_LEAVE_L2         = 1050L; // 病假（仅记录）
-    private static final long IND_LEAVE_L3         = 1220L; // 病假（不扣分）
+    private static final long IND_EXAM_L2          = 35L;  // 考试成绩
+    private static final long IND_EXAM_L3_THEORY   = 351L; // 季度理论≥98 +5
+    private static final long IND_EXAM_L3_MACHINE  = 352L; // 季度开机员≥98 +5
 
     // ── Score defaults ────────────────────────────────────────
     private static final BigDecimal NEG_ONE   = BigDecimal.valueOf(-1.00);
@@ -116,8 +118,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         for (String type : Arrays.asList(
                 "supervision_problem", "realtime_interception", "security_test",
                 "unsafe_event", "seizure_stats", "reward_approval",
-                "service_patrol", "complaint", "terminal_bonus", "banner_letter",
-                "exam_score", "reward_penalty", "leave_special")) {
+                "service_patrol", "complaint", "terminal_bonus", "exam_score")) {
             SyncResult r = doSync(type);
             sb.append(type).append(":+").append(r.getTotalInserted())
               .append("/skip").append(r.getTotalSkipped()).append("  ");
@@ -149,10 +150,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             case "service_patrol":        return syncServicePatrol();
             case "complaint":             return syncComplaint();
             case "terminal_bonus":        return syncTerminalBonus();
-            case "banner_letter":         return syncBannerLetter();
             case "exam_score":            return syncExamScore();
-            case "reward_penalty":        return syncRewardPenalty();
-            case "leave_special":         return syncLeaveSpecial();
             default: return new SyncResult(0, 0, "unknown type: " + type);
         }
     }
@@ -161,19 +159,24 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
     //  Per-table sync methods
     // ═════════════════════════════════════════════════════════
 
-    /** 1. 部门监察问题记录 → 安全防控能力/员工规范化操作 */
+    /** 1. 部门监察问题记录 → 安全防控能力/员工规范化操作（按问题层级区分L3） */
     private SyncResult syncSupervisionProblem() {
         List<LedgerSupervisionProblem> list = supervisionMapper.selectList(new LedgerSupervisionProblem());
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_SUPERVISION_L2);
-        ScoreIndicator lv3 = getIndicator(IND_SUPERVISION_L3);
         int ins = 0, skip = 0;
         for (LedgerSupervisionProblem row : list) {
             String src = "supervision_problem:" + row.getId();
             if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getInspectedName())) { skip++; continue; }
-            BigDecimal sv = row.getDeductScore() != null
-                    ? row.getDeductScore().negate() : NEG_ONE;
+            // 按问题层级选取L3指标和默认分值
+            String level = row.getProblemType() != null ? row.getProblemType() : "";
+            long l3Id; BigDecimal defaultSv;
+            if (level.contains("上级")) { l3Id = IND_SUPERVISION_L3_LEADER; defaultSv = BigDecimal.valueOf(-1.20); }
+            else if (level.contains("部门")) { l3Id = IND_SUPERVISION_L3_DEPT; defaultSv = BigDecimal.valueOf(-0.80); }
+            else { l3Id = IND_SUPERVISION_L3_STATION; defaultSv = NEG_ONE; }
+            BigDecimal sv = row.getDeductScore() != null ? row.getDeductScore().negate() : defaultSv;
+            ScoreIndicator lv3 = getIndicator(l3Id);
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectedName(),
                     row.getTeamName(), row.getRecordDate(),
                     row.getLocation(), sv, ZERO,
@@ -184,20 +187,19 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 2. 实时质控拦截 → 安全防控能力/后台实时质控拦截 */
+    /** 2. 实时质控拦截 → 安全防控能力/后台实时质控拦截（按问题层级区分L3） */
     private SyncResult syncRealtimeInterception() {
         List<LedgerRealtimeInterception> list = interceptionMapper.selectList(new LedgerRealtimeInterception());
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_INTERCEPT_L2);
-        ScoreIndicator lv3 = getIndicator(IND_INTERCEPT_L3);
         int ins = 0, skip = 0;
         for (LedgerRealtimeInterception row : list) {
             String src = "realtime_interception:" + row.getId();
             if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getInspectorName())) { skip++; continue; }
-            // 实时拦截是负分（被拦截到问题）
-            BigDecimal sv = row.getDeductScore() != null
-                    ? row.getDeductScore().negate() : NEG_ONE;
+            // 实时拦截台账无层级字段，按实际deductScore计分；L3指标默认站层级
+            BigDecimal sv = row.getDeductScore() != null ? row.getDeductScore().negate() : NEG_ONE;
+            ScoreIndicator lv3 = getIndicator(IND_INTERCEPT_L3_STATION);
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectorName(),
                     row.getTeamName(), row.getRecordDate(),
                     row.getChannelNo(), sv, ZERO,
@@ -208,18 +210,23 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 3. 安保测试（仅"未通过"才计分） */
+    /** 3. 安保测试（仅"未通过"才计分，按层级选L3，分值均为-0.5） */
     private SyncResult syncSecurityTest() {
         List<LedgerSecurityTest> list = securityTestMapper.selectList(new LedgerSecurityTest());
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_SECTEST_L2);
-        ScoreIndicator lv3 = getIndicator(IND_SECTEST_L3);
         int ins = 0, skip = 0;
         for (LedgerSecurityTest row : list) {
             String src = "security_test:" + row.getId();
             if (existsBySrc(src)) { skip++; continue; }
             if (!"未通过".equals(row.getTestResult())) { skip++; continue; }
             if (!hasName(row.getTestedName())) { skip++; continue; }
+            String level = row.getTestType() != null ? row.getTestType() : "";
+            long l3Id;
+            if (level.contains("局方")) { l3Id = IND_SECTEST_L3_GOV; }
+            else if (level.contains("公司")) { l3Id = IND_SECTEST_L3_CORP; }
+            else { l3Id = IND_SECTEST_L3_STA; }
+            ScoreIndicator lv3 = getIndicator(l3Id);
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getTestedName(),
                     row.getTeamName(), row.getRecordDate(),
                     null, NEG_HALF, ZERO,
@@ -230,19 +237,25 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 4. 不安全事件 */
+    /** 4. 不安全事件（按类别选L3和默认分值） */
     private SyncResult syncUnsafeEvent() {
         List<LedgerUnsafeEvent> list = unsafeEventMapper.selectList(new LedgerUnsafeEvent());
         Long dimId = dimCache.get("安全防控能力");
         ScoreIndicator lv2 = getIndicator(IND_UNSAFE_L2);
-        ScoreIndicator lv3 = getIndicator(IND_UNSAFE_L3);
         int ins = 0, skip = 0;
         for (LedgerUnsafeEvent row : list) {
             String src = "unsafe_event:" + row.getId();
             if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getResponsibleName())) { skip++; continue; }
-            BigDecimal sv = row.getDeductScore() != null
-                    ? row.getDeductScore().negate() : NEG_TWO;
+            String cat = row.getEventType() != null ? row.getEventType() : "";
+            long l3Id; BigDecimal defaultSv;
+            if (cat.contains("一类"))      { l3Id = IND_UNSAFE_L3_CAT1; defaultSv = BigDecimal.valueOf(-10.00); }
+            else if (cat.contains("二类")) { l3Id = IND_UNSAFE_L3_CAT2; defaultSv = BigDecimal.valueOf(-8.00); }
+            else if (cat.contains("三类")) { l3Id = IND_UNSAFE_L3_CAT3; defaultSv = BigDecimal.valueOf(-5.00); }
+            else if (cat.contains("四类")) { l3Id = IND_UNSAFE_L3_CAT4; defaultSv = BigDecimal.valueOf(-3.00); }
+            else                           { l3Id = IND_UNSAFE_L3_CAT5; defaultSv = NEG_TWO; }
+            BigDecimal sv = row.getDeductScore() != null ? row.getDeductScore().negate() : defaultSv;
+            ScoreIndicator lv3 = getIndicator(l3Id);
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getResponsibleName(),
                     row.getTeamName(), row.getRecordDate(),
                     null, sv, ZERO,
@@ -253,7 +266,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 5. 查获违规品统计（加分） */
+    /** 5. 查获违规品统计（加分，按类别选L3） */
     private SyncResult syncSeizureStats() {
         List<LedgerSeizureStats> list = seizureMapper.selectList(new LedgerSeizureStats());
         Long dimId = dimCache.get("安全防控能力");
@@ -263,13 +276,11 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             String src = "seizure_stats:" + row.getId();
             if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getInspectorName())) { skip++; continue; }
-            // 按类别确定指标和分值
             String cat = row.getItemCategory() != null ? row.getItemCategory() : "";
             long l3Id; BigDecimal sv;
-            if (cat.contains("一类")) { l3Id = IND_SEIZURE_L3_A; sv = POS_ONE; }
+            if (cat.contains("一类"))      { l3Id = IND_SEIZURE_L3_A; sv = POS_ONE; }
             else if (cat.contains("二类")) { l3Id = IND_SEIZURE_L3_B; sv = POS_HALF; }
-            else { l3Id = IND_SEIZURE_L3_C; sv = POS_015; }
-            // 叠加分
+            else                           { l3Id = IND_SEIZURE_L3_C; sv = POS_015; }
             BigDecimal cascade = row.getStackedScore() != null ? row.getStackedScore() : ZERO;
             ScoreIndicator lv3 = getIndicator(l3Id);
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectorName(),
@@ -282,7 +293,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 6. 小额奖励审批单（安全类查获加分） */
+    /** 6. 小额奖励审批单（安全类查获加分，按类别选L3） */
     private SyncResult syncRewardApproval() {
         List<LedgerRewardApproval> list = rewardApprovalMapper.selectList(new LedgerRewardApproval());
         Long dimId = dimCache.get("安全防控能力");
@@ -292,12 +303,11 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             String src = "reward_approval:" + row.getId();
             if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getPersonName())) { skip++; continue; }
-            // 奖励类别
             String cat = row.getRewardType() != null ? row.getRewardType() : "";
             long l3Id; BigDecimal sv;
-            if ("一类".equals(cat) || cat.contains("一类")) { l3Id = IND_SEIZURE_L3_A; sv = POS_ONE; }
-            else if ("二类".equals(cat) || cat.contains("二类")) { l3Id = IND_SEIZURE_L3_B; sv = POS_HALF; }
-            else { l3Id = IND_SEIZURE_L3_C; sv = POS_015; }
+            if (cat.contains("一类"))      { l3Id = IND_SEIZURE_L3_A; sv = POS_ONE; }
+            else if (cat.contains("二类")) { l3Id = IND_SEIZURE_L3_B; sv = POS_HALF; }
+            else                           { l3Id = IND_SEIZURE_L3_C; sv = POS_015; }
             ScoreIndicator lv3 = getIndicator(l3Id);
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
                     row.getTeamName(), row.getApproveDate() != null ? new java.util.Date(row.getApproveDate().getTime()) : null,
@@ -309,19 +319,23 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 7. 服务巡查 → 服务响应能力/服务监察 */
+    /** 7. 服务巡查 → 服务响应能力/服务监察（按问题层级区分L3） */
     private SyncResult syncServicePatrol() {
         List<LedgerServicePatrol> list = servicePatrolMapper.selectList(new LedgerServicePatrol());
         Long dimId = dimCache.get("服务响应能力");
         ScoreIndicator lv2 = getIndicator(IND_SVCPATROL_L2);
-        ScoreIndicator lv3 = getIndicator(IND_SVCPATROL_L3);
         int ins = 0, skip = 0;
         for (LedgerServicePatrol row : list) {
             String src = "service_patrol:" + row.getId();
             if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getInspectedName())) { skip++; continue; }
-            BigDecimal sv = row.getDeductScore() != null
-                    ? row.getDeductScore().negate() : NEG_08;
+            String level = row.getServiceType() != null ? row.getServiceType() : "";
+            long l3Id; BigDecimal defaultSv;
+            if (level.contains("航站楼")) { l3Id = IND_SVCPATROL_L3_TERMINAL; defaultSv = BigDecimal.valueOf(-1.20); }
+            else if (level.contains("站层级") || level.contains("站级")) { l3Id = IND_SVCPATROL_L3_STATION; defaultSv = NEG_ONE; }
+            else { l3Id = IND_SVCPATROL_L3_DEPT; defaultSv = NEG_08; }
+            BigDecimal sv = row.getDeductScore() != null ? row.getDeductScore().negate() : defaultSv;
+            ScoreIndicator lv3 = getIndicator(l3Id);
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getInspectedName(),
                     row.getTeamName(), row.getRecordDate(),
                     row.getLocation(), sv, ZERO,
@@ -332,20 +346,18 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 8. 投诉情况（有责任人才计分） */
+    /** 8. 投诉情况（有责任人才计分；旅客服务投诉为L2叶子节点，无L3） */
     private SyncResult syncComplaint() {
         List<LedgerComplaint> list = complaintMapper.selectList(new LedgerComplaint());
         Long dimId = dimCache.get("服务响应能力");
         ScoreIndicator lv2 = getIndicator(IND_COMPLAINT_L2);
-        ScoreIndicator lv3 = getIndicator(IND_COMPLAINT_L3);
         int ins = 0, skip = 0;
         for (LedgerComplaint row : list) {
             String src = "complaint:" + row.getId();
             if (existsBySrc(src)) { skip++; continue; }
             if (!hasName(row.getResponsibleName())) { skip++; continue; }
-            BigDecimal sv = row.getDeductScore() != null
-                    ? row.getDeductScore().negate() : NEG_TWO;
-            ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getResponsibleName(),
+            BigDecimal sv = row.getDeductScore() != null ? row.getDeductScore().negate() : NEG_TWO;
+            ScoreEvent e = buildEvent(dimId, lv2, null, row.getResponsibleName(),
                     row.getTeamName(), row.getRecordDate(),
                     null, sv, ZERO,
                     row.getComplaintDesc(), src, row.getEvidenceFile());
@@ -355,12 +367,12 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 9. 航站楼加分 */
+    /** 9. 航站楼加分 → 服务响应能力/典型服务案例/航站楼加分（分值取台账add_score） */
     private SyncResult syncTerminalBonus() {
         List<LedgerTerminalBonus> list = terminalBonusMapper.selectList(new LedgerTerminalBonus());
         Long dimId = dimCache.get("服务响应能力");
         ScoreIndicator lv2 = getIndicator(IND_TYPCASE_L2);
-        ScoreIndicator lv3 = getIndicator(IND_TYPCASE_LETTER);  // 默认表扬信
+        ScoreIndicator lv3 = getIndicator(IND_TYPCASE_L3);
         int ins = 0, skip = 0;
         for (LedgerTerminalBonus row : list) {
             String src = "terminal_bonus:" + row.getId();
@@ -377,32 +389,7 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 10. 锦旗及感谢信 */
-    private SyncResult syncBannerLetter() {
-        List<LedgerBannerLetter> list = bannerLetterMapper.selectList(new LedgerBannerLetter());
-        Long dimId = dimCache.get("服务响应能力");
-        ScoreIndicator lv2 = getIndicator(IND_TYPCASE_L2);
-        int ins = 0, skip = 0;
-        for (LedgerBannerLetter row : list) {
-            String src = "banner_letter:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
-            if (!hasName(row.getPersonName())) { skip++; continue; }
-            boolean isBanner = "1".equals(row.getType());
-            long l3Id = isBanner ? IND_TYPCASE_BANNER : IND_TYPCASE_LETTER;
-            BigDecimal sv = row.getAddScore() != null ? row.getAddScore()
-                    : (isBanner ? POS_ONE : POS_07);
-            ScoreIndicator lv3 = getIndicator(l3Id);
-            ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
-                    row.getTeamName(), row.getRecordDate(),
-                    null, sv, ZERO,
-                    row.getContentDesc(), src, row.getEvidenceFile());
-            scoreEventMapper.insert(e);
-            ins++;
-        }
-        return new SyncResult(ins, skip, "");
-    }
-
-    /** 11. 成绩收集（≥98加5分，其余仅记录） */
+    /** 10. 成绩收集（≥98加5分；其余不计分，暂无台账规则） */
     private SyncResult syncExamScore() {
         List<LedgerExamScore> list = examScoreMapper.selectList(new LedgerExamScore());
         Long dimId = dimCache.get("业务实操能力");
@@ -414,21 +401,16 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
             if (!hasName(row.getPersonName())) { skip++; continue; }
             if (row.getScore() == null) { skip++; continue; }
             double score = row.getScore().doubleValue();
-            // ≥98 → 加分；<60 → 扣分（补考）；其余仅记录
-            BigDecimal sv;
-            ScoreIndicator lv3;
-            if (score >= 98) {
-                sv = POS_FIVE;
-                lv3 = getIndicator(IND_EXAM_L3_THEORY);
-            } else if (score < 60) {
-                sv = BigDecimal.valueOf(-2.00);
-                lv3 = getIndicator(1140L); // 补考（阶梯递增）
-            } else {
-                skip++; continue; // 60~97 仅记录，不影响得分
-            }
+            // 仅≥98分加分；补考扣分规则暂无台账，不处理
+            if (score < 98) { skip++; continue; }
+            // 按科目区分L3（图像成绩→开机员能力，其余→理论）
+            String category = row.getExamCategory() != null ? row.getExamCategory() : "";
+            long l3Id = category.contains("图像") || category.contains("开机")
+                    ? IND_EXAM_L3_MACHINE : IND_EXAM_L3_THEORY;
+            ScoreIndicator lv3 = getIndicator(l3Id);
             ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
                     row.getTeamName(), null,
-                    null, sv, ZERO,
+                    null, POS_FIVE, ZERO,
                     row.getExamCategory() + " " + row.getExamPeriod(), src, null);
             scoreEventMapper.insert(e);
             ins++;
@@ -436,50 +418,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
         return new SyncResult(ins, skip, "");
     }
 
-    /** 12. 部门奖惩记录 */
-    private SyncResult syncRewardPenalty() {
-        List<LedgerRewardPenalty> list = rewardPenaltyMapper.selectList(new LedgerRewardPenalty());
-        Long dimId = dimCache.get("作风践行能力");
-        int ins = 0, skip = 0;
-        for (LedgerRewardPenalty row : list) {
-            String src = "reward_penalty:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
-            if (!hasName(row.getPersonName())) { skip++; continue; }
-            boolean isPenalty = "2".equals(row.getType());
-            ScoreIndicator lv2 = getIndicator(isPenalty ? IND_PENALTY_L2 : IND_REWARD_L2);
-            BigDecimal sv = row.getScoreChange() != null ? row.getScoreChange()
-                    : (isPenalty ? NEG_TWO : POS_ONE);
-            ScoreEvent e = buildEvent(dimId, lv2, null, row.getPersonName(),
-                    row.getTeamName(), row.getRecordDate(),
-                    null, sv, ZERO,
-                    row.getEventDesc(), src, row.getEvidenceFile());
-            scoreEventMapper.insert(e);
-            ins++;
-        }
-        return new SyncResult(ins, skip, "");
-    }
-
-    /** 13. 请休假记录（仅记录，不计分） */
-    private SyncResult syncLeaveSpecial() {
-        List<LedgerLeaveSpecial> list = leaveSpecialMapper.selectList(new LedgerLeaveSpecial());
-        Long dimId = dimCache.get("身心调节能力");
-        ScoreIndicator lv2 = getIndicator(IND_LEAVE_L2);
-        ScoreIndicator lv3 = getIndicator(IND_LEAVE_L3);
-        int ins = 0, skip = 0;
-        for (LedgerLeaveSpecial row : list) {
-            String src = "leave_special:" + row.getId();
-            if (existsBySrc(src)) { skip++; continue; }
-            if (!hasName(row.getPersonName())) { skip++; continue; }
-            ScoreEvent e = buildEvent(dimId, lv2, lv3, row.getPersonName(),
-                    row.getTeamName(), null,
-                    null, ZERO, ZERO,
-                    row.getLeaveType(), src, null);
-            scoreEventMapper.insert(e);
-            ins++;
-        }
-        return new SyncResult(ins, skip, "");
-    }
-
     // ═════════════════════════════════════════════════════════
     //  Helpers
     // ═════════════════════════════════════════════════════════
@@ -514,7 +452,6 @@ public class LedgerSyncServiceImpl implements ILedgerSyncService {
                 .filter(x -> x.getValue().equals(dimId)).map(Map.Entry::getKey).findFirst().orElse("") : "");
         if (lv2 != null) {
             e.setLevel2Name(lv2.getName());
-            // lv3 作为末级指标 ID
         }
         if (lv3 != null) {
             e.setIndicatorId(lv3.getId());

airport-ledger/src/main/java/com/sundot/airport/ledger/service/impl/ScoreRadarServiceImpl.java

@@ -1,6 +1,7 @@
 package com.sundot.airport.ledger.service.impl;
 
 import com.sundot.airport.common.core.domain.entity.SysDept;
+import com.sundot.airport.common.core.domain.entity.SysUser;
 import com.sundot.airport.ledger.domain.ScoreDimension;
 import com.sundot.airport.ledger.domain.ScoreEvent;
 import com.sundot.airport.ledger.domain.vo.MemberScoreVO;
@@ -8,6 +9,7 @@ import com.sundot.airport.ledger.mapper.ScoreDimensionMapper;
 import com.sundot.airport.ledger.mapper.ScoreEventMapper;
 import com.sundot.airport.ledger.service.IScoreRadarService;
 import com.sundot.airport.system.mapper.SysDeptMapper;
+import com.sundot.airport.system.mapper.SysUserMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -28,11 +30,13 @@ public class ScoreRadarServiceImpl implements IScoreRadarService {
     @Autowired
     private SysDeptMapper sysDeptMapper;
 
+    @Autowired
+    private SysUserMapper sysUserMapper;
+
     @Override
     public List<String> selectTeamList() {
-        // 从 sys_dept 读 dept_type=MANAGER（班组）的列表，不依赖 score_event 是否有数据
         SysDept query = new SysDept();
-        query.setDeptType("MANAGER");
+        query.setDeptType("TEAMS");
         return sysDeptMapper.selectDeptList(query).stream()
                 .map(SysDept::getDeptName)
                 .filter(name -> name != null && !name.isEmpty())
@@ -48,37 +52,57 @@ public class ScoreRadarServiceImpl implements IScoreRadarService {
         List<ScoreDimension> dimensions = scoreDimensionMapper.selectList(dq);
         dimensions.sort(Comparator.comparing(d -> (d.getSortOrder() == null ? 999 : d.getSortOrder())));
 
-        // 2. 获取该班组所有事件记录
-        ScoreEvent eq = new ScoreEvent();
-        eq.setTeamName(teamName);
-        List<ScoreEvent> events = scoreEventMapper.selectList(eq);
+        // 2. 从 sys_dept + sys_user 获取小组完整成员列表
+        //    即使没有加减分记录，成员也需要展示
+        Set<String> rosterNames = getMemberRoster(teamName);
+
+        // 3. 加载全量事件记录，按花名册姓名过滤
+        //    不依赖 team_name 字段（台账导入的 team_name 是班组级别，与小组名不匹配）
+        //    通过姓名匹配花名册，确保只统计本小组成员的事件
+        //    原始数据不规范：person_name 可能为 "张三,李四,王五"，需拆分后各自计分
+        List<ScoreEvent> events = scoreEventMapper.selectList(new ScoreEvent());
 
-        // 3. 按姓名分组 → 每人的维度事件分合计
+        // 4. 按拆分后的姓名分组汇总各维度得分（仅统计花名册成员）
         //    Map<personName, Map<dimensionId, eventScoreSum>>
         Map<String, Map<Long, BigDecimal>> personDimMap = new LinkedHashMap<>();
         for (ScoreEvent e : events) {
-            String person = e.getPersonName();
-            if (person == null || person.trim().isEmpty()) continue;
+            String rawName = e.getPersonName();
+            if (rawName == null || rawName.trim().isEmpty()) continue;
             Long dimId = e.getDimensionId();
+            if (dimId == null) continue;
             BigDecimal val = e.getTotalScore() != null ? e.getTotalScore() : BigDecimal.ZERO;
-            personDimMap
-                    .computeIfAbsent(person, k -> new HashMap<>())
-                    .merge(dimId, val, BigDecimal::add);
+
+            // 拆分逗号分隔的多人姓名，只处理在本小组花名册中的人
+            String[] names = rawName.split("[,，]");
+            for (String n : names) {
+                String name = n.trim();
+                if (name.isEmpty()) continue;
+                if (!rosterNames.contains(name)) continue; // 不在本组，跳过
+                personDimMap
+                        .computeIfAbsent(name, k -> new HashMap<>())
+                        .merge(dimId, val, BigDecimal::add);
+            }
         }
 
-        // 4. 构建 VO
+        // 5. 合并花名册与事件记录：花名册中的人若无事件记录，也需要出现
+        //    先把花名册成员加入（保证顺序：花名册在前，事件中有但花名册没有的追加到后面）
+        Set<String> allNames = new LinkedHashSet<>(rosterNames);
+        allNames.addAll(personDimMap.keySet());
+
+        // 6. 构建 VO
         List<MemberScoreVO> result = new ArrayList<>();
-        for (Map.Entry<String, Map<Long, BigDecimal>> entry : personDimMap.entrySet()) {
+        for (String name : allNames) {
+            Map<Long, BigDecimal> dimScoreMap = personDimMap.getOrDefault(name, Collections.emptyMap());
+
             MemberScoreVO vo = new MemberScoreVO();
-            vo.setPersonName(entry.getKey());
+            vo.setPersonName(name);
             vo.setTeamName(teamName);
 
             List<MemberScoreVO.DimScore> dimScores = new ArrayList<>();
             BigDecimal totalScore = BigDecimal.ZERO;
 
             for (ScoreDimension dim : dimensions) {
-                BigDecimal eventScore = entry.getValue()
-                        .getOrDefault(dim.getId(), BigDecimal.ZERO);
+                BigDecimal eventScore = dimScoreMap.getOrDefault(dim.getId(), BigDecimal.ZERO);
                 BigDecimal base = dim.getBaseScore() != null ? dim.getBaseScore() : BigDecimal.valueOf(80);
                 BigDecimal dimScore = base.add(eventScore);
 
@@ -105,8 +129,35 @@ public class ScoreRadarServiceImpl implements IScoreRadarService {
             result.add(vo);
         }
 
-        // 5. 按综合得分降序排序
+        // 7. 按综合得分降序排序
         result.sort((a, b) -> b.getTotalScore().compareTo(a.getTotalScore()));
         return result;
     }
+
+    /**
+     * 从 sys_dept + sys_user 查询班组完整花名册
+     * dept_type='MANAGER' 对应班组，nick_name 对应 person_name
+     */
+    private Set<String> getMemberRoster(String teamName) {
+        // 找班组对应的 dept_id
+        SysDept deptQuery = new SysDept();
+        deptQuery.setDeptType("TEAMS");
+        deptQuery.setDeptName(teamName);
+        List<SysDept> depts = sysDeptMapper.selectDeptList(deptQuery);
+        if (depts == null || depts.isEmpty()) {
+            return new LinkedHashSet<>();
+        }
+        Long deptId = depts.get(0).getDeptId();
+
+        // 查该班组下所有在职用户的 nick_name
+        List<SysUser> users = sysUserMapper.selectUsersByDeptId(deptId);
+        if (users == null) {
+            return new LinkedHashSet<>();
+        }
+        return users.stream()
+                .filter(u -> "0".equals(u.getStatus()) && "0".equals(u.getDelFlag()))
+                .map(SysUser::getNickName)
+                .filter(n -> n != null && !n.trim().isEmpty())
+                .collect(Collectors.toCollection(LinkedHashSet::new));
+    }
 }

pom.xml

@@ -253,6 +253,13 @@
                 <version>${airport.version}</version>
             </dependency>
 
+            <!-- 台账管理模块-->
+            <dependency>
+                <groupId>com.sundot.airport</groupId>
+                <artifactId>airport-ledger</artifactId>
+                <version>${airport.version}</version>
+            </dependency>
+
             <dependency>
                 <groupId>org.projectlombok</groupId>
                 <artifactId>lombok</artifactId>
@@ -281,6 +288,7 @@
         <module>airport-exam</module>
         <module>airport-check</module>
         <module>airport-attendance</module>
+        <module>airport-ledger</module>
     </modules>
     <packaging>pom</packaging>
 

sql/excel_to_sql.py

@@ -0,0 +1,540 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+"""
+旅检三部"三三"数字管理平台 Excel → SQL 导入脚本
+运行: python excel_to_sql.py
+输出: ledger_data_import.sql
+"""
+
+import os, re, sys
+from datetime import datetime, date
+
+try:
+    import openpyxl
+except ImportError:
+    sys.exit("请先安装 openpyxl: pip install openpyxl")
+
+# ──────────────────────────────────────────────
+# 配置
+# ──────────────────────────────────────────────
+EXCEL_DIR  = r'C:\Users\linzo\Downloads'
+OUTPUT_SQL = r'C:\Users\linzo\IdeaProjects\chongqing-server\sql\ledger_data_import.sql'
+BATCH_NO   = datetime.now().strftime('BATCH_%Y%m%d_%H%M%S')
+CREATE_BY  = 'admin'
+CREATE_TIME = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+
+# ──────────────────────────────────────────────
+# 工具函数
+# ──────────────────────────────────────────────
+def find_excel():
+    for f in os.listdir(EXCEL_DIR):
+        if '旅检' in f and f.endswith('.xlsx') and not f.startswith('~'):
+            return os.path.join(EXCEL_DIR, f)
+    raise FileNotFoundError('找不到 旅检*.xlsx 文件，请检查路径')
+
+def esc(v, maxlen=None):
+    """转义 SQL 字符串值，可选最大长度截断"""
+    if v is None:
+        return 'NULL'
+    s = str(v).strip()
+    if s == '' or s == 'None':
+        return 'NULL'
+    s = s.replace('\\', '\\\\').replace("'", "\\'").replace('\n', '\\n').replace('\r', '').replace('\t', ' ')
+    if maxlen and len(s) > maxlen:
+        s = s[:maxlen]
+    return f"'{s}'"
+
+def to_date(v):
+    """将各种格式的日期转成 'YYYY-MM-DD' 或 NULL"""
+    if v is None:
+        return 'NULL'
+    if isinstance(v, (datetime, date)):
+        return f"'{v.strftime('%Y-%m-%d')}'"
+    s = str(v).strip()
+    if not s or s == 'None':
+        return 'NULL'
+    # 尝试多种格式
+    for fmt in ('%Y-%m-%d %H:%M:%S', '%Y-%m-%d %H:%M', '%Y-%m-%d', '%Y/%m/%d', '%m/%d/%Y'):
+        try:
+            return f"'{datetime.strptime(s.split('.')[0].strip(), fmt).strftime('%Y-%m-%d')}'"
+        except ValueError:
+            pass
+    # 返回原始字符串（可能有特殊格式）
+    return esc(s[:10])
+
+def to_decimal(v, default='NULL'):
+    if v is None:
+        return default
+    s = str(v).strip().replace('¥', '').replace(',', '').strip()
+    if not s or s == 'None':
+        return default
+    try:
+        return str(float(s))
+    except ValueError:
+        return default
+
+def to_int(v, default='NULL'):
+    if v is None:
+        return default
+    try:
+        return str(int(float(str(v))))
+    except (ValueError, TypeError):
+        return default
+
+def row_vals(ws, row_num):
+    """返回一行所有单元格值（列表）"""
+    row = list(ws.iter_rows(min_row=row_num, max_row=row_num, values_only=True))
+    return list(row[0]) if row else []
+
+def iter_data_rows(ws, header_row=2):
+    """从 header_row+1 开始迭代有效数据行"""
+    for row in ws.iter_rows(min_row=header_row + 1, values_only=True):
+        # 跳过全空行
+        if all(v is None or str(v).strip() == '' for v in row):
+            continue
+        yield list(row)
+
+def pad(lst, n):
+    """把列表补齐到 n 长度"""
+    return lst + [None] * max(0, n - len(lst))
+
+# ──────────────────────────────────────────────
+# 各 sheet 的映射函数
+# 每个函数返回 list of SQL INSERT 语句
+# ──────────────────────────────────────────────
+
+def sheet_supervision_problem(ws):
+    """部门监察问题记录表 → ledger_supervision_problem
+    Excel R2: 时间(0) 区域(1) 工作点(2) 岗位(3) 责任人(4) 问题描述(5)
+              问题类型(6) 整改措施(7) 依据(8) 问题层级(9) 班组(10)
+              队室质控员(11) 质控推送队室负责人(12) 附件(13) 整改情况(14)
+              佐证材料(15) 发送至相关人员(16) 本月内发生问题次数(17)
+              上月质控问题超过三次人员(18) 检查人员(19) 分管质控经理(20)
+              录入时间(21) 部门培训教员(22) 队室内勤(23) 队室负责人(24)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 25)
+        stmts.append(
+            f"INSERT INTO ledger_supervision_problem "
+            f"(record_date,location,channel_no,inspected_name,problem_desc,problem_type,"
+            f"result_handling,remark,team_name,inspector_name,evidence_file,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[1])},{esc(c[2])},{esc(c[4])},{esc(c[5])},{esc(c[6])},"
+            f"{esc(c[7])},{esc(c[8])},{esc(c[10])},{esc(c[11])},{esc(c[13])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_patrol_inspection(ws):
+    """队室三级质控巡查记录表 → ledger_patrol_inspection
+    Excel R2: 巡查日期(0) 巡查区域(1) 巡查工作点(2) 巡查时间段(3) 巡查岗位(4)
+              被检查人员(5) 有无问题(6) 检查情况描述(7) 类型(8) 整改措施(9)
+              附件(10) 整改情况(11) 佐证材料(12) 班组(13) 责任组长(14)
+              队室质控员(15) 队室负责人(16) 填报人(17) 队室内勤(18) 填报时间(19)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 20)
+        stmts.append(
+            f"INSERT INTO ledger_patrol_inspection "
+            f"(record_date,location,channel_no,inspected_name,patrol_type,patrol_item,"
+            f"problem_desc,result_handling,evidence_file,team_name,inspector_name,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[1])},{esc(c[2])},{esc(c[5])},{esc(c[8])},{esc(c[4])},"
+            f"{esc(c[7])},{esc(c[9])},{esc(c[10])},{esc(c[13])},{esc(c[14])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def _parse_datetime(v):
+    """返回 (date_str, time_str) tuple for SQL"""
+    if v is None:
+        return 'NULL', 'NULL'
+    if isinstance(v, datetime):
+        return f"'{v.strftime('%Y-%m-%d')}'", f"'{v.strftime('%H:%M:%S')}'"
+    s = str(v).strip()
+    if not s or s == 'None':
+        return 'NULL', 'NULL'
+    for fmt in ('%Y-%m-%d %H:%M:%S', '%Y-%m-%d %H:%M', '%Y-%m-%d'):
+        try:
+            dt = datetime.strptime(s.split('.')[0].strip(), fmt)
+            return f"'{dt.strftime('%Y-%m-%d')}'", f"'{dt.strftime('%H:%M:%S')}'"
+        except ValueError:
+            pass
+    return esc(s[:10]), 'NULL'
+
+
+def sheet_realtime_interception(ws):
+    """部门实时质控拦截情况记录表 → ledger_realtime_interception
+    Excel R2: 时间(0) 区域(1) 工作点(2) 岗位(3) 责任人(4) 实时质控拦截物品(5)
+              个数(6) 问题类型(7) 整改措施(8) 问题层级(9) 班组(10)
+              附件(11) 问题类别(12) 个人复盘(13) 队室复盘(14)
+              队室质控员(15) 质控推送队室负责人(16) 开机年限(17)
+              责任人开机年龄(18) 发送至相关人员(19)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 20)
+        d, t = _parse_datetime(c[0])
+        stmts.append(
+            f"INSERT INTO ledger_realtime_interception "
+            f"(record_date,record_time,channel_no,inspector_name,item_name,"
+            f"item_quantity,item_category,handling_method,team_name,evidence_file,remark,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{d},{t},{esc(c[2])},{esc(c[4])},{esc(c[5])},"
+            f"{to_int(c[6])},{esc(c[7])},{esc(c[8])},{esc(c[10])},{esc(c[11])},{esc(c[12])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_service_patrol(ws):
+    """服务巡查 → ledger_service_patrol
+    Excel R2: 时间(0) 区域(1) 工作点(2) 岗位(3) 责任人(4) 问题描述(5)
+              问题类型(6) 整改措施(7) 班组(8) 问题层级(9)
+              队室服务联络人(10) 服务推送队室负责人(11) 附件(12)
+              整改情况(13) 佐证材料(14) 发送至相关人员(15)
+              本月内发生问题次数(16) 检查人员(17) 分管服务经理(18) 队室内勤(19)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 20)
+        stmts.append(
+            f"INSERT INTO ledger_service_patrol "
+            f"(record_date,location,inspected_name,problem_desc,service_type,"
+            f"result_handling,team_name,evidence_file,inspector_name,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[1])},{esc(c[4])},{esc(c[5])},{esc(c[6])},"
+            f"{esc(c[7])},{esc(c[8])},{esc(c[12])},{esc(c[17])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_complaint(ws):
+    """投诉情况 → ledger_complaint
+    Excel R2: 时间(0) 航班号(1) 旅客姓名(2) 班组(3) 责任人(4)
+              投诉情况(5) 旅客诉求(6) 类别(7) 渠道来源(8)
+              是否有责(9) 处理进度(10) 责任队长(11) 队室内勤(12)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 13)
+        stmts.append(
+            f"INSERT INTO ledger_complaint "
+            f"(record_date,flight_no,passenger_name,team_name,responsible_name,"
+            f"complaint_desc,complaint_type,result_handling,remark,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[1])},{esc(c[2])},{esc(c[3])},{esc(c[4])},"
+            f"{esc(c[5])},{esc(c[7])},{esc(c[10])},{esc(c[8])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_security_test(ws):
+    """安保测试记录表（部门）→ ledger_security_test
+    Excel R2: 开展时间(0) 测试区域(1) 测试通道(2) 测试项目(3)
+              被测试人员(4) 被测试岗位(5) 测试物品(6) 开展项目图片或视频(7)
+              是否通过(8) 层级(9) 整改措施(10) 复查地点及时间(11)
+              整改材料(12) 班组(13) 推送队室质控员(14) 推送质控队长(15)
+              队室内勤(16) 点击推送至相关人员(17) 队室负责人(18)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 19)
+        stmts.append(
+            f"INSERT INTO ledger_security_test "
+            f"(record_date,location,channel_no,test_item,tested_name,test_type,"
+            f"evidence_file,test_result,result_handling,team_name,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[1])},{esc(c[2])},{esc(c[3])},{esc(c[4])},{esc(c[6])},"
+            f"{esc(c[7])},{esc(c[8])},{esc(c[10])},{esc(c[13])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_channel_pass_rate(ws):
+    """通道过检率 → ledger_channel_pass_rate
+    Excel R2: 组长(0) 班组(1) 队室内勤(2) 2026年1月平均过检率(3) 2026年2月...(4) 2026年3月...(5) ...
+    结构是 pivot：一行=一个班组，多列=多月；展开为多行
+    """
+    headers = row_vals(ws, 2)
+    # 找月份列（列3起）
+    month_cols = []
+    for idx, h in enumerate(headers[3:], start=3):
+        if h and str(h).strip():
+            month_cols.append((idx, str(h).strip()))
+
+    # 提取月份年份
+    def parse_month(label):
+        m = re.search(r'(\d{4})年(\d{1,2})月', label)
+        if m:
+            return f"{m.group(1)}-{int(m.group(2)):02d}-01"
+        return None
+
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, len(headers) + 5)
+        team = esc(c[1])
+        for col_idx, label in month_cols:
+            rate = to_decimal(c[col_idx] if col_idx < len(c) else None)
+            if rate == 'NULL':
+                continue
+            month_date = parse_month(label)
+            rec_date = f"'{month_date}'" if month_date else 'NULL'
+            stmts.append(
+                f"INSERT INTO ledger_channel_pass_rate "
+                f"(record_date,team_name,pass_rate,remark,"
+                f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+                f"{rec_date},{team},{rate},{esc(label)},"
+                f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+            )
+    return stmts
+
+
+def sheet_unsafe_event(ws):
+    """不安全事件 → ledger_unsafe_event
+    Excel R2: 时间(0) 事件描述(1) 类别(2) 航班号(3) 责任人(4)
+              涉及班组(5) 涉及物品(6) 岗位(7) 区域(8) 通道号(9)
+              图像(10) 队室内勤(11)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 12)
+        stmts.append(
+            f"INSERT INTO ledger_unsafe_event "
+            f"(record_date,event_desc,event_type,responsible_name,team_name,"
+            f"evidence_file,remark,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[1])},{esc(c[2])},{esc(c[4])},{esc(c[5])},"
+            f"{esc(c[10])},{esc(c[8])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_seizure_stats(ws):
+    """2026查获违规品统计 → ledger_seizure_stats
+    Excel R2: 查获时间(0) 信息提取(1) 信息提取2(2) 部门/队室(3) 工作区域(4)
+              安检员(5) 安检资格证书等级(6) 岗位(7) 航班号(8) 目的地(9)
+              进/出港(10) 违规主体(11) 旅客姓名(12) 旅客性别(13) 旅客民族(14)
+              旅客年龄(15) 违规类别(16) 违规物品种类(17) 二级分类(18) 数量(19)
+              ...（可能更多列）
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 30)
+        stmts.append(
+            f"INSERT INTO ledger_seizure_stats "
+            f"(record_date,team_name,inspector_name,flight_no,passenger_name,"
+            f"item_category,item_name,item_quantity,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[3])},{esc(c[5])},{esc(c[8])},{esc(c[12])},"
+            f"{esc(c[16])},{esc(c[17])},{to_int(c[19])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_terminal_bonus(ws):
+    """航站楼加分 → ledger_terminal_bonus
+    Excel R2: 审核日期(0) 姓名(1) 班组(2) 加分分数(3) 队室内勤(4) 总加分数(5) 队室负责人(6)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 7)
+        stmts.append(
+            f"INSERT INTO ledger_terminal_bonus "
+            f"(approve_date,person_name,team_name,add_score,remark,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[1])},{esc(c[2])},{to_decimal(c[3],'0')},{esc(c[4])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_exam_score(ws):
+    """成绩收集 → ledger_exam_score
+    Excel R2: 类别(0) 期数(1) 考试人员(2) 理论成绩(3) 图像成绩(4) 班组(5) 分类(6) 备注（补考分数）(7) 队室教员(8)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 9)
+        stmts.append(
+            f"INSERT INTO ledger_exam_score "
+            f"(exam_category,exam_period,person_name,score,team_name,remark,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{esc(c[0])},{esc(c[1])},{esc(c[2])},{to_decimal(c[3],'NULL')},{esc(c[5])},{esc(c[7])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_reward_approval(ws):
+    """小额奖励审批单-安检-质控 → ledger_reward_approval
+    特殊：R1 就是表头（没有 title row）
+    Excel R1: 员工编码(0) 姓名(1) 查获（事件）时间(2) 奖励类别(3) 查获物品(4)
+              类别(5) 奖励事由（安全）(6) 人员类别(7) 主要事由简述(8)
+    数据从 R2 开始
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=1):  # header_row=1 means data from row 2
+        c = pad(cols, 9)
+        stmts.append(
+            f"INSERT INTO ledger_reward_approval "
+            f"(approve_date,person_name,reward_type,approval_status,remark,"
+            f"import_batch,source_type,create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[2])},{esc(c[1])},{esc(c[3])},'待审批',{esc(c[8])},"
+            f"'{BATCH_NO}','1','{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_reward_penalty(ws):
+    """部门奖惩记录表 → ledger_reward_penalty
+    Excel R2: 姓名(0) 班组(1) 事由(2) 扣罚金额(3) 最后更新时间(4)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 5)
+        # 扣罚金额转为负数分值（仅金额，非分值，存为负数）
+        amt = to_decimal(c[3], 'NULL')
+        score_change = f"-{amt}" if amt != 'NULL' else 'NULL'
+        stmts.append(
+            f"INSERT INTO ledger_reward_penalty "
+            f"(record_date,person_name,team_name,type,event_desc,score_change,"
+            f"create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[4])},{esc(c[0])},{esc(c[1])},'2',{esc(c[2])},{score_change},"
+            f"'{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_leave_special(ws):
+    """请、休假记录表（特殊）→ ledger_leave_special
+    Excel R2: 姓名(0) 班组(1) 时间（起）(2) 时间（止）(3) 休假类别(4) 天数/时长(5)
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 6)
+        stmts.append(
+            f"INSERT INTO ledger_leave_special "
+            f"(person_name,team_name,leave_type,start_date,end_date,days,"
+            f"create_by,create_time,del_flag) VALUES ("
+            f"{esc(c[0])},{esc(c[1])},{esc(c[4])},{to_date(c[2])},{to_date(c[3])},{to_decimal(c[5],'NULL')},"
+            f"'{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+def sheet_banner_letter(ws):
+    """锦旗及感谢信 → ledger_banner_letter
+    Excel R2: 时间(0) 姓名(1) 获得感谢信的具体内容(2) 类别(3) 图片和附件(4) 班组(5) 队室内勤(6)
+    类别: 感谢信→'2', 锦旗→'1', 其他→'2'
+    """
+    stmts = []
+    for cols in iter_data_rows(ws, header_row=2):
+        c = pad(cols, 7)
+        typ = '1' if str(c[3] or '').strip() in ('锦旗',) else '2'
+        stmts.append(
+            f"INSERT INTO ledger_banner_letter "
+            f"(record_date,person_name,content_desc,type,evidence_file,team_name,remark,"
+            f"create_by,create_time,del_flag) VALUES ("
+            f"{to_date(c[0])},{esc(c[1])},{esc(c[2])},'{typ}',{esc(c[4])},{esc(c[5])},{esc(c[6])},"
+            f"'{CREATE_BY}','{CREATE_TIME}','0');"
+        )
+    return stmts
+
+
+# ──────────────────────────────────────────────
+# sheet name → handler mapping
+# ──────────────────────────────────────────────
+SHEET_MAP = {
+    '部门监察问题记录表':          ('ledger_supervision_problem',    sheet_supervision_problem),
+    '队室三级质控巡查记录表':       ('ledger_patrol_inspection',      sheet_patrol_inspection),
+    '部门实时质控拦截情况记录表':   ('ledger_realtime_interception',  sheet_realtime_interception),
+    '服务巡查':                    ('ledger_service_patrol',         sheet_service_patrol),
+    '投诉情况':                    ('ledger_complaint',              sheet_complaint),
+    '安保测试记录表（部门）':       ('ledger_security_test',          sheet_security_test),
+    '通道过检率':                  ('ledger_channel_pass_rate',      sheet_channel_pass_rate),
+    '不安全事件':                  ('ledger_unsafe_event',           sheet_unsafe_event),
+    '2026查获违规品统计':          ('ledger_seizure_stats',          sheet_seizure_stats),
+    '航站楼加分':                  ('ledger_terminal_bonus',         sheet_terminal_bonus),
+    '成绩收集':                    ('ledger_exam_score',             sheet_exam_score),
+    '小额奖励审批单-安检-质控':    ('ledger_reward_approval',        sheet_reward_approval),
+    '部门奖惩记录表':              ('ledger_reward_penalty',         sheet_reward_penalty),
+    '请、休假记录表（特殊）':      ('ledger_leave_special',          sheet_leave_special),
+    '锦旗及感谢信':               ('ledger_banner_letter',          sheet_banner_letter),
+}
+
+SKIP_SHEETS = {
+    '旅检三部人员信息表', '日常培训记录', '组长履职情况记录表',
+    '健康锐兵（2026_3）', '宿舍消防安全专项自查表（部门）', '培训台账问题通报',
+}
+
+# ──────────────────────────────────────────────
+# 主程序
+# ──────────────────────────────────────────────
+def main():
+    excel_path = find_excel()
+    print(f'读取文件: {excel_path}')
+
+    wb = openpyxl.load_workbook(excel_path, read_only=True, data_only=True)
+
+    lines = [
+        '-- =============================================',
+        f'-- 台账数据导入 SQL  批次: {BATCH_NO}',
+        f'-- 生成时间: {CREATE_TIME}',
+        f'-- 来源文件: {os.path.basename(excel_path)}',
+        '-- =============================================',
+        'SET NAMES utf8mb4;',
+        'SET FOREIGN_KEY_CHECKS=0;',
+        '',
+    ]
+
+    total = 0
+    for sheet_name in wb.sheetnames:
+        if sheet_name in SKIP_SHEETS:
+            print(f'  [跳过] {sheet_name}')
+            continue
+
+        if sheet_name not in SHEET_MAP:
+            print(f'  [未映射] {sheet_name}')
+            continue
+
+        table_name, handler = SHEET_MAP[sheet_name]
+        ws = wb[sheet_name]
+        try:
+            stmts = handler(ws)
+        except Exception as e:
+            print(f'  [ERROR] {sheet_name}: {e}')
+            import traceback; traceback.print_exc()
+            stmts = []
+
+        lines.append(f'-- ── {sheet_name} → {table_name} ({len(stmts)} 行) ──')
+        lines.extend(stmts)
+        lines.append('')
+        total += len(stmts)
+        print(f'  [OK] {sheet_name} → {table_name}: {len(stmts)} 条')
+
+    lines.append('SET FOREIGN_KEY_CHECKS=1;')
+    lines.append(f'-- 共生成 {total} 条 INSERT 语句')
+
+    wb.close()
+
+    with open(OUTPUT_SQL, 'w', encoding='utf-8') as f:
+        f.write('\n'.join(lines))
+
+    print(f'\n✅ 完成！共 {total} 条，已写入:\n   {OUTPUT_SQL}')
+    print(f'\n执行方式（在 MySQL 客户端中）:')
+    print(f'  USE chongqing;  -- 替换为你的库名')
+    print(f'  SOURCE {OUTPUT_SQL.replace(chr(92), "/")};')
+
+
+if __name__ == '__main__':
+    main()

sql/fix_sync_indicator_ids.sql

@@ -0,0 +1,24 @@
+-- ============================================================
+-- 同步数据修复脚本（2026-04-25）
+-- 背景：原同步服务使用 indicator_init.sql 的旧指标ID（1001+），
+--       与 score.sql 的新指标ID（11, 12, ...）不匹配，
+--       导致所有已同步 score_event 记录的 indicator_id 无效。
+--       同时，reward_penalty / leave_special / banner_letter
+--       按最新配分表属于"暂无台账，不考虑导入规则"，已从同步逻辑移除。
+-- ============================================================
+
+-- 步骤1：清空所有台账同步写入的 score_event（source_type='2'）
+-- 手动录入（source_type='1'）不受影响
+DELETE FROM score_event WHERE source_type = '2';
+
+-- 步骤2：确认当前 score_indicator 使用的是 score.sql 中的新ID（11, 12...）
+-- 如果 MAX(id) 约 1500，说明是新版；如果约 1343，说明还是旧版，需重建指标
+-- SELECT MAX(id), COUNT(*) FROM score_indicator WHERE del_flag='0';
+
+-- 步骤3（如果指标仍是旧版 1001+ ID，需要重建）：
+-- DELETE FROM score_indicator;
+-- 然后重新执行 score.sql 中三段 INSERT INTO score_indicator（ID 11~1522）
+
+-- 步骤4：部署新版后端代码后，在页面点击"同步台账"重新同步
+-- 或调用接口：POST /ledger/sync/all
+-- ============================================================

sql/indicator_init.sql

@@ -0,0 +1,267 @@
+-- =============================================
+-- 评分指标初始化脚本（128条，共6个维度）
+-- 依赖：score.sql 已执行（score_dimension 已有6条数据，建表已完成）
+-- 执行前确认：SELECT id, name FROM score_dimension ORDER BY sort_order;
+--
+-- ID 规则（与 score.sql 保持一致）：
+--   L2: 11~62   L3: 111~552   L4: 1211~1522
+--
+-- 暂无台账说明（来源：配分表分析.csv）：
+--   以下维度下的所有指标暂时标注，不参与同步计分规则：
+--   · 作风践行能力（全部）
+--   · 群团协作能力（全部）
+--   · 身心调节能力（全部）
+--   · 安全防控/服务响应下的"风险隐患"子项
+--   · 业务实操除"考试成绩"外的所有子项
+-- =============================================
+
+-- 使用变量存储维度ID，避免与AUTO_INCREMENT值绑定
+SET @dim1 = (SELECT id FROM score_dimension WHERE name = '安全防控能力' LIMIT 1);
+SET @dim2 = (SELECT id FROM score_dimension WHERE name = '服务响应能力' LIMIT 1);
+SET @dim3 = (SELECT id FROM score_dimension WHERE name = '业务实操能力' LIMIT 1);
+SET @dim4 = (SELECT id FROM score_dimension WHERE name = '作风践行能力' LIMIT 1);
+SET @dim5 = (SELECT id FROM score_dimension WHERE name = '群团协作能力' LIMIT 1);
+SET @dim6 = (SELECT id FROM score_dimension WHERE name = '身心调节能力' LIMIT 1);
+
+-- ============================================================
+-- 一、安全防控能力 L2（6条）
+-- ============================================================
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`cascade_rule`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+(11,@dim1,0,2,'员工规范化操作',  NULL,0,'返航/二次清舱-10、航班延误-8、旅客滞留-5、产生舆论-2、通报批评(站)-2、(公司)-3、(局方)-10、外部通报扭转-1',1,'0','【部门监察问题记录表】','admin',NOW()),
+(12,@dim1,0,2,'后台实时质控拦截',NULL,0,NULL,2,'0','【部门实时质控拦截情况记录表】','admin',NOW()),
+(13,@dim1,0,2,'不安全事件',      NULL,0,NULL,3,'0','【不安全事件】','admin',NOW()),
+(14,@dim1,0,2,'安保测试未通过',  NULL,0,NULL,4,'0','【安保测试记录表（部门）】是否通过=未通过','admin',NOW()),
+(15,@dim1,0,2,'典型案例查获',    NULL,0,'通报表扬(站)+1、(公司)+3、(局方)+5、讲评会点名表扬+0.5',5,'0','【小额奖励审批单-安检-质控】','admin',NOW()),
+(16,@dim1,0,2,'风险隐患',        NULL,0,NULL,6,'0','暂无台账，不考虑导入规则','admin',NOW());
+
+-- 安全防控能力 L3（13条）
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+-- 员工规范化操作 → 11
+(111,@dim1,11,3,'站层级质控',  '2',-1.00,1,'0','【部门监察问题记录表】问题层级=站层级','admin',NOW()),
+(112,@dim1,11,3,'部门层级质控','2',-0.80,2,'0','【部门监察问题记录表】问题层级=部门层级','admin',NOW()),
+(113,@dim1,11,3,'上级领导巡查','2',-1.20,3,'0','【部门监察问题记录表】问题层级=上级领导巡查','admin',NOW()),
+-- 后台实时质控拦截 → 12
+(121,@dim1,12,3,'站层级',  '2',-1.00,1,'0','【部门实时质控拦截记录表】问题层级=站层级','admin',NOW()),
+(122,@dim1,12,3,'部门层级','2',-0.80,2,'0','【部门实时质控拦截记录表】问题层级=部门层级','admin',NOW()),
+-- 不安全事件 → 13
+(131,@dim1,13,3,'一类','2',-10.00,1,'0','未经安检旅客进隔离区；爆炸装置；枪支弹药','admin',NOW()),
+(132,@dim1,13,3,'二类','2', -8.00,2,'0','枪支零部件；管制器具（管制刀具/警用催泪瓦斯/警用电击器等）','admin',NOW()),
+(133,@dim1,13,3,'三类','2', -5.00,3,'0','易燃液/固/气体；遇水自燃物；毒害品；腐蚀品；放射性物品','admin',NOW()),
+(134,@dim1,13,3,'四类','2', -3.00,4,'0','漏检错检乘机证件；弹壳；烟花爆竹（D类除外）','admin',NOW()),
+(135,@dim1,13,3,'五类','2', -2.00,5,'0','禁带锐器/钝器；D类烟花；火种；禁限锂电池等','admin',NOW()),
+-- 安保测试未通过 → 14（三层均为-0.5）
+(141,@dim1,14,3,'局方层级','2',-0.50,1,'0','is否通过=未通过，层级=局方层级','admin',NOW()),
+(142,@dim1,14,3,'公司层级','2',-0.50,2,'0','是否通过=未通过，层级=公司层级','admin',NOW()),
+(143,@dim1,14,3,'站层级',  '2',-0.50,3,'0','是否通过=未通过，层级=站层级','admin',NOW()),
+-- 典型案例查获 → 15
+(151,@dim1,15,3,'一类',    '1', 1.00,1,'0','【小额奖励审批单-安检-质控】查获物品类别=一类','admin',NOW()),
+(152,@dim1,15,3,'二类',    '1', 0.50,2,'0','【小额奖励审批单-安检-质控】查获物品类别=二类','admin',NOW()),
+(153,@dim1,15,3,'特殊查获','1', 0.15,3,'0','后台实时质控人员拦截数','admin',NOW()),
+-- 风险隐患（安全）→ 16（暂无台账）
+(161,@dim1,16,3,'发现安全隐患及时上报并进行处置',        '1',1.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(162,@dim1,16,3,'通过自愿报告系统上报安全建议并进行采纳','1',1.00,2,'0','暂无台账；经质控部研究采纳并奖励','admin',NOW()),
+(163,@dim1,16,3,'在部门层级内部上报安全建议',            '1',0.50,3,'0','暂无台账；经部门研究采纳并实施','admin',NOW());
+
+-- ============================================================
+-- 二、服务响应能力 L2（4条）
+-- ============================================================
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`cascade_rule`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+-- 旅客服务投诉：叶子节点（无L3，责任人不为空时计分）
+(21,@dim2,0,2,'旅客服务投诉','2',-2.00,'航班延误-10、旅客滞留-5、人员受伤-5、金额赔付-2、产生舆论-2、通报批评(站)-2、(公司)-3、(局方)-10、外部通报扭转-1',1,'0','【投诉情况】责任人不为空时计分；不对所属班组/队室计分','admin',NOW()),
+(22,@dim2,0,2,'服务监察',    NULL, 0.00,NULL,2,'0','【服务巡查】','admin',NOW()),
+(23,@dim2,0,2,'典型服务案例',NULL, 0.00,NULL,3,'0','【航站楼加分】','admin',NOW()),
+(24,@dim2,0,2,'风险隐患',    NULL, 0.00,NULL,4,'0','暂无台账，不考虑导入规则','admin',NOW());
+
+-- 服务响应能力 L3（8条）
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+-- 服务监察 → 22
+(221,@dim2,22,3,'航站楼及以上层级','2',-1.20,1,'0','【服务巡查】问题层级=航站楼及以上','admin',NOW()),
+(222,@dim2,22,3,'站层级',          '2',-1.00,2,'0','【服务巡查】问题层级=站层级','admin',NOW()),
+(223,@dim2,22,3,'部门层级',        '2',-0.80,3,'0','【服务巡查】问题层级=部门层级','admin',NOW()),
+-- 典型服务案例 → 23（分值取台账 add_score 字段）
+(231,@dim2,23,3,'航站楼加分',     '1',0.00,1,'0','【航站楼加分】分值以台账add_score字段为准；需上报航站楼确认','admin',NOW()),
+(232,@dim2,23,3,'讲评会点名表扬', '1',0.50,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 风险隐患（服务）→ 24（暂无台账）
+(241,@dim2,24,3,'发现服务隐患及时上报并进行处置',          '1',1.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(242,@dim2,24,3,'通过自愿报告系统上报服务建议并进行采纳',  '1',1.00,2,'0','暂无台账；经质控部研究采纳并奖励','admin',NOW()),
+(243,@dim2,24,3,'在部门层级内部上报服务建议经部门采纳',    '1',0.50,3,'0','暂无台账；经部门研究采纳并实施','admin',NOW());
+
+-- ============================================================
+-- 三、业务实操能力 L2（6条）
+-- ============================================================
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`cascade_rule`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+(31,@dim3,0,2,'站层级及以上考核',          NULL, 0.00,'补考阶梯递增：第1次-2，第2次-4，第3次-6，后续每次再+2',1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(32,@dim3,0,2,'队室及部门层级考核未通过',  '2', -1.00,NULL,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(33,@dim3,0,2,'技能保持未完成培训',        '2', -0.20,NULL,3,'0','暂无台账；每超1天扣0.2分','admin',NOW()),
+(34,@dim3,0,2,'岗位技能与实操能力不匹配',  NULL, 0.00,NULL,4,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(35,@dim3,0,2,'考试成绩',                  NULL, 0.00,NULL,5,'0','【考试成绩】','admin',NOW()),
+(36,@dim3,0,2,'导师带徒',                  NULL, 0.00,NULL,6,'0','暂无台账，不考虑导入规则','admin',NOW());
+
+-- 业务实操能力 L3（10条）
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`cascade_rule`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+-- 站层级及以上考核 → 31（暂无台账）
+(311,@dim3,31,3,'季度理论考试补考','2',-2.00,'阶梯递增：第1次-2，第2次-4，第3次-6，每次递增2分',1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 岗位技能与实操能力不匹配 → 34（暂无台账）
+(341,@dim3,34,3,'拿取中级证书满3年未放开机人员', '2',-0.50,NULL,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(342,@dim3,34,3,'返岗员工未在规定时间内放单号位','2',-0.50,NULL,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(343,@dim3,34,3,'新员工未在规定时间内放单号位',  '2',-0.50,NULL,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 考试成绩 → 35（有数据，同步计分）
+(351,@dim3,35,3,'季度理论考试',      '1',5.00,NULL,1,'0','【考试成绩】理论成绩≥98分加5分','admin',NOW()),
+(352,@dim3,35,3,'季度开机员能力考核','1',5.00,NULL,2,'0','【考试成绩】图像成绩≥98分加5分','admin',NOW()),
+-- 导师带徒 → 36（暂无台账）
+(361,@dim3,36,3,'初级核心岗位（验证、人身）未通过','2',-0.20,NULL,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(362,@dim3,36,3,'初级核心岗位（验证、人身）通过',  '1', 1.00,NULL,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(363,@dim3,36,3,'中级开机岗位未通过',             '2',-0.20,NULL,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(364,@dim3,36,3,'中级开机岗位通过',               '1', 5.00,NULL,4,'0','暂无台账，不考虑导入规则','admin',NOW());
+
+-- ============================================================
+-- 四、作风践行能力 L2（7条，全部暂无台账）
+-- ============================================================
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+(41,@dim4,0,2,'诚信记录',    '2',-10.00,1,'0','暂无台账，不考虑导入规则；徇私舞弊/考试作弊被通报','admin',NOW()),
+(42,@dim4,0,2,'信息报送真实度','2',-2.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(43,@dim4,0,2,'出勤情况',    NULL, 0.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(44,@dim4,0,2,'形象维护',    NULL, 0.00,4,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(45,@dim4,0,2,'勤务执行力',  '2', -2.00,5,'0','暂无台账；接到通道开放通知10分钟内未到达','admin',NOW()),
+(46,@dim4,0,2,'全勤',        '1',  5.00,6,'0','暂无台账；一季度内无迟到/早退/请假（含病假）','admin',NOW()),
+(47,@dim4,0,2,'志愿者服务',  '1',  0.50,7,'0','暂无台账；参与安检站/航站楼等志愿者服务','admin',NOW());
+
+-- 作风践行能力 L3（11条，全部暂无台账）
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+-- 出勤情况 → 43
+(431,@dim4,43,3,'迟到、早退','2', -1.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(432,@dim4,43,3,'中途离岗',  '2', -5.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(433,@dim4,43,3,'旷工',      '2',-10.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 形象维护 → 44
+(441,@dim4,44,3,'私拿旅客物品','2', -2.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(442,@dim4,44,3,'占用公司财务','2', -5.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(443,@dim4,44,3,'着制服外出',  '2', -1.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(444,@dim4,44,3,'纪委监察',    '2', -2.00,4,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(445,@dim4,44,3,'打架斗殴',    '2',-10.00,5,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(446,@dim4,44,3,'站内审批',    '1',  2.00,6,'0','暂无台账；旅客无理取闹正确处置，经部门申报站内审批认定','admin',NOW()),
+(447,@dim4,44,3,'部门审批',    '1',  0.50,7,'0','暂无台账；经部门研究讨论认定','admin',NOW());
+
+-- ============================================================
+-- 五、群团协作能力 L2（5条，全部暂无台账）
+-- ============================================================
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+(51,@dim5,0,2,'活动参与度',  NULL,0.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(52,@dim5,0,2,'团队荣誉',    NULL,0.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(53,@dim5,0,2,'个人荣誉',    NULL,0.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(54,@dim5,0,2,'新闻',        NULL,0.00,4,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(55,@dim5,0,2,'自主活动筹备',NULL,0.00,5,'0','暂无台账，不考虑导入规则','admin',NOW());
+
+-- 群团协作能力 L3（14条，全部暂无台账）
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+-- 活动参与度 → 51
+(511,@dim5,51,3,'部门层级',    '1',0.50,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(512,@dim5,51,3,'站层级',      '1',1.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(513,@dim5,51,3,'站层级及以上','1',2.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 团队荣誉 → 52（L4展开在下方）
+(521,@dim5,52,3,'部门层级',    NULL,0.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(522,@dim5,52,3,'站层级',      NULL,0.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(523,@dim5,52,3,'站层级及以上',NULL,0.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 个人荣誉 → 53（L4展开在下方）
+(531,@dim5,53,3,'部门层级',    NULL,0.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(532,@dim5,53,3,'站层级',      NULL,0.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(533,@dim5,53,3,'站层级及以上',NULL,0.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 新闻 → 54（L4展开在下方）
+(541,@dim5,54,3,'站层级（CQ安小检）',        NULL,0.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(542,@dim5,54,3,'公司层级（重庆飞/OA集团）', NULL,0.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(543,@dim5,54,3,'局方层级',                  NULL,0.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 自主活动筹备 → 55（L4展开在下方）
+(551,@dim5,55,3,'部门层级',NULL,0.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(552,@dim5,55,3,'站层级',  NULL,0.00,2,'0','暂无台账，不考虑导入规则','admin',NOW());
+
+-- 群团协作能力 L4（37条，全部暂无台账）
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+-- 团队荣誉 - 部门层级 → 521
+(1211,@dim5,521,4,'一等奖','1', 3.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1212,@dim5,521,4,'二等奖','1', 2.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1213,@dim5,521,4,'三等奖','1', 1.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 团队荣誉 - 站层级 → 522
+(1221,@dim5,522,4,'一等奖','1', 5.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1222,@dim5,522,4,'二等奖','1', 4.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1223,@dim5,522,4,'三等奖','1', 3.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 团队荣誉 - 站层级及以上 → 523
+(1231,@dim5,523,4,'一等奖','1', 7.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1232,@dim5,523,4,'二等奖','1', 6.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1233,@dim5,523,4,'三等奖','1', 5.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 个人荣誉 - 部门层级 → 531
+(1311,@dim5,531,4,'一等奖','1', 4.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1312,@dim5,531,4,'二等奖','1', 3.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1313,@dim5,531,4,'三等奖','1', 2.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 个人荣誉 - 站层级 → 532
+(1321,@dim5,532,4,'一等奖','1', 6.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1322,@dim5,532,4,'二等奖','1', 5.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1323,@dim5,532,4,'三等奖','1', 4.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 个人荣誉 - 站层级及以上 → 533
+(1331,@dim5,533,4,'一等奖','1', 8.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1332,@dim5,533,4,'二等奖','1', 7.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1333,@dim5,533,4,'三等奖','1', 6.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 新闻 - 站层级（CQ安小检）→ 541
+(1411,@dim5,541,4,'新闻发表',      '1',1.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1412,@dim5,541,4,'诗歌绘画微镜头','1',0.50,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1413,@dim5,541,4,'视频脚本编辑',  '1',1.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1414,@dim5,541,4,'视频摄影制作',  '1',1.00,4,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1415,@dim5,541,4,'视频员工参演',  '1',0.50,5,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 新闻 - 公司层级 → 542
+(1421,@dim5,542,4,'新闻发表',      '1',1.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1422,@dim5,542,4,'诗歌绘画微镜头','1',1.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1423,@dim5,542,4,'视频脚本编辑',  '1',1.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1424,@dim5,542,4,'视频幕后制作',  '1',1.00,4,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1425,@dim5,542,4,'视频员工参演',  '1',1.00,5,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 新闻 - 局方层级 → 543
+(1431,@dim5,543,4,'新闻发表',      '1',1.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1432,@dim5,543,4,'诗歌绘画微镜头','1',1.00,2,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1433,@dim5,543,4,'视频脚本编辑',  '1',1.00,3,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1434,@dim5,543,4,'视频幕后制作',  '1',1.00,4,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1435,@dim5,543,4,'视频员工参演',  '1',1.00,5,'0','暂无台账，不考虑导入规则','admin',NOW()),
+-- 自主活动筹备 - 部门层级 → 551
+(1511,@dim5,551,4,'活动策划筹备','1',3.00,1,'0','暂无台账；负责策划方向/后勤采购/设备调试/现场协调','admin',NOW()),
+(1512,@dim5,551,4,'活动辅助推进','1',1.00,2,'0','暂无台账；主持/摄影/幕后人员','admin',NOW()),
+-- 自主活动筹备 - 站层级 → 552
+(1521,@dim5,552,4,'活动策划筹备','1',6.00,1,'0','暂无台账，不考虑导入规则','admin',NOW()),
+(1522,@dim5,552,4,'活动辅助推进','1',3.00,2,'0','暂无台账，不考虑导入规则','admin',NOW());
+
+-- ============================================================
+-- 六、身心调节能力 L2（2条，全部暂无台账）
+-- ============================================================
+INSERT INTO `score_indicator`
+  (`id`,`dimension_id`,`parent_id`,`level`,`name`,`type`,`score_value`,`sort_order`,`status`,`remark`,`create_by`,`create_time`)
+VALUES
+(61,@dim6,0,2,'病假',    NULL,0.00,1,'0','暂无台账，不考虑导入规则；具体规则待定','admin',NOW()),
+(62,@dim6,0,2,'活动打卡',NULL,0.00,2,'0','暂无台账，不考虑导入规则；休息日运动打卡+0.5','admin',NOW());
+
+-- ============================================================
+-- 验证
+-- ============================================================
+-- SELECT d.name AS 维度, COUNT(i.id) AS 指标总数
+-- FROM score_dimension d
+-- LEFT JOIN score_indicator i ON i.dimension_id = d.id AND i.del_flag='0'
+-- GROUP BY d.id, d.name ORDER BY d.sort_order;
+-- 预期总数：128条
+--
+-- SELECT COUNT(*) AS 总指标数 FROM score_indicator WHERE del_flag='0';

sql/score.sql

@@ -121,12 +121,15 @@ INSERT INTO `score_dimension` (`name`, `weight`, `base_score`, `sort_order`, `st
 
 -- ═══════════════════════════════════════════
 -- 3. 指标体系（128条）
+--    ⚠️  推荐使用 indicator_init.sql 代替此段：
+--       indicator_init.sql 使用 @dim 变量动态查询维度ID，
+--       不依赖 AUTO_INCREMENT 顺序，更安全可靠。
+--
+--    此处 dimension_id 假设按插入顺序为 1~6：
 --      1=安全防控  2=服务响应  3=业务实操
 --      4=作风践行  5=群团协作  6=身心调节
 --    type: '1'=加分  '2'=扣分  NULL=分类节点
 --    score_value: 正=加分 负=扣分 0=分类节点/待定
 -- ═══════════════════════════════════════════
 
 -- ── Level 2（二级指标，parent_id=0，共30条）──────────────────

sql/sys_dept.sql

@@ -0,0 +1,80 @@
+/*
+ Navicat Premium Data Transfer
+
+ Source Server         : localhost_3306
+ Source Server Type    : MySQL
+ Source Server Version : 80045
+ Source Host           : localhost:3306
+ Source Schema         : chongqing-test
+
+ Target Server Type    : MySQL
+ Target Server Version : 80045
+ File Encoding         : 65001
+
+ Date: 24/04/2026 15:37:53
+*/
+
+SET NAMES utf8mb4;
+SET FOREIGN_KEY_CHECKS = 0;
+
+-- ----------------------------
+-- Table structure for sys_dept
+-- ----------------------------
+DROP TABLE IF EXISTS `sys_dept`;
+CREATE TABLE `sys_dept`  (
+  `dept_id` bigint(0) NOT NULL AUTO_INCREMENT COMMENT '部门id',
+  `parent_id` bigint(0) NULL DEFAULT 0 COMMENT '父部门id',
+  `ancestors` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '祖级列表',
+  `dept_name` varchar(30) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '部门名称',
+  `order_num` int(0) NULL DEFAULT 0 COMMENT '显示顺序',
+  `leader` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '负责人',
+  `phone` varchar(11) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '联系电话',
+  `email` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '邮箱',
+  `status` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '0' COMMENT '部门状态（0正常 1停用）',
+  `del_flag` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '0' COMMENT '删除标志（0代表存在 2代表删除）',
+  `create_by` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '创建者',
+  `create_time` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
+  `update_by` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '更新者',
+  `update_time` datetime(0) NULL DEFAULT NULL COMMENT '更新时间',
+  `dept_type` varchar(32) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT 'STATION' COMMENT '部门类型',
+  `dept_type_desc` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '机构站' COMMENT '部门类型名称',
+  PRIMARY KEY (`dept_id`) USING BTREE,
+  INDEX `idx_sys_dept_parent_id`(`parent_id`) USING BTREE
+) ENGINE = InnoDB AUTO_INCREMENT = 131 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '部门表' ROW_FORMAT = Dynamic;
+
+-- ----------------------------
+-- Records of sys_dept
+-- ----------------------------
+INSERT INTO `sys_dept` VALUES (100, 0, '0', '安检站', 1, '', '', '', '0', '0', 'admin', '2025-07-07 16:07:22', 'admin', '2025-11-28 16:00:40', 'STATION', '机构站');
+INSERT INTO `sys_dept` VALUES (101, 100, '0,100', '旅检一部', 0, NULL, NULL, NULL, '0', '0', 'admin', '2026-04-22 12:34:06', '', NULL, 'BRIGADE', '机构站');
+INSERT INTO `sys_dept` VALUES (102, 100, '0,100', '旅检二部', 1, NULL, NULL, NULL, '0', '0', 'admin', '2026-04-22 12:34:31', 'admin', '2026-04-22 12:34:39', 'BRIGADE', '机构站');
+INSERT INTO `sys_dept` VALUES (103, 100, '0,100', '旅检三部', 2, NULL, NULL, NULL, '0', '0', 'admin', '2026-04-22 12:34:55', '', NULL, 'BRIGADE', '机构站');
+INSERT INTO `sys_dept` VALUES (104, 103, '0,100,103', '安平班组', 0, '项锐', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:35:56', 'admin', '2026-04-22 12:49:15', 'MANAGER', '机构站');
+INSERT INTO `sys_dept` VALUES (105, 103, '0,100,103', '屹动班组', 1, '李健', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:36:57', 'admin', '2026-04-22 12:48:49', 'MANAGER', '机构站');
+INSERT INTO `sys_dept` VALUES (106, 103, '0,100,103', '芮盾班组', 2, '刘怡春', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:37:25', 'admin', '2026-04-22 12:37:33', 'MANAGER', '机构站');
+INSERT INTO `sys_dept` VALUES (107, 103, '0,100,103', '拓新班组', 3, '杨小瑜', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:38:01', '', NULL, 'MANAGER', '机构站');
+INSERT INTO `sys_dept` VALUES (108, 103, '0,100,103', '安行班组', 4, '赵金鹏', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:41:57', 'admin', '2026-04-22 12:54:23', 'MANAGER', '机构站');
+INSERT INTO `sys_dept` VALUES (109, 103, '0,100,103', '木兰班组', 5, '陈殷红', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:42:27', '', NULL, 'MANAGER', '机构站');
+INSERT INTO `sys_dept` VALUES (110, 104, '0,100,103,104', '陈行小组', 0, '陈行', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:43:12', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (111, 104, '0,100,103,104', '杨龙小组', 1, '杨龙', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:43:32', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (112, 104, '0,100,103,104', '王岚玉小组', 2, '王岚玉', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:49:55', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (113, 105, '0,100,103,105', '凌静小组', 0, '凌静', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:50:34', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (114, 105, '0,100,103,105', '张长圣小组', 1, '张长圣', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:50:54', 'admin', '2026-04-22 12:51:22', 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (115, 105, '0,100,103,105', '代航小组', 2, '代航', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:51:15', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (116, 106, '0,100,103,106', '卢兴旭小组', 0, '卢兴旭', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:51:41', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (117, 106, '0,100,103,106', '张露小组', 1, '张露', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:52:06', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (118, 106, '0,100,103,106', '刘婷婷小组', 2, '刘婷婷', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:52:25', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (119, 107, '0,100,103,107', '贾剑雄小组', 0, '贾剑雄', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:52:53', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (120, 107, '0,100,103,107', '聂倩小组', 1, '聂倩', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:53:08', 'admin', '2026-04-22 12:53:38', 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (121, 107, '0,100,103,107', '肖灿小组', 2, '肖灿', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:53:32', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (122, 108, '0,100,103,108', '周游波小组', 0, '周游波', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:54:12', 'admin', '2026-04-22 12:54:36', 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (123, 108, '0,100,103,108', '刘欢欢小组', 1, '刘欢欢', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:54:54', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (124, 108, '0,100,103,108', '史飞小组', 2, '史飞', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:55:17', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (125, 109, '0,100,103,109', '赵俊秀小组', 0, '赵俊秀', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:55:39', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (126, 109, '0,100,103,109', '李学伟小组', 1, '李学伟', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:55:59', 'admin', '2026-04-22 15:26:01', 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (127, 109, '0,100,103,109', '罗园园小组', 2, '罗园园', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:56:25', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (128, 109, '0,100,103,109', '尹一澄小组', 3, '尹一澄', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:56:43', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (129, 109, '0,100,103,109', '李川小组', 4, '李川', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:57:00', '', NULL, 'TEAMS', '机构站');
+INSERT INTO `sys_dept` VALUES (130, 109, '0,100,103,109', '罗方程雪小组', 5, '罗方程雪', NULL, NULL, '0', '0', 'admin', '2026-04-22 12:57:20', '', NULL, 'TEAMS', '机构站');
+
+SET FOREIGN_KEY_CHECKS = 1;

sql/sys_user.sql

@@ -0,0 +1,88 @@
+/*
+ Navicat Premium Data Transfer
+
+ Source Server         : localhost_3306
+ Source Server Type    : MySQL
+ Source Server Version : 80045
+ Source Host           : localhost:3306
+ Source Schema         : chongqing-test
+
+ Target Server Type    : MySQL
+ Target Server Version : 80045
+ File Encoding         : 65001
+
+ Date: 25/04/2026 12:31:26
+*/
+
+SET NAMES utf8mb4;
+SET FOREIGN_KEY_CHECKS = 0;
+
+-- ----------------------------
+-- Table structure for sys_user
+-- ----------------------------
+DROP TABLE IF EXISTS `sys_user`;
+CREATE TABLE `sys_user`  (
+  `user_id` bigint(0) NOT NULL AUTO_INCREMENT COMMENT '用户ID',
+  `dept_id` bigint(0) NOT NULL COMMENT '部门ID',
+  `user_name` varchar(30) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '用户账号',
+  `nick_name` varchar(30) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '用户昵称',
+  `user_type` varchar(2) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '00' COMMENT '用户类型（00系统用户）',
+  `email` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '用户邮箱',
+  `phonenumber` varchar(11) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '手机号码',
+  `sex` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '0' COMMENT '用户性别（0男 1女 2未知）',
+  `avatar` varchar(250) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '头像地址',
+  `password` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '密码',
+  `status` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '0' COMMENT '账号状态（0正常 1停用）',
+  `del_flag` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '0' COMMENT '删除标志（0代表存在 2代表删除）',
+  `login_ip` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '最后登录IP',
+  `login_date` datetime(0) NULL DEFAULT NULL COMMENT '最后登录时间',
+  `pwd_update_date` datetime(0) NULL DEFAULT NULL COMMENT '密码最后更新时间',
+  `create_by` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '创建者',
+  `create_time` datetime(0) NULL DEFAULT NULL COMMENT '创建时间',
+  `update_by` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '' COMMENT '更新者',
+  `update_time` datetime(0) NULL DEFAULT NULL COMMENT '更新时间',
+  `remark` varchar(500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '备注',
+  `card_number` varchar(18) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '身份证号',
+  `political_status` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '政治面貌',
+  `training_compliance_status` char(1) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT '0' COMMENT '培训合规状态（0=合规；1=不合规）',
+  `qualification_level` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '资质等级',
+  `administrative_status` varchar(500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '行政情况（含处罚记录）',
+  `physical_health_status` varchar(500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '身体健康情况',
+  `emergency_contact_name` varchar(30) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '紧急联系人姓名',
+  `emergency_contact_phone` varchar(11) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '紧急联系人电话',
+  `emergency_contact_relationship` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '紧急联系人关系',
+  `zodiac` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '生肖',
+  `constellation` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '星座',
+  `blood_group` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '血型',
+  `character_characteristics` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '性格特征',
+  `working_style` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '工作风格',
+  `team_cooperation` varchar(128) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '团队配合',
+  `self_assessment_personality_trait` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '自我评价-性格特质',
+  `self_assessment_capability_performance` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '自我评价-能力表现',
+  `self_assessment_interpersonal_interaction` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '自我评价-人际互动',
+  `self_assessment_growth_potential` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '自我评价-成长潜力',
+  `colleague_comments_personality_trait` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '同事评价-性格特质',
+  `colleague_comments_capability_performance` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '同事评价-能力表现',
+  `colleague_comments_interpersonal_interaction` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '同事评价-人际互动',
+  `colleague_comments_growth_potential` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '同事评价-成长潜力',
+  `superior_evaluation_personality_trait` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '上级评价-性格特质',
+  `superior_evaluation_capability_performance` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '上级评价-能力表现',
+  `superior_evaluation_interpersonal_interaction` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '上级评价-人际互动',
+  `superior_evaluation_growth_potential` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '上级评价-成长潜力',
+  `subordinate_evaluation_personality_trait` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '下级评价-性格特质',
+  `subordinate_evaluation_capability_performance` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '下级评价-能力表现',
+  `subordinate_evaluation_interpersonal_interaction` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '下级评价-人际互动',
+  `subordinate_evaluation_growth_potential` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '下级评价-成长潜力',
+  `schooling` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '学历（硕士、本科、专科、技校）',
+  `political_review_situation` varchar(500) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '政审情况',
+  `start_working_date` date NULL DEFAULT NULL COMMENT '开始工作时间',
+  `security_check_start_date` date NULL DEFAULT NULL COMMENT '安检开始时间',
+  `security_inspection_position` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '安检工作岗位',
+  `work_rewards_number` int(0) NULL DEFAULT NULL COMMENT '工作奖励次数',
+  `work_penalties_number` int(0) NULL DEFAULT NULL COMMENT '工作处罚次数',
+  `security_work_position` varchar(20) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '曾在安检工作中担任过的最高职务（安检员、班组长）',
+  PRIMARY KEY (`user_id`) USING BTREE,
+  INDEX `idx_sys_user_dept_id`(`dept_id`) USING BTREE
+) ENGINE = InnoDB AUTO_INCREMENT = 320 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_general_ci COMMENT = '用户信息表' ROW_FORMAT = Dynamic;
+
+SET FOREIGN_KEY_CHECKS = 1;

sql/truncate_ledger.sql

@@ -0,0 +1,32 @@
+-- ============================================================
+-- 清理台账导入原始数据
+-- 场景：重新全量导入前清空所有台账表和同步数据
+-- 注意：只清空数据，不删除表结构
+-- ============================================================
+
+SET FOREIGN_KEY_CHECKS = 0;
+
+-- 台账原始数据（15张表）
+TRUNCATE TABLE `ledger_supervision_problem`;     -- 部门监察问题记录
+TRUNCATE TABLE `ledger_patrol_inspection`;        -- 队室三级质控巡查记录
+TRUNCATE TABLE `ledger_realtime_interception`;    -- 部门实时质控拦截记录
+TRUNCATE TABLE `ledger_service_patrol`;           -- 服务巡查记录
+TRUNCATE TABLE `ledger_complaint`;                -- 投诉情况
+TRUNCATE TABLE `ledger_security_test`;            -- 安保测试记录（部门）
+TRUNCATE TABLE `ledger_channel_pass_rate`;        -- 通道过检率
+TRUNCATE TABLE `ledger_unsafe_event`;             -- 不安全事件
+TRUNCATE TABLE `ledger_seizure_stats`;            -- 查获违规品统计
+TRUNCATE TABLE `ledger_terminal_bonus`;           -- 航站楼加分
+TRUNCATE TABLE `ledger_exam_score`;               -- 成绩收集
+TRUNCATE TABLE `ledger_reward_approval`;          -- 小额奖励审批单
+TRUNCATE TABLE `ledger_reward_penalty`;           -- 部门奖惩记录
+TRUNCATE TABLE `ledger_leave_special`;            -- 请休假记录（特殊）
+TRUNCATE TABLE `ledger_banner_letter`;            -- 锦旗及感谢信
+
+-- 台账导入日志
+TRUNCATE TABLE `ledger_import_log`;
+
+-- 台账同步写入的配分事项（source_type='2'），手动录入（='1'）不受影响
+DELETE FROM `score_event` WHERE `source_type` = '2';
+
+SET FOREIGN_KEY_CHECKS = 1;