blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2024-03-22 b874fdb322d0740838f73e5ed260f800bf43ad1a 
 utils/hosting_api_util.py


@@ -16,17 +16,19 @@


OPERRATE_SET = 1  # 设置


OPERRATE_DELETE = 2  # 删除


OPERRATE_GET = 3  # 获取


OPERRATE_ADD = 4  # 添加




# 代码名单类型


CODE_LIST_WHITE = "white"


CODE_LIST_BLACK = "black"


CODE_LIST_WANT = "want"


CODE_LIST_PAUSE_BUY = "pause_buy"




CODE_LIST_MUST_BUY = "must_buy"


# 类型


API_TYPE_TRADE = "trade"  # 交易


API_TYPE_TRADE_STATE = "trade_state"  # 交易状态


API_TYPE_TRADE_MODE = "trade_mode"  # 交易模式


API_TYPE_SELL_RULE = "sell_rule"  # 卖出规则


API_TYPE_CODE_LIST = "code_list"  # 代码名单


API_TYPE_EXPORT_L2 = "export_l2"  # 导出L2数据


API_TYPE_INIT = "init"  # 初始化


@@ -36,7 +38,12 @@


API_TYPE_GET_ENV = "get_env"  # 获取环境信息


API_TYPE_SYNC_L1_TARGET_CODES = "sync_l1_subscript_codes"  # 同步L1需要订阅的代码


API_TYPE_SYSTEM_LOG = "system_log"  # 系统日志




API_TYPE_GET_FROM_DATA_SERVER = "get_from_data_server"  # 从数据服务器拉取数据


API_TYPE_CODE_TRADE_INFO = "code_trade_info"  # 代码交易信息


API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT = "l2_listen_active_count"  # L2有效监听数量


API_TYPE_SAVE_RUNNING_DATA = "save_running_data"  # 保存运行时数据


API_TYPE_GET_CODE_POSITION_INFO = "get_code_position_info"  # 获取代码持仓信息


API_TYPE_COMMON_REQUEST = "common_request"  # 通用请求


# 超时时间2s


TIMEOUT = 5.0




@@ -124,13 +131,14 @@


# blocking是否阻塞进程


def trade_order(direction, code, volume, price, price_type=2, blocking=True):


    print("客户端", ClientSocketManager.socket_client_dict)


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


                                   {"type": API_TYPE_TRADE, "trade_type": 1,


                                    "direction": direction,


                                    "code": code,


                                    "volume": volume,


                                    "price_type": price_type,


                                    "price": price, "sinfo": f"order_{code}_{round(time.time() * 1000)}"})


    request_id, client = __request(


        ClientSocketManager.CLIENT_TYPE_TRADE if direction == 1 else ClientSocketManager.CLIENT_TYPE_TRADE_SELL,


        {"type": API_TYPE_TRADE, "trade_type": 1,


         "direction": direction,


         "code": code,


         "volume": volume,


         "price_type": price_type,


         "price": price, "sinfo": f"order_{code}_{round(time.time() * 1000)}"})




    return __read_response(client, request_id, blocking)




@@ -143,13 +151,13 @@


                                    "code": code,


                                    "accountID": accountID,


                                    "orderSysID": orderSysID,


                                    "sinfo": f"cancel_order_{code}_{round(time.time() * 1000)}"})


                                    "sinfo": f"cb_{code}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)






# 设置交易状态


def set_trade_state(state, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_TRADE_STATE, "operate": OPERRATE_SET,


                                    "state": state,


                                    "sinfo": f"cb_{API_TYPE_TRADE_STATE}_{round(time.time() * 1000)}"})


@@ -158,7 +166,7 @@




# 获取交易状态


