| | |
|---|
| | | from log_module import log_export |
|---|
| | | from log_module.log import hx_logger_l2_transaction, logger_debug, logger_request_api |
|---|
| | | from strategy import data_cache |
|---|
| | | from strategy.kpl_data_manager import KPLStockOfMarketsPlateLogManager |
|---|
| | | from strategy.trade_setting import TradeSetting |
|---|
| | | from trade import huaxin_trade_api, huaxin_trade_data_update |
|---|
| | | from trade.huaxin_trade_record_manager import DelegateRecordManager, DealRecordManager, MoneyManager, PositionManager |
|---|
| | |
|---|
| | | time_str = params_dict.get("time") |
|---|
| | | if not time_str: |
|---|
| | | time_str = tool.get_now_time_str() |
|---|
| | | datas = log_export.load_stock_of_markets_plate() |
|---|
| | | fdatas = [] |
|---|
| | | for data in datas: |
|---|
| | | # (发生时间,[净流入板块], {"板块":(代码, 名称, 涨幅)}) |
|---|
| | | fdatas.append((data[0], [x[1] for x in data[1][0]], |
|---|
| | | {p: [(xx[0], xx[1], xx[6]) for xx in data[1][1][p]] for p in data[1][1]})) |
|---|
| | | fdatas = KPLStockOfMarketsPlateLogManager().get_filter_log_datas() |
|---|
| | | response_data = json.dumps({"code": 1, "msg": "暂无内容"}) |
|---|
| | | for i in range(len(fdatas) - 1, -1, -1): |
|---|
| | | if fdatas[i][0] <= time_str: |
|---|
