fish/asset_assistant
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add

Browse Source
This commit is contained in:
vipg
2025-11-14 15:50:30 +08:00
parent 338e2603a6
commit 9627c939f6
3 changed files with 67 additions and 92 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
backend/futures_trade_record/sql/02_create_record_table.sql Normal file
View File

@@ -0,0 +1,30 @@
-- 切换到目标数据库
\c postgres;
CREATE OR REPLACE FUNCTION update_record_modified_column()
RETURNS TRIGGER AS $$
BEGIN
NEW.updated_at = CURRENT_TIMESTAMP;
RETURN NEW;
END;
$$ LANGUAGE plpgsql VOLATILE;
DO $$
BEGIN
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'record') THEN
CREATE TABLE record (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL,
deleted BOOLEAN NOT NULL DEFAULT FALSE,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
);
CREATE TRIGGER update_record_updated_at
BEFORE UPDATE ON "record"
FOR EACH ROW
EXECUTE FUNCTION update_record_modified_column();
RAISE NOTICE 'created record table and trigger';
ELSE
RAISE NOTICE 'record table already exists';
END IF;
END $$;

92
backend/futures_trade_record/sql/02_create_trade_record_table.sql
View File

@@ -1,92 +0,0 @@
-- 切换到目标数据库
\c postgres;
CREATE OR REPLACE FUNCTION update_trade_record_modified_column()
RETURNS TRIGGER AS $$
BEGIN
NEW.updated_at = CURRENT_TIMESTAMP;
RETURN NEW;
END;
$$ LANGUAGE plpgsql VOLATILE;
DO $$
BEGIN
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_trade_record = 'trade_record') THEN
-- 创建交易记录表（根据业务场景命名为 trade_record，可按需修改）
CREATE TABLE trade_record (
-- 主键 UUID，默认使用 PostgreSQL 内置函数生成唯一值
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL,
-- 开仓日期相关（整数类型，限制合理范围避免无效数据）
open_year INT NOT NULL CHECK (open_year > 1900 AND open_year <= EXTRACT(YEAR FROM CURRENT_DATE) + 1),
open_month INT NOT NULL CHECK (open_month BETWEEN 1 AND 12),
open_day INT NOT NULL CHECK (open_day BETWEEN 1 AND 31),
-- 品种、合约、方向（字符串类型，根据业务长度调整 varchar 长度）
variety VARCHAR(50) NOT NULL, -- 品种（如：黄金、原油）
contract VARCHAR(50) NOT NULL, -- 合约（如：AU2406、CL2407）
direction VARCHAR(20) NOT NULL CHECK (direction IN ('多头', '空头', '买入', '卖出')), -- 限制合法方向值
-- 开仓相关数值（使用 numeric 类型替代 double，避免浮点数精度丢失，适合金融数据）
open_price NUMERIC(12, 6) NOT NULL, -- 开仓价格（精度：整数位6位+小数位6位，可按需调整）
open_commission NUMERIC(10, 6) NOT NULL DEFAULT 0.00, -- 开仓手续费（默认0）
-- 平仓日期相关（允许 NULL，未平仓时为空）
close_year INT CHECK (close_year IS NULL OR (close_year > 1900 AND close_year <= EXTRACT(YEAR FROM CURRENT_DATE) + 1)),
close_month INT CHECK (close_month IS NULL OR close_month BETWEEN 1 AND 12),
close_day INT CHECK (close_day IS NULL OR close_day BETWEEN 1 AND 31),
-- 平仓相关数值（允许 NULL，未平仓时为空；同样使用 numeric 保证精度）
close_price NUMERIC(12, 6), -- 平仓价格
close_commission NUMERIC(10, 6) DEFAULT 0.00, -- 平仓手续费（默认0）
variety_tick NUMERIC(12, 6), -- 品种跳点
close_tick_diff NUMERIC(12, 6), -- 平仓跳点差价
tick_price NUMERIC(12, 6), -- 跳点价格
tick_diff_profit NUMERIC(12, 6), -- 平仓跳点差价盈亏
total_commission NUMERIC(10, 6) DEFAULT 0.00, -- 总手续费（开仓+平仓，可通过触发器自动计算）
close_profit NUMERIC(12, 6) -- 平仓盈亏
deleted BOOLEAN NOT NULL DEFAULT FALSE,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
);
CREATE TRIGGER update_trade_record_updated_at
BEFORE UPDATE ON "trade_record"
FOR EACH ROW
EXECUTE FUNCTION update_trade_record_modified_column();
-- 按开仓日期查询索引
CREATE INDEX idx_trade_open_date ON trade_record (open_year, open_month, open_day);
-- 按品种+合约查询索引
CREATE INDEX idx_trade_variety_contract ON trade_record (variety, contract);
-- 按平仓状态查询索引（未平仓：close_year IS NULL）
CREATE INDEX idx_trade_close_status ON trade_record (close_year);
--------------- 注释说明（增强可读性）-------------
COMMENT ON TABLE trade_record IS '交易记录表（存储开仓/平仓相关信息）';
COMMENT ON COLUMN trade_record.id IS '主键UUID（全局唯一标识）';
COMMENT ON COLUMN trade_record.open_year IS '开仓年份';
COMMENT ON COLUMN trade_record.open_month IS '开仓月份';
COMMENT ON COLUMN trade_record.open_day IS '开仓日期';
COMMENT ON COLUMN trade_record.variety IS '交易品种（如：FG、RB）';
COMMENT ON COLUMN trade_record.contract IS '交易合约（如：2401）';
COMMENT ON COLUMN trade_record.direction IS '交易方向（多/空）';
COMMENT ON COLUMN trade_record.open_price IS '开仓价格';
COMMENT ON COLUMN trade_record.open_commission IS '开仓手续费';
COMMENT ON COLUMN trade_record.close_year IS '平仓年份（未平仓为NULL）';
COMMENT ON COLUMN trade_record.close_month IS '平仓月份（未平仓为NULL）';
COMMENT ON COLUMN trade_record.close_day IS '平仓日期（未平仓为NULL）';
COMMENT ON COLUMN trade_record.close_price IS '平仓价格（未平仓为NULL）';
COMMENT ON COLUMN trade_record.close_commission IS '平仓手续费（未平仓为NULL）';
COMMENT ON COLUMN trade_record.variety_tick IS '品种跳点';
COMMENT ON COLUMN trade_record.close_tick_diff IS '平仓差价跳点（（平仓价格-开仓价格）/品种最小跳点）';
COMMENT ON COLUMN trade_record.tick_price IS '跳点价格（单个跳点对应的金额）';
COMMENT ON COLUMN trade_record.tick_diff_profit IS '差价盈亏（基于平仓差价跳点计算的盈利/亏损）';
COMMENT ON COLUMN trade_record.total_commission IS '总手续费（开仓+平仓，自动计算）';
COMMENT ON COLUMN trade_record.close_profit IS '平仓盈亏（最终实际盈利/亏损）';
RAISE NOTICE 'created trade_record table and trigger';
ELSE
RAISE NOTICE 'trade_record table already exists';
END IF;
END $$;