def get_trade_state(blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_TRADE_STATE, "operate": OPERRATE_GET,


                                    "sinfo": f"cb_{API_TYPE_TRADE_STATE}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -166,7 +174,7 @@




# 设置交易模式


def set_trade_mode(mode, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_TRADE_MODE, "operate": OPERRATE_SET, "mode": mode,


                                    "sinfo": f"cb_{API_TYPE_TRADE_MODE}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -174,7 +182,7 @@




# 获取交易模式


def get_trade_mode(blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_TRADE_MODE, "operate": OPERRATE_GET,


                                    "sinfo": f"cb_{API_TYPE_TRADE_MODE}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -182,7 +190,7 @@




# -----代码名单操作----


def add_code_list(code, code_list_type, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_CODE_LIST, "code_list_type": code_list_type, "code": code,


                                    "operate": OPERRATE_SET,


                                    "sinfo": f"cb_{API_TYPE_CODE_LIST}_{round(time.time() * 1000)}"})


@@ -190,7 +198,7 @@






def remove_code_list(code, code_list_type, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_CODE_LIST, "code_list_type": code_list_type, "code": code,


                                    "operate": OPERRATE_DELETE,


                                    "sinfo": f"cb_{API_TYPE_CODE_LIST}_{round(time.time() * 1000)}"})


@@ -198,7 +206,7 @@






def get_code_list(code_list_type, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_CODE_LIST, "code_list_type": code_list_type,


                                    "operate": OPERRATE_GET,


                                    "sinfo": f"cb_{API_TYPE_CODE_LIST}_{round(time.time() * 1000)}"})


@@ -207,7 +215,7 @@




# -----导出L2数据----


def export_l2_data(code, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_EXPORT_L2, "code": code,


                                    "sinfo": f"cb_{API_TYPE_EXPORT_L2}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -215,7 +223,7 @@




# -----每日初始化----


def everyday_init(blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_INIT,


                                    "sinfo": f"cb_{API_TYPE_INIT}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -223,7 +231,7 @@




#  刷新交易数据


def refresh_trade_data(type, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"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)


@@ -231,7 +239,7 @@




#  获取代码属性


def get_code_attribute(code, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_CODE_ATRRIBUTE, "code": code,


                                    "sinfo": f"cb_{API_TYPE_CODE_ATRRIBUTE}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -239,7 +247,7 @@




#  获取代码交易状态


def get_code_trade_state(code, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_CODE_TRADE_STATE, "code": code,


                                    "sinfo": f"{API_TYPE_CODE_TRADE_STATE}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -247,7 +255,7 @@




# 获取环境信息


def get_env_info(blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_GET_ENV,


                                    "sinfo": f"cb_{API_TYPE_GET_ENV}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -255,7 +263,7 @@




# 获取环境信息


def sync_l1_subscript_codes(blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_SYNC_L1_TARGET_CODES,


                                    "sinfo": f"cb_{API_TYPE_SYNC_L1_TARGET_CODES}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)


@@ -263,12 +271,70 @@




# 获取系统日志


def get_system_logs(start_index, count, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE,


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_SYSTEM_LOG, "start_index": start_index, "count": count,


                                    "sinfo": f"cb_{API_TYPE_SYSTEM_LOG}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)






# 拉取data_server的内容


def get_from_data_server(path, params, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_GET_FROM_DATA_SERVER, "path": path, "params": params,


                                    "sinfo": f"cb_{API_TYPE_GET_FROM_DATA_SERVER}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking, timeout=30)






# 获取代码的交易信息


def get_code_trade_info(code, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_CODE_TRADE_INFO, "code": code,


                                    "sinfo": f"cb_{API_TYPE_CODE_TRADE_INFO}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking, timeout=30)






# L2有效监听数量


def get_l2_listen_active_count(blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT,


                                    "sinfo": f"cb_{API_TYPE_CODE_L2_LISTEN_ACTIVE_COUNT}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking, timeout=30)






# 保存正在运行的数据


def save_running_data(blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_COMMON,


                                   {"type": API_TYPE_SAVE_RUNNING_DATA,


                                    "sinfo": f"cb_{API_TYPE_SAVE_RUNNING_DATA}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking, timeout=30)






# 保存正在运行的数据


def sell_rule(operate, data={}, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE_SELL,


                                   {"type": API_TYPE_SELL_RULE, "operate": operate, "data": data,


                                    "sinfo": f"cb_{API_TYPE_SELL_RULE}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking, timeout=10)






# 获取代码持仓信息


def get_code_position_info(code, blocking=True):


    request_id, client = __request(ClientSocketManager.CLIENT_TYPE_TRADE_SELL,


                                   {"type": API_TYPE_GET_CODE_POSITION_INFO, "code": code,


                                    "sinfo": f"cb_{API_TYPE_GET_CODE_POSITION_INFO}_{round(time.time() * 1000)}"})


    return __read_response(client, request_id, blocking)






def common_request(params={}, blocking=True):


    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_COMMON, data)


    return __read_response(client, request_id, blocking, timeout=10)






if __name__ == "__main__":


    d = {"id": "123123"}


    print(d.pop("id"))