chore: import upstream snapshot with attribution

2026-07-13 12:07:23 +08:00
commit 9c7a92f663
190 changed files with 88544 additions and 0 deletions
@@ -0,0 +1,73 @@
+from time import sleep
+
+from vnpy.event import EventEngine, Event
+from vnpy.trader.engine import MainEngine
+from vnpy.trader.ui import MainWindow, create_qapp
+from vnpy.trader.event import EVENT_LOG
+from vnpy.trader.object import LogData
+from vnpy_ctp import CtpGateway
+from vnpy_rpcservice import RpcServiceApp
+from vnpy_rpcservice.rpc_service.engine import RpcEngine, EVENT_RPC_LOG
+
+
+def main_ui() -> None:
+    """"""
+    qapp = create_qapp()
+
+    event_engine = EventEngine()
+
+    main_engine = MainEngine(event_engine)
+
+    main_engine.add_gateway(CtpGateway)
+    main_engine.add_app(RpcServiceApp)
+
+    main_window = MainWindow(main_engine, event_engine)
+    main_window.showMaximized()
+
+    qapp.exec()
+
+
+def process_log_event(event: Event) -> None:
+    """"""
+    log: LogData = event.data
+    msg: str = f"{log.time}\t{log.msg}"
+    print(msg)
+
+
+def main_terminal() -> None:
+    """"""
+    event_engine: EventEngine = EventEngine()
+    event_engine.register(EVENT_LOG, process_log_event)
+    event_engine.register(EVENT_RPC_LOG, process_log_event)
+
+    main_engine: MainEngine = MainEngine(event_engine)
+    main_engine.add_gateway(CtpGateway)
+    rpc_engine: RpcEngine = main_engine.add_app(RpcServiceApp)
+
+    setting: dict[str, str] = {
+        "用户名": "",
+        "密码": "",
+        "经纪商代码": "9999",
+        "交易服务器": "180.168.146.187:10101",
+        "行情服务器": "180.168.146.187:10111",
+        "产品名称": "simnow_client_test",
+        "授权编码": "0000000000000000",
+        "产品信息": ""
+    }
+    main_engine.connect(setting, "CTP")
+    sleep(10)
+
+    rep_address: str = "tcp://127.0.0.1:2014"
+    pub_address: str = "tcp://127.0.0.1:4102"
+    rpc_engine.start(rep_address, pub_address)
+
+    while True:
+        sleep(1)
+
+
+if __name__ == "__main__":
+    # Run in GUI mode
+    # main_ui()
+
+    # Run in CLI mode
+    main_terminal()