# 交易测试
|
# 清除交易数据
|
import unittest
|
from unittest import mock
|
|
import big_money_num_manager
|
import l2_data_manager
|
import redis_manager
|
import trade_manager
|
from l2_data_manager import TradePointManager
|
# from l2_data_manager_new import L2TradeDataProcessor, L2LimitUpMoneyStatisticUtil, AverageBigNumComputer
|
|
|
def clear_trade_data(code):
|
redis_l2 = redis_manager.RedisManager(1).getRedis()
|
keys = ["buy1_volumn_latest_info-{}", "m_big_money_begin-{}", "m_big_money_process_index-{}"]
|
for k in keys:
|
redis_l2.delete(k.format(code))
|
TradePointManager.delete_buy_point(code)
|
big_money_num_manager.reset(code)
|
redis_trade = redis_manager.RedisManager(2).getRedis()
|
redis_trade.delete("trade-state-{}".format(code))
|
|
redis_info = redis_manager.RedisManager(0).getRedis()
|
keys = redis_info.keys("*{}*".format(code))
|
for k in keys:
|
if k.find("pre") is not None:
|
continue
|
if k.find("zyltgb") is not None:
|
continue
|
|
redis_info.delete(k)
|
|
|
# class TestTrade(unittest.TestCase):
|
# processor = L2TradeDataProcessor()
|
# code = "002094"
|
# l2_data_manager.load_l2_data(code)
|
# l2_data_manager.local_today_datas[code] = l2_data_manager.local_today_datas[code][0:520]
|
# buy_single_index = 426
|
# buy_exec_index = 479
|
# processor.random_key[code] = mock.Mock(return_value=123123)
|
# L2LimitUpMoneyStatisticUtil._L2LimitUpMoneyStatisticUtil__get_l2_latest_money_record = mock.Mock(
|
# return_value=(0, -1))
|
#
|
# AverageBigNumComputer.place_order_success(code, buy_single_index, buy_exec_index)
|
#
|
# L2LimitUpMoneyStatisticUtil.process_data(code, buy_single_index, buy_exec_index, buy_single_index,
|
# buy_exec_index, False)
|
#
|
# l2_data_manager.TradePointManager.get_buy_compute_start_data = mock.Mock(return_value=(426, 479, 479, 0, 100))
|
# buy_single_index, buy_exec_index, compute_index, num, count = l2_data_manager.TradePointManager.get_buy_compute_start_data(
|
# code)
|
# processor.unreal_buy_dict[code] = mock.Mock(return_value=(479, 167234623))
|
#
|
#
|
# processor.process_order(code, 480, 519, 167234623, False)
|
# print(buy_single_index, buy_exec_index, compute_index, num, count)
|
|
|
# if __name__ == "__main__":
|
# unittest.main()
|
