##update

QACTPBeeBroker/__init__.py

@@ -7,7 +7,7 @@
 from QACTPBeeBroker.setting import eventmq_ip, ip
 from QAPUBSUB.producer import publisher_routing
 
-__version__ = '1.2'
+__version__ = '1.3'
 __author__ = 'yutiansut'
 
 
@@ -37,6 +37,7 @@ def on_tick(self, tick):
             return
         try:
             x = dumps(tick)  #
+            print(tick.symbol)
             self.pub.pub(x, routing_key=tick.symbol)
         except Exception as e:
             print(e)
@@ -99,8 +100,12 @@ def go(userid, password, brokerid, mdaddr, tdaddr, appid, authcode):
         cont['product'] = cont['product'].value
         cont['date'] = cur_date
         print(cont)
-        contractdb.update_one({'gateway_name': 'ctp', 'symbol': cont['symbol']}, {
-            '$set': cont}, upsert=True)
+        try:
+            contractdb.update_one({'gateway_name': 'ctp', 'symbol': cont['symbol']}, {
+                '$set': cont}, upsert=True)
+        except Exception as e:
+            print(e)
+
 
 
 if __name__ == '__main__':

beebroker.py

@@ -0,0 +1,39 @@
+from time import sleep
+
+from ctpbee.interface.ctp.td_api import BeeTdApi
+
+
+class TdApi(BeeTdApi):
+
+    def __init__(self):
+        super().__init__(event_engine=None)
+
+    def on_event(self, type, data):
+        print(type, data)
+
+
+if __name__ == '__main__':
+    api = TdApi()
+    login_info = {
+                     "userid": "089131",
+                     "password": "350888",
+                     "brokerid": "9999",
+                     # 24小时
+                     "md_address": "tcp://180.168.146.187:10131",
+                     "td_address": "tcp://180.168.146.187:10130",
+                     # # 移动
+                     # "md_address": "tcp://218.202.237.33:10112",
+                     # "td_address": "tcp://218.202.237.33:10102",
+                     "product_info": "",
+                     "appid": "simnow_client_test",
+                     "auth_code": "0000000000000000",
+                 }
+    api.connect(login_info)
+
+    # api.send_order()
+    # api.cancel_order()
+    while True:
+        api.query_account()
+        sleep(2)
+        api.query_position()
+        sleep(2)

setup.py

@@ -62,7 +62,7 @@ def read(fname):
         'Intended Audience :: Developers',
         'Operating System :: OS Independent',
     ],
-    install_requires=['quantaxis', 'quantaxis_pubsub==1.6.2'],
+    install_requires=['quantaxis', 'quantaxis_pubsub>=1.6.3', 'ctpbee<=0.31.2'],
     entry_points={
         'console_scripts': [
             'QACTPBEE = QACTPBeeBroker.__init__:go'