huaxin_client/l2_data_manager.py
@@ -158,13 +158,13 @@ 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) else: if temp_list: # 上传数据 self.__upload_l2_data(code, upload_queue, temp_list) @@ -189,12 +189,11 @@ 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) else: if temp_list: # 上传数据 self.__upload_l2_data(code, upload_queue, temp_list)