| | |
|---|
| | | import http |
|---|
| | | import json |
|---|
| | | import logging |
|---|
| | | import multiprocessing |
|---|
| | | import socketserver |
|---|
| | | import threading |
|---|
| | | import time |
|---|
| | | from http.server import BaseHTTPRequestHandler |
|---|
| | | |
|---|
| | | import psutil |
|---|
| | | import requests |
|---|
| | | |
|---|
| | | from huaxin_client import l2_client_test, l1_subscript_codes_manager |
|---|
| | | from log_module.log import logger_local_huaxin_l2_transaction_big_order |
|---|
| | | from log_module.log import logger_local_huaxin_l2_transaction_big_order, logger_system |
|---|
| | | from third_data.custom_block_in_money_manager import CodeInMoneyManager, BlockInMoneyRankManager |
|---|
| | | from utils import tool |
|---|
| | | import urllib.parse as urlparse |
|---|
| | | from urllib.parse import parse_qs |
|---|
| | | |
|---|
| | | |
|---|
| | | class DataServer(BaseHTTPRequestHandler): |
|---|
| | | # 禁用日志输出 |
|---|
| | | def log_message(self, format, *args): |
|---|
| | | pass |
|---|
| | | |
|---|
| | | def do_GET(self): |
|---|
| | | path = self.path |
|---|
| | | url = urlparse.urlparse(path) |
|---|
| | | response_data = "" |
|---|
| | | if url.path == "/get_block_codes_money": |
|---|
| | | ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()]) |
|---|
| | | block = ps_dict['block'] |
|---|
| | | try: |
|---|
| | | fdatas = BlockInMoneyRankManager().get_block_codes_money(block) |
|---|
| | | response_data = json.dumps({"code": 0, "data": fdatas}) |
|---|
| | | except Exception as e: |
|---|
| | | response_data = json.dumps({"code": 1, "msg": str(e)}) |
|---|
| | | self.send_response(200) |
|---|
| | | # 发给请求客户端的响应数据 |
|---|
| | | self.send_header('Content-type', 'application/json') |
|---|
| | | self.end_headers() |
|---|
| | | self.wfile.write(response_data.encode()) |
|---|
| | | |
|---|
| | | |
|---|
| | | class ThreadedHTTPServer(socketserver.ThreadingMixIn, http.server.HTTPServer): |
|---|
| | | pass |
|---|
| | | |
|---|
| | | |
|---|
| | | def __run_server(addr, port): |
|---|
| | | handler = DataServer |
|---|
| | | try: |
|---|
| | | httpd = ThreadedHTTPServer((addr, port), handler) |
|---|
| | | print("L2_IN_MONEY HTTP server is at: http://%s:%d/" % (addr, port)) |
|---|
| | | httpd.serve_forever() |
|---|
| | | except Exception as e: |
|---|
| | | logger_system.exception(e) |
|---|
| | | logger_system.error(f"端口服务器：{port} 启动失败") |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(): |
|---|
| | |
|---|
| | | BlockInMoneyRankManager().compute() |
|---|
| | | in_list = BlockInMoneyRankManager().get_in_list() |
|---|
| | | out_list = BlockInMoneyRankManager().get_out_list() |
|---|
| | | # (代码,名称,强度,主力净额) |
|---|
| | | fins = [(0, x[0], 0, x[1]) for x in in_list[:50]] |
|---|
| | | fouts = [(0, x[0], 0, x[1]) for x in out_list[:50]] |
|---|
| | | # (代码,名称,强度,主力净额) |
|---|
| | | # 上传 |
|---|
| | | __upload_data("jingxuan_rank", json.dumps(fins)) |
|---|
| | | __upload_data("jingxuan_rank_out", json.dumps(fouts)) |
|---|
| | |
|---|
| | | time.sleep(3) |
|---|
| | | |
|---|
| | | |
|---|
| | | def __update_today_limit_up_records(): |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | BlockInMoneyRankManager().load_today_limit_up_codes() |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | finally: |
|---|
| | | time.sleep(3) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | threading.Thread(target=__compute_and_upload, daemon=True).start() |
|---|
| | | # 启动内部接口服务 |
|---|
| | | threading.Thread(target=__run_server, args=("0.0.0.0", 9005,), daemon=True).start() |
|---|
| | | # 启用定时更新当日涨停 |
|---|
| | | threading.Thread(target=__update_today_limit_up_records, daemon=True).start() |
|---|
| | | run() |
|---|
| | | while True: |
|---|
| | | time.sleep(2) |
|---|
