| | |
|---|
| | | time_str = datetime.datetime.now().strftime("%Y-%m-%d") + " 09:30:00" |
|---|
| | | timestamp = time.mktime(time.strptime(time_str, '%Y-%m-%d %H:%M:%S')) |
|---|
| | | limit_up_codes = set() |
|---|
| | | for k in limit_up_record_datas: |
|---|
| | | if code_block_dict.get(k[3]) == block: |
|---|
| | | if int(k[5]) < timestamp: |
|---|
| | | limit_up_codes.add(k[3]) |
|---|
| | | if limit_up_record_datas: |
|---|
| | | for k in limit_up_record_datas: |
|---|
| | | if code_block_dict.get(k[3]) == block: |
|---|
| | | if int(k[5]) < timestamp: |
|---|
| | | limit_up_codes.add(k[3]) |
|---|
| | | return limit_up_codes |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | for k in block_limit_up_dict: |
|---|
| | | has_shsz = False |
|---|
| | | for b in block_limit_up_dict[k]: |
|---|
| | | if b[0].find('00') == 0 or b[0].find('60') == 0: |
|---|
| | | if tool.is_can_buy_code(b[0]): |
|---|
| | | has_shsz = True |
|---|
| | | break |
|---|
| | | if not has_shsz: |
|---|
| | |
|---|
| | | if k[3] == code: |
|---|
| | | # 获取当前代码涨停时间 |
|---|
| | | limit_up_time = int(k[5]) |
|---|
| | | if shsz and not tool.is_shsz_code(k[3]): |
|---|
| | | if shsz and not tool.is_can_buy_code(k[3]): |
|---|
| | | continue |
|---|
| | | # 剔除高位板 |
|---|
| | | if k[3] in yesterday_current_limit_up_codes: |
|---|
| | |
|---|
| | | |
|---|
| | | # 获取当日实时身位 |
|---|
| | | # 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, open_limit_up_count, shsz=False): |
|---|
| | | def get_code_current_rank(code, block, current_limit_up_datas, code_limit_up_reasons_dict, |
|---|
| | | yesterday_current_limit_up_codes, exclude_codes, open_limit_up_count, shsz=False, |
|---|
| | | limit_up_time=time.time()): |
|---|
| | | block_codes_infos = [] |
|---|
| | | limit_up_time = time.time() |
|---|
| | | for k in current_limit_up_datas: |
|---|
| | | if k[0] == code: |
|---|
| | | # 获取当前代码涨停时间 |
|---|
| | | limit_up_time = int(k[2]) |
|---|
| | | if shsz and not tool.is_shsz_code(k[0]): |
|---|
| | | if shsz and not tool.is_can_buy_code(k[0]): |
|---|
| | | continue |
|---|
| | | # 剔除高位板 |
|---|
| | | if k[0] in yesterday_current_limit_up_codes: |
|---|
| | | continue |
|---|
| | | if code_limit_up_reason_dict.get(k[0]) == block: |
|---|
| | | if code_limit_up_reasons_dict.get(k[0]) and block in code_limit_up_reasons_dict.get(k[0]): |
|---|
| | | if k[0] != code: |
|---|
| | | # 代码.涨停时间 |
|---|
| | | block_codes_infos.append((k[0], int(k[2]))) |
|---|
