| | |
| | | import base64 |
| | | import concurrent.futures |
| | | import copy |
| | | import json |
| | |
| | | except: |
| | | pass |
| | | |
| | | try: |
| | | if order_begin_pos: |
| | | fdata['mode'] = order_begin_pos.mode |
| | | else: |
| | | fdata['mode'] = -1 |
| | | except: |
| | | pass |
| | | |
| | | fdatas.append(fdata) |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | |
| | | kpl_data_manager.PullTask.repaire_pull_task() |
| | | # 修复数据服务 |
| | | server_util.repaire_data_server() |
| | | # 任务修复 |
| | | huaxin_trade_data_update.repaire_task() |
| | | self.send_response({"code": 0, "data": {}}, client_id, request_id) |
| | | elif ctype == "get_trade_queue": |
| | | code = data["code"] |
| | |
| | | elif ctype == "set_radical_buy_block_count_setting": |
| | | # 设置买入金额和数量 |
| | | data_str = data["data"] |
| | | data_str = base64.b64decode(data_str).decode('utf-8') |
| | | setting = json.loads(data_str) |
| | | RadicalBuyBlockCodeCountManager().set_block_code_count(setting) |
| | | self.send_response({"code": 0, "data": setting, "msg": f""}, |