重要修订！！

positions_list 修订2

QMT/download_data.py

@@ -61,12 +61,12 @@ if __name__ == '__main__':
     eng_b = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qmt_stocks?charset=utf8')
     eng_f = create_engine('mysql+pymysql://root:r6kEwqWU9!v3@localhost:3307/qmt_stocks_front?charset=utf8')
 
-    # download_data(stocks, eng_b, eng_f)
+    download_data(stocks, eng_b, eng_f)
 
-    scheduler = BlockingScheduler()
-    scheduler.add_job(func=download_data, trigger='cron', hour='15', minute='45', args=[stocks, eng_b, eng_f],
-                      timezone="Asia/Shanghai")
-    try:
-        scheduler.start()
-    except (KeyboardInterrupt, SystemExit):
-        pass
+    # scheduler = BlockingScheduler()
+    # scheduler.add_job(func=download_data, trigger='cron', hour='15', minute='45', args=[stocks, eng_b, eng_f],
+    #                   timezone="Asia/Shanghai")
+    # try:
+    #     scheduler.start()
+    # except (KeyboardInterrupt, SystemExit):
+    #     pass

QMT/real_time.py

@@ -34,7 +34,7 @@ def real_price(datas):
 def ma(stock, num, data):
     global engine_stock
     try:
-        i = (num- 1) * -1
+        i = (num - 1) * -1
         df = pd.read_sql_query(
             'select close from `%s_1d`' % stock, engine_stock)
     except:
@@ -95,9 +95,9 @@ def sell_trader(data, positions_list):
             print('持仓', stock, data[stock])
             current_price = data[stock]['lastPrice']
             open_price = data[stock]['open']
-            print('价格：', current_price, open_price)
             MA5 = ma(stock, 5, data)
             MA5_1 = ma_1(stock, 5)
+            print('价格：', current_price, open_price, MA5, MA5_1)
             if current_price < MA5 or MA5 < MA5_1 or current_price > MA5 * 1.07:
                 print('卖出信号！！！！！！', stock, current_price)