| | |
|---|
| | | # 最近3分钟内的买1金额 |
|---|
| | | __latest_3m_buy1_money_list_dict = {} |
|---|
| | | __open_limit_up_lowest_price_cache = {} |
|---|
| | | # 均价 |
|---|
| | | __average_rate_dict = {} |
|---|
| | | |
|---|
| | | __instance = None |
|---|
| | | |
|---|
| | |
|---|
| | | price = self.__get_open_limit_up_lowest_price_cache(code) |
|---|
| | | return price |
|---|
| | | |
|---|
| | | # 处理 |
|---|
| | | def get_average_rate(self, code): |
|---|
| | | return self.__average_rate_dict.get(code) |
|---|
| | | |
|---|
| | | def process(self, code, buy_1_price, buy_1_volume, time_str, limit_up_price, sell_1_price, sell_1_volumn): |
|---|
| | | # 处理 |
|---|
| | | def process(self, code, buy_1_price, buy_1_volume, time_str, limit_up_price, sell_1_price, sell_1_volumn, |
|---|
| | | average_rate=None): |
|---|
| | | self.__average_rate_dict[code] = average_rate |
|---|
| | | data_str = f"{buy_1_price},{buy_1_volume},{time_str},{limit_up_price},{sell_1_price},{sell_1_volumn}" |
|---|
| | | if self.__latest_data.get(code) == data_str: |
|---|
| | | return |
|---|
| | | |
|---|
| | | # 记录日志 |
|---|
| | | logger_trade_queue_price_info.info( |
|---|
| | | f"code={code} data: time_str-{time_str}, buy_1_price-{buy_1_price},limit_up_price-{limit_up_price},sell_1_price-{sell_1_price},sell_1_volumn-{sell_1_volumn}") |
|---|
| | | f"code={code} data: time_str-{time_str}, buy_1_price-{buy_1_price},limit_up_price-{limit_up_price},sell_1_price-{sell_1_price},sell_1_volumn-{sell_1_volumn},percent_rate-{percent_rate}") |
|---|
| | | # 买1价格不能小于1块 |
|---|
| | | if float(buy_1_price) < 1.0: |
|---|
| | | return |
|---|
