| | |
| | | return False |
| | | |
| | | |
| | | # 最近几天是否有最大量 |
| | | def is_latest_max_volume(record_datas, day_count): |
| | | datas = copy.deepcopy(record_datas) |
| | | datas.sort(key=lambda x: x["bob"]) |
| | | datas = datas[-120:] |
| | | max_volume = (0, datas[0]["volume"]) |
| | | for i in range(0, len(datas)): |
| | | if max_volume[1] < datas[i]["volume"]: |
| | | max_volume = (i, datas[i]["volume"]) |
| | | if len(datas) - max_volume[0] <= day_count: |
| | | return True |
| | | return False |
| | | |
| | | |
| | | # 是否有涨停 |
| | | def get_first_limit_up_count(datas): |
| | | datas = copy.deepcopy(datas) |
| | |
| | | |
| | | if can_buy_result is None: |
| | | return False, True, "尚未获取到板块信息" |
| | | if not can_buy_result[0]: |
| | | |
| | | # 板块不可买,且没有挂过单的就不能买 |
| | | if not can_buy_result[0] and trade_manager.CodesTradeStateManager().get_trade_state_cache(code) == trade_manager.TRADE_STATE_NOT_TRADE: |
| | | return False, True, can_buy_result[1] |
| | | return True, False, can_buy_result[1] |
| | | |