add

backend/sql/04_country.sql

@@ -98,17 +98,19 @@ BEGIN
     CREATE OR REPLACE VIEW country_info_view AS
     SELECT 
         u.id AS country_id,
-        n.name AS name,
-        c.code AS code,
-        u.deleted AS deleted
+        n.name AS country_name,       -- 国家名称
+        c.code AS country_code,       -- 国家代码
+        f.flag AS country_flag,       -- 国旗信息
     FROM 
         country u
-    JOIN 
-        country_name n ON u.id = n.country_id
-    JOIN 
-        country_code c ON u.id = c.country_id
+    LEFT JOIN 
+        country_name n ON u.id = n.country_id AND n.deleted = FALSE  -- 过滤已删除名称
+    LEFT JOIN 
+        country_code c ON u.id = c.country_id AND c.deleted = FALSE  -- 过滤已删除代码
+    LEFT JOIN 
+        country_flag f ON u.id = f.country_id AND f.deleted = FALSE  -- 左连接：允许无国旗数据
     WHERE
-        u.deleted = FALSE;
+        u.deleted = FALSE;  -- 只查询未删除的国家
 
     -- 根据视图是否已存在输出不同提示
     IF view_exists THEN

backend/src/logic4country/04_country.sql

@@ -0,0 +1,135 @@
+-- 切换到目标数据库
+\c postgres;
+
+DO $$
+BEGIN
+    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'country') THEN
+        CREATE TABLE country ( 
+            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_country_updated_at
+        BEFORE UPDATE ON "country"
+        FOR EACH ROW
+        EXECUTE FUNCTION update_data_modified_column();
+        
+        RAISE NOTICE 'created country table and trigger';
+    ELSE
+        RAISE NOTICE 'country table already exists';
+    END IF;
+
+    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'country_name') THEN
+        CREATE TABLE country_name (
+            id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL,
+            country_id UUID NOT NULL,
+            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_name_updated_at
+        BEFORE UPDATE ON "country_name"
+        FOR EACH ROW
+        EXECUTE FUNCTION update_data_modified_column();
+        
+        RAISE NOTICE 'created country_name table and trigger';
+    ELSE
+        RAISE NOTICE 'country_name table already exists';
+    END IF;
+
+    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'country_code') THEN
+        CREATE TABLE country_code (
+            id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL,
+            country_id UUID NOT NULL,
+            code 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_code_updated_at
+        BEFORE UPDATE ON "country_code"
+        FOR EACH ROW
+        EXECUTE FUNCTION update_data_modified_column();
+        
+        RAISE NOTICE 'created country_code table and trigger';
+    ELSE
+        RAISE NOTICE 'country_code table already exists';
+    END IF;
+
+    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'country_flag') THEN
+        CREATE TABLE country_flag (
+            id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL,
+            country_id UUID NOT NULL,
+            flag 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_flag_updated_at
+        BEFORE UPDATE ON "country_flag"
+        FOR EACH ROW
+        EXECUTE FUNCTION update_data_modified_column();
+        
+        RAISE NOTICE 'created country_flag table and trigger';
+    ELSE
+        RAISE NOTICE 'country_flag table already exists';
+    END IF;
+END $$;
+
+DO $$
+DECLARE
+    view_exists BOOLEAN;
+BEGIN
+    -- 检查视图是否已存在
+    SELECT EXISTS (
+        SELECT 1 FROM information_schema.views 
+        WHERE table_name = 'country_info_view'
+    ) INTO view_exists;
+
+    -- 若视图存在，先删除（避免字段名冲突）
+    IF view_exists THEN
+        DROP VIEW country_info_view;
+        RAISE NOTICE '已删除旧视图 country_info_view';
+    END IF;
+
+    -- 创建或更新视图
+    -- 创建新视图（关联所有子表，展示完整品种信息）
+    CREATE VIEW variety_info_view AS
+    SELECT
+        v.id AS variety_id,
+        vn.name AS variety_name,
+        vc.code AS variety_code,
+        vt.tick AS min_tick, -- 最小变动价位
+        vtp.price AS tick_value, -- 变动价位价值
+        ve.exchange_id, -- 关联的交易所ID
+        -- 关联交易所名称（需确保 exchange_name 表存在，若不需要可删除以下 2 行）
+        en.name AS exchange_name,
+        esn.short_name AS exchange_short_name,
+        v.deleted,
+        v.created_at,
+        v.updated_at
+    FROM
+        variety v
+    LEFT JOIN variety_name vn ON v.id = vn.variety_id AND vn.deleted = FALSE
+    LEFT JOIN variety_code vc ON v.id = vc.variety_id AND vc.deleted = FALSE
+    LEFT JOIN variety_tick vt ON v.id = vt.variety_id AND vt.deleted = FALSE
+    LEFT JOIN variety_tick_price vtp ON v.id = vtp.variety_id AND vtp.deleted = FALSE
+    LEFT JOIN variety_exchange ve ON v.id = ve.variety_id AND ve.deleted = FALSE
+    -- 关联交易所名称表（可选，根据实际需求决定是否保留）
+    LEFT JOIN exchange_name en ON ve.exchange_id = en.exchange_id AND en.deleted = FALSE
+    LEFT JOIN exchange_short_name esn ON ve.exchange_id = esn.exchange_id AND esn.deleted = FALSE
+    WHERE
+        v.deleted = FALSE;
+
+    -- 根据视图是否已存在输出不同提示
+    IF view_exists THEN
+        RAISE NOTICE '视图 country_info_view 已更新（删除旧视图后重建）';
+    ELSE
+        RAISE NOTICE '视图 country_info_view 已创建';
+    END IF;
+EXCEPTION
+    WHEN OTHERS THEN
+        RAISE NOTICE '处理视图时发生错误: %', SQLERRM;
+END $$;