lizhao/bci_algo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update log

Browse Source
This commit is contained in:
lizhao
2026-06-08 19:43:44 +08:00
parent af4fb48737
commit f47e7d914f
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Zmq/filterProcess.py
View File

@@ -175,7 +175,7 @@ class SlidingFilter(threading.Thread):
continue continue
filtered_data = self._filter_window_data(window_data) filtered_data = self._filter_window_data(window_data)
algo_log(f"滤波后{filtered_data.shape}数据", level='debug') # algo_log(f"滤波后{filtered_data.shape}数据", level='debug')
if self.filter_result_callback is not None: if self.filter_result_callback is not None:
self.filter_result_callback(filtered_data[:64, :]) self.filter_result_callback(filtered_data[:64, :])

6
Zmq/zmqServer.py
View File

@@ -176,7 +176,7 @@ class zmqServer(threading.Thread):
# 转置为上位机需要的[50, 通道数]格式 # 转置为上位机需要的[50, 通道数]格式
filtered_data = filtered_data.T.astype(np.float64) filtered_data = filtered_data.T.astype(np.float64)
send_buf = filtered_data.tobytes() send_buf = filtered_data.tobytes()
algo_log(f"发送滤波数据，长度: {len(send_buf)}字节, filtered_data.shape: {filtered_data.shape}", level="DEBUG") algo_log(f"发送滤波数据，长度: {len(send_buf)}字节, filtered_data.shape: {filtered_data.shape}", level="DEBUG", record_once=True)
self.data_send_queue.put(send_buf) self.data_send_queue.put(send_buf)
def _process_data_send_queue(self): def _process_data_send_queue(self):
@@ -193,7 +193,7 @@ class zmqServer(threading.Thread):
b"", b"",
send_buf send_buf
]) ])
algo_log(f"发送滤波数据成功，长度: {len(send_buf)}字节", level="DEBUG") algo_log(f"发送滤波数据成功，长度: {len(send_buf)}字节", level="DEBUG", record_once=True)
except Exception as e: except Exception as e:
algo_log(f"发送滤波数据失败: {e}", level="ERROR") algo_log(f"发送滤波数据失败: {e}", level="ERROR")
@@ -322,7 +322,7 @@ class zmqServer(threading.Thread):
def detect_event(self, samples): def detect_event(self, samples):
self.pack_contain_event = False self.pack_contain_event = False
# 第65通道为事件通道 # 第65通道为事件通道
events = np.array(samples[-2])[0].tolist() events = samples[-2].tolist()
for idx, event in enumerate(events): for idx, event in enumerate(events):
if int(event) in self.events: if int(event) in self.events:
new_key = "".join( new_key = "".join(