| | |
|---|
| | | val = json.loads(val) |
|---|
| | | return val[0], val[1] |
|---|
| | | |
|---|
| | | # 添加记录 |
|---|
| | | def __add_recod(self, code): |
|---|
| | | key = "buy1_volumn_codes" |
|---|
| | | self.__get_redis().sadd(key, code) |
|---|
| | | self.__get_redis().expire(key, 10) |
|---|
| | | |
|---|
| | | # 获取当前正在监听的代码 |
|---|
| | | def get_current_codes(self): |
|---|
| | | key = "buy1_volumn_codes" |
|---|
| | | return self.__get_redis().smembers(key) |
|---|
| | | |
|---|
| | | # 返回是否需要更新数据 |
|---|
| | | def save(self, code, time_str, volumn,price): |
|---|
| | | def save(self, code, time_str, volumn, price): |
|---|
| | | # 客户端数据未加载出来过滤 |
|---|
| | | if volumn < 1: |
|---|
| | | return False |
|---|
| | | # 14:55:00之后不在处理 |
|---|
| | | if int(time_str.replace(':', '')) >= int("145500"): |
|---|
| | | return False |
|---|
| | | |
|---|
| | | self.__add_recod(code) |
|---|
| | | # 判断是否为涨停价 |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price(code) |
|---|
| | | if limit_up_price != tool.to_price(decimal.Decimal(price)): |
|---|
| | |
|---|
| | | time_str, volumn = self.__get_latest_record(code) |
|---|
| | | return time_str, volumn |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | |
|---|
| | | JueJinBuy1VolumnManager().save("001203", "15:00:00", 40586553, 12.12) |
|---|
| | | if __name__ == '__main__': |
|---|
| | | JueJinBuy1VolumnManager().save("001203", "15:00:00", 40586553, 12.12) |
|---|
