From d1bf04791ad095b17660a1f383b7a12f0a59b1d1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 26 四月 2023 19:15:06 +0800
Subject: [PATCH] 优化H撤/融入网页看盘页面/开盘啦数据应用
---
gui.py | 14 ++++++++++++++
1 files changed, 14 insertions(+), 0 deletions(-)
diff --git a/gui.py b/gui.py
index a926581..6282b5e 100644
--- a/gui.py
+++ b/gui.py
@@ -22,6 +22,7 @@
from trade import l2_trade_util
from trade.l2_trade_factor import L2TradeFactorUtil
from ocr import ocr_server
+from third_data import data_server
from server import *
import l2.l2_data_util
@@ -60,6 +61,13 @@
t1.setDaemon(True)
t1.start()
+ t1 = threading.Thread(target=createDataServer)
+ # 鍚庡彴杩愯
+ t1.setDaemon(True)
+ t1.start()
+
+
+
laddr = "", 9001
tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_juejin=pipe_juejin) # 娉ㄦ剰锛氬弬鏁版槸MyBaseRequestHandle
# tcpserver.handle_request() # 鍙帴鍙椾竴涓鎴风杩炴帴
@@ -71,6 +79,10 @@
tcpserver = ocr_server.run("", 9002)
tcpserver.serve_forever()
+def createDataServer():
+ print("create OCRServer")
+ tcpserver = data_server.run("", 9004)
+ tcpserver.serve_forever()
def startJueJin(pipe):
juejin.JueJinManager(pipe).start()
@@ -85,6 +97,7 @@
self.serverProcess = multiprocessing.Process(target=createServer, args=(p1, gs_server_pipe,))
self.jueJinProcess = multiprocessing.Process(target=startJueJin, args=(p2,))
self.ocrServerProcess = multiprocessing.Process(target=createOCRServer)
+
self.p1 = p1
self.p2 = p2
@@ -120,6 +133,7 @@
self.jueJinProcess.start()
self.serverProcess.start()
self.ocrServerProcess.start()
+
L2CodeOperate.get_instance()
# 瀹㈡埛绔槦鍒楁搷浣�
process = multiprocessing.Process(target=L2CodeOperate.run())
--
Gitblit v1.8.0