| | |
|---|
| | | import threading |
|---|
| | | import time |
|---|
| | | |
|---|
| | | import requests |
|---|
| | | import schedule |
|---|
| | | |
|---|
| | | import constant |
|---|
| | |
|---|
| | | from trade.huaxin.huaxin_trade_record_manager import DelegateRecordManager |
|---|
| | | from trade.order_statistic import DealAndDelegateWithBuyModeDataManager |
|---|
| | | from trade.buy_radical.radical_buy_data_manager import RadicalBuyDataManager, RadicalBuyBlockManager, \ |
|---|
| | | EveryLimitupBigDealOrderManager, RadicalCodeMarketInfoManager |
|---|
| | | EveryLimitupBigDealOrderManager, RadicalCodeMarketInfoManager, RadicalBigOrderThresholdManager |
|---|
| | | from trade.sell.sell_rule_manager import TradeRuleManager |
|---|
| | | from trade.trade_data_manager import RadicalBuyDealCodesManager |
|---|
| | | from trade.trade_manager import CodesTradeStateManager |
|---|
| | |
|---|
| | | finally: |
|---|
| | | cls.__updating_jx_blocks_codes.discard(code_) |
|---|
| | | |
|---|
| | | def pull_pre_deal_big_orders(code_): |
|---|
| | | response_data = requests.get( |
|---|
| | | "http://127.0.0.1:9005/get_big_buy_order_list?code=" + code_) |
|---|
| | | r_str = response_data.text |
|---|
| | | response_data = json.loads(r_str) |
|---|
| | | if response_data["code"] == 0: |
|---|
| | | datas = response_data["data"] |
|---|
| | | logger_debug.info(f"拉取炸板前成交的大单：{code_}-{datas}") |
|---|
| | | if datas: |
|---|
| | | RadicalBigOrderThresholdManager().set_big_deal_order_list(code_, datas, gpcode_manager.get_limit_up_price_as_num(code_)) |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | time_str = f"{data['dataTimeStamp']}" |
|---|
| | | if time_str.startswith("9"): |
|---|
| | | time_str = "0" + time_str |
|---|
| | |
|---|
| | | if data["sell"] and len(data["sell"]) > 1 and data["sell"][1][1] > 0: |
|---|
| | | # 出现卖二 |
|---|
| | | radical_buy_strategy.clear_data(code, force=True) |
|---|
| | | if RadicalBigOrderThresholdManager().is_need_update(code): |
|---|
| | | # 炸板更新数据 |
|---|
| | | cls.__sell_thread_pool.submit( |
|---|
| | | lambda: pull_pre_deal_big_orders(code)) |
|---|
| | | |
|---|
| | | # 设置扫入数据 |
|---|
| | | RadicalCodeMarketInfoManager().set_market_info(code, time_str, round(float(limit_up_price), 2), data["buy"][0], |
|---|
