diff --git a/newstock-system/src/main/java/com/ruoyi/newstocksystem/domain/TTrends.java b/newstock-system/src/main/java/com/ruoyi/newstocksystem/domain/TTrends.java
index de36eab..b98b467 100644
--- a/newstock-system/src/main/java/com/ruoyi/newstocksystem/domain/TTrends.java
+++ b/newstock-system/src/main/java/com/ruoyi/newstocksystem/domain/TTrends.java
@@ -24,6 +24,10 @@ public class TTrends extends BaseEntity
     @Excel(name = "交易日期", dateFormat = "yyyy-MM-dd")
     private Date tradeDate;
 
+    /** 行业名称（关联t_industry_basic表） */
+    @Excel(name = "行业名称")
+    private String industryName;
+    
     /** 所属东财行业代码 */
     @Excel(name = "东财行业代码")
     private String eastmoneyIndustryCode;
@@ -84,6 +88,16 @@ public class TTrends extends BaseEntity
         this.tradeDate = tradeDate;
     }
 
+    public String getIndustryName()
+    {
+        return industryName;
+    }
+
+    public void setIndustryName(String industryName)
+    {
+        this.industryName = industryName;
+    }
+    
     public String getEastmoneyIndustryCode()
     {
         return eastmoneyIndustryCode;
diff --git a/newstock-system/src/main/java/com/ruoyi/newstocksystem/mapper/TIndustryBasicMapper.java b/newstock-system/src/main/java/com/ruoyi/newstocksystem/mapper/TIndustryBasicMapper.java
index 3d4ef0c..c44d825 100644
--- a/newstock-system/src/main/java/com/ruoyi/newstocksystem/mapper/TIndustryBasicMapper.java
+++ b/newstock-system/src/main/java/com/ruoyi/newstocksystem/mapper/TIndustryBasicMapper.java
@@ -66,4 +66,12 @@ public interface TIndustryBasicMapper
      * @return 结果
      */
     public int batchUpsertIndustryBasic(List<TIndustryBasic> industryBasicList);
+    
+    /**
+     * 根据行业名称查询行业基础数据
+     * 
+     * @param industryName 行业名称
+     * @return 行业基础数据
+     */
+    public TIndustryBasic selectTIndustryBasicByName(String industryName);
 }
\ No newline at end of file
diff --git a/newstock-system/src/main/java/com/ruoyi/newstocksystem/service/TTrendsService.java b/newstock-system/src/main/java/com/ruoyi/newstocksystem/service/TTrendsService.java
index 551bf89..42c84fb 100644
--- a/newstock-system/src/main/java/com/ruoyi/newstocksystem/service/TTrendsService.java
+++ b/newstock-system/src/main/java/com/ruoyi/newstocksystem/service/TTrendsService.java
@@ -68,10 +68,18 @@ public interface TTrendsService
     public int batchUpsert(List<TTrends> tTrendsList);
     
     /**
-     * 验证行业代码是否在基础表中存在
+     * 验证行业名称是否在基础表中存在
      * 
-     * @param industryCode 行业代码
+     * @param industryName 行业名称
      * @return 是否存在
      */
-    public boolean validateIndustryCodeExists(String industryCode);
+    public boolean validateIndustryNameExists(String industryName);
+    
+    /**
+     * 验证行业名称（关联t_industry_basic表）是否在基础表中存在
+     * 
+     * @param industryName 行业名称
+     * @return 是否存在
+     */
+    public boolean validateIndustryBasicNameExists(String industryName);
 }
\ No newline at end of file
diff --git a/newstock-system/src/main/java/com/ruoyi/newstocksystem/service/impl/TTrendsServiceImpl.java b/newstock-system/src/main/java/com/ruoyi/newstocksystem/service/impl/TTrendsServiceImpl.java
index 824e6c8..8e6fc48 100644
--- a/newstock-system/src/main/java/com/ruoyi/newstocksystem/service/impl/TTrendsServiceImpl.java
+++ b/newstock-system/src/main/java/com/ruoyi/newstocksystem/service/impl/TTrendsServiceImpl.java
@@ -108,8 +108,15 @@ public class TTrendsServiceImpl implements TTrendsService
     }
     
     @Override
-    public boolean validateIndustryCodeExists(String industryCode)
+    public boolean validateIndustryNameExists(String industryName)
     {
-        return tIndustryBasicMapper.selectTIndustryBasicByCode(industryCode) != null;
+        // 由于t_trends表现在使用industry_name作为主键的一部分，这里应该验证行业名称
+        return tIndustryBasicMapper.selectTIndustryBasicByName(industryName) != null;
+    }
+    
+    @Override
+    public boolean validateIndustryBasicNameExists(String industryName)
+    {
+        return tIndustryBasicMapper.selectTIndustryBasicByName(industryName) != null;
     }
 }
\ No newline at end of file
diff --git a/newstock-system/src/main/resources/mapper/newstocksystem/TIndustryBasicMapper.xml b/newstock-system/src/main/resources/mapper/newstocksystem/TIndustryBasicMapper.xml
index c038e72..de8c1cf 100644
--- a/newstock-system/src/main/resources/mapper/newstocksystem/TIndustryBasicMapper.xml
+++ b/newstock-system/src/main/resources/mapper/newstocksystem/TIndustryBasicMapper.xml
@@ -43,6 +43,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         order by sort_order asc
     </select>
 
