simulator.js 69 KB

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