[Add]增加算法交易RPC服务的数据推送功能

examples/CryptoTrader/BITMEX_connect.json

@@ -1,6 +1,6 @@
 {
-	"apiKey": "dVOUiqMzayJSW8gCGax_zWpy",
+	"apiKey": "",
-	"apiSecret": "dTh0NWAvGA3h9YczL90R1MGxGc_BZtG05EJ3MoiMYRvtS5mL",
+	"apiSecret": "",
 	"sessionCount": 3,
 	"symbols": ["XBTUSD", "EOSM18", "XRPM18"]
 }

vnpy/trader/app/algoTrading/algoEngine.py

@@ -228,6 +228,10 @@ class AlgoEngine(object):
         event.dict_['data'] = d
         self.eventEngine.put(event)
         
+        # RPC推送
+        if self.rpcServer:
+            self.rpcServer.publish('AlgoTrading', event)
+        
         # 保存数据到数据库
         history = self.historyDict.setdefault(algoName, {})
         history['algoName'] = algoName
@@ -238,7 +242,8 @@ class AlgoEngine(object):
                                  history,
                                  {'algoName': algoName},
                                  True)
-    
+        
+        
     #----------------------------------------------------------------------
     def putParamEvent(self, algo, d):
         """更新参数"""
@@ -249,6 +254,10 @@ class AlgoEngine(object):
         event.dict_['data'] = d
         self.eventEngine.put(event)    
         
+        # RPC推送
+        if self.rpcServer:
+            self.rpcServer.publish('AlgoTrading', event)        
+        
         # 保存数据到数据库
         history = self.historyDict.setdefault(algoName, {})
         history['algoName'] = algoName