| | |
|---|
| | | |
|---|
| | | dask.compute(f1, f2, f3, f4) |
|---|
| | | else: |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price(code) |
|---|
| | | # 涨停价成交 |
|---|
| | | if limit_up_price and abs(float(limit_up_price) - float(datas[-1][1])) < 0.01: |
|---|
| | | # 买入订单号 |
|---|
| | | # 获取开盘啦的涨停时间 |
|---|
| | | kpl_total_datas = kpl_data_manager.KPLLimitUpDataRecordManager.total_datas |
|---|
| | | if total_datas and kpl_total_datas: |
|---|
| | | limit_up_time = None |
|---|
| | | for d in kpl_total_datas: |
|---|
| | | if d[3] == code: |
|---|
| | | limit_up_time = int(d[5]) |
|---|
| | | if limit_up_time: |
|---|
| | | if int(tool.to_time_str(limit_up_time).replace(":", "")) < int( |
|---|
| | | total_datas[0]["val"]["time"].replace(":", "")): |
|---|
| | | # 涨停时间比第一条数据时间还早 |
|---|
| | | l2_trade_util.forbidden_trade(code) |
|---|
| | | logger_trade.warning(f"{code}添加到禁止买入，原因：涨停时间比第一条数据时间还早") |
|---|
| | | pass |
|---|
| | | except Exception as e: |
|---|
| | | hx_logger_l2_transaction.exception(e) |
|---|
| | | |
|---|
