|
|
|
|
@ -702,77 +702,7 @@ class HandheldHandle(object): |
|
|
|
|
pass |
|
|
|
|
|
|
|
|
|
pass |
|
|
|
|
""" |
|
|
|
|
def dealAllMeasurements(self, ): |
|
|
|
|
log.info(f" 所有测量文件", __name__, "dealAllMeasurements", ) |
|
|
|
|
if len(self.filelist)<1: |
|
|
|
|
pass |
|
|
|
|
# 前面已经考虑各种文件错误 |
|
|
|
|
for df in self.filelist: |
|
|
|
|
# 处理信息帧 |
|
|
|
|
self.info_dict = {} |
|
|
|
|
self.info_path_fname:Path = df["info_path"] |
|
|
|
|
self.sensor_path_fname:Path = df["sensor_path"] |
|
|
|
|
hex_info = self.read_bin( self.info_path_fname ) |
|
|
|
|
try: |
|
|
|
|
self.info_dict = self.decode_info( hex_info ) |
|
|
|
|
except: |
|
|
|
|
log.error( f"处理信息文件" |
|
|
|
|
+ "/" +self.info_path_fname.stem |
|
|
|
|
+ "出现错误", __name__, "dealAllMeasurements" ) |
|
|
|
|
raise MyException( "处理文件"+ self.info_path_fname + "出现错误") |
|
|
|
|
pass |
|
|
|
|
|
|
|
|
|
try: |
|
|
|
|
# self.dealOneMeasurement(self.sensor_path_fname ) |
|
|
|
|
# 手持测量 需要分组 |
|
|
|
|
self.measurement_interval = int(self.info_dict['Measure_Interval']) |
|
|
|
|
self.measurement_repeat = int(self.info_dict['Measure_Repeat']) |
|
|
|
|
self.dealOneHandheldMeasurement(self.sensor_path_fname ) |
|
|
|
|
except Exception as e: |
|
|
|
|
log.error( "处理传感器文件" + self.sensor_path_fname.name + "出现错误",__name__,"dealAllMeasurements") |
|
|
|
|
raise MyException( "处理传感器文件" + self.sensor_path_fname.name + "出现错误" ) |
|
|
|
|
pass |
|
|
|
|
self.__set_msg('notice', '处理文件完成') |
|
|
|
|
pub.sendMessage('update' , msg=self.msg) |
|
|
|
|
log.info(f"Finished !! ", __name__, "dealAllMeasurements") |
|
|
|
|
return True,self.error_result |
|
|
|
|
pass |
|
|
|
|
|
|
|
|
|
def dealOneHandheldMeasurement(self, fpath:Path): |
|
|
|
|
'''handheld一次测量包含多组数据''' |
|
|
|
|
# 调用handheldbuf 处理，将一组数据提交出来 |
|
|
|
|
log.info(f" 处理一个文件，多组测量数据", __name__, "dealOneHandheldMeasurement") |
|
|
|
|
if len(self.filelist)<1: |
|
|
|
|
pass |
|
|
|
|
|
|
|
|
|
# 当前文件名 |
|
|
|
|
self.output_path = OUTPUT_DIR |
|
|
|
|
self.current_filepath = fpath |
|
|
|
|
self.current_measure_time = self.hhp.getCurrentMeasureTimeFromPath(fpath) |
|
|
|
|
self.get_ymdhms() |
|
|
|
|
self.output_path = self.output_path.joinpath( self.ymdhms ) |
|
|
|
|
log.debug(f"current_measure_time: {self.current_measure_time}", __name__, "dealOneHandheldMeasurement") |
|
|
|
|
|
|
|
|
|
self.hhb.readFile2Buf(fpath) |
|
|
|
|
log.debug(f"buf: {self.hhb.get_buf_size()}", __name__, "dealOneHandheldMeasurement") |
|
|
|
|
self.decode_sensor_buf() |
|
|
|
|
|
|
|
|
|
# 解析Buf, 对buf分组，获得[{lsky: esky : lwater} .... ] |
|
|
|
|
len_total = len(self.intensity_before_avg) |
|
|
|
|
if len_total%self.measurement_repeat != 0: |
|
|
|
|
self.res = {} |
|
|
|
|
return # 返回退出 |
|
|
|
|
|
|
|
|
|
# 依据总的次数 除重复次数，获得总的测了多少组数据 |
|
|
|
|
group_num = int(len_total/self.measurement_repeat) |
|
|
|
|
|
|
|
|
|
log.info(f"group_num -> {group_num}, ervery group -> {self.measurement_repeat} ", __name__, "dealOneHandheldMeasurement") |
|
|
|
|
self.real_wavelength = self.getWavelenthDict() |
|
|
|
|
# if group_num == 1: |
|
|
|
|
# self.dealOneGroup() # self.intensity_before_avg |
|
|
|
|
# return |
|
|
|
|
""" |
|
|
|
|
|
|
|
|
|
class ExternalFun(object): |
|
|
|
|
def __init__(self, aw:AWRAMSData=None): |
|
|
|
|
|
