leemuzi/real-time-fund
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: supabase upsert 操作不再返回 select 信息以减少 edgress 流量

Browse Source
This commit is contained in:
hzm
2026-03-09 10:55:45 +08:00
parent f379c9fef5
commit 5f909cc669
1 changed files with 6 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
app/page.jsx
View File

@@ -3067,9 +3067,6 @@ export default function HomePage() {
const dataToSync = payload || collectLocalPayload(); // Fallback to full sync if no payload const dataToSync = payload || collectLocalPayload(); // Fallback to full sync if no payload
const now = nowInTz().toISOString(); const now = nowInTz().toISOString();
let upsertData = null;
let updateError = null;
if (isPartial) { if (isPartial) {
// 增量更新：使用 RPC 调用 // 增量更新：使用 RPC 调用
const { error: rpcError } = await supabase.rpc('update_user_config_partial', { const { error: rpcError } = await supabase.rpc('update_user_config_partial', {
@@ -3080,7 +3077,7 @@ export default function HomePage() {
console.error('增量同步失败，尝试全量同步', rpcError); console.error('增量同步失败，尝试全量同步', rpcError);
// RPC 失败回退到全量更新 // RPC 失败回退到全量更新
const fullPayload = collectLocalPayload(); const fullPayload = collectLocalPayload();
const { data, error } = await supabase const { error } = await supabase
.from('user_configs') .from('user_configs')
.upsert( .upsert(
{ {
@@ -3089,17 +3086,12 @@ export default function HomePage() {
updated_at: now updated_at: now
}, },
{ onConflict: 'user_id' } { onConflict: 'user_id' }
) );
.select(); if (error) throw error;
upsertData = data;
updateError = error;
} else {
// RPC 成功，模拟 upsertData 格式以便后续逻辑通过
upsertData = [{ id: 'rpc_success' }];
} }
} else { } else {
// 全量更新 // 全量更新
const { data, error } = await supabase const { error } = await supabase
.from('user_configs') .from('user_configs')
.upsert( .upsert(
{ {
@@ -3108,15 +3100,8 @@ export default function HomePage() {
updated_at: now updated_at: now
}, },
{ onConflict: 'user_id' } { onConflict: 'user_id' }
) );
.select(); if (error) throw error;
upsertData = data;
updateError = error;
}
if (updateError) throw updateError;
if (!upsertData || upsertData.length === 0) {
throw new Error('同步失败：未写入任何数据，请检查账号状态或重新登录');
} }
storageHelper.setItem('localUpdatedAt', now); storageHelper.setItem('localUpdatedAt', now);