20240626

9. [aio.py] 修改了版本
10. [current.py] max/avg功能结束之前会将结果数据追加写入源文件，avg算法更改为average+3×std
11. [wavelogger.py] 算法更改为 average+3×std

aio/code/data_process/current.py

@@ -6,7 +6,7 @@ from pandas import read_csv, concat, set_option
 from re import match
 from threading import Thread
 from time import sleep
-from csv import reader
+from csv import reader, writer
 
 
 class GetThreadResult(Thread):
@@ -99,6 +99,11 @@ def current_max(data_files, rcs, trqh, w2t):
         current[axis].append(_)
         w2t(f"{data_file}: {_:.4f}")
 
+        with open(data_file, 'a+') as f_data:
+            csv_writer = writer(f_data)
+            csv_writer.writerow([''] * 4)
+            csv_writer.writerow([_])
+
     for axis, cur in current.items():
         if not cur:
             continue
@@ -127,10 +132,15 @@ def current_avg(data_files, rcs, trqh, w2t):
         c_avg = df[col].mean()
 
         scale = 1 if data_file.endswith('.csv') else 1000
-        _ = (abs(c_avg)+c_std)/scale*rca
+        _ = (abs(c_avg)+c_std*3)/scale*rca
         current[axis].append(_)
         w2t(f"{data_file}: {_:.4f}")
 
+        with open(data_file, 'a+') as f_data:
+            csv_writer = writer(f_data)
+            csv_writer.writerow([''] * 4)
+            csv_writer.writerow([_])
+
     for axis, cur in current.items():
         if not cur:
             continue

aio/code/data_process/wavelogger.py

@@ -136,7 +136,7 @@ def single_file_proc(ws, data_file, df, low, high, cycle, w2t):
             _row_lt = find_point('forward', _step, 'c'+str(_row), data_file, 'lt', df, _row, w2t)
             _start = int(_row_gt + (_row_lt - _row_gt - 50) / 2)
             _end = _start + 50
-            value = df.iloc[_start:_end, 2].mean() + df.iloc[_start:_end, 2].std()
+            value = df.iloc[_start:_end, 2].mean() + 3 * df.iloc[_start:_end, 2].std()
             _data[count].append(value)
         else:
             _row_gt = find_point('forward', _step, 'c'+str(_row), data_file, 'gt', df, _row, w2t)