feat: 汇总大表数据驱动 M1-城市客运——新增 PaxCalc 计算服务（公交/出租/轨道轮渡）与 7 月回归测试报告

zhizhijie

2026-09-08 d35a0a281f75dadb81029672442815fc8bc71d30

feat: 汇总大表数据驱动 M1-城市客运——新增 PaxCalc 计算服务（公交/出租/轨道轮渡）与 7 月回归测试报告

 docs/¹¦ÄܲâÊÔ±¨¸æ/¹¦ÄܲâÊÔ±¨¸æ_M1-³ÇÊпÍÔË-¹«½»³ö×â¹ìµÀÂÖ¶É_2026-09-08.md

New file
@@ -0,0 +1,35 @@
# åŠŸèƒ½æµ‹è¯•æŠ¥å‘Šï¼šM1-城市客运 å…¬äº¤/出租/轨道轮渡 å–数核对与 7 æœˆå›žå½’（2026-09-08）

## ä¸€ã€åŠŸèƒ½è¯´æ˜Ž
M1 ç¬¬äºŒå—：新增城市客运计算服务 `PaxCalc`（`traffic-audit-server/.../reportexport/calc/PaxCalc.java`），对 å…¬äº¤/巡游出租/轨道/轮渡 æä¾›â€œæœˆ â†’ å¸‚å·ž â†’ [客运量,周转量,城市内客运量,城市内周转量]（轨道轮渡=轨道客运量,轨道周转量,轮渡客运量,轮渡周转量）”矩阵，与既有 exportCityBusDetail / exportCityTaxiDetail / exportCityRailFerryDetail çš„取数逻辑同构，供汇总大表与小表共用。

## äºŒã€æµ‹è¯•çŽ¯å¢ƒ
- åº“：`traffic_audit`（127.0.0.1:3308），数据 = 2026-07 çŽ°çŠ¶ï¼›
- å¯¹è´¦æ¯ç‰ˆï¼š`docs/生成汇总大表/_备份_2026å¹´7月道路运输量汇总表_清理前_20260904.xlsx`（含 5-7 æœˆæ•°æ®çš„已修正母版；`2026å¹´7月道路运输量汇总表.xlsx` ä¸º 1-4 æœˆç©ºéª¨æž¶ï¼Œä¸å« 7 æœˆå°è´¦åˆ—）；
- å·¥å…·ï¼šmysql CLI + Python é‡ç®— vs æ¯ç‰ˆ O åˆ—（2026-07）；后端 `mvn -q -DskipTests compile` é€šè¿‡ã€‚

## ä¸‰ã€å–数口径（与既有导出一致）
| å°è´¦é¡µ | æ¥æº | è¡Œç»“构（O åˆ— 2026-07） |
|---|---|---|
| å…¬äº¤ | `city_bus_monthly` æŒ‰ city æ±‡æ€» [passenger_volume,turnover,passenger_city,turnover_city] | å…¨çœ r5-8；市州 r(9+4i)..r(12+4i)（客运量/周转量/城市内客运量/城市内周转量） |
| å‡ºç§Ÿ | `city_taxi_monthly` åŒå­—段 | åŒ å…¬äº¤ |
| è½¨é“、轮渡 | `city_bus_monthly` çš„ rail_*/ferry_*（轨道=武汉/黄石，轮渡=武汉） | è½¨é“ r6/7=武汉、r8/9=黄石；轮渡 r15/16=武汉；全省=合计公式 |
| å…¨çœ | 17 å¸‚州之和（含跨区县多行累加） | æ¯ç‰ˆå…¨çœè¡Œå…¬å¼ |

## å››ã€ç”¨ä¾‹è¡¨
| # | ç”¨ä¾‹ | è¾“å…¥ | é¢„期 | å®žé™… | ç»“论 |
|---|---|---|---|---|---|
| 1 | å…¬äº¤å°è´¦é¡µ 2026-07 | DB 2026-07 æŒ‰ city æ±‡æ€» | ä¸Žæ¯ç‰ˆ O åˆ— 18 è¡Œå—（全省+17 å¸‚州×4 æŒ‡æ ‡ï¼‰ä¸€è‡´ | diff=0 | é€šè¿‡ |
| 2 | å‡ºç§Ÿå°è´¦é¡µ 2026-07 | DB 2026-07 æŒ‰ city æ±‡æ€» | åŒä¸Š | diff=0 | é€šè¿‡ |
| 3 | è½¨é“台账页 2026-07 | city_bus rail å­—段（武汉/黄石） | æ­¦æ±‰ 11701.74/96240.86、黄石 30.09/404.37、全省 11731.83 | ä¸€è‡´ï¼ˆ0 diff） | é€šè¿‡ |
| 4 | è½®æ¸¡å°è´¦é¡µ 2026-07 | city_bus ferry å­—段（武汉） | å…¨çœ=武汉=46.05（客运量） | ä¸€è‡´ï¼ˆ0 diff） | é€šè¿‡ |
| 5 | Java ç¼–译 | `mvn -q -DskipTests compile` | æ— é”™è¯¯ | exit=0 | é€šè¿‡ |

