| | |
|---|
| | | import threading |
|---|
| | | import time |
|---|
| | | |
|---|
| | | import constant |
|---|
| | | import qcvalueaddproapi |
|---|
| | | from log_module.log import logger_system, logger_debug |
|---|
| | | from log_module.log import logger_system |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | | global g_userid, g_passwd, g_address, g_port, g_seqnum |
|---|
| | |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | val = request_queue.get() |
|---|
| | | logger_debug.info(f"读取华鑫增值服务请求：{val}") |
|---|
| | | type_ = val['type'] |
|---|
| | | request_id = val['request_id'] |
|---|
| | | data = val.get('data') |
|---|
| | |
|---|
| | | results = thespi.queryBars(code, start_date, end_date) |
|---|
| | | __set_response_data(request_id, results) |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | pass |
|---|
| | | |
|---|
| | | |
|---|
| | | def run(request_queue: multiprocessing.Queue, response_queue: multiprocessing.Queue): |
|---|
| | |
|---|
| | | g_port = 25556 |
|---|
| | | g_userid = "388000013942" |
|---|
| | | g_passwd = "110808" |
|---|
| | | |
|---|
| | | # 内网 |
|---|
| | | g_address = "192.168.84.61" |
|---|
| | | g_port = 25557 |
|---|
| | | if not constant.is_windows(): |
|---|
| | | # 内网 |
|---|
| | | g_address = "192.168.84.61" |
|---|
| | | g_port = 25557 |
|---|
| | | |
|---|
| | | #IP（192.168.84.61）、端口（25557 |
|---|
| | | |
|---|
