diff --git a/src/main/java/cn/stock/market/web/MessageRetifiveController.java b/src/main/java/cn/stock/market/web/MessageRetifiveController.java
index de074e5..845c0f9 100644
--- a/src/main/java/cn/stock/market/web/MessageRetifiveController.java
+++ b/src/main/java/cn/stock/market/web/MessageRetifiveController.java
@@ -3,17 +3,20 @@ package cn.stock.market.web;
 import cn.stock.market.domain.basic.entity.RetifiveStock;
 import cn.stock.market.domain.basic.service.RetifiveStockService;
 import cn.stock.market.dto.RetifiveStockInfo;
+import cn.stock.market.infrastructure.db.po.QRetifiveStockPO;
 import cn.stock.market.listener.AppClient;
 import cn.stock.market.listener.ConcurrentAppClient;
 import cn.stock.market.listener.StockInfoRefinitiv;
 import cn.stock.market.listener.SymbolRefinitiv;
 import cn.stock.market.utils.ServerResponse;
 import com.google.common.collect.Lists;
+import com.querydsl.core.types.Predicate;
 import com.thomsonreuters.ema.access.DataType;
 import com.thomsonreuters.ema.access.FieldEntry;
 import com.thomsonreuters.ema.access.FieldList;
 import com.thomsonreuters.ema.access.RefreshMsg;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.mongodb.core.MongoTemplate;
@@ -540,7 +543,10 @@ public class MessageRetifiveController {
 
         RetifiveStock retifiveStock = RetifiveStock.builder().stockType(stockType).saveTime(new Date()).isLock(0).isShow(0)
                 .stockCode(stockCode).symbol(name).stockName(stockName).build();
-        retifiveStockService.repository().save(retifiveStock);
+        List<RetifiveStock> all = retifiveStockService.repository().findAll(QRetifiveStockPO.retifiveStockPO.symbol.eq(name));
+        if(CollectionUtils.isEmpty(all)){
+            retifiveStockService.repository().save(retifiveStock);
+        }
     }