From 8d1af291069dbec0fcf59f9e38d56b1f788df244 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 20 八月 2025 15:01:23 +0800
Subject: [PATCH] 目录调整
---
trade/trade_manager.py | 63 -------------------------------
1 files changed, 1 insertions(+), 62 deletions(-)
diff --git a/trade/trade_manager.py b/trade/trade_manager.py
index 7f4246e..c9c28e2 100644
--- a/trade/trade_manager.py
+++ b/trade/trade_manager.py
@@ -13,6 +13,7 @@
from cancel_strategy.s_l_h_cancel_strategy import CancelRateHumanSettingManager
from code_attribute import gpcode_manager
+from code_attribute.gpcode_manager import CodesContinueBuyMoneyManager
from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager
from db.mysql_data_delegate import Mysqldb
from db.redis_manager_delegate import RedisUtils
@@ -271,68 +272,6 @@
return codes
# 璁剧疆浜ゆ槗璐︽埛鐨勫彲鐢ㄩ噾棰�
-
-
-class CodesContinueBuyMoneyManager:
- """
- 浠ｇ爜缁拱閲戦绠＄悊
- """
- __db = 2
- __redis_manager = redis_manager.RedisManager(2)
- __instance = None
- __buy_money_dict = {}
-
- def __new__(cls, *args, **kwargs):
- if not cls.__instance:
- cls.__instance = super(CodesContinueBuyMoneyManager, cls).__new__(cls, *args, **kwargs)
- cls.__load_datas()
-
- return cls.__instance
-
- @classmethod
- def __get_redis(cls):
- return cls.__redis_manager.getRedis()
-
- @classmethod
- def __load_datas(cls):
- __redis = cls.__get_redis()
- # 鍒濆鍖栨暟鎹�
- keys = RedisUtils.keys(__redis, "continue_buy_money-*", auto_free=False)
- if keys:
- for key in keys:
- code = key.split("-")[-1]
- cls.__buy_money_dict[code] = int(RedisUtils.get(__redis, key, auto_free=False))
-
- def set_continue_buy_money(self, code, money):
- """
- 璁剧疆缁拱閲戦
- @param code:
- @param money:
- @return:
- """
- self.__buy_money_dict[code] = money
- RedisUtils.setex_async(self.__db, f"continue_buy_money-{code}", tool.get_expire(), money)
- async_log_util.info(logger_trade, f"璁剧疆缁拱閲戦锛歿code}-{money}")
-
- def remove_continue_buy_money(self, code):
- """
- 绉婚櫎缁拱閲戦
- @param code:
- @return:
- """
- if code not in self.__buy_money_dict:
- return
- self.__buy_money_dict.pop(code)
- RedisUtils.delete_async(self.__db, f"continue_buy_money-{code}")
- async_log_util.info(logger_trade, f"绉婚櫎缁拱閲戦锛歿code}")
-
- def get_continue_buy_money(self, code):
- """
- 鑾峰彇缁拱閲戦
- @param code:
- @return:
- """
- return self.__buy_money_dict.get(code)
# 淇濆瓨浜ゆ槗鎴愬姛鐨勬暟鎹�
--
Gitblit v1.8.0