| | |
| | | from records import huaxin_trade_record_manager |
| | | from third_data import kpl_data_manager, kpl_util |
| | | from third_data.kpl_data_manager import PullTask, KPLCodeJXBlockManager, KPLLimitUpDataRecordManager |
| | | from trade import huaxin_trade_api, huaxin_trade_data_update, huaxin_sell_util, backtest_trade, buy_strategy |
| | | from trade import huaxin_trade_api, huaxin_trade_data_update, huaxin_sell_util, backtest_trade, buy_strategy, \ |
| | | sell_strategy |
| | | from trade.buy_strategy import BuyStrategyDataManager, StrategyBuyOrderRefManager |
| | | from trade.trade_manager import CodeTradeStateManager |
| | | from trade.trade_settings import WantBuyCodesManager, TradeStateManager |
| | |
| | | code = result[0] |
| | | # 正股需要加载板块 |
| | | if code.find("11") != 0 and code.find("12") != 0: |
| | | # 正股代码 |
| | | limit_up_price = tool.get_limit_up_price(code, result[8]) |
| | | # 涨幅大于5%才开始获取板块 |
| | | if result[2] > 0.05: |
| | | KPLCodeJXBlockManager().load_jx_blocks(result[0], result[3], |
| | | float(limit_up_price), |
| | | KPLLimitUpDataRecordManager.get_current_reasons()) |
| | | else: |
| | | # 可转债代码,处理 |
| | | sell_strategy.process_market_info(result, __BuyStrategyDataManager) |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | | time.sleep(1) |