automas_admin/AUTO-MAS-test
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Revert "新增用户字段today_stauts"

Browse Source 
This reverts commit 4ff632ed2a.
This commit is contained in:
DLmaster
2025-02-07 19:56:41 +08:00
parent 4ff632ed2a
commit 6c2f19a884
4 changed files with 8 additions and 50 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
app/core/config.py
View File

@@ -145,7 +145,7 @@ class AppConfig:
if mode == "Maa":
self.cur.execute(
"CREATE TABLE adminx(admin text,id text,server text,day int,status text,last date,game text,game_1 text,game_2 text,routine text,annihilation text,infrastructure text,password byte,notes text,numb int,mode text,uid int,today_status text)"
"CREATE TABLE adminx(admin text,id text,server text,day int,status text,last date,game text,game_1 text,game_2 text,routine text,annihilation text,infrastructure text,password byte,notes text,numb int,mode text,uid int)"
)
self.cur.execute("CREATE TABLE version(v text)")
self.cur.execute("INSERT INTO version VALUES(?)", ("v1.4",))
@@ -161,7 +161,7 @@ class AppConfig:
db = sqlite3.connect(self.database_path)
cur = db.cursor()
cur.execute("CREATE TABLE version(v text)")
cur.execute("INSERT INTO version VALUES(?)", ("v1.5",))
cur.execute("INSERT INTO version VALUES(?)", ("v1.4",))
db.commit()
cur.close()
db.close()
@@ -172,7 +172,7 @@ class AppConfig:
cur.execute("SELECT * FROM version WHERE True")
version = cur.fetchall()
if version[0][0] != "v1.5":
if version[0][0] != "v1.4":
logger.info("数据文件版本更新开始")
if_streaming = False
# v1.0-->v1.1
@@ -387,40 +387,10 @@ class AppConfig:
) as f:
json.dump(queue_config, f, ensure_ascii=False, indent=4)
(self.app_path / "config/gui.json").unlink()
if version[0][0] == "v1.4" or if_streaming:
logger.info("数据文件版本更新：v1.4-->v1.5")
if_streaming = True
# 检查adminx表是否存在
cur.execute("SELECT name FROM sqlite_master WHERE type='table' AND name='adminx'")
if not cur.fetchone():
self.create_adminx_table(cur)
else:
# 获取现有数据
cur.execute("SELECT * FROM adminx")
data = cur.fetchall()
# 重建表以包含新字段
cur.execute("DROP TABLE IF EXISTS adminx")
self.create_adminx_table(cur)
# 恢复数据
for row in data:
cur.execute(
"INSERT INTO adminx VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)",
row + ("n",) # 添加today_status默认值为'n'
)
cur.execute("DELETE FROM version WHERE v = ?", ("v1.4",))
cur.execute("INSERT INTO version VALUES(?)", ("v1.5",))
db.commit()
cur.close()
db.close()
logger.info("数据文件版本更新完成")
def create_adminx_table(self, cur):
"""创建adminx表"""
cur.execute(
"CREATE TABLE adminx(admin text,id text,server text,day int,status text,last date,game text,game_1 text,game_2 text,routine text,annihilation text,infrastructure text,password byte,notes text,numb int,mode text,uid int,today_status text)"
)
def search_config(self) -> list:
"""搜索所有子配置文件"""
@@ -464,7 +434,6 @@ class AppConfig:
lasts: list,
notes: list,
numbs: list,
today_status: list,
) -> None:
"""将代理完成后发生改动的用户信息同步至本地数据库"""
@@ -488,10 +457,6 @@ class AppConfig:
"UPDATE adminx SET numb = ? WHERE mode = ? AND uid = ?",
(numbs[index], modes[index], uids[index]),
)
cur.execute( # 添加today_status的更新
"UPDATE adminx SET today_status = ? WHERE mode = ? AND uid = ?",
(today_status[index], modes[index], uids[index]),
)
db.commit()
cur.close()
db.close()

5
app/core/task_manager.py
View File

@@ -45,7 +45,7 @@ class Task(QThread):
push_info_bar = Signal(str, str, str, int)
question = Signal(str, str)
question_response = Signal(bool)
update_user_info = Signal(Path, list, list, list, list, list, list, list)
update_user_info = Signal(Path, list, list, list, list, list, list)
create_task_list = Signal(list)
create_user_list = Signal(list)
update_task_list = Signal(list)
@@ -137,7 +137,7 @@ class Task(QThread):
self.task.update_user_list.connect(self.update_user_list.emit)
self.task.update_log_text.connect(self.update_log_text.emit)
self.task.update_user_info.connect(
lambda modes, uids, days, lasts, notes, numbs, today_status: self.update_user_info.emit(
lambda modes, uids, days, lasts, notes, numbs: self.update_user_info.emit(
self.member_dict[self.task_list[i][0]][1],
modes,
uids,
@@ -145,7 +145,6 @@ class Task(QThread):
lasts,
notes,
numbs,
today_status
)
)
self.task.accomplish.connect(