| | |
|---|
| | | import redis_manager |
|---|
| | | import tool |
|---|
| | | import global_util |
|---|
| | | import functools |
|---|
| | | |
|---|
| | | _redisManager = redis_manager.RedisManager(0) |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | def save_limit_up_time(code, time): |
|---|
| | |
|---|
| | | global_util.limit_up_time[code] = redis.get(key) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 板块强度排序 |
|---|
| | | def sort_code_by_limit_time(codes): |
|---|
| | | if not global_util.limit_up_time: |
|---|
| | | load_limit_up_time() |
|---|
| | | list = [] |
|---|
| | | for code in codes: |
|---|
| | | limit_up_time = global_util.limit_up_time.get(code) |
|---|
| | | if limit_up_time is not None: |
|---|
| | | list.append((code, limit_up_time)) |
|---|
| | | new_s = sorted(list, key=lambda e: int(e[1].replace(":", ""))) |
|---|
| | | dict_ = {} |
|---|
| | | # 相同值为同一排序 |
|---|
| | | sort_index = 0 |
|---|
| | | for i in range(0, len(new_s)): |
|---|
| | | if new_s[i - 1][1] != new_s[i][1] and i > 0: |
|---|
| | | sort_index += 1 |
|---|
| | | dict_[new_s[i][0]] = sort_index |
|---|
| | | return dict_ |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | list = [("1234578", "09:00:03"), ("12345", "09:00:00"), ("123456", "09:00:00"), ("123457", "09:00:03")] |
|---|
| | | new_s = sorted(list, key=lambda e: int(e[1].replace(":", ""))) |
|---|
| | | dict_ = {} |
|---|
| | | # 相同值为同一排序 |
|---|
| | | sort_index = 0 |
|---|
| | | for i in range(0, len(new_s)): |
|---|
| | | if new_s[i - 1][1] != new_s[i][1] and i > 0: |
|---|
| | | sort_index += 1 |
|---|
| | | dict_[new_s[i][0]] = sort_index |
|---|
| | | print(dict_) |
|---|
| | | list = [("1234578", "09:00:03",None), ("12345", "09:00:01",True), ("123456", "09:00:00",True), ("123457", "09:00:04",False)] |
|---|
