add

backend/futures_trade_record/sql/02_create_update_function.sql

@@ -0,0 +1,7 @@
+CREATE OR REPLACE FUNCTION update_data_modified_column()
+RETURNS TRIGGER AS $$
+BEGIN
+    NEW.updated_at = CURRENT_TIMESTAMP;
+    RETURN NEW;
+END;
+$$ LANGUAGE plpgsql VOLATILE;

backend/futures_trade_record/sql/03_create_record_table.sql

@@ -1,14 +1,6 @@
 -- 切换到目标数据库
 \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
@@ -21,7 +13,7 @@ BEGIN
         CREATE TRIGGER update_record_updated_at
         BEFORE UPDATE ON "record"
         FOR EACH ROW
-        EXECUTE FUNCTION update_record_modified_column();
+        EXECUTE FUNCTION update_data_modified_column();
         
         RAISE NOTICE 'created record table and trigger';
     ELSE

backend/futures_trade_record/sql/04_create_deal_table.sql

@@ -1,14 +1,6 @@
 -- 切换到目标数据库
 \c postgres;
 
-CREATE OR REPLACE FUNCTION update_deal_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 = 'deal') THEN
@@ -42,7 +34,7 @@ BEGIN
         CREATE TRIGGER update_deal_updated_at
         BEFORE UPDATE ON "deal"
         FOR EACH ROW
-        EXECUTE FUNCTION update_deal_modified_column();
+        EXECUTE FUNCTION update_data_modified_column();
 
         -- 1. 开仓日期索引（支持「未删除+开仓日期」查询）
         CREATE INDEX idx_trade_open_date ON deal (deleted, open_year, open_month, open_day);

backend/futures_trade_record/sql/04_create_variety_table.sql

@@ -0,0 +1,41 @@
+-- 切换到目标数据库
+\c postgres;
+
+DO $$
+BEGIN
+    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety') THEN
+        CREATE TABLE variety ( 
+            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_variety_updated_at
+        BEFORE UPDATE ON "variety"
+        FOR EACH ROW
+        EXECUTE FUNCTION update_data_modified_column();
+        
+        RAISE NOTICE 'created variety table and trigger';
+    ELSE
+        RAISE NOTICE 'variety table already exists';
+    END IF;
+
+    IF NOT EXISTS (SELECT 1 FROM information_schema.tables WHERE table_name = 'variety_name') THEN
+        CREATE TABLE variety_name ( 
+            id UUID DEFAULT gen_random_uuid_v7() PRIMARY KEY NOT NULL,
+            name VARCHAR(50) NOT NULL,
+            code VARCHAR(50) 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_name_updated_at
+        BEFORE UPDATE ON "variety_name"
+        FOR EACH ROW
+        EXECUTE FUNCTION update_data_modified_column();
+        
+        RAISE NOTICE 'created variety_name table and trigger';
+    ELSE
+        RAISE NOTICE 'variety_name table already exists';
+    END IF;
+END $$;