Skip to content

U
ubains-module-test
提交 c7001c0e authored 作者: 陈泽健's avatar 陈泽健
浏览文件
操作

处理read_xlsx_data函数增加sheet传参，实现测试用例中会议室列表的部分功能。

上级 2eab86e2
显示空白字符变更
内嵌 并排
正在显示 包含 143 行增加 和 196 行删除
运维集控/项目测试/运维标准版/定时任务执行.py
浏览文件 @ c7001c0e
......@@ -68,7 +68,8 @@ start_workers(3)
# 定义每天定时执行的任务
# 每天早上07:50执行后台系统设置功能测试
schedule.every().day.at("07:50").do(run_task, run_automation_test, report_title="运维系统测试报告", report_url_prefix="http://nat.ubainsyun.com:31135", ding_type="标准版巡检")
for day in ['monday', 'tuesday', 'wednesday', 'thursday', 'friday']:
schedule.every().__getattribute__(day).at("07:50").do(run_task, run_automation_test, report_title="运维系统测试报告", report_url_prefix="http://nat.ubainsyun.com:31135", ding_type="标准版巡检")
# 调试使用
#schedule.every().day.at("09:59").do(run_task, run_automation_test, report_title="运维系统脚本调试", report_url_prefix="http://nat.ubainsyun.com:31135", ding_type="标准版巡检")
......
预定系统/Base/Mqtt_Send.py
浏览文件 @ c7001c0e
......@@ -395,7 +395,7 @@ class Mqtt:
"startTime": config['startTime'],
"endTime": config['endTime'],
"companyNumber": config['companyNumber'],
"participantList": ["JiaoJiao", "JiaYu", "DuiFangZhengZaiZhangTouFa", "DuoTangMaLaBan"]
"participantList": ["JiaoJiao", "JiaYu", "DuiFangZhengZaiZhangTouFa", "DuoTangMaLaBan", "DaLi", "500mlLingDu", "tt.", "wilbur"]
}]
})
......
预定系统/Base/base.py
浏览文件 @ c7001c0e
......@@ -461,26 +461,39 @@ def read_csv_data(csv_file_path):
# 读取测试用例xlsx文件中的JSON数据进行数据驱动函数
import openpyxl
def read_xlsx_data(xlsx_file_path):
def read_xlsx_data(xlsx_file_path, sheet_name=None):
"""
读取XLSX文件中的数据，并将其转换为一个包含字典的列表，每个字典代表一行测试用例数据。
参数:
xlsx_file_path (str): XLSX文件的路径。
sheet_name (str, optional): 工作表的名称。如果未指定，则使用活动工作表。
返回:
list: 包含字典的列表，每个字典包含测试用例的名称和参数。
"""
try:
# 打开XLSX文件
workbook = openpyxl.load_workbook(xlsx_file_path)
# 假设数据在第一个工作表中
except FileNotFoundError:
raise FileNotFoundError(f"文件未找到: {xlsx_file_path}")
except Exception as e:
raise Exception(f"无法打开文件: {e}")
# 选择工作表
if sheet_name:
try:
sheet = workbook[sheet_name]
except KeyError:
raise KeyError(f"工作表未找到: {sheet_name}")
else:
sheet = workbook.active
# 读取表头，从第三行开始
headers = [cell.value for cell in sheet[3]]
# 打印表头列名
# print(f"表头列名: {headers}")
INFO(f"表头列名: {headers}")
# 找到表头中名为 'JSON' 的列索引
try:
......@@ -490,21 +503,23 @@ def read_xlsx_data(xlsx_file_path):
ddt_cases = []
# 遍历XLSX文件中的每一行数据，从第四行开始
for row in sheet.iter_rows(min_row=4, values_only=True):
for row_num, row in enumerate(sheet.iter_rows(min_row=4, values_only=True), start=4):
# 获取 JSON 列的数据
json_data = row[json_index]
# 打印 JSON 数据以进行调试
# print(f"JSON 数据: {json_data}")
INFO(f"行 {row_num} 的 JSON 数据: {json_data}")
# 检查 JSON 数据是否为空
if json_data is None or json_data.strip() == "":
INFO(f"跳过行 {row_num}，JSON 数据为空")
continue
# 解析 JSON 字符串
try:
if json_data:
parsed_json = json.loads(json_data)
else:
raise ValueError("JSON 数据为空")
except json.JSONDecodeError:
raise ValueError(f"无法解析 JSON 数据: {json_data}")
raise ValueError(f"行 {row_num} 的 JSON 数据无法解析: {json_data}")
# 将解析后的 JSON 数据添加到列表中
ddt_cases.append(parsed_json)
......@@ -514,6 +529,7 @@ def read_xlsx_data(xlsx_file_path):
# 返回包含所有测试用例数据的列表
return ddt_cases
# 获取当前进程的 CPU 占用率函数
def get_cpu_usage(interval=1):
"""
......@@ -1349,60 +1365,6 @@ def kill_ngrok():
# ngrok_path = r'D:\GithubData\自动化\ubains-module-test\预定系统\ngrok\ngrok-调试主机\ngrok.exe'
# start_ngrok(ngrok_path, ngrok_config_path)
# 读取XLSX文件JSON数据函数
def read_xlsx_data(xlsx_file_path):
"""
读取XLSX文件中的数据，并将其转换为一个包含字典的列表，每个字典代表一行测试用例数据。
参数:
xlsx_file_path (str): XLSX文件的路径。
返回:
list: 包含字典的列表，每个字典包含测试用例的名称和参数。
"""
# 打开XLSX文件
workbook = openpyxl.load_workbook(xlsx_file_path)
# 假设数据在第一个工作表中
sheet = workbook.active
# 读取表头，从第三行开始
headers = [cell.value for cell in sheet[3]]
# 打印表头列名
# print(f"表头列名: {headers}")
# 找到表头中名为 'JSON' 的列索引
try:
json_index = headers.index('JSON')
except ValueError as e:
raise ValueError(f"表头中没有找到所需的列: {e}")
ddt_cases = []
# 遍历XLSX文件中的每一行数据，从第四行开始
for row in sheet.iter_rows(min_row=4, values_only=True):
# 获取 JSON 列的数据
json_data = row[json_index]
# 打印 JSON 数据以进行调试
# print(f"JSON 数据: {json_data}")
# 解析 JSON 字符串
try:
if json_data:
parsed_json = json.loads(json_data)
else:
raise ValueError("JSON 数据为空")
except json.JSONDecodeError:
raise ValueError(f"无法解析 JSON 数据: {json_data}")
# 将解析后的 JSON 数据添加到列表中
ddt_cases.append(parsed_json)
# 日志记录：XLSX文件已读取
INFO("XLSX文件已读取")
# 返回包含所有测试用例数据的列表
return ddt_cases
# 字符串转换枚举类型函数
def get_by_enum(type_str):
"""
......
预定系统/README.md
浏览文件 @ c7001c0e
......@@ -243,3 +243,5 @@
- Base函数库中的函数缩略补充函数使用说明，增加相关注释，删除无用函数。
64. 2025-03-07
- 删除中控屏操作的多余截屏函数调用。处理get_screenshot_with_retry函数的目录构建传参问题。
65. 2025-03-1-
- 处理read_xlsx_data函数增加sheet传参，实现测试用例中会议室列表的部分功能。
\ No newline at end of file
预定系统/cases/会议室列表/__st__.py 0 → 100644
浏览文件 @ c7001c0e
import sys
import os
from time import sleep
# 获取当前脚本的绝对路径
current_dir = os.path.dirname(os.path.abspath(__file__))
# 构建预定系统的绝对路径
预定系统_path = os.path.abspath(os.path.join(current_dir, '..','..'))
# 添加路径
sys.path.append(预定系统_path)
# 导入模块
from 预定系统.Base.base import *
def suite_setup():
STEP(1, "初始化浏览器")
# 初始化浏览器与系统地址
browser_init("标准版预定系统")
wd = GSTORE['wd']
admin_login("admin@Test", "Ubains@4321")
sleep(2)
safe_click((By.CSS_SELECTOR, ".el-collapse-item__arrow.el-icon-arrow-right"), wd)
sleep(2)
def suite_teardown():
browser_quit()
\ No newline at end of file
预定系统/cases/会议室列表/会议室列表功能测试.py 0 → 100644
浏览文件 @ c7001c0e
import sys
import os
# 获取当前脚本的绝对路径
current_dir = os.path.dirname(os.path.abspath(__file__))
# 构建预定系统的绝对路径
预定系统_path = os.path.abspath(os.path.join(current_dir, '..','..','..'))
# 添加路径
sys.path.append(预定系统_path)
# 导入模块
from 预定系统.Base.base import *
# 获取当前脚本所在的目录
current_dir = os.path.dirname(os.path.abspath(__file__))
# 构建XLSX文件的绝对路径
xlsx_file_path = os.path.join(current_dir, '../../测试数据/会议室列表/会议预定测试用例.xlsx')
class MeetingList_000x:
tags = ['新-会议室列表']
"""
执行指令是：
1.cd 预定系统
2.hytest --report_title 账号密码登录测试报告 --report_url_prefix http://nat.ubainsyun.com:31133 --tag 新-会议室列表
"""
def teststeps(self):
wd = GSTORE['wd']
ddt_cases = read_xlsx_data(xlsx_file_path,"会议室列表")
# 遍历 ddt_cases 并获取每一个 JSON 对象
for case in ddt_cases:
for step in case:
print(f"当前步骤: {step}")
if "MeetingRoomToken" in step.get("page"):
# 先赋值
locator_type = get_by_enum(step.get('locator_type'))
locator_value = step.get('locator_value')
element_type = step.get('element_type')
element_value = step.get('element_value')
expented_result = step.get('expented_result')
if element_type == "input":
# 点击展开筛选界面
STEP(1, "搜索会议室")
safe_send_keys((locator_type, locator_value), element_value, wd)
send_keyboard((locator_type, locator_value), wd)
sleep(2)
# 点击【查询】按钮
safe_click((By.XPATH, "//span[contains(text(),'查询')]"), wd)
sleep(1)
elif element_type == "click":
# 点击会议室，查看提示信息
STEP(2, "点击【会议预约】")
safe_click((locator_type, locator_value), wd)
sleep(2)
# 判断是否为已授权的会议室，如果是，则点击会议预定判断是否进入会议预定界面，否则，点击会议预定，查看提示信息
if "会议" in expented_result:
notify_text = elment_get_text((By.XPATH, "//div[@class='reserve_Title']"), wd)
else:
notify_text = get_notify_text(wd, (By.XPATH, "//p[@class='el-message__content']"),
"MeetingList", "RoomToken", f"未授权会议室点击【会议预定】")
INFO(f"提示信息为：{notify_text}")
# 判断提示信息是否正确
sleep(1)
CHECK_POINT("提示信息是否正确", expented_result in notify_text)
\ No newline at end of file
预定系统/cases/登录模块/新-账号密码登录测试.py
浏览文件 @ c7001c0e
......@@ -13,8 +13,8 @@ from 预定系统.Base.base import *
# 获取当前脚本所在的目录
current_dir = os.path.dirname(os.path.abspath(__file__))
# 构建CSV文件的绝对路径
csv_file_path = os.path.join(current_dir, '../../测试数据/登录模块/会议预定测试用例.xlsx')
# 构建xlsx文件的绝对路径
xlsx_file_path = os.path.join(current_dir, '../../测试数据/登录模块/会议预定测试用例.xlsx')
class Login_00x:
tags = ['新-登录测试']
......@@ -30,7 +30,7 @@ class Login_00x:
本函数根据参数输入账号、密码和验证码，并检查登录后的提示信息是否与预期相符。
"""
wd = GSTORE['wd']
ddt_cases = read_xlsx_data(csv_file_path)
ddt_cases = read_xlsx_data(xlsx_file_path,"登录页面")
# 遍历 ddt_cases 并获取每一个 JSON 对象
for case in ddt_cases:
......
预定系统/测试数据/MQTT模块/富创项目/富创项目_会议修改推送.csv
浏览文件 @ c7001c0e
topic,action,thirdPartyMeetingId,thirdPartyRoomId,conferenceName,messageName,startTime,endTime,companyNumber
/meeting/message/sync,mod,6565416702283087871,1,表处办公室1号会议室,富创预约1,2025-03-06 09:10:00.0,2025-03-06 09:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087872,1,表处办公室1号会议室,富创预约2,2025-03-06 10:10:00.0,2025-03-06 10:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087873,1,表处办公室1号会议室,富创预约3,2025-03-06 11:10:00.0,2025-03-06 11:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087874,1,表处办公室1号会议室,富创预约4,2025-03-06 12:10:00.0,2025-03-06 12:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087875,1,表处办公室1号会议室,富创预约5,2025-03-06 13:10:00.0,2025-03-06 13:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087876,1,表处办公室1号会议室,富创预约6,2025-03-06 14:10:00.0,2025-03-06 14:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087877,1,表处办公室1号会议室,富创预约7,2025-03-06 15:31:00.0,2025-03-06 15:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087878,1,表处办公室1号会议室,富创预约8,2025-03-06 16:10:00.0,2025-03-06 16:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087879,1,表处办公室1号会议室,富创预约9,2025-03-06 17:10:00.0,2025-03-06 17:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087880,1,表处办公室1号会议室,富创预约10,2025-03-06 18:10:00.0,2025-03-06 18:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087881,1,表处办公室1号会议室,富创预约11,2025-03-06 18:50:00.0,2025-03-06 19:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087882,1,表处办公室1号会议室,富创预约12,2025-03-06 20:10:00.0,2025-03-06 20:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087883,1,表处办公室1号会议室,富创预约13,2025-03-06 21:10:00.0,2025-03-06 21:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087884,1,表处办公室1号会议室,富创预约14,2025-03-06 22:10:00.0,2025-03-06 22:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087885,1,表处办公室1号会议室,富创预约15,2025-03-06 23:10:00.0,2025-03-06 23:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087886,1,表处办公室1号会议室,富创预约16,2025-03-07 00:10:00.0,2025-03-07 00:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087887,1,表处办公室1号会议室,富创预约17,2025-03-07 01:10:00.0,2025-03-07 01:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087888,1,表处办公室1号会议室,富创预约18,2025-03-07 02:10:00.0,2025-03-07 02:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087889,1,表处办公室1号会议室,富创预约19,2025-03-07 03:10:00.0,2025-03-07 03:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087890,1,表处办公室1号会议室,富创预约20,2025-03-07 04:10:00.0,2025-03-07 04:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087891,1,表处办公室1号会议室,富创预约21,2025-03-07 05:10:00.0,2025-03-07 05:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087892,1,表处办公室1号会议室,富创预约22,2025-03-07 06:10:00.0,2025-03-07 06:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087893,1,表处办公室1号会议室,富创预约23,2025-03-07 07:10:00.0,2025-03-07 07:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087894,1,表处办公室1号会议室,富创预约24,2025-03-07 08:10:00.0,2025-03-07 08:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087895,1,表处办公室1号会议室,富创预约25,2025-03-07 09:10:00.0,2025-03-07 09:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087896,1,表处办公室1号会议室,富创预约26,2025-03-07 10:10:00.0,2025-03-07 10:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087897,1,表处办公室1号会议室,富创预约27,2025-03-07 11:10:00.0,2025-03-07 11:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087898,1,表处办公室1号会议室,富创预约28,2025-03-07 12:10:00.0,2025-03-07 12:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087899,1,表处办公室1号会议室,富创预约29,2025-03-07 13:10:00.0,2025-03-07 13:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087900,1,表处办公室1号会议室,富创预约30,2025-03-07 14:10:00.0,2025-03-07 14:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087901,1,表处办公室1号会议室,富创预约31,2025-03-07 15:10:00.0,2025-03-07 15:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087902,1,表处办公室1号会议室,富创预约32,2025-03-07 16:10:00.0,2025-03-07 16:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087903,1,表处办公室1号会议室,富创预约33,2025-03-07 17:10:00.0,2025-03-07 17:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087904,1,表处办公室1号会议室,富创预约34,2025-03-07 18:10:00.0,2025-03-07 18:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087905,1,表处办公室1号会议室,富创预约35,2025-03-07 19:10:00.0,2025-03-07 19:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087906,1,表处办公室1号会议室,富创预约36,2025-03-07 20:10:00.0,2025-03-07 20:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087907,1,表处办公室1号会议室,富创预约37,2025-03-07 21:10:00.0,2025-03-07 21:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087908,1,表处办公室1号会议室,富创预约38,2025-03-07 22:10:00.0,2025-03-07 22:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,mod,6565416702283087909,1,表处办公室1号会议室,富创预约39,2025-03-07 23:10:00.0,2025-03-07 23:40:00.0,CN-E8V-UBAINS
\ No newline at end of file
/meeting/message/sync,mod,7565416702283087898,1,表处办公室1号会议室,富创预约,2025-03-09 16:31:00.0,2025-03-09 16:43:00.0,CN-JHP-UBAINS
\ No newline at end of file
预定系统/测试数据/MQTT模块/富创项目/富创项目_会议删除推送.csv
浏览文件 @ c7001c0e
topic,action,thirdPartyMeetingId,thirdPartyRoomId,conferenceName,messageName,startTime,endTime,companyNumber
/meeting/message/sync,del,6565416702283087871,1,表处办公室1号会议室,富创预约1,2025-03-06 09:10:00.0,2025-03-06 09:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087872,1,表处办公室1号会议室,富创预约2,2025-03-06 10:10:00.0,2025-03-06 10:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087873,1,表处办公室1号会议室,富创预约3,2025-03-06 11:10:00.0,2025-03-06 11:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087874,1,表处办公室1号会议室,富创预约4,2025-03-06 12:10:00.0,2025-03-06 12:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087875,1,表处办公室1号会议室,富创预约5,2025-03-06 13:10:00.0,2025-03-06 13:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087876,1,表处办公室1号会议室,富创预约6,2025-03-06 14:10:00.0,2025-03-06 14:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087877,1,表处办公室1号会议室,富创预约7,2025-03-06 15:10:00.0,2025-03-06 15:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087878,1,表处办公室1号会议室,富创预约8,2025-03-06 16:10:00.0,2025-03-06 16:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087879,1,表处办公室1号会议室,富创预约9,2025-03-06 17:10:00.0,2025-03-06 17:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087880,1,表处办公室1号会议室,富创预约10,2025-03-06 18:10:00.0,2025-03-06 18:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087881,1,表处办公室1号会议室,富创预约11,2025-03-06 19:10:00.0,2025-03-06 19:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087882,1,表处办公室1号会议室,富创预约12,2025-03-06 20:10:00.0,2025-03-06 20:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087883,1,表处办公室1号会议室,富创预约13,2025-03-06 21:10:00.0,2025-03-06 21:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087884,1,表处办公室1号会议室,富创预约14,2025-03-06 22:10:00.0,2025-03-06 22:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087885,1,表处办公室1号会议室,富创预约15,2025-03-06 23:10:00.0,2025-03-06 23:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087886,1,表处办公室1号会议室,富创预约16,2025-03-07 00:10:00.0,2025-03-07 00:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087887,1,表处办公室1号会议室,富创预约17,2025-03-07 01:10:00.0,2025-03-07 01:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087888,1,表处办公室1号会议室,富创预约18,2025-03-07 02:10:00.0,2025-03-07 02:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087889,1,表处办公室1号会议室,富创预约19,2025-03-07 03:10:00.0,2025-03-07 03:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087890,1,表处办公室1号会议室,富创预约20,2025-03-07 04:10:00.0,2025-03-07 04:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087891,1,表处办公室1号会议室,富创预约21,2025-03-07 05:10:00.0,2025-03-07 05:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087892,1,表处办公室1号会议室,富创预约22,2025-03-07 06:10:00.0,2025-03-07 06:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087893,1,表处办公室1号会议室,富创预约23,2025-03-07 07:10:00.0,2025-03-07 07:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087894,1,表处办公室1号会议室,富创预约24,2025-03-07 08:10:00.0,2025-03-07 08:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087895,1,表处办公室1号会议室,富创预约25,2025-03-07 09:10:00.0,2025-03-07 09:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087896,1,表处办公室1号会议室,富创预约26,2025-03-07 10:10:00.0,2025-03-07 10:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087897,1,表处办公室1号会议室,富创预约27,2025-03-07 11:10:00.0,2025-03-07 11:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087898,1,表处办公室1号会议室,富创预约28,2025-03-07 12:10:00.0,2025-03-07 12:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087899,1,表处办公室1号会议室,富创预约29,2025-03-07 13:10:00.0,2025-03-07 13:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087900,1,表处办公室1号会议室,富创预约30,2025-03-07 14:10:00.0,2025-03-07 14:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087901,1,表处办公室1号会议室,富创预约31,2025-03-07 15:10:00.0,2025-03-07 15:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087902,1,表处办公室1号会议室,富创预约32,2025-03-07 16:10:00.0,2025-03-07 16:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087903,1,表处办公室1号会议室,富创预约33,2025-03-07 17:10:00.0,2025-03-07 17:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087904,1,表处办公室1号会议室,富创预约34,2025-03-07 18:10:00.0,2025-03-07 18:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087905,1,表处办公室1号会议室,富创预约35,2025-03-07 19:10:00.0,2025-03-07 19:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087906,1,表处办公室1号会议室,富创预约36,2025-03-07 20:10:00.0,2025-03-07 20:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087907,1,表处办公室1号会议室,富创预约37,2025-03-07 21:10:00.0,2025-03-07 21:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087908,1,表处办公室1号会议室,富创预约38,2025-03-07 22:10:00.0,2025-03-07 22:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,del,6565416702283087909,1,表处办公室1号会议室,富创预约39,2025-03-07 23:10:00.0,2025-03-07 23:30:00.0,CN-E8V-UBAINS
\ No newline at end of file
/meeting/message/sync,del,7565416702283087898,1,表处办公室1号会议室,富创预约,2025-03-09 16:31:00.0,2025-03-09 16:43:00.0,CN-JHP-UBAINS
\ No newline at end of file
预定系统/测试数据/MQTT模块/富创项目/富创项目_会议预约推送.csv
浏览文件 @ c7001c0e
topic,action,thirdPartyMeetingId,thirdPartyRoomId,conferenceName,messageName,startTime,endTime,companyNumber
/meeting/message/sync,add,6565416702283087871,1,表处办公室1号会议室,富创预约1,2025-03-06 09:10:00.0,2025-03-06 09:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087872,1,表处办公室1号会议室,富创预约2,2025-03-06 10:10:00.0,2025-03-06 10:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087873,1,表处办公室1号会议室,富创预约3,2025-03-06 11:10:00.0,2025-03-06 11:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087874,1,表处办公室1号会议室,富创预约4,2025-03-06 12:10:00.0,2025-03-06 12:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087875,1,表处办公室1号会议室,富创预约5,2025-03-06 13:10:00.0,2025-03-06 13:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087876,1,表处办公室1号会议室,富创预约6,2025-03-06 14:10:00.0,2025-03-06 14:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087877,1,表处办公室1号会议室,富创预约7,2025-03-06 15:10:00.0,2025-03-06 15:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087878,1,表处办公室1号会议室,富创预约8,2025-03-06 16:10:00.0,2025-03-06 16:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087879,1,表处办公室1号会议室,富创预约9,2025-03-06 17:10:00.0,2025-03-06 17:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087880,1,表处办公室1号会议室,富创预约10,2025-03-06 18:10:00.0,2025-03-06 18:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087881,1,表处办公室1号会议室,富创预约11,2025-03-06 19:10:00.0,2025-03-06 19:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087882,1,表处办公室1号会议室,富创预约12,2025-03-06 20:10:00.0,2025-03-06 20:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087883,1,表处办公室1号会议室,富创预约13,2025-03-06 21:10:00.0,2025-03-06 21:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087884,1,表处办公室1号会议室,富创预约14,2025-03-06 22:10:00.0,2025-03-06 22:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087885,1,表处办公室1号会议室,富创预约15,2025-03-06 23:10:00.0,2025-03-06 23:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087885,1,表处办公室1号会议室,富创预约15,2025-03-06 23:35:00.0,2025-03-06 23:40:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087886,1,表处办公室1号会议室,富创预约16,2025-03-06 23:45:00.0,2025-03-06 23:55:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087886,1,表处办公室1号会议室,富创预约16,2025-03-07 00:10:00.0,2025-03-07 00:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087887,1,表处办公室1号会议室,富创预约17,2025-03-07 01:10:00.0,2025-03-07 01:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087888,1,表处办公室1号会议室,富创预约18,2025-03-07 02:10:00.0,2025-03-07 02:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087889,1,表处办公室1号会议室,富创预约19,2025-03-07 03:10:00.0,2025-03-07 03:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087890,1,表处办公室1号会议室,富创预约20,2025-03-07 04:10:00.0,2025-03-07 04:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087891,1,表处办公室1号会议室,富创预约21,2025-03-07 05:10:00.0,2025-03-07 05:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087892,1,表处办公室1号会议室,富创预约22,2025-03-07 06:10:00.0,2025-03-07 06:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087893,1,表处办公室1号会议室,富创预约23,2025-03-07 07:10:00.0,2025-03-07 07:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087894,1,表处办公室1号会议室,富创预约24,2025-03-07 08:10:00.0,2025-03-07 08:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087895,1,表处办公室1号会议室,富创预约25,2025-03-07 09:10:00.0,2025-03-07 09:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087896,1,表处办公室1号会议室,富创预约26,2025-03-07 10:10:00.0,2025-03-07 10:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087897,1,表处办公室1号会议室,富创预约27,2025-03-07 11:10:00.0,2025-03-07 11:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087898,1,表处办公室1号会议室,富创预约28,2025-03-07 12:10:00.0,2025-03-07 12:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087899,1,表处办公室1号会议室,富创预约29,2025-03-07 13:10:00.0,2025-03-07 13:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087900,1,表处办公室1号会议室,富创预约30,2025-03-07 14:10:00.0,2025-03-07 14:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087901,1,表处办公室1号会议室,富创预约31,2025-03-07 15:10:00.0,2025-03-07 15:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087902,1,表处办公室1号会议室,富创预约32,2025-03-07 16:10:00.0,2025-03-07 16:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087903,1,表处办公室1号会议室,富创预约33,2025-03-07 17:10:00.0,2025-03-07 17:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087904,1,表处办公室1号会议室,富创预约34,2025-03-07 18:10:00.0,2025-03-07 18:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087905,1,表处办公室1号会议室,富创预约35,2025-03-07 19:10:00.0,2025-03-07 19:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087906,1,表处办公室1号会议室,富创预约36,2025-03-07 20:10:00.0,2025-03-07 20:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087907,1,表处办公室1号会议室,富创预约37,2025-03-07 21:10:00.0,2025-03-07 21:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087908,1,表处办公室1号会议室,富创预约38,2025-03-07 22:10:00.0,2025-03-07 22:30:00.0,CN-E8V-UBAINS
/meeting/message/sync,add,6565416702283087909,1,表处办公室1号会议室,富创预约39,2025-03-07 23:10:00.0,2025-03-07 23:30:00.0,CN-E8V-UBAINS
\ No newline at end of file
/meeting/message/sync,add,7565416702283087898,1,表处办公室1号会议室,富创预约,2025-03-09 16:31:00.0,2025-03-09 16:43:00.0,CN-JHP-UBAINS
\ No newline at end of file
预定系统/项目定制/富创项目24-12-25/MQTT会议推送.py
浏览文件 @ c7001c0e
......@@ -5,17 +5,17 @@ from 预定系统.Base.base import *
current_dir = os.path.dirname(os.path.abspath(__file__))
# 构建会议预约CSV文件的绝对路径
# csv_file_path = os.path.join(current_dir, '../../测试数据/MQTT模块/富创项目/富创项目_会议预约推送.csv')
csv_file_path = os.path.join(current_dir, '../../测试数据/MQTT模块/富创项目/富创项目_会议预约推送.csv')
# 构建会议修改CSV文件的绝对路径
csv_file_path = os.path.join(current_dir, '../../测试数据/MQTT模块/富创项目/富创项目_会议修改推送.csv')
# 构建会议删除CSV文件的绝对路径
# csv_file_path = os.path.join(current_dir, '../../测试数据/MQTT模块/富创项目/富创项目_会议修改推送.csv')
# # 构建会议删除CSV文件的绝对路径
# csv_file_path = os.path.join(current_dir, '../../测试数据/MQTT模块/富创项目/富创项目_会议删除推送.csv')
if __name__ == "__main__":
# 读取配置文件
configs = Mqtt.read_config_from_csv(csv_file_path)
broker_address = "192.168.1.193"
broker_address = "192.168.5.218"
port = 1883
num_repeats = 1000 # 重复执行的次数
interval_between_repeats = 0.2 # 每次重复之间的间隔时间（秒）
......
预定系统/项目定制/富创项目24-12-25/MQTT消息监听.py
浏览文件 @ c7001c0e
......@@ -8,7 +8,7 @@ logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(
def on_connect(client, userdata, flags, rc):
logging.info("已连接到MQTT服务器")
# 订阅多个主题
topics = ["/androidPanel/", "/meeting/sign/result", "/meeting/message/sync", "/uams/android/broadcast"]
topics = ["/androidPanel/", "/meeting/sign/result", "/meeting/message/sync", "/uams/android/broadcast", "/meeting/message/igzk5herl6mntnui3grjt04v3vq6m7z5/"]
for t in topics:
client.subscribe(t)
......@@ -16,8 +16,10 @@ def on_message(client, userdata, msg):
logging.info(f"接收到消息: 主题={msg.topic}, 消息体={msg.payload.decode()}")
if __name__ == "__main__":
broker_address = "192.168.1.193"
broker_address = "192.168.5.218"
port = 1883
username = "mqtt@cmdb"
password = "mqtt@webpassw0RD"
# 创建 MQTT 客户端实例
mqtt_client = mqtt.Client()
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论