| | |
|---|
| | | self.send_response(json.dumps({"code": 1, "msg": f"数据处理出错：{e}"}), client_id, request_id) |
|---|
| | | |
|---|
| | | def OnGetCodePositionInfo(self, client_id, request_id, data): |
|---|
| | | code = data.get("code") |
|---|
| | | __start_time = time.time() |
|---|
| | | try: |
|---|
| | | code = data["code"] |
|---|
| | | if not tool.is_shsz_code(code): |
|---|
| | | raise Exception("非主板代码") |
|---|
| | | # 获取代码基本信息 |
|---|
| | |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | | self.send_response({"code": 1, "msg": f"数据处理出错：{e}"}, client_id, request_id) |
|---|
| | | finally: |
|---|
| | | use_time = time.time()-__start_time |
|---|
| | | if use_time > 0.01: |
|---|
| | | # 耗时10ms以上才记录日志 |
|---|
| | | async_log_util.info(logger_trade_position_api_request, f"{code}请求持仓耗时：{use_time*1000}ms") |
|---|
| | | |
|---|
| | | |
|---|
| | | def OnCommonRequest(self, client_id, request_id, data): |
|---|
| | | # 通用请求 |
|---|
