From 6ded141b11fa8b7bc59450d5fa61b46b250cbac3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 22 八月 2025 15:54:30 +0800
Subject: [PATCH] bug修复/委托记录增量更新
---
code_attribute/gpcode_manager.py | 66 ++++++++++++++++++++++++++++++++
1 files changed, 65 insertions(+), 1 deletions(-)
diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py
index 5c5dce3..cc3496a 100644
--- a/code_attribute/gpcode_manager.py
+++ b/code_attribute/gpcode_manager.py
@@ -9,7 +9,7 @@
from db.mysql_data_delegate import Mysqldb
from db.redis_manager_delegate import RedisUtils
from log_module import log_export, async_log_util
-from log_module.log import logger_pre_close_price, logger_debug
+from log_module.log import logger_pre_close_price, logger_debug, logger_trade
from trade import trade_record_log_util
from utils import tool
import decimal
@@ -582,6 +582,70 @@
RedisUtils.delete(self.__get_redis(), "green-trade-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)
+
+
+
+
def __parse_codes_data(code_datas):
codes = []
name_codes = {}
--
Gitblit v1.8.0