| | |
| | | data = ( |
| | | d["securityID"], d["dataTimeStamp"], d["lastPrice"], d["totalVolumeTrade"], d["totalValueTrade"], d["buy"], |
| | | d["sell"]) |
| | | market_code_dict[pDepthMarketData.SecurityID] = data |
| | | market_code_dict[d["securityID"]] = data |
| | | |
| | | |
| | | def __init_l2(): |
| | |
| | | result = huaxin_trade_api.get_money(blocking=True) |
| | | logger_debug.info(f"测试交易账户获取:{result}") |
| | | # 发送信息 |
| | | requests.post("http://127.0.0.1:9008/upload_big_order_datas", json.dumps([(1, 2, 3, 4, 5)])) |
| | | requests.post("http://127.0.0.1:9008/upload_big_order_datas", json=json.dumps({"data": [(1, 2, 3, 4, 5)]})) |
| | | # 获取增值服务API |
| | | result = hx_qc_value_util.get_next_trading_date("2025-06-06") |
| | | logger_debug.info(f"测试获取下一个交易日:{result}") |
| | |
| | | params = {} |
| | | datas = self.rfile.read(int(self.headers['content-length'])) |
| | | _str = str(datas, encoding="gbk") |
| | | # print(_str) |
| | | print("post请求参数:", _str) |
| | | params = json.loads(_str) |
| | | return params |
| | | |
| | |
| | | # 价格区间 |
| | | self.price_range = (3, 60) |
| | | # 老题材涨停数 |
| | | self.limit_up_count_of_old_plate = 2 |
| | | self.limit_up_count_of_old_plate = 4 |
| | | # 新题材涨停数 |
| | | self.limit_up_count_of_new_plate = 2 |
| | | self.limit_up_count_of_new_plate = 4 |
| | | # 昨日不能涨停 |
| | | self.cant_yesterday_limit_up = True |
| | | # 昨日不能跌停 |
| | |
| | | statistic_average(r"C:\Users\Administrator\Desktop\2个票涨停之后买.txt") |
| | | print("======3个票涨停之后买") |
| | | statistic_average(r"C:\Users\Administrator\Desktop\3个票涨停之后买.txt") |
| | | print("======4个票涨停之后买") |
| | | statistic_average(r"C:\Users\Administrator\Desktop\4个票涨停之后买.txt") |
| | | |