合作站
+
+
+
+
+
+
+ 地图引擎: 羚牛氢能 GIS (AMap 3D Engine)站点数据服务 · 公开目录视角: 全国加氢站网络
+ ${escapeHTML(node.name)}${label ? `${escapeHTML(label)}` : ''}
${subline ? `${escapeHTML(subline)}
` : ''}未找到匹配站点
请尝试名称、地址、城市或拼音首字母
'; return; }
+ box.innerHTML = display.slice(0, 100).map((node, index) => { const distance = node.kind === 'station' ? stationDistance(node.station) : Number.POSITIVE_INFINITY, partnerTag = node.kind === 'station' && node.cooperative ? '合作' : ''; return ``; }).join('');
+ box.querySelectorAll('[data-node-id]').forEach(button => button.addEventListener('click', () => { const node = display.find(item => item.id === button.dataset.nodeId); if (node?.kind === 'station') selectStation(node.station, true); else if (node) state.map?.setZoomAndCenter(nextZoomForLevel(node.level), node.lnglat); }));
+}
+function compareNodes(left, right) { if (state.userLocation && left.kind === 'station' && right.kind === 'station') return stationDistance(left.station) - stationDistance(right.station); return right.count - left.count || String(left.name || '').localeCompare(String(right.name || ''), 'zh-CN'); }
+
+function fuzzySearchScore(value, query) {
+ const needle = normalize(query); if (!needle) return 4;
+ const text = normalize(value); if (text === needle) return 0; if (text.startsWith(needle)) return 1; if (text.includes(needle)) return 2;
+ const pinyin = toPinyin(value); if (pinyin === needle || pinyin.startsWith(needle) || initials(pinyin).startsWith(needle)) return 3;
+ return pinyin.includes(needle) || initials(pinyin).includes(needle) ? 4 : Number.POSITIVE_INFINITY;
+}
+function compactPath(parts) { return parts.filter(Boolean).join(' · '); }
+function stationLocationOptions() {
+ const groups = new Map();
+ const add = (level, station) => {
+ const province = station.province || '', city = station.city || '', district = station.district || '';
+ const key = level === 'province' ? `province|${province}` : level === 'city' ? `city|${province}|${city}` : `district|${province}|${city}|${district}`;
+ if (!groups.has(key)) groups.set(key, { type: 'location', level, province, city, district, stations: [] });
+ groups.get(key).stations.push(station);
+ };
+ for (const station of stationTypeScope()) { const district = stationDistrictName(station); if (station.province) add('province', station); if (station.province && station.city) add('city', station); if (station.province && station.city && district) add('district', { ...station, district }); }
+ return [...groups.values()].map(option => {
+ const target = option.level === 'province' ? option.province : option.level === 'city' ? option.city : option.district;
+ const longitude = option.stations.reduce((sum, station) => sum + Number(station.longitude), 0) / option.stations.length;
+ const latitude = option.stations.reduce((sum, station) => sum + Number(station.latitude), 0) / option.stations.length;
+ return { ...option, label: stationGroupName({ province: target, city: target }, option.level === 'province' ? 'province' : 'city'), path: compactPath([option.province, option.city, option.district]), lnglat: [longitude, latitude] };
+ });
+}
+function stationLocationSuggestions(query) {
+ return stationLocationOptions().map(option => ({ ...option, score: Math.min(fuzzySearchScore(option.label, query), fuzzySearchScore(option.path, query)) }))
+ .filter(option => Number.isFinite(option.score)).sort((left, right) => left.score - right.score || left.label.localeCompare(right.label, 'zh-CN')).slice(0, normalize(query) ? 8 : 6);
+}
+function stationEntitySuggestions(query) {
+ if (!normalize(query)) return [];
+ return filteredStations().map(station => ({ type: 'station', station, score: stationSearchScore(station, query) }))
+ .filter(item => item.score > 0).sort((left, right) => right.score - left.score || String(left.station.name || '').localeCompare(String(right.station.name || ''), 'zh-CN')).slice(0, 5);
+}
+function renderStationSearchSuggestions() {
+ const box = document.getElementById('stationSearchSuggestions'); if (!box || box.hidden) return;
+ const locations = stationLocationSuggestions(state.searchText), stations = stationEntitySuggestions(state.searchText);
+ state.suggestions = [...locations, ...stations]; state.activeSuggestion = Math.min(state.activeSuggestion, state.suggestions.length - 1);
+ if (!state.suggestions.length) { box.innerHTML = '未找到匹配的位置或站点'; return; }
+ let html = '';
+ if (locations.length) html += `位置${locations.map((item, index) => ``).join('')}`;
+ if (stations.length) html += `加氢站${stations.map((item, offset) => { const index = locations.length + offset, station = item.station; return ``; }).join('')}`;
+ box.innerHTML = html;
+}
+function openStationSearchSuggestions() { const box = document.getElementById('stationSearchSuggestions'); if (!box) return; box.hidden = false; renderStationSearchSuggestions(); }
+function closeStationSearchSuggestions() { const box = document.getElementById('stationSearchSuggestions'); if (box) box.hidden = true; state.activeSuggestion = -1; }
+function focusSearchResults() {
+ const stations = filteredStations(); if (!state.map || !stations.length) return;
+ const longitudes = stations.map(station => Number(station.longitude)), latitudes = stations.map(station => Number(station.latitude));
+ const center = [(Math.min(...longitudes) + Math.max(...longitudes)) / 2, (Math.min(...latitudes) + Math.max(...latitudes)) / 2];
+ const span = Math.max(Math.max(...longitudes) - Math.min(...longitudes), Math.max(...latitudes) - Math.min(...latitudes));
+ const zoom = stations.length === 1 ? 14 : span < .1 ? 13 : span < .35 ? 11.5 : span < 1 ? 9.5 : 7;
+ state.map.setZoomAndCenter(zoom, center);
+}
+function handleStationSearchInput(value) { state.searchText = value; document.getElementById('clearSearch').hidden = !normalize(value); state.activeSuggestion = -1; openStationSearchSuggestions(); window.clearTimeout(state.searchDebounce); state.searchDebounce = window.setTimeout(() => { state.query = value; state.selected = null; closeDetail(); render(); if (normalize(value)) focusSearchResults(); }, 180); }
+function selectStationSearchSuggestion(index) {
+ const item = state.suggestions[index]; if (!item) return;
+ if (item.type === 'location') { state.locationFilter = { province: item.province, city: item.city, district: item.district }; state.query = ''; state.searchText = ''; document.getElementById('stationSearch').value = ''; document.getElementById('clearSearch').hidden = true; state.map?.setZoomAndCenter(item.level === 'province' ? 7.2 : item.level === 'city' ? 10.5 : 13, item.lnglat); document.getElementById('selectedRegionHint').textContent = `视角: ${item.path}`; closeStationSearchSuggestions(); render(); return; }
+ closeStationSearchSuggestions(); selectStation(item.station, true);
+}
+function setStationFilter(filter) { if (!['all', 'partner'].includes(filter) || state.stationFilter === filter) return; state.stationFilter = filter; state.selected = null; closeDetail(); document.querySelectorAll('[data-station-filter]').forEach(button => button.classList.toggle('is-active', button.dataset.stationFilter === filter)); render(); renderStationSearchSuggestions(); }
+function clearSearch() { window.clearTimeout(state.searchDebounce); document.getElementById('stationSearch').value = ''; state.query = ''; state.searchText = ''; state.locationFilter = { province: '', city: '', district: '' }; closeStationSearchSuggestions(); closeDetail(); resetMap(); render(); }
+function handleSearchKeydown(event) { if (event.key === 'Escape') { closeStationSearchSuggestions(); event.currentTarget.blur(); return; } if (!['ArrowDown', 'ArrowUp', 'Enter'].includes(event.key)) return; const box = document.getElementById('stationSearchSuggestions'); if (box?.hidden) openStationSearchSuggestions(); if (event.key === 'Enter' && state.activeSuggestion >= 0) { event.preventDefault(); selectStationSearchSuggestion(state.activeSuggestion); return; } if (event.key !== 'Enter') { event.preventDefault(); const direction = event.key === 'ArrowDown' ? 1 : -1; state.activeSuggestion = (state.activeSuggestion + direction + state.suggestions.length) % Math.max(state.suggestions.length, 1); renderStationSearchSuggestions(); } }
+
+function selectStation(station, fit = false) {
+ if (!station) return; state.selected = station; if (fit) state.map?.setZoomAndCenter(14.5, coords(station));
+ document.getElementById('detailName').textContent = station.name || station.shortName || '未命名站点'; document.getElementById('detailRegion').textContent = stationRegion(station);
+ const cooperative = Boolean(station.cooperative), tag = document.getElementById('detailType'); tag.textContent = cooperative ? '合作站' : '外部站'; tag.classList.toggle('is-station', cooperative);
+ const distance = stationDistance(station); document.getElementById('detailFields').innerHTML = `${detailField('站点状态', cooperative ? '合作站点' : '外部站点')}${detailField('行政区域', stationRegion(station))}${detailField('详细地址', station.address || '暂无详细地址', true)}${Number.isFinite(distance) ? detailField('距离我', `${formatNumber(distance, 1)} km`) : ''}`;
+ document.getElementById('stationDetail').hidden = false; renderMarkers(); renderList();
+}
+function detailField(label, value, full = false) { return `请尝试名称、地址、城市或拼音首字母
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/station-navigation/server.py b/station-navigation/server.py
new file mode 100644
index 00000000..6831ed60
--- /dev/null
+++ b/station-navigation/server.py
@@ -0,0 +1,230 @@
+"""Public hydrogen station navigation service.
+
+This process deliberately has a smaller API boundary than the operations map:
+it retrieves only station directory fields and never exposes vehicle records or
+hydrogen-volume fields.
+"""
+
+import hashlib
+from http.server import HTTPServer, SimpleHTTPRequestHandler
+import json
+import os
+from pathlib import Path
+from socketserver import ThreadingMixIn
+import threading
+import time
+from urllib.error import HTTPError, URLError
+from urllib.parse import urlparse
+from urllib.request import Request, urlopen
+
+
+ROOT = Path(__file__).resolve().parent
+# Production deliberately reuses the operations map's visual assets. Keeping
+# this configurable lets the standalone release live under its own directory.
+VEHICLE_MAP_ROOT = Path(os.getenv("VEHICLE_MAP_ASSET_ROOT", str(ROOT.parent / "vehicle-map")))
+HOST = os.getenv("STATION_NAVIGATION_HOST", "0.0.0.0")
+PORT = int(os.getenv("STATION_NAVIGATION_PORT", "20804"))
+OPEN_PLATFORM_BASE_URL = os.getenv("OPEN_PLATFORM_BASE_URL", "https://open.d.lnoneos.com").rstrip("/")
+OPEN_PLATFORM_APP_KEY = os.getenv("OPEN_PLATFORM_APP_KEY", "").strip()
+UPSTREAM_TIMEOUT_SECONDS = float(os.getenv("UPSTREAM_TIMEOUT_SECONDS", "15"))
+STATION_CACHE_SECONDS = int(os.getenv("STATION_NAVIGATION_CACHE_SECONDS", "120"))
+_cache_lock = threading.Lock()
+_cache = {}
+
+
+def _static_asset_version():
+ digest = hashlib.sha256()
+ for filename in ("app.js", "styles.css"):
+ digest.update((ROOT / filename).read_bytes())
+ digest.update((VEHICLE_MAP_ROOT / "styles.css").read_bytes())
+ return digest.hexdigest()[:16]
+
+
+STATIC_ASSET_VERSION = _static_asset_version()
+
+
+class ThreadingHTTPServer(ThreadingMixIn, HTTPServer):
+ daemon_threads = True
+ allow_reuse_address = True
+
+
+def _json_bytes(value):
+ return json.dumps(value, ensure_ascii=False, separators=(",", ":")).encode("utf-8")
+
+
+def _post_open_platform(path, body):
+ if not OPEN_PLATFORM_APP_KEY:
+ raise RuntimeError("OPEN_PLATFORM_APP_KEY is not configured")
+ request = Request(
+ OPEN_PLATFORM_BASE_URL + path,
+ data=_json_bytes(body),
+ method="POST",
+ headers={
+ "Authorization": "Bearer " + OPEN_PLATFORM_APP_KEY,
+ "Content-Type": "application/json",
+ "Accept": "application/json",
+ "User-Agent": "lingniu-station-navigation/1.0",
+ },
+ )
+ try:
+ with urlopen(request, timeout=UPSTREAM_TIMEOUT_SECONDS) as response:
+ payload = json.load(response)
+ except HTTPError as exc:
+ detail = exc.read(2048).decode("utf-8", errors="replace")
+ raise RuntimeError(f"open platform returned HTTP {exc.code}: {detail}") from exc
+ except URLError as exc:
+ raise RuntimeError(f"open platform unavailable: {exc.reason}") from exc
+ if payload.get("code") != "SUCCESS":
+ raise RuntimeError(f"open platform rejected request: {payload.get('code')} {payload.get('message')}")
+ return payload.get("data") or []
+
+
+def _cached(key, ttl_seconds, loader):
+ now = time.time()
+ with _cache_lock:
+ cached = _cache.get(key)
+ if cached and now - cached[0] < ttl_seconds:
+ return cached[1]
+ value = loader()
+ with _cache_lock:
+ _cache[key] = (now, value)
+ return value
+
+
+def _public_station(station):
+ """Positive allowlist: do not add operational or hydrogen fields here."""
+ fields = (
+ "id", "name", "shortName", "province", "city", "district", "address",
+ "longitude", "latitude", "cooperative",
+ )
+ return {field: station.get(field) for field in fields if station.get(field) is not None}
+
+
+def _load_station_directory():
+ stations = _post_open_platform("/api/v1/hydrogen-stations/query", {})
+ directory = [_public_station(station) for station in stations]
+ return {
+ "status": "ok",
+ "asOf": time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()),
+ "summary": {
+ "totalStations": len(directory),
+ "cooperativeStations": sum(1 for station in directory if station.get("cooperative")),
+ },
+ "stations": directory,
+ }
+
+
+def _prewarm_station_directory_cache():
+ """Fetch the public directory after startup so first navigation is warm."""
+ try:
+ _cached("station-directory", STATION_CACHE_SECONDS, _load_station_directory)
+ except Exception as exc: # The request path will retry without blocking startup.
+ print(f"station navigation cache warmup deferred: {exc}")
+
+
+class StationNavigationHandler(SimpleHTTPRequestHandler):
+ server_version = "LingniuStationNavigation/1.0"
+
+ def do_GET(self):
+ path = urlparse(self.path).path
+ if path in {"/", "/index.html"}:
+ self._serve_index()
+ return
+ if path == "/api/health":
+ self._write_json(200, {
+ "status": "ok",
+ "service": "station-navigation",
+ "openPlatformConfigured": bool(OPEN_PLATFORM_APP_KEY),
+ })
+ return
+ if path == "/api/stations":
+ try:
+ self._write_json(200, _cached("station-directory", STATION_CACHE_SECONDS, _load_station_directory))
+ except Exception as exc:
+ self.log_error("station directory refresh failed: %s", exc)
+ self._write_json(502, {
+ "status": "error",
+ "code": "UPSTREAM_UNAVAILABLE",
+ "message": "加氢站数据暂时不可用，请稍后重试",
+ })
+ return
+ if path == "/assets/logo_light.svg":
+ self._serve_logo()
+ return
+ if path == "/assets/vehicle-map.css":
+ self._serve_vehicle_map_styles()
+ return
+ if path.startswith("/api/"):
+ self._write_json(404, {"status": "error", "code": "NOT_FOUND"})
+ return
+ super().do_GET()
+
+ def _serve_index(self):
+ try:
+ template = (ROOT / "index.html").read_text(encoding="utf-8")
+ body = template.replace("__ASSET_VERSION__", STATIC_ASSET_VERSION).encode("utf-8")
+ except OSError as exc:
+ self.log_error("index template unavailable: %s", exc)
+ self.send_error(500, "Station navigation is temporarily unavailable")
+ return
+ self.send_response(200)
+ self.send_header("Content-Type", "text/html; charset=utf-8")
+ self.send_header("Content-Length", str(len(body)))
+ self.send_header("Cache-Control", "no-cache")
+ self.end_headers()
+ self.wfile.write(body)
+
+ def _serve_logo(self):
+ try:
+ body = (VEHICLE_MAP_ROOT / "logo_light.svg").read_bytes()
+ except OSError:
+ self.send_error(404)
+ return
+ self.send_response(200)
+ self.send_header("Content-Type", "image/svg+xml")
+ self.send_header("Content-Length", str(len(body)))
+ self.send_header("Cache-Control", "public, max-age=86400")
+ self.end_headers()
+ self.wfile.write(body)
+
+ def _serve_vehicle_map_styles(self):
+ try:
+ body = (VEHICLE_MAP_ROOT / "styles.css").read_bytes()
+ except OSError:
+ self.send_error(404)
+ return
+ self.send_response(200)
+ self.send_header("Content-Type", "text/css; charset=utf-8")
+ self.send_header("Content-Length", str(len(body)))
+ self.send_header("Cache-Control", "no-cache")
+ self.end_headers()
+ self.wfile.write(body)
+
+ def end_headers(self):
+ if self.path == "/" or self.path.split("?", 1)[0].endswith((".html", ".css", ".js", ".svg")):
+ self.send_header("Cache-Control", "no-cache")
+ self.send_header("X-Content-Type-Options", "nosniff")
+ self.send_header("Referrer-Policy", "strict-origin-when-cross-origin")
+ self.send_header("X-Frame-Options", "SAMEORIGIN")
+ super().end_headers()
+
+ def _write_json(self, status, payload):
+ body = _json_bytes(payload)
+ self.send_response(status)
+ self.send_header("Content-Type", "application/json; charset=utf-8")
+ self.send_header("Cache-Control", "no-store")
+ self.send_header("Content-Length", str(len(body)))
+ self.end_headers()
+ self.wfile.write(body)
+
+
+if __name__ == "__main__":
+ server = ThreadingHTTPServer((HOST, PORT), StationNavigationHandler)
+ threading.Thread(target=_prewarm_station_directory_cache, daemon=True).start()
+ print(f"Lingniu Station Navigation listening on http://{HOST}:{PORT}")
+ try:
+ server.serve_forever()
+ except KeyboardInterrupt:
+ pass
+ finally:
+ server.server_close()
diff --git a/station-navigation/start-local.sh b/station-navigation/start-local.sh
new file mode 100755
index 00000000..511f6154
--- /dev/null
+++ b/station-navigation/start-local.sh
@@ -0,0 +1,6 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+export STATION_NAVIGATION_HOST="${STATION_NAVIGATION_HOST:-127.0.0.1}"
+export STATION_NAVIGATION_PORT="${STATION_NAVIGATION_PORT:-20804}"
+exec python3 "$(dirname "$0")/server.py"
diff --git a/station-navigation/styles.css b/station-navigation/styles.css
new file mode 100644
index 00000000..9a1ee725
--- /dev/null
+++ b/station-navigation/styles.css
@@ -0,0 +1,20 @@
+/* Keep the public service visually identical to the main map shell. */
+.station-navigation-shell .header-kpi-group { display: flex; }
+.station-navigation-shell .map-filter-chip { min-height: 27px; padding: 0 9px; border: 1px solid var(--glass-border); border-radius: 8px; background: var(--pill-bg); color: var(--text-muted); font-size: 10px; font-weight: 700; cursor: pointer; }
+.station-navigation-shell .map-filter-chip.is-active { border-color: rgba(0,113,67,.24); background: rgba(0,113,67,.1); color: var(--accent-primary); }
+.station-navigation-shell .filter-chip-rail { display: flex; gap: 6px; }
+.station-navigation-shell .province-info-card.is-station-point { min-width: 92px; }
+.station-navigation-shell .province-info-card.is-station-point .p-total { color: var(--accent-primary); }
+.station-navigation-shell .province-info-card.is-external .p-total { color: var(--text-muted); }
+.station-navigation-shell .rank-glass-row { cursor: pointer; }
+.station-navigation-shell .rank-glass-row.is-selected { background: rgba(0,113,67,.09); border-color: rgba(0,113,67,.2); }
+.station-navigation-shell .r-name { display: flex; min-width: 0; align-items: flex-start; gap: 5px; line-height: 1.35; }
+.station-navigation-shell .station-list-name { min-width: 0; overflow-wrap: anywhere; white-space: normal; }
+.station-navigation-shell .station-list-partner-tag { flex: 0 0 auto; margin-top: 1px; padding: 2px 5px; border-radius: 4px; background: rgba(0,113,67,.1); color: var(--accent-primary); font-size: 9px; font-weight: 700; line-height: 1; }
+.station-navigation-shell .rank-empty { display: grid; min-height: 160px; place-items: center; color: var(--text-muted); font-size: 12px; text-align: center; }
+.station-navigation-shell .map-detail-card .detail-grid { margin-bottom: 0; }
+@media (max-width: 760px) {
+ .station-navigation-shell .header-kpi-group { display: flex; }
+ .station-navigation-shell .filter-chip-rail { max-width: 124px; overflow: hidden; }
+ .station-navigation-shell .map-filter-chip { padding: 0 7px; font-size: 9px; }
+}
diff --git a/station-navigation/tests/test_app.mjs b/station-navigation/tests/test_app.mjs
new file mode 100644
index 00000000..333fa69e
--- /dev/null
+++ b/station-navigation/tests/test_app.mjs
@@ -0,0 +1,73 @@
+import assert from 'node:assert/strict';
+import fs from 'node:fs';
+import vm from 'node:vm';
+
+const source = fs.readFileSync(new URL('../app.js', import.meta.url), 'utf8');
+const sandbox = {
+ console,
+ document: { addEventListener() {}, getElementById() { return null; } },
+ window: {},
+ pinyinPro: { pinyin(value) { return value === '广州合作站' ? 'guang zhou he zuo zhan' : value; } },
+ navigator: {},
+};
+sandbox.globalThis = sandbox;
+vm.runInNewContext(source, sandbox, { filename: 'app.js' });
+
+assert.equal(sandbox.stationSearchScore({ name: '广州合作站' }, 'gz'), 2);
+assert.equal(sandbox.stationSearchScore({ address: '广东省广州市黄埔区' }, '黄埔'), 3);
+assert.equal(sandbox.stationSearchScore({ name: '广州合作站' }, '北京'), 0);
+assert.equal(sandbox.hasCoordinates({ longitude: 113.2, latitude: 23.1 }), true);
+assert.equal(sandbox.hasCoordinates({ longitude: 'bad', latitude: 23.1 }), false);
+vm.runInNewContext(`
+ state.stations = [
+ { id: 'partner', name: '广州合作站', cooperative: true },
+ { id: 'external', name: '广州外部站', cooperative: false }
+ ];
+ globalThis.allStationIds = filteredStations().map(station => station.id);
+ state.stationFilter = 'partner';
+ globalThis.partnerStationIds = filteredStations().map(station => station.id);
+`, sandbox);
+assert.equal(sandbox.allStationIds.join(','), 'partner,external');
+assert.equal(sandbox.partnerStationIds.join(','), 'partner');
+vm.runInNewContext(`
+ state.stations = [
+ { id: 'gd-hp', name: '黄埔合作站', province: '广东省', city: '广州市', district: '黄埔区', longitude: 113.3, latitude: 23.1, cooperative: true },
+ { id: 'gd-nh', name: '南海合作站', province: '广东省', city: '佛山市', district: '南海区', longitude: 113.1, latitude: 23.0, cooperative: true },
+ { id: 'zj-jx', name: '嘉兴合作站', province: '浙江省', city: '嘉兴市', district: '秀洲区', longitude: 120.7, latitude: 30.7, cooperative: true }
+ ];
+ globalThis.hierarchy = [stationHierarchyLevel(4.8), stationHierarchyLevel(8), stationHierarchyLevel(13)];
+ globalThis.provinceNodeCount = buildStationNodes(filteredStations(), 'province').length;
+ globalThis.cityNodeCount = buildStationNodes(filteredStations(), 'city').length;
+ globalThis.stationNodeCount = buildStationNodes(filteredStations(), 'station').length;
+ globalThis.locationOptionCount = stationLocationOptions().length;
+`, sandbox);
+assert.equal(sandbox.hierarchy.join(','), 'province,city,station');
+assert.equal(sandbox.provinceNodeCount, 2);
+assert.equal(sandbox.cityNodeCount, 3);
+assert.equal(sandbox.stationNodeCount, 3);
+assert.equal(sandbox.locationOptionCount, 8);
+vm.runInNewContext(`
+ globalThis.inferredDistrict = stationDistrictName({ province: '浙江省', city: '嘉兴市', address: '嘉兴市海盐县海盐经济开发区' });
+ state.locationFilter = { province: '', city: '', district: '' };
+ state.query = '广州';
+ globalThis.queryMatches = stationMatchesQuery({ name: '广州合作站' });
+ globalThis.queryMisses = stationMatchesQuery({ name: '杭州合作站' });
+`, sandbox);
+assert.equal(sandbox.inferredDistrict, '海盐县');
+assert.equal(sandbox.queryMatches, true);
+assert.equal(sandbox.queryMisses, false);
+assert.ok(Math.abs(sandbox.distanceKm([113, 23], [114, 23]) - 102.4) < 1);
+assert.match(source, /zoom < 11\) return 'city'/);
+assert.match(source, /state\.userLocation && left\.kind === 'station'/);
+assert.doesNotMatch(source, /rankSecondaryTab|setRank\(/);
+assert.match(source, /stationSearchSuggestions/);
+assert.match(source, /handleStationSearchInput/);
+assert.match(source, /window\.setTimeout\(\(\) => \{ state\.query = value/);
+assert.match(source, /focusSearchResults\(\)/);
+assert.match(source, /visibleOnly && !normalize\(state\.query\)/);
+assert.match(source, /station-list-partner-tag/);
+assert.match(source, /node\.cooperative \? 'H₂ · 合作' : ''/);
+assert.doesNotMatch(source, /在线 \$\{formatNumber\(node\.online\)\}/);
+assert.doesNotMatch(source, /monthlyHydrogenKg|totalHydrogenKg|vehicle/);
+assert.match(source, /uri\.amap\.com\/navigation/);
+console.log('station navigation app tests: ok');
diff --git a/station-navigation/tests/test_server.py b/station-navigation/tests/test_server.py
new file mode 100644
index 00000000..625dd4c8
--- /dev/null
+++ b/station-navigation/tests/test_server.py
@@ -0,0 +1,46 @@
+import importlib.util
+from pathlib import Path
+import unittest
+from unittest.mock import patch
+
+
+SPEC = importlib.util.spec_from_file_location("station_navigation_server", Path(__file__).parents[1] / "server.py")
+server = importlib.util.module_from_spec(SPEC)
+SPEC.loader.exec_module(server)
+
+
+class StationNavigationTest(unittest.TestCase):
+ def test_directory_is_a_positive_allowlist_without_hydrogen_data(self):
+ source = [{
+ "id": "GD-1", "name": "广州合作站", "province": "广东省", "city": "广州市",
+ "district": "黄埔区", "address": "开源大道1号", "longitude": 113.2, "latitude": 23.1,
+ "cooperative": True, "monthlyHydrogenKg": 88.8, "totalHydrogenKg": 999.9,
+ "vehicleCount": 20,
+ }]
+ with patch.object(server, "_post_open_platform", return_value=source):
+ result = server._load_station_directory()
+
+ self.assertEqual(result["summary"], {"totalStations": 1, "cooperativeStations": 1})
+ station = result["stations"][0]
+ self.assertEqual(station["name"], "广州合作站")
+ self.assertNotIn("monthlyHydrogenKg", station)
+ self.assertNotIn("totalHydrogenKg", station)
+ self.assertNotIn("vehicleCount", station)
+
+ def test_static_assets_are_fingerprinted(self):
+ self.assertRegex(server.STATIC_ASSET_VERSION, r"^[0-9a-f]{16}$")
+
+ def test_default_cache_window_is_two_minutes(self):
+ self.assertEqual(server.STATION_CACHE_SECONDS, 120)
+
+ def test_cache_reuses_directory_snapshot_within_window(self):
+ calls = []
+ with patch.object(server, "_cache", {}):
+ first = server._cached("station-directory", 120, lambda: calls.append("load") or {"version": 1})
+ second = server._cached("station-directory", 120, lambda: calls.append("load") or {"version": 2})
+ self.assertEqual(calls, ["load"])
+ self.assertEqual(first, second)
+
+
+if __name__ == "__main__":
+ unittest.main()
diff --git a/vehicle-map/README.md b/vehicle-map/README.md
index ee538505..f8a00c7d 100644
--- a/vehicle-map/README.md
+++ b/vehicle-map/README.md
@@ -37,8 +37,8 @@ python3 server.py
本服务提供：
- `GET /api/health`：进程及配置状态；
-- `GET /api/dashboard`：面向前端的公开聚合数据，默认缓存5秒；加氢站缓存1小时。
+- `GET /api/dashboard`：面向前端的公开聚合数据，默认缓存 2 分钟；加氢站目录同样缓存 2 分钟。服务启动后会后台预热缓存，避免首位访问者等待上游数据请求。
-全国视图按车辆最新 GPS 坐标落入省级行政区，不按车牌归属地推断；没有有效实时坐标的车辆会单独计入“无实时位置”，不会伪造省份归属。页面每15秒刷新一次。
+全国视图按车辆最新 GPS 坐标落入省级行政区，不按车牌归属地推断；没有有效实时坐标的车辆会单独计入“无实时位置”，不会伪造省份归属。页面每 15 秒请求一次，但服务端最多每 2 分钟刷新一次上游快照，以换取更快、更稳定的首屏加载。
车辆地图按缩放级别逐级下钻：全国视角（小于7级）按省聚合，7–9.5级按市聚合，9.5–12级按区县聚合，12级及以上显示当前视野内的单车真实位置。点击省、市、区县气泡会自动进入下一级。
diff --git a/vehicle-map/server.py b/vehicle-map/server.py
index aa498558..5af61cd9 100644
--- a/vehicle-map/server.py
+++ b/vehicle-map/server.py
@@ -31,8 +31,8 @@ PORT = int(os.getenv("VEHICLE_MAP_PORT", "20800"))
OPEN_PLATFORM_BASE_URL = os.getenv("OPEN_PLATFORM_BASE_URL", "https://open.d.lnoneos.com").rstrip("/")
OPEN_PLATFORM_APP_KEY = os.getenv("OPEN_PLATFORM_APP_KEY", "").strip()
UPSTREAM_TIMEOUT_SECONDS = float(os.getenv("UPSTREAM_TIMEOUT_SECONDS", "15"))
-DASHBOARD_CACHE_SECONDS = int(os.getenv("DASHBOARD_CACHE_SECONDS", "5"))
-STATION_CACHE_SECONDS = int(os.getenv("STATION_CACHE_SECONDS", "3600"))
+DASHBOARD_CACHE_SECONDS = int(os.getenv("DASHBOARD_CACHE_SECONDS", "120"))
+STATION_CACHE_SECONDS = int(os.getenv("STATION_CACHE_SECONDS", "120"))
_cache_lock = threading.Lock()
_cache = {}
@@ -149,6 +149,18 @@ def _load_dashboard():
}
+def _prewarm_dashboard_cache():
+ """Warm the first dashboard snapshot after a process restart.
+
+ A warm snapshot lets the first visitor receive the cached response instead
+ of waiting for the three upstream requests to complete.
+ """
+ try:
+ _cached("dashboard", DASHBOARD_CACHE_SECONDS, _load_dashboard)
+ except Exception as exc: # A later request can retry; startup must stay available.
+ print(f"vehicle map cache warmup deferred: {exc}")
+
+
class VehicleMapHandler(SimpleHTTPRequestHandler):
server_version = "LingniuVehicleMap/1.0"
@@ -215,6 +227,7 @@ class VehicleMapHandler(SimpleHTTPRequestHandler):
if __name__ == "__main__":
server = ThreadingHTTPServer((HOST, PORT), VehicleMapHandler)
+ threading.Thread(target=_prewarm_dashboard_cache, daemon=True).start()
print(f"Lingniu Vehicle Map listening on http://{HOST}:{PORT}")
try:
server.serve_forever()
diff --git a/vehicle-map/tests/test_server.py b/vehicle-map/tests/test_server.py
index f46d2f9d..421eb558 100644
--- a/vehicle-map/tests/test_server.py
+++ b/vehicle-map/tests/test_server.py
@@ -47,5 +47,17 @@ class DashboardTest(unittest.TestCase):
index_template = (Path(__file__).parents[1] / "index.html").read_text(encoding="utf-8")
self.assertEqual(index_template.count("__ASSET_VERSION__"), 2)
+ def test_default_cache_window_is_two_minutes(self):
+ self.assertEqual(server.DASHBOARD_CACHE_SECONDS, 120)
+ self.assertEqual(server.STATION_CACHE_SECONDS, 120)
+
+ def test_cache_reuses_dashboard_snapshot_within_window(self):
+ calls = []
+ with patch.object(server, "_cache", {}):
+ first = server._cached("dashboard", 120, lambda: calls.append("load") or {"version": 1})
+ second = server._cached("dashboard", 120, lambda: calls.append("load") or {"version": 2})
+ self.assertEqual(calls, ["load"])
+ self.assertEqual(first, second)
+
if __name__ == "__main__":
unittest.main()
+ 
+
+
+
+ 加氢站导航
+
+ 站点总数-- 座
+ 合作站点-- 座
+
+
+
+
+
+
+
+