parent
8d58729f21
commit
3e60a77696
@ -0,0 +1,237 @@ |
||||
# import numpy as np |
||||
|
||||
from pathlib import Path |
||||
|
||||
|
||||
class DataPlot(): |
||||
''' |
||||
从文件读取数据，出来成待显示数据 |
||||
''' |
||||
|
||||
# def __init__(self, mypanel, ): |
||||
def __init__(self, ): |
||||
# self.mypanel = mypanel |
||||
# self.__eventManager = eventManger |
||||
# self.dataSaveFile = DATA_FNAME_WITHOUT_WATER |
||||
# self.axes_title = "Water Attenuation Coefficient" |
||||
# self.axes_xlabel = "Wavelength (nm)" |
||||
# self.axes_ylabel = "Attenuation Coefficient m(-1)" |
||||
# self.axes_title = "Attenuation Coefficient Demo" |
||||
self.demo_time = '' |
||||
self.demo_wl = [] # 纯水 |
||||
self.demo_data = [] # 纯水 |
||||
|
||||
self.wavelength = None |
||||
self.data_one = None |
||||
self.data_multi = None |
||||
# self.mode = "one" # multi |
||||
# self.begin_line = None |
||||
# self.line_interval = None |
||||
self.fpath :Path = Path() |
||||
self.total_lines = 0 |
||||
self.token = ";" |
||||
# self.MPL = myPanel.MPL_Panel(self) # 调用自己建立的 panel 类 |
||||
# self.Figure = self.MPL.Figure |
||||
# self.axes = self.MPL.axes |
||||
# self.FigureCanvas = self.MPL.FigureCanvas |
||||
def set_file_path( self, fpath:Path ): |
||||
self.fpath = fpath |
||||
pass |
||||
|
||||
def set_wavelength(self): |
||||
pass |
||||
|
||||
# def set_mode(self, mode ="one"): |
||||
# self.mode = mode |
||||
# pass |
||||
|
||||
def set_token(self, token =";"): |
||||
self.token = token |
||||
pass |
||||
|
||||
def set_begin_line( self, lineno = 0 ): |
||||
self.begin_line = lineno |
||||
pass |
||||
|
||||
def set_line_interval( self, line_interval = 0 ): |
||||
self.line_interval = line_interval |
||||
pass |
||||
|
||||
def get_total_lines( self, ): |
||||
''' 大文件 ''' |
||||
count = 0 |
||||
thefile = open( self.fpath, 'rb') |
||||
while True: |
||||
buffer = thefile.read(8192*1024) |
||||
if not buffer: |
||||
break |
||||
count += buffer.count(b'\n') |
||||
self.total_lines = count + 1 |
||||
|
||||
def get_wavelength_from_file( self, ): |
||||
tmp = self.get_first_line() |
||||
self.wavelength = tmp.split(self.token)[1:] |
||||
pass |
||||
|
||||
def get_reverse_x_lineno( self, x ): |
||||
line = self.__get_reverse_x_lineno(x) |
||||
line = line.split(self.token) |
||||
return line[0], line[1:] |
||||
pass |
||||
|
||||
def get_multi_by_x_m_n( self, x,m,n ): |
||||
# res_time = [] |
||||
# res_lines = [] |
||||
lines = self.__get_reverse_x_m_n_line(x,m,n) |
||||
# print(f'+++++ {lines}') |
||||
# for i in range(len(lines)): |
||||
# ln = |
||||
# res_time.append( lines[i] [0] ) |
||||
# res_lines.append( lines[i][1:] ) |
||||
# return res_time, res_lines |
||||
return lines |
||||
pass |
||||
|
||||
def __get_reverse_x_lineno(self, x): |
||||
""" |
||||
获得倒数第x行 |
||||
""" |
||||
try: |
||||
# filesize = os.path.getsize(self.fpath) |
||||
filesize = self.fpath.stat().st_size |
||||
if filesize == 0: |
||||
return None |
||||
else: |
||||
with open(self.fpath, 'rb') as fp: # to use seek from end, must use mode 'rb' |
||||
offset = -8 # initialize offset |
||||
while -offset < filesize: # offset cannot exceed file size |
||||
fp.seek(offset, 2) # read # offset chars from eof(represent by number '2') |
||||
lines = fp.readlines() # read from fp to eof |
||||
if len(lines) >= x+1: # if contains at least 2 lines |
||||
return lines[-1*x] # then last line is totally included |
||||
else: |
||||
offset *= 2 # enlarge offset |
||||
fp.seek(0) |
||||
lines = fp.readlines() |
||||
if len(lines) < x: |
||||
raise Exception("行数有误，请重试") |
||||
return lines[-1*x] |
||||
except FileNotFoundError: |
||||
print(self.fpath.name + ' not found!') |
||||
return None |
||||
|
||||
def __get_reverse_x_m_n_line(self, x, m=1, n=1): |
||||
""" |
||||
获得倒数第x行, 间隔m行, 共取n个行 |
||||
""" |
||||
print(f'__get_reverse_x_m_n_line {x} {self.fpath}') |
||||
min_lines = x + m*n |
||||
res_lines = [] |
||||
try: |
||||
# filesize = os.path.getsize(self.fpath) |
||||
filesize = self.fpath.stat().st_size |
||||
if filesize == 0: |
||||
return None |
||||
else: |
||||
with open(self.fpath, 'rb') as fp: # to use seek from end, must use mode 'rb'x |
||||
offset = -8 # initialize offset |
||||
while -offset < filesize: # offset cannot exceed file size |
||||
fp.seek( offset, 2 ) # read # offset chars from eof(represent by number '2') |
||||
lines = fp.readlines() # read from fp to eof |
||||
if len(lines) >= min_lines+1 : |
||||
for i in range(n): |
||||
res_lines.append( lines[-1*(x+m*i)].decode()) |
||||
return res_lines |
||||
else: |
||||
offset *= 2 # enlarge offset |
||||
fp.seek( 0 ) |
||||
lines = fp.readlines( ) |
||||
if len(lines) < min_lines: |
||||
raise Exception("行数有误，请重试") |
||||
for i in range(n): |
||||
res_lines.append( lines[-1*(x+m*i)].decode()) |
||||
return res_lines |
||||
print(res_lines) |
||||
except FileNotFoundError: |
||||
print(self.fpath.name + ' not found!') |
||||
return None |
||||
|
||||
def get_first_line(self, ): |
||||
firstline = '' |
||||
with open(self.fpath, 'rb') as fp: # to use seek from end, must use mode 'rb'x |
||||
firstline = fp.readline() |
||||
return firstline.decode() |
||||
|
||||
def get_last_line(self,filename:Path): |
||||
""" |
||||
获得最后一行 |
||||
:param filename: file name |
||||
:return: last line or None for empty file |
||||
""" |
||||
try: |
||||
filesize = filename.stat().st_size |
||||
if filesize == 0: |
||||
return None |
||||
else: |
||||
with open(filename, 'rb') as fp: # to use seek from end, must use mode 'rb' |
||||
offset = -8 # initialize offset |
||||
while -offset < filesize: # offset cannot exceed file size |
||||
fp.seek(offset, 2) # read # offset chars from eof(represent by number '2') |
||||
lines = fp.readlines() # read from fp to eof |
||||
if len(lines) >= 2: # if contains at least 2 lines |
||||
return lines[-1] # then last line is totally included |
||||
else: |
||||
offset *= 2 # enlarge offset |
||||
fp.seek(0) |
||||
lines = fp.readlines() |
||||
return lines[-1] |
||||
except FileNotFoundError: |
||||
print(filename + ' not found!') |
||||
return None |
||||
|
||||
def tail(file, taillines=500, return_str=True, avg_line_length=None): |
||||
""" |
||||
大文件的尾行，小文件会导致报错 |
||||
taillines : 读取尾部多少行 |
||||
avg_line_length:每行字符平均数, |
||||
return_str:返回类型，默认为字符串，False为列表。 |
||||
offset:每次循环相对文件末尾指针偏移数 |
||||
f.tell() 当前指针位置 |
||||
f.seek(a,b) a 偏移量， b:0 1 2 ，文件头 当前位置 文件尾部 |
||||
""" |
||||
with open(file, errors='ignore') as f: |
||||
if not avg_line_length: |
||||
f.seek(0, 2) |
||||
f.seek(f.tell() - 3000) |
||||
avg_line_length = int(3000 / len(f.readlines())) + 10 |
||||
f.seek(0, 2) |
||||
end_pointer = f.tell() |
||||
offset = taillines * avg_line_length |
||||
if offset > end_pointer: |
||||
f.seek(0, 0) |
||||
lines = f.readlines()[-taillines:] |
||||
return "".join(lines) if return_str else lines |
||||
offset_init = offset |
||||
i = 1 |
||||
while len(f.readlines()) < taillines: |
||||
location = f.tell() - offset |
||||
f.seek(location) |
||||
i += 1 |
||||
offset = i * offset_init |
||||
if f.tell() - offset < 0: |
||||
f.seek(0, 0) |
||||
break |
||||
else: |
||||
f.seek(end_pointer - offset) |
||||
lines = f.readlines() |
||||
if len(lines) >= taillines: |
||||
lines = lines[-taillines:] |
||||
|
||||
return "".join(lines) if return_str else lines |
||||
|
||||
|
||||
if __name__ == "__main__": |
||||
d = DataPlot() |
||||
|
||||
|
||||
|
||||
@ -0,0 +1,126 @@ |
||||
import threading |
||||
import time |
||||
|
||||
class Mythead(threading.Thread): |
||||
'''线程守护''' |
||||
def __init__(self ): |
||||
super(Mythead, self).__init__() |
||||
pass |
||||
|
||||
def set_task(self, func, *args): |
||||
self.func = func |
||||
self.args = args |
||||
|
||||
def run(self): |
||||
# print(f" --- {len(self.args)}") |
||||
if len(self.args) > 0: |
||||
self.func(self.args) |
||||
else: |
||||
self.func( ) |
||||
|
||||
class Multithread(threading.Thread): |
||||
''' |
||||
多线程 |
||||
子线程.join() -> ( 设置在start之后, 等所有阻塞线程运行完, 再运行主线程 ) |
||||
子线程.setDaemon(True) -> 设置子线程A为守护线程, 主线程所在的进程内所有非守护线程统统运行完毕, |
||||
无论子线程A有没有结束, 程序都结束 |
||||
Method: |
||||
|
||||
''' |
||||
def __init__(self): |
||||
super(Multithread, self).__init__() |
||||
self.__tasks = [] |
||||
self.act = [] |
||||
# self.__block = False |
||||
pass |
||||
|
||||
# def set_task( self, tasks ): |
||||
# self.__tasks = tasks |
||||
|
||||
def add_task(self, func, daemon=False, join=True,args=()): |
||||
tmp_dict = {} |
||||
tmp_dict.update( {"func" : func}) |
||||
if daemon == True: |
||||
tmp_dict.update( {"daemon" : True}) |
||||
else: |
||||
tmp_dict.update( {"daemon" : False}) |
||||
if join == True: |
||||
tmp_dict.update( {"join" : True}) |
||||
else: |
||||
tmp_dict.update( {"join" : False}) |
||||
if args == (): |
||||
tmp_dict.update( {"args" : ()}) |
||||
else: |
||||
tmp_dict.update( {"args" : args}) |
||||
self.__tasks.append( tmp_dict ) |
||||
|
||||
def remove_tasks(self, ): |
||||
self.__tasks = [] |
||||
self.act = [] |
||||
|
||||
def add_task_2_act(self, task): |
||||
t = threading.Thread( target = task['func'], args = task['args'] ) |
||||
self.act.append(t) |
||||
t.start() |
||||
|
||||
def execute_one_act(self,i): |
||||
if self.__tasks[i]['join']: |
||||
self.act[i].join() # 子线程阻塞完毕再运行主线程 |
||||
pass |
||||
|
||||
def prepare_tasks(self): |
||||
self.act = [] |
||||
for task in self.__tasks: |
||||
self.add_task_2_act(task) |
||||
|
||||
def execute_tasks(self): |
||||
try: |
||||
for i in range( len(self.act) ): |
||||
self.execute_one_act( i ) |
||||
pass |
||||
except Exception as e: |
||||
print(e) |
||||
|
||||
def prepare_tasks(self): |
||||
self.act = [] |
||||
for task in self.__tasks: |
||||
t = threading.Thread( target = task['func'], args = task['args'] ) |
||||
self.act.append(t) |
||||
t.start() |
||||
|
||||
def simultaneously_execute_tasks(self): |
||||
self.prepare_tasks() |
||||
self.execute_tasks() |
||||
|
||||
def sequently_execute_tasks(self): |
||||
for task in self.__tasks: |
||||
t = threading.Thread( target = task['func'], args = task['args'] ) |
||||
t.start() |
||||
t.join() |
||||
|
||||
|
||||
def t1(self): |
||||
print("thread1...") |
||||
time.sleep(10) |
||||
print("thread1... after sleep...") |
||||
|
||||
def t2(self): |
||||
print("thread2...") |
||||
time.sleep(5) |
||||
print("thread2... after sleep...") |
||||
|
||||
def t3(self): |
||||
print("thread3...") |
||||
time.sleep(3) |
||||
print("thread3... after sleep...") |
||||
|
||||
if __name__ == '__main__': |
||||
mt = Multithread() |
||||
mt.add_task(mt.t1) |
||||
mt.add_task(mt.t2) |
||||
mt.add_task(mt.t3) |
||||
# mt.prepare_tasks() # 线程同步运行 |
||||
# mt.execute_tasks() |
||||
# mt.simultaneously_execute_tasks() |
||||
mt.sequently_execute_tasks() |
||||
|
||||
@ -0,0 +1,100 @@ |
||||
#!/usr/bin/env python |
||||
# -*- encoding: utf-8 -*- |
||||
import wx |
||||
# from configobj import ConfigObj |
||||
from myconfig import MyConfig |
||||
from myconfig import YAML_FILE_NAME |
||||
|
||||
class UI_Plot_Setting(wx.Dialog): |
||||
""" |
||||
@description : 绘图 配置 |
||||
""" |
||||
def __init__(self, parent, id): |
||||
# 串口页面配置 |
||||
super(UI_Plot_Setting, self).__init__( parent ,id = id ) |
||||
self.config = MyConfig() |
||||
self.InitUI() |
||||
self.SetSize((400, 400)) |
||||
self.SetTitle(" 绘图 序列号 ") |
||||
|
||||
def InitUI(self): |
||||
self.config_yml = self.config.read_rtv_yaml() |
||||
|
||||
self.panel = wx.Panel(self) |
||||
self.vbox = wx.BoxSizer(wx.VERTICAL) |
||||
|
||||
self.sb = wx.StaticBox(self.panel, label='指定绘图设置 ') |
||||
self.sbs = wx.StaticBoxSizer(self.sb, orient=wx.VERTICAL) |
||||
|
||||
self.hbox1 = wx.BoxSizer(wx.HORIZONTAL) |
||||
self.staticText1 = wx.StaticText(self.panel, label='起始行号 ',size=(60, -1), style=wx.ALIGN_CENTRE_VERTICAL ) |
||||
self.textCtrl1 = wx.TextCtrl(self.panel, value="",size=(250,25) ) |
||||
tmp = self.get_str_from_config( "LineBegin" ) |
||||
if tmp is not None: |
||||
self.textCtrl1.SetValue(tmp) |
||||
self.hbox1.Add(self.staticText1, flag=wx.TOP|wx.LEFT, border=5) |
||||
self.hbox1.Add(self.textCtrl1, flag=wx.TOP|wx.LEFT, border=5) |
||||
self.sbs.Add(self.hbox1, flag=wx.TOP|wx.LEFT, border= 5) |
||||
|
||||
self.hbox2 = wx.BoxSizer(wx.HORIZONTAL) |
||||
self.staticText2 = wx.StaticText(self.panel, label='间隔行号: ' ,size=(60, -1)) |
||||
# self.staticText2_1 = wx.StaticText(self.panel, label='分钟 ' ,size=(60, -1)) |
||||
self.textCtrl2 = wx.TextCtrl(self.panel, value="",size=(250,25)) |
||||
tmp = self.get_str_from_config( "LineInterval" ) |
||||
if tmp is not None: |
||||
self.textCtrl2.SetValue(tmp) |
||||
self.hbox2.Add(self.staticText2, flag=wx.TOP|wx.LEFT, border=5) |
||||
self.hbox2.Add(self.textCtrl2,flag=wx.TOP|wx.LEFT, border=5) |
||||
# self.hbox2.Add(self.staticText2_1, flag=wx.TOP|wx.LEFT, border=5) |
||||
self.sbs.Add(self.hbox2, flag=wx.TOP|wx.LEFT, border=5) |
||||
|
||||
self.panel.SetSizer(self.sbs) |
||||
|
||||
self.hbox_0 = wx.BoxSizer(wx.HORIZONTAL) |
||||
self.okButton = wx.Button(self, label=u'保存配置') |
||||
self.closeButton = wx.Button(self, label='Close') |
||||
self.hbox_0.Add(self.okButton) |
||||
self.hbox_0.Add(self.closeButton, flag = wx.LEFT, border=5) |
||||
|
||||
# 添加 vbox 到panel |
||||
self.vbox.Add(self.panel, proportion=1, |
||||
flag=wx.ALL | wx.EXPAND, border=5) |
||||
|
||||
self.vbox.Add(self.hbox_0, flag=wx.ALIGN_CENTER | wx.TOP | wx.BOTTOM, border=10) |
||||
|
||||
self.SetSizer(self.vbox) |
||||
|
||||
self.okButton.Bind(wx.EVT_BUTTON, self.OnSave) |
||||
self.closeButton.Bind(wx.EVT_BUTTON, self.OnClose) |
||||
|
||||
def get_str_from_config( self, key ): |
||||
return str(self.config_yml[key]) |
||||
pass |
||||
|
||||
def set_config_by_key_val( self, key, val ): |
||||
# print(f" {key} current type {type( self.config_yml[section][key] )}") |
||||
if type( self.config_yml [key] ) == int: |
||||
self.config_yml [key] = int(val) |
||||
elif type( self.config_yml [key] ) == float: |
||||
self.config_yml [key] = float(val) |
||||
else: |
||||
self.config_yml[key] = val |
||||
pass |
||||
|
||||
|
||||
def saveData(self, e): |
||||
pass |
||||
|
||||
def OnClose(self, e): |
||||
|
||||
self.Destroy() |
||||
|
||||
def OnSave(self, e): |
||||
success = True |
||||
# 赋值字典，写入文件 |
||||
self.set_config_by_key_val( "LineBegin",self.textCtrl1.GetValue( )) |
||||
self.set_config_by_key_val( "LineInterval",self.textCtrl2.GetValue( )) |
||||
self.config.write_rtv_yaml(self.config_yml) |
||||
del self.config |
||||
if success: |
||||
self.EndModal(wx.ID_OK) |
||||
Loading…
Reference in new issue