1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
| """
| 行情管理
| """
| from log_module import async_log_util
| from log_module.log import logger_local_huaxin_l2_market
|
| __market_info_dict = {}
|
|
| class MarketInfo:
| def __init__(self, code, price, rate, buy1_price, buy1_volume, total_volume, total_bid_volume, total_ask_volume, pre_close_price):
| self.code = code
| self.price = price
| self.rate = rate
| self.buy1_price = buy1_price
| self.buy1_volume = buy1_volume
| self.total_volume = total_volume
| self.total_bid_volume = total_bid_volume
| self.total_ask_volume = total_ask_volume
| self.pre_close_price = pre_close_price
|
|
| def set_market_info(data, with_log=True):
| """
| 设置行情信息
| :param with_log: 是否写入日志
| :param data: (代码, 最近的价格, 涨幅, 买1价， 买1量, 成交总量, 买入量, 卖出量, 昨日收盘价, 时间戳)
| :return:
| """
| if with_log:
| async_log_util.info(logger_local_huaxin_l2_market, f"{data}")
| __market_info_dict[data[0]] = MarketInfo(data[0], data[1], data[2], data[3], data[4], data[5], data[6], data[7], data[8])
|
|
| def get_market_info(code) -> MarketInfo:
| """
| 获取行情信息
| :param code:
| :return:
| """
| return __market_info_dict.get(code)
|
|
