zjk/H100PowerManger
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

增加了状态显示弹窗

Browse Source
This commit is contained in:
zjk
2025-01-21 19:34:23 +08:00
parent d2961cf005
commit 57dd677271
17 changed files with 844 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
data/msg/uPower_fcsState_st.json
+19 -19
View File
@@ -1,30 +1,30 @@
{
"backpressure1_fp32": -1.6155215737897056e+25,
"backpressure2_fp32": 1.9618178500547439e-44,
"ch4oConcent1_fp32": 3.7196912217041245e-12,
"ch4oConcent2_fp32": 1.1664828806579075e-38,
"ch4o_fp32": 1.1754855226419623e-38,
"excTemp_fp32": 1.1664828806579075e-38,
"faultCode1_uint16": 29888,
"faultCode2_uint16": 49624,
"ch4oConcent1_fp32": 1687.0,
"ch4oConcent2_fp32": 1.1726195870227251e-38,
"ch4o_fp32": 1.1753983618774813e-38,
"excTemp_fp32": 1.1726195870227251e-38,
"faultCode1_uint16": 38848,
"faultCode2_uint16": 21499,
"faultCode3_uint16": 0,
"fcuCurIns_fp32": -1775767650304.0,
"fcuCurPower_fp32": 7.894814654516588e-39,
"fcuCurIns_fp32": 2.1062722967662487e+22,
"fcuCurPower_fp32": 7.9041248815135621e-39,
"fcuCur_fp32": 1.7755460477889746e-38,
"fcuFaultLeve_uint8": 194,
"fcuFaultLeve_uint8": 226,
"fcuOutIns_fp32": 0.0,
"fcuOutPower_fp32": 2.152394441202919e-42,
"fcuState_uint8": 124,
"fcuVolIns_fp32": 0.0,
"fcuVolPower_fp32": 1.1664542941692352e-38,
"fcuVol_fp32": 1.1754855226419623e-38,
"fcuVolPower_fp32": 1.1725886183266636e-38,
"fcuVol_fp32": 1.1753983618774813e-38,
"flameDet_uint8": 0,
"h2Concent1_fp32": 3.8200553831302386e-12,
"h2Concent2_fp32": 1.1664828806579075e-38,
"o2Concent1_fp32": 4.5144443738820428e-14,
"o2Concent2_fp32": 1.1664828806579075e-38,
"o2Level_fp32": 1.1664542941692352e-38,
"o2_fp32": -1075184933011456.0,
"powLimit_fp32": 1.166482740528061e-38,
"powerGen_fp32": -1075322371964928.0
"h2Concent1_fp32": 1715.25,
"h2Concent2_fp32": 1.1726195870227251e-38,
"o2Concent1_fp32": 19.4140625,
"o2Concent2_fp32": 1.1726195870227251e-38,
"o2Level_fp32": 1.1725886183266636e-38,
"o2_fp32": -1.5729414295823943e+36,
"powLimit_fp32": 1.1726194468928787e-38,
"powerGen_fp32": -1.5732659481360528e+36
}
data/msg/uPower_liBatState_st.json
+11 -11
View File
@@ -6,16 +6,16 @@
"insBatSoc_uint8": 0,
"insBatTotalElect_uint16": 2,
"insChargeState_uint8": 71,
"insCurSocHold1_uint8": 41,
"insCurSocHold2_uint8": 204,
"insCurSocHold3_uint8": 4,
"insCurSocHold1_uint8": 65,
"insCurSocHold2_uint8": 221,
"insCurSocHold3_uint8": 175,
"insCurrent_uint16": 0,
"insLinkVol_uint16": 52163,
"insLinkVol_uint16": 56547,
"insNegRelayState_uint8": 0,
"insNegRes_uint16": 52265,
"insPackVol_uint16": 32516,
"insNegRes_uint16": 56641,
"insPackVol_uint16": 32687,
"insPosRelayState_uint8": 0,
"insPosRes_uint16": 18488,
"insPosRes_uint16": 38968,
"insfaultCode_uint8": 176,
"powBatCurElect_uint16": 0,
"powBatSoc_uint8": 0,
@@ -27,12 +27,12 @@
"powCurToInsLimit1_uint8": 48,
"powCurToinsLimit2_uint8": 0,
"powCur_uint16": 15376,
"powLinkVol_uint16": 32516,
"powLinkVol_uint16": 32687,
"powNegRelayState_uint8": 0,
"powNegRes_uint16": 32516,
"powNegRes_uint16": 32687,
"powPosRelayState_uint8": 0,
"powPosRes_uint16": 52247,
"powPosRes_uint16": 56623,
"powerBatLimit_uint16": 0,
"powerPackVol_uint16": 0,
"powfaultCode_uint8": 68
"powfaultCode_uint8": 148
}
src/pPowerManger/PowerManger.cpp
+14 -8
View File
@@ -104,8 +104,7 @@ bool PowerManger::Iterate()
updateTime();
//2. 运行状态机
m_fsm.run(m_pmState,this);
cout <<"CURRENT STATE:" << m_pmState.name << " | CURRENT EVENT :" << m_pmEvent << endl;
// cout <<"CURRENT STATE:" << m_pmState.name << " | CURRENT EVENT :" << m_pmEvent << endl;
AppCastingMOOSApp::Iterate();
//3. 输出报告
buildPowerSysReport();
@@ -799,14 +798,20 @@ int PowerManger::handleInite_s1(FSM_State &fsm, void* pData)
{
cout << fsm.name << endl;
PowerManger* pm = (PowerManger*)pData;
//1. 检查复合管控器连接
double StartTime = pm->GetAppStartTime();
while (!pm->m_connected)
{
disHighVolBusCmd a;
a.fuelCellCircuitBreaker = DIS_BREAKER_OFF;
a.propulsionMotorCircuitBreaker = DIS_BREAKER_OFF;
pm->m_udpComm.sendDisSysCmd(a);
MOOSPause(1000);
pm->updateTime();
double dft = abs(pm->m_current_time - StartTime);
if(dft > 1)
if(dft > 10)
{
pm->m_pmState = pm->m_Fault_s99;
break;
@@ -835,18 +840,19 @@ int PowerManger::handleInite_s1(FSM_State &fsm, void* pData)
// 首先闭合应急电源开关
//TODO 检查并配置当前配电装置状态
disHighVolBusCmd a;
a.fuelCellCircuitBreaker = 0xAA;
a.propulsionMotorCircuitBreaker = 0xAA;
a.fuelCellCircuitBreaker = DIS_BREAKER_OFF;
a.propulsionMotorCircuitBreaker = DIS_BREAKER_OFF;
pm->m_udpComm.sendDisSysCmd(a);
MOOSPause(1000);
// pm->workCondition = "";
return 0;
}
int PowerManger::handleFault_s99(FSM_State &fsm, void* pData)
{
cout << fsm.name << endl;
// cout << fsm.name << endl;
PowerManger* pm = (PowerManger*)pData;
pm->printState(fsm,"故障");
return 0;
}
src/pPowerManger/ccuUdpMsg.h
+4
View File
@@ -21,6 +21,10 @@
#define DIS_HVBUSB_CMD_ID 0x0003
#define DIS_LVBUS_CMD_ID 0x0004
#define DIS_BREAKER_ON 0x55
#define DIS_BREAKER_OFF 0xAA
#define DIS_FAULTOFF 0x5A
typedef unsigned int Checksum;
typedef unsigned char cChecksum;
test/model/untitled.slx
BIN
View File
Binary file not shown.
test/model/untitled.slx.original
BIN
View File
Binary file not shown.
test/scripts/TestGUI.py
+46
View File
@@ -0,0 +1,46 @@
import socket
import struct
import tkinter as tk
import threading
from udpmsg import *
from datetime import datetime
from disSys import *
from logWin import *
from udpComm import *
# 创建UDP通信套接字
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 目标IP地址和端口号
target_ip = 'localhost'
target_port = 5001
server_address = (target_ip, target_port)
sock.bind(server_address)
# 要发送的消息
# 创建主窗口
root = tk.Tk()
root.title("能源管理系统调试")
# 创建消息显示窗口
logFrame = tk.LabelFrame(root, text="消息显示")
logFrame.grid(row=1, columnspan=3 ,column=0, sticky='nsw')
logwin = logWin(logFrame)
logwin.grid(row=0, column=0, sticky='nesw')
# 创建配电窗口
disSysFrame = tk.LabelFrame(root, text="配电系统")
disSysFrame.grid(row=0, column=0, sticky='ne')
disSysWin = disSys(disSysFrame)
disSysWin.grid(row=0, column=0, sticky='ne')
# 创建并启动接收和发送消息的线程
thread = threading.Thread(target=receive_messages, args=(sock, logwin, disSysWin))
thread.daemon = True
thread.start()
thread2 = threading.Thread(target=send_messages, args=(sock, logwin, disSysWin))
thread2.daemon = True
thread2.start()
# 运行主循环
root.mainloop()
# 关闭套接字
sock.close()
test/scripts/gui.py → test/scripts/back/gui.py
View File
test/scripts/guiEle.py → test/scripts/back/guiEle.py
View File
test/scripts/guiInput.py → test/scripts/back/guiInput.py
View File
test/scripts/test.py → test/scripts/back/test.py
View File
test/scripts/back/testGui.py
+44
View File
@@ -0,0 +1,44 @@
import socket
import struct
import tkinter as tk
import threading
from udpmsg import *
from datetime import datetime
from tkinter import font
from disSys import *
from guiEle import ElementDisplayApp
from until import *
from guiInput import InputGUI
# 创建UDP套接字
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server_address = ('localhost', 5001)
sock.bind(server_address)
# 创建主窗口
root = tk.Tk()
root.title("能源管理系统调试")
disSysWin = disSys(root)
disSysWin.grid(row=0, column=0, sticky='ne')
# 创建一个文本框用于显示消息
custom_font = font.Font(family="Arial", size=12, weight="normal")
text_box = tk.Text(root, height=10, width=50, font=custom_font)
text_box.grid(row=6, column=0, sticky='ne')
# 创建并启动接收和发送消息的线程
# thread = threading.Thread(target=receive_messages, args=(sock, text_box,eleplay))
# thread.daemon = True
# thread.start()
# thread2 = threading.Thread(target=send_messages, args=(sock, eleplay))
# thread2.daemon = True
# thread2.start()
# 运行主循环
root.mainloop()
# 关闭套接字
sock.close()
test/scripts/until.py → test/scripts/back/until.py
View File
test/scripts/ccuSys.py
+20
View File
@@ -0,0 +1,20 @@
import socket
import struct
import tkinter as tk
import threading
from udpmsg import *
from datetime import datetime
from tkinter import font
from guiEle import ElementDisplayApp
from until import *
from guiInput import InputGUI
from tkinter import Frame
class ccuSys(Frame):
def __init__(self,root):
super().__init__(root)
self.createWidgets()
def createWidgets(self):
pass
test/scripts/disSys.py
+502
View File
@@ -0,0 +1,502 @@
import socket
import struct
import tkinter as tk
import threading
from udpmsg import *
from datetime import datetime
from tkinter import font
from tkinter import Frame
from tkinter.ttk import *
class disSys(Frame):
def __init__(self,root):
super().__init__(root)
# 当前接受的消息,用于显示和更新
self.disHVB = msg_disHighVolBusFbMsg()
self.disHVBA = msg_disHighAVolBusFbMsg()
self.disHVBB = msg_disHighBVolBusFbMsg()
self.disLVB = msg_disLowBusFbMsg()
# 初始化列框架列表
self.col_frames = []
self.createWidgets()
self.root = root
self.root.after(2000, self.update_disp)
def createWidgets(self):
# 定义每组的颜色
self.colors = ["#FFC0CB", "#ADD8E6", "#90EE90", "#FFD700"]
# 创建自定义字体
self.custom_font = font.Font(family="Arial", size=12, weight='normal')
# 创建4个Frame来分组显示元素的值
# 断路器的frame
title=list(['高压母线断路器','高电压A母线断路器','高电压B母线断路器','低电压母线断路器'])
self.frames = []
for i in range(4):
frame = tk.Frame(self, bg=self.colors[i], padx=10, pady=10)
# frame.pack(padx=10, pady=10, expand=True, fill='both')
title_label = tk.Label(frame, text=title[i],bg=self.colors[i],relief='solid' ,font=("Arial", 16, "bold"))
title_label.grid(row=0, column=0, columnspan=4, pady=(2, 2), sticky="nsew")
self.frames.append(frame)
self.frames[0].grid(row=0, column=0, sticky='nsew')
self.frames[1].grid(row=0, column=1, sticky='nsew')
self.frames[2].grid(row=1, column=0, sticky='nsew')
self.frames[3].grid(row=1, column=1, sticky='nsew')
################################################故障选择#########################################################
inputFrame = tk.LabelFrame(self, bg='Azure',text='故障选择',font=self.custom_font ,padx=10, pady=10)
inputFrame.grid(row=0, column=2, columnspan=2, padx=2, pady=2, sticky="nsew")
# # 添加输入框来更新值 TODO：添加输入框,更新故障信息
self.checkboxes = []
self.checkboxesVar = []
self.faultDict1 = {0:'动力母线绝缘低',
1:'A汇流排绝缘低',
2:'仪表电源失电',
3:'应急电源失电',
4:'DC/DC模块过温'}
self.faultDict2 = {0:'仪表电源失电',
1:'应急电源失电',
2:'浸水报警'}
self.faultDict3 = {0:'仪表电源失电',
1:'应急电源失电',
2:'仪表汇流排绝缘低'}
self.faultDict4 = {0:'仪表失电',
1:'浸水报警'}
spl_linenum = 1
for i, dictionary in enumerate([self.faultDict1, self.faultDict2, self.faultDict3, self.faultDict4]):
self.checkboxes.append([])
self.checkboxesVar.append([])
spl = Separator(inputFrame, orient='vertical')
spl.grid(row=0, column=spl_linenum+i*2, rowspan=5, pady=(2, 2), sticky="nsew")
for j, (key, value) in enumerate(dictionary.items()):
checkboxVar = tk.IntVar()
checkbox = tk.Checkbutton(inputFrame, text=value, variable=checkboxVar,font=self.custom_font,anchor="w",
command=lambda i=i, j=j: self.cheak_fault(i, j))
checkbox.grid(row=j, column=i*2, padx=1, pady=1, sticky="nsew")
self.checkboxes[i].append(checkbox)
self.checkboxesVar[i].append(checkboxVar)
################################################电路状态#########################################################
dispFrame = tk.LabelFrame(self, bg='Azure',text='电路状态',font=self.custom_font ,padx=10, pady=10)
dispFrame.grid(row=1, column=2, columnspan=2, padx=2, pady=2, sticky="nsew") # 调整输入框的上下边距并居中显示
value = '关闭'
self.labelDcDc = tk.Label(dispFrame, text=f"{'DC/DC模块'}:{value}", font=self.custom_font, relief='groove' ,anchor="w")
self.labelDcDc.grid(row=0, column=0, padx=1, pady=1, sticky="nsew")
self.DcDcbutton = tk.Button(dispFrame, text="TURN", command=self.toggle_DcDc)
self.DcDcbutton.grid(row=0, column=1, padx=1, pady=1, sticky="nsew")
self.labelWaterInput = tk.Label(dispFrame, text=f"{'冷却水进水阀'}:{value}", font=self.custom_font, relief='groove' ,anchor="w")
self.labelWaterInput.grid(row=1, column=0, padx=1, pady=1, sticky="nsew")
self.buttonWaterInput = tk.Button(dispFrame, text="TURN", command=self.toggle_WaterInput)
self.buttonWaterInput.grid(row=1, column=1, padx=1, pady=1, sticky="nsew")
self.labelWaterOutput = tk.Label(dispFrame, text=f"{'冷却水出水阀'}:{value}", font=self.custom_font, relief='groove' ,anchor="w")
self.labelWaterOutput.grid(row=2, column=0, padx=1, pady=1, sticky="nsew")
self.buttonWaterOutput = tk.Button(dispFrame, text="TURN", command=self.toggle_WaterOutput)
self.buttonWaterOutput.grid(row=2, column=1, padx=1, pady=1, sticky="nsew")
self.buttonCurrenStateWin = tk.Button(dispFrame, text="显示电路状态", command=self.show_CurrentState)
self.buttonCurrenStateWin.grid(row=0, rowspan=3 , columnspan=2 , column=3,padx=10, pady=1, sticky="nsew")
################################################断路器操作#########################################################
# 定义四个字典来存储元素的值
self.dict1={'燃料电池断路器':'闭合',
'动力锂电池断路器':'闭合',
'推进电机断路器':'闭合',
'仪表锂电池断路器':'闭合',
'DC/DC5模块断路器':'闭合',
'艏部高压配电断路器':'闭合',
'艏部FT4/5断路器':'闭合',
'艉舵1/2断路器':'闭合',
'艉舵3/4断路器':'闭合',
'FB预留断路器':'闭合',
'TYZ预留断路器':'闭合',
'预留断路器':'闭合'}
self.dict2 = {'艏部FT1-3断路器':'闭合',
'启闭机构断路器':'闭合',
'桅杆舵机断路器':'闭合',
'XCZ断路器':'闭合',
'艏舵断路器':'闭合',
'敞开电缸断路器':'闭合'}
self.dict3 = {'仪表锂电池断路器':'闭合',
'艏部低压断路器':'闭合',
'UNIT4断路器':'闭合',
'DC/DC1断路器':'闭合',
'预留断路器1':'闭合',
'预留断路器2':'闭合',
'艉部应急电池开关':'闭合'}
self.dict4 = {'UNIT1断路器':'闭合',
'UNIT2断路器':'闭合',
'UNIT3断路器':'闭合',
'UNIT5断路器':'闭合',
'艏部抛载断路器':'闭合',
'预留断路器1':'闭合',
'预留断路器2':'断开',
'艏部应急电池开关':'闭合'}
self.labels = []
for i, dictionary in enumerate([self.dict1, self.dict2, self.dict3, self.dict4]):
self.labels.append([])
for j, (key, value) in enumerate(dictionary.items()):
# 根据元素的值选择颜色
if value == "闭合":
color = "green"
else:
color = "red"
label = tk.Label(self.frames[i], text=f"{key}: {value}", fg=color, font=self.custom_font, relief='groove' ,anchor="w")
if (j%2==0):
label.grid(row=j//2 + 1, column=j%2, padx=1, pady=1,sticky="nsew")
else:
label.grid(row=j//2 + 1, column=j%2+1, padx=1, pady=1,sticky="nsew")
self.labels[i].append(label)
# 添加按钮来改变字典中的值
button = tk.Button(self.frames[i], text="TURN", command=lambda i=i, j=j: self.toggle_value(i, j))
if (j%2==0):
button.grid(row=j//2+1, column=j%2+1, padx=1, pady=1)
else:
button.grid(row=j//2+1, column=j%2+2, padx=1, pady=1, sticky="nsew")
self.update_disp()
# 创建保存电流及电压信息的表格
self.disHVBData = []
self.disHVBAData = []
self.disHVBBData = []
self.disLVBData = []
def update_disp(self):
for i, dictionary in enumerate([self.dict1, self.dict2, self.dict3, self.dict4]):
for j, (key, value) in enumerate(dictionary.items()):
# 根据元素的值选择颜色
if value == "闭合":
color = "green"
else:
color = "red"
self.labels[i][j].config(text=f"{key}: {value}", fg=color)
def toggle_value(self, i, j):
dictionary = [self.dict1, self.dict2, self.dict3, self.dict4][i]
key = list(dictionary.keys())[j]
if dictionary[key] == "闭合":
dictionary[key] = "断开"
else:
dictionary[key] = "闭合"
print(f'{key}操作')
self.update_disp()
def toggle_DcDc(self):
if (self.labelDcDc.cget("text")[-1] == '开'):
self.labelDcDc.config(text=f"{'DC/DC模块'}:关闭")
else:
self.labelDcDc.config(text=f"{'DC/DC模块'}:打开")
print('DC/DC模块操作')
def toggle_WaterInput(self):
if (self.labelWaterInput.cget("text")[-1] == '开'):
self.labelWaterInput.config(text=f"{'冷却水进水阀'}:关闭")
else:
self.labelWaterInput.config(text=f"{'冷却水进水阀'}:打开")
print('冷却水进水阀操作')
def toggle_WaterOutput(self):
if (self.labelWaterOutput.cget("text")[-1] == '开'):
self.labelWaterOutput.config(text=f"{'冷却水出水阀'}:关闭")
else:
self.labelWaterOutput.config(text=f"{'冷却水出水阀'}:打开")
print('冷却水出水阀操作')
def cheak_fault(self,i,j):
#TODO:实现故障更新和选择
print(self.checkboxes[i][j].cget("text"),self.checkboxesVar[i][j].get())
# print(self.checkboxesVar[i][j].get())
def update_currentState(self):
# 更新所有数值显示
for struct, name, entry in self.state_entries:
entry.delete(0, tk.END)
entry.insert(0, str(getattr(struct, name)))
print('电路状态已更新')
def _create_scrollable_column(self, parent_frame, title, data_struct, state_font):
"""创建带滚动条的列"""
col_frame = tk.LabelFrame(parent_frame, text=title, font=state_font,
bd=2, relief=tk.GROOVE, padx=5, pady=5)
col_frame.grid(row=0, column=len(self.col_frames), padx=5, pady=5, sticky="nsew")
col_frame.rowconfigure(0, weight=1)
col_frame.columnconfigure(0, weight=1)
self.col_frames.append(col_frame)
# 创建滚动条容器
canvas = tk.Canvas(col_frame)
v_scrollbar = tk.Scrollbar(col_frame, orient="vertical", command=canvas.yview)
h_scrollbar = tk.Scrollbar(col_frame, orient="horizontal", command=canvas.xview)
# 创建可滚动内容框架
scrollable_frame = tk.Frame(canvas)
canvas.create_window((0, 0), window=scrollable_frame, anchor="nw")
# 配置滚动区域
def _configure_scrollregion(e):
canvas.configure(scrollregion=canvas.bbox("all"))
canvas.config(height=min(e.height, 600))
canvas.yview_moveto(0)
canvas.xview_moveto(0)
scrollable_frame.bind("<Configure>", _configure_scrollregion)
# 配置滚动条
canvas.configure(yscrollcommand=v_scrollbar.set, xscrollcommand=h_scrollbar.set)
h_scrollbar.config(command=canvas.xview)
v_scrollbar.config(command=canvas.yview)
# 布局
canvas.grid(row=0, column=0, sticky="nsew")
v_scrollbar.grid(row=0, column=1, sticky="ns")
h_scrollbar.grid(row=1, column=0, sticky="ew")
# 添加数据项
for name, value in data_struct.__dict__.items():
row_frame = tk.Frame(scrollable_frame)
row_frame.pack(fill=tk.X, padx=5, pady=2)
name_label = tk.Label(row_frame, text=name, font=state_font, width=30, anchor="w")
name_label.pack(side=tk.LEFT, padx=5)
entry = tk.Entry(row_frame, font=state_font, width=20)
entry.pack(side=tk.RIGHT, padx=5, fill=tk.X, expand=True)
entry.insert(0, str(value))
entry.config(state='readonly')
self.state_entries.append((data_struct, name, entry))
def show_CurrentState(self):
"""显示当前电路状态窗口"""
# 初始化窗口
self.currentStateWin = tk.Toplevel(self)
self.currentStateWin.title("电路状态")
self.currentStateWin.geometry("1400x800")
self.currentStateWin.minsize(1000, 600)
self.currentStateWin.protocol("WM_DELETE_WINDOW", self.on_close_currentState)
# 创建主容器
main_frame = tk.Frame(self.currentStateWin)
main_frame.pack(fill=tk.BOTH, expand=True, padx=10, pady=10)
# 配置网格布局
for i in range(4):
main_frame.columnconfigure(i, weight=1)
# 创建自定义字体
state_font = font.Font(family="Arial", size=10, weight='bold')
# 初始化状态条目列表
self.state_entries = []
self.col_frames = []
# 创建各状态列
self._create_scrollable_column(main_frame, "高压母线", self.disHVB, state_font)
self._create_scrollable_column(main_frame, "高电压A母线", self.disHVBA, state_font)
self._create_scrollable_column(main_frame, "高电压B母线", self.disHVBB, state_font)
self._create_scrollable_column(main_frame, "低电压母线", self.disLVB, state_font)
# 配置主框架布局权重
main_frame.rowconfigure(1, weight=1)
# 添加底部按钮容器
btn_frame = tk.Frame(main_frame)
btn_frame.grid(row=2, column=0, columnspan=4, pady=10, sticky="sew")
# 添加更新按钮
update_btn = tk.Button(btn_frame, text="立即更新", font=state_font,
command=self.update_currentState)
update_btn.pack(fill=tk.X, padx=5, pady=5)
# update_btn.pack(side=tk.LEFT, padx=5)
# 启动定时更新
self.update_interval = 1000 # 5秒
self.schedule_update()
def on_close_currentState(self):
"""窗口关闭回调"""
if hasattr(self, 'update_job'):
self.currentStateWin.after_cancel(self.update_job)
self.currentStateWin.destroy()
def schedule_update(self):
"""安排定时更新"""
self.update_currentState()
self.update_job = self.currentStateWin.after(self.update_interval, self.schedule_update)
def updata_data(self):
if (self.dict1['燃料电池断路器']=='闭合'):
self.disHVB.DCB1 = 0x55
else:
self.disHVB.DCB1 = 0xAA
if (self.dict1['动力锂电池断路器']=='闭合'):
self.disHVB.DCB2 = 0x55
else:
self.disHVB.DCB2 = 0xAA
if (self.dict1['推进电机断路器']=='闭合'):
self.disHVB.ZK1 = 0x55
else:
self.disHVB.ZK1 = 0xAA
if (self.dict1['仪表锂电池断路器']=='闭合'):
self.disHVB.ZK2 = 0x55
else:
self.disHVB.ZK2 = 0xAA
if (self.dict1['DC/DC5模块断路器']=='闭合'):
self.disHVB.ZK3 = 0x55
else:
self.disHVB.ZK3 = 0xAA
if (self.dict1['艏部高压配电断路器']=='闭合'):
self.disHVB.ZK4 = 0x55
else:
self.disHVB.ZK4 = 0xAA
if (self.dict1['艏部FT4/5断路器']=='闭合'):
self.disHVB.ZK5 = 0x55
else:
self.disHVB.ZK5 = 0xAA
if (self.dict1['艉舵1/2断路器']=='闭合'):
self.disHVB.ZK6 = 0x55
else:
self.disHVB.ZK6 = 0xAA
if (self.dict1['艉舵3/4断路器']=='闭合'):
self.disHVB.ZK7 = 0x55
else:
self.disHVB.ZK7 = 0xAA
if (self.dict1['FB预留断路器']=='闭合'):
self.disHVB.ZK8 = 0x55
else:
self.disHVB.ZK8 = 0xAA
if (self.dict1['TYZ预留断路器']=='闭合'):
self.disHVB.ZK9 = 0x55
else:
self.disHVB.ZK9 = 0xAA
if (self.dict1['预留断路器']=='闭合'):
self.disHVB.ZK10 = 0x55
else:
self.disHVB.ZK10 = 0xAA
######################################################
if (self.dict2['艏部FT1-3断路器']=='闭合'):
self.disHVBA.bowFTDevice123CircuitBreaker = 0x55
else:
self.disHVBA.bowFTDevice123CircuitBreaker = 0xAA
if (self.dict2['启闭机构断路器']=='闭合'):
self.disHVBA.actuatorCircuitBreaker = 0x55
else:
self.disHVBA.actuatorCircuitBreaker = 0xAA
if (self.dict2['桅杆舵机断路器']=='闭合'):
self.disHVBA.mastSteeringGearControlBoxCircuitBreaker = 0x55
else:
self.disHVBA.mastSteeringGearControlBoxCircuitBreaker = 0xAA
if (self.dict2['XCZ断路器']=='闭合'):
self.disHVBA.xczCircuitBreaker = 0x55
else:
self.disHVBA.xczCircuitBreaker = 0xAA
if (self.dict2['艏舵断路器']=='闭合'):
self.disHVBA.bowRudderControlBoxCircuitBreaker = 0x55
else:
self.disHVBA.bowRudderControlBoxCircuitBreaker = 0xAA
if (self.dict2['敞开电缸断路器']=='闭合'):
self.disHVBA.openWaterCoverStartCylinderCircuitBreaker = 0x55
else:
self.disHVBA.openWaterCoverStartCylinderCircuitBreaker = 0xAA
####################################################################
if (self.dict3['仪表锂电池断路器']=='闭合'):
self.disHVBB.lithiumBatteryGroupInstrumentCircuitBreaker = 0x55
else:
self.disHVBB.lithiumBatteryGroupInstrumentCircuitBreaker = 0xAA
if (self.dict3['艏部低压断路器']=='闭合'):
self.disHVBB.bowLowVoltageDistributionCircuitBreaker = 0x55
else:
self.disHVBB.bowLowVoltageDistributionCircuitBreaker = 0xAA
if (self.dict3['UNIT4断路器']=='闭合'):
self.disHVBB.unit4CircuitBreaker = 0x55
else:
self.disHVBB.unit4CircuitBreaker = 0xAA
if (self.dict3['DC/DC1断路器']=='闭合'):
self.disHVBB.dcdc1CircuitBreaker = 0x55
else:
self.disHVBB.dcdc1CircuitBreaker = 0xAA
if (self.dict3['预留断路器1']=='闭合'):
self.disHVBB.reservedCircuitBreaker1 = 0x55
else:
self.disHVBB.reservedCircuitBreaker1 = 0xAA
if (self.dict3['预留断路器2']=='闭合'):
self.disHVBB.reservedCircuitBreaker2 = 0x55
else:
self.disHVBB.reservedCircuitBreaker2 = 0xAA
if (self.dict3['艉部应急电池开关']=='闭合'):
self.disHVBB.emergencyLithiumBatteryGroup2CircuitBreaker = 0x55
else:
self.disHVBB.emergencyLithiumBatteryGroup2CircuitBreaker = 0xAA
######################################################################
if (self.dict4['UNIT1断路器']=='闭合'):
self.disLVB.unit1CircuitBreaker = 0x55
else:
self.disLVB.unit1CircuitBreaker = 0xAA
if (self.dict4['UNIT2断路器']=='闭合'):
self.disLVB.unit2CircuitBreaker = 0x55
else:
self.disLVB.unit2CircuitBreaker = 0xAA
if (self.dict4['UNIT3断路器']=='闭合'):
self.disLVB.unit3CircuitBreaker = 0x55
else:
self.disLVB.unit3CircuitBreaker = 0xAA
if (self.dict4['UNIT5断路器']=='闭合'):
self.disLVB.unit5CircuitBreaker = 0x55
else:
self.disLVB.unit5CircuitBreaker = 0xAA
if (self.dict4['预留断路器1']=='闭合'):
self.disLVB.reservedCircuitBreaker1 = 0x55
else:
self.disLVB.reservedCircuitBreaker1 = 0xAA
if (self.dict4['预留断路器2']=='闭合'):
self.disLVB.reservedCircuitBreaker2 = 0x55
else:
self.disLVB.reservedCircuitBreaker2 = 0xAA
if (self.dict4['艏部抛载断路器']=='闭合'):
self.disLVB.bowPZDeviceCircuitBreaker = 0x55
else:
self.disLVB.bowPZDeviceCircuitBreaker = 0xAA
if (self.dict4['艏部应急电池开关']=='闭合'):
self.disLVB.emergencyLithiumBatteryGroup1CircuitBreaker = 0x55
else:
self.disLVB.emergencyLithiumBatteryGroup1CircuitBreaker = 0xAA
a = self.disHVB.pack()
b = self.disHVBA.pack()
c = self.disHVBB.pack()
d = self.disLVB.pack()
return a,b,c,d
if __name__ == "__main__":
root = tk.Tk()
app = disSys(root)
app.pack()
root.mainloop()
test/scripts/logWin.py
+78
View File
@@ -0,0 +1,78 @@
import socket
import struct
import tkinter as tk
import threading
from udpmsg import *
from datetime import datetime
from tkinter import font, filedialog
from tkinter import Frame
from tkinter.ttk import *
class logWin(Frame):
def __init__(self, root):
super().__init__(root)
self.root = root
custom_font = font.Font(family="Arial", size=12, weight="normal")
# 设置 state 为 tk.DISABLED 禁用编辑功能
self.text_box = tk.Text(root, height=10, width=50, font=custom_font, state=tk.DISABLED)
self.text_box.grid(row=0, column=0, columnspan=2, sticky='nsew')
# 创建垂直滚动条
scrollbar = tk.Scrollbar(root, command=self.text_box.yview)
scrollbar.grid(row=0, column=2, sticky='ns')
# 将滚动条与 Text 组件关联
self.text_box.config(yscrollcommand=scrollbar.set)
# 创建保存按钮
save_button = tk.Button(root, text="保存日志", command=self.save_log)
save_button.grid(row=1, column=0, sticky='ew')
# 创建清空按钮
clear_button = tk.Button(root, text="清空日志", command=self.clear_log)
clear_button.grid(row=1, column=1, sticky='ew')
# 配置行和列的权重，使组件能够随窗口大小变化而调整
root.grid_rowconfigure(0, weight=1)
root.grid_columnconfigure(0, weight=1)
root.grid_columnconfigure(1, weight=1)
def display_log(self, log_message):
# 启用编辑功能
self.text_box.config(state=tk.NORMAL)
# 将日志信息添加到 Text 组件中
self.text_box.insert(tk.END, log_message + "\n")
# 滚动到 Text 组件的底部，以显示最新的日志信息
self.text_box.see(tk.END)
# 禁用编辑功能
self.text_box.config(state=tk.DISABLED)
def save_log(self):
# 打开文件选择对话框
file_path = filedialog.asksaveasfilename(defaultextension=".txt", filetypes=[("Text Files", "*.txt"), ("All Files", "*.*")])
if file_path:
# 获取文本框中的内容
log_content = self.text_box.get("1.0", tk.END)
# 将内容写入文件
with open(file_path, "w") as file:
file.write(log_content)
# 显示保存成功的提示
tk.messagebox.showinfo("保存成功", "日志已成功保存到文件。")
def clear_log(self):
# 启用编辑功能
self.text_box.config(state=tk.NORMAL)
# 清空 Text 组件中的内容
self.text_box.delete("1.0", tk.END)
# 禁用编辑功能
self.text_box.config(state=tk.DISABLED)
if __name__ == "__main__":
root = tk.Tk()
root.title("能源管理系统调试")
log_win = logWin(root)
# 假设您有一个日志消息需要显示
for i in range(100):
log_win.display_log("这是一条日志信息" + str(i))
root.mainloop()
test/scripts/udpComm.py
+106
View File
@@ -0,0 +1,106 @@
import socket
import struct
import tkinter as tk
import threading
from udpmsg import *
from datetime import datetime
from tkinter import font
import threading
from disSys import *
from logWin import *
target_ip = '127.0.0.1'
target_port = 5000
def receive_messages(sock, logwin:logWin, disSysWin:disSys):
while True:
current_time = datetime.now()
formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
data, address = sock.recvfrom(4096)
headBuf = data[:6]
header = struct.unpack('<BBHH',headBuf)
start1 = data[0]
start2 = data[1]
msg_id = data[2]
msg_len = data[3]
if(start1==0x40 and start2==0x40):
if(msg_id==0x0001):
msg = msg_disHVBCmd()
msg.unpack(data)
# text_box.insert(tk.END, f"{formatted_time}->接收到来自 {address} | 高压母线配电指令:\n")
logWin.display_log(logwin,f"{formatted_time}->接收到来自 {address} | 高压母线配电指令:")
if(msg.fuelCellCircuitBreaker==0x55):
disSysWin.dict1['燃料电池断路器']='闭合'
elif(msg.fuelCellCircuitBreaker==0xAA):
disSysWin.dict1['燃料电池断路器']='断开'
if(msg.powerLithiumBatteryCircuitBreaker==0x55):
disSysWin.dict1['动力锂电池断路器']='闭合'
elif(msg.powerLithiumBatteryCircuitBreaker==0xAA):
disSysWin.dict1['动力锂电池断路器']='断开'
if(msg.propulsionMotorCircuitBreaker==0x55):
disSysWin.dict1['推进电机断路器']='闭合'
elif(msg.propulsionMotorCircuitBreaker==0xAA):
disSysWin.dict1['推进电机断路器']='断开'
if(msg.lithiumBatteryGroupInstrumentCircuitBreaker==0x55):
disSysWin.dict1['仪表锂电池断路器']='闭合'
elif(msg.lithiumBatteryGroupInstrumentCircuitBreaker==0xAA):
disSysWin.dict1['仪表锂电池断路器']='断开'
if(msg.dcDc5ModuleCircuitBreaker==0x55):
disSysWin.dict1['DC/DC5模块断路器']='闭合'
elif(msg.dcDc5ModuleCircuitBreaker==0xAA):
disSysWin.dict1['DC/DC5模块断路器']='断开'
if(msg.bowHighVoltageDistributionBoxCircuitBreaker==0x55):
disSysWin.dict1['艏部高压配电断路器']='闭合'
elif(msg.bowHighVoltageDistributionBoxCircuitBreaker==0xAA):
disSysWin.dict1['艏部高压配电断路器']='断开'
if(msg.sternFTDevice45CircuitBreaker==0x55):
disSysWin.dict1['艏部FT4/5断路器']='闭合'
elif(msg.sternFTDevice45CircuitBreaker==0xAA):
disSysWin.dict1['艏部FT4/5断路器']='断开'
if(msg.sternRudderSwitch1CircuitBreaker==0x55):
disSysWin.dict1['艉舵1/2断路器']='闭合'
elif(msg.sternRudderSwitch1CircuitBreaker==0xAA):
disSysWin.dict1['艉舵1/2断路器']='断开'
if(msg.sternRudderSwitch2CircuitBreaker==0x55):
disSysWin.dict1['艉舵3/4断路器']='闭合'
elif(msg.sternRudderSwitch2CircuitBreaker==0xAA):
disSysWin.dict1['艉舵3/4断路器']='断开'
if(msg.fbReservedCircuitBreaker==0x55):
disSysWin.dict1['FB预留断路器']='闭合'
elif(msg.fbReservedCircuitBreaker==0xAA):
disSysWin.dict1['FB预留断路器']='断开'
if(msg.tyzReservedCircuitBreaker==0x55):
disSysWin.dict1['TYZ预留断路器']='闭合'
elif(msg.tyzReservedCircuitBreaker==0xAA):
disSysWin.dict1['TYZ预留断路器']='断开'
if(msg.reservedCircuitBreaker==0x55):
disSysWin.dict1['预留断路器']='闭合'
elif(msg.reservedCircuitBreaker==0xAA):
disSysWin.dict1['预留断路器']='断开'
disSysWin.update_disp()
def send_messages(sock, logwin:logWin, disSysWin:disSys):
while True:
# 配电消息反馈
a,b,c,d = disSysWin.updata_data()
sock.sendto(a, (target_ip, target_port))
sock.sendto(b, (target_ip, target_port))
sock.sendto(c, (target_ip, target_port))
sock.sendto(d, (target_ip, target_port))
#TODO复合管控消息反馈
threading.Event().wait(1) # 每隔1秒发送一次消息