import xtconstant

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, engine],
-    #                   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, engine],
+                      timezone="Asia/Shanghai")
+    try:
+        scheduler.start()
+    except (KeyboardInterrupt, SystemExit):
+        pass

QMT/real_time.py

@@ -4,7 +4,7 @@ import os
 import pandas as pd
 from xtquant.xttrader import XtQuantTrader, XtQuantTraderCallback
 from xtquant.xttype import StockAccount
-from xtquant import xtdata
+from xtquant import xtdata, xtconstant
 import time
 from sqlalchemy import create_engine
 from jqdatasdk import *
@@ -190,8 +190,8 @@ def buy_trader(data):
                     volume = int((cash / 2 / current_price) // 100 * 100)
                     print('volume：', volume)
                     print('买入信号！！！！！！', stock, volume, current_price)
-                    # order_id = xt_trader.order_stock(acc, stock, xtconstant.STOCK_BUY, volume, xtconstant.LATEST_PRICE, current_price, 'strategy1', 'order_test')
-                    # print(order_id)
+                    order_id = xt_trader.order_stock(acc, stock, xtconstant.STOCK_BUY, volume, xtconstant.LATEST_PRICE, current_price, 'strategy1', 'order_test')
+                    print(order_id)
     print('一轮结束了，现在时间是：', dt.now())