Compare commits
No commits in common. "e70c0602c8b82e779adae8188d173a32a9a407bf" and "06e52d58d6533b4dc29af8bb68bfebe58bdebe24" have entirely different histories.
e70c0602c8
...
06e52d58d6
@ -11,13 +11,11 @@
|
|||||||
- 完成核心 `transactions` (交易流水) 表的建立，并严格运用了 `numeric(36,18)` 的高精度配置。
|
- 完成核心 `transactions` (交易流水) 表的建立，并严格运用了 `numeric(36,18)` 的高精度配置。
|
||||||
- `assets` 表完成多次业务演进：新增 `latestPrice` (支持现价追踪)、`exchange` (显式交易所绑定) 以及 `name` (中文名称解析) 字段。
|
- `assets` 表完成多次业务演进：新增 `latestPrice` (支持现价追踪)、`exchange` (显式交易所绑定) 以及 `name` (中文名称解析) 字段。
|
||||||
- `exchange_rates` (汇率表) 已建立，支持联合主键与跨币种交叉汇率架构。
|
- `exchange_rates` (汇率表) 已建立，支持联合主键与跨币种交叉汇率架构。
|
||||||
- **引入 `portfolio_snapshots` 表**：用于每日记录投资组合快照，字段包括 `date` (唯一日期)、`total_value_cny` (当日总市值)、`total_cost_cny` (当日总投入本金)，为历史净值走势图奠定底层数据结构。
|
|
||||||
|
|
||||||
## 核心业务与服务端逻辑 (Server Actions)
|
## 核心业务与服务端逻辑 (Server Actions)
|
||||||
- 完成高精度交易流水与资产的 Server Actions 开发，成功实现字符串级别的高精度防腐层拦截（基于 Zod & Big.js）。
|
- 完成高精度交易流水与资产的 Server Actions 开发，成功实现字符串级别的高精度防腐层拦截（基于 Zod & Big.js）。
|
||||||
- 补全资产与流水的全栈增删改查 (CRUD) 操作，`createTransaction` 现已支持根据 `exchange` 自动判定并锁定 `txCurrency`。
|
- 补全资产与流水的全栈增删改查 (CRUD) 操作，`createTransaction` 现已支持根据 `exchange` 自动判定并锁定 `txCurrency`。
|
||||||
- **估值与 P&L 引擎：** 完成底层估值引擎升级，打通交叉汇率换算逻辑；实现原币种 (Native) 与本位币 (CNY Base) 双轨制的历史成本追溯与真实盈亏 (P&L) 计算引擎。
|
- **估值与 P&L 引擎：** 完成底层估值引擎升级，打通交叉汇率换算逻辑；实现原币种 (Native) 与本位币 (CNY Base) 双轨制的历史成本追溯与真实盈亏 (P&L) 计算引擎。
|
||||||
- **快照记录引擎：** 新增 `src/actions/snapshots.ts`，`recordDailySnapshot()` 函数基于 `getPortfolioPositions()` 实时计算总市值与总成本，使用 `Asia/Shanghai` 时区获取当日日期，执行 Upsert 逻辑确保每天仅存一条记录；`getSnapshots()` 支持按日期范围与数量限制查询历史快照数据。
|
|
||||||
|
|
||||||
## 外部行情接口与网络 (Market Data Engines)
|
## 外部行情接口与网络 (Market Data Engines)
|
||||||
- **股票行情引擎：** 彻底抛弃低效海外接口，自主研发智能路由接入腾讯财经 (`qt.gtimg.cn`) 极速接口。引入原生 `ArrayBuffer` 与 `TextDecoder(gbk)` 彻底解决历史中文乱码问题，实现沪、深、港、美四大市场毫秒级实时同步。
|
- **股票行情引擎：** 彻底抛弃低效海外接口，自主研发智能路由接入腾讯财经 (`qt.gtimg.cn`) 极速接口。引入原生 `ArrayBuffer` 与 `TextDecoder(gbk)` 彻底解决历史中文乱码问题，实现沪、深、港、美四大市场毫秒级实时同步。
|
||||||
@ -30,7 +28,6 @@
|
|||||||
- 打通 `/dashboard/assets` 与 `/dashboard/transactions` 页面前后端数据流转，修复早期录入与 404 缺陷。
|
- 打通 `/dashboard/assets` 与 `/dashboard/transactions` 页面前后端数据流转，修复早期录入与 404 缺陷。
|
||||||
- 完成 UI 层高精度数据格式化，针对不同资产类型实现动态精度展示，清理因数据库 `numeric` 导致的尾随零问题。
|
- 完成 UI 层高精度数据格式化，针对不同资产类型实现动态精度展示，清理因数据库 `numeric` 导致的尾随零问题。
|
||||||
- 引入 `recharts` 图表引擎，构建了基于实时 CNY 估值的资产分布环形图。
|
- 引入 `recharts` 图表引擎，构建了基于实时 CNY 估值的资产分布环形图。
|
||||||
- 实装基于 Recharts 的历史净值面积图 (NetWorthChart)，支持总市值与投入本金的双轨趋势对比。
|
|
||||||
- 优化表单交互：实装了交易所与币种的智能联动逻辑，并运用 `disabled` 属性实现了表单字段的只读防腐锁定。
|
- 优化表单交互：实装了交易所与币种的智能联动逻辑，并运用 `disabled` 属性实现了表单字段的只读防腐锁定。
|
||||||
|
|
||||||
## UX 与全局交互 (UI/UX)
|
## UX 与全局交互 (UI/UX)
|
||||||
|
|||||||
@ -22,10 +22,8 @@ import {
|
|||||||
import { toast } from 'sonner';
|
import { toast } from 'sonner';
|
||||||
import { getPortfolioSummary } from '@/actions/portfolio';
|
import { getPortfolioSummary } from '@/actions/portfolio';
|
||||||
import { getAssets } from '@/actions/asset';
|
import { getAssets } from '@/actions/asset';
|
||||||
import { recordDailySnapshot, getSnapshots } from '@/actions/snapshots';
|
|
||||||
import { formatQuantity, formatAmount } from '@/lib/formatters';
|
import { formatQuantity, formatAmount } from '@/lib/formatters';
|
||||||
import AllocationChart from '@/components/dashboard/allocation-chart';
|
import AllocationChart from '@/components/dashboard/allocation-chart';
|
||||||
import NetWorthChart from '@/components/dashboard/net-worth-chart';
|
|
||||||
import { SyncButton } from '@/components/assets/sync-button';
|
import { SyncButton } from '@/components/assets/sync-button';
|
||||||
import { AddTransactionDialog } from '@/components/transactions/add-transaction-dialog';
|
import { AddTransactionDialog } from '@/components/transactions/add-transaction-dialog';
|
||||||
import { UpdateTransactionDialog } from '@/components/transactions/update-transaction-dialog';
|
import { UpdateTransactionDialog } from '@/components/transactions/update-transaction-dialog';
|
||||||
@ -86,7 +84,6 @@ export default function DashboardPage() {
|
|||||||
const [isPending, startTransition] = useTransition();
|
const [isPending, startTransition] = useTransition();
|
||||||
const [updateTarget, setUpdateTarget] = useState<any>(null);
|
const [updateTarget, setUpdateTarget] = useState<any>(null);
|
||||||
const [deleteTarget, setDeleteTarget] = useState<any>(null);
|
const [deleteTarget, setDeleteTarget] = useState<any>(null);
|
||||||
const [snapshots, setSnapshots] = useState<any[]>([]);
|
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
async function loadData() {
|
async function loadData() {
|
||||||
@ -102,15 +99,6 @@ export default function DashboardPage() {
|
|||||||
loadData();
|
loadData();
|
||||||
}, []);
|
}, []);
|
||||||
|
|
||||||
useEffect(() => {
|
|
||||||
async function loadSnapshots() {
|
|
||||||
await recordDailySnapshot();
|
|
||||||
const data = await getSnapshots({ limit: 30 });
|
|
||||||
setSnapshots(data);
|
|
||||||
}
|
|
||||||
loadSnapshots();
|
|
||||||
}, []);
|
|
||||||
|
|
||||||
const toggleExpand = (id: string) => {
|
const toggleExpand = (id: string) => {
|
||||||
setExpandedIds(prev => ({ ...prev, [id]: !prev[id] }));
|
setExpandedIds(prev => ({ ...prev, [id]: !prev[id] }));
|
||||||
};
|
};
|
||||||
@ -182,15 +170,6 @@ export default function DashboardPage() {
|
|||||||
</CardContent>
|
</CardContent>
|
||||||
</Card>
|
</Card>
|
||||||
|
|
||||||
<Card>
|
|
||||||
<CardHeader>
|
|
||||||
<CardTitle className="text-base font-medium">净值走势</CardTitle>
|
|
||||||
</CardHeader>
|
|
||||||
<CardContent>
|
|
||||||
<NetWorthChart snapshots={snapshots} />
|
|
||||||
</CardContent>
|
|
||||||
</Card>
|
|
||||||
|
|
||||||
<Card>
|
<Card>
|
||||||
<CardHeader>
|
<CardHeader>
|
||||||
<CardTitle>持仓明细</CardTitle>
|
<CardTitle>持仓明细</CardTitle>
|
||||||
|
|||||||
@ -1,24 +0,0 @@
|
|||||||
CREATE TABLE "exchange_rates" (
|
|
||||||
"id" uuid PRIMARY KEY NOT NULL,
|
|
||||||
"from_currency" varchar(10) NOT NULL,
|
|
||||||
"to_currency" varchar(10) NOT NULL,
|
|
||||||
"rate" numeric(20, 8) NOT NULL,
|
|
||||||
"updated_at" timestamp with time zone DEFAULT now()
|
|
||||||
);
|
|
||||||
--> statement-breakpoint
|
|
||||||
CREATE TABLE "portfolio_snapshots" (
|
|
||||||
"id" uuid PRIMARY KEY NOT NULL,
|
|
||||||
"date" date NOT NULL,
|
|
||||||
"total_value_cny" numeric(36, 18) NOT NULL,
|
|
||||||
"total_cost_cny" numeric(36, 18) NOT NULL,
|
|
||||||
"created_at" timestamp with time zone DEFAULT now() NOT NULL,
|
|
||||||
"updated_at" timestamp with time zone DEFAULT now() NOT NULL,
|
|
||||||
CONSTRAINT "portfolio_snapshots_date_unique" UNIQUE("date")
|
|
||||||
);
|
|
||||||
--> statement-breakpoint
|
|
||||||
ALTER TABLE "assets" ALTER COLUMN "id" DROP DEFAULT;--> statement-breakpoint
|
|
||||||
ALTER TABLE "users" ALTER COLUMN "id" DROP DEFAULT;--> statement-breakpoint
|
|
||||||
ALTER TABLE "assets" ADD COLUMN "name" varchar(100);--> statement-breakpoint
|
|
||||||
ALTER TABLE "assets" ADD COLUMN "exchange" varchar(10) DEFAULT 'US';--> statement-breakpoint
|
|
||||||
ALTER TABLE "assets" ADD COLUMN "latest_price" numeric(36, 18) DEFAULT '0' NOT NULL;--> statement-breakpoint
|
|
||||||
CREATE UNIQUE INDEX "currency_pair_idx" ON "exchange_rates" USING btree ("from_currency","to_currency");
|
|
||||||
@ -1,375 +0,0 @@
|
|||||||
{
|
|
||||||
"id": "26b392bf-03db-4f71-86d5-395d5c07fae5",
|
|
||||||
"prevId": "18d8b1e1-2700-4d54-adf8-493d526d5bf5",
|
|
||||||
"version": "7",
|
|
||||||
"dialect": "postgresql",
|
|
||||||
"tables": {
|
|
||||||
"public.assets": {
|
|
||||||
"name": "assets",
|
|
||||||
"schema": "",
|
|
||||||
"columns": {
|
|
||||||
"id": {
|
|
||||||
"name": "id",
|
|
||||||
"type": "uuid",
|
|
||||||
"primaryKey": true,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"symbol": {
|
|
||||||
"name": "symbol",
|
|
||||||
"type": "varchar(20)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"name": {
|
|
||||||
"name": "name",
|
|
||||||
"type": "varchar(100)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": false
|
|
||||||
},
|
|
||||||
"type": {
|
|
||||||
"name": "type",
|
|
||||||
"type": "asset_type_enum",
|
|
||||||
"typeSchema": "public",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"exchange": {
|
|
||||||
"name": "exchange",
|
|
||||||
"type": "varchar(10)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": false,
|
|
||||||
"default": "'US'"
|
|
||||||
},
|
|
||||||
"base_currency": {
|
|
||||||
"name": "base_currency",
|
|
||||||
"type": "varchar(10)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"latest_price": {
|
|
||||||
"name": "latest_price",
|
|
||||||
"type": "numeric(36, 18)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true,
|
|
||||||
"default": "'0'"
|
|
||||||
},
|
|
||||||
"created_at": {
|
|
||||||
"name": "created_at",
|
|
||||||
"type": "timestamp with time zone",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": false,
|
|
||||||
"default": "now()"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"indexes": {},
|
|
||||||
"foreignKeys": {},
|
|
||||||
"compositePrimaryKeys": {},
|
|
||||||
"uniqueConstraints": {
|
|
||||||
"assets_symbol_unique": {
|
|
||||||
"name": "assets_symbol_unique",
|
|
||||||
"nullsNotDistinct": false,
|
|
||||||
"columns": [
|
|
||||||
"symbol"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"policies": {},
|
|
||||||
"checkConstraints": {},
|
|
||||||
"isRLSEnabled": false
|
|
||||||
},
|
|
||||||
"public.exchange_rates": {
|
|
||||||
"name": "exchange_rates",
|
|
||||||
"schema": "",
|
|
||||||
"columns": {
|
|
||||||
"id": {
|
|
||||||
"name": "id",
|
|
||||||
"type": "uuid",
|
|
||||||
"primaryKey": true,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"from_currency": {
|
|
||||||
"name": "from_currency",
|
|
||||||
"type": "varchar(10)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"to_currency": {
|
|
||||||
"name": "to_currency",
|
|
||||||
"type": "varchar(10)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"rate": {
|
|
||||||
"name": "rate",
|
|
||||||
"type": "numeric(20, 8)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"updated_at": {
|
|
||||||
"name": "updated_at",
|
|
||||||
"type": "timestamp with time zone",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": false,
|
|
||||||
"default": "now()"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"indexes": {
|
|
||||||
"currency_pair_idx": {
|
|
||||||
"name": "currency_pair_idx",
|
|
||||||
"columns": [
|
|
||||||
{
|
|
||||||
"expression": "from_currency",
|
|
||||||
"isExpression": false,
|
|
||||||
"asc": true,
|
|
||||||
"nulls": "last"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"expression": "to_currency",
|
|
||||||
"isExpression": false,
|
|
||||||
"asc": true,
|
|
||||||
"nulls": "last"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"isUnique": true,
|
|
||||||
"concurrently": false,
|
|
||||||
"method": "btree",
|
|
||||||
"with": {}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"foreignKeys": {},
|
|
||||||
"compositePrimaryKeys": {},
|
|
||||||
"uniqueConstraints": {},
|
|
||||||
"policies": {},
|
|
||||||
"checkConstraints": {},
|
|
||||||
"isRLSEnabled": false
|
|
||||||
},
|
|
||||||
"public.portfolio_snapshots": {
|
|
||||||
"name": "portfolio_snapshots",
|
|
||||||
"schema": "",
|
|
||||||
"columns": {
|
|
||||||
"id": {
|
|
||||||
"name": "id",
|
|
||||||
"type": "uuid",
|
|
||||||
"primaryKey": true,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"date": {
|
|
||||||
"name": "date",
|
|
||||||
"type": "date",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"total_value_cny": {
|
|
||||||
"name": "total_value_cny",
|
|
||||||
"type": "numeric(36, 18)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"total_cost_cny": {
|
|
||||||
"name": "total_cost_cny",
|
|
||||||
"type": "numeric(36, 18)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"created_at": {
|
|
||||||
"name": "created_at",
|
|
||||||
"type": "timestamp with time zone",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true,
|
|
||||||
"default": "now()"
|
|
||||||
},
|
|
||||||
"updated_at": {
|
|
||||||
"name": "updated_at",
|
|
||||||
"type": "timestamp with time zone",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true,
|
|
||||||
"default": "now()"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"indexes": {},
|
|
||||||
"foreignKeys": {},
|
|
||||||
"compositePrimaryKeys": {},
|
|
||||||
"uniqueConstraints": {
|
|
||||||
"portfolio_snapshots_date_unique": {
|
|
||||||
"name": "portfolio_snapshots_date_unique",
|
|
||||||
"nullsNotDistinct": false,
|
|
||||||
"columns": [
|
|
||||||
"date"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"policies": {},
|
|
||||||
"checkConstraints": {},
|
|
||||||
"isRLSEnabled": false
|
|
||||||
},
|
|
||||||
"public.transactions": {
|
|
||||||
"name": "transactions",
|
|
||||||
"schema": "",
|
|
||||||
"columns": {
|
|
||||||
"id": {
|
|
||||||
"name": "id",
|
|
||||||
"type": "uuid",
|
|
||||||
"primaryKey": true,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"asset_id": {
|
|
||||||
"name": "asset_id",
|
|
||||||
"type": "uuid",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"tx_type": {
|
|
||||||
"name": "tx_type",
|
|
||||||
"type": "transaction_type_enum",
|
|
||||||
"typeSchema": "public",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"quantity": {
|
|
||||||
"name": "quantity",
|
|
||||||
"type": "numeric(36, 18)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"price": {
|
|
||||||
"name": "price",
|
|
||||||
"type": "numeric(36, 18)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"fee": {
|
|
||||||
"name": "fee",
|
|
||||||
"type": "numeric(36, 18)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true,
|
|
||||||
"default": "'0'"
|
|
||||||
},
|
|
||||||
"tx_currency": {
|
|
||||||
"name": "tx_currency",
|
|
||||||
"type": "varchar(10)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"exchange_rate": {
|
|
||||||
"name": "exchange_rate",
|
|
||||||
"type": "numeric(20, 8)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true,
|
|
||||||
"default": "'1'"
|
|
||||||
},
|
|
||||||
"executed_at": {
|
|
||||||
"name": "executed_at",
|
|
||||||
"type": "timestamp with time zone",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"created_at": {
|
|
||||||
"name": "created_at",
|
|
||||||
"type": "timestamp with time zone",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": false,
|
|
||||||
"default": "now()"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"indexes": {},
|
|
||||||
"foreignKeys": {
|
|
||||||
"transactions_asset_id_assets_id_fk": {
|
|
||||||
"name": "transactions_asset_id_assets_id_fk",
|
|
||||||
"tableFrom": "transactions",
|
|
||||||
"tableTo": "assets",
|
|
||||||
"columnsFrom": [
|
|
||||||
"asset_id"
|
|
||||||
],
|
|
||||||
"columnsTo": [
|
|
||||||
"id"
|
|
||||||
],
|
|
||||||
"onDelete": "no action",
|
|
||||||
"onUpdate": "no action"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"compositePrimaryKeys": {},
|
|
||||||
"uniqueConstraints": {},
|
|
||||||
"policies": {},
|
|
||||||
"checkConstraints": {},
|
|
||||||
"isRLSEnabled": false
|
|
||||||
},
|
|
||||||
"public.users": {
|
|
||||||
"name": "users",
|
|
||||||
"schema": "",
|
|
||||||
"columns": {
|
|
||||||
"id": {
|
|
||||||
"name": "id",
|
|
||||||
"type": "uuid",
|
|
||||||
"primaryKey": true,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"username": {
|
|
||||||
"name": "username",
|
|
||||||
"type": "varchar(50)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"password_hash": {
|
|
||||||
"name": "password_hash",
|
|
||||||
"type": "varchar(255)",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true
|
|
||||||
},
|
|
||||||
"created_at": {
|
|
||||||
"name": "created_at",
|
|
||||||
"type": "timestamp with time zone",
|
|
||||||
"primaryKey": false,
|
|
||||||
"notNull": true,
|
|
||||||
"default": "now()"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"indexes": {},
|
|
||||||
"foreignKeys": {},
|
|
||||||
"compositePrimaryKeys": {},
|
|
||||||
"uniqueConstraints": {
|
|
||||||
"users_username_unique": {
|
|
||||||
"name": "users_username_unique",
|
|
||||||
"nullsNotDistinct": false,
|
|
||||||
"columns": [
|
|
||||||
"username"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"policies": {},
|
|
||||||
"checkConstraints": {},
|
|
||||||
"isRLSEnabled": false
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"enums": {
|
|
||||||
"public.asset_type_enum": {
|
|
||||||
"name": "asset_type_enum",
|
|
||||||
"schema": "public",
|
|
||||||
"values": [
|
|
||||||
"STOCK",
|
|
||||||
"CRYPTO",
|
|
||||||
"CASH"
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"public.transaction_type_enum": {
|
|
||||||
"name": "transaction_type_enum",
|
|
||||||
"schema": "public",
|
|
||||||
"values": [
|
|
||||||
"BUY",
|
|
||||||
"SELL",
|
|
||||||
"DIVIDEND",
|
|
||||||
"AIRDROP",
|
|
||||||
"FEE"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"schemas": {},
|
|
||||||
"sequences": {},
|
|
||||||
"roles": {},
|
|
||||||
"policies": {},
|
|
||||||
"views": {},
|
|
||||||
"_meta": {
|
|
||||||
"columns": {},
|
|
||||||
"schemas": {},
|
|
||||||
"tables": {}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -22,13 +22,6 @@
|
|||||||
"when": 1777289592183,
|
"when": 1777289592183,
|
||||||
"tag": "0002_rapid_invaders",
|
"tag": "0002_rapid_invaders",
|
||||||
"breakpoints": true
|
"breakpoints": true
|
||||||
},
|
|
||||||
{
|
|
||||||
"idx": 3,
|
|
||||||
"version": "7",
|
|
||||||
"when": 1777433725731,
|
|
||||||
"tag": "0003_watery_xorn",
|
|
||||||
"breakpoints": true
|
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
@ -1,103 +0,0 @@
|
|||||||
'use server';
|
|
||||||
|
|
||||||
import { db } from '@/db';
|
|
||||||
import { portfolioSnapshots } from '@/db/schema';
|
|
||||||
import { getPortfolioPositions } from './portfolio';
|
|
||||||
import { eq, sql } from 'drizzle-orm';
|
|
||||||
|
|
||||||
function getTodayInShanghai(): string {
|
|
||||||
const now = new Date();
|
|
||||||
const utcStr = now.toLocaleString('en-US', { timeZone: 'UTC' });
|
|
||||||
const utcDate = new Date(utcStr);
|
|
||||||
const shanghaiOffset = 8 * 60 * 60 * 1000;
|
|
||||||
const shanghaiDate = new Date(utcDate.getTime() + shanghaiOffset);
|
|
||||||
const year = shanghaiDate.getFullYear();
|
|
||||||
const month = String(shanghaiDate.getMonth() + 1).padStart(2, '0');
|
|
||||||
const day = String(shanghaiDate.getDate()).padStart(2, '0');
|
|
||||||
return `${year}-${month}-${day}`;
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function recordDailySnapshot() {
|
|
||||||
const positions = await getPortfolioPositions();
|
|
||||||
|
|
||||||
const totalValueCny = positions.reduce(
|
|
||||||
(sum, pos) => sum.plus(pos.cnyValue || '0'),
|
|
||||||
0 as number | string
|
|
||||||
);
|
|
||||||
|
|
||||||
const totalCostCny = positions.reduce(
|
|
||||||
(sum, pos) => sum.plus(pos.totalCostCny || '0'),
|
|
||||||
0 as number | string
|
|
||||||
);
|
|
||||||
|
|
||||||
const dateStr = getTodayInShanghai();
|
|
||||||
|
|
||||||
const existing = await db
|
|
||||||
.select()
|
|
||||||
.from(portfolioSnapshots)
|
|
||||||
.where(eq(portfolioSnapshots.date, dateStr))
|
|
||||||
.limit(1);
|
|
||||||
|
|
||||||
const now = new Date();
|
|
||||||
|
|
||||||
if (existing.length > 0) {
|
|
||||||
await db
|
|
||||||
.update(portfolioSnapshots)
|
|
||||||
.set({
|
|
||||||
totalValueCny: String(totalValueCny),
|
|
||||||
totalCostCny: String(totalCostCny),
|
|
||||||
updatedAt: now,
|
|
||||||
})
|
|
||||||
.where(eq(portfolioSnapshots.date, dateStr));
|
|
||||||
|
|
||||||
return {
|
|
||||||
success: true,
|
|
||||||
action: 'updated',
|
|
||||||
date: dateStr,
|
|
||||||
totalValueCny: String(totalValueCny),
|
|
||||||
totalCostCny: String(totalCostCny),
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
await db
|
|
||||||
.insert(portfolioSnapshots)
|
|
||||||
.values({
|
|
||||||
date: dateStr,
|
|
||||||
totalValueCny: String(totalValueCny),
|
|
||||||
totalCostCny: String(totalCostCny),
|
|
||||||
createdAt: now,
|
|
||||||
updatedAt: now,
|
|
||||||
});
|
|
||||||
|
|
||||||
return {
|
|
||||||
success: true,
|
|
||||||
action: 'inserted',
|
|
||||||
date: dateStr,
|
|
||||||
totalValueCny: String(totalValueCny),
|
|
||||||
totalCostCny: String(totalCostCny),
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function getSnapshots(params?: {
|
|
||||||
limit?: number;
|
|
||||||
startDate?: string;
|
|
||||||
endDate?: string;
|
|
||||||
}) {
|
|
||||||
const { limit = 365, startDate, endDate } = params || {};
|
|
||||||
|
|
||||||
let query = db
|
|
||||||
.select()
|
|
||||||
.from(portfolioSnapshots)
|
|
||||||
.orderBy(sql`"${date}" DESC`);
|
|
||||||
|
|
||||||
if (startDate) {
|
|
||||||
query = query.where(sql`"${date}" >= ${startDate}`);
|
|
||||||
}
|
|
||||||
if (endDate) {
|
|
||||||
query = query.where(sql`"${date}" <= ${endDate}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
const snapshots = await query.limit(limit);
|
|
||||||
|
|
||||||
return snapshots.reverse();
|
|
||||||
}
|
|
||||||
@ -1,141 +0,0 @@
|
|||||||
'use client';
|
|
||||||
|
|
||||||
import { AreaChart, Area, XAxis, YAxis, Tooltip, ResponsiveContainer } from 'recharts';
|
|
||||||
|
|
||||||
interface Snapshot {
|
|
||||||
date: string;
|
|
||||||
totalValueCny: string;
|
|
||||||
totalCostCny: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
interface NetWorthChartProps {
|
|
||||||
snapshots: Snapshot[];
|
|
||||||
}
|
|
||||||
|
|
||||||
function CustomTooltip({ active, payload, label }: { active?: boolean; payload?: Array<{ name: string; value: string; payload: Snapshot }>; label?: string }) {
|
|
||||||
if (active && payload && payload.length) {
|
|
||||||
const data = payload[0].payload;
|
|
||||||
const totalValue = parseFloat(data.totalValueCny);
|
|
||||||
const totalCost = parseFloat(data.totalCostCny);
|
|
||||||
const pnl = totalValue - totalCost;
|
|
||||||
const pnlPercent = totalCost > 0 ? (pnl / totalCost) * 100 : 0;
|
|
||||||
const isPositive = pnl >= 0;
|
|
||||||
|
|
||||||
const formattedDate = (label || '').replace(/-/g, '/');
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div style={{
|
|
||||||
backgroundColor: 'hsl(var(--card))',
|
|
||||||
borderColor: 'hsl(var(--border))',
|
|
||||||
borderRadius: '8px',
|
|
||||||
color: 'hsl(var(--foreground))',
|
|
||||||
fontSize: '13px',
|
|
||||||
padding: '12px 16px',
|
|
||||||
boxShadow: '0 4px 12px rgba(0,0,0,0.15)',
|
|
||||||
}}>
|
|
||||||
<div style={{ fontWeight: '600', marginBottom: '8px', fontSize: '14px' }}>
|
|
||||||
{formattedDate}
|
|
||||||
</div>
|
|
||||||
<div style={{ display: 'flex', justifyContent: 'space-between', gap: '24px', marginBottom: '4px' }}>
|
|
||||||
<span style={{ color: 'hsl(var(--muted-foreground))', display: 'flex', alignItems: 'center', gap: '6px' }}>
|
|
||||||
<span style={{ display: 'inline-block', width: '8px', height: '8px', borderRadius: '2px', backgroundColor: '#f59e0b' }} />
|
|
||||||
总市值
|
|
||||||
</span>
|
|
||||||
<span style={{ fontWeight: '700', color: '#f59e0b' }}>
|
|
||||||
¥{totalValue.toLocaleString('zh-CN', { minimumFractionDigits: 2, maximumFractionDigits: 2 })}
|
|
||||||
</span>
|
|
||||||
</div>
|
|
||||||
<div style={{ display: 'flex', justifyContent: 'space-between', gap: '24px', marginBottom: '4px' }}>
|
|
||||||
<span style={{ color: 'hsl(var(--muted-foreground))', display: 'flex', alignItems: 'center', gap: '6px' }}>
|
|
||||||
<span style={{ display: 'inline-block', width: '8px', height: '8px', borderRadius: '2px', backgroundColor: '#9ca3af' }} />
|
|
||||||
投入本金
|
|
||||||
</span>
|
|
||||||
<span style={{ fontWeight: '600', color: 'hsl(var(--muted-foreground))' }}>
|
|
||||||
¥{totalCost.toLocaleString('zh-CN', { minimumFractionDigits: 2, maximumFractionDigits: 2 })}
|
|
||||||
</span>
|
|
||||||
</div>
|
|
||||||
<div style={{ display: 'flex', justifyContent: 'space-between', gap: '24px', paddingTop: '6px', borderTop: '1px solid hsl(var(--border))' }}>
|
|
||||||
<span style={{ color: 'hsl(var(--muted-foreground))', fontWeight: '500' }}>净盈亏</span>
|
|
||||||
<span style={{
|
|
||||||
fontWeight: '700',
|
|
||||||
color: isPositive ? '#ef4444' : '#22c55e',
|
|
||||||
}}>
|
|
||||||
{isPositive ? '+' : ''}¥{pnl.toLocaleString('zh-CN', { minimumFractionDigits: 2, maximumFractionDigits: 2 })}
|
|
||||||
{' '}({isPositive ? '+' : ''}{pnlPercent.toFixed(2)}%)
|
|
||||||
</span>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
export default function NetWorthChart({ snapshots }: NetWorthChartProps) {
|
|
||||||
if (!snapshots || snapshots.length === 0) {
|
|
||||||
return (
|
|
||||||
<div className="flex items-center justify-center h-[320px] text-muted-foreground">
|
|
||||||
暂无历史数据
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
const chartData = snapshots.map(s => ({
|
|
||||||
date: s.date.replace(/-/g, '/'),
|
|
||||||
totalValueCny: parseFloat(s.totalValueCny),
|
|
||||||
totalCostCny: parseFloat(s.totalCostCny),
|
|
||||||
}));
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div className="h-[320px] w-full">
|
|
||||||
<ResponsiveContainer width="100%" height="100%">
|
|
||||||
<AreaChart data={chartData} margin={{ top: 10, right: 20, left: 10, bottom: 10 }}>
|
|
||||||
<defs>
|
|
||||||
<linearGradient id="totalValueGradient" x1="0" y1="0" x2="0" y2="1">
|
|
||||||
<stop offset="0%" stopColor="#f59e0b" stopOpacity={0.3} />
|
|
||||||
<stop offset="100%" stopColor="#f59e0b" stopOpacity={0.02} />
|
|
||||||
</linearGradient>
|
|
||||||
<linearGradient id="totalCostGradient" x1="0" y1="0" x2="0" y2="1">
|
|
||||||
<stop offset="0%" stopColor="#9ca3af" stopOpacity={0.15} />
|
|
||||||
<stop offset="100%" stopColor="#9ca3af" stopOpacity={0.02} />
|
|
||||||
</linearGradient>
|
|
||||||
</defs>
|
|
||||||
<XAxis
|
|
||||||
dataKey="date"
|
|
||||||
tick={{ fontSize: 12, fill: 'hsl(var(--muted-foreground))' }}
|
|
||||||
axisLine={{ stroke: 'hsl(var(--border))' }}
|
|
||||||
tickLine={{ stroke: 'hsl(var(--border))' }}
|
|
||||||
interval="preserveStartEnd"
|
|
||||||
/>
|
|
||||||
<YAxis
|
|
||||||
tick={{ fontSize: 12, fill: 'hsl(var(--muted-foreground))' }}
|
|
||||||
axisLine={{ stroke: 'hsl(var(--border))' }}
|
|
||||||
tickLine={{ stroke: 'hsl(var(--border))' }}
|
|
||||||
tickFormatter={(value: number) => {
|
|
||||||
if (value >= 1000000) return `¥${(value / 1000000).toFixed(1)}M`;
|
|
||||||
if (value >= 1000) return `¥${(value / 1000).toFixed(0)}K`;
|
|
||||||
return `¥${value.toFixed(0)}`;
|
|
||||||
}}
|
|
||||||
/>
|
|
||||||
<Tooltip content={<CustomTooltip />} />
|
|
||||||
<Area
|
|
||||||
type="monotone"
|
|
||||||
dataKey="totalValueCny"
|
|
||||||
stroke="#f59e0b"
|
|
||||||
strokeWidth={2}
|
|
||||||
fill="url(#totalValueGradient)"
|
|
||||||
name="总市值"
|
|
||||||
/>
|
|
||||||
<Area
|
|
||||||
type="monotone"
|
|
||||||
dataKey="totalCostCny"
|
|
||||||
stroke="#9ca3af"
|
|
||||||
strokeWidth={1.5}
|
|
||||||
strokeDasharray="4 4"
|
|
||||||
fill="url(#totalCostGradient)"
|
|
||||||
name="投入本金"
|
|
||||||
/>
|
|
||||||
</AreaChart>
|
|
||||||
</ResponsiveContainer>
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
@ -100,8 +100,8 @@ export function UpdateTransactionDialog({
|
|||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (transaction && open) {
|
if (transaction && open) {
|
||||||
form.reset({
|
form.reset({
|
||||||
assetId: String(transaction.assetId),
|
assetId: transaction.assetId,
|
||||||
txType: String(transaction.txType),
|
txType: transaction.txType,
|
||||||
quantity: parseFloat(transaction.quantity).toString(),
|
quantity: parseFloat(transaction.quantity).toString(),
|
||||||
price: parseFloat(transaction.price).toString(),
|
price: parseFloat(transaction.price).toString(),
|
||||||
fee: parseFloat(transaction.fee || 0).toString(),
|
fee: parseFloat(transaction.fee || 0).toString(),
|
||||||
@ -150,9 +150,9 @@ export function UpdateTransactionDialog({
|
|||||||
render={({ field }) => (
|
render={({ field }) => (
|
||||||
<FormItem>
|
<FormItem>
|
||||||
<FormLabel>标的资产</FormLabel>
|
<FormLabel>标的资产</FormLabel>
|
||||||
<Select onValueChange={field.onChange} value={field.value} defaultValue={field.value}>
|
<Select disabled={true} onValueChange={field.onChange} value={field.value} defaultValue={field.value}>
|
||||||
<FormControl>
|
<FormControl>
|
||||||
<SelectTrigger disabled={true}>
|
<SelectTrigger>
|
||||||
<SelectValue placeholder="选择资产" />
|
<SelectValue placeholder="选择资产" />
|
||||||
</SelectTrigger>
|
</SelectTrigger>
|
||||||
</FormControl>
|
</FormControl>
|
||||||
@ -174,9 +174,9 @@ export function UpdateTransactionDialog({
|
|||||||
render={({ field }) => (
|
render={({ field }) => (
|
||||||
<FormItem>
|
<FormItem>
|
||||||
<FormLabel>交易类型</FormLabel>
|
<FormLabel>交易类型</FormLabel>
|
||||||
<Select onValueChange={field.onChange} value={field.value} defaultValue={field.value}>
|
<Select disabled={true} onValueChange={field.onChange} value={field.value} defaultValue={field.value}>
|
||||||
<FormControl>
|
<FormControl>
|
||||||
<SelectTrigger disabled={true}>
|
<SelectTrigger>
|
||||||
<SelectValue placeholder="选择交易类型" />
|
<SelectValue placeholder="选择交易类型" />
|
||||||
</SelectTrigger>
|
</SelectTrigger>
|
||||||
</FormControl>
|
</FormControl>
|
||||||
@ -201,7 +201,7 @@ export function UpdateTransactionDialog({
|
|||||||
<FormItem>
|
<FormItem>
|
||||||
<FormLabel>數量</FormLabel>
|
<FormLabel>數量</FormLabel>
|
||||||
<FormControl>
|
<FormControl>
|
||||||
<Input type="text" autoComplete="off" {...field} />
|
<Input type="text" {...field} />
|
||||||
</FormControl>
|
</FormControl>
|
||||||
<FormMessage />
|
<FormMessage />
|
||||||
</FormItem>
|
</FormItem>
|
||||||
@ -214,7 +214,7 @@ export function UpdateTransactionDialog({
|
|||||||
<FormItem>
|
<FormItem>
|
||||||
<FormLabel>價格</FormLabel>
|
<FormLabel>價格</FormLabel>
|
||||||
<FormControl>
|
<FormControl>
|
||||||
<Input type="text" autoComplete="off" {...field} />
|
<Input type="text" {...field} />
|
||||||
</FormControl>
|
</FormControl>
|
||||||
<FormMessage />
|
<FormMessage />
|
||||||
</FormItem>
|
</FormItem>
|
||||||
@ -229,7 +229,7 @@ export function UpdateTransactionDialog({
|
|||||||
<FormItem>
|
<FormItem>
|
||||||
<FormLabel>手續費</FormLabel>
|
<FormLabel>手續費</FormLabel>
|
||||||
<FormControl>
|
<FormControl>
|
||||||
<Input type="text" autoComplete="off" {...field} />
|
<Input type="text" {...field} />
|
||||||
</FormControl>
|
</FormControl>
|
||||||
<FormMessage />
|
<FormMessage />
|
||||||
</FormItem>
|
</FormItem>
|
||||||
@ -265,7 +265,7 @@ export function UpdateTransactionDialog({
|
|||||||
<FormItem>
|
<FormItem>
|
||||||
<FormLabel>執行時間</FormLabel>
|
<FormLabel>執行時間</FormLabel>
|
||||||
<FormControl>
|
<FormControl>
|
||||||
<Input type="datetime-local" autoComplete="off" {...field} />
|
<Input type="datetime-local" {...field} />
|
||||||
</FormControl>
|
</FormControl>
|
||||||
<FormMessage />
|
<FormMessage />
|
||||||
</FormItem>
|
</FormItem>
|
||||||
|
|||||||
@ -1,4 +1,4 @@
|
|||||||
import { pgTable, uuid, varchar, timestamp, pgEnum, numeric, uniqueIndex, date } from "drizzle-orm/pg-core";
|
import { pgTable, uuid, varchar, timestamp, pgEnum, numeric, uniqueIndex } from "drizzle-orm/pg-core";
|
||||||
|
|
||||||
export const users = pgTable("users", {
|
export const users = pgTable("users", {
|
||||||
id: uuid("id").primaryKey().$defaultFn(() => crypto.randomUUID()),
|
id: uuid("id").primaryKey().$defaultFn(() => crypto.randomUUID()),
|
||||||
@ -65,16 +65,3 @@ export const exchangeRates = pgTable("exchange_rates", {
|
|||||||
}, (table) => [
|
}, (table) => [
|
||||||
uniqueIndex("currency_pair_idx").on(table.fromCurrency, table.toCurrency),
|
uniqueIndex("currency_pair_idx").on(table.fromCurrency, table.toCurrency),
|
||||||
]);
|
]);
|
||||||
|
|
||||||
export const portfolioSnapshots = pgTable("portfolio_snapshots", {
|
|
||||||
id: uuid("id").primaryKey().$defaultFn(() => crypto.randomUUID()),
|
|
||||||
date: date("date", { mode: "string" }).notNull().unique(),
|
|
||||||
totalValueCny: numeric("total_value_cny", { precision: 36, scale: 18 }).notNull(),
|
|
||||||
totalCostCny: numeric("total_cost_cny", { precision: 36, scale: 18 }).notNull(),
|
|
||||||
createdAt: timestamp("created_at", { withTimezone: true, mode: "date" })
|
|
||||||
.defaultNow()
|
|
||||||
.notNull(),
|
|
||||||
updatedAt: timestamp("updated_at", { withTimezone: true, mode: "date" })
|
|
||||||
.defaultNow()
|
|
||||||
.notNull(),
|
|
||||||
});
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user