| | |
|---|
| | | import constant |
|---|
| | | from db import redis_manager_delegate as redis_manager, mysql_data_delegate as mysql_data |
|---|
| | | from db.redis_manager_delegate import RedisUtils |
|---|
| | | from log_module import log_export |
|---|
| | | from log_module import log_export, async_log_util |
|---|
| | | from log_module.log import hx_logger_l2_transaction, logger_debug, logger_request_api |
|---|
| | | from strategy import data_cache |
|---|
| | | from strategy.kpl_data_manager import KPLStockOfMarketsPlateLogManager |
|---|
| | |
|---|
| | | raise Exception("没有获取到L1数据") |
|---|
| | | pre_price = data[1] |
|---|
| | | current_price = data[2] if data[2] else data[5][0][0] |
|---|
| | | # 获取最新成交价格 |
|---|
| | | latest_deal_price = data_cache.latest_deal_price_dict.get(code) |
|---|
| | | if latest_deal_price: |
|---|
| | | current_price = round(float(latest_deal_price), 2) |
|---|
| | | async_log_util.info(logger_debug, f"根据成交价卖出：{code}-{latest_deal_price}") |
|---|
| | | |
|---|
| | | price = tool.get_buy_min_price(current_price) |
|---|
| | | price = max(price, tool.get_limit_down_price(code, pre_price)) |
|---|
| | | else: |
|---|
