1.板上盯卖 L2决策分支简化/外部接口优化

admin

9 天以前 0d58b8db40c4607f589b08010b38d127b1080836

 data_server.py

@@ -15,9 +15,9 @@
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
@@ -110,18 +110,6 @@
                     "auto_buy": TradeSetting().get_auto_buy()}
            response_data = json.dumps({"code": 0, "data": fdata})

        elif url.path == "/set_trade_settings":
            running = params_dict.get("running")
            auto_sell = params_dict.get("auto_sell")
            auto_buy = params_dict.get("auto_buy")
            if running is not None:
                TradeSetting().set_running(int(running))
            if auto_sell is not None:
                TradeSetting().set_auto_sell(int(auto_sell))
            if auto_buy is not None:
                TradeSetting().set_auto_buy(int(auto_buy))
            response_data = json.dumps({"code": 0, "data": {}})

        elif url.path == "/get_env":
            request_id = params_dict.get("request_id")
            use_time_list = []
@@ -193,9 +181,9 @@
                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":
            # 获取开盘啦流入板块详细信息
@@ -204,7 +192,7 @@
                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:
@@ -286,6 +274,23 @@
                    else:
                        huaxin_trade_api.add_trade_callback_data(body)
                result_str = json.dumps({"code": 0})
            elif url.path == "/set_trade_settings":
                params = self.__parse_request()
                if not self.__is_sign_right(params):
                    result_str = json.dumps({"code": 1001, "msg": "签名错误"})
                    return
                logger_debug.info(f"set_trade_settings: {params}")
                running = params.get("running")
                auto_sell = params.get("auto_sell")
                auto_buy = params.get("auto_buy")
                if running is not None:
                    TradeSetting().set_running(int(running))
                if auto_sell is not None:
                    TradeSetting().set_auto_sell(int(auto_sell))
                if auto_buy is not None:
                    TradeSetting().set_auto_buy(int(auto_buy))
                result_str = json.dumps({"code": 0, "data": {}})

            elif url.path == "/buy":
                # 签名验证
                params = self.__parse_request()
@@ -450,7 +455,7 @@
        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__":