K线形态加入计算

Administrator

2023-11-15 4062c0d9d4b7bc8e1d9e866a86c98db5c51f4fa0

 huaxin_client/l2_data_manager.py

@@ -158,23 +158,23 @@
        upload_queue = queue_info[1]
        while True:
            try:
                if len(q) > 0:
                while len(q) > 0:
                    data = q.popleft()
                    # 前置数据处理，过滤掉无用的数据
                    data = self.__filter_order(data)
                    if data:
                        temp_list.append(data)

                if temp_list:
                    # 上传数据
                    self.__upload_l2_data(code, upload_queue, temp_list)
                    temp_list = []
                else:
                    if temp_list:
                        # 上传数据
                        self.__upload_l2_data(code, upload_queue, temp_list)
                        temp_list = []
                    else:
                        if code not in self.temp_order_queue_dict:
                            self.l2_order_codes.discard(code)
                            break
                        self.l2_order_codes.add(code)
                        time.sleep(0.001)
                    if code not in self.temp_order_queue_dict:
                        self.l2_order_codes.discard(code)
                        break
                    self.l2_order_codes.add(code)
                    time.sleep(0.001)

            except Exception as e:
                logging.exception(e)
@@ -189,22 +189,21 @@
        temp_list = []
        while True:
            try:
                if len(q) > 0:
                while len(q) > 0:
                    data = q.popleft()
                    data = self.__filter_transaction(data)
                    if data:
                        temp_list.append(data)
                if temp_list:
                    # 上传数据
                    self.__upload_l2_data(code, upload_queue, temp_list)
                    temp_list = []
                else:
                    if temp_list:
                        # 上传数据
                        self.__upload_l2_data(code, upload_queue, temp_list)
                        temp_list = []
                    else:
                        if code not in self.temp_transaction_queue_dict:
                            self.l2_transaction_codes.discard(code)
                            break
                        self.l2_transaction_codes.add(code)
                        time.sleep(0.002)
                    if code not in self.temp_transaction_queue_dict:
                        self.l2_transaction_codes.discard(code)
                        break
                    self.l2_transaction_codes.add(code)
                    time.sleep(0.002)
            except:
                pass
            finally: