data_server.py

@@ -110,19 +110,6 @@
                     "auto_buy": TradeSetting().get_auto_buy()}
            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 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 = []
@@ -287,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()

 strategy/buying_strategy.py

@@ -430,6 +430,14 @@
                                            data_cache.bought_plate.extend(limit_up_plate_included_list)
                                            logger_info(
                                                f"【{k_line_data[0]['sec_name']}】交易成功！持仓集合：{data_cache.position_symbols_set}")
                                            purchased_stock_details = {
                                                "name": k_line_data[0]['sec_name'],
                                                "policy_name": "有概念有强度策略分支",
                                                "plate_name": limit_up_plate_included,
                                                "buy_time_trading_volume_ratio": (current_volume / k_line_data[0]['volume']),
                                            }
                                            data_cache.purchased_stocks_details_list.append(purchased_stock_details)
                                            logger_info(f"已成交股票详情列表：{data_cache.purchased_stocks_details_list} ")

                                    # 有概念无强度视界
                                    if strength_list_have_it is False:
@@ -545,8 +553,8 @@
                                '''
                                无概念 有强度视界
                                '''
                                if len(limit_up_plate_included) == 0 or limit_up_plate_included.issubset(
                                        check_plate_list) is True:
                                if len(limit_up_plate_included) == 0 and limit_up_plate_included.issubset(
                                        check_plate_list) is False:
                                    # logger_info(f"【无概念】")
                                    if strength_list_have_it is True:
                                        logger_info(

 strategy/data_cache.py

@@ -278,5 +278,7 @@

# 有意购买的股票名称列表
willing_buy_list = []
# 已成交股票详情列表
purchased_stocks_details_list = []

logging.info(f"全局初始化数据  完成《《《 - {os.getpid()}")