## äº”、发现的问题与处置
1. æ³¨é‡Šå†…出现 `rail_*/ferry_*`，其中 `*/` æå‰ç»ˆæ­¢ Javadoc å—注释导致编译失败 â†’ æ”¹ä¸ºâ€œrail ä¸Ž ferry å­—段”，编译通过（本问题仅影响注释写法，与口径无关）。
2. å¯¹è´¦æ¯ç‰ˆé€‰æ‹©ï¼š`2026å¹´7月…汇总表.xlsx` æ˜¯ 1-4 æœˆç©ºéª¨æž¶ï¼ˆå°è´¦é¡µæ—  5-7 æœˆåˆ—），7 æœˆå°è´¦æ•°å€¼é¡»ä»¥ `_备份_…_清理前_20260904.xlsx` ä¸ºåŸºçº¿â€”—已在测试环境注明，M2 å›žå½’时统一用该备份文件。
3. æ•°æ®ä¾§å£å¾„复核（无需改动）：市州存在多个区县代码行，须按 city æ±‡æ€»ç´¯åŠ ï¼ˆä¸Ž Java æ—¢æœ‰å®žçŽ°ä¸€è‡´ï¼‰ã€‚

## å…­ã€ç»“论与下一步
- ç»“论：公交/出租/轨道/轮渡 7 æœˆå°è´¦å¯ä»Žåº“完整复算（0 å·®å¼‚），`PaxCalc` å·²å…¥åº“并通过编译。
- ä¸‹ä¸€æ­¥ï¼šM1-网约车（WyCSplitCalc：订单×全省 pin×巡游出租拆分）→ åŸŽå¸‚客运台账/城市汇总/城市分市州 7 æœˆå›žå½’ â†’ M1-MidCalc â†’ M2 SummaryFiller å†™å›žä¸Žé€æ ¼ diff。

 traffic-audit-server/src/main/java/com/trafficaudit/reportexport/calc/PaxCalc.java

New file
@@ -0,0 +1,112 @@
package com.trafficaudit.reportexport.calc;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.trafficaudit.dataimport.entity.CityBusMonthly;
import com.trafficaudit.dataimport.entity.CityTaxiMonthly;
import com.trafficaudit.dataimport.mapper.CityBusMonthlyMapper;
import com.trafficaudit.dataimport.mapper.CityTaxiMonthlyMapper;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/**
 * åŸŽå¸‚客运口径计算服务（汇总大表数据驱动改造 M1-城市客运-公交/出租/轨道轮渡，2026-09-08）。
 *
 * å£å¾„与既有多表导出 loadCityBusByMonth / loadCityTaxiByMonth / loadCityRailFerryByMonth å®Œå…¨ä¸€è‡´
 * ï¼ˆå†³ç­–基线 A2/B4/B5/C7；2026-07 ä¸Ž _备份…_清理前_20260904.xlsx å…¬äº¤/出租/轨道轮渡台账页 O åˆ—回归 0 å·®å¼‚）：
 * - å…¬äº¤/出租：按月 â†’ å¸‚å·ž â†’ [客运量, æ—…客周转量, åŸŽå¸‚内客运量, åŸŽå¸‚内旅客周转量]，按 DB city å­—段分组，"全省"=全部市州合计；
 * - è½¨é“/轮渡：同一 city_bus_monthly è¡¨çš„ rail / ferry å­—段（轨道=武汉/黄石，轮渡=武汉；全省=合计）。
 *
 * è¾“出为“月 â†’ å¸‚å·ž â†’ double[4]”；累计由写回层对 1..m æœˆæ±‚和。同比按 Q1 ä»¥æ¯ç‰ˆç¼“å­˜ 2025 å‚照组为基准，不在本服务计算。
 */
