| | |
| | | "money": (score_source_list[2] if score_source_list[2] else 0)} |
| | | |
| | | # 资金力度 |
| | | deal_indexes = trade.deal_big_money_manager.DealComputeProgressManager().get_traded_indexes(code) |
| | | deal_indexes = set() |
| | | deal_info = "" |
| | | params["score_data"]["deal_big_money"] = {"score": score_list[8], "money": score_source_list[8][0] // 10000, |
| | | "base_money": score_source_list[8][1] // 10000, |
| | |
| | | if params_strs: |
| | | path += "?" |
| | | path += "&".join(params_strs) |
| | | try: |
| | | # 获取参数 |
| | | response = requests.get(f"http://127.0.0.1:9004{path}") |
| | | if response.status_code == 200: |
| | | self.send_response(response.text, client_id, request_id) |
| | | else: |
| | | self.send_response(json.dumps({"code": 1, "msg": f"网络请求状态错误:{response.status_code}"}), client_id, |
| | | request_id) |
| | | except: |
| | | self.send_response(json.dumps({"code": 1, "msg": "网络请求出错"}), client_id, request_id) |
| | | |
| | | |
| | | class MyL2DataCallback(l2_data_transform_protocol.L2DataCallBack): |