华鑫适配

Administrator

2023-07-13 a8e30cdd7e3b8c7cd93ac52c9441d1598c71c5dc

华鑫适配

 l2/huaxin/huaxin_target_codes_manager.py

@@ -4,6 +4,7 @@
import json

from db import redis_manager
from utils import tool

redisManager = redis_manager.RedisManager(0)

@@ -13,6 +14,8 @@


__L2_CODE_KEY = "huaxin_l2_code_list"

__SUBSCRIPT_KEY = "huaxin_subscript_codes"


def clear():
@@ -28,3 +31,16 @@
    if val:
        return json.loads(val)
    return val


# 设置订阅代码
def save_subscript_codes(codes):
    __get_redis().setex(__SUBSCRIPT_KEY, tool.get_expire(), json.dumps(codes))


# 获取订阅的代码
def get_subscript_codes():
    val = __get_redis().get(__SUBSCRIPT_KEY)
    if not val:
        return []
    return json.loads(val)

 trade/huaxin/trade_api_server.py

@@ -9,6 +9,7 @@
import time

import constant
from code_attribute import gpcode_manager
from l2 import l2_data_manager_new
from l2.huaxin import huaxin_target_codes_manager
from log_module.log import hx_logger_l2_upload, hx_logger_contact_debug, hx_logger_trade_callback, \
@@ -251,6 +252,16 @@
                            trade_data_request_queue.put_nowait({"type": "position_list"})
                        return_str = json.dumps(
                            {"code": 0, "data": {}, "msg": ""})
                    elif type_ == "get_huaxin_subscript_codes":
                        # 获取华鑫订阅的代码
                        codes = huaxin_target_codes_manager.get_subscript_codes()
                        fresults = []
                        if codes:
                            for code in codes:
                                code_name = gpcode_manager.get_code_name(code)
                                fresults.append((code, code_name))
                        return_str = json.dumps(
                            {"code": 0, "data": {"count": len(fresults), "list": fresults}, "msg": ""})
                    # 查询委托列表
                    elif type_ == 'test':
                        # 卖出

 trade/huaxin/trade_server.py

@@ -10,6 +10,7 @@
from code_attribute import gpcode_manager
from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, l2_data_manager
from l2.cancel_buy_strategy import HourCancelBigNumComputer, LCancelBigNumComputer
from l2.huaxin import huaxin_target_codes_manager
from log_module.log import hx_logger_l2_upload, hx_logger_contact_debug, hx_logger_trade_callback, \
    hx_logger_l2_orderdetail, hx_logger_l2_transaction, hx_logger_l2_market_data, logger_l2_trade_buy_queue
from trade import deal_big_money_manager
@@ -209,6 +210,11 @@
                                                                        sell_1_price, sell_1_volume // 100)
                        hx_logger_l2_market_data.info(f"{code}#{data}")
                        sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))
                    elif data_json["type"] == "l2_subscript_codes":
                        data = data_json["data"]
                        datas = data["data"]
                        # 订阅的代码
                        huaxin_target_codes_manager.save_subscript_codes(datas)
                else:
                    # 断开连接
                    break