l2数据计算优化

Administrator

2022-09-18 b946684114d097e937b766f986d12c7eea8edce8

 server.py

@@ -6,11 +6,13 @@
import time

import data_process
import global_util
import gpcode_manager
import authority
import juejin
import l2_data_manager
import l2_data_util
import ths_industry_util
import tool
import trade_manager
import l2_code_operate
@@ -103,7 +105,7 @@
                                        self.l2CodeOperate.set_operate_code_state(client, channel, 1)

                                if gpcode_manager.is_listen(code):
                                    l2_data_manager.process_data(code, datas, capture_timestamp)
                                    l2_data_manager.L2TradeDataProcessor.process(code, datas, capture_timestamp)
                            except l2_data_manager.L2DataException as l:
                                # 单价不符
                                if l.get_code() == l2_data_manager.L2DataException.CODE_PRICE_ERROR:
@@ -154,8 +156,14 @@
                    t1.start()
                elif type == 2:
                    # 涨停代码
                    codeList = data_process.parseGPCode(_str)
                    gpcode_manager.set_limit_up_list(codeList)
                    dataList = data_process.parseGPCode(_str)
                    # 设置涨停时间
                    for d in dataList:
                        _time = d["time"]
                        if _time != "00:00:00":
                            global_util.limit_up_time[d["code"]] = _time
                    gpcode_manager.set_limit_up_list(dataList)
                    ths_industry_util.set_industry_hot_num(dataList)
                elif type == 3:
                    # 交易成功信息
                    dataList = data_process.parseList(_str)