third_data/kpl_data_constant.py | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
trade/trade_manager.py | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
third_data/kpl_data_constant.py
@@ -2,6 +2,7 @@ import constant from db import redis_manager_delegate as redis_manager from db.redis_manager_delegate import RedisUtils from third_data import kpl_util from third_data.third_blocks_manager import BlockMapManager from utils import tool @@ -139,7 +140,8 @@ # 取涨停次数最多的和最近涨停的 blocks.add(block_infos[0][0]) blocks -= constant.KPL_INVALID_BLOCKS return blocks # 去除例如概念这些泛指词 return set([kpl_util.filter_block(x) for x in blocks]) def get_limit_up_reasons(self, code): """ trade/trade_manager.py
@@ -580,6 +580,8 @@ if trade_gui is not None: trade_gui.THSBuyWinManagerNew.cancel_distribute_win_for_code(code) # 交易成功时间过去3s之后,且当前委托列表里面还有该代码数据就再次执行撤单 # 新版下单不处理 if not constant.IS_NEW_VERSION_PLACE_ORDER: if tool.trade_time_sub(tool.get_now_time_str(), _time) > 3: # 获取到当前是否委托 for dd in latest_trade_delegate_data: @@ -596,7 +598,6 @@ latest_trade_delegate_data.extend(datas) codes = [] for data in datas: code = data["code"] if code is not None: codes.append(code) @@ -665,6 +666,8 @@ RadicalBuyDealCodesManager().add_deal_code(code) # 取s消所有的挂单 if constant.API_TRADE_ENABLE: if not constant.IS_NEW_VERSION_PLACE_ORDER: # 新版本拆单下单不撤单 if constant.TRADE_WAY == constant.TRADE_WAY_JUEJIN: trade_juejin.cancel_order(code) elif constant.TRADE_WAY == constant.TRADE_WAY_HUAXIN: