检测/修复数据服务

Administrator

2024-07-12 dd4636adb21cba5eec0b217b14b1d2bd09d0a09c

 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"]