+    <select id="selectTIndustryBasicByName" parameterType="String" resultMap="TIndustryBasicResult">
+        <include refid="selectTIndustryBasicVo"/>
+        where industry_name = #{industryName}
+    </select>
+
     <insert id="insertTIndustryBasic" parameterType="com.ruoyi.newstocksystem.domain.TIndustryBasic" useGeneratedKeys="false">
         insert into t_industry_basic
         <trim prefix="(" suffix=")" suffixOverrides=",">
diff --git a/newstock-system/src/main/resources/mapper/newstocksystem/TStocksInTrendMapper.xml b/newstock-system/src/main/resources/mapper/newstocksystem/TStocksInTrendMapper.xml
index 7751303..b9e52a6 100644
--- a/newstock-system/src/main/resources/mapper/newstocksystem/TStocksInTrendMapper.xml
+++ b/newstock-system/src/main/resources/mapper/newstocksystem/TStocksInTrendMapper.xml
@@ -97,7 +97,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         </foreach>
         ON DUPLICATE KEY UPDATE
             rank = VALUES(rank),
-            momentum_type = VALUES(momentum_type),
             update_time = VALUES(update_time)
     </insert>
 </mapper>
\ No newline at end of file
diff --git a/newstock-system/src/main/resources/mapper/newstocksystem/TTrendsMapper.xml b/newstock-system/src/main/resources/mapper/newstocksystem/TTrendsMapper.xml
index 72da911..12ac1cb 100644
--- a/newstock-system/src/main/resources/mapper/newstocksystem/TTrendsMapper.xml
+++ b/newstock-system/src/main/resources/mapper/newstocksystem/TTrendsMapper.xml
@@ -7,6 +7,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <resultMap type="TTrends" id="TTrendsResult">
         <id     property="id"                           column="id"                           />
         <result property="tradeDate"                    column="trade_date"                    />
+        <result property="industryName"                 column="industry_name"                 />
         <result property="eastmoneyIndustryCode"        column="eastmoney_industry_code"        />
         <result property="eastmoneyIndustryName"        column="eastmoney_industry_name"        />
         <result property="stocksCount"                  column="stocks_count"                  />
@@ -20,7 +21,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </resultMap>
 
     <sql id="selectTTrendsVo">
-        select id, trade_date, eastmoney_industry_code, eastmoney_industry_name, stocks_count, trend_value, trend_value_change, rank, rank_change, momentum_type, create_time, update_time from t_trends
+        select id, trade_date, industry_name, eastmoney_industry_code, eastmoney_industry_name, stocks_count, trend_value, trend_value_change, rank, rank_change, momentum_type, create_time, update_time from t_trends
     </sql>
 
     <select id="selectTTrendsById" parameterType="Long" resultMap="TTrendsResult">
@@ -32,6 +33,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <include refid="selectTTrendsVo"/>
         <where>
             <if test="tradeDate != null ">and trade_date = #{tradeDate}</if>
+            <if test="industryName != null  and industryName != ''">and industry_name = #{industryName}</if>
             <if test="eastmoneyIndustryCode != null  and eastmoneyIndustryCode != ''">and eastmoney_industry_code = #{eastmoneyIndustryCode}</if>
             <if test="eastmoneyIndustryName != null  and eastmoneyIndustryName != ''">and eastmoney_industry_name = #{eastmoneyIndustryName}</if>
             <if test="stocksCount != null ">and stocks_count = #{stocksCount}</if>
@@ -47,6 +49,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         insert into t_trends
         <trim prefix="(" suffix=")" suffixOverrides=",">
             <if test="tradeDate != null">trade_date,</if>
+            <if test="industryName != null and industryName != ''">industry_name,</if>
             <if test="eastmoneyIndustryCode != null and eastmoneyIndustryCode != ''">eastmoney_industry_code,</if>
             <if test="eastmoneyIndustryName != null and eastmoneyIndustryName != ''">eastmoney_industry_name,</if>
             <if test="stocksCount != null">stocks_count,</if>
@@ -60,6 +63,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
          </trim>
         <trim prefix="values (" suffix=")" suffixOverrides=",">
             <if test="tradeDate != null">#{tradeDate},</if>
+            <if test="industryName != null and industryName != ''">#{industryName},</if>
             <if test="eastmoneyIndustryCode != null and eastmoneyIndustryCode != ''">#{eastmoneyIndustryCode},</if>
             <if test="eastmoneyIndustryName != null and eastmoneyIndustryName != ''">#{eastmoneyIndustryName},</if>
             <if test="stocksCount != null">#{stocksCount},</if>
@@ -77,6 +81,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         update t_trends
         <trim prefix="SET" suffixOverrides=",">
             <if test="tradeDate != null">trade_date = #{tradeDate},</if>
