| | |
|---|
| | | from trade.huaxin import huaxin_trade_api as trade_api, huaxin_trade_api, huaxin_trade_data_update, \ |
|---|
| | | huaxin_trade_record_manager, huaxin_sell_util |
|---|
| | | from api.outside_api_command_callback import OutsideApiCommandCallback |
|---|
| | | from trade.huaxin.huaxin_trade_record_manager import DelegateRecordManager |
|---|
| | | from trade.order_statistic import DealAndDelegateWithBuyModeDataManager |
|---|
| | | from trade.radical_buy_data_manager import RedicalBuyDataManager |
|---|
| | | from trade.sell.sell_rule_manager import TradeRuleManager |
|---|
| | |
|---|
| | | return |
|---|
| | | for d in datas: |
|---|
| | | if gpcode_manager.BuyOpenLimitUpCodeManager().is_in_cache(d[0]): |
|---|
| | | #09:19:50 到 09:20:00判断是否要撤单 |
|---|
| | | if int("09:19:50") <=tool.get_now_time_as_int()<int("09:20:00"): |
|---|
| | | # 09:19:50 到 09:20:00判断是否要撤单 |
|---|
| | | if int("09:19:50") <= tool.get_now_time_as_int() < int("09:20:00"): |
|---|
| | | async_log_util.info(logger_debug, f"排1撤单：{d}") |
|---|
| | | if d[8]*d[5] < 1e8: |
|---|
| | | code = d[0] |
|---|
| | | current_delegates = DelegateRecordManager().list_current_delegates(code) |
|---|
| | | if current_delegates: |
|---|
| | | for c in current_delegates: |
|---|
| | | huaxin_trade_api.cancel_order(1, code, c["orderSysID"]) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 获取L1现价 |
|---|
| | | @classmethod |
|---|
| | | def get_l1_current_price(cls, code): |
|---|
