第一个Alpha版本

core/qmt.py

@@ -23,7 +23,7 @@ class QmtV(XtQuantTraderCallback):
         self.xttrader = XtQuantTrader(config.miniQMTPath, sessionId)
         xtdata.enable_hello = False
     
-    def connect(self):
+    def connect(self) -> bool:
         self.xttrader.register_callback(self)
         self.xttrader.start()
         self.xttrader.connect()
@@ -31,7 +31,7 @@ class QmtV(XtQuantTraderCallback):
         PrintLog(LogLevel.INFO, f'- [{'成功' if self.xttrader.connected else '失败'}]市场交易连接: {config.miniQMTPath}')
         if self.xttrader.connected == False:
             self.inited = False
-            return
+            return self.inited
         else:
             self.inited = True
         
@@ -41,8 +41,9 @@ class QmtV(XtQuantTraderCallback):
         PrintLog(LogLevel.INFO, f'- [{'成功' if subscribe_result == 0 else '失败'}:{subscribe_result}]交易状态订阅')
         if subscribe_result != 0:
             self.inited = False
-            return
+            return self.inited
         self.startMarketDataSubscription()
+        return self.inited
     
     
     def getStockPosition(self, stock_code: str):
@@ -129,9 +130,12 @@ class QmtV(XtQuantTraderCallback):
     
     # ========================================#
     def startMarketDataSubscription(self):
-        self.subscriptionId = xtdata.subscribe_whole_quote(['SH', 'SZ'], self.onDataUpdate)
-        
-        PrintLog(LogLevel.INFO, f'- [市场数据订阅成功-{self.subscriptionId}]')
+        try:
+            self.subscriptionId = xtdata.subscribe_whole_quote(['SH', 'SZ'], self.onDataUpdate)
+            
+            PrintLog(LogLevel.INFO, f'- [市场数据订阅成功-{self.subscriptionId}]')
+        except Exception as e:
+            PrintLog(LogLevel.ERROR, f'- [市场数据订阅失败-{e}]')
     
     def stopMarketDataSubscription(self):
         PrintLog(LogLevel.INFO, '- 停止市场数据订阅')