Fix cache staleness: auto-refresh when DB has newer data than cache

src/lib/dataService.js

@@ -215,7 +215,8 @@ class DataService {
         }
       }
 
-      // 计算日期范围 - 使用标准化后的日期
+      // 计算日期范围 - 直接使用 seqFiltered 的最后一条记录的日期，而不是从日期数组中取
+      // 这样可以确保使用的是实际数据的最后一天，而不是排序后的日期数组
       const dates = seqFiltered
         .map(s => {
           const dateStr = s.dateNormalized || (typeof s.date === 'string' ? s.date.split('T')[0] : s.date)
@@ -224,9 +225,21 @@ class DataService {
         .filter(Boolean)
         .sort()
       const start_date = dates[0] || '-'
-      const end_date = dates[dates.length - 1] || '-'
       
-      console.log(`[DataService] STEP3 - ${row.agent_name}|${row.asset}|${row.model}: Final end_date = ${end_date}, dates array length = ${dates.length}`)
+      // 使用 seqFiltered 的最后一条记录的日期作为 end_date，确保是实际数据的最后一天
+      let end_date = '-'
+      if (seqFiltered.length > 0) {
+        const lastRow = seqFiltered[seqFiltered.length - 1]
+        end_date = lastRow.dateNormalized || (typeof lastRow.date === 'string' ? lastRow.date.split('T')[0] : lastRow.date) || '-'
+      } else if (dates.length > 0) {
+        end_date = dates[dates.length - 1]
+      }
+      
+      console.log(`[DataService] STEP3 - ${row.agent_name}|${row.asset}|${row.model}: Final end_date = ${end_date}, dates array length = ${dates.length}, seqFiltered length = ${seqFiltered.length}`)
+      if (seqFiltered.length > 0) {
+        const lastRowDate = seqFiltered[seqFiltered.length - 1].dateNormalized || (typeof seqFiltered[seqFiltered.length - 1].date === 'string' ? seqFiltered[seqFiltered.length - 1].date.split('T')[0] : seqFiltered[seqFiltered.length - 1].date)
+        console.log(`[DataService] STEP3 - Last row date: ${lastRowDate}, dates array last: ${dates.length > 0 ? dates[dates.length - 1] : 'N/A'}`)
+      }
 
       let closed_days = 0
       if (dates.length > 1) {
@@ -321,6 +334,43 @@ class DataService {
           }
         }
 
+        // 检查缓存数据是否是最新的：从 Supabase 查询最新日期，如果缓存中没有最新日期，则强制刷新
+        if (all && all.length > 0) {
+          try {
+            // 获取缓存中的最新日期
+            const cachedDates = all.map(r => r && r.date).filter(Boolean).sort()
+            const cachedMaxDate = cachedDates.length > 0 ? cachedDates[cachedDates.length - 1] : null
+            
+            // 从 Supabase 查询最新日期（只查询日期，不查询所有数据）
+            const { data: latestData, error } = await supabase
+              .from('trading_decisions')
+              .select('date')
+              .order('date', { ascending: false })
+              .limit(1)
+            
+            if (!error && latestData && latestData.length > 0) {
+              const dbMaxDate = latestData[0].date
+              const cachedMaxDateStr = cachedMaxDate ? (typeof cachedMaxDate === 'string' ? cachedMaxDate.split('T')[0] : cachedMaxDate) : null
+              const dbMaxDateStr = typeof dbMaxDate === 'string' ? dbMaxDate.split('T')[0] : dbMaxDate
+              
+              console.log(`[DataService] Cache check: cached max date = ${cachedMaxDateStr}, DB max date = ${dbMaxDateStr}`)
+              
+              // 如果数据库中的最新日期比缓存中的新，强制刷新
+              if (cachedMaxDateStr && dbMaxDateStr && dbMaxDateStr > cachedMaxDateStr) {
+                console.log(`[DataService] Cache is stale (${cachedMaxDateStr} < ${dbMaxDateStr}), fetching fresh data...`)
+                await clearAllStores()
+                clearAllDecisions()
+                all = await this._fetchAllFromRemote()
+                setAllDecisions(all)
+                await writeRawDecisions(all)
+              }
+            }
+          } catch (e) {
+            console.error('[DataService] Error checking cache freshness:', e)
+            // 如果检查失败，继续使用缓存
+          }
+        }
+
         if (!all) {
           // 最后从远程拉取
           all = await this._fetchAllFromRemote()