| | |
|---|
| | | # 获取当日实时身位 |
|---|
| | | # before_blocks_dict格式位{"代码":set("板块")} |
|---|
| | | def get_code_current_rank(code, block, current_limit_up_datas, code_limit_up_reason_dict, |
|---|
| | | yesterday_current_limit_up_codes, exclude_codes, shsz=False): |
|---|
| | | yesterday_current_limit_up_codes, exclude_codes,open_limit_up_count, shsz=False): |
|---|
| | | block_codes_infos = [] |
|---|
| | | limit_up_time = time.time() |
|---|
| | | for k in current_limit_up_datas: |
|---|
| | |
|---|
| | | if k[0] in yesterday_current_limit_up_codes: |
|---|
| | | continue |
|---|
| | | if code_limit_up_reason_dict.get(k[0]) == block: |
|---|
| | | if k[0] != code and k[0] not in exclude_codes: |
|---|
| | | if k[0] != code: |
|---|
| | | # 代码.涨停时间 |
|---|
| | | block_codes_infos.append((k[0], int(k[2]))) |
|---|
| | | block_codes_infos.append((code, limit_up_time)) |
|---|
| | | block_codes_infos.sort(key=lambda x: x[1]) |
|---|
| | | front_codes = [] |
|---|
| | | first_count = 0 |
|---|
| | | for i in range(0, len(block_codes_infos)): |
|---|
| | | if i == open_limit_up_count and exclude_codes and block_codes_infos[i][0] in exclude_codes: |
|---|
| | | # 非开1老大被排除 |
|---|
| | | first_count += 1 |
|---|
| | | continue |
|---|
| | | if block_codes_infos[i][0] == code: |
|---|
| | | return i, front_codes |
|---|
| | | return i - first_count, front_codes |
|---|
| | | else: |
|---|
| | | front_codes.append(block_codes_infos[i][0]) |
|---|
| | | return 0, [] |
|---|
