| | |
|---|
| | | from trade.sell import sell_manager |
|---|
| | | from trade.sell.sell_rule_manager import TradeRuleManager, SellRule |
|---|
| | | from trade.trade_manager import TradeTargetCodeModeManager, AutoCancelSellModeManager |
|---|
| | | from settings.trade_setting import MarketSituationManager |
|---|
| | | from settings.trade_setting import MarketSituationManager, TradeBlockBuyModeManager |
|---|
| | | from utils import socket_util, data_export_util, tool, huaxin_util, output_util, global_util |
|---|
| | | from server import server_util |
|---|
| | | from servers import server_util |
|---|
| | | |
|---|
| | | |
|---|
| | | class OutsideApiCommandCallback(outside_api_command_manager.ActionCallback): |
|---|
| | |
|---|
| | | count = history_k_data_manager.update_history_k_bars() |
|---|
| | | self.send_response({"code": 0, "data": {"count": count}, "msg": f"需要更新K线代码数量：{count}"}, client_id, |
|---|
| | | request_id) |
|---|
| | | elif ctype == "get_buy_block_mode": |
|---|
| | | # 获取买入板块的模式 |
|---|
| | | can_buy_unique_block = TradeBlockBuyModeManager().can_buy_unique_block() |
|---|
| | | self.send_response({"code": 0, "data": {"unique_block": 1 if can_buy_unique_block else 0 }, "msg": f""}, client_id, |
|---|
| | | request_id) |
|---|
| | | |
|---|
| | | elif ctype == "add_buy_unique_block_mode": |
|---|
| | | # 添加独苗买入模式 |
|---|
| | | TradeBlockBuyModeManager().add_unique_block() |
|---|
| | | self.send_response({"code": 0, "data": {}, "msg": f""}, |
|---|
| | | client_id, |
|---|
| | | request_id) |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | self.send_response({"code": 1, "msg": f"数据处理出错：{e}"}, client_id, request_id) |
|---|
