main_gui.py 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793
  1. #!/usr/bin/env python
  2. # -*- encoding: utf-8 -*-
  3. '''
  4. @Contact : liuyuqi.gov@msn.cn
  5. @Time : 2023/04/27 02:55:59
  6. @License : Copyright © 2017-2022 liuyuqi. All Rights Reserved.
  7. @Desc : repo_sync GUI入口
  8. 打包说明:
  9. 使用PyInstaller可以将此应用打包为单个可执行文件:
  10. 1. 安装必要的包:
  11. pip install pyinstaller
  12. pip install -e . # 以开发模式安装当前包
  13. 2. 打包命令:
  14. pyinstaller --onefile --windowed --icon=icon.ico --add-data "repo_sync/config.yml;repo_sync" main_gui.py
  15. (如果有图标文件,可以通过--icon参数指定)
  16. 3. 打包后的可执行文件将位于dist目录中
  17. 注意:确保在打包前先安装repo_sync包,这样PyInstaller才能正确找到所有依赖。
  18. '''
  19. import sys
  20. import os
  21. import threading
  22. import subprocess
  23. import yaml
  24. try:
  25. from PyQt5.QtWidgets import (
  26. QApplication, QTabWidget, QWidget, QVBoxLayout, QHBoxLayout, QLabel,
  27. QRadioButton, QPushButton, QButtonGroup, QGroupBox, QMessageBox,
  28. QLineEdit, QScrollArea, QFileDialog, QFormLayout, QCheckBox, QTextEdit,
  29. QComboBox, QDialog, QDialogButtonBox, QGridLayout, QToolButton, QListWidget, QListWidgetItem
  30. )
  31. from PyQt5.QtCore import Qt, pyqtSignal, QObject
  32. HAS_QT = True
  33. except ImportError:
  34. HAS_QT = False
  35. print("PyQt5 not installed, GUI mode not available")
  36. # 直接导入repo_sync模块
  37. sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
  38. try:
  39. from repo_sync.repo_sync import RepoSync
  40. from repo_sync.version import __version__
  41. from repo_sync.utils.config_reader import ConfigReader
  42. except ImportError:
  43. print("无法导入repo_sync模块,尝试直接导入...")
  44. try:
  45. from repo_sync import RepoSync
  46. from version import __version__
  47. from utils.config_reader import ConfigReader
  48. except ImportError:
  49. print("导入repo_sync模块失败,请确保repo_sync已正确安装")
  50. __version__ = "未知"
  51. # 创建一个空的RepoSync类作为替代
  52. class RepoSync:
  53. def __init__(self, params):
  54. self.params = params
  55. def run(self):
  56. print("RepoSync模块未找到,无法执行操作")
  57. # 确保config.yml文件存在
  58. def ensure_config_file():
  59. config_file = os.path.join(os.path.dirname(os.path.abspath(__file__)), 'config.yml')
  60. if not os.path.exists(config_file):
  61. # 创建空的config.yml文件
  62. default_config = {
  63. 'accounts': {
  64. 'github': {
  65. 'enable': 1,
  66. '1': {
  67. 'username': '',
  68. 'token': '',
  69. 'private': True
  70. }
  71. }
  72. },
  73. 'log': {
  74. 'level': 'debug',
  75. 'file': '/tmp/repo_sync.log',
  76. 'max_size': '100MB',
  77. 'max_backups': 3,
  78. 'max_age': 7,
  79. 'console_formatter': {
  80. 'level': 'debug',
  81. 'format': '%(asctime)s - %(levelname)s - %(message)s'
  82. },
  83. 'file_formatter': {
  84. 'level': 'debug',
  85. 'format': '%(asctime)s - %(levelname)s - %(message)s'
  86. }
  87. }
  88. }
  89. with open(config_file, 'w', encoding='utf-8') as f:
  90. yaml.dump(default_config, f, default_flow_style=False)
  91. return config_file
  92. class SettingsTab(QWidget):
  93. def __init__(self, parent=None):
  94. super().__init__(parent)
  95. # 确保config.yml文件存在
  96. ensure_config_file()
  97. # 初始化account_lists字典
  98. self.account_lists = {}
  99. self.config_reader = ConfigReader()
  100. self.init_ui()
  101. def init_ui(self):
  102. layout = QVBoxLayout()
  103. # 创建平台选择标签页
  104. self.platform_tabs = QTabWidget()
  105. # 平台配置
  106. self.platform_configs = {
  107. "github": ["username", "token", "private"],
  108. "gitlab": ["host", "username", "token", "private"],
  109. "gitee": ["username", "token", "private"],
  110. "gitcode": ["username", "token", "private"],
  111. "git.yoq.me": ["username", "token", "private"],
  112. "coding": ["username", "token", "project", "private"],
  113. "aliyun": ["compoanyid", "group_id", "username", "token", "private"],
  114. "cnb": ["username", "token", "private"]
  115. }
  116. # 为每个平台创建标签页
  117. self.platform_pages = {}
  118. for platform in self.platform_configs.keys():
  119. page = QWidget()
  120. page_layout = QVBoxLayout()
  121. # 账户列表
  122. account_group = QGroupBox("Accounts")
  123. account_layout = QVBoxLayout()
  124. account_list = QListWidget()
  125. self.account_lists[platform] = account_list
  126. account_list.currentItemChanged.connect(lambda current, previous, p=platform: self.select_account(p, current))
  127. account_buttons = QHBoxLayout()
  128. add_btn = QPushButton("Add Account")
  129. add_btn.clicked.connect(lambda checked, p=platform: self.add_account(p))
  130. delete_btn = QPushButton("Delete Account")
  131. delete_btn.clicked.connect(lambda checked, p=platform: self.delete_account(p))
  132. enable_btn = QPushButton("Enable Account")
  133. enable_btn.clicked.connect(lambda checked, p=platform: self.enable_account(p))
  134. account_buttons.addWidget(add_btn)
  135. account_buttons.addWidget(delete_btn)
  136. account_buttons.addWidget(enable_btn)
  137. account_layout.addWidget(account_list)
  138. account_layout.addLayout(account_buttons)
  139. account_group.setLayout(account_layout)
  140. # 账户详情表单
  141. form_group = QGroupBox("Account Details")
  142. form_layout = QFormLayout()
  143. form_group.setLayout(form_layout)
  144. page_layout.addWidget(account_group)
  145. page_layout.addWidget(form_group)
  146. # 保存按钮
  147. save_btn = QPushButton("Save Settings")
  148. save_btn.clicked.connect(self.save_settings)
  149. page_layout.addWidget(save_btn)
  150. page.setLayout(page_layout)
  151. self.platform_pages[platform] = {
  152. "form": form_layout
  153. }
  154. self.platform_tabs.addTab(page, platform)
  155. layout.addWidget(self.platform_tabs)
  156. self.setLayout(layout)
  157. # 加载设置
  158. self.load_settings()
  159. def load_settings(self):
  160. # 为每个平台加载账户
  161. for platform in self.platform_configs.keys():
  162. account_list = self.account_lists[platform]
  163. account_list.clear()
  164. # 获取该平台的所有账户
  165. accounts = self.config_reader.get_platform_accounts(platform)
  166. # 添加到列表
  167. for account in accounts:
  168. item = QListWidgetItem(account)
  169. account_list.addItem(item)
  170. # 选择第一个账户
  171. if account_list.count() > 0:
  172. account_list.setCurrentRow(0)
  173. self.select_account(platform, account_list.item(0))
  174. def select_account(self, platform, item):
  175. if not item:
  176. return
  177. account = item.text()
  178. form = self.platform_pages[platform]["form"]
  179. # 清空表单
  180. while form.rowCount() > 0:
  181. form.removeRow(0)
  182. # 获取账户配置
  183. account_config = self.config_reader.get_account_config(platform, account)
  184. # 创建表单项
  185. self.field_widgets = {}
  186. for field in self.platform_configs[platform]:
  187. value = account_config.get(field, "")
  188. if field == "private":
  189. widget = QCheckBox()
  190. widget.setChecked(value if isinstance(value, bool) else value.lower() != "false")
  191. else:
  192. widget = QLineEdit()
  193. if field in ["token", "password"]:
  194. widget.setEchoMode(QLineEdit.Password)
  195. widget.setText(str(value))
  196. self.field_widgets[field] = widget
  197. form.addRow(f"{field.capitalize()}:", widget)
  198. def add_account(self, platform):
  199. dialog = AddAccountDialog(platform, self)
  200. if dialog.exec_() == QDialog.Accepted:
  201. account_data = dialog.get_account_data()
  202. account_name = account_data["name"]
  203. if not account_name:
  204. QMessageBox.warning(self, "Warning", "Account name cannot be empty.")
  205. return
  206. # 更新config.yml文件
  207. config = self.config_reader.config
  208. if platform not in config['accounts']:
  209. config['accounts'][platform] = {'enable': 1}
  210. # 添加新账户
  211. config['accounts'][platform][account_name] = {
  212. field: value for field, value in account_data.items() if field != 'name'
  213. }
  214. # 保存配置
  215. with open(self.config_reader.config_path, 'w', encoding='utf-8') as f:
  216. yaml.dump(config, f, default_flow_style=False)
  217. # 重新加载设置
  218. self.config_reader = ConfigReader()
  219. self.load_settings()
  220. # 选择新账户
  221. account_list = self.account_lists[platform]
  222. for i in range(account_list.count()):
  223. if account_list.item(i).text() == account_name:
  224. account_list.setCurrentRow(i)
  225. self.select_account(platform, account_list.item(i))
  226. break
  227. def delete_account(self, platform):
  228. account_list = self.account_lists[platform]
  229. current_item = account_list.currentItem()
  230. if not current_item:
  231. return
  232. account = current_item.text()
  233. reply = QMessageBox.question(
  234. self,
  235. "Confirm Deletion",
  236. f"Are you sure you want to delete the account '{account}' for {platform}?",
  237. QMessageBox.Yes | QMessageBox.No,
  238. QMessageBox.No
  239. )
  240. if reply == QMessageBox.Yes:
  241. # 更新config.yml文件
  242. config = self.config_reader.config
  243. if platform in config['accounts'] and account in config['accounts'][platform]:
  244. del config['accounts'][platform][account]
  245. # 保存配置
  246. with open(self.config_reader.config_path, 'w', encoding='utf-8') as f:
  247. yaml.dump(config, f, default_flow_style=False)
  248. # 重新加载设置
  249. self.config_reader = ConfigReader()
  250. self.load_settings()
  251. def enable_account(self, platform):
  252. account_list = self.account_lists[platform]
  253. current_item = account_list.currentItem()
  254. if not current_item:
  255. return
  256. account = current_item.text()
  257. # 更新config.yml文件
  258. config = self.config_reader.config
  259. if platform in config['accounts']:
  260. # 将当前账户的配置复制到第一个账户位置
  261. account_config = config['accounts'][platform][account]
  262. config['accounts'][platform]['1'] = account_config
  263. # 保存配置
  264. with open(self.config_reader.config_path, 'w', encoding='utf-8') as f:
  265. yaml.dump(config, f, default_flow_style=False)
  266. QMessageBox.information(
  267. self,
  268. "Success",
  269. f"Account '{account}' has been enabled for {platform}."
  270. )
  271. # 重新加载设置
  272. self.config_reader = ConfigReader()
  273. self.load_settings()
  274. def save_settings(self):
  275. # 保存当前显示的账户配置
  276. platform = list(self.platform_configs.keys())[self.platform_tabs.currentIndex()]
  277. account_list = self.account_lists[platform]
  278. current_item = account_list.currentItem()
  279. if current_item and hasattr(self, 'field_widgets'):
  280. account = current_item.text()
  281. # 更新config.yml文件
  282. config = self.config_reader.config
  283. if platform not in config['accounts']:
  284. config['accounts'][platform] = {'enable': 1}
  285. # 更新账户配置
  286. account_config = {}
  287. for field, widget in self.field_widgets.items():
  288. if isinstance(widget, QCheckBox):
  289. value = widget.isChecked()
  290. else:
  291. value = widget.text().strip()
  292. if value:
  293. account_config[field] = value
  294. config['accounts'][platform][account] = account_config
  295. # 保存配置
  296. with open(self.config_reader.config_path, 'w', encoding='utf-8') as f:
  297. yaml.dump(config, f, default_flow_style=False)
  298. QMessageBox.information(self, "Success", "Settings saved successfully!")
  299. class AddAccountDialog(QDialog):
  300. def __init__(self, platform, parent=None):
  301. super().__init__(parent)
  302. self.platform = platform
  303. self.init_ui()
  304. def init_ui(self):
  305. self.setWindowTitle(f"Add {self.platform} Account")
  306. layout = QFormLayout()
  307. # 账户名称
  308. self.name_edit = QLineEdit()
  309. layout.addRow("Account Name:", self.name_edit)
  310. # 其他字段
  311. self.field_widgets = {}
  312. platform_configs = {
  313. "github": ["username", "token", "private"],
  314. "gitlab": ["host", "username", "token", "private"],
  315. "gitee": ["username", "token", "private"],
  316. "gitcode": ["username", "token", "private"],
  317. "git.yoq.me": ["username", "token", "private"],
  318. "coding": ["username", "token", "project", "private"],
  319. "aliyun": ["compoanyid", "group_id", "username", "token", "private"],
  320. "cnb": ["username", "token", "private"]
  321. }
  322. for field in platform_configs[self.platform]:
  323. if field == "private":
  324. widget = QCheckBox()
  325. widget.setChecked(True)
  326. else:
  327. widget = QLineEdit()
  328. if field in ["token", "password"]:
  329. widget.setEchoMode(QLineEdit.Password)
  330. self.field_widgets[field] = widget
  331. layout.addRow(f"{field.capitalize()}:", widget)
  332. # 按钮
  333. buttons = QDialogButtonBox(
  334. QDialogButtonBox.Ok | QDialogButtonBox.Cancel,
  335. Qt.Horizontal, self)
  336. buttons.accepted.connect(self.accept)
  337. buttons.rejected.connect(self.reject)
  338. layout.addRow(buttons)
  339. self.setLayout(layout)
  340. def get_account_data(self):
  341. data = {"name": self.name_edit.text().strip()}
  342. for field, widget in self.field_widgets.items():
  343. if isinstance(widget, QCheckBox):
  344. data[field] = widget.isChecked()
  345. else:
  346. data[field] = widget.text().strip()
  347. return data
  348. class MainTab(QWidget):
  349. def __init__(self, parent=None):
  350. super().__init__(parent)
  351. layout = QVBoxLayout()
  352. # 路径选择
  353. path_layout = QHBoxLayout()
  354. self.path_label = QLabel("Local Path: ")
  355. self.path_edit = QLineEdit()
  356. self.path_edit.setText(get_active_explorer_path())
  357. self.path_btn = QPushButton("Browse...")
  358. self.path_btn.clicked.connect(self.choose_path)
  359. path_layout.addWidget(self.path_label)
  360. path_layout.addWidget(self.path_edit)
  361. path_layout.addWidget(self.path_btn)
  362. layout.addLayout(path_layout)
  363. # 操作
  364. op_group = QGroupBox("Operation:")
  365. op_layout = QHBoxLayout()
  366. self.op_buttons = QButtonGroup(self)
  367. for i, op in enumerate(["create", "push", "pull", "clone", "delete"]):
  368. btn = QRadioButton(op.capitalize())
  369. if i == 1:
  370. btn.setChecked(True)
  371. self.op_buttons.addButton(btn, i)
  372. op_layout.addWidget(btn)
  373. op_group.setLayout(op_layout)
  374. layout.addWidget(op_group)
  375. # 平台
  376. pf_group = QGroupBox("Platform:")
  377. pf_layout = QHBoxLayout()
  378. self.pf_buttons = QButtonGroup(self)
  379. self.platforms = ["github", "gitlab", "gitee", "gitcode", "git.yoq.me", "coding", "aliyun", "cnb"]
  380. for i, pf in enumerate(self.platforms):
  381. btn = QRadioButton(pf.capitalize())
  382. if i == 0:
  383. btn.setChecked(True)
  384. self.pf_buttons.addButton(btn, i)
  385. pf_layout.addWidget(btn)
  386. pf_group.setLayout(pf_layout)
  387. layout.addWidget(pf_group)
  388. # 账户选择
  389. account_layout = QHBoxLayout()
  390. account_layout.addWidget(QLabel("Account:"))
  391. self.account_combo = QComboBox()
  392. self.account_combo.setMinimumWidth(200)
  393. account_layout.addWidget(self.account_combo)
  394. account_layout.addStretch()
  395. layout.addLayout(account_layout)
  396. # 按钮区域 (run和cancel)
  397. btn_layout = QHBoxLayout()
  398. self.run_btn = QPushButton("run it")
  399. self.run_btn.clicked.connect(self.run_repo_sync)
  400. self.cancel_btn = QPushButton("Cancel")
  401. self.cancel_btn.clicked.connect(self.cancel_operation)
  402. self.cancel_btn.setEnabled(False)
  403. btn_layout.addWidget(self.run_btn)
  404. btn_layout.addWidget(self.cancel_btn)
  405. layout.addLayout(btn_layout)
  406. # 命令执行结果
  407. result_group = QGroupBox("Execution Result:")
  408. result_layout = QVBoxLayout()
  409. self.result_text = QTextEdit()
  410. self.result_text.setReadOnly(True)
  411. result_layout.addWidget(self.result_text)
  412. result_group.setLayout(result_layout)
  413. layout.addWidget(result_group)
  414. self.setLayout(layout)
  415. # 命令执行相关
  416. self.process = None
  417. self.command_signals = CommandSignals()
  418. self.command_signals.output.connect(self.update_output)
  419. self.command_signals.finished.connect(self.process_finished)
  420. # 初始化配置读取器
  421. self.config_reader = ConfigReader()
  422. # 平台变更时更新账户列表
  423. self.pf_buttons.buttonClicked.connect(self.update_account_list)
  424. self.update_account_list()
  425. def choose_path(self):
  426. path = QFileDialog.getExistingDirectory(self, "Select Directory")
  427. if path:
  428. self.path_edit.setText(path)
  429. def update_account_list(self):
  430. self.account_combo.clear()
  431. pf_id = self.pf_buttons.checkedId()
  432. platform = self.platforms[pf_id]
  433. # 读取所有账户
  434. accounts = self.get_platform_accounts(platform)
  435. # 找出启用的账户
  436. enabled_account = "1"
  437. # 添加账户到下拉框,启用的账户放在最前面
  438. if enabled_account in accounts:
  439. accounts.remove(enabled_account)
  440. self.account_combo.addItem(f"{enabled_account} (启用中)")
  441. for account in accounts:
  442. self.account_combo.addItem(account)
  443. # 默认选择启用的账户
  444. self.account_combo.setCurrentIndex(0)
  445. def get_platform_accounts(self, platform):
  446. # 读取config.yml文件中的所有配置
  447. accounts = set()
  448. # 获取该平台的所有账户
  449. try:
  450. platform_accounts = self.config_reader.get_platform_accounts(platform)
  451. for account in platform_accounts:
  452. accounts.add(account)
  453. except Exception as e:
  454. print(f"Error getting platform accounts: {str(e)}")
  455. # 确保至少有一个默认账户
  456. if not accounts:
  457. accounts.add("1")
  458. return sorted(list(accounts))
  459. def run_repo_sync(self):
  460. repo_path = self.path_edit.text().strip()
  461. if not repo_path:
  462. QMessageBox.warning(self, "Warning", "Please select a local path.")
  463. return
  464. op_id = self.op_buttons.checkedId()
  465. pf_id = self.pf_buttons.checkedId()
  466. op = ["create", "push", "pull", "clone", "delete"][op_id]
  467. pf = self.platforms[pf_id]
  468. # 获取选择的账户名(去掉可能的"(启用中)"后缀)
  469. account_text = self.account_combo.currentText()
  470. account = account_text.split(" (")[0] if " (" in account_text else account_text
  471. # 清空结果区域
  472. self.result_text.clear()
  473. # 检查平台配置
  474. account_config = self.config_reader.get_account_config(pf, account)
  475. if not account_config.get('token'):
  476. QMessageBox.warning(self, "Warning", f"Please configure {pf} token for account '{account}' in Settings tab first.")
  477. return
  478. # 构建参数
  479. args = {
  480. 'command': op,
  481. 'platform': pf,
  482. 'repo_path': repo_path
  483. }
  484. # 如果不是默认账户,需要设置环境变量
  485. if account != "1":
  486. # 保存原始环境变量
  487. self.original_env = {}
  488. for field, value in account_config.items():
  489. env_var = f"{pf}_{field}"
  490. if env_var in os.environ:
  491. self.original_env[env_var] = os.environ[env_var]
  492. os.environ[env_var] = str(value)
  493. # 显示执行命令
  494. cmd_str = f"repo_sync {op} -p {pf} -repo_path {repo_path}"
  495. self.result_text.append(f"Running: {cmd_str}\n")
  496. # 执行命令
  497. self.run_btn.setEnabled(False)
  498. self.cancel_btn.setEnabled(True)
  499. # 重定向标准输出和标准错误
  500. self.original_stdout = sys.stdout
  501. self.original_stderr = sys.stderr
  502. sys.stdout = self.OutputRedirector(self.command_signals)
  503. sys.stderr = self.OutputRedirector(self.command_signals)
  504. # 在新线程中执行命令
  505. self.process_thread = threading.Thread(
  506. target=self.run_module,
  507. args=(args,)
  508. )
  509. self.process_thread.daemon = True
  510. self.process_thread.start()
  511. def run_module(self, args):
  512. try:
  513. # 正确导入repo_sync模块的main函数
  514. from repo_sync.repo_sync import RepoSync
  515. self.running = True
  516. return_code = 0
  517. try:
  518. # 直接创建RepoSync实例并运行
  519. rs = RepoSync(args)
  520. rs.run()
  521. except SystemExit as e:
  522. return_code = e.code if isinstance(e.code, int) else 1
  523. except Exception as e:
  524. self.command_signals.output.emit(f"Error: {str(e)}")
  525. return_code = 1
  526. finally:
  527. self.command_signals.finished.emit(return_code)
  528. # 恢复标准输出和标准错误
  529. sys.stdout = self.original_stdout
  530. sys.stderr = self.original_stderr
  531. # 恢复环境变量
  532. if hasattr(self, 'original_env'):
  533. for var, value in self.original_env.items():
  534. os.environ[var] = value
  535. delattr(self, 'original_env')
  536. except Exception as e:
  537. self.command_signals.output.emit(f"Error: {str(e)}")
  538. self.command_signals.finished.emit(1)
  539. # 恢复标准输出和标准错误
  540. sys.stdout = self.original_stdout
  541. sys.stderr = self.original_stderr
  542. # 输出重定向类
  543. class OutputRedirector:
  544. def __init__(self, signals):
  545. self.signals = signals
  546. self.buffer = ""
  547. def write(self, text):
  548. self.buffer += text
  549. if '\n' in self.buffer:
  550. lines = self.buffer.split('\n')
  551. for line in lines[:-1]:
  552. self.signals.output.emit(line)
  553. self.buffer = lines[-1]
  554. def flush(self):
  555. if self.buffer:
  556. self.signals.output.emit(self.buffer)
  557. self.buffer = ""
  558. def run_process(self, cmd, env=None):
  559. try:
  560. self.process = subprocess.Popen(
  561. cmd,
  562. stdout=subprocess.PIPE,
  563. stderr=subprocess.STDOUT,
  564. text=True,
  565. bufsize=1,
  566. universal_newlines=True,
  567. env=env
  568. )
  569. # 读取输出
  570. for line in self.process.stdout:
  571. self.command_signals.output.emit(line)
  572. self.process.wait()
  573. self.command_signals.finished.emit(self.process.returncode)
  574. except Exception as e:
  575. self.command_signals.output.emit(f"Error: {str(e)}")
  576. self.command_signals.finished.emit(1)
  577. def update_output(self, text):
  578. self.result_text.append(text)
  579. # 自动滚动到底部
  580. self.result_text.verticalScrollBar().setValue(
  581. self.result_text.verticalScrollBar().maximum()
  582. )
  583. def process_finished(self, return_code):
  584. self.process = None
  585. self.run_btn.setEnabled(True)
  586. self.cancel_btn.setEnabled(False)
  587. if return_code == 0:
  588. self.result_text.append("\nOperation completed successfully.")
  589. else:
  590. self.result_text.append(f"\nOperation failed with return code {return_code}.")
  591. def cancel_operation(self):
  592. if self.process:
  593. self.process.terminate()
  594. self.result_text.append("\nOperation cancelled by user.")
  595. else:
  596. # 直接调用模式下,通过退出标志通知线程结束
  597. self.running = False
  598. self.result_text.append("\nOperation cancelled by user.")
  599. # 恢复标准输出和标准错误
  600. if hasattr(self, 'original_stdout') and hasattr(self, 'original_stderr'):
  601. sys.stdout = self.original_stdout
  602. sys.stderr = self.original_stderr
  603. # 恢复环境变量
  604. if hasattr(self, 'original_env'):
  605. for var, value in self.original_env.items():
  606. os.environ[var] = value
  607. delattr(self, 'original_env')
  608. # Explorer路径获取
  609. try:
  610. import win32com.client
  611. def get_active_explorer_path():
  612. shell = win32com.client.Dispatch("Shell.Application")
  613. for window in shell.Windows():
  614. if window.Name in ["文件资源管理器", "Windows Explorer"]:
  615. return window.Document.Folder.Self.Path
  616. return os.getcwd()
  617. except ImportError:
  618. def get_active_explorer_path():
  619. return os.getcwd()
  620. # 命令执行信号类
  621. class CommandSignals(QObject):
  622. output = pyqtSignal(str)
  623. finished = pyqtSignal(int)
  624. class AboutTab(QWidget):
  625. def __init__(self, parent=None):
  626. super().__init__(parent)
  627. layout = QVBoxLayout()
  628. layout.addWidget(QLabel(f"repo_sync tools v{__version__}"))
  629. layout.addWidget(QLabel("作者: liuyuqi.gov@msn.cn"))
  630. layout.addWidget(QLabel("GitHub: https://github.com/jianboy/repo_sync"))
  631. layout.addWidget(QLabel("\n功能说明:"))
  632. layout.addWidget(QLabel("- 支持多个代码托管平台"))
  633. layout.addWidget(QLabel("- 支持创建/推送/拉取/克隆/删除操作"))
  634. layout.addWidget(QLabel("- 自动获取资源管理器当前路径"))
  635. layout.addWidget(QLabel("- 配置信息保存在config.yml文件中"))
  636. layout.addWidget(QLabel("- 支持每个平台配置多个账户"))
  637. layout.addWidget(QLabel("- 命令行执行结果实时显示"))
  638. self.setLayout(layout)
  639. class RepoSyncMainWindow(QTabWidget):
  640. def __init__(self):
  641. super().__init__()
  642. self.setWindowTitle('repo_sync tools v1.12')
  643. self.resize(800, 700)
  644. self.main_tab = MainTab()
  645. self.addTab(self.main_tab, '主界面')
  646. self.settings_tab = SettingsTab()
  647. self.addTab(self.settings_tab, '设置')
  648. self.about_tab = AboutTab()
  649. self.addTab(self.about_tab, '关于')
  650. def main():
  651. """GUI主入口函数"""
  652. if not HAS_QT:
  653. print("PyQt5 not installed. Please install it with: pip install PyQt5")
  654. print("Running in fallback mode...")
  655. # 这里可以添加一个简单的命令行界面作为后备
  656. return
  657. try:
  658. # 确保config.yml文件存在
  659. ensure_config_file()
  660. app = QApplication(sys.argv)
  661. window = RepoSyncMainWindow()
  662. window.show()
  663. sys.exit(app.exec_())
  664. except Exception as e:
  665. print(f"Error starting GUI: {str(e)}")
  666. import traceback
  667. traceback.print_exc()
  668. if __name__ == '__main__':
  669. main()