| | |
|---|
| | | def __increment_down_price_time(self, code, seconds): |
|---|
| | | key = "under_water_seconds-{}".format(code) |
|---|
| | | self.__get_redis().incrby(key, seconds) |
|---|
| | | # 设置个失效时间 |
|---|
| | | self.__get_redis().expire(key, tool.get_expire()) |
|---|
| | | |
|---|
| | | def __get_down_price_time_as_seconds(self, code): |
|---|
| | | key = "under_water_seconds-{}".format(code) |
|---|
| | |
|---|
| | | else: |
|---|
| | | return int(val) |
|---|
| | | |
|---|
| | | def __save_current_price_codes_count(self,count): |
|---|
| | | # 清除所有的水下捞数据 |
|---|
| | | def clear_under_water_data(self): |
|---|
| | | key = "under_water_*" |
|---|
| | | keys = self.__get_redis().keys(key) |
|---|
| | | for k in keys: |
|---|
| | | self.__get_redis().delete(k) |
|---|
| | | |
|---|
| | | def __save_current_price_codes_count(self, count): |
|---|
| | | key = "current_price_codes_count" |
|---|
| | | self.__get_redis().setex(key,10,count) |
|---|
| | | self.__get_redis().setex(key, 10, count) |
|---|
| | | |
|---|
| | | def __get_current_price_codes_count(self): |
|---|
| | | key = "current_price_codes_count" |
|---|
| | | count = self.__get_redis().get(key) |
|---|
| | | return 0 if count is None else count |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | def process_rate(self, code, rate, time_str): |
|---|
| | | # 9点半之前的数据不处理 |
|---|
| | |
|---|
| | | |
|---|
| | | def get_current_price_codes_count(self): |
|---|
| | | return self.__get_current_price_codes_count() |
|---|
| | | |
|---|
| | | |
|---|
| | | # 是否为水下捞 |
|---|
| | | def is_under_water(self, code): |
|---|
