| | |
|---|
| | | |
|---|
| | | # 获取根路径 |
|---|
| | | def get_path_prefix(): |
|---|
| | | return 'D:' if is_windows() else '/home' |
|---|
| | | return 'D:' if is_windows() else '/home/userzjj' |
|---|
| | | |
|---|
| | | |
|---|
| | | # 水下捞累计连续水下时间最小值 |
|---|
| | |
|---|
| | | # 大单笔数 |
|---|
| | | BIG_MONEY_NUM = 7888 |
|---|
| | | |
|---|
| | | CACHE_PATH = f"{'D:' if is_windows() else '/home'}/trade_cache" |
|---|
| | | CACHE_PATH = f"{'D:' if is_windows() else '/home/userzjj'}/trade_cache" |
|---|
| | | |
|---|
| | | # S撤比例 |
|---|
| | | S_CANCEL_MIN_MONEY = 98 |
|---|
| | |
|---|
| | | code_name = gpcode_manager.get_code_name(code) |
|---|
| | | fresults.append((code, code_name)) |
|---|
| | | |
|---|
| | | fdata = middle_api_protocol.load_l2_subscript_codes(fresults) |
|---|
| | | fdata = middle_api_protocol.load_l2_subscript_codes(fresults) |
|---|
| | | middle_api_protocol.request(fdata) |
|---|
| | | finally: |
|---|
| | | sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8'))) |
|---|
| | |
|---|
| | | self.send_response(result, client_id, request_id) |
|---|
| | | except Exception as e: |
|---|
| | | self.send_response({"code": 1, "msg": str(e)}, client_id, request_id) |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(pipe_trade, pipe_l1): |
|---|
| | |
|---|
| | | |
|---|
| | | from utils import socket_util |
|---|
| | | |
|---|
| | | # SERVER_HOST = '43.138.167.68' |
|---|
| | | SERVER_HOST = '192.168.3.122' |
|---|
| | | SERVER_HOST = '43.138.167.68' |
|---|
| | | # SERVER_HOST = '192.168.3.122' |
|---|
| | | SERVER_PORT = 10008 |
|---|
| | | |
|---|
| | | |
|---|
