| | |
|---|
| | | def set_level_1_codes_datas(cls, datas, request_id=None): |
|---|
| | | async_log_util.info(logger_l2_codes_subscript, f"({request_id})接受到L1的数据，开始预处理") |
|---|
| | | yesterday_codes = kpl_data_manager.get_yesterday_limit_up_codes() |
|---|
| | | fixed_codes = gpcode_manager.BuyOpenLimitUpCodeManager().get_codes() |
|---|
| | | if fixed_codes is None: |
|---|
| | | fixed_codes = set() |
|---|
| | | # 订阅的代码 |
|---|
| | | flist = [] |
|---|
| | | temp_volumns = [] |
|---|
| | |
|---|
| | | # 如果现价是0.0就取买1价 |
|---|
| | | price = d[1] if d[1] > 0 else d[5] |
|---|
| | | # 格式 (代码,现价,涨幅,量,更新时间,买1价格,买1量) |
|---|
| | | # 剔除昨日涨停的票 |
|---|
| | | if code in yesterday_codes: |
|---|
| | | # 剔除昨日涨停的票且不在固定代码中的票 |
|---|
| | | if code in yesterday_codes and code not in fixed_codes: |
|---|
| | | continue |
|---|
| | | # 剔除股价大于40块的票 |
|---|
| | | if price > constant.MAX_SUBSCRIPT_CODE_PRICE: |
|---|
