| | |
|---|
| | | TargetCodePlateKeyManager |
|---|
| | | from third_data.history_k_data_util import JueJinApi |
|---|
| | | from trade import trade_manager, l2_trade_util, \ |
|---|
| | | trade_data_manager, trade_constant, radical_buy_strategy, radical_buy_data_manager |
|---|
| | | trade_data_manager, trade_constant, radical_buy_strategy, radical_buy_data_manager, buy_open_limit_up_strategy |
|---|
| | | from trade.buy_money_count_setting import BuyMoneyAndCountSetting, BuyMoneyUtil |
|---|
| | | |
|---|
| | | from trade.huaxin import huaxin_trade_api as trade_api, huaxin_trade_api, huaxin_trade_data_update, \ |
|---|
| | |
|---|
| | | current_delegates = DelegateRecordManager().list_current_delegates(code) |
|---|
| | | if current_delegates: |
|---|
| | | for c in current_delegates: |
|---|
| | | huaxin_trade_api.cancel_order(1, code, c["orderSysID"]) |
|---|
| | | huaxin_trade_api.cancel_order(huaxin_trade_api.TRADE_DIRECTION_BUY, code, |
|---|
| | | c["orderSysID"]) |
|---|
| | | |
|---|
| | | # 获取L1现价 |
|---|
| | | @classmethod |
|---|
| | |
|---|
| | | result_by_volume = radical_buy_strategy.process_limit_up_active_buy_deal(code, transaction_datas) |
|---|
| | | async_log_util.info(logger_l2_radical_buy, f"量买入结果判断：{code}, 结果：{result_by_volume} 板块：{buy_blocks}") |
|---|
| | | if result_by_volume[0] != radical_buy_strategy.BUY_MODE_NONE: |
|---|
| | | if tool.get_now_time_as_int() < 93200: |
|---|
| | | radical_buy_data_manager.ExcludeIndexComputeCodesManager.add_code(code) |
|---|
| | | async_log_util.info(logger_l2_radical_buy, |
|---|
| | | f"09:32之前不交易：{code}") |
|---|
| | | return |
|---|
| | | # 判断是否开得太高 |
|---|
| | | open_price = L1DataManager.get_open_price(code) |
|---|
| | | if not radical_buy_strategy.is_can_buy_with_open_price(code, open_price): |
|---|
| | | async_log_util.info(logger_l2_radical_buy, |
|---|
| | | f"开得太高：{code}") |
|---|
| | | radical_buy_data_manager.ExcludeIndexComputeCodesManager.add_code(code) |
|---|
| | | return |
|---|
| | | radical_buy_data_manager.ExcludeIndexComputeCodesManager.remove_code(code) |
|---|
| | | |
|---|
| | | |
|---|
| | | if result_by_volume[0] == radical_buy_strategy.BUY_MODE_DIRECT: |
|---|
| | | refer_sell_data = L2MarketSellManager().get_refer_sell_data(code, |
|---|
| | |
|---|
| | | return |
|---|
| | | try: |
|---|
| | | volume = tool.get_buy_volume_by_money(limit_up_price, constant.AVAILABLE_BUY_MONEYS[0]) |
|---|
| | | result = huaxin_trade_api.order(1, code, volume, limit_up_price, blocking=True, |
|---|
| | | shadow_price=shadow_price) |
|---|
| | | result = huaxin_trade_api.order(huaxin_trade_api.TRADE_DIRECTION_BUY, code, volume, limit_up_price, |
|---|
| | | blocking=True, |
|---|
| | | shadow_price=shadow_price, shadow_volume=volume) |
|---|
| | | async_log_util.info(logger_trade, f"{code}下单结束：{result}") |
|---|
| | | buy_open_limit_up_strategy.BuyOpenLimitupDataManager().set_place_order_info(code, volume, volume) |
|---|
| | | except Exception as e: |
|---|
| | | pass |
|---|
| | | |
|---|
