| | |
| | | # 交易测试 |
| | | # 清除交易数据 |
| | | 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_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() |