| | |
|---|
| | | from db import redis_manager_delegate as redis_manager, mysql_data_delegate as mysql_data |
|---|
| | | from db.redis_manager_delegate import RedisUtils |
|---|
| | | from log_module import log_export, async_log_util |
|---|
| | | from log_module.log import hx_logger_l2_transaction, logger_debug, logger_request_api |
|---|
| | | from log_module.log import hx_logger_l2_transaction, logger_debug, logger_request_api, logger_system |
|---|
| | | from strategy import data_cache |
|---|
| | | from strategy.kpl_data_manager import KPLStockOfMarketsPlateLogManager, KPLMarketStockHeatLogManager |
|---|
| | | from strategy.kpl_data_manager import KPLMarketsSiftPlateLogManager, KPLMarketStockHeatLogManager |
|---|
| | | 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 |
|---|
| | |
|---|
| | | response_data = json.dumps({"code": 0, "data": fdata}) |
|---|
| | | |
|---|
| | | elif url.path == "/set_trade_settings": |
|---|
| | | logger_debug.info(f"set_trade_settings: {params_dict}") |
|---|
| | | running = params_dict.get("running") |
|---|
| | | auto_sell = params_dict.get("auto_sell") |
|---|
| | | auto_buy = params_dict.get("auto_buy") |
|---|
| | |
|---|
| | | if use_time_list and use_time_list[-1][1] > 10: |
|---|
| | | logger_debug.warning(f"环境获取时间大于10s({request_id}):{use_time_list}") |
|---|
| | | # 获取板块强度数据 |
|---|
| | | elif url.path == "/load_get_kpl_market_sift_plate": |
|---|
| | | elif url.path == "/load_kpl_market_sift_plate": |
|---|
| | | # 加载数据 |
|---|
| | | KPLStockOfMarketsPlateLogManager().load_data() |
|---|
| | | KPLMarketsSiftPlateLogManager().load_data() |
|---|
| | | response_data = json.dumps({"code": 0, "msg": "暂无内容"}) |
|---|
| | | elif url.path == "/get_kpl_market_sift_plate": |
|---|
| | | # 获取开盘啦流入板块详细信息 |
|---|
| | |
|---|
| | | time_str = params_dict.get("time") |
|---|
| | | if not time_str: |
|---|
| | | time_str = tool.get_now_time_str() |
|---|
| | | fdatas = KPLStockOfMarketsPlateLogManager().get_filter_log_datas() |
|---|
| | | fdatas = KPLMarketsSiftPlateLogManager().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: |
|---|
| | |
|---|
| | | response_data = json.dumps({"code": 1, "msg": str(e)}) |
|---|
| | | |
|---|
| | | # 获取个股强度数据 |
|---|
| | | elif url.path == "/load_get_kpl_market_stock_heat": |
|---|
| | | elif url.path == "/load_kpl_market_stock_heat": |
|---|
| | | # 加载数据 |
|---|
| | | KPLMarketStockHeatLogManager().load_data() |
|---|
| | | response_data = json.dumps({"code": 0, "msg": "暂无内容"}) |
|---|
| | | elif url.path == "/get_get_kpl_market_stock_heat": |
|---|
| | | elif url.path == "/get_kpl_market_stock_heat": |
|---|
| | | # 获取开盘啦流入板块详细信息 |
|---|
| | | print("==========get_kpl_stock_of_markets_plate==========") |
|---|
| | | try: |
|---|
| | |
|---|
| | | print("HTTP server is at: http://%s:%d/" % (addr, port)) |
|---|
| | | httpd.serve_forever() |
|---|
| | | except Exception as e: |
|---|
| | | pass |
|---|
| | | logger_system.exception(e) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
