-- =========================================================
-- trade.sql 🎉
-- 无物化视图 | 超可视提示 | 可重复执行
-- PostgreSQL 17.4+ 👍
-- =========================================================

-- 1️⃣ 开始 🚀
DO $$
BEGIN
    RAISE NOTICE '🚀============ trade 部署开始 ============🚀';
END $$;

-- 2️⃣ 连接目标库
\c postgres;

-- 3️⃣ 表结构 -----------------------------------
DO $$
BEGIN
    -- trade 主表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade') THEN
        CREATE TABLE trade (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            deleted BOOLEAN NOT NULL DEFAULT FALSE,
            created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
            updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
        );
        RAISE NOTICE '1️⃣✅ trade 主表已创建';
    ELSE
        RAISE NOTICE '1️⃣⏩ trade 主表已存在，跳过';
    END IF;

    -- remark 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_remark') THEN
        CREATE TABLE remark (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            remark VARCHAR 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_remark_updated_at
            BEFORE UPDATE ON remark
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '2️⃣✅ remark 子表已创建';
    ELSE
        RAISE NOTICE '2️⃣⏩ remark 子表已存在，跳过';
    END IF;

    -- open_date 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_open_date') THEN
        CREATE TABLE open_date (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            year INT NOT NULL DEFAULT 0,
            month INT NOT NULL DEFAULT 0,
            day INT NOT NULL DEFAULT 0,
            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_date_updated_at
            BEFORE UPDATE ON open_date
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '3️⃣✅ open_date 子表已创建';
    ELSE
        RAISE NOTICE '3️⃣⏩ open_date 子表已存在，跳过';
    END IF;

    -- variety 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_variety') THEN
        CREATE TABLE variety (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            variety_id UUID NOT NULL,
            variety_name VARCHAR 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_variety_updated_at
            BEFORE UPDATE ON variety
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '4️⃣✅ variety 子表已创建';
    ELSE
        RAISE NOTICE '4️⃣⏩ variety 子表已存在，跳过';
    END IF;

    -- direction 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_direction') THEN
        CREATE TABLE direction (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            direction VARCHAR 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_direction_updated_at
            BEFORE UPDATE ON direction
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '5️⃣✅ direction 子表已创建';
    ELSE
        RAISE NOTICE '5️⃣⏩ direction 子表已存在，跳过';
    END IF;

    -- open_price 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_open_price') THEN
        CREATE TABLE open_price (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            open_price NUMERIC(10,6) NOT NULL CHECK (open_price >= 0.00) DEFAULT 0.00,
            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_price_updated_at
            BEFORE UPDATE ON open_price
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '6️⃣✅ open_price 子表已创建';
    ELSE
        RAISE NOTICE '6️⃣⏩ open_price 子表已存在，跳过';
    END IF;

    -- open_fee 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_open_fee') THEN
        CREATE TABLE open_fee (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            open_fee NUMERIC(10,6) NOT NULL CHECK (open_fee >= 0.00) DEFAULT 0.00,
            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_fee_updated_at
            BEFORE UPDATE ON open_fee
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '7️⃣✅ open_fee 子表已创建';
    ELSE
        RAISE NOTICE '7️⃣⏩ open_fee 子表已存在，跳过';
    END IF;

    -- close_date 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_close_date') THEN
        CREATE TABLE close_date (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            year INT NOT NULL DEFAULT 0,
            month INT NOT NULL DEFAULT 0,
            day INT NOT NULL DEFAULT 0,
            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_close_date_updated_at
            BEFORE UPDATE ON close_date
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '8️⃣✅ close_date 子表已创建';
    ELSE
        RAISE NOTICE '8️⃣⏩ close_date 子表已存在，跳过';
    END IF;

    -- close_price 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_close_price') THEN
        CREATE TABLE close_price (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            close_price NUMERIC(10,6) NOT NULL CHECK (close_price >= 0.00) DEFAULT 0.00,
            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_close_price_updated_at
            BEFORE UPDATE ON close_price
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '9️⃣✅ close_price 子表已创建';
    ELSE
        RAISE NOTICE '9️⃣⏩ close_price 子表已存在，跳过';
    END IF;

    -- close_fee 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_close_fee') THEN
        CREATE TABLE close_fee (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            close_fee NUMERIC(10,6) NOT NULL CHECK (close_fee >= 0.00) DEFAULT 0.00,
            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_close_fee_updated_at
            BEFORE UPDATE ON close_fee
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '🔟✅ close_fee 子表已创建';
    ELSE
        RAISE NOTICE '🔟⏩ close_fee 子表已存在，跳过';
    END IF;

    -- profit 子表
    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'trade_profit') THEN
        CREATE TABLE profit (
            id UUID DEFAULT gen_random_uuid() PRIMARY KEY,
            trade_id UUID NOT NULL,
            variety_tick NUMERIC(12,6) NOT NULL DEFAULT 0.00,
            variety_tick_price NUMERIC(12,6) NOT NULL CHECK (variety_tick_price >= 0.00) DEFAULT 0.00,
            win_tick NUMERIC(12,6) NOT NULL DEFAULT 0.00,
            win_tick_price NUMERIC(12,6) NOT NULL DEFAULT 0.00,
            fee_cost NUMERIC(12,6) NOT NULL DEFAULT 0.00,
            trade_win NUMERIC(12,6) NOT NULL DEFAULT 0.00,
            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_profit_updated_at
            BEFORE UPDATE ON profit
            FOR EACH ROW EXECUTE FUNCTION update_data_modified_column();
        RAISE NOTICE '1️⃣1️⃣✅ profit 子表已创建';
    ELSE
        RAISE NOTICE '1️⃣1️⃣⏩ profit 子表已存在，跳过';
    END IF;
END $$;

-- 4️⃣ 视图 ------------------------------------
DROP VIEW IF EXISTS trade_info_view;
CREATE OR REPLACE VIEW trade_info_view AS
SELECT
    t.id AS trade_id,
    r.remark AS remark,
    od.year AS open_year,
    od.month AS open_month,
    od.day AS open_day,
    v.variety_name AS variety_name,
    d.direction AS direction,
    format_numeric_to_original(op.open_price) AS open_price,
    format_numeric_to_original(of.open_fee) AS open_fee,
    cd.year AS close_year,
    cd.month AS close_month,
    cd.day AS close_day,
    format_numeric_to_original(cp.close_price) AS close_price,
    format_numeric_to_original(cp.close_fee) AS close_fee,
FROM trade t
LEFT JOIN remark r ON t.id = r.trade_id AND r.deleted = FALSE
LEFT JOIN open_date od ON t.id = od.trade_id AND od.deleted = FALSE
LEFT JOIN variety v ON t.id = v.trade_id AND v.deleted = FALSE
LEFT JOIN direction d ON t.id = d.trade_id AND d.deleted = FALSE
LEFT JOIN open_price op ON t.id = op.trade_id AND op.deleted = FALSE
LEFT JOIN open_fee of ON t.id = of.trade_id AND of.deleted = FALSE
LEFT JOIN close_date cd ON t.id = cd.trade_id AND cd.deleted = FALSE
LEFT JOIN close_price cp ON t.id = cp.trade_id AND cp.deleted = FALSE
LEFT JOIN close_fee cf ON t.id = cf.trade_id AND cf.deleted = FALSE
WHERE t.deleted = FALSE;

RAISE NOTICE '4️⃣✅ trade_info_view 已创建/更新';

-- 5️⃣ 性能索引 ------------------------------------------------
CREATE INDEX IF NOT EXISTS idx_remark_trade_id_deleted ON remark(trade_id, deleted);
CREATE INDEX IF NOT EXISTS idx_open_date_trade_id_deleted ON open_date(trade_id, deleted);
CREATE INDEX IF NOT EXISTS idx_variety_trade_id_deleted ON variety(trade_id, deleted);
CREATE INDEX IF NOT EXISTS idx_direction_trade_id_deleted ON direction(trade_id, deleted);
CREATE INDEX IF NOT EXISTS idx_open_price_trade_id_deleted ON open_price(trade_id, deleted);
CREATE INDEX IF NOT EXISTS idx_open_fee_trade_id_deleted ON open_fee(trade_id, deleted);
CREATE INDEX IF NOT EXISTS idx_close_date_trade_id_deleted ON close_date(trade_id, deleted);
CREATE INDEX IF NOT EXISTS idx_close_price_trade_id_deleted ON close_price(trade_id, deleted);
CREATE INDEX IF NOT EXISTS idx_close_fee_trade_id_deleted ON close_fee(trade_id, deleted);

RAISE NOTICE '5️⃣✅ 全部索引已确保存在';

-- 6️⃣ 完成 🎉
DO $$
BEGIN
    RAISE NOTICE '🎉============ trade 部署完成 ============🎉';
END $$;