From 0e68e24f54db11d340785b17570fff2bc5fc7ac6 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 24 七月 2023 13:05:16 +0800
Subject: [PATCH] bug修复
---
l2/l2_data_manager.py | 20 +++++++++-----------
1 files changed, 9 insertions(+), 11 deletions(-)
diff --git a/l2/l2_data_manager.py b/l2/l2_data_manager.py
index a127107..b99c0fa 100644
--- a/l2/l2_data_manager.py
+++ b/l2/l2_data_manager.py
@@ -3,10 +3,9 @@
"""
import json
-
-import redis_manager
-import tool
-from log import logger_l2_trade_buy
+from db import redis_manager
+from utils import tool
+from log_module.log import logger_l2_trade_buy
_redisManager = redis_manager.RedisManager(1)
@@ -49,9 +48,9 @@
_key = "buy_compute_index_info-{}".format(code)
_data_json = redis.get(_key)
if _data_json is None:
- return None, None, None, 0, 0, []
+ return None, None, None, 0, 0, [],0
_data = json.loads(_data_json)
- return _data[0], _data[1], _data[2], _data[3], _data[4], _data[5]
+ return _data[0], _data[1], _data[2], _data[3], _data[4], _data[5], _data[6]
# 璁剧疆涔板叆鐐圭殑鍊�
# buy_single_index 涔板叆淇″彿浣�
@@ -59,18 +58,17 @@
# compute_index 璁＄畻浣嶇疆
# nums 绱绾拱棰�
@staticmethod
- def set_buy_compute_start_data(code, buy_single_index, buy_exec_index, compute_index, nums, count, max_num_sets):
+ def set_buy_compute_start_data(code, buy_single_index, buy_exec_index, compute_index, nums, count, max_num_sets, volume_rate):
redis = TradePointManager.__get_redis()
expire = tool.get_expire()
_key = "buy_compute_index_info-{}".format(code)
if buy_single_index is not None:
redis.setex(_key, expire,
- json.dumps((buy_single_index, buy_exec_index, compute_index, nums, count, list(max_num_sets))))
+ json.dumps((buy_single_index, buy_exec_index, compute_index, nums, count, list(max_num_sets),volume_rate)))
else:
- _buy_single_index, _buy_exec_index, _compute_index, _nums, _count, _max_num_index = TradePointManager.get_buy_compute_start_data(
- code)
+ _buy_single_index, _buy_exec_index, _compute_index, _nums, _count, _max_num_index,_volume_rate = TradePointManager.get_buy_compute_start_data(code)
redis.setex(_key, expire,
- json.dumps((_buy_single_index, buy_exec_index, compute_index, nums, count, list(max_num_sets))))
+ json.dumps((_buy_single_index, buy_exec_index, compute_index, nums, count, list(max_num_sets),volume_rate)))
# 鑾峰彇鎾や拱鍏ュ紑濮嬭绠楃殑淇℃伅
# 杩斿洖鏁版嵁鐨勫唴瀹逛负锛氭挙閿�鐐圭储寮� 鎾や拱绾拱棰� 璁＄畻鐨勬暟鎹储寮�
--
Gitblit v1.8.0