【自动化办公】批量一键移除PDF电子签名+支持windows系统

class PdfSignatureRemovalThread(QThread):
"""PDF签名移除处理线程"""

# 信号定义
log_signal = Signal(str, str) # 日志信号(消息, 级别)
progress_signal = Signal(int, int) # 进度信号(当前, 总数)
finished_signal = Signal(bool, str) # 完成信号(成功, 消息)

def __init__(self, pdf_directory):
super().__init__()
self.pdf_directory = pdf_directory
self.is_running = True
self.user_api = UserAPI()

def run(self):
"""执行PDF签名移除任务"""
try:
self.log_signal.emit("开始扫描PDF文件...", "INFO")

# 获取目录下所有PDF文件
pdf_files = []
for root, dirs, files in os.walk(self.pdf_directory):
# 跳过out.error目录
if "out" in dirs:
dirs.remove("out")
if "error" in dirs:
dirs.remove("error")
for file in files:
if file.lower().endswith('.pdf'):
pdf_files.append(os.path.join(root, file))

if not pdf_files:
self.log_signal.emit("未找到PDF文件", "WARNING")
self.finished_signal.emit(False, "未找到PDF文件")
return

# 试用用户
if global_state.get_user_info() is None:
self.log_signal.emit("未登录，请返回主界面登录", "ERROR")
self.finished_signal.emit(False, "未登录，请返回主界面登录")
return

if global_state.get_user_type() == 0 and len(pdf_files) > 10:
self.log_signal.emit("试用用户最多10条", "ERROR")
self.finished_signal.emit(False, "试用用户最多10条")
return

## 消耗 次数
res = self.user_api.get_and_decr()
if res.get('code') != 0:
self.log_signal.emit(res.get('msg'), "ERROR")
self.finished_signal.emit(False, res.get('msg'))
return

if len(pdf_files) > 500:
self.log_signal.emit("数据量大于500条，请分批执行", "ERROR")
self.finished_signal.emit(False, "数据量大于500条，请分批执行")
return

self.log_signal.emit(f"找到 {len(pdf_files)} 个PDF文件", "INFO")


## 创建out目录
out_directory, error_directory = RemovePdfService.mk_out_dir(self.pdf_directory)

# 处理每个PDF文件
success_count = 0
for i, pdf_file in enumerate(pdf_files):
if not self.is_running:
break

self.progress_signal.emit(i + 1, len(pdf_files))
file_name, file_ext = os.path.splitext(os.path.basename(pdf_file))
output_file = os.path.join(out_directory, file_name + "." + file_ext)
filename = os.path.basename(pdf_file)
try:
## 开始处理 移除签名
RemovePdfService.do_handle(pdf_file, output_file)
success_count += 1
self.log_signal.emit(f"处理完成: {filename}", "SUCCESS")
except Exception as e:
self.log_signal.emit(f"处理失败 {os.path.basename(pdf_file)}: {str(e)}", "ERROR")
shutil.copy2(pdf_file, error_directory)

if self.is_running:
self.log_signal.emit(f"批量处理完成，成功处理 {success_count}/{len(pdf_files)} 个文件", "SUCCESS")
self.finished_signal.emit(True, f"成功处理 {success_count} 个文件")
else:
self.log_signal.emit("任务已取消", "WARNING")
self.finished_signal.emit(False, "任务已取消")

except Exception as e:
self.log_signal.emit(f"处理过程中发生错误: {str(e)}", "ERROR")
self.finished_signal.emit(False, f"处理失败: {str(e)}")

def stop(self):
"""停止处理"""
self.is_running = False