simulator.js 69 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028
  1. (function () {
  2. const DEFAULT_CENTER = [31.2304, 121.4737]
  3. const DEFAULT_CONFIG_URL = 'https://oss-mbh5.colormaprun.com/wxmini/test/game.json'
  4. const DEFAULT_TILE_URL = 'https://{s}.tile.openstreetmap.org/{z}/{x}/{y}.png'
  5. const PROXY_BASE_URL = `${location.origin}/proxy?url=`
  6. const GPS_WS_URL = `ws://${location.hostname}:17865/mock-gps`
  7. const HEART_RATE_WS_URL = `ws://${location.hostname}:17865/mock-hr`
  8. const DEBUG_LOG_WS_URL = `ws://${location.hostname}:17865/debug-log`
  9. const DEFAULT_GATEWAY_BRIDGE_URL = 'ws://127.0.0.1:18080/ws'
  10. const LEGACY_GATEWAY_BRIDGE_URLS = new Set([
  11. 'ws://127.0.0.1:8080/ws',
  12. 'ws://localhost:8080/ws',
  13. ])
  14. const BRIDGE_CONFIG_STORAGE_KEY = 'mock-gps-sim.bridge-config'
  15. const BRIDGE_PRESETS_STORAGE_KEY = 'mock-gps-sim.bridge-presets'
  16. const SIM_CHANNEL_STORAGE_KEY = 'mock-gps-sim.channel-id'
  17. const MAX_DEBUG_LOG_LINES = 400
  18. function normalizeSimChannelId(rawValue) {
  19. const trimmed = String(rawValue || '').trim()
  20. return trimmed || 'default'
  21. }
  22. const map = L.map('map').setView(DEFAULT_CENTER, 16)
  23. let tileLayer = createTileLayer(DEFAULT_TILE_URL, {
  24. maxZoom: 20,
  25. attribution: '© OpenStreetMap',
  26. }).addTo(map)
  27. const liveMarker = L.circleMarker(DEFAULT_CENTER, {
  28. radius: 11,
  29. color: '#ffffff',
  30. weight: 3,
  31. fillColor: '#ff2f92',
  32. fillOpacity: 0.94,
  33. }).addTo(map)
  34. const pathLine = L.polyline([], {
  35. color: '#0ea5a4',
  36. weight: 4,
  37. opacity: 0.9,
  38. }).addTo(map)
  39. const courseLayer = L.layerGroup().addTo(map)
  40. const pathMarkers = []
  41. const pathPoints = []
  42. const state = {
  43. socket: null,
  44. heartRateSocket: null,
  45. debugSocket: null,
  46. connected: false,
  47. heartRateConnected: false,
  48. debugConnected: false,
  49. socketConnecting: false,
  50. heartRateSocketConnecting: false,
  51. debugSocketConnecting: false,
  52. streaming: false,
  53. heartRateStreaming: false,
  54. heartRateSampleMode: false,
  55. pathEditMode: false,
  56. playbackRunning: false,
  57. playbackTimer: 0,
  58. streamTimer: 0,
  59. heartRateStreamTimer: 0,
  60. lastSentText: '--',
  61. lastHeartRateSentText: '--',
  62. lastResourceDetailText: '尚未载入资源',
  63. lastTrackSourceText: '路径待命',
  64. simChannelId: 'default',
  65. currentLatLng: L.latLng(DEFAULT_CENTER[0], DEFAULT_CENTER[1]),
  66. headingDeg: 0,
  67. currentSegmentIndex: 0,
  68. currentSegmentProgress: 0,
  69. lastPlaybackAt: 0,
  70. heartRateSampleStartedAt: 0,
  71. loadedCourse: null,
  72. resourceLoading: false,
  73. bridgeEnabled: false,
  74. bridgeConnected: false,
  75. bridgeAuthenticated: false,
  76. bridgeTargetText: '--',
  77. bridgeLastStatusText: '--',
  78. bridgeConfigSaving: false,
  79. bridgePresets: [],
  80. debugLogEntries: [],
  81. debugLogScopeFilter: 'all',
  82. debugLogPanelMinimized: false,
  83. }
  84. const elements = {
  85. socketStatus: document.getElementById('socketStatus'),
  86. configUrlInput: document.getElementById('configUrlInput'),
  87. loadConfigBtn: document.getElementById('loadConfigBtn'),
  88. fitCourseBtn: document.getElementById('fitCourseBtn'),
  89. tileUrlInput: document.getElementById('tileUrlInput'),
  90. applyTilesBtn: document.getElementById('applyTilesBtn'),
  91. resetTilesBtn: document.getElementById('resetTilesBtn'),
  92. courseUrlInput: document.getElementById('courseUrlInput'),
  93. loadCourseBtn: document.getElementById('loadCourseBtn'),
  94. clearCourseBtn: document.getElementById('clearCourseBtn'),
  95. resourceStatus: document.getElementById('resourceStatus'),
  96. resourceDetail: document.getElementById('resourceDetail'),
  97. courseJumpList: document.getElementById('courseJumpList'),
  98. realtimeStatus: document.getElementById('realtimeStatus'),
  99. lastSendStatus: document.getElementById('lastSendStatus'),
  100. gatewayBridgeStatus: document.getElementById('gatewayBridgeStatus'),
  101. gatewayBridgeTarget: document.getElementById('gatewayBridgeTarget'),
  102. gatewayBridgeLast: document.getElementById('gatewayBridgeLast'),
  103. gatewayBridgePresetSelect: document.getElementById('gatewayBridgePresetSelect'),
  104. gatewayBridgePresetNameInput: document.getElementById('gatewayBridgePresetNameInput'),
  105. applyGatewayBridgePresetBtn: document.getElementById('applyGatewayBridgePresetBtn'),
  106. saveGatewayBridgePresetBtn: document.getElementById('saveGatewayBridgePresetBtn'),
  107. deleteGatewayBridgePresetBtn: document.getElementById('deleteGatewayBridgePresetBtn'),
  108. gatewayBridgeEnabledInput: document.getElementById('gatewayBridgeEnabledInput'),
  109. gatewayBridgeUrlInput: document.getElementById('gatewayBridgeUrlInput'),
  110. gatewayBridgeTokenInput: document.getElementById('gatewayBridgeTokenInput'),
  111. gatewayBridgeChannelIdInput: document.getElementById('gatewayBridgeChannelIdInput'),
  112. gatewayBridgeDeviceIdInput: document.getElementById('gatewayBridgeDeviceIdInput'),
  113. gatewayBridgeGroupIdInput: document.getElementById('gatewayBridgeGroupIdInput'),
  114. gatewayBridgeSourceIdInput: document.getElementById('gatewayBridgeSourceIdInput'),
  115. gatewayBridgeSourceModeInput: document.getElementById('gatewayBridgeSourceModeInput'),
  116. applyGatewayBridgeConfigBtn: document.getElementById('applyGatewayBridgeConfigBtn'),
  117. reloadGatewayBridgeConfigBtn: document.getElementById('reloadGatewayBridgeConfigBtn'),
  118. playbackStatus: document.getElementById('playbackStatus'),
  119. heartRateStatus: document.getElementById('heartRateStatus'),
  120. lastHeartRateStatus: document.getElementById('lastHeartRateStatus'),
  121. sendHeartRateOnceBtn: document.getElementById('sendHeartRateOnceBtn'),
  122. startHeartRateStreamBtn: document.getElementById('startHeartRateStreamBtn'),
  123. stopHeartRateStreamBtn: document.getElementById('stopHeartRateStreamBtn'),
  124. applyHeartRatePresetBtn: document.getElementById('applyHeartRatePresetBtn'),
  125. toggleHeartRateSampleBtn: document.getElementById('toggleHeartRateSampleBtn'),
  126. heartRateInput: document.getElementById('heartRateInput'),
  127. heartRateHzSelect: document.getElementById('heartRateHzSelect'),
  128. heartRateSampleTemplateSelect: document.getElementById('heartRateSampleTemplateSelect'),
  129. trackFileInput: document.getElementById('trackFileInput'),
  130. importTrackBtn: document.getElementById('importTrackBtn'),
  131. connectBtn: document.getElementById('connectBtn'),
  132. simChannelIdInput: document.getElementById('simChannelIdInput'),
  133. sendOnceBtn: document.getElementById('sendOnceBtn'),
  134. streamBtn: document.getElementById('streamBtn'),
  135. stopStreamBtn: document.getElementById('stopStreamBtn'),
  136. togglePathModeBtn: document.getElementById('togglePathModeBtn'),
  137. clearPathBtn: document.getElementById('clearPathBtn'),
  138. fitPathBtn: document.getElementById('fitPathBtn'),
  139. playPathBtn: document.getElementById('playPathBtn'),
  140. pausePathBtn: document.getElementById('pausePathBtn'),
  141. hzSelect: document.getElementById('hzSelect'),
  142. accuracyInput: document.getElementById('accuracyInput'),
  143. speedInput: document.getElementById('speedInput'),
  144. loopPathInput: document.getElementById('loopPathInput'),
  145. pathHint: document.getElementById('pathHint'),
  146. latText: document.getElementById('latText'),
  147. lonText: document.getElementById('lonText'),
  148. headingText: document.getElementById('headingText'),
  149. pathCountText: document.getElementById('pathCountText'),
  150. log: document.getElementById('log'),
  151. debugLog: document.getElementById('debugLog'),
  152. debugLogMeta: document.getElementById('debugLogMeta'),
  153. clearDebugLogBtn: document.getElementById('clearDebugLogBtn'),
  154. debugLogScopeFilter: document.getElementById('debugLogScopeFilter'),
  155. floatingDebugLogPanel: document.getElementById('floatingDebugLogPanel'),
  156. toggleDebugLogPanelBtn: document.getElementById('toggleDebugLogPanelBtn'),
  157. topGpsStatus: document.getElementById('topGpsStatus'),
  158. topHrStatus: document.getElementById('topHrStatus'),
  159. topLoggerStatus: document.getElementById('topLoggerStatus'),
  160. topGatewayStatus: document.getElementById('topGatewayStatus'),
  161. summaryResourceText: document.getElementById('summaryResourceText'),
  162. summaryGpsSendText: document.getElementById('summaryGpsSendText'),
  163. summaryHrSendText: document.getElementById('summaryHrSendText'),
  164. summaryPathText: document.getElementById('summaryPathText'),
  165. summaryGatewayText: document.getElementById('summaryGatewayText'),
  166. }
  167. elements.configUrlInput.value = DEFAULT_CONFIG_URL
  168. applySimChannelId(loadSimChannelId(), false)
  169. function createTileLayer(urlTemplate, extraOptions) {
  170. return L.tileLayer(urlTemplate, Object.assign({
  171. maxZoom: 20,
  172. attribution: 'Custom Map',
  173. }, extraOptions || {}))
  174. }
  175. function log(message) {
  176. const time = new Date().toLocaleTimeString()
  177. elements.log.textContent = `[${time}] ${message}\n` + elements.log.textContent
  178. }
  179. function loadSimChannelId() {
  180. try {
  181. return normalizeSimChannelId(window.localStorage.getItem(SIM_CHANNEL_STORAGE_KEY))
  182. } catch (_error) {
  183. return 'default'
  184. }
  185. }
  186. function saveSimChannelId(channelId) {
  187. try {
  188. window.localStorage.setItem(SIM_CHANNEL_STORAGE_KEY, normalizeSimChannelId(channelId))
  189. } catch (_error) {
  190. // noop
  191. }
  192. }
  193. function applySimChannelId(channelId, persist) {
  194. state.simChannelId = normalizeSimChannelId(channelId)
  195. if (elements.simChannelIdInput) {
  196. elements.simChannelIdInput.value = state.simChannelId
  197. }
  198. if (persist) {
  199. saveSimChannelId(state.simChannelId)
  200. }
  201. renderDebugLog()
  202. }
  203. function logDebug(entry) {
  204. if (!elements.debugLog) {
  205. return
  206. }
  207. const normalized = {
  208. timestamp: entry.timestamp || Date.now(),
  209. channelId: normalizeSimChannelId(entry.channelId),
  210. scope: String(entry.scope || 'app'),
  211. level: String(entry.level || 'info'),
  212. message: String(entry.message || ''),
  213. payload: entry.payload && typeof entry.payload === 'object' ? entry.payload : null,
  214. }
  215. state.debugLogEntries.unshift(normalized)
  216. if (state.debugLogEntries.length > MAX_DEBUG_LOG_LINES) {
  217. state.debugLogEntries = state.debugLogEntries.slice(0, MAX_DEBUG_LOG_LINES)
  218. }
  219. renderDebugScopeOptions()
  220. renderDebugLog()
  221. }
  222. function clearDebugLog() {
  223. state.debugLogEntries = []
  224. renderDebugScopeOptions()
  225. renderDebugLog()
  226. }
  227. function renderDebugScopeOptions() {
  228. if (!elements.debugLogScopeFilter) {
  229. return
  230. }
  231. const staticOptions = ['all', 'logger', 'gps-logo', 'gps', 'heart-rate', 'track', 'compass', 'h5', 'content-card', 'gateway']
  232. const seenScopes = new Set(staticOptions)
  233. state.debugLogEntries.forEach((entry) => {
  234. if (entry.scope) {
  235. seenScopes.add(entry.scope)
  236. }
  237. })
  238. const options = Array.from(seenScopes)
  239. const currentValue = options.includes(state.debugLogScopeFilter) ? state.debugLogScopeFilter : 'all'
  240. elements.debugLogScopeFilter.innerHTML = options
  241. .map((scope) => `<option value="${scope}">${scope === 'all' ? '全部' : scope}</option>`)
  242. .join('')
  243. elements.debugLogScopeFilter.value = currentValue
  244. state.debugLogScopeFilter = currentValue
  245. }
  246. function renderDebugLog() {
  247. if (!elements.debugLog) {
  248. return
  249. }
  250. const filteredEntries = state.debugLogEntries.filter((entry) => {
  251. if (normalizeSimChannelId(entry.channelId) !== state.simChannelId) {
  252. return false
  253. }
  254. return state.debugLogScopeFilter === 'all' || entry.scope === state.debugLogScopeFilter
  255. })
  256. if (elements.debugLogMeta) {
  257. const scopeLabel = state.debugLogScopeFilter === 'all' ? '全部' : state.debugLogScopeFilter
  258. elements.debugLogMeta.textContent = `通道 ${state.simChannelId} · ${scopeLabel} · ${filteredEntries.length} 条`
  259. }
  260. elements.debugLog.textContent = filteredEntries
  261. .map((entry) => {
  262. const time = new Date(entry.timestamp || Date.now()).toLocaleTimeString()
  263. const level = String(entry.level || 'info').toUpperCase()
  264. const payloadText = entry.payload ? ` ${JSON.stringify(entry.payload)}` : ''
  265. return `[${time}] [${entry.channelId}] [${entry.scope}] [${level}] ${entry.message}${payloadText}`
  266. })
  267. .join('\n')
  268. }
  269. function updateDebugLogPanelState() {
  270. if (!elements.floatingDebugLogPanel || !elements.toggleDebugLogPanelBtn) {
  271. return
  272. }
  273. elements.floatingDebugLogPanel.classList.toggle('is-minimized', state.debugLogPanelMinimized)
  274. elements.toggleDebugLogPanelBtn.textContent = state.debugLogPanelMinimized ? '展开' : '缩小'
  275. }
  276. function setResourceStatus(message, tone) {
  277. elements.resourceStatus.textContent = message
  278. elements.resourceStatus.className = 'hint'
  279. if (tone === 'ok') {
  280. elements.resourceStatus.classList.add('hint--ok')
  281. } else if (tone === 'warn') {
  282. elements.resourceStatus.classList.add('hint--warn')
  283. }
  284. }
  285. function updateReadout() {
  286. elements.latText.textContent = state.currentLatLng.lat.toFixed(6)
  287. elements.lonText.textContent = state.currentLatLng.lng.toFixed(6)
  288. elements.headingText.textContent = `${Math.round(state.headingDeg)}°`
  289. elements.pathCountText.textContent = String(pathPoints.length)
  290. liveMarker.setLatLng(state.currentLatLng)
  291. }
  292. function setSocketBadge(connected) {
  293. elements.socketStatus.textContent = connected ? '已连接' : '未连接'
  294. elements.socketStatus.className = connected ? 'badge badge--ok' : 'badge badge--muted'
  295. }
  296. function setConnectionValue(element, text, tone) {
  297. if (!element) {
  298. return
  299. }
  300. element.textContent = text
  301. element.classList.remove('is-ok', 'is-warn')
  302. if (tone === 'ok') {
  303. element.classList.add('is-ok')
  304. } else if (tone === 'warn') {
  305. element.classList.add('is-warn')
  306. }
  307. }
  308. function formatClockTime(timestamp) {
  309. if (!timestamp) {
  310. return '--'
  311. }
  312. return new Date(timestamp).toLocaleTimeString()
  313. }
  314. function updateUiState() {
  315. elements.connectBtn.textContent = state.connected ? '桥接已连接' : state.socketConnecting ? '连接中...' : '连接桥接'
  316. elements.connectBtn.classList.toggle('is-active', state.connected)
  317. elements.connectBtn.disabled = state.connected || state.socketConnecting
  318. elements.sendOnceBtn.disabled = !state.connected
  319. elements.streamBtn.textContent = state.streaming ? '发送中' : '开始连续发送'
  320. elements.streamBtn.classList.toggle('is-active', state.streaming)
  321. elements.streamBtn.disabled = !state.connected || state.streaming
  322. elements.stopStreamBtn.disabled = !state.streaming
  323. elements.sendHeartRateOnceBtn.disabled = !state.heartRateConnected
  324. elements.startHeartRateStreamBtn.textContent = state.heartRateStreaming ? '发送中' : '开始连续发送'
  325. elements.startHeartRateStreamBtn.classList.toggle('is-active', state.heartRateStreaming)
  326. elements.startHeartRateStreamBtn.disabled = !state.heartRateConnected || state.heartRateStreaming
  327. elements.stopHeartRateStreamBtn.disabled = !state.heartRateStreaming
  328. elements.toggleHeartRateSampleBtn.textContent = state.heartRateSampleMode ? '关闭真实样本' : '模拟真实样本'
  329. elements.toggleHeartRateSampleBtn.classList.toggle('is-active', state.heartRateSampleMode)
  330. elements.togglePathModeBtn.textContent = state.pathEditMode ? '关闭路径编辑' : '开启路径编辑'
  331. elements.togglePathModeBtn.classList.toggle('is-active', state.pathEditMode)
  332. elements.importTrackBtn.disabled = state.resourceLoading
  333. elements.clearPathBtn.textContent = pathPoints.length ? `清空路径 (${pathPoints.length})` : '清空路径'
  334. elements.clearPathBtn.disabled = pathPoints.length === 0
  335. elements.fitPathBtn.disabled = pathPoints.length < 2
  336. elements.playPathBtn.textContent = state.playbackRunning ? '回放中' : '开始回放'
  337. elements.playPathBtn.classList.toggle('is-active', state.playbackRunning)
  338. elements.playPathBtn.disabled = pathPoints.length < 2 || state.playbackRunning
  339. elements.pausePathBtn.disabled = !state.playbackRunning
  340. elements.fitCourseBtn.disabled = !state.loadedCourse
  341. elements.clearCourseBtn.disabled = !state.loadedCourse
  342. elements.loadConfigBtn.textContent = state.resourceLoading ? '载入中...' : '载入配置'
  343. elements.loadConfigBtn.disabled = state.resourceLoading
  344. elements.loadCourseBtn.textContent = state.resourceLoading ? '载入中...' : '载入控制点'
  345. elements.loadCourseBtn.disabled = state.resourceLoading
  346. elements.applyTilesBtn.disabled = state.resourceLoading
  347. elements.resetTilesBtn.disabled = state.resourceLoading
  348. elements.lastSendStatus.textContent = `最近发送: ${state.lastSentText}`
  349. elements.lastHeartRateStatus.textContent = `最近发送: ${state.lastHeartRateSentText}`
  350. elements.resourceDetail.textContent = state.lastResourceDetailText
  351. elements.gatewayBridgeTarget.textContent = `目标设备: ${state.bridgeTargetText}`
  352. elements.gatewayBridgeLast.textContent = `最近状态: ${state.bridgeLastStatusText}`
  353. elements.applyGatewayBridgeConfigBtn.disabled = state.bridgeConfigSaving
  354. elements.reloadGatewayBridgeConfigBtn.disabled = state.bridgeConfigSaving
  355. elements.applyGatewayBridgePresetBtn.disabled = state.bridgeConfigSaving || !elements.gatewayBridgePresetSelect.value
  356. elements.saveGatewayBridgePresetBtn.disabled = state.bridgeConfigSaving
  357. elements.deleteGatewayBridgePresetBtn.disabled = state.bridgeConfigSaving || !elements.gatewayBridgePresetSelect.value
  358. if (!state.bridgeEnabled) {
  359. elements.gatewayBridgeStatus.textContent = '未启用'
  360. } else if (state.bridgeConnected && state.bridgeAuthenticated) {
  361. elements.gatewayBridgeStatus.textContent = '已连接并已认证'
  362. } else if (state.bridgeConnected) {
  363. elements.gatewayBridgeStatus.textContent = '已连接,等待认证'
  364. } else {
  365. elements.gatewayBridgeStatus.textContent = '已启用,未连接'
  366. }
  367. if (state.connected && state.streaming) {
  368. elements.realtimeStatus.textContent = `桥接已连接,正在以 ${elements.hzSelect.value} Hz 连续发送`
  369. } else if (state.connected) {
  370. elements.realtimeStatus.textContent = '桥接已连接,待命中'
  371. } else if (state.socketConnecting) {
  372. elements.realtimeStatus.textContent = '桥接连接中'
  373. } else {
  374. elements.realtimeStatus.textContent = '桥接未连接'
  375. }
  376. if (state.heartRateConnected && state.heartRateStreaming) {
  377. elements.heartRateStatus.textContent = state.heartRateSampleMode
  378. ? `桥接已连接,正在以 ${elements.heartRateHzSelect.value} Hz 发送真实心率样本`
  379. : `桥接已连接,正在以 ${elements.heartRateHzSelect.value} Hz 连续发送心率`
  380. } else if (state.heartRateConnected) {
  381. elements.heartRateStatus.textContent = state.heartRateSampleMode ? '真实心率样本待命' : '心率模拟待命'
  382. } else if (state.heartRateSocketConnecting) {
  383. elements.heartRateStatus.textContent = '桥接连接中'
  384. } else {
  385. elements.heartRateStatus.textContent = '桥接未连接'
  386. }
  387. if (state.playbackRunning) {
  388. elements.playbackStatus.textContent = `路径回放中,速度 ${elements.speedInput.value} km/h`
  389. } else if (state.pathEditMode) {
  390. elements.playbackStatus.textContent = '路径编辑中,点击地图追加路径点'
  391. } else if (pathPoints.length >= 2) {
  392. elements.playbackStatus.textContent = `${state.lastTrackSourceText},共 ${pathPoints.length} 个路径点`
  393. } else {
  394. elements.playbackStatus.textContent = '路径待命'
  395. }
  396. setConnectionValue(
  397. elements.topGpsStatus,
  398. state.connected ? (state.streaming ? '发送中' : '已连接') : state.socketConnecting ? '连接中' : '未连接',
  399. state.connected ? 'ok' : state.socketConnecting ? 'warn' : null
  400. )
  401. setConnectionValue(
  402. elements.topHrStatus,
  403. state.heartRateConnected ? (state.heartRateStreaming ? '发送中' : '已连接') : state.heartRateSocketConnecting ? '连接中' : '未连接',
  404. state.heartRateConnected ? 'ok' : state.heartRateSocketConnecting ? 'warn' : null
  405. )
  406. setConnectionValue(
  407. elements.topLoggerStatus,
  408. state.debugConnected ? '已连接' : state.debugSocketConnecting ? '连接中' : '未连接',
  409. state.debugConnected ? 'ok' : state.debugSocketConnecting ? 'warn' : null
  410. )
  411. setConnectionValue(
  412. elements.topGatewayStatus,
  413. !state.bridgeEnabled ? '未启用' : state.bridgeConnected && state.bridgeAuthenticated ? '已认证' : state.bridgeConnected ? '待认证' : '未连接',
  414. state.bridgeConnected && state.bridgeAuthenticated ? 'ok' : state.bridgeEnabled ? 'warn' : null
  415. )
  416. if (elements.summaryResourceText) {
  417. elements.summaryResourceText.textContent = state.resourceLoading ? '载入中' : state.loadedCourse ? '已载入' : '未载入'
  418. }
  419. if (elements.summaryGpsSendText) {
  420. elements.summaryGpsSendText.textContent = state.connected ? (state.streaming ? `${elements.hzSelect.value} Hz` : '待命') : '未连接'
  421. }
  422. if (elements.summaryHrSendText) {
  423. elements.summaryHrSendText.textContent = state.heartRateConnected ? (state.heartRateStreaming ? `${elements.heartRateHzSelect.value} Hz` : '待命') : '未连接'
  424. }
  425. if (elements.summaryPathText) {
  426. elements.summaryPathText.textContent = state.playbackRunning ? '回放中' : state.pathEditMode ? '编辑中' : pathPoints.length >= 2 ? `${pathPoints.length} 点` : '待命'
  427. }
  428. if (elements.summaryGatewayText) {
  429. elements.summaryGatewayText.textContent = !state.bridgeEnabled ? '未启用' : state.bridgeConnected && state.bridgeAuthenticated ? '已认证' : state.bridgeConnected ? '待认证' : '未连接'
  430. }
  431. }
  432. function bridgeConfigFromServerPayload(payload) {
  433. const config = payload && payload.config ? payload.config : {}
  434. return {
  435. enabled: Boolean(config.enabled),
  436. url: normalizeGatewayBridgeUrl(typeof config.url === 'string' ? config.url : ''),
  437. token: typeof config.token === 'string' ? config.token : '',
  438. channelId: typeof config.channelId === 'string' ? config.channelId : '',
  439. deviceId: typeof config.deviceId === 'string' ? config.deviceId : '',
  440. groupId: typeof config.groupId === 'string' ? config.groupId : '',
  441. sourceId: typeof config.sourceId === 'string' ? config.sourceId : '',
  442. sourceMode: typeof config.sourceMode === 'string' ? config.sourceMode : 'mock',
  443. }
  444. }
  445. function normalizeGatewayBridgeUrl(value) {
  446. const next = String(value || '').trim()
  447. if (!next) {
  448. return DEFAULT_GATEWAY_BRIDGE_URL
  449. }
  450. if (LEGACY_GATEWAY_BRIDGE_URLS.has(next)) {
  451. return DEFAULT_GATEWAY_BRIDGE_URL
  452. }
  453. return next
  454. }
  455. function getBridgeConfigDraft() {
  456. try {
  457. const raw = window.localStorage.getItem(BRIDGE_CONFIG_STORAGE_KEY)
  458. if (!raw) {
  459. return null
  460. }
  461. const parsed = JSON.parse(raw)
  462. return {
  463. enabled: Boolean(parsed.enabled),
  464. url: normalizeGatewayBridgeUrl(typeof parsed.url === 'string' ? parsed.url : ''),
  465. token: typeof parsed.token === 'string' ? parsed.token : '',
  466. channelId: typeof parsed.channelId === 'string' ? parsed.channelId : '',
  467. deviceId: typeof parsed.deviceId === 'string' ? parsed.deviceId : '',
  468. groupId: typeof parsed.groupId === 'string' ? parsed.groupId : '',
  469. sourceId: typeof parsed.sourceId === 'string' ? parsed.sourceId : '',
  470. sourceMode: typeof parsed.sourceMode === 'string' ? parsed.sourceMode : 'mock',
  471. }
  472. } catch (_error) {
  473. return null
  474. }
  475. }
  476. function loadBridgePresets() {
  477. try {
  478. const raw = window.localStorage.getItem(BRIDGE_PRESETS_STORAGE_KEY)
  479. if (!raw) {
  480. return []
  481. }
  482. const parsed = JSON.parse(raw)
  483. if (!Array.isArray(parsed)) {
  484. return []
  485. }
  486. return parsed
  487. .map((item) => {
  488. const config = item && item.config ? item.config : {}
  489. return {
  490. name: item && typeof item.name === 'string' ? item.name.trim() : '',
  491. config: {
  492. enabled: Boolean(config.enabled),
  493. url: normalizeGatewayBridgeUrl(typeof config.url === 'string' ? config.url : ''),
  494. token: typeof config.token === 'string' ? config.token : '',
  495. channelId: typeof config.channelId === 'string' ? config.channelId : '',
  496. deviceId: typeof config.deviceId === 'string' ? config.deviceId : '',
  497. groupId: typeof config.groupId === 'string' ? config.groupId : '',
  498. sourceId: typeof config.sourceId === 'string' ? config.sourceId : '',
  499. sourceMode: typeof config.sourceMode === 'string' ? config.sourceMode : 'mock',
  500. },
  501. }
  502. })
  503. .filter((item) => item.name)
  504. } catch (_error) {
  505. return []
  506. }
  507. }
  508. function saveBridgePresets() {
  509. try {
  510. window.localStorage.setItem(BRIDGE_PRESETS_STORAGE_KEY, JSON.stringify(state.bridgePresets))
  511. } catch (_error) {
  512. // noop
  513. }
  514. }
  515. function renderBridgePresetOptions(selectedName) {
  516. const currentValue = typeof selectedName === 'string'
  517. ? selectedName
  518. : elements.gatewayBridgePresetSelect.value
  519. elements.gatewayBridgePresetSelect.innerHTML = '<option value="">选择预设</option>'
  520. state.bridgePresets.forEach((preset) => {
  521. const option = document.createElement('option')
  522. option.value = preset.name
  523. option.textContent = preset.name
  524. if (preset.name === currentValue) {
  525. option.selected = true
  526. }
  527. elements.gatewayBridgePresetSelect.appendChild(option)
  528. })
  529. }
  530. function saveBridgeConfigDraft(config) {
  531. try {
  532. window.localStorage.setItem(BRIDGE_CONFIG_STORAGE_KEY, JSON.stringify({
  533. ...config,
  534. url: normalizeGatewayBridgeUrl(config && config.url),
  535. }))
  536. } catch (_error) {
  537. // noop
  538. }
  539. }
  540. function fillBridgeConfigForm(config) {
  541. elements.gatewayBridgeEnabledInput.checked = Boolean(config.enabled)
  542. elements.gatewayBridgeUrlInput.value = normalizeGatewayBridgeUrl(config && config.url)
  543. elements.gatewayBridgeTokenInput.value = config.token || ''
  544. elements.gatewayBridgeChannelIdInput.value = config.channelId || ''
  545. elements.gatewayBridgeDeviceIdInput.value = config.deviceId || ''
  546. elements.gatewayBridgeGroupIdInput.value = config.groupId || ''
  547. elements.gatewayBridgeSourceIdInput.value = config.sourceId || ''
  548. elements.gatewayBridgeSourceModeInput.value = config.sourceMode || 'mock'
  549. }
  550. function readBridgeConfigForm() {
  551. return {
  552. enabled: elements.gatewayBridgeEnabledInput.checked,
  553. url: normalizeGatewayBridgeUrl(elements.gatewayBridgeUrlInput.value),
  554. token: String(elements.gatewayBridgeTokenInput.value || '').trim(),
  555. channelId: String(elements.gatewayBridgeChannelIdInput.value || '').trim(),
  556. deviceId: String(elements.gatewayBridgeDeviceIdInput.value || '').trim(),
  557. groupId: String(elements.gatewayBridgeGroupIdInput.value || '').trim(),
  558. sourceId: String(elements.gatewayBridgeSourceIdInput.value || '').trim(),
  559. sourceMode: String(elements.gatewayBridgeSourceModeInput.value || '').trim() || 'mock',
  560. }
  561. }
  562. function selectedBridgePreset() {
  563. const name = String(elements.gatewayBridgePresetSelect.value || '').trim()
  564. if (!name) {
  565. return null
  566. }
  567. return state.bridgePresets.find((item) => item.name === name) || null
  568. }
  569. function applyBridgePresetToForm() {
  570. const preset = selectedBridgePreset()
  571. if (!preset) {
  572. log('未选择桥接预设')
  573. return
  574. }
  575. fillBridgeConfigForm(preset.config)
  576. elements.gatewayBridgePresetNameInput.value = preset.name
  577. saveBridgeConfigDraft(preset.config)
  578. updateUiState()
  579. log(`已载入桥接预设: ${preset.name}`)
  580. }
  581. function saveCurrentBridgePreset() {
  582. const name = String(elements.gatewayBridgePresetNameInput.value || '').trim()
  583. if (!name) {
  584. log('请先输入预设名称')
  585. return
  586. }
  587. const config = readBridgeConfigForm()
  588. const nextPreset = { name, config }
  589. const existingIndex = state.bridgePresets.findIndex((item) => item.name === name)
  590. if (existingIndex >= 0) {
  591. state.bridgePresets.splice(existingIndex, 1, nextPreset)
  592. } else {
  593. state.bridgePresets.push(nextPreset)
  594. state.bridgePresets.sort((left, right) => left.name.localeCompare(right.name, 'zh-CN'))
  595. }
  596. saveBridgePresets()
  597. renderBridgePresetOptions(name)
  598. log(`已保存桥接预设: ${name}`)
  599. updateUiState()
  600. }
  601. function deleteSelectedBridgePreset() {
  602. const preset = selectedBridgePreset()
  603. if (!preset) {
  604. log('未选择桥接预设')
  605. return
  606. }
  607. state.bridgePresets = state.bridgePresets.filter((item) => item.name !== preset.name)
  608. saveBridgePresets()
  609. renderBridgePresetOptions('')
  610. if (elements.gatewayBridgePresetNameInput.value.trim() === preset.name) {
  611. elements.gatewayBridgePresetNameInput.value = ''
  612. }
  613. log(`已删除桥接预设: ${preset.name}`)
  614. updateUiState()
  615. }
  616. function connectSocket() {
  617. if (state.socket && (state.socket.readyState === WebSocket.OPEN || state.socket.readyState === WebSocket.CONNECTING)) {
  618. return
  619. }
  620. const socket = new WebSocket(GPS_WS_URL)
  621. state.socket = socket
  622. state.socketConnecting = true
  623. setSocketBadge(false)
  624. updateUiState()
  625. log(`连接 ${GPS_WS_URL}`)
  626. socket.addEventListener('open', () => {
  627. state.connected = true
  628. state.socketConnecting = false
  629. setSocketBadge(true)
  630. updateUiState()
  631. log('桥接已连接')
  632. })
  633. socket.addEventListener('close', () => {
  634. state.connected = false
  635. state.socketConnecting = false
  636. stopStream()
  637. setSocketBadge(false)
  638. updateUiState()
  639. log('桥接已断开')
  640. })
  641. socket.addEventListener('error', () => {
  642. state.connected = false
  643. state.socketConnecting = false
  644. stopStream()
  645. setSocketBadge(false)
  646. updateUiState()
  647. log('桥接连接失败')
  648. })
  649. }
  650. function connectHeartRateSocket() {
  651. if (state.heartRateSocket && (state.heartRateSocket.readyState === WebSocket.OPEN || state.heartRateSocket.readyState === WebSocket.CONNECTING)) {
  652. return
  653. }
  654. const socket = new WebSocket(HEART_RATE_WS_URL)
  655. state.heartRateSocket = socket
  656. state.heartRateSocketConnecting = true
  657. updateUiState()
  658. log(`连接心率模拟 ${HEART_RATE_WS_URL}`)
  659. socket.addEventListener('open', () => {
  660. state.heartRateConnected = true
  661. state.heartRateSocketConnecting = false
  662. updateUiState()
  663. log('心率模拟已连接')
  664. })
  665. socket.addEventListener('close', () => {
  666. state.heartRateConnected = false
  667. state.heartRateSocketConnecting = false
  668. state.heartRateSocket = null
  669. stopHeartRateStream()
  670. updateUiState()
  671. log('心率模拟已断开')
  672. })
  673. socket.addEventListener('error', () => {
  674. state.heartRateConnected = false
  675. state.heartRateSocketConnecting = false
  676. state.heartRateSocket = null
  677. stopHeartRateStream()
  678. updateUiState()
  679. log('心率模拟连接失败')
  680. })
  681. }
  682. function connectDebugSocket() {
  683. if (state.debugSocket && (state.debugSocket.readyState === WebSocket.OPEN || state.debugSocket.readyState === WebSocket.CONNECTING)) {
  684. return
  685. }
  686. const socket = new WebSocket(DEBUG_LOG_WS_URL)
  687. state.debugSocket = socket
  688. state.debugConnected = false
  689. state.debugSocketConnecting = true
  690. log(`连接日志通道 ${DEBUG_LOG_WS_URL}`)
  691. socket.addEventListener('message', (event) => {
  692. let parsed = null
  693. try {
  694. parsed = JSON.parse(String(event.data || ''))
  695. } catch (_error) {
  696. return
  697. }
  698. if (parsed && parsed.type === 'debug-log') {
  699. logDebug(parsed)
  700. }
  701. })
  702. socket.addEventListener('open', () => {
  703. state.debugSocketConnecting = false
  704. state.debugSocket = socket
  705. state.debugConnected = true
  706. log('日志通道已连接')
  707. updateUiState()
  708. })
  709. socket.addEventListener('close', () => {
  710. state.debugSocketConnecting = false
  711. state.debugSocket = null
  712. state.debugConnected = false
  713. log('日志通道已断开')
  714. updateUiState()
  715. window.setTimeout(connectDebugSocket, 1500)
  716. })
  717. socket.addEventListener('error', () => {
  718. state.debugSocketConnecting = false
  719. state.debugSocket = null
  720. state.debugConnected = false
  721. log('日志通道连接失败')
  722. updateUiState()
  723. })
  724. }
  725. async function refreshGatewayBridgeStatus() {
  726. try {
  727. const response = await fetch('/bridge-status', {
  728. cache: 'no-store',
  729. })
  730. if (!response.ok) {
  731. throw new Error(`HTTP ${response.status}`)
  732. }
  733. const status = await response.json()
  734. state.bridgeEnabled = Boolean(status.enabled)
  735. state.bridgeConnected = Boolean(status.connected)
  736. state.bridgeAuthenticated = Boolean(status.authenticated)
  737. if (status.channelId) {
  738. state.bridgeTargetText = `${status.channelId}${status.deviceId ? ` / ${status.deviceId}` : ''}${status.groupId ? ` / ${status.groupId}` : ''}`
  739. } else {
  740. state.bridgeTargetText = status.deviceId
  741. ? `${status.deviceId}${status.groupId ? ` / ${status.groupId}` : ''}`
  742. : '--'
  743. }
  744. state.bridgeLastStatusText = status.lastError
  745. ? `错误: ${status.lastError}`
  746. : status.lastSentAt
  747. ? `${status.lastSentTopic || 'unknown'} @ ${formatClockTime(status.lastSentAt)}`
  748. : '待命'
  749. updateUiState()
  750. } catch (_error) {
  751. state.bridgeEnabled = false
  752. state.bridgeConnected = false
  753. state.bridgeAuthenticated = false
  754. state.bridgeTargetText = '--'
  755. state.bridgeLastStatusText = '状态读取失败'
  756. updateUiState()
  757. }
  758. }
  759. async function loadGatewayBridgeConfig(options) {
  760. const preserveForm = Boolean(options && options.preserveForm)
  761. const response = await fetch('/bridge-config', {
  762. cache: 'no-store',
  763. })
  764. if (!response.ok) {
  765. throw new Error(`桥接配置读取失败: HTTP ${response.status}`)
  766. }
  767. const payload = await response.json()
  768. if (!preserveForm) {
  769. fillBridgeConfigForm(bridgeConfigFromServerPayload(payload))
  770. }
  771. return payload
  772. }
  773. async function applyGatewayBridgeConfig() {
  774. const config = readBridgeConfigForm()
  775. if (!config.url) {
  776. log('桥接配置缺少网关地址')
  777. return
  778. }
  779. if (!config.deviceId) {
  780. log('桥接配置缺少目标 Device ID')
  781. return
  782. }
  783. if (!config.sourceId) {
  784. log('桥接配置缺少 Source ID')
  785. return
  786. }
  787. state.bridgeConfigSaving = true
  788. updateUiState()
  789. try {
  790. const response = await fetch('/bridge-config', {
  791. method: 'POST',
  792. headers: {
  793. 'Content-Type': 'application/json',
  794. },
  795. body: JSON.stringify(config),
  796. })
  797. const payload = await response.json()
  798. if (!response.ok) {
  799. throw new Error(payload && payload.error ? payload.error : `HTTP ${response.status}`)
  800. }
  801. saveBridgeConfigDraft(config)
  802. fillBridgeConfigForm(bridgeConfigFromServerPayload(payload))
  803. await refreshGatewayBridgeStatus()
  804. log(`已应用新网关桥接配置 -> ${config.deviceId}`)
  805. } catch (error) {
  806. log(error && error.message ? error.message : '桥接配置应用失败')
  807. } finally {
  808. state.bridgeConfigSaving = false
  809. updateUiState()
  810. }
  811. }
  812. function proxyUrl(targetUrl) {
  813. return `${PROXY_BASE_URL}${encodeURIComponent(targetUrl)}`
  814. }
  815. async function fetchJson(targetUrl) {
  816. const response = await fetch(proxyUrl(targetUrl), { cache: 'no-store' })
  817. if (!response.ok) {
  818. throw new Error(`载入失败: ${response.status} ${targetUrl}`)
  819. }
  820. const text = await response.text()
  821. return parseJsonWithFallback(text)
  822. }
  823. async function fetchText(targetUrl) {
  824. const response = await fetch(proxyUrl(targetUrl), { cache: 'no-store' })
  825. if (!response.ok) {
  826. throw new Error(`载入失败: ${response.status} ${targetUrl}`)
  827. }
  828. return response.text()
  829. }
  830. function parseJsonWithFallback(text) {
  831. try {
  832. return JSON.parse(text)
  833. } catch (_error) {
  834. const sanitized = text
  835. .replace(/,\s*"center"\s*:\s*\[[^\]]*\]\s*(?=[}\r\n])/g, '')
  836. .replace(/"center"\s*:\s*\[[^\]]*\]\s*,/g, '')
  837. .replace(/,\s*([}\]])/g, '$1')
  838. return JSON.parse(sanitized)
  839. }
  840. }
  841. function resolveUrl(baseUrl, relativePath) {
  842. const trimmed = String(relativePath || '').trim()
  843. if (!trimmed) {
  844. return ''
  845. }
  846. if (/^https?:\/\//i.test(trimmed)) {
  847. return trimmed
  848. }
  849. const url = new URL(baseUrl)
  850. if (trimmed.startsWith('/')) {
  851. return `${url.origin}${trimmed}`
  852. }
  853. const baseDir = baseUrl.slice(0, baseUrl.lastIndexOf('/') + 1)
  854. return `${baseDir}${trimmed.replace(/^\.\//, '')}`
  855. }
  856. function joinUrl(rootUrl, relativePath) {
  857. const normalizedRoot = String(rootUrl || '').replace(/\/+$/, '')
  858. const normalizedPath = String(relativePath || '').replace(/^\/+/, '')
  859. return `${normalizedRoot}/${normalizedPath}`
  860. }
  861. function webMercatorToLatLng(x, y) {
  862. const lon = x / 20037508.34 * 180
  863. let lat = y / 20037508.34 * 180
  864. lat = 180 / Math.PI * (2 * Math.atan(Math.exp(lat * Math.PI / 180)) - Math.PI / 2)
  865. return L.latLng(lat, lon)
  866. }
  867. function applyTileTemplate(tileUrl, options) {
  868. const trimmed = String(tileUrl || '').trim()
  869. if (!trimmed) {
  870. throw new Error('瓦片模板不能为空')
  871. }
  872. if (tileLayer) {
  873. map.removeLayer(tileLayer)
  874. }
  875. tileLayer = createTileLayer(trimmed, options || {}).addTo(map)
  876. elements.tileUrlInput.value = trimmed
  877. }
  878. function fitBoundsFromMercator(bounds) {
  879. if (!Array.isArray(bounds) || bounds.length !== 4) {
  880. return
  881. }
  882. const southWest = webMercatorToLatLng(Number(bounds[0]), Number(bounds[1]))
  883. const northEast = webMercatorToLatLng(Number(bounds[2]), Number(bounds[3]))
  884. map.fitBounds(L.latLngBounds(southWest, northEast), { padding: [24, 24] })
  885. }
  886. function parseCoordinateTuple(rawValue) {
  887. const parts = rawValue.trim().split(',')
  888. if (parts.length < 2) {
  889. return null
  890. }
  891. const lon = Number(parts[0])
  892. const lat = Number(parts[1])
  893. if (!Number.isFinite(lon) || !Number.isFinite(lat)) {
  894. return null
  895. }
  896. return { lat, lon }
  897. }
  898. function extractPointCoordinates(block) {
  899. const pointMatch = block.match(/<Point\b[\s\S]*?<coordinates>([\s\S]*?)<\/coordinates>[\s\S]*?<\/Point>/i)
  900. if (!pointMatch) {
  901. return null
  902. }
  903. const coordinateMatch = pointMatch[1].trim().match(/-?\d+(?:\.\d+)?,-?\d+(?:\.\d+)?(?:,-?\d+(?:\.\d+)?)?/)
  904. return coordinateMatch ? parseCoordinateTuple(coordinateMatch[0]) : null
  905. }
  906. function decodeXmlEntities(text) {
  907. return text
  908. .replace(/&lt;/g, '<')
  909. .replace(/&gt;/g, '>')
  910. .replace(/&quot;/g, '"')
  911. .replace(/&#39;/g, "'")
  912. .replace(/&apos;/g, "'")
  913. .replace(/&amp;/g, '&')
  914. }
  915. function stripXml(text) {
  916. return decodeXmlEntities(String(text || '').replace(/<[^>]+>/g, ' ')).replace(/\s+/g, ' ').trim()
  917. }
  918. function extractTagText(block, tagName) {
  919. const match = block.match(new RegExp(`<${tagName}\\b[^>]*>([\\s\\S]*?)<\\/${tagName}>`, 'i'))
  920. return match ? stripXml(match[1]) : ''
  921. }
  922. function normalizeCourseLabel(label) {
  923. return String(label || '').trim().replace(/\s+/g, ' ')
  924. }
  925. function inferExplicitKind(label, placemarkBlock) {
  926. const normalized = normalizeCourseLabel(label).toUpperCase().replace(/[^A-Z0-9]/g, '')
  927. const styleHint = String(placemarkBlock || '').toUpperCase()
  928. if (
  929. normalized === 'S'
  930. || normalized.startsWith('START')
  931. || /^S\d+$/.test(normalized)
  932. || styleHint.includes('START')
  933. || styleHint.includes('TRIANGLE')
  934. ) {
  935. return 'start'
  936. }
  937. if (
  938. normalized === 'F'
  939. || normalized === 'M'
  940. || normalized.startsWith('FINISH')
  941. || normalized.startsWith('GOAL')
  942. || /^F\d+$/.test(normalized)
  943. || styleHint.includes('FINISH')
  944. || styleHint.includes('GOAL')
  945. ) {
  946. return 'finish'
  947. }
  948. return null
  949. }
  950. function extractPlacemarkPoints(kmlText) {
  951. const placemarkBlocks = kmlText.match(/<Placemark\b[\s\S]*?<\/Placemark>/gi) || []
  952. const points = []
  953. placemarkBlocks.forEach((placemarkBlock) => {
  954. const point = extractPointCoordinates(placemarkBlock)
  955. if (!point) {
  956. return
  957. }
  958. const label = normalizeCourseLabel(extractTagText(placemarkBlock, 'name'))
  959. points.push({
  960. label,
  961. point,
  962. explicitKind: inferExplicitKind(label, placemarkBlock),
  963. })
  964. })
  965. return points
  966. }
  967. function classifyOrderedNodes(points) {
  968. if (!points.length) {
  969. return []
  970. }
  971. const startIndex = points.findIndex((point) => point.explicitKind === 'start')
  972. let finishIndex = -1
  973. for (let index = points.length - 1; index >= 0; index -= 1) {
  974. if (points[index].explicitKind === 'finish') {
  975. finishIndex = index
  976. break
  977. }
  978. }
  979. return points.map((point, index) => {
  980. let kind = point.explicitKind
  981. if (!kind) {
  982. if (startIndex === -1 && index === 0) {
  983. kind = 'start'
  984. } else if (finishIndex === -1 && points.length > 1 && index === points.length - 1) {
  985. kind = 'finish'
  986. } else {
  987. kind = 'control'
  988. }
  989. }
  990. return {
  991. label: point.label,
  992. point: point.point,
  993. kind,
  994. }
  995. })
  996. }
  997. function parseCourseKml(kmlText) {
  998. const points = extractPlacemarkPoints(kmlText)
  999. if (!points.length) {
  1000. throw new Error('KML 中没有可用的 Point 控制点')
  1001. }
  1002. const nodes = classifyOrderedNodes(points)
  1003. const starts = []
  1004. const controls = []
  1005. const finishes = []
  1006. let controlSequence = 1
  1007. nodes.forEach((node) => {
  1008. if (node.kind === 'start') {
  1009. starts.push({
  1010. label: node.label || 'Start',
  1011. point: node.point,
  1012. })
  1013. return
  1014. }
  1015. if (node.kind === 'finish') {
  1016. finishes.push({
  1017. label: node.label || 'Finish',
  1018. point: node.point,
  1019. })
  1020. return
  1021. }
  1022. controls.push({
  1023. label: node.label || String(controlSequence),
  1024. sequence: controlSequence,
  1025. point: node.point,
  1026. })
  1027. controlSequence += 1
  1028. })
  1029. return {
  1030. title: extractTagText(kmlText, 'name') || 'Orienteering Course',
  1031. starts,
  1032. controls,
  1033. finishes,
  1034. }
  1035. }
  1036. function buildDivIcon(className, html, size) {
  1037. return L.divIcon({
  1038. className,
  1039. html,
  1040. iconSize: size,
  1041. iconAnchor: [size[0] / 2, size[1] / 2],
  1042. })
  1043. }
  1044. function setCurrentPosition(lat, lon) {
  1045. state.currentLatLng = L.latLng(lat, lon)
  1046. updateReadout()
  1047. }
  1048. function jumpToPoint(lat, lon, zoom) {
  1049. setCurrentPosition(lat, lon)
  1050. map.flyTo([lat, lon], zoom || Math.max(map.getZoom(), 18), {
  1051. duration: 0.6,
  1052. })
  1053. }
  1054. function buildJumpChip(label, point, className) {
  1055. const button = document.createElement('button')
  1056. button.type = 'button'
  1057. button.className = `jump-chip ${className || ''}`.trim()
  1058. button.textContent = label
  1059. button.addEventListener('click', () => {
  1060. jumpToPoint(point.lat, point.lon, 19)
  1061. log(`跳转到 ${label}`)
  1062. })
  1063. return button
  1064. }
  1065. function refreshCourseJumpList(course) {
  1066. elements.courseJumpList.innerHTML = ''
  1067. if (!course) {
  1068. return
  1069. }
  1070. course.starts.forEach((item) => {
  1071. elements.courseJumpList.appendChild(buildJumpChip('开始点', item.point, 'jump-chip--start'))
  1072. })
  1073. course.controls.forEach((item) => {
  1074. elements.courseJumpList.appendChild(buildJumpChip(String(item.sequence), item.point, ''))
  1075. })
  1076. course.finishes.forEach((item) => {
  1077. elements.courseJumpList.appendChild(buildJumpChip('结束点', item.point, 'jump-chip--finish'))
  1078. })
  1079. }
  1080. function renderCourse(course) {
  1081. courseLayer.clearLayers()
  1082. state.loadedCourse = course
  1083. refreshCourseJumpList(course)
  1084. course.starts.forEach((item) => {
  1085. const marker = L.marker([item.point.lat, item.point.lon], {
  1086. icon: buildDivIcon('course-marker', '<div class="course-marker__start"></div>', [36, 36]),
  1087. })
  1088. marker.on('click', () => jumpToPoint(item.point.lat, item.point.lon, 19))
  1089. marker.addTo(courseLayer)
  1090. })
  1091. course.controls.forEach((item) => {
  1092. const marker = L.marker([item.point.lat, item.point.lon], {
  1093. icon: buildDivIcon(
  1094. 'course-marker',
  1095. `<div class="course-marker__control">${item.sequence}</div>`,
  1096. [40, 40],
  1097. ),
  1098. })
  1099. marker.on('click', () => jumpToPoint(item.point.lat, item.point.lon, 19))
  1100. marker.addTo(courseLayer)
  1101. })
  1102. course.finishes.forEach((item) => {
  1103. const marker = L.marker([item.point.lat, item.point.lon], {
  1104. icon: buildDivIcon('course-marker', '<div class="course-marker__finish"></div>', [40, 40]),
  1105. })
  1106. marker.on('click', () => jumpToPoint(item.point.lat, item.point.lon, 19))
  1107. marker.addTo(courseLayer)
  1108. })
  1109. fitCourseBounds()
  1110. updateUiState()
  1111. }
  1112. function clearCourse() {
  1113. state.loadedCourse = null
  1114. courseLayer.clearLayers()
  1115. refreshCourseJumpList(null)
  1116. setResourceStatus('已清空控制点', 'warn')
  1117. state.lastResourceDetailText = '已清空控制点'
  1118. updateUiState()
  1119. }
  1120. function fitCourseBounds() {
  1121. if (!state.loadedCourse) {
  1122. return
  1123. }
  1124. const latLngs = []
  1125. state.loadedCourse.starts.forEach((item) => latLngs.push([item.point.lat, item.point.lon]))
  1126. state.loadedCourse.controls.forEach((item) => latLngs.push([item.point.lat, item.point.lon]))
  1127. state.loadedCourse.finishes.forEach((item) => latLngs.push([item.point.lat, item.point.lon]))
  1128. if (!latLngs.length) {
  1129. return
  1130. }
  1131. map.fitBounds(L.latLngBounds(latLngs), { padding: [30, 30] })
  1132. }
  1133. async function loadCourseFromUrl(courseUrl, shouldFit) {
  1134. const trimmed = String(courseUrl || '').trim()
  1135. if (!trimmed) {
  1136. throw new Error('KML 地址不能为空')
  1137. }
  1138. const kmlText = await fetchText(trimmed)
  1139. const course = parseCourseKml(kmlText)
  1140. renderCourse(course)
  1141. elements.courseUrlInput.value = trimmed
  1142. if (shouldFit !== false) {
  1143. fitCourseBounds()
  1144. }
  1145. setResourceStatus(`已载入控制点: ${course.title}`, 'ok')
  1146. state.lastResourceDetailText = `最近资源: 控制点 ${course.title} (${formatClockTime(Date.now())})`
  1147. log(`已载入 KML: ${trimmed}`)
  1148. updateUiState()
  1149. }
  1150. async function loadConfigResources() {
  1151. const configUrl = String(elements.configUrlInput.value || '').trim()
  1152. if (!configUrl) {
  1153. setResourceStatus('请先填写 game.json 地址', 'warn')
  1154. return
  1155. }
  1156. state.resourceLoading = true
  1157. updateUiState()
  1158. setResourceStatus('正在载入配置...', null)
  1159. try {
  1160. const config = await fetchJson(configUrl)
  1161. let mapStatus = '未找到瓦片配置'
  1162. if (config.map && config.mapmeta) {
  1163. const mapRootUrl = resolveUrl(configUrl, config.map)
  1164. const mapMetaUrl = resolveUrl(configUrl, config.mapmeta)
  1165. const mapMeta = await fetchJson(mapMetaUrl)
  1166. const tilePathTemplate = mapMeta.tilePathTemplate || `{z}/{x}/{y}.${mapMeta.tileFormat || 'png'}`
  1167. const tileTemplateUrl = /^https?:\/\//i.test(tilePathTemplate)
  1168. ? tilePathTemplate
  1169. : joinUrl(mapRootUrl, tilePathTemplate)
  1170. applyTileTemplate(tileTemplateUrl, {
  1171. minZoom: Number.isFinite(mapMeta.minZoom) ? mapMeta.minZoom : 16,
  1172. maxZoom: Number.isFinite(mapMeta.maxZoom) ? mapMeta.maxZoom : 20,
  1173. attribution: 'Custom Map',
  1174. })
  1175. mapStatus = '已载入瓦片'
  1176. if (Array.isArray(mapMeta.bounds) && mapMeta.bounds.length === 4) {
  1177. fitBoundsFromMercator(mapMeta.bounds)
  1178. }
  1179. }
  1180. let courseStatus = '未找到 KML 配置'
  1181. if (config.course) {
  1182. const courseUrl = resolveUrl(configUrl, config.course)
  1183. elements.courseUrlInput.value = courseUrl
  1184. await loadCourseFromUrl(courseUrl, false)
  1185. courseStatus = '已载入控制点'
  1186. }
  1187. setResourceStatus(`配置已载入: ${mapStatus} / ${courseStatus}`, 'ok')
  1188. state.lastResourceDetailText = `最近资源: 配置 ${formatClockTime(Date.now())}`
  1189. log(`已载入配置: ${configUrl}`)
  1190. } catch (error) {
  1191. const message = error && error.message ? error.message : '未知错误'
  1192. setResourceStatus(`配置载入失败: ${message}`, 'warn')
  1193. log(`配置载入失败: ${message}`)
  1194. } finally {
  1195. state.resourceLoading = false
  1196. updateUiState()
  1197. }
  1198. }
  1199. function getAccuracy() {
  1200. return Math.max(1, Number(elements.accuracyInput.value) || 6)
  1201. }
  1202. function getSpeedMps() {
  1203. return Math.max(0.2, (Number(elements.speedInput.value) || 6) / 3.6)
  1204. }
  1205. function getHeartRateBpm() {
  1206. return Math.max(40, Math.min(220, Math.round(Number(elements.heartRateInput.value) || 120)))
  1207. }
  1208. function getSampleHeartRateBpm() {
  1209. const now = Date.now()
  1210. if (!state.heartRateSampleStartedAt) {
  1211. state.heartRateSampleStartedAt = now
  1212. }
  1213. const elapsedSeconds = (now - state.heartRateSampleStartedAt) / 1000
  1214. const template = elements.heartRateSampleTemplateSelect.value || 'jog'
  1215. let cycleSeconds = 360
  1216. let bpm = 120
  1217. const jitter = Math.sin(elapsedSeconds * 1.7) * 1.8 + Math.sin(elapsedSeconds * 0.47) * 1.2
  1218. if (template === 'recovery') {
  1219. cycleSeconds = 300
  1220. const phase = elapsedSeconds % cycleSeconds
  1221. if (phase < 80) {
  1222. bpm = 82 + phase * 0.08
  1223. } else if (phase < 190) {
  1224. bpm = 89 + Math.sin((phase - 80) / 20) * 3
  1225. } else {
  1226. bpm = 90 - (phase - 190) * 0.06 + Math.sin((phase - 190) / 18) * 2
  1227. }
  1228. } else if (template === 'tempo') {
  1229. cycleSeconds = 320
  1230. const phase = elapsedSeconds % cycleSeconds
  1231. if (phase < 50) {
  1232. bpm = 102 + phase * 0.42
  1233. } else if (phase < 230) {
  1234. bpm = 124 + Math.sin((phase - 50) / 14) * 5 + Math.sin((phase - 50) / 36) * 3
  1235. } else {
  1236. bpm = 126 - (phase - 230) * 0.18 + Math.sin((phase - 230) / 12) * 3
  1237. }
  1238. } else if (template === 'interval') {
  1239. cycleSeconds = 260
  1240. const phase = elapsedSeconds % cycleSeconds
  1241. if (phase < 40) {
  1242. bpm = 100 + phase * 0.35
  1243. } else {
  1244. const wavePhase = phase - 40
  1245. const intervalCycle = wavePhase % 44
  1246. if (intervalCycle < 20) {
  1247. bpm = 140 + intervalCycle * 1.2
  1248. } else if (intervalCycle < 32) {
  1249. bpm = 164 - (intervalCycle - 20) * 0.45
  1250. } else {
  1251. bpm = 158 - (intervalCycle - 32) * 2.7
  1252. }
  1253. }
  1254. } else {
  1255. const phase = elapsedSeconds % cycleSeconds
  1256. if (phase < 60) {
  1257. bpm = 96 + phase * 0.35
  1258. } else if (phase < 150) {
  1259. bpm = 118 + Math.sin((phase - 60) / 18) * 6
  1260. } else if (phase < 240) {
  1261. bpm = 138 + Math.sin((phase - 150) / 10) * 9
  1262. } else if (phase < 300) {
  1263. bpm = 158 + Math.sin((phase - 240) / 7) * 8
  1264. } else {
  1265. bpm = 124 - (phase - 300) * 0.22 + Math.sin((phase - 300) / 15) * 4
  1266. }
  1267. }
  1268. const nextBpm = Math.max(72, Math.min(182, Math.round(bpm + jitter)))
  1269. elements.heartRateInput.value = String(nextBpm)
  1270. return nextBpm
  1271. }
  1272. function sendCurrentPoint() {
  1273. if (!state.socket || state.socket.readyState !== WebSocket.OPEN) {
  1274. log('未连接桥接,无法发送')
  1275. return
  1276. }
  1277. const payload = {
  1278. type: 'mock_gps',
  1279. timestamp: Date.now(),
  1280. channelId: state.simChannelId,
  1281. lat: Number(state.currentLatLng.lat.toFixed(6)),
  1282. lon: Number(state.currentLatLng.lng.toFixed(6)),
  1283. accuracyMeters: getAccuracy(),
  1284. speedMps: Number(getSpeedMps().toFixed(2)),
  1285. headingDeg: Number(state.headingDeg.toFixed(1)),
  1286. }
  1287. state.socket.send(JSON.stringify(payload))
  1288. state.lastSentText = `${formatClockTime(payload.timestamp)} @ ${payload.lat.toFixed(6)}, ${payload.lon.toFixed(6)}`
  1289. updateUiState()
  1290. }
  1291. function sendCurrentHeartRate() {
  1292. if (!state.heartRateSocket || state.heartRateSocket.readyState !== WebSocket.OPEN) {
  1293. log('未连接心率模拟,无法发送心率')
  1294. return
  1295. }
  1296. const payload = {
  1297. type: 'mock_heart_rate',
  1298. timestamp: Date.now(),
  1299. channelId: state.simChannelId,
  1300. bpm: state.heartRateSampleMode ? getSampleHeartRateBpm() : getHeartRateBpm(),
  1301. }
  1302. state.heartRateSocket.send(JSON.stringify(payload))
  1303. state.lastHeartRateSentText = `${formatClockTime(payload.timestamp)} @ ${payload.bpm} bpm`
  1304. updateUiState()
  1305. }
  1306. function startStream() {
  1307. stopStream()
  1308. state.streaming = true
  1309. const intervalMs = Math.max(80, 1000 / (Number(elements.hzSelect.value) || 5))
  1310. sendCurrentPoint()
  1311. state.streamTimer = window.setInterval(sendCurrentPoint, intervalMs)
  1312. updateUiState()
  1313. log(`开始连续发送 (${Math.round(1000 / intervalMs)} Hz)`)
  1314. }
  1315. function stopStream() {
  1316. state.streaming = false
  1317. if (state.streamTimer) {
  1318. window.clearInterval(state.streamTimer)
  1319. state.streamTimer = 0
  1320. log('已停止连续发送')
  1321. }
  1322. updateUiState()
  1323. }
  1324. function startHeartRateStream() {
  1325. stopHeartRateStream()
  1326. state.heartRateStreaming = true
  1327. if (state.heartRateSampleMode && !state.heartRateSampleStartedAt) {
  1328. state.heartRateSampleStartedAt = Date.now()
  1329. }
  1330. const intervalMs = Math.max(150, 1000 / (Number(elements.heartRateHzSelect.value) || 1))
  1331. sendCurrentHeartRate()
  1332. state.heartRateStreamTimer = window.setInterval(sendCurrentHeartRate, intervalMs)
  1333. updateUiState()
  1334. log(`开始连续发送心率 (${Math.round(1000 / intervalMs)} Hz)`)
  1335. }
  1336. function stopHeartRateStream() {
  1337. state.heartRateStreaming = false
  1338. if (state.heartRateStreamTimer) {
  1339. window.clearInterval(state.heartRateStreamTimer)
  1340. state.heartRateStreamTimer = 0
  1341. log('已停止连续发送心率')
  1342. }
  1343. updateUiState()
  1344. }
  1345. function applyHeartRatePreset() {
  1346. const sampleBpm = [88, 102, 118, 136, 154, 170]
  1347. const current = getHeartRateBpm()
  1348. let nextIndex = sampleBpm.findIndex((value) => value > current)
  1349. if (nextIndex === -1) {
  1350. nextIndex = 0
  1351. }
  1352. elements.heartRateInput.value = String(sampleBpm[nextIndex])
  1353. log(`已应用心率分区样本: ${sampleBpm[nextIndex]} bpm`)
  1354. }
  1355. function toggleHeartRateSampleMode() {
  1356. state.heartRateSampleMode = !state.heartRateSampleMode
  1357. state.heartRateSampleStartedAt = state.heartRateSampleMode ? Date.now() : 0
  1358. if (state.heartRateSampleMode) {
  1359. const bpm = getSampleHeartRateBpm()
  1360. log(`已开启真实心率样本 (${elements.heartRateSampleTemplateSelect.value || 'jog'}): ${bpm} bpm`)
  1361. } else {
  1362. log('已关闭真实心率样本')
  1363. }
  1364. updateUiState()
  1365. }
  1366. function syncPathLine() {
  1367. pathLine.setLatLngs(pathPoints)
  1368. elements.pathCountText.textContent = String(pathPoints.length)
  1369. updateUiState()
  1370. }
  1371. function clearPathMarkers() {
  1372. while (pathMarkers.length) {
  1373. map.removeLayer(pathMarkers.pop())
  1374. }
  1375. }
  1376. function refreshPathMarkers() {
  1377. clearPathMarkers()
  1378. pathPoints.forEach((point, index) => {
  1379. const marker = L.circleMarker(point, {
  1380. radius: 5,
  1381. color: '#ffffff',
  1382. weight: 2,
  1383. fillColor: index === 0 ? '#0ea5a4' : '#0b625b',
  1384. fillOpacity: 0.95,
  1385. }).addTo(map)
  1386. pathMarkers.push(marker)
  1387. })
  1388. }
  1389. function addPathPoint(latlng) {
  1390. pathPoints.push(L.latLng(latlng.lat, latlng.lng))
  1391. state.lastTrackSourceText = '手工路径'
  1392. syncPathLine()
  1393. refreshPathMarkers()
  1394. }
  1395. function fitPathBounds() {
  1396. if (pathPoints.length < 2) {
  1397. return
  1398. }
  1399. map.fitBounds(L.latLngBounds(pathPoints), { padding: [30, 30] })
  1400. }
  1401. function replacePathPoints(nextPoints, sourceLabel) {
  1402. pathPoints.splice(0, pathPoints.length)
  1403. nextPoints.forEach((point) => {
  1404. pathPoints.push(L.latLng(point.lat, point.lng))
  1405. })
  1406. state.lastTrackSourceText = sourceLabel
  1407. stopPlayback()
  1408. syncPathLine()
  1409. refreshPathMarkers()
  1410. if (pathPoints.length) {
  1411. state.currentLatLng = L.latLng(pathPoints[0].lat, pathPoints[0].lng)
  1412. updateReadout()
  1413. }
  1414. if (pathPoints.length >= 2) {
  1415. fitPathBounds()
  1416. }
  1417. }
  1418. function parseGeoJsonTrack(rawValue) {
  1419. const latLngs = []
  1420. function pushLngLat(coords) {
  1421. if (!Array.isArray(coords) || coords.length < 2) {
  1422. return
  1423. }
  1424. const lng = Number(coords[0])
  1425. const lat = Number(coords[1])
  1426. if (Number.isFinite(lat) && Number.isFinite(lng)) {
  1427. latLngs.push({ lat, lng })
  1428. }
  1429. }
  1430. function walk(node) {
  1431. if (!node || typeof node !== 'object') {
  1432. return
  1433. }
  1434. if (node.type === 'FeatureCollection' && Array.isArray(node.features)) {
  1435. node.features.forEach(walk)
  1436. return
  1437. }
  1438. if (node.type === 'Feature' && node.geometry) {
  1439. walk(node.geometry)
  1440. return
  1441. }
  1442. if (node.type === 'LineString' && Array.isArray(node.coordinates)) {
  1443. node.coordinates.forEach(pushLngLat)
  1444. return
  1445. }
  1446. if (node.type === 'MultiLineString' && Array.isArray(node.coordinates)) {
  1447. node.coordinates.forEach((line) => {
  1448. if (Array.isArray(line)) {
  1449. line.forEach(pushLngLat)
  1450. }
  1451. })
  1452. }
  1453. }
  1454. if (Array.isArray(rawValue)) {
  1455. rawValue.forEach((item) => {
  1456. if (Array.isArray(item)) {
  1457. pushLngLat(item)
  1458. return
  1459. }
  1460. if (item && typeof item === 'object') {
  1461. const lat = Number(item.lat)
  1462. const lng = Number(item.lng !== undefined ? item.lng : item.lon)
  1463. if (Number.isFinite(lat) && Number.isFinite(lng)) {
  1464. latLngs.push({ lat, lng })
  1465. }
  1466. }
  1467. })
  1468. return latLngs
  1469. }
  1470. walk(rawValue)
  1471. return latLngs
  1472. }
  1473. function parseGpxTrack(text) {
  1474. const xml = new DOMParser().parseFromString(text, 'application/xml')
  1475. const latLngs = []
  1476. const trackPoints = Array.from(xml.querySelectorAll('trkpt'))
  1477. const routePoints = trackPoints.length ? [] : Array.from(xml.querySelectorAll('rtept'))
  1478. const nodes = trackPoints.length ? trackPoints : routePoints
  1479. nodes.forEach((node) => {
  1480. const lat = Number(node.getAttribute('lat'))
  1481. const lng = Number(node.getAttribute('lon'))
  1482. if (Number.isFinite(lat) && Number.isFinite(lng)) {
  1483. latLngs.push({ lat, lng })
  1484. }
  1485. })
  1486. return latLngs
  1487. }
  1488. function parseKmlTrack(text) {
  1489. const xml = new DOMParser().parseFromString(text, 'application/xml')
  1490. const latLngs = []
  1491. const lineStrings = Array.from(xml.querySelectorAll('LineString coordinates'))
  1492. lineStrings.forEach((node) => {
  1493. String(node.textContent || '')
  1494. .trim()
  1495. .split(/\s+/)
  1496. .forEach((tuple) => {
  1497. const parsed = parseCoordinateTuple(tuple)
  1498. if (parsed) {
  1499. latLngs.push({ lat: parsed.lat, lng: parsed.lon })
  1500. }
  1501. })
  1502. })
  1503. return latLngs
  1504. }
  1505. function parseTrackFile(fileName, text) {
  1506. const lowerName = String(fileName || '').toLowerCase()
  1507. if (lowerName.endsWith('.gpx')) {
  1508. return parseGpxTrack(text)
  1509. }
  1510. if (lowerName.endsWith('.kml')) {
  1511. return parseKmlTrack(text)
  1512. }
  1513. if (lowerName.endsWith('.geojson') || lowerName.endsWith('.json')) {
  1514. return parseGeoJsonTrack(parseJsonWithFallback(text))
  1515. }
  1516. if (text.includes('<gpx')) {
  1517. return parseGpxTrack(text)
  1518. }
  1519. if (text.includes('<kml') || text.includes('<LineString')) {
  1520. return parseKmlTrack(text)
  1521. }
  1522. return parseGeoJsonTrack(parseJsonWithFallback(text))
  1523. }
  1524. async function handleTrackFileSelected(file) {
  1525. if (!file) {
  1526. return
  1527. }
  1528. try {
  1529. const text = await file.text()
  1530. const latLngs = parseTrackFile(file.name, text)
  1531. if (!latLngs || latLngs.length < 2) {
  1532. throw new Error('轨迹文件中没有可回放的路径点')
  1533. }
  1534. replacePathPoints(latLngs, `轨迹文件 ${file.name}`)
  1535. log(`已导入轨迹文件: ${file.name} (${latLngs.length} 点)`)
  1536. } catch (error) {
  1537. const message = error && error.message ? error.message : '轨迹文件导入失败'
  1538. log(message)
  1539. alert(message)
  1540. } finally {
  1541. elements.trackFileInput.value = ''
  1542. }
  1543. }
  1544. function toRad(value) {
  1545. return value * Math.PI / 180
  1546. }
  1547. function toDeg(value) {
  1548. return value * 180 / Math.PI
  1549. }
  1550. function getDistanceMeters(from, to) {
  1551. const earth = 6371000
  1552. const lat1 = toRad(from.lat)
  1553. const lat2 = toRad(to.lat)
  1554. const dLat = lat2 - lat1
  1555. const dLon = toRad(to.lng - from.lng)
  1556. const a = Math.sin(dLat / 2) * Math.sin(dLat / 2)
  1557. + Math.cos(lat1) * Math.cos(lat2) * Math.sin(dLon / 2) * Math.sin(dLon / 2)
  1558. return earth * 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a))
  1559. }
  1560. function getHeadingDeg(from, to) {
  1561. const lat1 = toRad(from.lat)
  1562. const lat2 = toRad(to.lat)
  1563. const dLon = toRad(to.lng - from.lng)
  1564. const y = Math.sin(dLon) * Math.cos(lat2)
  1565. const x = Math.cos(lat1) * Math.sin(lat2) - Math.sin(lat1) * Math.cos(lat2) * Math.cos(dLon)
  1566. const bearing = (toDeg(Math.atan2(y, x)) + 360) % 360
  1567. return bearing
  1568. }
  1569. function interpolateLatLng(from, to, t) {
  1570. return L.latLng(
  1571. from.lat + (to.lat - from.lat) * t,
  1572. from.lng + (to.lng - from.lng) * t,
  1573. )
  1574. }
  1575. function tickPlayback() {
  1576. if (!state.playbackRunning || pathPoints.length < 2) {
  1577. return
  1578. }
  1579. const now = performance.now()
  1580. if (!state.lastPlaybackAt) {
  1581. state.lastPlaybackAt = now
  1582. }
  1583. const deltaSeconds = (now - state.lastPlaybackAt) / 1000
  1584. state.lastPlaybackAt = now
  1585. let remainingTravel = getSpeedMps() * deltaSeconds
  1586. while (remainingTravel > 0 && state.currentSegmentIndex < pathPoints.length - 1) {
  1587. const from = pathPoints[state.currentSegmentIndex]
  1588. const to = pathPoints[state.currentSegmentIndex + 1]
  1589. const segmentDistance = getDistanceMeters(from, to)
  1590. if (!segmentDistance) {
  1591. state.currentSegmentIndex += 1
  1592. state.currentSegmentProgress = 0
  1593. continue
  1594. }
  1595. const remainingSegment = segmentDistance * (1 - state.currentSegmentProgress)
  1596. if (remainingTravel >= remainingSegment) {
  1597. remainingTravel -= remainingSegment
  1598. state.currentSegmentIndex += 1
  1599. state.currentSegmentProgress = 0
  1600. state.currentLatLng = L.latLng(to.lat, to.lng)
  1601. state.headingDeg = getHeadingDeg(from, to)
  1602. } else {
  1603. state.currentSegmentProgress += remainingTravel / segmentDistance
  1604. state.currentLatLng = interpolateLatLng(from, to, state.currentSegmentProgress)
  1605. state.headingDeg = getHeadingDeg(from, to)
  1606. remainingTravel = 0
  1607. }
  1608. }
  1609. if (state.currentSegmentIndex >= pathPoints.length - 1) {
  1610. if (elements.loopPathInput.checked) {
  1611. state.currentSegmentIndex = 0
  1612. state.currentSegmentProgress = 0
  1613. state.currentLatLng = L.latLng(pathPoints[0].lat, pathPoints[0].lng)
  1614. } else {
  1615. stopPlayback()
  1616. }
  1617. }
  1618. updateReadout()
  1619. if (state.streaming) {
  1620. sendCurrentPoint()
  1621. }
  1622. if (state.playbackRunning) {
  1623. state.playbackTimer = window.requestAnimationFrame(tickPlayback)
  1624. }
  1625. }
  1626. function startPlayback() {
  1627. if (pathPoints.length < 2) {
  1628. log('至少需要两个路径点')
  1629. return
  1630. }
  1631. stopPlayback()
  1632. state.playbackRunning = true
  1633. state.currentSegmentIndex = 0
  1634. state.currentSegmentProgress = 0
  1635. state.currentLatLng = L.latLng(pathPoints[0].lat, pathPoints[0].lng)
  1636. state.lastPlaybackAt = 0
  1637. updateReadout()
  1638. updateUiState()
  1639. log('开始路径回放')
  1640. state.playbackTimer = window.requestAnimationFrame(tickPlayback)
  1641. }
  1642. function stopPlayback() {
  1643. state.playbackRunning = false
  1644. state.lastPlaybackAt = 0
  1645. if (state.playbackTimer) {
  1646. window.cancelAnimationFrame(state.playbackTimer)
  1647. state.playbackTimer = 0
  1648. }
  1649. updateUiState()
  1650. }
  1651. map.on('click', (event) => {
  1652. if (state.pathEditMode) {
  1653. addPathPoint(event.latlng)
  1654. return
  1655. }
  1656. setCurrentPosition(event.latlng.lat, event.latlng.lng)
  1657. })
  1658. liveMarker.on('mousedown', () => {
  1659. map.dragging.disable()
  1660. })
  1661. map.on('mousemove', (event) => {
  1662. if (event.originalEvent.buttons !== 1) {
  1663. return
  1664. }
  1665. if (state.pathEditMode) {
  1666. return
  1667. }
  1668. setCurrentPosition(event.latlng.lat, event.latlng.lng)
  1669. })
  1670. map.on('mouseup', () => {
  1671. map.dragging.enable()
  1672. })
  1673. elements.connectBtn.addEventListener('click', connectSocket)
  1674. if (elements.simChannelIdInput) {
  1675. elements.simChannelIdInput.addEventListener('change', () => {
  1676. applySimChannelId(elements.simChannelIdInput.value, true)
  1677. log(`已切换模拟通道 ${state.simChannelId}`)
  1678. })
  1679. }
  1680. elements.applyGatewayBridgePresetBtn.addEventListener('click', applyBridgePresetToForm)
  1681. elements.saveGatewayBridgePresetBtn.addEventListener('click', saveCurrentBridgePreset)
  1682. elements.deleteGatewayBridgePresetBtn.addEventListener('click', deleteSelectedBridgePreset)
  1683. elements.gatewayBridgePresetSelect.addEventListener('change', () => {
  1684. const preset = selectedBridgePreset()
  1685. elements.gatewayBridgePresetNameInput.value = preset ? preset.name : ''
  1686. updateUiState()
  1687. })
  1688. elements.applyGatewayBridgeConfigBtn.addEventListener('click', applyGatewayBridgeConfig)
  1689. elements.reloadGatewayBridgeConfigBtn.addEventListener('click', async () => {
  1690. try {
  1691. await loadGatewayBridgeConfig()
  1692. await refreshGatewayBridgeStatus()
  1693. log('已重新读取桥接配置')
  1694. } catch (error) {
  1695. log(error && error.message ? error.message : '桥接配置读取失败')
  1696. }
  1697. })
  1698. elements.importTrackBtn.addEventListener('click', () => {
  1699. elements.trackFileInput.click()
  1700. })
  1701. elements.trackFileInput.addEventListener('change', (event) => {
  1702. const input = event.target
  1703. const file = input && input.files && input.files[0] ? input.files[0] : null
  1704. handleTrackFileSelected(file)
  1705. })
  1706. elements.loadConfigBtn.addEventListener('click', loadConfigResources)
  1707. elements.fitCourseBtn.addEventListener('click', fitCourseBounds)
  1708. elements.applyTilesBtn.addEventListener('click', () => {
  1709. try {
  1710. applyTileTemplate(elements.tileUrlInput.value, { attribution: 'Custom Map' })
  1711. setResourceStatus('已应用自定义瓦片', 'ok')
  1712. state.lastResourceDetailText = `最近资源: 自定义瓦片 ${formatClockTime(Date.now())}`
  1713. updateUiState()
  1714. } catch (error) {
  1715. setResourceStatus(error && error.message ? error.message : '瓦片应用失败', 'warn')
  1716. }
  1717. })
  1718. elements.resetTilesBtn.addEventListener('click', () => {
  1719. applyTileTemplate(DEFAULT_TILE_URL, {
  1720. maxZoom: 20,
  1721. attribution: '&copy; OpenStreetMap',
  1722. })
  1723. setResourceStatus('已恢复 OSM 底图', 'ok')
  1724. state.lastResourceDetailText = `最近资源: OSM 底图 ${formatClockTime(Date.now())}`
  1725. updateUiState()
  1726. })
  1727. elements.loadCourseBtn.addEventListener('click', async () => {
  1728. try {
  1729. await loadCourseFromUrl(elements.courseUrlInput.value, true)
  1730. } catch (error) {
  1731. const message = error && error.message ? error.message : 'KML 载入失败'
  1732. setResourceStatus(message, 'warn')
  1733. log(message)
  1734. }
  1735. })
  1736. elements.clearCourseBtn.addEventListener('click', clearCourse)
  1737. elements.fitPathBtn.addEventListener('click', fitPathBounds)
  1738. elements.sendOnceBtn.addEventListener('click', () => {
  1739. sendCurrentPoint()
  1740. log('已发送当前位置')
  1741. })
  1742. elements.streamBtn.addEventListener('click', startStream)
  1743. elements.stopStreamBtn.addEventListener('click', stopStream)
  1744. elements.sendHeartRateOnceBtn.addEventListener('click', () => {
  1745. sendCurrentHeartRate()
  1746. log('已发送当前心率')
  1747. })
  1748. elements.startHeartRateStreamBtn.addEventListener('click', startHeartRateStream)
  1749. elements.stopHeartRateStreamBtn.addEventListener('click', stopHeartRateStream)
  1750. elements.applyHeartRatePresetBtn.addEventListener('click', applyHeartRatePreset)
  1751. elements.toggleHeartRateSampleBtn.addEventListener('click', toggleHeartRateSampleMode)
  1752. elements.togglePathModeBtn.addEventListener('click', () => {
  1753. state.pathEditMode = !state.pathEditMode
  1754. elements.pathHint.textContent = state.pathEditMode
  1755. ? '地图点击将按顺序追加路径点。'
  1756. : '点击“开启路径编辑”后,在地图上逐点添加路径。'
  1757. updateUiState()
  1758. })
  1759. elements.clearPathBtn.addEventListener('click', () => {
  1760. pathPoints.splice(0, pathPoints.length)
  1761. state.lastTrackSourceText = '路径待命'
  1762. syncPathLine()
  1763. clearPathMarkers()
  1764. stopPlayback()
  1765. log('已清空路径')
  1766. })
  1767. elements.playPathBtn.addEventListener('click', startPlayback)
  1768. elements.pausePathBtn.addEventListener('click', () => {
  1769. stopPlayback()
  1770. log('已暂停回放')
  1771. })
  1772. if (elements.clearDebugLogBtn) {
  1773. elements.clearDebugLogBtn.addEventListener('click', clearDebugLog)
  1774. }
  1775. if (elements.toggleDebugLogPanelBtn) {
  1776. elements.toggleDebugLogPanelBtn.addEventListener('click', () => {
  1777. state.debugLogPanelMinimized = !state.debugLogPanelMinimized
  1778. updateDebugLogPanelState()
  1779. })
  1780. }
  1781. if (elements.debugLogScopeFilter) {
  1782. elements.debugLogScopeFilter.addEventListener('change', () => {
  1783. state.debugLogScopeFilter = elements.debugLogScopeFilter.value || 'all'
  1784. renderDebugLog()
  1785. })
  1786. }
  1787. updateReadout()
  1788. setSocketBadge(false)
  1789. renderDebugScopeOptions()
  1790. renderDebugLog()
  1791. updateDebugLogPanelState()
  1792. setResourceStatus('支持直接载入 game.json,也支持单独填瓦片模板和 KML 地址。', null)
  1793. state.bridgePresets = loadBridgePresets()
  1794. renderBridgePresetOptions('')
  1795. updateUiState()
  1796. const draftBridgeConfig = getBridgeConfigDraft()
  1797. if (draftBridgeConfig) {
  1798. fillBridgeConfigForm(draftBridgeConfig)
  1799. }
  1800. loadGatewayBridgeConfig({ preserveForm: Boolean(draftBridgeConfig) })
  1801. .then(async () => {
  1802. if (draftBridgeConfig) {
  1803. log('已恢复上次桥接配置草稿,可直接点“应用桥接配置”')
  1804. }
  1805. await refreshGatewayBridgeStatus()
  1806. })
  1807. .catch((error) => {
  1808. log(error && error.message ? error.message : '桥接配置读取失败')
  1809. refreshGatewayBridgeStatus()
  1810. })
  1811. refreshGatewayBridgeStatus()
  1812. window.setInterval(refreshGatewayBridgeStatus, 3000)
  1813. connectSocket()
  1814. connectHeartRateSocket()
  1815. connectDebugSocket()
  1816. })()