From 6ded141b11fa8b7bc59450d5fa61b46b250cbac3 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 22 八月 2025 15:54:30 +0800
Subject: [PATCH] bug修复/委托记录增量更新
---
servers/data_server.py | 17 +++++++++++++++++
1 files changed, 17 insertions(+), 0 deletions(-)
diff --git a/servers/data_server.py b/servers/data_server.py
index bbc7b06..87025d5 100644
--- a/servers/data_server.py
+++ b/servers/data_server.py
@@ -1244,6 +1244,23 @@
response_data = json.dumps({"code": 0, "data": l2_down_data})
except Exception as e:
logger_debug.exception(e)
+ elif url.path == "/get_all_delegate_list":
+ # 鑾峰彇鎵�鏈夌殑濮旀墭鍒楄〃
+ try:
+ ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
+ update_time = ps_dict.get('update_time')
+ if not update_time:
+ update_time = 0
+ else:
+ update_time = int(update_time)
+ record_dict = huaxin_trade_record_manager.DelegateRecordManager().get_all_delegate_records_dict()
+ datas = [v for k, v in record_dict.items() if v['localUpdateTime'] > update_time]
+ if datas:
+ datas.sort(key=lambda x: x['insertTime'])
+ update_time = max(datas, key=lambda x: x['localUpdateTime'])['localUpdateTime']
+ response_data = json.dumps({"code": 0, "data": {'list': datas, 'update_time': update_time}})
+ except Exception as e:
+ logger_debug.exception(e)
async_log_util.info(logger_request_api, f"缁撴潫璇锋眰{tool.get_thread_id()}-{url}")
self.send_response(200)
--
Gitblit v1.8.0