diff --git a/src/zvt/recorders/em/news/em_stock_news_recorder.py b/src/zvt/recorders/em/news/em_stock_news_recorder.py
index 5202534129a750e23de56eb816219e146a7bc3fd..dc6b18400f96a88d49dbac74d394b98a2b3b24d1 100644
--- a/src/zvt/recorders/em/news/em_stock_news_recorder.py
+++ b/src/zvt/recorders/em/news/em_stock_news_recorder.py
@@ -6,7 +6,6 @@ from zvt.contract.recorder import FixedCycleDataRecorder
 from zvt.domain import Stock
 from zvt.domain.misc.stock_news import StockNews
 from zvt.recorders.em import em_api
-from zvt.utils import to_pd_timestamp, count_interval, now_pd_timestamp
 
 
 class EMStockNewsRecorder(FixedCycleDataRecorder):
@@ -19,13 +18,7 @@ class EMStockNewsRecorder(FixedCycleDataRecorder):
     provider = "em"
 
     def record(self, entity, start, end, size, timestamps):
-        if not start or (start <= to_pd_timestamp("2018-01-01")):
-            start = to_pd_timestamp("2018-01-01")
-        if count_interval(start, now_pd_timestamp()) <= 30:
-            ps = 30
-        else:
-            ps = 200
-        news = em_api.get_news(entity_id=entity.id, ps=ps, start_timestamp=start)
+        news = em_api.get_news(entity_id=entity.id)
         if news:
             df = pd.DataFrame.from_records(news)
             self.logger.info(df)
@@ -33,8 +26,7 @@ class EMStockNewsRecorder(FixedCycleDataRecorder):
 
 
 if __name__ == "__main__":
-    # Stock.record_data(provider="em")
-    r = EMStockNewsRecorder(entity_ids=["stock_sz_000005"])
+    r = EMStockNewsRecorder(entity_ids=["stock_sz_000003"])
     r.run()
 # the __all__ is generated
 __all__ = ["EMStockNewsRecorder"]