| | |
|---|
| | | 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) |
|---|
