添加新版低吸中间服务器

admin

2025-06-04 287c506725b2d970f721f80169f83c2418cb0991

 utils/hosting_api_util.py

@@ -24,6 +24,7 @@
CODE_LIST_WANT = "want"
CODE_LIST_PAUSE_BUY = "pause_buy"
CODE_LIST_MUST_BUY = "must_buy"
CODE_LIST_GREEN = "green"
# 类型
API_TYPE_TRADE = "trade"  # 交易
API_TYPE_TRADE_STATE = "trade_state"  # 交易状态
@@ -378,6 +379,20 @@
    return __read_response(client, request_id, blocking)


def refresh_trade_data_for_cb(refresh_type, blocking=True):
    """
    刷新交易数据
    :param refresh_type:
    :param blocking:
    :return:
    """

    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE_CB,
                                   {"type": API_TYPE_REFRESH_TRADE_DATA, "ctype": refresh_type,
                                    "sinfo": f"cb_{API_TYPE_REFRESH_TRADE_DATA}_{round(time.time() * 1000)}"})
    return __read_response(client, request_id, blocking)


def get_account_money_for_cb(blocking=True):
    """
    获取账户资金情况
@@ -386,6 +401,19 @@
    :return:
    """
    return common_request_for_cb({"ctype": "get_account_money"}, blocking)


def refresh_trade_data_for_cb(type_, blocking=True):
    """
    刷新可转债交易数据
    :param code:
    :param blocking:
    :return:
    """
    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE_CB,
                                   {"type": API_TYPE_REFRESH_TRADE_DATA, "ctype": type_,
                                    "sinfo": f"cb_{API_TYPE_REFRESH_TRADE_DATA}_{round(time.time() * 1000)}"})
    return __read_response(client, request_id, blocking)


def common_request_for_cb(params, blocking=True):
@@ -404,5 +432,21 @@
    return __read_response(client, request_id, blocking, timeout=10)


def common_request_for_low_suction(params, blocking=True):
    """
    通用请求
    :param params:
    :param blocking:
    :return:
    """
    data = {"type": API_TYPE_COMMON_REQUEST,
            "sinfo": f"cb_{API_TYPE_COMMON_REQUEST}_{round(time.time() * 1000)}"}
    if params:
        for k in params:
            data[k] = params[k]
    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE_LOW_SUCTION, data)
    return __read_response(client, request_id, blocking, timeout=10)


if __name__ == "__main__":
    pass