diff --git a/examples/JaqsService/run.py b/examples/JaqsService/run.py index caedbcbe..cf954f24 100644 --- a/examples/JaqsService/run.py +++ b/examples/JaqsService/run.py @@ -5,13 +5,11 @@ import sys reload(sys) sys.setdefaultencoding('utf8') -# 判断操作系统 -import platform -system = platform.system() +from time import sleep # vn.trader模块 from vnpy.event import EventEngine -from vnpy.trader.vtEngine import MainEngine +from vnpy.trader.vtEngine import MainEngine, LogEngine from vnpy.trader.uiQt import createQApp from vnpy.trader.uiMainWindow import MainWindow @@ -20,31 +18,35 @@ from vnpy.trader.gateway import ctpGateway # 加载上层应用 from vnpy.trader.app import jaqsService +from vnpy.trader.app.jaqsService.jsEngine import EVENT_JS_LOG #---------------------------------------------------------------------- def main(): """主程序入口""" - # 创建Qt应用对象 - qApp = createQApp() + le = LogEngine() + le.setLogLevel(le.LEVEL_INFO) + le.addConsoleHandler() + le.addFileHandler() + + le.info(u'启动JAQS服务进程') - # 创建事件引擎 ee = EventEngine() + le.info(u'事件引擎创建成功') - # 创建主引擎 me = MainEngine(ee) - - # 添加交易接口 me.addGateway(ctpGateway) - - # 添加上层应用 me.addApp(jaqsService) + le.info(u'主引擎创建成功') - # 创建主窗口 - mw = MainWindow(me, ee) - mw.showMaximized() + ee.register(EVENT_LOG, le.processLogEvent) + ee.register(EVENT_JS_LOG, le.processLogEvent) + le.info(u'注册日志事件监听') - # 在主线程中启动Qt事件循环 - sys.exit(qApp.exec_()) + me.connect('CTP') + le.info(u'连接CTP接口') + + while True: + sleep(1) if __name__ == '__main__': diff --git a/examples/JaqsService/runUI.py b/examples/JaqsService/runUI.py new file mode 100644 index 00000000..caedbcbe --- /dev/null +++ b/examples/JaqsService/runUI.py @@ -0,0 +1,51 @@ +# encoding: UTF-8 + +# 重载sys模块,设置默认字符串编码方式为utf8 +import sys +reload(sys) +sys.setdefaultencoding('utf8') + +# 判断操作系统 +import platform +system = platform.system() + +# vn.trader模块 +from vnpy.event import EventEngine +from vnpy.trader.vtEngine import MainEngine +from vnpy.trader.uiQt import createQApp +from vnpy.trader.uiMainWindow import MainWindow + +# 加载底层接口 +from vnpy.trader.gateway import ctpGateway + +# 加载上层应用 +from vnpy.trader.app import jaqsService + +#---------------------------------------------------------------------- +def main(): + """主程序入口""" + # 创建Qt应用对象 + qApp = createQApp() + + # 创建事件引擎 + ee = EventEngine() + + # 创建主引擎 + me = MainEngine(ee) + + # 添加交易接口 + me.addGateway(ctpGateway) + + # 添加上层应用 + me.addApp(jaqsService) + + # 创建主窗口 + mw = MainWindow(me, ee) + mw.showMaximized() + + # 在主线程中启动Qt事件循环 + sys.exit(qApp.exec_()) + + +if __name__ == '__main__': + main()