main_gui.py 32 KB

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