| | |
|---|
| | | # 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, |
|---|
| | | async_log_util.info(logger_l2_process, "code:{} 处理数据范围: {}-{} 处理时间:{} 线程ID：{}", code, |
|---|
| | | add_datas[0]["index"], |
|---|
| | | add_datas[-1]["index"], round(t.time() * 1000) - __start_time, |
|---|
| | | capture_timestamp) |
|---|
| | | l2_log.threadIds.get(code)) |
|---|
| | | |
|---|
| | | # 处理未挂单 |
|---|
| | | @classmethod |
|---|
| | |
|---|
| | | # 判断板块 |
|---|
| | | # (可以买的板块列表, 是否是独苗, 消息简介,可买的强势主线, 板块关键词) |
|---|
| | | can_buy_result = cls.__get_can_buy_block(code) |
|---|
| | | l2_log.debug(code, "获取到的板块信息：{}", can_buy_result) |
|---|
| | | # l2_log.debug(code, "获取到的板块信息：{}", can_buy_result) |
|---|
| | | if can_buy_result is None: |
|---|
| | | return False, True, "尚未获取到板块信息" |
|---|
| | | # -------量的约束-------- |
|---|