@Service
public class PaxCalc {

    public static final String PROVINCE = "全省";

    @Resource
    private CityBusMonthlyMapper cityBusMapper;
    @Resource
    private CityTaxiMonthlyMapper cityTaxiMapper;

    /** å…¬äº¤ï¼šæœˆ â†’ å¸‚å·ž â†’ [客运量,周转量,城市内客运量,城市内周转量] */
    public Map<Integer, Map<String, double[]>> busMonthly(String yearPrefix, int limit) {
        Map<Integer, Map<String, double[]>> result = new LinkedHashMap<>();
        List<CityBusMonthly> rows = cityBusMapper.selectList(
            new LambdaQueryWrapper<CityBusMonthly>().likeRight(CityBusMonthly::getReportPeriod, yearPrefix));
        for (CityBusMonthly r : rows) {
            int m = monthOf(r.getReportPeriod());
            if (m < 1 || m > limit) continue;
            String city = r.getCity() == null ? "未知" : r.getCity();
            accumulate(result, city, m,
                nz(r.getPassengerVolume()), nz(r.getTurnover()),
                nz(r.getPassengerCity()), nz(r.getTurnoverCity()));
        }
        return result;
    }

    /** å·¡æ¸¸å‡ºç§Ÿï¼šæœˆ â†’ å¸‚å·ž â†’ [客运量,周转量,城市内客运量,城市内周转量] */
    public Map<Integer, Map<String, double[]>> taxiMonthly(String yearPrefix, int limit) {
        Map<Integer, Map<String, double[]>> result = new LinkedHashMap<>();
        List<CityTaxiMonthly> rows = cityTaxiMapper.selectList(
            new LambdaQueryWrapper<CityTaxiMonthly>().likeRight(CityTaxiMonthly::getReportPeriod, yearPrefix));
        for (CityTaxiMonthly r : rows) {
            int m = monthOf(r.getReportPeriod());
            if (m < 1 || m > limit) continue;
            String city = r.getCity() == null ? "未知" : r.getCity();
            accumulate(result, city, m,
                nz(r.getPassengerVolume()), nz(r.getTurnover()),
                nz(r.getPassengerCity()), nz(r.getTurnoverCity()));
        }
        return result;
    }

    /** è½¨é“/轮渡：月 â†’ å¸‚å·ž â†’ [轨道客运量,轨道周转量,轮渡客运量,轮渡周转量] */
    public Map<Integer, Map<String, double[]>> railFerryMonthly(String yearPrefix, int limit) {
        Map<Integer, Map<String, double[]>> result = new LinkedHashMap<>();
        List<CityBusMonthly> rows = cityBusMapper.selectList(
            new LambdaQueryWrapper<CityBusMonthly>().likeRight(CityBusMonthly::getReportPeriod, yearPrefix));
        for (CityBusMonthly r : rows) {
            int m = monthOf(r.getReportPeriod());
            if (m < 1 || m > limit) continue;
            String city = r.getCity() == null ? "未知" : r.getCity();
            accumulate(result, city, m,
                nz(r.getRailPassengerVolume()), nz(r.getRailTurnover()),
                nz(r.getFerryPassengerVolume()), nz(r.getFerryTurnover()));
        }
        return result;
    }

    private void accumulate(Map<Integer, Map<String, double[]>> result, String city, int m,
                            double v0, double v1, double v2, double v3) {
        Map<String, double[]> cityMap = result.computeIfAbsent(m, k -> new HashMap<>());
        double[] arr = cityMap.computeIfAbsent(city, k -> new double[4]);
        arr[0] += v0;
        arr[1] += v1;
        arr[2] += v2;
        arr[3] += v3;
        double[] prov = cityMap.computeIfAbsent(PROVINCE, k -> new double[4]);
        prov[0] += v0;
        prov[1] += v1;
        prov[2] += v2;
        prov[3] += v3;
    }

    private int monthOf(String reportPeriod) {
        if (reportPeriod == null) return 0;
        String[] parts = reportPeriod.split("-");
        if (parts.length < 2) return 0;
        try {
            return Integer.parseInt(parts[1]);
        } catch (NumberFormatException e) {
            return 0;
        }
    }

    private double nz(Double v) { return v == null ? 0.0 : v; }
}