diff --git a/EastMoneyPy/venv/main/eastmoney/dbConn.py b/EastMoneyPy/venv/main/eastmoney/dbConn.py
index 39a4c4c..93e7ed8 100644
--- a/EastMoneyPy/venv/main/eastmoney/dbConn.py
+++ b/EastMoneyPy/venv/main/eastmoney/dbConn.py
@@ -415,7 +415,7 @@
     # 获取yanzheng1涨幅靠前的code
     def calcYanZheng1Code(self):
         cursor = self.db.cursor()
-        sql = "SELECT t3.CODE FROM (SELECT t.CODE,sum(t.earn) AS e,t.price FROM t_yanzheng2 t WHERE t.`code` IN (SELECT t2.CODE FROM t_yanzheng2 t2 GROUP BY t2.`code`) GROUP BY t.CODE) AS t3 WHERE t3.e> 0 AND t3.e/t3.price> 0.5;"
+        sql = "SELECT t3.CODE FROM (SELECT t.CODE,sum(t.earn) AS e,t.price FROM t_yanzheng1 t WHERE t.`code` IN (SELECT t2.CODE FROM t_yanzheng1 t2 GROUP BY t2.`code`) GROUP BY t.CODE) AS t3 WHERE t3.e> 0 AND t3.e/t3.price> 0.5;"
         try:
             cursor.execute(sql)
             return cursor.fetchall()
@@ -435,6 +435,12 @@
         cursor.execute(sql)
         self.db.commit()
 
+    def saveYanZheng1History(self, data):
+        cursor = self.db.cursor()
+        sql = "INSERT INTO t_yanzheng1_history (code, name, shijian, zhangfu, level_zhuli_per) VALUES ('%s', '%s','%s','%s','%s');" % \
+              (data[0], data[1], data[2], data[3], data[4])
+        cursor.execute(sql)
+        self.db.commit()
 
 
     def getYanZheng1Code(self):