| | |
|---|
| | | 'val']['time']) |
|---|
| | | cls.volume_rate_info[code] = (volume_rate, volume_rate_index) |
|---|
| | | |
|---|
| | | latest_time = add_datas[len(add_datas) - 1]["val"]["time"] |
|---|
| | | latest_time = add_datas[-1]["val"]["time"] |
|---|
| | | |
|---|
| | | # __start_time = l2_data_log.l2_time(code, round(t.time() * 1000) - __start_time, |
|---|
| | | # "l2数据准备时间") |
|---|
| | |
|---|
| | | cls.__process_order(code, start_index, end_index, capture_timestamp, is_first_code) |
|---|
| | | else: |
|---|
| | | # 未挂单,时间相差不大才能挂单 |
|---|
| | | if l2.l2_data_util.L2DataUtil.is_same_time(now_time_str, latest_time) or int(now_time_str.replace(":","")) < int("093200"): |
|---|
| | | if tool.trade_time_sub(latest_time, "09:32:00") < 0 or l2.l2_data_util.L2DataUtil.is_same_time(now_time_str, latest_time): |
|---|
| | | cls.__process_not_order(code, start_index, end_index, capture_timestamp, is_first_code) |
|---|
| | | |
|---|
| | | async_log_util.info(logger_l2_process, "code:{} 处理数据范围: {}-{} 处理时间:{} 截图时间戳：{}", code, |
|---|
| | |
|---|
| | | # 快速买入法的信号位置查找 |
|---|
| | | @classmethod |
|---|
| | | def __compute_fast_order_begin_pos(cls, code, start_index, end_index): |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price(code) |
|---|
| | | # if float(limit_up_price) < 3: |
|---|
| | | # return False, -1, "股价小于3块" |
|---|
| | | total_datas = local_today_datas[code] |
|---|
| | | start_time_str = total_datas[start_index]["val"]["time"] |
|---|
| | | # if tool.trade_time_sub(start_time_str, "13:00:00") > 0: |
|---|
| | | # return False, -1, "超过规定时间" |
|---|
| | | refer_sell_data = cls.__L2MarketSellManager.get_refer_sell_data(code, start_time_str) |
|---|
| | | if refer_sell_data is None: |
|---|
| | | return False, -1, "总卖为空" |
|---|
