新增掘金检测接口

Administrator

2023-07-18 3cc54d41c3f33e2d3557fd34eed163f3af48c19e

新增掘金检测接口

 trade/huaxin/huaxin_trade_api.py

@@ -24,6 +24,16 @@
    active_client_dict = {}

    @classmethod
    def list_client(cls, _type):
        if _type == cls.CLIENT_TYPE_TRADE:
            if _type in cls.socket_client_dict:
                return cls.socket_client_dict.get(_type)
        else:
            if _type in cls.socket_client_dict:
                return [cls.socket_client_dict.get(_type)]
        return []

    @classmethod
    def add_client(cls, _type, rid, sk):
        if _type == cls.CLIENT_TYPE_TRADE:
            # 交易列表

 trade/huaxin/trade_api_server.py

@@ -15,7 +15,7 @@
from l2.huaxin import huaxin_target_codes_manager
from log_module.log import  hx_logger_trade_debug
from third_data import block_info
from third_data.history_k_data_util import HistoryKDatasUtils
from third_data.history_k_data_util import HistoryKDatasUtils, JueJinApi
from trade import trade_manager, trade_huaxin

from trade.huaxin import huaxin_trade_api as trade_api, huaxin_trade_api, huaxin_trade_record_manager
@@ -279,6 +279,28 @@
                        inited_data.everyday_init()
                        return_str = json.dumps(
                            {"code": 0, "data": {}, "msg": ""})
                    elif type_ == 'huaxin_channel_state':
                        # 华鑫通道状态
                        types = [huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_TRADE,
                                 huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_CMD_L2,
                                 huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_DEAL_LIST,
                                 huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_DELEGATE_LIST,
                                 huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_MONEY,
                                 huaxin_trade_api.ClientSocketManager.CLIENT_TYPE_POSITION_LIST]
                        fdata = {}
                        for t in types:
                            trade_list = huaxin_trade_api.ClientSocketManager.list_client(t)
                            fdata[t] = len(trade_list)
                    elif type_ == 'juejin_is_valid':
                        # 掘金是否可用
                        try:
                            date = JueJinApi.get_previous_trading_date(tool.get_now_date_str())
                            if date:
                                return_str = json.dumps(
                                    {"code": 0,  "msg": ""})
                        except Exception as e:
                            return_str = json.dumps(
                                {"code": 0, "msg": str(e)})
                    # 查询委托列表
                    elif type_ == 'test':
                        # 卖出