From dd4636adb21cba5eec0b217b14b1d2bd09d0a09c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 12 七月 2024 13:51:21 +0800
Subject: [PATCH] 检测/修复数据服务
---
trade/huaxin/outside_api_command_callback.py | 14 ++++++++++++--
1 files changed, 12 insertions(+), 2 deletions(-)
diff --git a/trade/huaxin/outside_api_command_callback.py b/trade/huaxin/outside_api_command_callback.py
index 13e4c72..c408c1b 100644
--- a/trade/huaxin/outside_api_command_callback.py
+++ b/trade/huaxin/outside_api_command_callback.py
@@ -49,7 +49,7 @@
from trade.sell.sell_rule_manager import TradeRuleManager, SellRule
from trade.trade_manager import TradeTargetCodeModeManager, AutoCancelSellModeManager
from settings.trade_setting import MarketSituationManager
-from utils import socket_util, data_export_util, tool, huaxin_util, output_util, global_util
+from utils import socket_util, data_export_util, tool, huaxin_util, output_util, global_util, server_util
class OutsideApiCommandCallback(outside_api_command_manager.ActionCallback):
@@ -509,6 +509,14 @@
except Exception as e:
logger_debug.exception(e)
fdata["today_history_k_bar_count"] = -1
+
+ # 鑾峰彇鏁版嵁鏈嶅姟鍣ㄦ槸鍚﹁仈閫�
+ try:
+ is_data_server_open = socket_util.is_port_bind(9004)
+ fdata["data_server_open"] = 1 if is_data_server_open else 0
+ except Exception as e:
+ logger_debug.exception(e)
+ fdata["data_server_open"] = -1
# 鑾峰彇浜ゆ槗閫氶亾
result = {"code": 0, "data": fdata, "msg": ""}
@@ -1133,8 +1141,10 @@
elif ctype == "get_per_code_buy_money":
self.send_response({"code": 0, "data": {"money": constant.BUY_MONEY_PER_CODE}}, client_id, request_id)
elif ctype == "repaire_task":
- # 淇浠诲姟
+ # 淇寮�鐩樺暒浠诲姟
kpl_data_manager.PullTask.repaire_pull_task()
+ # 淇鏁版嵁鏈嶅姟
+ server_util.repaire_data_server()
self.send_response({"code": 0, "data": {}}, client_id, request_id)
elif ctype == "get_trade_queue":
code = data["code"]
--
Gitblit v1.8.0