From e8ea6340db725a3b36a78e090fc6f97a90900264 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 07 八月 2023 14:06:29 +0800
Subject: [PATCH] redis批量提交数据
---
server.py | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/server.py b/server.py
index 6ee0558..4d17e72 100644
--- a/server.py
+++ b/server.py
@@ -314,7 +314,7 @@
apply_time = item["apply_time"]
if apply_time and len(apply_time) >= 8:
code = item["code"]
- trade_state = trade_manager.get_trade_state(code)
+ trade_state = trade_manager.get_trade_state_cache(code)
# 璁剧疆涓嬪崟鐘舵�佺殑浠ｇ爜涓哄凡濮旀墭
if trade_state == trade_manager.TRADE_STATE_BUY_PLACE_ORDER:
origin_apply_time = apply_time
@@ -634,7 +634,7 @@
data = json.loads(_str)
code = data["data"]["code"]
if code:
- state = trade_manager.get_trade_state(code)
+ state = trade_manager.get_trade_state_cache(code)
if state == trade_manager.TRADE_STATE_BUY_PLACE_ORDER or state == trade_manager.TRADE_STATE_BUY_DELEGATED or state == trade_manager.TRADE_STATE_BUY_CANCEL_ING:
try:
l2_data_manager_new.L2TradeDataProcessor.cancel_buy(code, "鎵嬪姩鎾ら攢")
@@ -811,7 +811,7 @@
data = json.loads(_str)
codes = data["data"]["codes"]
code = codes[0]
- state = trade_manager.get_trade_state(code)
+ state = trade_manager.get_trade_state_cache(code)
if state != trade_manager.TRADE_STATE_BUY_CANCEL_SUCCESS and state != trade_manager.TRADE_STATE_BUY_SUCCESS:
return_str = json.dumps({"code": 0, "msg": "鍙互鍙栨秷"})
else:
--
Gitblit v1.8.0