| | |
|---|
| | | RedisUtils.delete_async(self.__db, k) |
|---|
| | | |
|---|
| | | # 设置当前的总卖 |
|---|
| | | def set_current_total_sell_data(self, code, time_str, money, volume): |
|---|
| | | def set_current_total_sell_data(self, code, time_str, money, volume, sell_1_info): |
|---|
| | | # 记录日志 |
|---|
| | | async_log_util.info(logger_l2_market_sell, f"{code}: {time_str}-{money}") |
|---|
| | | async_log_util.info(logger_l2_market_sell, f"{code}: {time_str}-{money} {sell_1_info}") |
|---|
| | | if code in self.__current_total_sell_data_cache: |
|---|
| | | self.__last_total_sell_data_cache[code] = self.__current_total_sell_data_cache.get(code) |
|---|
| | | self.__current_total_sell_data_cache[code] = (time_str, round(money), volume) |
|---|
| | | self.__current_total_sell_data_cache[code] = (time_str, round(money), volume, sell_1_info) |
|---|
| | | |
|---|
| | | def get_current_total_sell_data(self, code): |
|---|
| | | return self.__current_total_sell_data_cache.get(code) |
|---|
