2023-12-22 22:42:24 +08:00
|
|
|
|
import time
|
|
|
|
|
|
|
|
|
|
from PyQt5.QtCore import QTimer
|
2023-12-13 22:12:50 +08:00
|
|
|
|
from PyQt5.QtWidgets import QApplication, QWidget, QPushButton, QDialog, QVBoxLayout, QCheckBox, QHBoxLayout, \
|
|
|
|
|
QProgressBar, QLabel, QMessageBox
|
|
|
|
|
|
|
|
|
|
from app.DataBase.output_pc import Output
|
|
|
|
|
|
|
|
|
|
types = {
|
|
|
|
|
'文本': 1,
|
|
|
|
|
'图片': 3,
|
|
|
|
|
'语音': 34,
|
|
|
|
|
'视频': 43,
|
|
|
|
|
'表情包': 47,
|
|
|
|
|
'拍一拍等系统消息': 10000
|
|
|
|
|
}
|
|
|
|
|
Stylesheet = """
|
|
|
|
|
QPushButton{
|
|
|
|
|
background-color: #ffffff;
|
|
|
|
|
}
|
|
|
|
|
QPushButton:hover {
|
|
|
|
|
background-color: lightgray;
|
|
|
|
|
}
|
|
|
|
|
"""
|
|
|
|
|
|
2023-12-22 22:42:24 +08:00
|
|
|
|
|
2023-12-13 22:12:50 +08:00
|
|
|
|
class ExportDialog(QDialog):
|
|
|
|
|
def __init__(self, contact=None, title="选择导出的类型", file_type="csv", parent=None):
|
|
|
|
|
super(ExportDialog, self).__init__(parent)
|
|
|
|
|
self.setStyleSheet(Stylesheet)
|
|
|
|
|
self.contact = contact
|
|
|
|
|
if file_type == 'html':
|
|
|
|
|
self.export_type = Output.HTML
|
2023-12-22 22:42:24 +08:00
|
|
|
|
self.export_choices = {"文本": True, "图片": True, "语音": False, "视频": False, "表情包": False,
|
2023-12-13 22:12:50 +08:00
|
|
|
|
'拍一拍等系统消息': True} # 定义导出的数据类型,默认全部选择
|
|
|
|
|
elif file_type == 'csv':
|
|
|
|
|
self.export_type = Output.CSV
|
|
|
|
|
self.export_choices = {"文本": True, "图片": True, "视频": True, "表情包": True} # 定义导出的数据类型,默认全部选择
|
|
|
|
|
elif file_type == 'txt':
|
|
|
|
|
self.export_type = Output.TXT
|
2023-12-22 22:42:24 +08:00
|
|
|
|
self.export_choices = {"文本": True, "图片": True, "语音": True, "视频": True,
|
|
|
|
|
"表情包": True} # 定义导出的数据类型,默认全部选择
|
2023-12-13 22:12:50 +08:00
|
|
|
|
else:
|
|
|
|
|
self.export_choices = {"文本": True, "图片": True, "视频": True, "表情包": True} # 定义导出的数据类型,默认全部选择
|
|
|
|
|
self.setWindowTitle(title)
|
|
|
|
|
layout = QVBoxLayout(self)
|
|
|
|
|
self.resize(400, 300)
|
|
|
|
|
self.worker = None # 导出线程
|
|
|
|
|
self.progress_bar = QProgressBar(self)
|
|
|
|
|
self.progress_label = QLabel(self)
|
2023-12-22 22:42:24 +08:00
|
|
|
|
self.time_label = QLabel(self)
|
2023-12-13 22:12:50 +08:00
|
|
|
|
for export_type, default_state in self.export_choices.items():
|
|
|
|
|
checkbox = QCheckBox(export_type)
|
|
|
|
|
checkbox.setChecked(default_state)
|
|
|
|
|
layout.addWidget(checkbox)
|
|
|
|
|
layout.addWidget(self.progress_bar)
|
|
|
|
|
layout.addWidget(self.progress_label)
|
2023-12-22 22:42:24 +08:00
|
|
|
|
layout.addWidget(self.time_label)
|
2023-12-13 22:40:56 +08:00
|
|
|
|
self.notice_label = QLabel(self)
|
2023-12-22 22:42:24 +08:00
|
|
|
|
self.notice_label.setText(
|
|
|
|
|
"注意:导出HTML时选择图片、视频、语音、表情包(特别是表情包)\n会导致大大影响导出速度,请合理选择导出的类型")
|
2023-12-13 22:40:56 +08:00
|
|
|
|
layout.addWidget(self.notice_label)
|
2023-12-13 22:12:50 +08:00
|
|
|
|
hlayout = QHBoxLayout(self)
|
|
|
|
|
self.export_button = QPushButton("导出")
|
|
|
|
|
self.export_button.clicked.connect(self.export_data)
|
|
|
|
|
hlayout.addWidget(self.export_button)
|
|
|
|
|
|
|
|
|
|
self.cancel_button = QPushButton("取消")
|
|
|
|
|
self.cancel_button.clicked.connect(self.reject) # 使用reject关闭对话框
|
|
|
|
|
hlayout.addWidget(self.cancel_button)
|
|
|
|
|
layout.addLayout(hlayout)
|
|
|
|
|
self.setLayout(layout)
|
2023-12-22 22:42:24 +08:00
|
|
|
|
self.timer = QTimer(self)
|
|
|
|
|
self.time = 0
|
|
|
|
|
self.total_msg_num = 100 # 总的消息个数
|
|
|
|
|
self.num = 0 # 当前完成的消息个数
|
|
|
|
|
self.timer.timeout.connect(self.update_elapsed_time)
|
2023-12-13 22:12:50 +08:00
|
|
|
|
|
|
|
|
|
def export_data(self):
|
|
|
|
|
self.export_button.setEnabled(False)
|
|
|
|
|
self.cancel_button.setEnabled(False)
|
|
|
|
|
# 在这里获取用户选择的导出数据类型
|
|
|
|
|
selected_types = {types[export_type]: checkbox.isChecked() for export_type, checkbox in
|
|
|
|
|
zip(self.export_choices.keys(), self.findChildren(QCheckBox))}
|
|
|
|
|
|
|
|
|
|
# 在这里根据用户选择的数据类型执行导出操作
|
|
|
|
|
print("选择的数据类型:", selected_types)
|
|
|
|
|
self.worker = Output(self.contact, type_=self.export_type, message_types=selected_types)
|
|
|
|
|
self.worker.progressSignal.connect(self.update_progress)
|
|
|
|
|
self.worker.okSignal.connect(self.export_finished)
|
2023-12-22 22:42:24 +08:00
|
|
|
|
self.worker.rangeSignal.connect(self.set_total_msg_num)
|
2023-12-13 22:12:50 +08:00
|
|
|
|
self.worker.start()
|
2023-12-22 22:42:24 +08:00
|
|
|
|
# 启动定时器,每1000毫秒更新一次任务进度
|
|
|
|
|
self.timer.start(1000)
|
|
|
|
|
self.start_time = time.time()
|
2023-12-13 22:12:50 +08:00
|
|
|
|
# self.accept() # 使用accept关闭对话框
|
|
|
|
|
|
2023-12-22 22:42:24 +08:00
|
|
|
|
def set_total_msg_num(self, num):
|
|
|
|
|
self.total_msg_num = num
|
|
|
|
|
|
2023-12-13 22:12:50 +08:00
|
|
|
|
def export_finished(self):
|
|
|
|
|
self.export_button.setEnabled(True)
|
|
|
|
|
self.cancel_button.setEnabled(True)
|
2023-12-22 22:42:24 +08:00
|
|
|
|
self.time = 0
|
|
|
|
|
end_time = time.time()
|
|
|
|
|
print(f'总耗时:{end_time - self.start_time}s')
|
2023-12-13 22:12:50 +08:00
|
|
|
|
reply = QMessageBox(self)
|
|
|
|
|
reply.setIcon(QMessageBox.Information)
|
|
|
|
|
reply.setWindowTitle('OK')
|
|
|
|
|
reply.setText(f"导出聊天记录成功\n在./data/目录下(跟exe文件在一起)")
|
|
|
|
|
reply.addButton("确认", QMessageBox.AcceptRole)
|
|
|
|
|
reply.addButton("取消", QMessageBox.RejectRole)
|
|
|
|
|
api = reply.exec_()
|
|
|
|
|
self.accept()
|
|
|
|
|
|
2023-12-22 22:42:24 +08:00
|
|
|
|
def update_elapsed_time(self):
|
|
|
|
|
self.time += 1
|
|
|
|
|
self.time_label.setText(f"耗时: {self.time}s")
|
|
|
|
|
|
2023-12-13 22:12:50 +08:00
|
|
|
|
def update_progress(self, progress_percentage):
|
2023-12-22 22:42:24 +08:00
|
|
|
|
self.num += 1
|
|
|
|
|
progress_percentage = int((self.num) / self.total_msg_num * 100)
|
2023-12-13 22:12:50 +08:00
|
|
|
|
self.progress_bar.setValue(progress_percentage)
|
|
|
|
|
self.progress_label.setText(f"导出进度: {progress_percentage}%")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
|
import sys
|
|
|
|
|
|
|
|
|
|
app = QApplication(sys.argv)
|
|
|
|
|
dialog = ExportDialog()
|
|
|
|
|
result = dialog.exec_() # 使用exec_()获取用户的操作结果
|
|
|
|
|
if result == QDialog.Accepted:
|
|
|
|
|
print("用户点击了导出按钮")
|
|
|
|
|
else:
|
|
|
|
|
print("用户点击了取消按钮")
|
|
|
|
|
sys.exit(app.exec_())
|