Compare commits
4 Commits
e713485d00
...
dial_gauge
Author | SHA1 | Date | |
---|---|---|---|
4925d899b4 | |||
3814d163c5 | |||
340d48876b | |||
60726d9d07 |
2
.gitignore
vendored
2
.gitignore
vendored
@ -12,3 +12,5 @@ aio/code/durable_action/__pycache__/
|
||||
aio/assets/templates/durable/
|
||||
aio/assets/templates/.__c_msg.lock
|
||||
aio/code/commons/__pycache__/
|
||||
aio/assets/templates/debug.log
|
||||
dial_gauge/results.xlsx
|
||||
|
@ -590,4 +590,14 @@ v0.2.0.5(2024/07/31)
|
||||
- 保持电流,只取最后 15s
|
||||
- 优化 ssh 输入密码的部分
|
||||
6. [t_change_ui: all the part]: 引入 commons 包,并定制了 logging 输出,后续持续优化
|
||||
7. [APIs: btn_functions.py]: 重写了告警输出函数,从日志中拿数据
|
||||
8. [APIs: aio.py]: 将日志框输出的内容,也保存至日志文件
|
||||
9. [APIs: do_brake.py]
|
||||
- 修改获取初始速度的逻辑,只获取configs文件中配置的时间内的速度
|
||||
- 新增 configs 参数 single_brake,可针对特定条件做测试
|
||||
10. [APIs: all]: 添加了 logger.setLevel(INFO),只有添加这个,单个模块内才生效
|
||||
|
||||
v0.2.0.6(2024/08/09)
|
||||
1. [t_change_ui: all files]
|
||||
- 修改了 logger 的实现
|
||||
- 尤其是 clibs.py,使用日志字典,重写了日志记录的功能
|
Binary file not shown.
@ -14,15 +14,14 @@ from commons import openapi, clibs
|
||||
from matplotlib.pyplot import rcParams, figure, subplots_adjust, close
|
||||
from matplotlib import use
|
||||
from pandas import DataFrame, read_excel
|
||||
import logging
|
||||
|
||||
with open(clibs.log_data, 'w') as _:
|
||||
with open(clibs.log_data_hmi, 'w') as _hmi, open(clibs.log_data_debug, 'w', encoding='utf-8') as _debug:
|
||||
for i in range(1, 11):
|
||||
try:
|
||||
remove(f'{clibs.log_data}.{i}')
|
||||
remove(f'{clibs.log_data_hmi}.{i}')
|
||||
except FileNotFoundError:
|
||||
pass
|
||||
logger = logging.getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
logger.info("日志文件初始化完成...")
|
||||
|
||||
use('Agg')
|
||||
@ -449,6 +448,7 @@ class App(customtkinter.CTk):
|
||||
self.textbox.tag_add(color, 'insert', 'end')
|
||||
self.textbox.tag_config(tagName=color, foreground=color)
|
||||
tab_name_cur = self.tabview.get()
|
||||
logger.info(text)
|
||||
|
||||
if tab_name == tab_name_cur:
|
||||
if wait != 0:
|
||||
|
@ -1,10 +1,8 @@
|
||||
from json import loads
|
||||
from sys import argv
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
tab_name = clibs.tab_names['at']
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
|
||||
|
||||
def trigger_estop(md, w2t):
|
||||
@ -38,12 +36,15 @@ def get_state(hr, w2t):
|
||||
|
||||
|
||||
def warning_info(hr, w2t):
|
||||
for msg in hr.c_msg:
|
||||
if 'alarm' in msg.lower():
|
||||
w2t(str(loads(msg)), tab_name=tab_name)
|
||||
for msg in hr.c_msg_xs:
|
||||
if 'alarm' in msg.lower():
|
||||
w2t(str(loads(msg)), tab_name=tab_name)
|
||||
for postfix in ['', '.2', '.3', '.4', '.5', '.6', '.7', '.8', '.9', '.10']:
|
||||
log_name = clibs.log_data_hmi + postfix
|
||||
try:
|
||||
with open(log_name, 'r', encoding='utf-8') as f_log:
|
||||
for line in f_log:
|
||||
if 'alarm' in line:
|
||||
w2t(line.strip(), tab_name=tab_name)
|
||||
except FileNotFoundError:
|
||||
pass
|
||||
|
||||
|
||||
def main(hr, md, func, w2t):
|
||||
|
@ -5,11 +5,10 @@ from paramiko import SSHClient, AutoAddPolicy
|
||||
from json import loads
|
||||
from openpyxl import load_workbook
|
||||
from pandas import DataFrame, concat
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
tab_name = clibs.tab_names['at']
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
|
||||
|
||||
def check_files(path, loadsel, data_dirs, data_files, w2t):
|
||||
@ -61,7 +60,7 @@ def gen_result_file(path, curve_data, axis, _reach, _load, _speed, count):
|
||||
_d2d_vel = {'hw_joint_vel_feedback': []}
|
||||
_d2d_trq = {'device_servo_trq_feedback': []}
|
||||
_d2d_stop = {'device_safety_estop': []}
|
||||
for data in curve_data[-240:]:
|
||||
for data in curve_data[-240:]: # 保留最后12s的数据
|
||||
dict_results = data['data']
|
||||
for item in dict_results:
|
||||
try:
|
||||
@ -85,6 +84,7 @@ def gen_result_file(path, curve_data, axis, _reach, _load, _speed, count):
|
||||
|
||||
def run_rl(path, loadsel, hr, md, config_file, result_dirs, w2t):
|
||||
_count = 0
|
||||
_total = 63
|
||||
display_pdo_params = [
|
||||
{"name": "hw_joint_vel_feedback", "channel": 0},
|
||||
{"name": "hw_joint_vel_feedback", "channel": 1},
|
||||
@ -104,6 +104,9 @@ def run_rl(path, loadsel, hr, md, config_file, result_dirs, w2t):
|
||||
ws = wb['Target']
|
||||
write_diagnosis = float(ws.cell(row=3, column=10).value)
|
||||
get_init_speed = float(ws.cell(row=4, column=10).value)
|
||||
single_brake = str(ws.cell(row=5, column=10).value)
|
||||
logger.info(f"write_diagnosis = {write_diagnosis}, get_init_speed = {get_init_speed}, single_brake = {single_brake}")
|
||||
|
||||
if ws.cell(row=1, column=1).value == 'positive':
|
||||
md.write_pon(1)
|
||||
elif ws.cell(row=1, column=1).value == 'negative':
|
||||
@ -118,7 +121,19 @@ def run_rl(path, loadsel, hr, md, config_file, result_dirs, w2t):
|
||||
_load = condition.split('_')[1].removeprefix('load')
|
||||
_speed = condition.split('_')[2].removeprefix('speed')
|
||||
|
||||
# for single condition test
|
||||
_single_axis = 0
|
||||
if single_brake != '0':
|
||||
_total = 3
|
||||
_single_axis = int(single_brake.split('-')[0])
|
||||
if _reach != single_brake.split('-')[1] or _load != single_brake.split('-')[2] or _speed != single_brake.split('-')[3]:
|
||||
continue
|
||||
|
||||
for axis in range(1, 4):
|
||||
# for single condition test
|
||||
if _single_axis != 0 and _single_axis != axis:
|
||||
continue
|
||||
|
||||
md.write_axis(axis)
|
||||
speed_max = 0
|
||||
if axis == 3 and _reach != '100':
|
||||
@ -130,7 +145,7 @@ def run_rl(path, loadsel, hr, md, config_file, result_dirs, w2t):
|
||||
_count += 1
|
||||
this_time = strftime("%Y-%m-%d %H:%M:%S", localtime(time()))
|
||||
prj_path = 'target/_build/target.prj'
|
||||
w2t(f"[{this_time} | {_count}/63] 正在执行 {axis} 轴 {condition} 的第 {count} 次制动测试...", 0, 0, 'purple', tab_name)
|
||||
w2t(f"[{this_time} | {_count}/{_total}] 正在执行 {axis} 轴 {condition} 的第 {count} 次制动测试...", 0, 0, 'purple', tab_name)
|
||||
|
||||
# 1. 关闭诊断曲线,触发软急停,并解除,目的是让可能正在运行着的机器停下来,切手动模式并下电
|
||||
md.trigger_estop()
|
||||
@ -180,13 +195,17 @@ def run_rl(path, loadsel, hr, md, config_file, result_dirs, w2t):
|
||||
w2t("20s内未收到机器人的运行信号,需要确认RL程序编写正确并正常执行...", 0, 111, 'red', tab_name)
|
||||
else:
|
||||
sleep(1)
|
||||
# 4. 打开诊断曲线,并执行采集,之后触发软急停,关闭曲线采集,找出最大速度,传递给RL程序,最后清除相关记录
|
||||
sleep(get_init_speed) # 获取实际最大速度,可通过configs.xlsx配置
|
||||
# 4. 找出最大速度,传递给RL程序,最后清除相关记录
|
||||
sleep(get_init_speed+5) # 冗余5s,指定时间后获取实际【正|负】方向的最大速度,可通过configs.xlsx配置
|
||||
clibs.execution('rl_task.stop', hr, w2t, tab_name, tasks=['brake'])
|
||||
# 找出最大速度
|
||||
_c_msg = hr.c_msg.copy()
|
||||
_number = 0
|
||||
for _msg in _c_msg:
|
||||
if _number > get_init_speed*20: # 最开始回零点的时候,二轴速度可以达到最大值,实际摆动时,某一方向可能达不到
|
||||
break
|
||||
if 'diagnosis.result' in _msg:
|
||||
_number += 1
|
||||
dict_results = loads(_msg)['data']
|
||||
for item in dict_results:
|
||||
if item.get('channel', None) == axis-1 and item.get('name', None) == 'hw_joint_vel_feedback':
|
||||
@ -195,7 +214,7 @@ def run_rl(path, loadsel, hr, md, config_file, result_dirs, w2t):
|
||||
speed_max = max(_, speed_max)
|
||||
elif ws.cell(row=1, column=1).value == 'negative':
|
||||
speed_max = min(_, speed_max)
|
||||
print(f"speed max = {speed_max}")
|
||||
logger.info(f"speed max = {speed_max}")
|
||||
speed_max = abs(speed_max)
|
||||
speed_target = float(ws.cell(row=3, column=axis+1).value) * float(_speed) / 100
|
||||
if speed_max < speed_target*0.95 or speed_max > speed_target*1.05:
|
||||
|
@ -4,10 +4,9 @@ from sys import argv
|
||||
from paramiko import SSHClient, AutoAddPolicy
|
||||
from json import loads
|
||||
from pandas import DataFrame, concat
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
tab_name = clibs.tab_names['at']
|
||||
display_pdo_params = [
|
||||
{"name": "hw_joint_vel_feedback", "channel": 0},
|
||||
@ -64,7 +63,7 @@ def data_proc_regular(path, filename, channel, scenario_time):
|
||||
lines = f_obj.readlines()
|
||||
_d2d_vel = {'hw_joint_vel_feedback': []}
|
||||
_d2d_trq = {'device_servo_trq_feedback': []}
|
||||
for line in lines:
|
||||
for line in lines[-500:]: # 保留最后25s的数据
|
||||
data = eval(line.strip())['data']
|
||||
for item in data:
|
||||
try:
|
||||
@ -168,7 +167,7 @@ def data_proc_regular(path, filename, channel, scenario_time):
|
||||
lines = f_obj.readlines()
|
||||
_d2d_vel = {'hw_joint_vel_feedback': []}
|
||||
_d2d_trq = {'device_servo_trq_feedback': []}
|
||||
for line in lines[-300:]:
|
||||
for line in lines[-300:]: # 保留最后15s的数据
|
||||
data = eval(line.strip())['data']
|
||||
for item in data:
|
||||
try:
|
||||
|
@ -4,10 +4,12 @@ from time import sleep
|
||||
from os.path import exists
|
||||
from paramiko import SSHClient, AutoAddPolicy
|
||||
from socket import setdefaulttimeout
|
||||
from logging import DEBUG, INFO, WARNING, ERROR, CRITICAL, Formatter, StreamHandler, basicConfig
|
||||
from concurrent_log_handler import ConcurrentRotatingFileHandler
|
||||
from logging import getLogger
|
||||
from logging.config import dictConfig
|
||||
import concurrent_log_handler
|
||||
|
||||
ip_addr = '192.168.0.160'
|
||||
ip_addr = '192.168.0.160' # for product
|
||||
# ip_addr = '192.168.84.129' # for test
|
||||
RADIAN = 57.3 # 180 / 3.1415926
|
||||
MAX_FRAME_SIZE = 1024
|
||||
TIMEOUT = 5
|
||||
@ -15,7 +17,8 @@ setdefaulttimeout(TIMEOUT)
|
||||
tab_names = {'dp': 'Data Process', 'at': 'Automatic Test', 'da': 'Duration Action', 'op': 'openapi'}
|
||||
# PREFIX = '' # for pyinstaller packaging
|
||||
PREFIX = '../assets/' # for source code debug
|
||||
log_data = f'{PREFIX}templates/c_msg.log'
|
||||
log_data_hmi = f'{PREFIX}templates/c_msg.log'
|
||||
log_data_debug = f'{PREFIX}templates/debug.log'
|
||||
heartbeat = f'{PREFIX}templates/heartbeat'
|
||||
durable_data_current_xlsx = f'{PREFIX}templates/durable/durable_data_current.xlsx'
|
||||
durable_data_current_max_xlsx = f'{PREFIX}templates/durable/durable_data_current_max.xlsx'
|
||||
@ -38,21 +41,80 @@ durable_data_current_max = {
|
||||
'axis6': [0 for _ in range(18)],
|
||||
}
|
||||
|
||||
fmt = Formatter('%(asctime)s # %(levelname)s-%(filename)s-%(funcName)s # %(message)s')
|
||||
# file_handler = logging.FileHandler(log_data)
|
||||
# file_handler = RotatingFileHandler(filename=log_data, backupCount=10, maxBytes=50*1024*1024, encoding='utf-8')
|
||||
file_handler = ConcurrentRotatingFileHandler(filename=log_data, backupCount=10, maxBytes=50*1024*1024, encoding='utf-8')
|
||||
file_handler.setFormatter(fmt)
|
||||
file_handler.setLevel(INFO)
|
||||
console_handler = StreamHandler()
|
||||
console_handler.setFormatter(fmt)
|
||||
console_handler.setLevel(ERROR)
|
||||
|
||||
# basicConfig(level=WARNING, # for product
|
||||
basicConfig(level=WARNING,
|
||||
datefmt='%Y-%m-%dT%H:%M:%S',
|
||||
# handlers=[file_handler]) # for product
|
||||
handlers=[file_handler, console_handler])
|
||||
# version:表示版本,该键值为从1开始的整数。该key必选,除此之外,其它key都是可选。
|
||||
# formatters:日志格式化器,其value值为一个字典,该字典的每个键值对都代表一个Formatter,键值对中,key代表Formatter ID(自定义ID),value为字典,描述如何配置相应的Formatter实例。默认格式为 ‘%(message)s’
|
||||
# filters:日志过滤器,其value值为一个字典,该字典的每个键值对都代表一个Filter,键值对中,key代表Filter ID(自定义ID),value为字典,描述如何配置相应的Filter实例。
|
||||
# handlers:日志处理器,其value值为一个字典,该字典的每个键值对都代表一个Handler,键值对中,key代表Handler ID(自定义ID),value为字典,描述如何配置相应的Handler实例,包含以下配置key:
|
||||
# class (必选):日志处理器类全称
|
||||
# level (可选):指定该日志处理器需要处理哪些级别的日志,低于该级别的日志将不被该handler处理。level可以为代表日志级别的整数或者表大写字符串,字符串日志级别和数字日志级别对应关系如下:
|
||||
# CRITICAL 50
|
||||
# ERROR 40
|
||||
# WARNING 30
|
||||
# INFO 20
|
||||
# DEBUG 10
|
||||
# NOTSET 0
|
||||
f_complex = '%(asctime)s # %(name)s-%(levelname)s-%(module)s-%(funcName)s-%(lineno)d # %(message)s'
|
||||
f_simple = '%(levelname)s-%(module)s-%(funcName)s-%(lineno)d: %(message)s'
|
||||
log_dicts = {
|
||||
'version': 1,
|
||||
'disable_existing_loggers': True,
|
||||
'formatters': {
|
||||
'standard': {
|
||||
'format': f_complex,
|
||||
'style': '%',
|
||||
'datefmt': '%Y-%m-%dT%H:%M:%S',
|
||||
},
|
||||
'test': {
|
||||
'format': f_simple,
|
||||
'style': '%',
|
||||
'datefmt': '%Y-%m-%dT%H:%M:%S',
|
||||
},
|
||||
},
|
||||
'filters': {},
|
||||
'handlers': {
|
||||
'console': {
|
||||
'level': 'DEBUG',
|
||||
'class': 'logging.StreamHandler',
|
||||
'formatter': 'test',
|
||||
},
|
||||
'hmi.log': {
|
||||
'level': 'DEBUG',
|
||||
'class': 'concurrent_log_handler.ConcurrentRotatingFileHandler',
|
||||
'filename': log_data_hmi,
|
||||
'maxBytes': 1024*1024*50,
|
||||
'backupCount': 10,
|
||||
'encoding': 'utf-8',
|
||||
'formatter': 'standard',
|
||||
},
|
||||
'debug.log': {
|
||||
'level': 'INFO',
|
||||
'class': 'logging.FileHandler',
|
||||
'filename': log_data_debug,
|
||||
'encoding': 'utf-8',
|
||||
'formatter': 'standard',
|
||||
},
|
||||
},
|
||||
'loggers': {
|
||||
'normal': {
|
||||
'handlers': ['hmi.log', 'debug.log'],
|
||||
'level': 'DEBUG',
|
||||
'propagate': False
|
||||
},
|
||||
'debug': {
|
||||
'handlers': ['console'],
|
||||
'level': 'DEBUG',
|
||||
'propagate': False
|
||||
},
|
||||
'': {
|
||||
'handlers': ['hmi.log', 'debug.log'],
|
||||
'level': 'DEBUG',
|
||||
'propagate': False
|
||||
},
|
||||
}
|
||||
}
|
||||
dictConfig(log_dicts)
|
||||
log_prod = getLogger('normal')
|
||||
log_debug = getLogger('debug')
|
||||
|
||||
|
||||
class GetThreadResult(Thread):
|
||||
|
@ -6,10 +6,10 @@ from time import time, sleep
|
||||
from pymodbus.client.tcp import ModbusTcpClient
|
||||
from pymodbus.payload import BinaryPayloadDecoder, BinaryPayloadBuilder
|
||||
from pymodbus.constants import Endian
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
|
||||
|
||||
class ModbusRequest(object):
|
||||
def __init__(self, w2t):
|
||||
@ -261,7 +261,7 @@ class HmiRequest(object):
|
||||
def msg_storage(self, response, flag=0):
|
||||
# response是解码后的字符串
|
||||
messages = self.c_msg if flag == 0 else self.c_msg_xs
|
||||
logger.warning(f"{loads(response)}")
|
||||
logger.debug(f"{loads(response)}")
|
||||
if 'move.monitor' in response:
|
||||
pass
|
||||
elif len(messages) < 10000:
|
||||
@ -502,7 +502,7 @@ class HmiRequest(object):
|
||||
|
||||
def get_from_id(self, msg_id, flag=0):
|
||||
for i in range(3):
|
||||
with open(clibs.log_data, mode='r', encoding='utf-8') as f_log:
|
||||
with open(clibs.log_data_hmi, mode='r', encoding='utf-8') as f_log:
|
||||
for line in f_log:
|
||||
if msg_id in line.strip():
|
||||
return line
|
||||
@ -510,7 +510,7 @@ class HmiRequest(object):
|
||||
else: # 尝试在上一次分割的日志中查找,只做一次
|
||||
sleep(1)
|
||||
try:
|
||||
with open(clibs.log_data+'.1', mode='r', encoding='utf-8') as f_log:
|
||||
with open(clibs.log_data_hmi+'.1', mode='r', encoding='utf-8') as f_log:
|
||||
for line in f_log:
|
||||
if msg_id in line.strip():
|
||||
return line
|
||||
@ -615,7 +615,7 @@ class HmiRequest(object):
|
||||
self.c.send(self.package(cmd))
|
||||
sleep(0.5)
|
||||
except Exception as Err:
|
||||
self.w2t(f"{cmd}\n请求发送失败...{Err}", 0, 0, 'red', tab_name=self.tab_name)
|
||||
self.w2t(f"{cmd}: 请求发送失败...{Err}", 0, 0, 'red', tab_name=self.tab_name)
|
||||
|
||||
return req['id']
|
||||
|
||||
|
@ -1,14 +1,12 @@
|
||||
# coding: utf-8
|
||||
from os.path import isfile
|
||||
from sys import argv
|
||||
from openpyxl import load_workbook
|
||||
from time import time, sleep, strftime, localtime
|
||||
from threading import Thread
|
||||
from pandas import read_csv
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
|
||||
|
||||
def check_files(path, raw_data_dirs, result_files, w2t):
|
||||
|
@ -5,10 +5,9 @@ from re import match
|
||||
from threading import Thread
|
||||
from time import sleep
|
||||
from csv import reader, writer
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
|
||||
|
||||
def w2t_local(msg, wait, w2t):
|
||||
|
@ -1,12 +1,10 @@
|
||||
# _*_ encoding:utf-8 _*_
|
||||
import pdfplumber
|
||||
from openpyxl import load_workbook
|
||||
from os import remove
|
||||
from sys import argv
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
|
||||
|
||||
def p_iso(file, p_files, ws, tmpfile):
|
||||
|
@ -2,10 +2,9 @@ from pandas import read_csv
|
||||
from csv import reader
|
||||
from sys import argv
|
||||
from openpyxl import Workbook
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
|
||||
|
||||
def find_point(bof, step, pos, data_file, flag, df, row, w2t):
|
||||
|
@ -6,10 +6,9 @@ from openpyxl import load_workbook
|
||||
from math import sqrt
|
||||
from numpy import power
|
||||
from csv import writer
|
||||
from logging import getLogger
|
||||
from commons import clibs
|
||||
|
||||
logger = getLogger(__file__)
|
||||
logger = clibs.log_prod
|
||||
tab_name = clibs.tab_names['da']
|
||||
count = 0
|
||||
display_pdo_params = [
|
||||
|
2
dial_gauge/README.md
Normal file
2
dial_gauge/README.md
Normal file
@ -0,0 +1,2 @@
|
||||
## 千分表数据自动采集
|
||||
|
6
dial_gauge/conf.ini
Normal file
6
dial_gauge/conf.ini
Normal file
@ -0,0 +1,6 @@
|
||||
[md_rtu]
|
||||
port = COM10
|
||||
|
||||
[md_tcp]
|
||||
addr = 192.168.0.160
|
||||
port = 502
|
99
dial_gauge/gauge.py
Normal file
99
dial_gauge/gauge.py
Normal file
@ -0,0 +1,99 @@
|
||||
from configparser import ConfigParser
|
||||
from pymodbus.client import ModbusSerialClient, ModbusTcpClient
|
||||
from time import sleep, strftime, localtime, time
|
||||
from openpyxl import load_workbook, Workbook
|
||||
from os import rename
|
||||
# import pymodbus
|
||||
# pymodbus.pymodbus_apply_logging_config("DEBUG")
|
||||
|
||||
|
||||
def initializations():
|
||||
try:
|
||||
now = strftime("%Y%m%d%H%M%S", localtime(time()))
|
||||
rename('results.xlsx', f'results_{now}.xlsx')
|
||||
except FileNotFoundError:
|
||||
pass
|
||||
|
||||
wb = Workbook()
|
||||
ws = wb.active
|
||||
ws.title = 'results'
|
||||
ws['A1'].value = '时间'
|
||||
ws['B1'].value = '次数'
|
||||
ws['C1'].value = '结果'
|
||||
wb.save('results.xlsx')
|
||||
wb.close()
|
||||
|
||||
|
||||
def do_connections():
|
||||
configs = ConfigParser()
|
||||
configs.read('conf.ini')
|
||||
|
||||
# ================ 配置Modbus TCP客户端 ================
|
||||
tcp_host = configs.get('md_tcp', 'addr')
|
||||
tcp_port = configs.getint('md_tcp', 'port')
|
||||
|
||||
client_tcp = ModbusTcpClient(tcp_host, tcp_port)
|
||||
if client_tcp.connect():
|
||||
print(f"Modbus TCP已连接到{tcp_host}:{tcp_port}...")
|
||||
else:
|
||||
raise Exception(f"Modbus TCP无法连接到{tcp_host}:{tcp_port}...")
|
||||
|
||||
# ================ 配置Modbus RTU客户端 ================
|
||||
rtu_port = configs.get('md_rtu', 'port')
|
||||
|
||||
client_rtu = ModbusSerialClient(
|
||||
method='rtu',
|
||||
port=rtu_port, # 根据实际情况调整端口,Windows上可能是 'COM3'
|
||||
baudrate=38400, # 根据协议设定波特率为38400
|
||||
timeout=1,
|
||||
parity='N', # 无奇偶校验
|
||||
stopbits=2, # 2个停止位
|
||||
bytesize=8 # 8个数据位
|
||||
)
|
||||
if client_rtu.connect():
|
||||
print(f"Modbus RTU已连接到系统{rtu_port}端口...")
|
||||
else:
|
||||
raise Exception(f"Modbus RTU无法连接到系统{rtu_port}端口...")
|
||||
|
||||
return client_tcp, client_rtu
|
||||
|
||||
|
||||
def get_gauge_data(client_tcp, client_rtu):
|
||||
count = 2
|
||||
client_tcp.write_register(41000, 1) # 将 act 信号置为 True
|
||||
# ================ 功能实现 ================
|
||||
while True:
|
||||
while True:
|
||||
res_tcp = client_tcp.read_holding_registers(41001, 1) # 获取 time_to_go 的值
|
||||
sleep(0.5)
|
||||
if not res_tcp.registers[0]:
|
||||
continue
|
||||
else:
|
||||
break
|
||||
try:
|
||||
res_rtu = client_rtu.read_holding_registers(0x0000, 2, slave=1)
|
||||
plus_or_minus = 1 if res_rtu.registers[0] == 0 else -1
|
||||
result = res_rtu.registers[1] * plus_or_minus / 10000
|
||||
now = strftime("%Y-%m-%d %H:%M:%S", localtime(time()))
|
||||
wb = load_workbook('results.xlsx')
|
||||
ws = wb['results']
|
||||
ws[f'A{count}'].value = now
|
||||
ws[f'B{count}'].value = count-1
|
||||
ws[f'C{count}'].value = float(result)
|
||||
wb.save('results.xlsx')
|
||||
wb.close()
|
||||
count += 1
|
||||
except:
|
||||
client_tcp.write_register(41000, 0) # 将 act 信号置为 False
|
||||
|
||||
sleep(2) #
|
||||
|
||||
|
||||
def main():
|
||||
initializations()
|
||||
client_tcp, client_rtu = do_connections()
|
||||
get_gauge_data(client_tcp, client_rtu)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
main()
|
43
dial_gauge/gauge.xml
Normal file
43
dial_gauge/gauge.xml
Normal file
@ -0,0 +1,43 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<m>
|
||||
<l>
|
||||
<c name="addr" type="2" value="41000"/>
|
||||
<c name="addr_1st" type="2" value="0"/>
|
||||
<c name="addr_2nd" type="2" value="0"/>
|
||||
<c name="bit_bias" type="2" value="0"/>
|
||||
<c name="byte_bias" type="4" value="0"/>
|
||||
<c name="description" type="10" value="pc to robot"/>
|
||||
<c name="dev_name" type="10" value="autotest"/>
|
||||
<c name="dev_type" type="10" value="MODBUS"/>
|
||||
<c name="end_addr" type="2" value="41000"/>
|
||||
<c name="function" type="10" value=""/>
|
||||
<c name="len" type="2" value="1"/>
|
||||
<c name="name" type="10" value="act"/>
|
||||
<c name="retain" type="1" value="false"/>
|
||||
<c name="rw" type="10" value="rd"/>
|
||||
<c name="type" type="10" value="bool"/>
|
||||
<c name="value"/>
|
||||
<c name="value_single" type="10" value=""/>
|
||||
<c name="bias" type="2" value="0"/>
|
||||
</l>
|
||||
<l>
|
||||
<c name="addr" type="2" value="41001"/>
|
||||
<c name="addr_1st" type="2" value="0"/>
|
||||
<c name="addr_2nd" type="2" value="0"/>
|
||||
<c name="bit_bias" type="2" value="0"/>
|
||||
<c name="byte_bias" type="4" value="0"/>
|
||||
<c name="description" type="10" value="robot to pc"/>
|
||||
<c name="dev_name" type="10" value="autotest"/>
|
||||
<c name="dev_type" type="10" value="MODBUS"/>
|
||||
<c name="end_addr" type="2" value="41001"/>
|
||||
<c name="function" type="10" value=""/>
|
||||
<c name="len" type="2" value="1"/>
|
||||
<c name="name" type="10" value="time_to_go"/>
|
||||
<c name="retain" type="1" value="false"/>
|
||||
<c name="rw" type="10" value="rdwr"/>
|
||||
<c name="type" type="10" value="bool"/>
|
||||
<c name="value"/>
|
||||
<c name="value_single" type="10" value=""/>
|
||||
<c name="bias" type="2" value="0"/>
|
||||
</l>
|
||||
</m>
|
BIN
dial_gauge/target_dial_gauge.zip
Normal file
BIN
dial_gauge/target_dial_gauge.zip
Normal file
Binary file not shown.
Reference in New Issue
Block a user