多普勒写频 (#35)

* 支持UVE5欢迎界面写频

* 支持UVE5固件烧录

* UVE5存储区扩大到512KB

* 多普勒写频

* UVE5自动校准时间

Author: losehu

src/components/navbar/index.vue

@@ -175,7 +175,7 @@
   import useLocale from '@/hooks/locale';
   import useUser from '@/hooks/user';
   import Menu from '@/components/menu/index.vue';
-  import { connect, disconnect, eeprom_init } from '@/utils/serial.js';
+  import { connect, disconnect, eeprom_init, rtc_sync_beijing } from '@/utils/serial.js';
   import { useI18n } from 'vue-i18n';
   const { t } = useI18n();
   const drivers = import.meta.glob('@/drivers/*.json', { eager: true });
@@ -308,6 +308,12 @@
         }
       })
 
+      // Auto sync device RTC to current Beijing time on connect (best effort).
+      // Only do this for UVE builds to avoid slowing down other firmwares.
+      if (/^UVE/i.test(version)) {
+        try { await rtc_sync_beijing(_connect); } catch {}
+      }
+
       appStore.updateSettings({ connectState: true, firmwareVersion: version, configuration: _configuration });
     }else{
       await disconnect(appStore.connectPort);

src/store/modules/app/index.ts

@@ -16,6 +16,9 @@ const useAppStore = defineStore('app', {
     appDevice(state: AppState) {
       return state.device;
     },
+    isUve5(state: AppState): boolean {
+      return typeof state.firmwareVersion === 'string' && state.firmwareVersion.startsWith('UVE');
+    },
     appAsyncMenus(state: AppState): RouteRecordNormalized[] {
       return state.serverMenu as unknown as RouteRecordNormalized[];
     },

src/store/modules/app/types.ts

@@ -16,5 +16,12 @@ export interface AppState {
   tabBar: boolean;
   menuFromServer: boolean;
   serverMenu: RouteRecordNormalized[];
+
+  // Device connection/runtime info (set on successful handshake in navbar connect)
+  connectState?: boolean;
+  connectPort?: unknown;
+  firmwareVersion?: string;
+  configuration?: unknown;
+
   [key: string]: unknown;
 }

src/utils/serial.js

@@ -1368,6 +1368,64 @@ async function eeprom_init(port) {
     return decoder.decode(version.slice(0, version.indexOf(0)));
 }
 
+function getBeijingDateParts(date = new Date()) {
+    const dtf = new Intl.DateTimeFormat('en-GB', {
+        timeZone: 'Asia/Shanghai',
+        year: 'numeric',
+        month: '2-digit',
+        day: '2-digit',
+        hour: '2-digit',
+        minute: '2-digit',
+        second: '2-digit',
+        hour12: false,
+    });
+    const parts = dtf.formatToParts(date);
+    const map = {};
+    for (const p of parts) {
+        if (p.type !== 'literal') map[p.type] = p.value;
+    }
+    return {
+        year: Number(map.year),
+        month: Number(map.month),
+        day: Number(map.day),
+        hour: Number(map.hour),
+        minute: Number(map.minute),
+        second: Number(map.second),
+    };
+}
+
+// Sync RTC on connect: send current Beijing time to device.
+// Firmware command:
+//   0x0610 (len=8): uint16 year, uint8 month,day,hour,minute,second, uint8 flags
+// Reply:
+//   0x0611 (len=1): uint8 status (0=OK)
+async function rtc_sync_beijing(port, { timeout = 600 } = {}) {
+    sessionStorage.removeItem('webusb')
+    const { year, month, day, hour, minute, second } = getBeijingDateParts();
+    const year_l = year & 0xff;
+    const year_h = (year >> 8) & 0xff;
+    const flags = 0x01;
+    const packet = new Uint8Array([
+        0x10, 0x06, // ID 0x0610
+        0x08, 0x00, // len=8
+        year_l, year_h,
+        month & 0xff,
+        day & 0xff,
+        hour & 0xff,
+        minute & 0xff,
+        second & 0xff,
+        flags,
+    ]);
+    await sendPacket(port, packet);
+    try {
+        const resp = await readPacket(port, 0x11, timeout);
+        return resp && resp.length >= 5 ? resp[4] : 0xff;
+    } catch (e) {
+        console.warn('rtc_sync_beijing: no reply (ignored)', e);
+        return null;
+    }
+}
+
 async function eeprom_read(port, address, size = 0x80, protocol = "official") {
     sessionStorage.removeItem('webusb')
     if (protocol == "official") {
@@ -1892,5 +1950,6 @@ export {
     readPacketNoVerify,
     uve5_flashFirmware,
     sendSMSPacket,
-    readSMSPacket
-}
+    readSMSPacket,
+    rtc_sync_beijing
+}

src/views/list/sat2/index.vue

@@ -68,12 +68,16 @@
 <script lang="ts" setup>
 import { ref, reactive, nextTick, onMounted, onUnmounted, computed } from 'vue';
 import { useAppStore } from '@/store';
-import { eeprom_write, eeprom_reboot, eeprom_init, hexReverseStringToUint8Array, stringToUint8Array } from '@/utils/serial.js';
+import { eeprom_write, eeprom_reboot, eeprom_init, hexReverseStringToUint8Array, stringToUint8Array, shared_read, shared_write } from '@/utils/serial.js';
 import useLoading from '@/hooks/loading';
 import QRCode from 'qrcode';
 import { Input, Select } from 'tdesign-vue-next';
 import { Message } from '@arco-design/web-vue';
 
+// Must match ESP32 mapping in src/app/driver/eeprom.cpp
+// EEPROM 0x1E200..0x20000 -> shared offset 0x10000..
+const UVE5_SHARED_TLE_BASE = 0x10000;
+
 const { loading, setLoading } = useLoading(true);
 
 const appStore = useAppStore();
@@ -142,6 +146,48 @@ const state: {
   satsData: []
 })
 
+// Auto-detect UVE5 shared-partition mode.
+// For UVE5 we always store TLE in the ESP32 shared partition (mapped from logical EEPROM 0x1E200..0x20000).
+// This is derived from the handshake firmware version at connect time.
+const isUveDevice = computed(() => appStore.isUve5);
+
+const uint8ToAscii = (bytes: Uint8Array) => {
+  // Keep it simple: the payload is ASCII. Replace NUL with spaces for readability.
+  const text = new TextDecoder('utf-8', { fatal: false }).decode(bytes);
+  return text.replace(/\u0000/g, ' ');
+}
+
+const readSharedBytes = async (start: number, length: number) => {
+  const out = new Uint8Array(length);
+  for (let i = 0; i < length; i += 0x80) {
+    const chunkLen = Math.min(0x80, length - i);
+    const chunk = await shared_read(appStore.connectPort, start + i, chunkLen);
+    out.set(chunk.subarray(0, chunkLen), i);
+  }
+  return out;
+}
+
+const validateTleRecordBytes = (record: Uint8Array) => {
+  if (!record || record.length < 160) return { ok: false, reason: 'readback too short' };
+  const nameBytes = record.subarray(0, 9);
+  const line1Bytes = record.subarray(9, 9 + 69);
+  const line2Bytes = record.subarray(9 + 69, 9 + 69 + 69);
+
+  const allSame = (bytes: Uint8Array, value: number) => bytes.every((b) => b === value);
+  if (allSame(record, 0x00) || allSame(record, 0xff)) return { ok: false, reason: 'all 0x00/0xFF' };
+
+  const name = uint8ToAscii(nameBytes).trim();
+  const line1 = uint8ToAscii(line1Bytes);
+  const line2 = uint8ToAscii(line2Bytes);
+
+  // Minimal structure check; firmware parser is stricter.
+  const looksLikeTle = line1.startsWith('1 ') && line2.startsWith('2 ');
+  if (!looksLikeTle) {
+    return { ok: false, reason: `unexpected TLE header (name='${name}')` };
+  }
+  return { ok: true, reason: '', name, line1, line2 };
+}
+
 const editableCellState = (cellParams) => {
   // 第一行不允许编辑
   const { row } = cellParams;
@@ -432,6 +478,20 @@ const restoreRange = async (start: any = 0, uint8Array: any) => {
   state.status = state.status + "写入进度：100.0%<br/>";
 }
 
+const restoreRangeShared = async (start: number, uint8Array: Uint8Array) => {
+  await eeprom_init(appStore.connectPort);
+  for (let i = 0; i < uint8Array.length; i += 0x40) {
+    const chunk = uint8Array.slice(i, i + 0x40);
+    await shared_write(appStore.connectPort, start + i, chunk, chunk.length);
+    state.status = state.status + "写入进度：" + ((i / uint8Array.length) * 100).toFixed(1) + "%<br/>";
+    nextTick(() => {
+      const textarea = document?.getElementById('statusArea');
+      if (textarea) textarea.scrollTop = textarea?.scrollHeight;
+    })
+  }
+  state.status = state.status + "写入进度：100.0%<br/>";
+}
+
 const calculateChecksum = (line: string) => {
   const chars = line.replace(/\d$/, ''); // 移除末位校验和
   let sum = 0;
@@ -450,7 +510,7 @@ const validateChecksum = (line: string) => {
 
 const writeIt = async () => {
   if (appStore.connectState != true) { alert(sessionStorage.getItem('noticeConnectK5')); return; };
-  if(appStore.configuration?.sat2 != true){
+  if (!isUveDevice.value && appStore.configuration?.sat2 != true) {
     alert(sessionStorage.getItem('noticeVersionNoSupport'));
     return;
   }
@@ -501,8 +561,33 @@ const writeIt = async () => {
       duration: 10 * 1000,
     });
   }
-  await restoreRange(0x1E200, payload)
-  await syncTime()
+  if (isUveDevice.value) {
+    state.status += `检测到 UVE 设备：将写入 shared@0x${UVE5_SHARED_TLE_BASE.toString(16)}<br/>`;
+    await restoreRangeShared(UVE5_SHARED_TLE_BASE, payload)
+
+    // Read-back verify first record so users immediately know whether the shared write actually landed.
+    try {
+      const first = await readSharedBytes(UVE5_SHARED_TLE_BASE, 160);
+      const chk = validateTleRecordBytes(first);
+      if (!chk.ok) {
+        setLoading(false)
+        return Message.error({
+          content: `写入完成但读回校验失败：${chk.reason}。这通常表示 shared 分区不可用（分区表没刷/label 不匹配）或固件未支持 shared 读写命令。\n\n如果你是用 app0_main 的快速上传刷机：请确保 partitions.bin 也被写入（本仓库 scripts/upload_app0.py 已改为同时刷 partitions.bin@0x8000）。或者完整刷一次 factory/分区表后再重试。`,
+          duration: 12 * 1000,
+        });
+      }
+      state.status += `读回校验通过：${chk.name}<br/>`;
+    } catch (e: any) {
+      setLoading(false)
+      return Message.error({
+        content: `写入完成但读回校验异常：${e?.message ?? e}。可能固件不支持 shared_read/shared_write。`,
+        duration: 12 * 1000,
+      });
+    }
+  } else {
+    state.status += `非 UVE 设备：将写入 EEPROM@0x1E200<br/>`;
+    await restoreRange(0x1E200, payload)
+  }
   await eeprom_reboot(appStore.connectPort);
   setLoading(false)
 }