124 lines
3.7 KiB
JavaScript
124 lines
3.7 KiB
JavaScript
/**
|
|
* 记录每次调用基金估值接口的结果，用于分时图。
|
|
* 规则：获取到最新日期的数据时，清掉所有老日期的数据，只保留当日分时点。
|
|
*/
|
|
import { isPlainObject, isString } from 'lodash';
|
|
|
|
const STORAGE_KEY = 'fundValuationTimeseries';
|
|
|
|
function getStored() {
|
|
if (typeof window === 'undefined' || !window.localStorage) return {};
|
|
try {
|
|
const raw = window.localStorage.getItem(STORAGE_KEY);
|
|
const parsed = raw ? JSON.parse(raw) : {};
|
|
return isPlainObject(parsed) ? parsed : {};
|
|
} catch {
|
|
return {};
|
|
}
|
|
}
|
|
|
|
function setStored(data) {
|
|
if (typeof window === 'undefined' || !window.localStorage) return;
|
|
try {
|
|
window.localStorage.setItem(STORAGE_KEY, JSON.stringify(data));
|
|
} catch (e) {
|
|
console.warn('valuationTimeseries persist failed', e);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 从 gztime 或 Date 得到日期字符串 YYYY-MM-DD
|
|
*/
|
|
function toDateStr(gztimeOrNow) {
|
|
if (isString(gztimeOrNow) && /^\d{4}-\d{2}-\d{2}/.test(gztimeOrNow)) {
|
|
return gztimeOrNow.slice(0, 10);
|
|
}
|
|
try {
|
|
const d = new Date();
|
|
const y = d.getFullYear();
|
|
const m = String(d.getMonth() + 1).padStart(2, '0');
|
|
const day = String(d.getDate()).padStart(2, '0');
|
|
return `${y}-${m}-${day}`;
|
|
} catch {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 记录一条估值。仅当 value 为有效数字时写入。
|
|
* 数据清理：若当前点所属日期大于已存点的最大日期，则清空该基金下所有旧日期的数据，只保留当日分时。
|
|
*
|
|
* @param {string} code - 基金代码
|
|
* @param {{ gsz?: number | null, gztime?: string | null }} payload - 估值与时间（来自接口）
|
|
* @returns {Array<{ time: string, value: number, date: string }>} 该基金当前分时序列（按时间升序）
|
|
*/
|
|
export function recordValuation(code, payload) {
|
|
const value = payload?.gsz != null ? Number(payload.gsz) : NaN;
|
|
if (!Number.isFinite(value)) return getValuationSeries(code);
|
|
|
|
const gztime = payload?.gztime ?? null;
|
|
const dateStr = toDateStr(gztime);
|
|
if (!dateStr) return getValuationSeries(code);
|
|
|
|
const timeLabel = isString(gztime) && gztime.length > 10
|
|
? gztime.slice(11, 16)
|
|
: (() => {
|
|
const d = new Date();
|
|
return `${String(d.getHours()).padStart(2, '0')}:${String(d.getMinutes()).padStart(2, '0')}`;
|
|
})();
|
|
|
|
const newPoint = { time: timeLabel, value, date: dateStr };
|
|
|
|
const all = getStored();
|
|
const list = Array.isArray(all[code]) ? all[code] : [];
|
|
|
|
const existingDates = list.map((p) => p.date).filter(Boolean);
|
|
const latestStoredDate = existingDates.length ? existingDates.reduce((a, b) => (a > b ? a : b), '') : '';
|
|
|
|
let nextList;
|
|
if (dateStr > latestStoredDate) {
|
|
nextList = [newPoint];
|
|
} else if (dateStr === latestStoredDate) {
|
|
const hasSameTime = list.some((p) => p.time === timeLabel);
|
|
if (hasSameTime) return list;
|
|
nextList = [...list, newPoint];
|
|
} else {
|
|
return list;
|
|
}
|
|
|
|
all[code] = nextList;
|
|
setStored(all);
|
|
return nextList;
|
|
}
|
|
|
|
/**
|
|
* 获取某基金的分时序列（只读）
|
|
* @param {string} code - 基金代码
|
|
* @returns {Array<{ time: string, value: number, date: string }>}
|
|
*/
|
|
export function getValuationSeries(code) {
|
|
const all = getStored();
|
|
const list = Array.isArray(all[code]) ? all[code] : [];
|
|
return list;
|
|
}
|
|
|
|
/**
|
|
* 删除某基金的全部分时数据（如用户删除该基金时调用）
|
|
* @param {string} code - 基金代码
|
|
*/
|
|
export function clearFund(code) {
|
|
const all = getStored();
|
|
if (!(code in all)) return;
|
|
const next = { ...all };
|
|
delete next[code];
|
|
setStored(next);
|
|
}
|
|
|
|
/**
|
|
* 获取全部分时数据，用于页面初始 state
|
|
* @returns {{ [code: string]: Array<{ time: string, value: number, date: string }> }}
|
|
*/
|
|
export function getAllValuationSeries() {
|
|
return getStored();
|
|
}
|