| | |
|---|
| | | sell_1_price, sell_1_volume // 100, average_rate) |
|---|
| | | latest_3m_buy1_money_list = code_price_manager.Buy1PriceManager().get_latest_3m_buy1_money_list(code) |
|---|
| | | # 拉取总大单成交 |
|---|
| | | threading.Thread(target=lambda: radical_buy_data_manager.TotalDealBigOrderInfoManager.update_big_order_info(code, data["totalValueTrade"]), daemon=True).start() |
|---|
| | | threading.Thread( |
|---|
| | | target=lambda: radical_buy_data_manager.TotalDealBigOrderInfoManager.update_big_order_info(code, data[ |
|---|
| | | "totalValueTrade"]), daemon=True).start() |
|---|
| | | |
|---|
| | | async_log_util.info(hx_logger_l2_market_data, f"{code}#{data}") |
|---|
| | | |
|---|
| | |
|---|
| | | else: |
|---|
| | | async_log_util.info(logger_l2_radical_buy, |
|---|
| | | f"即将炸板：{code}-{is_almost_open_limit_up}-{l2_market_time_str}") |
|---|
| | | if is_almost_open_limit_up: |
|---|
| | | # 自由流通市值50亿以上的不处理 |
|---|
| | | zyltgb = global_util.zyltgb_map.get( |
|---|
| | | code) |
|---|
| | | if zyltgb and zyltgb > 50e8: |
|---|
| | | return |
|---|
| | | |
|---|
| | | deal_codes = RadicalBuyDealCodesManager().get_deal_codes() |
|---|
| | | # 判断今日扫入的代码数量是否大于阈值 |
|---|
| | | radical_buy_setting = BuyMoneyAndCountSetting().get_radical_buy_setting() |
|---|