37
backend/futures_trade_record/sql/03_create_open_table.sql Normal file
View File

@@ -0,0 +1,37 @@
-- 切换到目标数据库
\c postgres;
CREATE OR REPLACE FUNCTION update_open_modified_column()
RETURNS TRIGGER AS $$
BEGIN
NEW.updated_at = CURRENT_TIMESTAMP;
RETURN NEW;
END;
$$ LANGUAGE plpgsql VOLATILE;
DO $$
BEGIN
IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_open = 'open') THEN
CREATE TABLE open (
id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL,
record_id UUID NOT NULL,
year INT NOT NULL,
month INT NOT NULL,
day INT NOT NULL,
variety_id VARCHAR(50) NOT NULL, -- 品种id
contract VARCHAR(50) NOT NULL, -- 合约（如：2401）
direction VARCHAR(20) NOT NULL CHECK (direction IN ('多', '空')), -- 限制合法方向
deleted BOOLEAN NOT NULL DEFAULT FALSE,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
);
CREATE TRIGGER update_open_updated_at
BEFORE UPDATE ON "open"
FOR EACH ROW
EXECUTE FUNCTION update_open_modified_column();
RAISE NOTICE 'Created open table and trigger';
ELSE
RAISE NOTICE 'open table already exists';
END IF;
END $$;