| | |
| | | # 设置成交价 |
| | | try: |
| | | current_price_process_manager.set_trade_price(code, fdatas[-1][0][1]) |
| | | if limit_up_price > fdatas[-1][0][1]: |
| | | if not fdatas[-1][2]: |
| | | # 没有涨停 |
| | | EveryLimitupBigDealOrderManager.open_limit_up(code, f"最新成交价:{fdatas[-1][0][1]}") |
| | | radical_buy_strategy.clear_data(code) |
| | | radical_buy_strategy.clear_data(code, msg=f"没有涨停:{fdatas[-1][0]}") |
| | | except: |
| | | pass |
| | | |
| | |
| | | __latest_deal_active_buy_order = {} |
| | | |
| | | |
| | | def clear_data(code, force=False, market_time_str=None): |
| | | def clear_data(code, force=False, market_time_str=None, msg=""): |
| | | """ |
| | | 清除数据:下单过后/开板后清除数据 |
| | | @param market_time_str: L2 market时间 |
| | |
| | | __deal_active_buy_total_money.pop(code) |
| | | # 清除L2下单信号 |
| | | if code in RadicalBuyDealCodesManager.buy_by_l2_delegate_expire_time_dict: |
| | | async_log_util.info(logger_l2_radical_buy, f"清除下单信号:{code}-{force}-{market_time_str} msg-{msg}") |
| | | RadicalBuyDealCodesManager.buy_by_l2_delegate_expire_time_dict.pop(code) |
| | | |
| | | |