update pay ui

This commit is contained in:
2025-12-10 16:05:53 +08:00
parent 0bf2b01ca6
commit cca6f3a054
2 changed files with 39 additions and 13 deletions

View File

@@ -229,30 +229,38 @@ const handleSZSERealtimeMessage = (
numTrades: afterhoursData.num_trades || 0, numTrades: afterhoursData.num_trades || 0,
}; };
// 盘后数据的当前价格:优先使用 bid_px买入价否则使用 offer_px卖出价
const afterhoursPrice = afterhoursData.bid_px || afterhoursData.offer_px || 0;
const prevClose = afterhoursData.prev_close || existing?.prevClose || 0;
if (existing) { if (existing) {
// 合并到现有数据 // 合并到现有数据,同时更新价格(如果盘后价格有效)
const newPrice = afterhoursPrice > 0 ? afterhoursPrice : existing.price;
updated[fullCode] = { updated[fullCode] = {
...existing, ...existing,
price: newPrice,
change: newPrice - prevClose,
changePct: calcChangePct(newPrice, prevClose),
afterhours: afterhoursInfo, afterhours: afterhoursInfo,
updateTime: timestamp, updateTime: timestamp,
} as QuoteData; } as QuoteData;
} else { } else {
// 盘后首次收到数据(刷新页面后),创建基础行情结构 // 盘后首次收到数据(刷新页面后),使用盘后价格创建行情结构
updated[fullCode] = { updated[fullCode] = {
code: fullCode, code: fullCode,
name: '', name: '',
price: 0, price: afterhoursPrice,
prevClose: afterhoursData.prev_close, prevClose: prevClose,
open: 0, open: 0,
high: 0, high: 0,
low: 0, low: 0,
volume: 0, volume: 0,
amount: 0, amount: 0,
change: 0, change: afterhoursPrice - prevClose,
changePct: 0, changePct: calcChangePct(afterhoursPrice, prevClose),
bidPrices: [], bidPrices: afterhoursPrice > 0 ? [afterhoursPrice] : [],
bidVolumes: [], bidVolumes: [],
askPrices: [], askPrices: afterhoursData.offer_px > 0 ? [afterhoursData.offer_px] : [],
askVolumes: [], askVolumes: [],
tradingPhase: afterhoursData.trading_phase, tradingPhase: afterhoursData.trading_phase,
afterhours: afterhoursInfo, afterhours: afterhoursInfo,

View File

@@ -2,7 +2,7 @@
* 热点概览数据获取 Hook * 热点概览数据获取 Hook
* 负责获取指数分时数据和概念异动数据 * 负责获取指数分时数据和概念异动数据
*/ */
import { useState, useEffect, useCallback } from 'react'; import { useState, useEffect, useCallback, useRef } from 'react';
import { logger } from '@utils/logger'; import { logger } from '@utils/logger';
/** /**
@@ -14,19 +14,36 @@ export const useHotspotData = (selectedDate) => {
const [error, setError] = useState(null); const [error, setError] = useState(null);
const [data, setData] = useState(null); const [data, setData] = useState(null);
const fetchData = useCallback(async () => { // 用于防止 React StrictMode 下的双重请求
const fetchingRef = useRef(false);
const lastDateRef = useRef(null);
const fetchData = useCallback(async (forceRefetch = false) => {
// 获取日期字符串用于比较
const dateStr = selectedDate ? selectedDate.toISOString().split('T')[0] : 'today';
// 如果正在请求中,或者日期未变化且不是强制刷新,跳过
if (fetchingRef.current && !forceRefetch) {
return;
}
if (lastDateRef.current === dateStr && data && !forceRefetch) {
return;
}
fetchingRef.current = true;
setLoading(true); setLoading(true);
setError(null); setError(null);
try { try {
const dateParam = selectedDate const dateParam = selectedDate
? `?date=${selectedDate.toISOString().split('T')[0]}` ? `?date=${dateStr}`
: ''; : '';
const response = await fetch(`/api/market/hotspot-overview${dateParam}`); const response = await fetch(`/api/market/hotspot-overview${dateParam}`);
const result = await response.json(); const result = await response.json();
if (result.success) { if (result.success) {
setData(result.data); setData(result.data);
lastDateRef.current = dateStr;
} else { } else {
setError(result.error || '获取数据失败'); setError(result.error || '获取数据失败');
} }
@@ -35,8 +52,9 @@ export const useHotspotData = (selectedDate) => {
setError('网络请求失败'); setError('网络请求失败');
} finally { } finally {
setLoading(false); setLoading(false);
fetchingRef.current = false;
} }
}, [selectedDate]); }, [selectedDate, data]);
useEffect(() => { useEffect(() => {
fetchData(); fetchData();
@@ -46,7 +64,7 @@ export const useHotspotData = (selectedDate) => {
loading, loading,
error, error,
data, data,
refetch: fetchData, refetch: () => fetchData(true),
}; };
}; };