wanzi/ftb-project-management
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(小宝预警): 串行保存风险缓存

Browse Source
This commit is contained in:
Script Generator
2026-06-29 18:46:54 +08:00
parent b11830278c
commit 7b1a48f1f7
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
apps/web/stores/useXiaobaoRiskStore.ts
View File

@@ -35,6 +35,9 @@ async function loadInsights(): Promise<XiaobaoRiskInsightCacheItem[] | null> {
return null; return null;
} }
let snapshotSaveQueue: Promise<void> = Promise.resolve();
let insightSaveQueue: Promise<void> = Promise.resolve();
export const useXiaobaoRiskStore = create<XiaobaoRiskState>((set, get) => ({ export const useXiaobaoRiskStore = create<XiaobaoRiskState>((set, get) => ({
snapshots: [], snapshots: [],
insights: [], insights: [],
@@ -52,11 +55,15 @@ export const useXiaobaoRiskStore = create<XiaobaoRiskState>((set, get) => ({
saveSnapshot: async (item) => { saveSnapshot: async (item) => {
const optimistic = upsertDailySnapshot(get().snapshots, item); const optimistic = upsertDailySnapshot(get().snapshots, item);
set({ snapshots: optimistic, error: undefined }); set({ snapshots: optimistic, error: undefined });
try { const task = snapshotSaveQueue.then(async () => {
const remote = await loadServerData<XiaobaoRiskSnapshot[]>('xiaobao-risk-snapshots'); const remote = await loadServerData<XiaobaoRiskSnapshot[]>('xiaobao-risk-snapshots');
const snapshots = mergeDailySnapshotCacheForSave(optimistic, Array.isArray(remote) ? remote : [], item); const snapshots = mergeDailySnapshotCacheForSave(get().snapshots, Array.isArray(remote) ? remote : [], item);
set({ snapshots, error: undefined }); set({ snapshots, error: undefined });
await saveServerData('xiaobao-risk-snapshots', snapshots); await saveServerData('xiaobao-risk-snapshots', snapshots);
});
snapshotSaveQueue = task.catch(() => undefined);
try {
await task;
} catch (error) { } catch (error) {
set({ error: '小宝预警快照保存失败' }); set({ error: '小宝预警快照保存失败' });
throw error; throw error;
@@ -66,11 +73,15 @@ export const useXiaobaoRiskStore = create<XiaobaoRiskState>((set, get) => ({
saveInsight: async (item) => { saveInsight: async (item) => {
const optimistic = upsertInsight(get().insights, item); const optimistic = upsertInsight(get().insights, item);
set({ insights: optimistic, error: undefined }); set({ insights: optimistic, error: undefined });
try { const task = insightSaveQueue.then(async () => {
const remote = await loadServerData<XiaobaoRiskInsightCacheItem[]>('xiaobao-risk-insights'); const remote = await loadServerData<XiaobaoRiskInsightCacheItem[]>('xiaobao-risk-insights');
const insights = mergeInsightCacheForSave(optimistic, Array.isArray(remote) ? remote : [], item); const insights = mergeInsightCacheForSave(get().insights, Array.isArray(remote) ? remote : [], item);
set({ insights, error: undefined }); set({ insights, error: undefined });
await saveServerData('xiaobao-risk-insights', insights); await saveServerData('xiaobao-risk-insights', insights);
});
insightSaveQueue = task.catch(() => undefined);
try {
await task;
} catch (error) { } catch (error) {
set({ error: '小宝预警解读保存失败' }); set({ error: '小宝预警解读保存失败' });
throw error; throw error;