+            <if test="industryName != null and industryName != ''">industry_name = #{industryName},</if>
             <if test="eastmoneyIndustryCode != null and eastmoneyIndustryCode != ''">eastmoney_industry_code = #{eastmoneyIndustryCode},</if>
             <if test="eastmoneyIndustryName != null and eastmoneyIndustryName != ''">eastmoney_industry_name = #{eastmoneyIndustryName},</if>
             <if test="stocksCount != null">stocks_count = #{stocksCount},</if>
@@ -104,6 +109,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <insert id="batchUpsert" parameterType="java.util.List">
         INSERT INTO t_trends (
             trade_date,
+            industry_name,
             eastmoney_industry_code,
             eastmoney_industry_name,
             stocks_count,
@@ -118,6 +124,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <foreach collection="list" item="item" separator=",">
             (
                 #{item.tradeDate},
+                #{item.industryName},
                 #{item.eastmoneyIndustryCode},
                 #{item.eastmoneyIndustryName},
                 #{item.stocksCount},
@@ -136,6 +143,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             trend_value_change = VALUES(trend_value_change),
             rank = VALUES(rank),
             rank_change = VALUES(rank_change),
+            eastmoney_industry_name = VALUES(eastmoney_industry_name),
             update_time = VALUES(update_time)
     </insert>
 </mapper>
\ No newline at end of file
diff --git a/sql_refacor0120/t_stock_financial.sql b/sql_refacor0120/t_stock_financial.sql
index fafea42..4416630 100644
--- a/sql_refacor0120/t_stock_financial.sql
+++ b/sql_refacor0120/t_stock_financial.sql
@@ -33,8 +33,7 @@ CREATE TABLE `t_stock_financial` (
   `bps` decimal(50, 4) NULL DEFAULT NULL COMMENT '每股净资产BPS',
   `create_time` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
   `update_time` datetime NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
-  UNIQUE KEY `uk_stock_period` (`stock_code`, `report_period`),
-  PRIMARY KEY (`id`, `report_period`),
+  PRIMARY KEY (`id`, `stock_code`, `report_period`),
   INDEX `idx_stock_code` (`stock_code`),
   INDEX `idx_report_period` (`report_period`),
   INDEX `idx_create_time` (`create_time`)
diff --git a/sql_refacor0120/t_stocks_in_trend.sql b/sql_refacor0120/t_stocks_in_trend.sql
index 4c6c4cc..b04da1f 100644
--- a/sql_refacor0120/t_stocks_in_trend.sql
+++ b/sql_refacor0120/t_stocks_in_trend.sql
@@ -28,8 +28,8 @@ CREATE TABLE `t_stocks_in_trend` (
   `momentum_type` varchar(45) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '动量数据类型（10日、20日）',
   `create_time` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
   `update_time` datetime NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
-  UNIQUE KEY `uk_stock_date_type` (`stock_code`, `trade_date`, `momentum_type`),
-  PRIMARY KEY (`id`, `trade_date`),
+  PRIMARY KEY (`id`, `stock_code`, `trade_date`, `momentum_type`),
+  INDEX `idx_pk_id` (`id`),
   INDEX `idx_stock_code` (`stock_code`),
   INDEX `idx_trade_date` (`trade_date`),
   INDEX `idx_momentum_type` (`momentum_type`),
diff --git a/sql_refacor0120/t_trends.sql b/sql_refacor0120/t_trends.sql
index 3d36678..a6321d9 100644
--- a/sql_refacor0120/t_trends.sql
+++ b/sql_refacor0120/t_trends.sql
@@ -23,8 +23,7 @@ DROP TABLE IF EXISTS `t_trends`;
 CREATE TABLE `t_trends` (
   `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键ID',
   `trade_date` date NOT NULL COMMENT '交易日期',
-  `eastmoney_industry_code` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '所属东财行业代码',
-  `eastmoney_industry_name` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '所属东财行业名称',
+  `industry_name` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '行业名称（关联t_industry_basic表）',
   `stocks_count` decimal(50, 4) NULL DEFAULT -1.0000 COMMENT '动量个股数量',
   `trend_value` decimal(50, 4) NULL DEFAULT -1.0000 COMMENT '动量值',
   `trend_value_change` decimal(50, 4) NULL DEFAULT -1.0000 COMMENT '动量值变化',
@@ -33,10 +32,9 @@ CREATE TABLE `t_trends` (
   `momentum_type` varchar(45) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '动量数据类型（10日、20日）',
   `create_time` datetime NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
   `update_time` datetime NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
-  UNIQUE KEY `uk_date_industry_type` (`trade_date`, `eastmoney_industry_code`, `momentum_type`),
-  PRIMARY KEY (`id`, `trade_date`),
+  PRIMARY KEY (`id`, `trade_date`, `industry_name`, `momentum_type`),
   INDEX `idx_trade_date` (`trade_date`),
-  INDEX `idx_eastmoney_industry_code` (`eastmoney_industry_code`),
+  INDEX `idx_industry_name` (`industry_name`),
   INDEX `idx_momentum_type` (`momentum_type`),
   INDEX `idx_rank` (`rank`),
   INDEX `idx_create_time` (`create_time`)