Update to v2.2

close #13
Waiting for updating and fix some bugs
2026-02-09 09:17:26 +08:00 · 2021-02-11 15:26:58 +08:00 · 2021-02-08 14:45:10 +08:00 · 2021-01-21 14:42:57 +08:00 · 2021-01-10 16:29:18 +08:00 · 2021-01-08 14:53:50 +08:00
28 changed files with 3108 additions and 2681 deletions
--- a/README.md
+++ b/README.md
@@ -2,14 +2,21 @@
 一个微型的Arcaea本地服务器  A small local server for Arcaea

 ## 简介 Introduction
-这是基于Python以及Flask的微型本地Arcaea服务器，可以模拟游戏的主要功能，一时兴起在五天之内糊了出来。这可能是我第一次写这种大程序，若有不妥之处，敬请谅解。  
-This is a small local Arcaea server based on Python and Flask, which can simulate the main functions of the game. I completed it on the spur of the moment in five days. This may be the first time I have written such a large program. Please understand if there is something wrong with it.
+这是基于Python以及Flask的微型本地Arcaea服务器，可以模拟游戏的主要功能。这可能是我第一次写这种大程序，若有不妥之处，敬请谅解。  
+
+本程序主要用于学习研究，不得用于任何商业行为，否则后果自负，这不是强制要求，只是一个提醒与警告。  
+
+This is a small local Arcaea server based on Python and Flask, which can simulate the main functions of the game. This may be the first time I have written such a large program. Please understand if there is something wrong with it.  
+
+This procedure is mainly used for study and research, and shall not be used for any commercial activities, otherwise the consequences will be borne by oneself. This is not a mandatory requirement, just a reminder and warning.
+
 > 虽然看起来很蠢，但是可以用！
 > It looks stupid, but it works!

 ## 特性 Features
 有以下 We have：
 - 登录、注册 Login and registration
+- 多设备登录 Multi device login
 - 成绩上传 Score upload
 - PTT
 - 排名 Rank
@@ -20,6 +27,7 @@ This is a small local Arcaea server based on Python and Flask, which can simulat
 - 自定义歌曲下载 Customizable songs download
 - 单曲和曲包购买（没啥用） Single songs and song packs purchase(useless)
 - 奖励系统 Present system
+- 兑换码系统 Redeem code system
 - 全角色立绘 All character drawings
 - 角色技能 Character skills
 - 自定义角色属性 Customizable characters attributes
@@ -31,12 +39,12 @@ This is a small local Arcaea server based on Python and Flask, which can simulat

 没有以下 We don't have：
 - 角色数值 Character characteristic value
- 数据同步的时间记录 The record of time for data synchronization 
 - 服务器安全性保证 Server security assurance

 可能有问题 There may be problems：
 - Recent 30
- 一些歌曲的解锁 Some Songs' unlocking
+- 一些歌曲的解锁 Some songs' unlocking
+- 同设备多共存登录 Multiple app logins on the same device

 ## 说明 Statement
 只是很有趣，用处探索中。  
@@ -55,12 +63,17 @@ It is just so interesting. What it can do is under exploration.
 >
 > Tips: When updating, please keep the original database in case of data loss.

-### Version 1.9
- 适用于Arcaea 3.4.0版本 For Arcaea 3.4.0
+### Version 2.2
+- 适用于Arcaea 3.5.1版本 For Arcaea 3.5.1
 - 更新了歌曲数据库 Update the song database.
- 新搭档**Luna & Mia**已解锁 Unlock the new character **Luna & Mia**.
- 新增了奖励系统 Add the present system.
- 修复了一些Bug Fix some bugs.
+- 新增多设备登录 Add multi device login.
+- 修改了配置文件结构 The configuration file structure has been modified.
+- 优化了代码结构 Optimize the code structure.
+- 修复了一堆Bug Fix many bugs.
+
+> 提醒：本次更新需重新登录
+> 
+> Tip: You need to log in Arcaea again in this update.


 ## 运行环境与依赖 Running environment and requirements
--- a/version/database/arcaea_database.db
+++ b/version/database/arcaea_database.db
--- a/version/database/arcsong.db
+++ b/version/database/arcsong.db
--- a/version/database/database_initialize.py
+++ b/version/database/database_initialize.py
@@ -33,13 +33,15 @@ rating real,
 favorite_character int,
 max_stamina_notification_enabled int,
 current_map text,
-ticket int
+ticket int,
+prog_boost int
 );''')
 c.execute('''create table if not exists login(access_token text,
-user_id int primary key,
-last_login_time int,
-last_login_ip text,
-last_login_device text
+user_id int,
+login_time int,
+login_ip text,
+login_device text,
+primary key(access_token, user_id)
 );''')
 c.execute('''create table if not exists friend(user_id_me int,
 user_id_other int,
@@ -206,7 +208,8 @@ clearedsongs_data text,
 unlocklist_data text,
 installid_data text,
 devicemodelname_data text,
-story_data text
+story_data text,
+createdAt int
 );''')
 c.execute('''create table if not exists present(present_id text primary key,
 expire_ts int,
@@ -217,19 +220,32 @@ c.execute('''create table if not exists user_present(user_id int,
 present_id text,
 primary key(user_id, present_id)
 );''')
+c.execute('''create table if not exists songfile(song_id text,
+file_type int,
+md5 text,
+primary key(song_id, file_type)
+);''')
+c.execute('''create table if not exists redeem(code text primary key,
+items text,
+type int
+);''')
+c.execute('''create table if not exists user_redeem(user_id int,
+code text,
+primary key(user_id, code)
+);''')


 char = ['Hikari', 'Tairitsu', 'Kou', 'Sapphire', 'Lethe', '', 'Tairitsu(Axium)', 'Tairitsu(Grievous Lady)', 'Stella', 'Hikari & Fisica', 'Ilith', 'Eto', 'Luna', 'Shirabe', 'Hikari(Zero)', 'Hikari(Fracture)', 'Hikari(Summer)', 'Tairitsu(Summer)', 'Tairitsu & Trin',
-        'Ayu', 'Eto & Luna', 'Yume', 'Seine & Hikari', 'Saya', 'Tairitsu & Chuni Penguin', 'Chuni Penguin', 'Haruna', 'Nono', 'MTA-XXX', 'MDA-21', 'Kanae', 'Hikari(Fantasia)', 'Tairitsu(Sonata)', 'Sia', 'DORO*C', 'Tairitsu(Tempest)', 'Brillante', 'Ilith(Summer)', 'Etude', 'Alice & Tenniel', 'Luna & Mia']
+        'Ayu', 'Eto & Luna', 'Yume', 'Seine & Hikari', 'Saya', 'Tairitsu & Chuni Penguin', 'Chuni Penguin', 'Haruna', 'Nono', 'MTA-XXX', 'MDA-21', 'Kanae', 'Hikari(Fantasia)', 'Tairitsu(Sonata)', 'Sia', 'DORO*C', 'Tairitsu(Tempest)', 'Brillante', 'Ilith(Summer)', 'Etude', 'Alice & Tenniel', 'Luna & Mia', 'Areus', 'Seele', 'Isabelle']

 skill_id = ['gauge_easy', '', '', '', 'note_mirror', '', '', 'gauge_hard', 'frag_plus_10_pack_stellights', 'gauge_easy|frag_plus_15_pst&prs', 'gauge_hard|fail_frag_minus_100', 'frag_plus_5_side_light', 'visual_hide_hp', 'frag_plus_5_side_conflict', 'challenge_fullcombo_0gauge', 'gauge_overflow', 'gauge_easy|note_mirror', 'note_mirror', 'visual_tomato_pack_tonesphere',
-            'frag_rng_ayu', 'gaugestart_30|gaugegain_70', 'combo_100-frag_1', 'audio_gcemptyhit_pack_groovecoaster', 'gauge_saya', 'gauge_chuni', 'kantandeshou', 'gauge_haruna', 'frags_nono', 'gauge_pandora', 'gauge_regulus', 'omatsuri_daynight', '', '', 'sometimes(note_mirror|frag_plus_5)', 'scoreclear_aa|visual_scoregauge', 'gauge_tempest', 'gauge_hard', 'gauge_ilith_summer', '', 'note_mirror|visual_hide_far', 'frags_ongeki']
+            'frag_rng_ayu', 'gaugestart_30|gaugegain_70', 'combo_100-frag_1', 'audio_gcemptyhit_pack_groovecoaster', 'gauge_saya', 'gauge_chuni', 'kantandeshou', 'gauge_haruna', 'frags_nono', 'gauge_pandora', 'gauge_regulus', 'omatsuri_daynight', '', '', 'sometimes(note_mirror|frag_plus_5)', 'scoreclear_aa|visual_scoregauge', 'gauge_tempest', 'gauge_hard', 'gauge_ilith_summer', '', 'note_mirror|visual_hide_far', 'frags_ongeki', 'gauge_areus', 'gauge_seele', 'gauge_isabelle']

 skill_id_uncap = ['', '', 'frags_kou', '', 'visual_ink', '', '', '', '', '', '', '', '', 'shirabe_entry_fee',
-                  '', '', '', '', '', '', '', 'frags_yume', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '']
+                  '', '', '', '', '', '', '', 'frags_yume', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '', '']

-for i in range(0, 41):
-    if i in [0, 1, 2, 4, 13, 26, 27, 28, 29, 36, 21]:
+for i in range(0, 44):
+    if i in [0, 1, 2, 4, 13, 26, 27, 28, 29, 36, 21, 42, 43]:
        sql = 'insert into character values('+str(
            i)+',"'+char[i]+'''",30,25000,25000,90,90,90,"'''+skill_id[i]+'''",0,0,"'''+skill_id_uncap[i]+'''",0,'',1,1)'''
        c.execute(sql)
--- a/version/database/packs.json
+++ b/version/database/packs.json
@@ -3,7 +3,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "core",
-		"_id": "5fdab049a6e343038b0582d4",
+		"_id": "6008c2ff36651a07ebc52ca9",
 		"is_available": true
 	}],
 	"price": 500,
@@ -15,12 +15,12 @@
 	"items": [{
 		"type": "pack",
 		"id": "shiawase",
-		"_id": "5fdab049a6e343038b058314",
+		"_id": "6008c2ff36651a07ebc52ce0",
 		"is_available": true
 	}, {
 		"type": "character",
 		"id": "kou",
-		"_id": "5fdab049a6e343038b058313",
+		"_id": "6008c2ff36651a07ebc52cdf",
 		"is_available": true
 	}],
 	"price": 500,
@@ -32,12 +32,12 @@
 	"items": [{
 		"type": "pack",
 		"id": "dynamix",
-		"_id": "5fdab049a6e343038b05831c",
+		"_id": "6008c2ff36651a07ebc52ce4",
 		"is_available": true
 	}, {
 		"type": "character",
 		"id": "sapphire",
-		"_id": "5fdab049a6e343038b05831b",
+		"_id": "6008c2ff36651a07ebc52ce3",
 		"is_available": true
 	}],
 	"price": 500,
@@ -49,12 +49,12 @@
 	"items": [{
 		"type": "pack",
 		"id": "mirai",
-		"_id": "5fdab049a6e343038b058318",
+		"_id": "6008c2ff36651a07ebc52cdc",
 		"is_available": true
 	}, {
 		"type": "character",
 		"id": "lethe",
-		"_id": "5fdab049a6e343038b058317",
+		"_id": "6008c2ff36651a07ebc52cdb",
 		"is_available": true
 	}],
 	"price": 500,
@@ -66,7 +66,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "yugamu",
-		"_id": "5fdab049a6e343038b0582d5",
+		"_id": "6008c2ff36651a07ebc52caa",
 		"is_available": true
 	}],
 	"price": 500,
@@ -78,7 +78,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "lanota",
-		"_id": "5fdab049a6e343038b058305",
+		"_id": "6008c2ff36651a07ebc52cd0",
 		"is_available": true
 	}],
 	"price": 500,
@@ -90,7 +90,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "nijuusei",
-		"_id": "5fdab049a6e343038b0582d6",
+		"_id": "6008c2ff36651a07ebc52cab",
 		"is_available": true
 	}],
 	"price": 500,
@@ -102,7 +102,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "rei",
-		"_id": "5fdab049a6e343038b0582fb",
+		"_id": "6008c2ff36651a07ebc52cc5",
 		"is_available": true
 	}],
 	"price": 500,
@@ -114,7 +114,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "tonesphere",
-		"_id": "5fdab049a6e343038b058307",
+		"_id": "6008c2ff36651a07ebc52cd2",
 		"is_available": true
 	}],
 	"price": 500,
@@ -126,7 +126,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "groovecoaster",
-		"_id": "5fdab049a6e343038b0582f1",
+		"_id": "6008c2ff36651a07ebc52ca1",
 		"is_available": true
 	}],
 	"price": 500,
@@ -138,7 +138,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "zettai",
-		"_id": "5fdab049a6e343038b0582fd",
+		"_id": "6008c2ff36651a07ebc52cc7",
 		"is_available": true
 	}],
 	"price": 500,
@@ -150,7 +150,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "chunithm",
-		"_id": "5fdab049a6e343038b0582e5",
+		"_id": "6008c2ff36651a07ebc52cbb",
 		"is_available": true
 	}],
 	"price": 300,
@@ -160,7 +160,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "prelude",
-		"_id": "5fdab049a6e343038b0582f2",
+		"_id": "6008c2ff36651a07ebc52ca2",
 		"is_available": true
 	}],
 	"price": 400,
@@ -170,7 +170,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "omatsuri",
-		"_id": "5fdab049a6e343038b0582fe",
+		"_id": "6008c2ff36651a07ebc52cc8",
 		"is_available": true
 	}],
 	"price": 500,
@@ -180,7 +180,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "vs",
-		"_id": "5fdab049a6e343038b0582e8",
+		"_id": "6008c2ff36651a07ebc52cbe",
 		"is_available": true
 	}],
 	"price": 500,
@@ -190,7 +190,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "extend",
-		"_id": "5fdab049a6e343038b0582f5",
+		"_id": "6008c2ff36651a07ebc52ca5",
 		"is_available": true
 	}],
 	"price": 700,
@@ -200,7 +200,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "alice",
-		"_id": "5fdab049a6e343038b058303",
+		"_id": "6008c2ff36651a07ebc52ccd",
 		"is_available": true
 	}],
 	"orig_price": 500,
@@ -210,7 +210,7 @@
 	"items": [{
 		"type": "pack",
 		"id": "alice_append_1",
-		"_id": "5fdab049a6e343038b0582df",
+		"_id": "6008c2ff36651a07ebc52cb4",
 		"is_available": true
 	}],
 	"orig_price": 300,
@@ -220,9 +220,29 @@
 	"items": [{
 		"type": "pack",
 		"id": "ongeki",
-		"_id": "5fdab049a6e343038b0582eb",
+		"_id": "6008c2ff36651a07ebc52cc1",
 		"is_available": true
 	}],
 	"orig_price": 400,
 	"price": 400
+}, {
+	"name": "maimai",
+	"items": [{
+		"type": "pack",
+		"id": "maimai",
+		"_id": "6008c2ff36651a07ebc52ca8",
+		"is_available": true
+	}],
+	"orig_price": 400,
+	"price": 400
+}, {
+	"name": "chunithm_append_1",
+	"items": [{
+		"type": "pack",
+		"id": "chunithm_append_1",
+		"_id": "6008c2ff36651a07ebc52cda",
+		"is_available": true
+	}],
+	"orig_price": 300,
+	"price": 300
 }]
--- a/version/database/singles.json
+++ b/version/database/singles.json
@@ -12,7 +12,7 @@
 	"items": [{
 		"id": "dataerror",
 		"type": "single",
-		"_id": "5fdab049a6e343038b0582ec",
+		"_id": "6008c2ff36651a07ebc52cb5",
 		"is_available": true
 	}],
 	"price": 100,
@@ -24,7 +24,7 @@
 	"items": [{
 		"id": "yourvoiceso",
 		"type": "single",
-		"_id": "5fdab049a6e343038b0582f8",
+		"_id": "6008c2ff36651a07ebc52cc2",
 		"is_available": true
 	}],
 	"price": 100,
@@ -36,7 +36,7 @@
 	"items": [{
 		"id": "crosssoul",
 		"type": "single",
-		"_id": "5fdab049a6e343038b058304",
+		"_id": "6008c2ff36651a07ebc52ccf",
 		"is_available": true
 	}],
 	"price": 100,
@@ -48,7 +48,7 @@
 	"items": [{
 		"type": "single",
 		"id": "impurebird",
-		"_id": "5fdab049a6e343038b0582e0",
+		"_id": "6008c2ff36651a07ebc52cb6",
 		"is_available": true
 	}],
 	"price": 100,
@@ -60,7 +60,7 @@
 	"items": [{
 		"type": "single",
 		"id": "auxesia",
-		"_id": "5fdab049a6e343038b0582ed",
+		"_id": "6008c2ff36651a07ebc52c9d",
 		"is_available": true
 	}],
 	"price": 100,
@@ -72,7 +72,7 @@
 	"items": [{
 		"type": "single",
 		"id": "modelista",
-		"_id": "5fdab049a6e343038b0582f9",
+		"_id": "6008c2ff36651a07ebc52cc3",
 		"is_available": true
 	}],
 	"price": 100,
@@ -84,7 +84,7 @@
 	"items": [{
 		"type": "single",
 		"id": "yozakurafubuki",
-		"_id": "5fdab049a6e343038b0582e1",
+		"_id": "6008c2ff36651a07ebc52cb7",
 		"is_available": true
 	}],
 	"price": 100,
@@ -96,7 +96,7 @@
 	"items": [{
 		"type": "single",
 		"id": "surrender",
-		"_id": "5fdab049a6e343038b0582ee",
+		"_id": "6008c2ff36651a07ebc52c9e",
 		"is_available": true
 	}],
 	"price": 100,
@@ -108,7 +108,7 @@
 	"items": [{
 		"type": "single",
 		"id": "metallicpunisher",
-		"_id": "5fdab049a6e343038b0582fa",
+		"_id": "6008c2ff36651a07ebc52cc4",
 		"is_available": true
 	}],
 	"price": 100,
@@ -118,7 +118,7 @@
 	"items": [{
 		"type": "single",
 		"id": "carminescythe",
-		"_id": "5fdab049a6e343038b0582e2",
+		"_id": "6008c2ff36651a07ebc52cb8",
 		"is_available": true
 	}],
 	"price": 100,
@@ -128,7 +128,7 @@
 	"items": [{
 		"type": "single",
 		"id": "bethere",
-		"_id": "5fdab049a6e343038b0582ef",
+		"_id": "6008c2ff36651a07ebc52c9f",
 		"is_available": true
 	}],
 	"price": 100,
@@ -140,7 +140,7 @@
 	"items": [{
 		"type": "single",
 		"id": "callmyname",
-		"_id": "5fdab049a6e343038b058306",
+		"_id": "6008c2ff36651a07ebc52cd1",
 		"is_available": true
 	}],
 	"price": 100,
@@ -152,7 +152,7 @@
 	"items": [{
 		"type": "single",
 		"id": "fallensquare",
-		"_id": "5fdab049a6e343038b0582d7",
+		"_id": "6008c2ff36651a07ebc52cac",
 		"is_available": true
 	}],
 	"price": 100,
@@ -164,7 +164,7 @@
 	"items": [{
 		"type": "single",
 		"id": "dropdead",
-		"_id": "5fdab049a6e343038b0582e3",
+		"_id": "6008c2ff36651a07ebc52cb9",
 		"is_available": true
 	}],
 	"price": 100,
@@ -176,7 +176,7 @@
 	"items": [{
 		"type": "single",
 		"id": "alexandrite",
-		"_id": "5fdab049a6e343038b0582f0",
+		"_id": "6008c2ff36651a07ebc52ca0",
 		"is_available": true
 	}],
 	"price": 100,
@@ -188,7 +188,7 @@
 	"items": [{
 		"type": "single",
 		"id": "astraltale",
-		"_id": "5fdab049a6e343038b0582fc",
+		"_id": "6008c2ff36651a07ebc52cc6",
 		"is_available": true
 	}],
 	"price": 100,
@@ -200,7 +200,7 @@
 	"items": [{
 		"type": "single",
 		"id": "phantasia",
-		"_id": "5fdab049a6e343038b0582d8",
+		"_id": "6008c2ff36651a07ebc52cad",
 		"is_available": true
 	}],
 	"price": 100,
@@ -210,7 +210,7 @@
 	"items": [{
 		"type": "single",
 		"id": "empireofwinter",
-		"_id": "5fdab049a6e343038b0582e4",
+		"_id": "6008c2ff36651a07ebc52cba",
 		"is_available": true
 	}],
 	"price": 100,
@@ -220,7 +220,7 @@
 	"items": [{
 		"type": "single",
 		"id": "libertas",
-		"_id": "5fdab049a6e343038b058308",
+		"_id": "6008c2ff36651a07ebc52cd3",
 		"is_available": true
 	}],
 	"price": 100,
@@ -232,7 +232,7 @@
 	"items": [{
 		"type": "single",
 		"id": "dottodot",
-		"_id": "5fdab049a6e343038b0582d9",
+		"_id": "6008c2ff36651a07ebc52cae",
 		"is_available": true
 	}],
 	"price": 100,
@@ -244,7 +244,7 @@
 	"items": [{
 		"type": "single",
 		"id": "dreadnought",
-		"_id": "5fdab049a6e343038b058309",
+		"_id": "6008c2ff36651a07ebc52cd4",
 		"is_available": true
 	}],
 	"price": 100,
@@ -256,7 +256,7 @@
 	"items": [{
 		"type": "single",
 		"id": "mirzam",
-		"_id": "5fdab049a6e343038b0582da",
+		"_id": "6008c2ff36651a07ebc52caf",
 		"is_available": true
 	}],
 	"price": 100,
@@ -268,7 +268,7 @@
 	"items": [{
 		"type": "single",
 		"id": "heavenlycaress",
-		"_id": "5fdab049a6e343038b0582e6",
+		"_id": "6008c2ff36651a07ebc52cbc",
 		"is_available": true
 	}],
 	"price": 100,
@@ -278,7 +278,7 @@
 	"items": [{
 		"type": "single",
 		"id": "filament",
-		"_id": "5fdab049a6e343038b0582f3",
+		"_id": "6008c2ff36651a07ebc52ca3",
 		"is_available": true
 	}],
 	"price": 100,
@@ -288,7 +288,7 @@
 	"items": [{
 		"type": "single",
 		"id": "avantraze",
-		"_id": "5fdab049a6e343038b05830a",
+		"_id": "6008c2ff36651a07ebc52cd5",
 		"is_available": true
 	}],
 	"price": 100,
@@ -298,7 +298,7 @@
 	"items": [{
 		"type": "single",
 		"id": "battlenoone",
-		"_id": "5fdab049a6e343038b0582ff",
+		"_id": "6008c2ff36651a07ebc52cc9",
 		"is_available": true
 	}],
 	"price": 100,
@@ -308,7 +308,7 @@
 	"items": [{
 		"type": "single",
 		"id": "saikyostronger",
-		"_id": "5fdab049a6e343038b0582db",
+		"_id": "6008c2ff36651a07ebc52cb0",
 		"is_available": true
 	}],
 	"price": 100,
@@ -318,7 +318,7 @@
 	"items": [{
 		"type": "single",
 		"id": "izana",
-		"_id": "5fdab049a6e343038b0582e7",
+		"_id": "6008c2ff36651a07ebc52cbd",
 		"is_available": true
 	}],
 	"price": 100,
@@ -328,7 +328,7 @@
 	"items": [{
 		"type": "single",
 		"id": "einherjar",
-		"_id": "5fdab049a6e343038b0582f4",
+		"_id": "6008c2ff36651a07ebc52ca4",
 		"is_available": true
 	}],
 	"price": 100,
@@ -338,7 +338,7 @@
 	"items": [{
 		"type": "single",
 		"id": "laqryma",
-		"_id": "5fdab049a6e343038b05830b",
+		"_id": "6008c2ff36651a07ebc52cd6",
 		"is_available": true
 	}],
 	"price": 100,
@@ -348,7 +348,7 @@
 	"items": [{
 		"type": "single",
 		"id": "amygdata",
-		"_id": "5fdab049a6e343038b058300",
+		"_id": "6008c2ff36651a07ebc52cca",
 		"is_available": true
 	}],
 	"price": 100,
@@ -358,7 +358,7 @@
 	"items": [{
 		"type": "single",
 		"id": "altale",
-		"_id": "5fdab049a6e343038b0582dc",
+		"_id": "6008c2ff36651a07ebc52cb1",
 		"is_available": true
 	}],
 	"price": 100,
@@ -368,7 +368,7 @@
 	"items": [{
 		"type": "single",
 		"id": "feelssoright",
-		"_id": "5fdab049a6e343038b05830c",
+		"_id": "6008c2ff36651a07ebc52cd7",
 		"is_available": true
 	}],
 	"price": 100,
@@ -378,7 +378,7 @@
 	"items": [{
 		"type": "single",
 		"id": "scarletcage",
-		"_id": "5fdab049a6e343038b058301",
+		"_id": "6008c2ff36651a07ebc52ccb",
 		"is_available": true
 	}],
 	"price": 100,
@@ -388,7 +388,7 @@
 	"items": [{
 		"type": "single",
 		"id": "teriqma",
-		"_id": "5fdab049a6e343038b0582dd",
+		"_id": "6008c2ff36651a07ebc52cb2",
 		"is_available": true
 	}],
 	"price": 100,
@@ -398,7 +398,7 @@
 	"items": [{
 		"type": "single",
 		"id": "mahoroba",
-		"_id": "5fdab049a6e343038b0582e9",
+		"_id": "6008c2ff36651a07ebc52cbf",
 		"is_available": true
 	}],
 	"price": 100,
@@ -408,7 +408,7 @@
 	"items": [{
 		"type": "single",
 		"id": "badtek",
-		"_id": "5fdab049a6e343038b05830d",
+		"_id": "6008c2ff36651a07ebc52cd8",
 		"is_available": true
 	}],
 	"price": 100,
@@ -418,7 +418,7 @@
 	"items": [{
 		"type": "single",
 		"id": "maliciousmischance",
-		"_id": "5fdab049a6e343038b058302",
+		"_id": "6008c2ff36651a07ebc52ccc",
 		"is_available": true
 	}],
 	"price": 100,
@@ -428,7 +428,7 @@
 	"items": [{
 		"type": "single",
 		"id": "buchigireberserker",
-		"_id": "5fdab049a6e343038b0582de",
+		"_id": "6008c2ff36651a07ebc52cb3",
 		"is_available": true
 	}],
 	"price": 100,
@@ -438,7 +438,7 @@
 	"items": [{
 		"type": "single",
 		"id": "galaxyfriends",
-		"_id": "5fdab049a6e343038b0582ea",
+		"_id": "6008c2ff36651a07ebc52cc0",
 		"is_available": true
 	}],
 	"price": 100,
@@ -448,7 +448,7 @@
 	"items": [{
 		"type": "single",
 		"id": "xeraphinite",
-		"_id": "5fdab049a6e343038b0582f7",
+		"_id": "6008c2ff36651a07ebc52ca7",
 		"is_available": true
 	}],
 	"orig_price": 100,
@@ -458,9 +458,19 @@
 	"items": [{
 		"type": "single",
 		"id": "xanatos",
-		"_id": "5fdab049a6e343038b05830e",
+		"_id": "6008c2ff36651a07ebc52cd9",
 		"is_available": true
 	}],
 	"price": 100,
 	"orig_price": 100
+}, {
+	"name": "attraqtia",
+	"items": [{
+		"type": "single",
+		"id": "attraqtia",
+		"_id": "6008c2ff36651a07ebc52cce",
+		"is_available": true
+	}],
+	"orig_price": 100,
+	"price": 100
 }]
--- a/version/main.py
+++ b/version/main.py
@@ -1,5 +1,8 @@
+# encoding: utf-8
+
 from flask import Flask, request, jsonify, make_response, send_from_directory
-import configparser
+from logging.config import dictConfig
+from setting import Config
 import base64
 import server.auth
 import server.info
@@ -80,259 +83,183 @@ def favicon():
    return app.send_static_file('favicon.ico')


-@app.route('/coffee/12/auth/login', methods=['POST'])  # 登录接口
+@app.route('/latte/13/auth/login', methods=['POST'])  # 登录接口
 def login():
    headers = request.headers
    id_pwd = headers['Authorization']
    id_pwd = base64.b64decode(id_pwd[6:]).decode()
    name, password = id_pwd.split(':', 1)
-
-    try:
-        token = server.auth.arc_login(name, password)
-        if token is not None:
-            r = {"success": True, "token_type": "Bearer"}
-            r['access_token'] = token
-            return jsonify(r)
-        else:
-            return error_return(104)  # 用户名或密码错误
-    except:
-        return error_return(108)
+    device_id = headers['DeviceId']
+    token, error_code = server.auth.arc_login(name, password, device_id)
+    if not error_code:
+        r = {"success": True, "token_type": "Bearer"}
+        r['access_token'] = token
+        return jsonify(r)
+    else:
+        return error_return(error_code)


-@app.route('/coffee/12/user/', methods=['POST'])  # 注册接口
+@app.route('/latte/13/user/', methods=['POST'])  # 注册接口
 def register():
    name = request.form['name']
    password = request.form['password']
-    try:
-        user_id, token, error_code = server.auth.arc_register(name, password)
-        if user_id is not None:
-            r = {"success": True, "value": {
-                'user_id': user_id, 'access_token': token}}
-            return jsonify(r)
-        else:
-            return error_return(error_code)  # 应该是101，用户名被占用，毕竟电子邮箱、设备号没记录
-    except:
-        return error_return(108)
+    device_id = request.form['device_id']
+    user_id, token, error_code = server.auth.arc_register(
+        name, password, device_id)
+    if user_id is not None:
+        r = {"success": True, "value": {
+            'user_id': user_id, 'access_token': token}}
+        return jsonify(r)
+    else:
+        return error_return(error_code)  # 应该是101，用户名被占用，毕竟电子邮箱没记录


 # 集成式请求，没想到什么好办法处理，就先这样写着
-@app.route('/coffee/12/compose/aggregate', methods=['GET'])
-def aggregate():
+@app.route('/latte/13/compose/aggregate', methods=['GET'])
+@server.auth.auth_required(request)
+def aggregate(user_id):
    calls = request.args.get('calls')
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            if calls == '[{ "endpoint": "/user/me", "id": 0 }]':  # 极其沙雕的判断，我猜get的参数就两种
-                r = server.info.arc_aggregate_small(user_id)
-            else:
-                r = server.info.arc_aggregate_big(user_id)
-            return jsonify(r)
-        else:
-            return error_return(108)
-    except:
-        return error_return(108)
+    if calls == '[{ "endpoint": "/user/me", "id": 0 }]':  # 极其沙雕的判断，我猜get的参数就两种
+        r = server.info.arc_aggregate_small(user_id)
+    else:
+        r = server.info.arc_aggregate_big(user_id)
+    return jsonify(r)


-@app.route('/coffee/12/user/me/character', methods=['POST'])  # 角色切换
-def character_change():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
+@app.route('/latte/13/user/me/character', methods=['POST'])  # 角色切换
+@server.auth.auth_required(request)
+def character_change(user_id):
    character_id = request.form['character']
    skill_sealed = request.form['skill_sealed']
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            flag = server.setme.change_char(
-                user_id, character_id, skill_sealed)
-            if flag:
-                return jsonify({
-                    "success": True,
-                    "value": {
-                        "user_id": user_id,
-                        "character": character_id
-                    }
-                })
-            else:
-                return error_return(108)
-        else:
-            return error_return(108)
-    except:
+
+    flag = server.setme.change_char(user_id, character_id, skill_sealed)
+    if flag:
+        return jsonify({
+            "success": True,
+            "value": {
+                "user_id": user_id,
+                "character": character_id
+            }
+        })
+    else:
        return error_return(108)


-@app.route('/coffee/<path:path>/toggle_uncap', methods=['POST'])  # 角色觉醒切换
-def character_uncap(path):
-    character_id = int(path[22:])
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            r = server.setme.change_char_uncap(user_id, character_id)
-            if r is not None:
-                return jsonify({
-                    "success": True,
-                    "value": {
-                        "user_id": user_id,
-                        "character": [r]
-                    }
-                })
-            else:
-                return error_return(108)
-        else:
-            return error_return(108)
-    except:
+@app.route('/latte/<path:path>/toggle_uncap', methods=['POST'])  # 角色觉醒切换
+@server.auth.auth_required(request)
+def character_uncap(user_id, path):
+    while '//' in path:
+        path = path.replace('//', '/')
+    character_id = int(path[21:])
+    r = server.setme.change_char_uncap(user_id, character_id)
+    if r is not None:
+        return jsonify({
+            "success": True,
+            "value": {
+                "user_id": user_id,
+                "character": [r]
+            }
+        })
+    else:
        return error_return(108)


-@app.route('/coffee/12/friend/me/add', methods=['POST'])  # 加好友
-def add_friend():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
+@app.route('/latte/13/friend/me/add', methods=['POST'])  # 加好友
+@server.auth.auth_required(request)
+def add_friend(user_id):
    friend_code = request.form['friend_code']
-    try:
-        user_id = server.auth.token_get_id(token)
-        friend_id = server.auth.code_get_id(friend_code)
-        if user_id is not None and friend_id is not None:
-            r = server.setme.arc_add_friend(user_id, friend_id)
-            if r is not None and r != 602 and r != 604:
-                return jsonify({
-                    "success": True,
-                    "value": {
-                        "user_id": user_id,
-                        "updatedAt": "2020-09-07T07:32:12.740Z",
-                        "createdAt": "2020-09-06T10:05:18.471Z",
-                        "friends": r
-                    }
-                })
-            else:
-                if r is not None:
-                    return error_return(r)
-                else:
-                    return error_return(108)
+    friend_id = server.auth.code_get_id(friend_code)
+    if friend_id is not None:
+        r = server.setme.arc_add_friend(user_id, friend_id)
+        if r is not None and r != 602 and r != 604:
+            return jsonify({
+                "success": True,
+                "value": {
+                    "user_id": user_id,
+                    "updatedAt": "2020-09-07T07:32:12.740Z",
+                    "createdAt": "2020-09-06T10:05:18.471Z",
+                    "friends": r
+                }
+            })
        else:
-            if friend_id is None:
-                return error_return(401)
+            if r is not None:
+                return error_return(r)
            else:
                return error_return(108)
-    except:
-        return error_return(108)
+    else:
+        return error_return(401)


-@app.route('/coffee/12/friend/me/delete', methods=['POST'])  # 删好友
-def delete_friend():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
+@app.route('/latte/13/friend/me/delete', methods=['POST'])  # 删好友
+@server.auth.auth_required(request)
+def delete_friend(user_id):
    friend_id = int(request.form['friend_id'])
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None and friend_id is not None:
-            r = server.setme.arc_delete_friend(user_id, friend_id)
-            if r is not None:
-                return jsonify({
-                    "success": True,
-                    "value": {
-                        "user_id": user_id,
-                        "updatedAt": "2020-09-07T07:32:12.740Z",
-                        "createdAt": "2020-09-06T10:05:18.471Z",
-                        "friends": r
-                    }
-                })
-            else:
-                return error_return(108)
-        else:
-            if friend_id is None:
-                return error_return(401)
-            else:
-                return error_return(108)
-    except:
-        return error_return(108)
-
-
-@app.route('/coffee/12/score/song/friend', methods=['GET'])  # 好友排名，默认最多50
-def song_score_friend():
-    song_id = request.args.get('song_id')
-    difficulty = request.args.get('difficulty')
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            r = server.arcscore.arc_score_friend(user_id, song_id, difficulty)
-            if r is not None:
-                return jsonify({
-                    "success": True,
-                    "value": r
-                })
-            else:
-                return error_return(108)
+    if friend_id is not None:
+        r = server.setme.arc_delete_friend(user_id, friend_id)
+        if r is not None:
+            return jsonify({
+                "success": True,
+                "value": {
+                    "user_id": user_id,
+                    "updatedAt": "2020-09-07T07:32:12.740Z",
+                    "createdAt": "2020-09-06T10:05:18.471Z",
+                    "friends": r
+                }
+            })
        else:
            return error_return(108)
-    except:
-        return error_return(108)
+    else:
+        return error_return(401)


-@app.route('/coffee/12/score/song/me', methods=['GET'])  # 我的排名，默认最多20
-def song_score_me():
+@app.route('/latte/13/score/song/friend', methods=['GET'])  # 好友排名，默认最多50
+@server.auth.auth_required(request)
+def song_score_friend(user_id):
    song_id = request.args.get('song_id')
    difficulty = request.args.get('difficulty')
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            r = server.arcscore.arc_score_me(user_id, song_id, difficulty)
-            if r is not None:
-                return jsonify({
-                    "success": True,
-                    "value": r
-                })
-            else:
-                return error_return(108)
-        else:
-            return error_return(108)
-    except:
+    r = server.arcscore.arc_score_friend(user_id, song_id, difficulty)
+    if r is not None:
+        return jsonify({
+            "success": True,
+            "value": r
+        })
+    else:
        return error_return(108)


-@app.route('/coffee/12/score/song', methods=['GET'])  # TOP20
-def song_score_top():
+@app.route('/latte/13/score/song/me', methods=['GET'])  # 我的排名，默认最多20
+@server.auth.auth_required(request)
+def song_score_me(user_id):
    song_id = request.args.get('song_id')
    difficulty = request.args.get('difficulty')
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            r = server.arcscore.arc_score_top(song_id, difficulty)
-            if r is not None:
-                return jsonify({
-                    "success": True,
-                    "value": r
-                })
-            else:
-                return error_return(108)
-        else:
-            return error_return(108)
-    except:
+    r = server.arcscore.arc_score_me(user_id, song_id, difficulty)
+    if r is not None:
+        return jsonify({
+            "success": True,
+            "value": r
+        })
+    else:
        return error_return(108)


-@app.route('/coffee/12/score/song', methods=['POST'])  # 成绩上传
-def song_score_post():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
+@app.route('/latte/13/score/song', methods=['GET'])  # TOP20
+@server.auth.auth_required(request)
+def song_score_top(user_id):
+    song_id = request.args.get('song_id')
+    difficulty = request.args.get('difficulty')
+    r = server.arcscore.arc_score_top(song_id, difficulty)
+    if r is not None:
+        return jsonify({
+            "success": True,
+            "value": r
+        })
+    else:
+        return error_return(108)
+
+
+@app.route('/latte/13/score/song', methods=['POST'])  # 成绩上传
+@server.auth.auth_required(request)
+def song_score_post(user_id):
    song_token = request.form['song_token']
    song_hash = request.form['song_hash']
    song_id = request.form['song_id']
@@ -348,35 +275,28 @@ def song_score_post():
    clear_type = int(request.form['clear_type'])
    submission_hash = request.form['submission_hash']

-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            # 增加成绩校验
-            if not server.arcscore.arc_score_check(user_id, song_id, difficulty, score, shiny_perfect_count, perfect_count, near_count, miss_count, health, modifier, beyond_gauge, clear_type, song_token, song_hash, submission_hash):
-                return error_return(107)
+    # 增加成绩校验
+    if not server.arcscore.arc_score_check(user_id, song_id, difficulty, score, shiny_perfect_count, perfect_count, near_count, miss_count, health, modifier, beyond_gauge, clear_type, song_token, song_hash, submission_hash):
+        return error_return(107)

-            r, re = server.arcscore.arc_score_post(user_id, song_id, difficulty, score, shiny_perfect_count,
-                                                   perfect_count, near_count, miss_count, health, modifier, beyond_gauge, clear_type)
-            if r:
-                if re:
-                    return jsonify({
-                        "success": True,
-                        "value": re
-                    })
-                else:
-                    return jsonify({
-                        "success": True,
-                        "value": {"user_rating": r}
-                    })
-            else:
-                return error_return(108)
+    r, re = server.arcscore.arc_score_post(user_id, song_id, difficulty, score, shiny_perfect_count,
+                                           perfect_count, near_count, miss_count, health, modifier, beyond_gauge, clear_type)
+    if r is not None:
+        if re:
+            return jsonify({
+                "success": True,
+                "value": re
+            })
        else:
-            return error_return(108)
-    except:
+            return jsonify({
+                "success": True,
+                "value": {"user_rating": r}
+            })
+    else:
        return error_return(108)


-@app.route('/coffee/12/score/token', methods=['GET'])  # 成绩上传所需的token，显然我不想验证
+@app.route('/latte/13/score/token', methods=['GET'])  # 成绩上传所需的token，显然我不想验证
 def score_token():
    return jsonify({
        "success": True,
@@ -387,57 +307,37 @@ def score_token():


 # 世界模式成绩上传所需的token，无验证
-@app.route('/coffee/12/score/token/world', methods=['GET'])
-def score_token_world():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
+@app.route('/latte/13/score/token/world', methods=['GET'])
+@server.auth.auth_required(request)
+def score_token_world(user_id):
    args = request.args
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id:
-            server.arcworld.play_world_song(user_id, args)
-            return jsonify({
-                "success": True,
-                "value": {
-                    "stamina": 12,
-                    "max_stamina_ts": 1599547603825,
-                    "token": "13145201919810"
-                }
-            })
-        else:
-            return error_return(108)
-    except:
+    server.arcworld.play_world_song(user_id, args)
+    return jsonify({
+        "success": True,
+        "value": {
+            "stamina": 12,
+            "max_stamina_ts": 1599547603825,
+            "token": "13145201919810"
+        }
+    })
+
+
+@app.route('/latte/13/user/me/save', methods=['GET'])  # 从云端同步
+@server.auth.auth_required(request)
+def cloud_get(user_id):
+    r = server.arcscore.arc_all_get(user_id)
+    if r is not None:
+        return jsonify({
+            "success": True,
+            "value": r
+        })
+    else:
        return error_return(108)


-@app.route('/coffee/12/user/me/save', methods=['GET'])  # 从云端同步
-def cloud_get():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            r = server.arcscore.arc_all_get(user_id)
-            if r is not None:
-                return jsonify({
-                    "success": True,
-                    "value": r
-                })
-            else:
-                return error_return(108)
-        else:
-            return error_return(108)
-    except:
-        return error_return(108)
-
-
-@app.route('/coffee/12/user/me/save', methods=['POST'])  # 向云端同步
-def cloud_post():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
+@app.route('/latte/13/user/me/save', methods=['POST'])  # 向云端同步
+@server.auth.auth_required(request)
+def cloud_post(user_id):
    scores_data = request.form['scores_data']
    clearlamps_data = request.form['clearlamps_data']
    clearedsongs_data = request.form['clearedsongs_data']
@@ -445,80 +345,82 @@ def cloud_post():
    installid_data = request.form['installid_data']
    devicemodelname_data = request.form['devicemodelname_data']
    story_data = request.form['story_data']
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            server.arcscore.arc_all_post(user_id, scores_data, clearlamps_data, clearedsongs_data,
-                                         unlocklist_data, installid_data, devicemodelname_data, story_data)
+
+    server.arcscore.arc_all_post(user_id, scores_data, clearlamps_data, clearedsongs_data,
+                                 unlocklist_data, installid_data, devicemodelname_data, story_data)
+    return jsonify({
+        "success": True,
+        "value": {
+            "user_id": user_id
+        }
+    })
+
+
+@app.route('/latte/13/purchase/me/redeem', methods=['POST'])  # 兑换码
+@server.auth.auth_required(request)
+def redeem(user_id):
+    code = request.form['code']
+    fragment, error_code = server.arcpurchase.claim_user_redeem(
+        user_id, code)
+    if not error_code:
+        if fragment > 0:
            return jsonify({
                "success": True,
-                "value": {
-                    "user_id": user_id
-                }
+                "value": {"coupon": "fragment"+str(fragment)}
            })
        else:
-            return error_return(108)
-    except:
-        return error_return(108)
-
-
-@app.route('/coffee/12/purchase/me/redeem', methods=['POST'])  # 兑换码，依然没有用
-def redeem():
-    return error_return(504)
+            return jsonify({
+                "success": True,
+                "value": {"coupon": ""}
+            })
+    else:
+        return error_return(error_code)


 # 礼物确认
-@app.route('/coffee/12/present/me/claim/<present_id>', methods=['POST'])
-def claim_present(present_id):
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            flag = server.arcpurchase.claim_user_present(user_id, present_id)
-            if flag:
-                return jsonify({
-                    "success": True
-                })
-            else:
-                return error_return(108)
-        else:
-            return error_return(108)
-    except:
+@app.route('/latte/13/present/me/claim/<present_id>', methods=['POST'])
+@server.auth.auth_required(request)
+def claim_present(user_id, present_id):
+    flag = server.arcpurchase.claim_user_present(user_id, present_id)
+    if flag:
+        return jsonify({
+            "success": True
+        })
+    else:
        return error_return(108)


-# 购买，为了world模式boost一下
-@app.route('/coffee/12/purchase/me/item', methods=['POST'])
-def item():
+@app.route('/latte/13/purchase/me/item', methods=['POST'])  # 购买，world模式boost
+@server.auth.auth_required(request)
+def prog_boost(user_id):
+    re = {"success": False}
+    if 'item_id' in request.form:
+        if request.form['item_id'] == 'prog_boost_300':
+            ticket, error_code = server.arcpurchase.get_prog_boost(user_id)
+            if error_code:
+                return error_return(error_code)
+
+            re = {
+                "success": True,
+                "value": {'ticket': ticket}
+            }
+    return jsonify(re)
+
+
+@app.route('/latte/13/purchase/me/pack', methods=['POST'])  # 曲包和单曲购买
+@server.auth.auth_required(request)
+def pack(user_id):
+    if 'pack_id' in request.form:
+        return jsonify(server.arcpurchase.buy_pack(user_id, request.form['pack_id']))
+    if 'single_id' in request.form:
+        return jsonify(server.arcpurchase.buy_single(user_id, request.form['single_id']))
+
    return jsonify({
        "success": True
    })


-@app.route('/coffee/12/purchase/me/pack', methods=['POST'])  # 曲包和单曲购买
-def pack():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id:
-            if 'pack_id' in request.form:
-                return jsonify(server.arcpurchase.buy_pack(user_id, request.form['pack_id']))
-            if 'single_id' in request.form:
-                return jsonify(server.arcpurchase.buy_single(user_id, request.form['single_id']))
-        else:
-            return error_return(108)
-    except:
-        return error_return(108)
-    return jsonify({
-        "success": True
-    })
-
-
-@app.route('/coffee/12/purchase/bundle/single', methods=['GET'])  # 单曲购买信息获取
+@app.route('/latte/13/purchase/bundle/single', methods=['GET'])  # 单曲购买信息获取
 def single():
    return jsonify({
        "success": True,
@@ -526,103 +428,66 @@ def single():
    })


-@app.route('/coffee/12/world/map/me', methods=['GET'])  # 获得世界模式信息，所有地图
-def world_all():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-
-        user_id = server.auth.token_get_id(token)
-        if user_id:
-            return jsonify({
-                "success": True,
-                "value": {
-                    "current_map": server.arcworld.get_current_map(user_id),
-                    "user_id": user_id,
-                    "maps": server.arcworld.get_world_all(user_id)
-                }
-            })
-        else:
-            return error_return(108)
-    except:
-        return error_return(108)
+@app.route('/latte/13/world/map/me', methods=['GET'])  # 获得世界模式信息，所有地图
+@server.auth.auth_required(request)
+def world_all(user_id):
+    return jsonify({
+        "success": True,
+        "value": {
+            "current_map": server.arcworld.get_current_map(user_id),
+            "user_id": user_id,
+            "maps": server.arcworld.get_world_all(user_id)
+        }
+    })


-@app.route('/coffee/12/world/map/me/', methods=['POST'])  # 进入地图
-def world_in():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
+@app.route('/latte/13/world/map/me/', methods=['POST'])  # 进入地图
+@server.auth.auth_required(request)
+def world_in(user_id):
    map_id = request.form['map_id']
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id:
-            return jsonify({
-                "success": True,
-                "value": server.arcworld.get_user_world(user_id, map_id)
-            })
-        else:
-            return error_return(108)
-    except:
-        return error_return(108)
+    return jsonify({
+        "success": True,
+        "value": server.arcworld.get_user_world(user_id, map_id)
+    })


-@app.route('/coffee/12/world/map/me/<map_id>', methods=['GET'])  # 获得单个地图完整信息
-def world_one(map_id):
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id:
-            server.arcworld.change_user_current_map(user_id, map_id)
-            return jsonify({
-                "success": True,
-                "value": {
-                    "user_id": user_id,
-                    "current_map": map_id,
-                    "maps": [server.arcworld.get_user_world_info(user_id, map_id)]
-                }
-            })
-        else:
-            return error_return(108)
-    except:
-        return error_return(108)
+@app.route('/latte/13/world/map/me/<map_id>', methods=['GET'])  # 获得单个地图完整信息
+@server.auth.auth_required(request)
+def world_one(user_id, map_id):
+    server.arcworld.change_user_current_map(user_id, map_id)
+    return jsonify({
+        "success": True,
+        "value": {
+            "user_id": user_id,
+            "current_map": map_id,
+            "maps": [server.arcworld.get_user_world_info(user_id, map_id)]
+        }
+    })


-@app.route('/coffee/12/serve/download/me/song', methods=['GET'])  # 歌曲下载
-def download_song():
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
+@app.route('/latte/13/serve/download/me/song', methods=['GET'])  # 歌曲下载
+@server.auth.auth_required(request)
+def download_song(user_id):
    song_ids = request.args.getlist('sid')
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id:
-            if server.arcdownload.is_able_download(user_id):
-                re = {}
-                if not song_ids:
-                    re = server.arcdownload.get_all_songs(user_id)
-                else:
-                    re = server.arcdownload.get_some_songs(user_id, song_ids)
-
-                return jsonify({
-                    "success": True,
-                    "value": re
-                })
-            else:
-                return error_return(903)
+    if server.arcdownload.is_able_download(user_id):
+        re = {}
+        if not song_ids:
+            re = server.arcdownload.get_all_songs(user_id)
        else:
-            return error_return(108)
-    except:
-        return error_return(108)
+            re = server.arcdownload.get_some_songs(user_id, song_ids)
+
+        return jsonify({
+            "success": True,
+            "value": re
+        })
+    else:
+        return error_return(903)


@app.route('/download/<path:file_path>', methods=['GET'])  # 下载
 def download(file_path):
-    t = request.args.get('t')
    try:
+        t = request.args.get('t')
        message = server.arcdownload.is_token_able_download(t)
        if message == 0:
            path = os.path.join('./database/songs', file_path)
@@ -636,38 +501,43 @@ def download(file_path):
        return error_return(108)


-@app.route('/coffee/<path:path>', methods=['POST'])  # 三个设置，写在最后降低优先级
-def sys_set(path):
+@app.route('/latte/<path:path>', methods=['POST'])  # 三个设置，写在最后降低优先级
+@server.auth.auth_required(request)
+def sys_set(user_id, path):
    set_arg = path[10:]
-    headers = request.headers
-    token = headers['Authorization']
-    token = token[7:]
    value = request.form['value']
-
-    try:
-        user_id = server.auth.token_get_id(token)
-        if user_id is not None:
-            server.setme.arc_sys_set(user_id, value, set_arg)
-            r = server.info.arc_aggregate_small(user_id)
-            r['value'] = r['value'][0]['value']
-            return jsonify(r)
-        else:
-            return error_return(108)
-    except:
-        return error_return(108)
+    server.setme.arc_sys_set(user_id, value, set_arg)
+    r = server.info.arc_aggregate_small(user_id)
+    r['value'] = r['value'][0]['value']
+    return jsonify(r)


 def main():
-    config = configparser.ConfigParser()
-    path = r'setting.ini'
-    config.read(path, encoding="utf-8")
-    HOST = config.get('CONFIG', 'HOST')
-    PORT = config.get('CONFIG', 'PORT')
-    app.config.from_mapping(SECRET_KEY='1145141919810')
+    app.config.from_mapping(SECRET_KEY=Config.SECRET_KEY)
    app.register_blueprint(web.login.bp)
    app.register_blueprint(web.index.bp)

-    app.run(HOST, PORT)
+    dictConfig({
+        'version': 1,
+        'formatters': {'default': {
+            'format': '[%(asctime)s] %(levelname)s in %(module)s: %(message)s',
+        }},
+        'root': {
+            'level': 'INFO'
+        }
+    })
+
+    app.logger.info("Start to initialize data in 'songfile' table...")
+    try:
+        error = server.arcdownload.initialize_songfile()
+    except:
+        error = 'Something wrong.'
+    if error:
+        app.logger.warning(error)
+    else:
+        app.logger.info('Complete!')
+
+    app.run(Config.HOST, Config.PORT)


 if __name__ == '__main__':
--- a/version/run.bat
+++ b/version/run.bat
@@ -1 +1 @@
-python main.py
+python -B main.py
--- a/version/server/arcdownload.py
+++ b/version/server/arcdownload.py
@@ -2,10 +2,12 @@ import os
 import hashlib
 from flask import url_for
 import sqlite3
+from server.sql import Connect
 import time
+from setting import Config

-time_limit = 3000  # 每个玩家24小时下载次数限制
-time_gap_limit = 1000  # 下载链接有效秒数
+time_limit = Config.DOWNLOAD_TIMES_LIMIT  # 每个玩家24小时下载次数限制
+time_gap_limit = Config.DOWNLOAD_TIME_GAP_LIMIT  # 下载链接有效秒数


 def get_file_md5(file_path):
@@ -13,13 +15,13 @@ def get_file_md5(file_path):
    if not os.path.isfile(file_path):
        return None
    myhash = hashlib.md5()
-    f = open(file_path, 'rb')
-    while True:
-        b = f.read(8096)
-        if not b:
-            break
-        myhash.update(b)
-    f.close()
+    with open(file_path, 'rb') as f:
+        while True:
+            b = f.read(8096)
+            if not b:
+                break
+            myhash.update(b)
+
    return myhash.hexdigest()


@@ -38,12 +40,27 @@ def get_one_song(c, user_id, song_id, file_dir='./database/songs'):
            token = token[:8]

            if i == 'base.ogg':
-                re['audio'] = {"checksum": get_file_md5(os.path.join(file_dir, song_id, 'base.ogg')),
+                c.execute(
+                    '''select md5 from songfile where song_id=:a and file_type=-1''', {'a': song_id})
+                x = c.fetchone()
+                if x:
+                    checksum = x[0]
+                else:
+                    checksum = get_file_md5(os.path.join(
+                        file_dir, song_id, 'base.ogg'))
+                re['audio'] = {"checksum": checksum,
                               "url": url_for('download', file_path=song_id+'/base.ogg', t=token, _external=True)}
            else:
                if 'chart' not in re:
                    re['chart'] = {}
-                re['chart'][i[0]] = {"checksum": get_file_md5(os.path.join(file_dir, song_id, i)),
+                c.execute(
+                    '''select md5 from songfile where song_id=:a and file_type=:b''', {'a': song_id, 'b': int(i[0])})
+                x = c.fetchone()
+                if x:
+                    checksum = x[0]
+                else:
+                    checksum = get_file_md5(os.path.join(file_dir, song_id, i))
+                re['chart'][i[0]] = {"checksum": checksum,
                                     "url": url_for('download', file_path=song_id+'/'+i, t=token, _external=True)}

            c.execute('''insert into download_token values(:a,:b,:c,:d,:e)''', {
@@ -56,72 +73,103 @@ def get_all_songs(user_id, file_dir='./database/songs'):
    # 获取所有歌的下载链接，返回字典
    dir_list = os.listdir(file_dir)
    re = {}
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    for i in dir_list:
-        if os.path.isdir(os.path.join(file_dir, i)):
-            re.update(get_one_song(c, user_id, i))
+    with Connect() as c:
+        for i in dir_list:
+            if os.path.isdir(os.path.join(file_dir, i)):
+                re.update(get_one_song(c, user_id, i, file_dir))

-    conn.commit()
-    conn.close()
    return re


 def get_some_songs(user_id, song_ids):
    # 获取一些歌的下载链接，返回字典
    re = {}
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    for song_id in song_ids:
-        re.update(get_one_song(c, user_id, song_id))
+    with Connect() as c:
+        for song_id in song_ids:
+            re.update(get_one_song(c, user_id, song_id))

-    conn.commit()
-    conn.close()
    return re


 def is_token_able_download(t):
    # token是否可以下载，返回错误码，0即可以
-    errorcode = 0
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select * from download_token where token = :t limit 1''',
-              {'t': t})
-    x = c.fetchone()
-    now = int(time.time())
-    if x and now - x[4] <= time_gap_limit:
-        c.execute(
-            '''select count(*) from user_download where user_id = :a''', {'a': x[0]})
-        y = c.fetchone()
-        if y and y[0] <= time_limit:
-            c.execute('''insert into user_download values(:a,:b,:c)''', {
-                      'a': x[0], 'b': x[3], 'c': now})
+    errorcode = 108
+    with Connect() as c:
+        c.execute('''select * from download_token where token = :t limit 1''',
+                  {'t': t})
+        x = c.fetchone()
+        now = int(time.time())
+        if x and now - x[4] <= time_gap_limit:
+            c.execute(
+                '''select count(*) from user_download where user_id = :a''', {'a': x[0]})
+            y = c.fetchone()
+            if y and y[0] <= time_limit:
+                c.execute('''insert into user_download values(:a,:b,:c)''', {
+                    'a': x[0], 'b': x[3], 'c': now})
+                errorcode = 0
+            else:
+                errorcode = 903
        else:
-            errorcode = 903
-    else:
-        errorcode = 108
+            errorcode = 108

-    conn.commit()
-    conn.close()
    return errorcode


 def is_able_download(user_id):
    # 是否可以下载，返回布尔值
-    f = True
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    now = int(time.time())
-    c.execute(
-        '''delete from user_download where user_id = :a and time <= :b''', {'a': user_id, 'b': now - 24*3600})
-    c.execute(
-        '''select count(*) from user_download where user_id = :a''', {'a': user_id})
-    y = c.fetchone()
-    if y and y[0] <= time_limit:
-        pass
-    else:
-        f = False
+    f = False
+    with Connect() as c:
+        now = int(time.time())
+        c.execute(
+            '''delete from user_download where user_id = :a and time <= :b''', {'a': user_id, 'b': now - 24*3600})
+        c.execute(
+            '''select count(*) from user_download where user_id = :a''', {'a': user_id})
+        y = c.fetchone()
+        if y and y[0] <= time_limit:
+            f = True
+        else:
+            f = False

-    conn.commit()
-    conn.close()
    return f
+
+
+def initialize_one_songfile(c, song_id, file_dir='./database/songs'):
+    # 计算并添加歌曲md5到表中，无返回
+    dir_list = os.listdir(os.path.join(file_dir, song_id))
+    for i in dir_list:
+        if os.path.isfile(os.path.join(file_dir, song_id, i)) and i in ['0.aff', '1.aff', '2.aff', '3.aff', 'base.ogg']:
+            if i == 'base.ogg':
+                c.execute('''insert into songfile values(:a,-1,:c)''', {
+                          'a': song_id, 'c': get_file_md5(os.path.join(file_dir, song_id, 'base.ogg'))})
+            else:
+                c.execute('''insert into songfile values(:a,:b,:c)''', {
+                          'a': song_id, 'b': int(i[0]), 'c': get_file_md5(os.path.join(file_dir, song_id, i))})
+
+    return
+
+
+def initialize_songfile(file_dir='./database/songs'):
+    # 初始化歌曲数据的md5表，返回错误信息
+    error = None
+    try:
+        dir_list = os.listdir(file_dir)
+    except:
+        error = 'OS error!'
+        return error
+    try:
+        conn = sqlite3.connect('./database/arcaea_database.db')
+        c = conn.cursor()
+    except:
+        error = 'Database error!'
+        return error
+    try:
+        c.execute('''delete from songfile''')
+        for i in dir_list:
+            if os.path.isdir(os.path.join(file_dir, i)):
+                initialize_one_songfile(c, i, file_dir)
+    except:
+        error = 'Initialization error!'
+    finally:
+        conn.commit()
+        conn.close()
+        return error
--- a/version/server/arcpurchase.py
+++ b/version/server/arcpurchase.py
@@ -1,4 +1,4 @@
-import sqlite3
+from server.sql import Connect
 import time
 import json

@@ -41,87 +41,91 @@ def get_item(c, type='pack'):

 def get_single_purchase():
    # main里面没开数据库，这里写一下代替
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    re = get_item(c, type='single')
-    conn.commit()
-    conn.close()
+    re = []
+    with Connect() as c:
+        re = get_item(c, type='single')
+
    return re


+def buy_item(c, user_id, price):
+    # 购买接口，返回成功与否标识符和剩余源点数
+    c.execute('''select ticket from user where user_id = :a''',
+              {'a': user_id})
+    ticket = c.fetchone()
+    if ticket:
+        ticket = ticket[0]
+    else:
+        ticket = 0
+
+    if ticket < price:
+        return False, ticket
+
+    c.execute('''update user set ticket = :b where user_id = :a''',
+              {'a': user_id, 'b': ticket-price})
+
+    return True, ticket - price
+
+
 def buy_pack(user_id, pack_id):
    # 曲包购买，返回字典
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select price from item where item_id = :a''', {'a': pack_id})
-    price = c.fetchone()
-    if price:
-        price = price[0]
-    else:
-        price = 0
+    re = {"success": False}
+    with Connect() as c:
+        c.execute('''select price from item where item_id = :a''',
+                  {'a': pack_id})
+        price = c.fetchone()
+        if price:
+            price = price[0]
+        else:
+            price = 0

-    c.execute('''select ticket from user where user_id = :a''', {'a': user_id})
-    ticket = c.fetchone()
-    if ticket:
-        ticket = ticket[0]
-    else:
-        ticket = 0
+        flag, ticket = buy_item(c, user_id, price)

-    if ticket < price:
-        conn.commit()
-        conn.close()
-        return {
-            "success": False
-        }
+        if flag:
+            c.execute('''insert into user_item values(:a,:b,'pack')''',
+                      {'a': user_id, 'b': pack_id})

-    c.execute('''update user set ticket = :b where user_id = :a''',
-              {'a': user_id, 'b': ticket-price})
-    c.execute('''insert into user_item values(:a,:b,'pack')''',
-              {'a': user_id, 'b': pack_id})
+            re = {"success": True}

-    conn.commit()
-    conn.close()
-    return {
-        "success": True
-    }
+    return re


 def buy_single(user_id, single_id):
    # 单曲购买，返回字典
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select price from item where item_id = :a''',
-              {'a': single_id})
-    price = c.fetchone()
-    if price:
-        price = price[0]
+    re = {"success": False}
+    with Connect() as c:
+        c.execute('''select price from item where item_id = :a''',
+                  {'a': single_id})
+        price = c.fetchone()
+        if price:
+            price = price[0]
+        else:
+            price = 0
+
+        flag, ticket = buy_item(c, user_id, price)
+
+        if flag:
+            c.execute('''insert into user_item values(:a,:b,'single')''',
+                      {'a': user_id, 'b': single_id})
+            re = {"success": True}
+
+    return re
+
+
+def get_prog_boost(user_id):
+    # 世界模式源韵强化，扣50源点，返回剩余源点数
+
+    ticket = -1
+    with Connect() as c:
+        flag, ticket = buy_item(c, user_id, 50)
+
+        if flag:
+            c.execute('''update user set prog_boost = 1 where user_id = :a''', {
+                      'a': user_id})
+    if ticket >= 0:
+        return ticket, None
    else:
-        price = 0
-
-    c.execute('''select ticket from user where user_id = :a''', {'a': user_id})
-    ticket = c.fetchone()
-    if ticket:
-        ticket = ticket[0]
-    else:
-        ticket = 0
-
-    if ticket < price:
-        conn.commit()
-        conn.close()
-        return {
-            "success": False
-        }
-
-    c.execute('''update user set ticket = :b where user_id = :a''',
-              {'a': user_id, 'b': ticket-price})
-    c.execute('''insert into user_item values(:a,:b,'single')''',
-              {'a': user_id, 'b': single_id})
-
-    conn.commit()
-    conn.close()
-    return {
-        "success": True
-    }
+        return 0, 108


 def get_user_present(c, user_id):
@@ -146,35 +150,70 @@ def get_user_present(c, user_id):
 def claim_user_present(user_id, present_id):
    # 确认并删除用户奖励，返回成功与否的布尔值
    flag = False
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-
-    c.execute('''select exists(select * from user_present where user_id=:a and present_id=:b)''',
-              {'a': user_id, 'b': present_id})
-    if c.fetchone() == (1,):
-        flag = True
-        c.execute('''delete from user_present where user_id=:a and present_id=:b''',
+    with Connect() as c:
+        c.execute('''select exists(select * from user_present where user_id=:a and present_id=:b)''',
                  {'a': user_id, 'b': present_id})
-        c.execute('''select * from present where present_id=:b''',
-                  {'b': present_id})
-        x = c.fetchone()
-        now = int(time.time() * 1000)
-        if now <= int(x[1]):
-            # 处理memory
-            items = json.loads(x[2])
-            for i in items:
-                if i['id'] == 'memory':
-                    c.execute('''select ticket from user where user_id=:a''', {
-                              'a': user_id})
-                    ticket = int(c.fetchone()[0])
-                    ticket += int(i['amount'])
-                    c.execute('''update user set ticket=:b where user_id=:a''', {
-                              'a': user_id, 'b': ticket})
+        if c.fetchone() == (1,):
+            c.execute('''delete from user_present where user_id=:a and present_id=:b''',
+                      {'a': user_id, 'b': present_id})
+            c.execute('''select * from present where present_id=:b''',
+                      {'b': present_id})
+            x = c.fetchone()
+            now = int(time.time() * 1000)
+            if now <= int(x[1]):
+                # 处理memory
+                items = json.loads(x[2])
+                for i in items:
+                    if i['id'] == 'memory':
+                        c.execute('''select ticket from user where user_id=:a''', {
+                            'a': user_id})
+                        ticket = int(c.fetchone()[0])
+                        ticket += int(i['amount'])
+                        c.execute('''update user set ticket=:b where user_id=:a''', {
+                            'a': user_id, 'b': ticket})
+                flag = True
+            else:
+                # 过期
+                flag = False

-        else:
-            # 过期
-            flag = False
-
-    conn.commit()
-    conn.close()
    return flag
+
+
+def claim_user_redeem(user_id, code):
+    # 处理兑换码，返回碎片数量和错误码
+    fragment = 0
+    error_code = 108
+    with Connect() as c:
+        c.execute('''select * from redeem where code=:a''', {'a': code})
+        x = c.fetchone()
+        if not x:
+            return 0, 504
+
+        if x[2] == 0:  # 一次性
+            c.execute(
+                '''select exists(select * from user_redeem where code=:a)''', {'a': code})
+            if c.fetchone() == (1,):
+                return 0, 505
+        elif x[2] == 1:  # 每个玩家一次
+            c.execute('''select exists(select * from user_redeem where code=:a and user_id=:b)''',
+                      {'a': code, 'b': user_id})
+            if c.fetchone() == (1,):
+                return 0, 506
+
+        c.execute('''insert into user_redeem values(:b,:a)''',
+                  {'a': code, 'b': user_id})
+
+        items = json.loads(x[1])
+        for i in items:
+            if i['type'] == 'fragment':
+                fragment = i['amount']
+            if i['type'] == 'memory':
+                c.execute('''select ticket from user where user_id=:a''', {
+                    'a': user_id})
+                ticket = int(c.fetchone()[0])
+                ticket += int(i['amount'])
+                c.execute('''update user set ticket=:b where user_id=:a''', {
+                    'a': user_id, 'b': ticket})
+        error_code = None
+
+    return fragment, error_code
--- a/version/server/arcscore.py
+++ b/version/server/arcscore.py
--- a/version/server/arcworld.py
+++ b/version/server/arcworld.py
@@ -1,5 +1,5 @@
 import json
-import sqlite3
+from server.sql import Connect
 import os


@@ -23,64 +23,17 @@ def get_world_name(file_dir='./database/map'):

 def get_world_info(map_id):
    # 读取json文件内容，返回字典
-    f = open('./database/map/'+map_id+'.json', 'r')
-    world_info = json.load(f)
-    f.close()
+    world_info = {}
+    with open('./database/map/'+map_id+'.json', 'r') as f:
+        world_info = json.load(f)
+
    return world_info


 def get_user_world_info(user_id, map_id):
    # 读取json文件内容，加上用户信息，返回字典
    info = get_world_info(map_id)
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select * from user_world where map_id = :a and user_id = :b''',
-              {'a': map_id, 'b': user_id})
-    x = c.fetchone()
-    if x:
-        info['curr_position'] = x[2]
-        info['curr_capture'] = x[3]
-        info['is_locked'] = int2b(x[4])
-    else:
-        c.execute('''insert into user_world values(:a,:b,0,0,0)''', {
-            'a': user_id, 'b': map_id})
-    conn.commit()
-    conn.close()
-    return info
-
-
-def get_current_map(user_id):
-    # 得到user的当前图，返回字符串
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select current_map from user where user_id = :a''',
-              {'a': user_id})
-    x = c.fetchone()
-    re = ''
-    if x:
-        re = x[0]
-
-    conn.commit()
-    conn.close()
-    return re
-
-
-def get_world_all(user_id):
-    # 读取所有地图信息并处理，返回字典列表
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    worlds = get_world_name()
-    re = []
-    for map_id in worlds:
-        info = get_world_info(map_id)
-        steps = info['steps']
-        del info['steps']
-        rewards = []
-        for step in steps:
-            if 'items' in step:
-                rewards.append(
-                    {'items': step['items'], 'position': step['position']})
-        info['rewards'] = rewards
+    with Connect() as c:
        c.execute('''select * from user_world where map_id = :a and user_id = :b''',
                  {'a': map_id, 'b': user_id})
        x = c.fetchone()
@@ -90,75 +43,110 @@ def get_world_all(user_id):
            info['is_locked'] = int2b(x[4])
        else:
            c.execute('''insert into user_world values(:a,:b,0,0,0)''', {
-                      'a': user_id, 'b': map_id})
+                'a': user_id, 'b': map_id})

-        re.append(info)
+    return info
+
+
+def get_current_map(user_id):
+    # 得到user的当前图，返回字符串
+    re = ''
+    with Connect() as c:
+        c.execute('''select current_map from user where user_id = :a''',
+                  {'a': user_id})
+        x = c.fetchone()
+        if x:
+            re = x[0]
+
+    return re
+
+
+def get_world_all(user_id):
+    # 读取所有地图信息并处理，返回字典列表
+    re = []
+    with Connect() as c:
+        worlds = get_world_name()
+        for map_id in worlds:
+            info = get_world_info(map_id)
+            steps = info['steps']
+            del info['steps']
+            rewards = []
+            for step in steps:
+                if 'items' in step:
+                    rewards.append(
+                        {'items': step['items'], 'position': step['position']})
+            info['rewards'] = rewards
+            c.execute('''select * from user_world where map_id = :a and user_id = :b''',
+                      {'a': map_id, 'b': user_id})
+            x = c.fetchone()
+            if x:
+                info['curr_position'] = x[2]
+                info['curr_capture'] = x[3]
+                info['is_locked'] = int2b(x[4])
+            else:
+                c.execute('''insert into user_world values(:a,:b,0,0,0)''', {
+                    'a': user_id, 'b': map_id})
+
+            re.append(info)

-    conn.commit()
-    conn.close()
    return re


 def get_user_world(user_id, map_id):
    # 获取用户图信息，返回字典
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select * from user_world where map_id = :a and user_id = :b''',
-              {'a': map_id, 'b': user_id})
-    x = c.fetchone()
-    re = {
-        "user_id": user_id,
-        "curr_position": 0,
-        "curr_capture": 0,
-        "is_locked": False,
-        "map_id": map_id
-    }
-    if x:
-        re['curr_position'] = x[2]
-        re['curr_capture'] = x[3]
-        re['is_locked'] = int2b(x[4])
-    else:
-        c.execute('''insert into user_world values(:a,:b,0,0,0)''', {
-            'a': user_id, 'b': map_id})
+    re = {}
+    with Connect() as c:
+        c.execute('''select * from user_world where map_id = :a and user_id = :b''',
+                  {'a': map_id, 'b': user_id})
+        x = c.fetchone()
+        re = {
+            "user_id": user_id,
+            "curr_position": 0,
+            "curr_capture": 0,
+            "is_locked": False,
+            "map_id": map_id
+        }
+        if x:
+            re['curr_position'] = x[2]
+            re['curr_capture'] = x[3]
+            re['is_locked'] = int2b(x[4])
+        else:
+            c.execute('''insert into user_world values(:a,:b,0,0,0)''', {
+                'a': user_id, 'b': map_id})

-    conn.commit()
-    conn.close()
    return re


 def change_user_current_map(user_id, map_id):
    # 改变用户当前图
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''update user set current_map = :a where user_id=:b''', {
-              'a': map_id, 'b': user_id})
-    conn.commit()
-    conn.close()
+    with Connect() as c:
+        c.execute('''update user set current_map = :a where user_id=:b''', {
+            'a': map_id, 'b': user_id})
    return None


 def play_world_song(user_id, args):
    # 声明是世界模式的打歌，并且记录加成信息
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
+    with Connect() as c:
+        stamina_multiply = 1
+        fragment_multiply = 100
+        prog_boost_multiply = 0
+        if 'stamina_multiply' in args:
+            stamina_multiply = int(args['stamina_multiply'])
+        if 'fragment_multiply' in args:
+            fragment_multiply = int(args['fragment_multiply'])
+        if 'prog_boost_multiply' in args:
+            c.execute('''select prog_boost from user where user_id=:a''', {
+                      'a': user_id})
+            x = c.fetchone()
+            if x and x[0] == 1:
+                prog_boost_multiply = 300

-    stamina_multiply = 1
-    fragment_multiply = 100
-    prog_boost_multiply = 0
-    if 'stamina_multiply' in args:
-        stamina_multiply = int(args['stamina_multiply'])
-    if 'fragment_multiply' in args:
-        fragment_multiply = int(args['fragment_multiply'])
-    if 'prog_boost_multiply' in args:
-        prog_boost_multiply = int(args['prog_boost_multiply'])
+        c.execute('''delete from world_songplay where user_id=:a and song_id=:b and difficulty=:c''', {
+            'a': user_id, 'b': args['song_id'], 'c': args['difficulty']})
+        c.execute('''insert into world_songplay values(:a,:b,:c,:d,:e,:f)''', {
+            'a': user_id, 'b': args['song_id'], 'c': args['difficulty'], 'd': stamina_multiply, 'e': fragment_multiply, 'f': prog_boost_multiply})

-    c.execute('''delete from world_songplay where user_id=:a and song_id=:b and difficulty=:c''', {
-              'a': user_id, 'b': args['song_id'], 'c': args['difficulty']})
-    c.execute('''insert into world_songplay values(:a,:b,:c,:d,:e,:f)''', {
-              'a': user_id, 'b': args['song_id'], 'c': args['difficulty'], 'd': stamina_multiply, 'e': fragment_multiply, 'f': prog_boost_multiply})
-
-    conn.commit()
-    conn.close()
    return None


--- a/version/server/auth.py
+++ b/version/server/auth.py
@@ -1,43 +1,71 @@
-import sqlite3
 import hashlib
 import time
 import server.arcworld
+from server.sql import Connect
+import functools
+from setting import Config


-def arc_login(name: str, password: str) -> str:  # 登录判断
-    # 查询数据库中的user表，验证账号密码，返回并记录token
+def arc_login(name: str, password: str, device_id: str):  # 登录判断
+    # 查询数据库中的user表，验证账号密码，返回并记录token，多返回个error code
    # token采用user_id和时间戳连接后hash生成（真的是瞎想的，没用bear）
    # 密码和token的加密方式为 SHA-256

-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    hash_pwd = hashlib.sha256(password.encode("utf8")).hexdigest()
-    c.execute('''select user_id from user where name = :name and password = :password''', {
-              'name': name, 'password': hash_pwd})
-    x = c.fetchone()
-    if x is not None:
-        user_id = str(x[0])
-        now = int(time.time() * 1000)
-        token = hashlib.sha256((user_id + str(now)).encode("utf8")).hexdigest()
-        c.execute(
-            '''select exists(select * from login where user_id = :user_id)''', {"user_id": user_id})
+    error_code = 108
+    token = None
+    with Connect() as c:
+        hash_pwd = hashlib.sha256(password.encode("utf8")).hexdigest()
+        c.execute('''select user_id, password from user where name = :name''', {
+            'name': name})
+        x = c.fetchone()
+        if x is not None:
+            if x[1] == '':
+                # 账号封禁
+                error_code = 106
+            elif x[1] == hash_pwd:
+                user_id = str(x[0])
+                now = int(time.time() * 1000)
+                token = hashlib.sha256(
+                    (user_id + str(now)).encode("utf8")).hexdigest()
+                c.execute(
+                    '''select login_device from login where user_id = :user_id''', {"user_id": user_id})
+                y = c.fetchall()
+                if y:
+                    device_list = []
+                    for i in y:
+                        if i[0]:
+                            device_list.append(i[0])
+                        else:
+                            device_list.append('')

-        if c.fetchone() == (1,):  # 删掉多余token
-            c.execute('''delete from login where user_id = :user_id''',
-                      {'user_id': user_id})
+                    should_delete_num = len(
+                        device_list) + 1 - Config.LOGIN_DEVICE_NUMBER_LIMIT

-        c.execute('''insert into login(access_token, user_id) values(:access_token, :user_id)''', {
-                  'user_id': user_id, 'access_token': token})
-        conn.commit()
-        conn.close()
-        return token
+                    if not Config.ALLOW_LOGIN_SAME_DEVICE:
+                        if device_id in device_list:  # 对相同设备进行删除
+                            c.execute('''delete from login where login_device=:a''', {
+                                'a': device_id})
+                            should_delete_num = len(
+                                device_list) + 1 - device_list.count(device_id) - Config.LOGIN_DEVICE_NUMBER_LIMIT

-    conn.commit()
-    conn.close()
-    return None
+                    if should_delete_num >= 1:  # 删掉多余token
+                        c.execute('''delete from login where rowid in (select rowid from login where user_id=:user_id limit :a);''',
+                                  {'user_id': user_id, 'a': int(should_delete_num)})
+
+                c.execute('''insert into login(access_token, user_id, login_device) values(:access_token, :user_id, :device_id)''', {
+                    'user_id': user_id, 'access_token': token, 'device_id': device_id})
+                error_code = None
+            else:
+                # 密码错误
+                error_code = 104
+        else:
+            # 用户名错误
+            error_code = 104
+
+    return token, error_code


-def arc_register(name: str, password: str):  # 注册
+def arc_register(name: str, password: str, device_id: str):  # 注册
    # 账号注册，只记录hash密码和用户名，生成user_id和user_code，自动登录返回token
    # token和密码的处理同登录部分

@@ -71,68 +99,83 @@ def arc_register(name: str, password: str):  # 注册
                c.execute('''insert into user_char values(:a,:b,:c,:d,:e,:f,:g,:h,:i,:j,:k,:l,:m,:n,:o)''', {
                          'a': user_id, 'b': i[0], 'c': i[2], 'd': i[3], 'e': i[4], 'f': i[5], 'g': i[6], 'h': i[7], 'i': i[8], 'j': i[9], 'k': i[10], 'l': i[11], 'm': i[12], 'n': i[14], 'o': i[15]})

-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    hash_pwd = hashlib.sha256(password.encode("utf8")).hexdigest()
-    c.execute(
-        '''select exists(select * from user where name = :name)''', {'name': name})
-    if c.fetchone() == (0,):
-        user_code = build_user_code(c)
-        user_id = build_user_id(c)
-        now = int(time.time() * 1000)
-        c.execute('''insert into user(user_id, name, password, join_date, user_code, rating_ptt, 
-        character_id, is_skill_sealed, is_char_uncapped, is_char_uncapped_override, is_hide_rating, favorite_character, max_stamina_notification_enabled, current_map, ticket)
-        values(:user_id, :name, :password, :join_date, :user_code, 0, 0, 0, 0, 0, 0, -1, 0, '', 0)
-        ''', {'user_code': user_code, 'user_id': user_id, 'join_date': now, 'name': name, 'password': hash_pwd})
-        c.execute('''insert into recent30(user_id) values(:user_id)''', {
-                  'user_id': user_id})
+    user_id = None
+    token = None
+    error_code = 108
+    with Connect() as c:
+        hash_pwd = hashlib.sha256(password.encode("utf8")).hexdigest()
+        c.execute(
+            '''select exists(select * from user where name = :name)''', {'name': name})
+        if c.fetchone() == (0,):
+            user_code = build_user_code(c)
+            user_id = build_user_id(c)
+            now = int(time.time() * 1000)
+            c.execute('''insert into user(user_id, name, password, join_date, user_code, rating_ptt, 
+            character_id, is_skill_sealed, is_char_uncapped, is_char_uncapped_override, is_hide_rating, favorite_character, max_stamina_notification_enabled, current_map, ticket)
+            values(:user_id, :name, :password, :join_date, :user_code, 0, 0, 0, 0, 0, 0, -1, 0, '', 0)
+            ''', {'user_code': user_code, 'user_id': user_id, 'join_date': now, 'name': name, 'password': hash_pwd})
+            c.execute('''insert into recent30(user_id) values(:user_id)''', {
+                'user_id': user_id})

-        token = hashlib.sha256(
-            (str(user_id) + str(now)).encode("utf8")).hexdigest()
-        c.execute('''insert into login(access_token, user_id) values(:access_token, :user_id)''', {
-                  'user_id': user_id, 'access_token': token})
+            token = hashlib.sha256(
+                (str(user_id) + str(now)).encode("utf8")).hexdigest()
+            c.execute('''insert into login(access_token, user_id, login_device) values(:access_token, :user_id, :device_id)''', {
+                'user_id': user_id, 'access_token': token, 'device_id': device_id})

-        insert_user_char(c, user_id)
-        conn.commit()
-        conn.close()
-        return user_id, token, 0
-    else:
-        conn.commit()
-        conn.close()
-        return None, None, 101
+            insert_user_char(c, user_id)
+            error_code = 0
+        else:
+            error_code = 101
+
+    return user_id, token, error_code


 def token_get_id(token: str):
    # 用token获取id，没有考虑不同用户token相同情况，说不定会有bug

-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select user_id from login where access_token = :token''', {
-              'token': token})
-    x = c.fetchone()
-    if x is not None:
-        conn.commit()
-        conn.close()
-        return x[0]
-    else:
-        conn.commit()
-        conn.close()
-        return None
+    user_id = None
+    with Connect() as c:
+        c.execute('''select user_id from login where access_token = :token''', {
+            'token': token})
+        x = c.fetchone()
+        if x is not None:
+            user_id = x[0]
+
+    return user_id


 def code_get_id(user_code):
    # 用user_code获取id

-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select user_id from user where user_code = :a''',
-              {'a': user_code})
-    x = c.fetchone()
-    if x is not None:
-        conn.commit()
-        conn.close()
-        return x[0]
-    else:
-        conn.commit()
-        conn.close()
-        return None
+    user_id = None
+
+    with Connect() as c:
+        c.execute('''select user_id from user where user_code = :a''',
+                  {'a': user_code})
+        x = c.fetchone()
+        if x is not None:
+            user_id = x[0]
+
+    return user_id
+
+
+def auth_required(request):
+    # arcaea登录验证，写成了修饰器
+    def decorator(view):
+        @functools.wraps(view)
+        def wrapped_view(*args, **kwargs):
+
+            user_id = None
+            with Connect() as c:
+                headers = request.headers
+                token = headers['Authorization']
+                token = token[7:]
+                user_id = token_get_id(token)
+
+            if user_id is not None:
+                return view(user_id, *args, **kwargs)
+            else:
+                return '''{"success":false,"error_code":108}'''
+
+        return wrapped_view
+    return decorator
--- a/version/server/info.py
+++ b/version/server/info.py
@@ -1,4 +1,4 @@
-import sqlite3
+from server.sql import Connect
 import server.arcworld
 import server.arcpurchase
 import time
@@ -170,6 +170,9 @@ def get_value_0(c, user_id):
        characters = []
        for i in user_character:
            characters.append(i['character_id'])
+        prog_boost = 0
+        if x[27] and x[27] != 0:
+            prog_boost = 300

        r = {"is_aprilfools": False,
             "curr_available_maps": [],
@@ -189,12 +192,12 @@ def get_value_0(c, user_id):
             "is_locked_name_duplicate": False,
             "is_skill_sealed": int2b(x[7]),
             "current_map": x[25],
-             "prog_boost": 0,
+             "prog_boost": prog_boost,
             "next_fragstam_ts": -1,
             "max_stamina_ts": 1586274871917,
             "stamina": 12,
             "world_unlocks": ["scenery_chap1", "scenery_chap2", "scenery_chap3", "scenery_chap4", "scenery_chap5"],
-             "world_songs": ["babaroque", "shadesoflight", "kanagawa", "lucifer", "anokumene", "ignotus", "rabbitintheblackroom", "qualia", "redandblue", "bookmaker", "darakunosono", "espebranch", "blacklotus", "givemeanightmare", "vividtheory", "onefr", "gekka", "vexaria3", "infinityheaven3", "fairytale3", "goodtek3", "suomi", "rugie", "faintlight", "harutopia", "goodtek", "dreaminattraction", "syro", "diode", "freefall", "grimheart", "blaster", "cyberneciacatharsis", "monochromeprincess", "revixy", "vector", "supernova", "nhelv", "purgatorium3", "dement3", "crossover", "guardina", "axiumcrisis", "worldvanquisher", "sheriruth", "pragmatism", "gloryroad", "etherstrike", "corpssansorganes", "lostdesire", "blrink", "essenceoftwilight", "lapis", "solitarydream", "lumia3", "purpleverse"],
+             "world_songs": ["babaroque", "shadesoflight", "kanagawa", "lucifer", "anokumene", "ignotus", "rabbitintheblackroom", "qualia", "redandblue", "bookmaker", "darakunosono", "espebranch", "blacklotus", "givemeanightmare", "vividtheory", "onefr", "gekka", "vexaria3", "infinityheaven3", "fairytale3", "goodtek3", "suomi", "rugie", "faintlight", "harutopia", "goodtek", "dreaminattraction", "syro", "diode", "freefall", "grimheart", "blaster", "cyberneciacatharsis", "monochromeprincess", "revixy", "vector", "supernova", "nhelv", "purgatorium3", "dement3", "crossover", "guardina", "axiumcrisis", "worldvanquisher", "sheriruth", "pragmatism", "gloryroad", "etherstrike", "corpssansorganes", "lostdesire", "blrink", "essenceoftwilight", "lapis", "solitarydream", "lumia3", "purpleverse", "moonheart3", "glow", "enchantedlove", "take"],
             "singles": get_user_singles(c, user_id),  # ["dataerror", "yourvoiceso", "crosssoul", "impurebird", "auxesia", "modelista", "yozakurafubuki", "surrender", "metallicpunisher", "carminescythe", "bethere", "callmyname", "fallensquare", "dropdead", "alexandrite", "astraltale", "phantasia", "empireofwinter", "libertas", "dottodot", "dreadnought", "mirzam", "heavenlycaress", "filament", "avantraze", "battlenoone", "saikyostronger", "izana", "einherjar", "laqryma", "amygdata", "altale", "feelssoright", "scarletcage", "teriqma", "mahoroba", "badtek", "maliciousmischance", "buchigireberserker", "galaxyfriends", "xeraphinite", "xanatos"]
             "packs": get_user_packs(c, user_id),
             # ["vs", "extend", "dynamix", "prelude", "core", "yugamu", "omatsuri", "zettai", "mirai", "shiawase", "chunithm", "nijuusei", "groovecoaster", "rei", "tonesphere", "lanota"]
@@ -211,148 +214,143 @@ def get_value_0(c, user_id):

 def arc_aggregate_small(user_id):
    # 返回用户数据
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    r = {"success": True,
-         "value": [{
-             "id": 0,
-             "value": get_value_0(c, user_id)
-         }]}
+    r = {"success": False}
+    with Connect() as c:
+        r = {"success": True,
+             "value": [{
+                 "id": 0,
+                 "value": get_value_0(c, user_id)
+             }]}

-    conn.commit()
-    conn.close()
    return r


 def arc_aggregate_big(user_id):
    # 返回用户数据和地图歌曲信息
-
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    r = {"success": True,
-         "value": [{
-             "id": 0,
-             "value": get_value_0(c, user_id)
-         }, {
-             "id": 1,
-             "value": server.arcpurchase.get_item(c, 'pack')
-         }, {
-             "id": 2,
-             "value": {}
-         }, {
-             "id": 3,
-             "value": {
-                 "max_stamina": 12,
-                 "stamina_recover_tick": 1800000,
-                 "core_exp": 250,
-                 "curr_ts": int(time.time())*1000,
-                 "level_steps": [{
-                     "level": 1,
-                     "level_exp": 0
-                 }, {
-                     "level": 2,
-                     "level_exp": 50
-                 }, {
-                     "level": 3,
-                     "level_exp": 100
-                 }, {
-                     "level": 4,
-                     "level_exp": 150
-                 }, {
-                     "level": 5,
-                     "level_exp": 200
-                 }, {
-                     "level": 6,
-                     "level_exp": 300
-                 }, {
-                     "level": 7,
-                     "level_exp": 450
-                 }, {
-                     "level": 8,
-                     "level_exp": 650
-                 }, {
-                     "level": 9,
-                     "level_exp": 900
-                 }, {
-                     "level": 10,
-                     "level_exp": 1200
-                 }, {
-                     "level": 11,
-                     "level_exp": 1600
-                 }, {
-                     "level": 12,
-                     "level_exp": 2100
-                 }, {
-                     "level": 13,
-                     "level_exp": 2700
-                 }, {
-                     "level": 14,
-                     "level_exp": 3400
-                 }, {
-                     "level": 15,
-                     "level_exp": 4200
-                 }, {
-                     "level": 16,
-                     "level_exp": 5100
-                 }, {
-                     "level": 17,
-                     "level_exp": 6100
-                 }, {
-                     "level": 18,
-                     "level_exp": 7200
-                 }, {
-                     "level": 19,
-                     "level_exp": 8500
-                 }, {
-                     "level": 20,
-                     "level_exp": 10000
-                 }, {
-                     "level": 21,
-                     "level_exp": 11500
-                 }, {
-                     "level": 22,
-                     "level_exp": 13000
-                 }, {
-                     "level": 23,
-                     "level_exp": 14500
-                 }, {
-                     "level": 24,
-                     "level_exp": 16000
-                 }, {
-                     "level": 25,
-                     "level_exp": 17500
-                 }, {
-                     "level": 26,
-                     "level_exp": 19000
-                 }, {
-                     "level": 27,
-                     "level_exp": 20500
-                 }, {
-                     "level": 28,
-                     "level_exp": 22000
-                 }, {
-                     "level": 29,
-                     "level_exp": 23500
-                 }, {
-                     "level": 30,
-                     "level_exp": 25000
-                 }],
-                 "world_ranking_enabled": False,
-                 "is_byd_chapter_unlocked": True
+    r = {"success": False}
+    with Connect() as c:
+        r = {"success": True,
+             "value": [{
+                 "id": 0,
+                 "value": get_value_0(c, user_id)
+             }, {
+                 "id": 1,
+                 "value": server.arcpurchase.get_item(c, 'pack')
+             }, {
+                 "id": 2,
+                 "value": {}
+             }, {
+                 "id": 3,
+                 "value": {
+                     "max_stamina": 12,
+                     "stamina_recover_tick": 1800000,
+                     "core_exp": 250,
+                     "curr_ts": int(time.time())*1000,
+                     "level_steps": [{
+                         "level": 1,
+                         "level_exp": 0
+                     }, {
+                         "level": 2,
+                         "level_exp": 50
+                     }, {
+                         "level": 3,
+                         "level_exp": 100
+                     }, {
+                         "level": 4,
+                         "level_exp": 150
+                     }, {
+                         "level": 5,
+                         "level_exp": 200
+                     }, {
+                         "level": 6,
+                         "level_exp": 300
+                     }, {
+                         "level": 7,
+                         "level_exp": 450
+                     }, {
+                         "level": 8,
+                         "level_exp": 650
+                     }, {
+                         "level": 9,
+                         "level_exp": 900
+                     }, {
+                         "level": 10,
+                         "level_exp": 1200
+                     }, {
+                         "level": 11,
+                         "level_exp": 1600
+                     }, {
+                         "level": 12,
+                         "level_exp": 2100
+                     }, {
+                         "level": 13,
+                         "level_exp": 2700
+                     }, {
+                         "level": 14,
+                         "level_exp": 3400
+                     }, {
+                         "level": 15,
+                         "level_exp": 4200
+                     }, {
+                         "level": 16,
+                         "level_exp": 5100
+                     }, {
+                         "level": 17,
+                         "level_exp": 6100
+                     }, {
+                         "level": 18,
+                         "level_exp": 7200
+                     }, {
+                         "level": 19,
+                         "level_exp": 8500
+                     }, {
+                         "level": 20,
+                         "level_exp": 10000
+                     }, {
+                         "level": 21,
+                         "level_exp": 11500
+                     }, {
+                         "level": 22,
+                         "level_exp": 13000
+                     }, {
+                         "level": 23,
+                         "level_exp": 14500
+                     }, {
+                         "level": 24,
+                         "level_exp": 16000
+                     }, {
+                         "level": 25,
+                         "level_exp": 17500
+                     }, {
+                         "level": 26,
+                         "level_exp": 19000
+                     }, {
+                         "level": 27,
+                         "level_exp": 20500
+                     }, {
+                         "level": 28,
+                         "level_exp": 22000
+                     }, {
+                         "level": 29,
+                         "level_exp": 23500
+                     }, {
+                         "level": 30,
+                         "level_exp": 25000
+                     }],
+                     "world_ranking_enabled": False,
+                     "is_byd_chapter_unlocked": True
+                 }
+             }, {
+                 "id": 4,
+                 "value": server.arcpurchase.get_user_present(c, user_id)
+             }, {
+                 "id": 5,
+                 "value": {
+                     "current_map": server.arcworld.get_current_map(user_id),
+                     "user_id": user_id,
+                     "maps": server.arcworld.get_world_all(user_id)
+                 }
             }
-         }, {
-             "id": 4,
-             "value": server.arcpurchase.get_user_present(c, user_id)
-         }, {
-             "id": 5,
-             "value": {
-                 "current_map": server.arcworld.get_current_map(user_id),
-                 "user_id": user_id,
-                 "maps": server.arcworld.get_world_all(user_id)
-             }
-         }
-         ]}
+             ]}

-    conn.commit()
-    conn.close()
    return r
--- a/version/server/setme.py
+++ b/version/server/setme.py
@@ -1,4 +1,4 @@
-import sqlite3
+from server.sql import Connect
 import server.info


@@ -20,98 +20,90 @@ def int2b(x):

 def change_char(user_id, character_id, skill_sealed):
    # 角色改变，包括技能封印的改变，返回成功与否的布尔值
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select is_uncapped, is_uncapped_override from user_char where user_id = :a and character_id = :b''',
-              {'a': user_id, 'b': character_id})
-    x = c.fetchone()
-    if x is not None:
-        if skill_sealed == 'false':
-            skill_sealed = False
-        else:
-            skill_sealed = True
-        c.execute('''update user set is_skill_sealed = :a, character_id = :b, is_char_uncapped = :c, is_char_uncapped_override = :d where user_id = :e''', {
-                  'a': b2int(skill_sealed), 'b': character_id, 'c': x[0], 'd': x[1], 'e': user_id})
+    re = False

-        conn.commit()
-        conn.close()
-        return True
+    with Connect() as c:
+        c.execute('''select is_uncapped, is_uncapped_override from user_char where user_id = :a and character_id = :b''',
+                  {'a': user_id, 'b': character_id})
+        x = c.fetchone()
+        if x is not None:
+            if skill_sealed == 'false':
+                skill_sealed = False
+            else:
+                skill_sealed = True
+            c.execute('''update user set is_skill_sealed = :a, character_id = :b, is_char_uncapped = :c, is_char_uncapped_override = :d where user_id = :e''', {
+                'a': b2int(skill_sealed), 'b': character_id, 'c': x[0], 'd': x[1], 'e': user_id})

-    conn.commit()
-    conn.close()
-    return False
+            re = True
+
+    return re


 def change_char_uncap(user_id, character_id):
    # 角色觉醒改变，返回字典
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select is_uncapped, is_uncapped_override from user_char where user_id = :a and character_id = :b''',
-              {'a': user_id, 'b': character_id})
-    x = c.fetchone()
    r = None
-    if x is not None and x[0] == 1:
-        c.execute('''update user set is_char_uncapped_override = :a where user_id = :b''', {
-                  'a': b2int(x[1] == 0), 'b': user_id})
-        c.execute('''update user_char set is_uncapped_override = :a where user_id = :b and character_id = :c''', {
-                  'a': b2int(x[1] == 0), 'b': user_id, 'c': character_id})
-        c.execute('''select * from user_char where user_id = :a and character_id = :b''',
+    with Connect() as c:
+        c.execute('''select is_uncapped, is_uncapped_override from user_char where user_id = :a and character_id = :b''',
                  {'a': user_id, 'b': character_id})
-        y = c.fetchone()
-        c.execute(
-            '''select name from character where character_id = :x''', {'x': y[1]})
-        z = c.fetchone()
-        if z is not None:
-            char_name = z[0]
-        if y is not None:
-            r = {
-                "is_uncapped_override": int2b(y[14]),
-                "is_uncapped": int2b(y[13]),
-                "uncap_cores": [],
-                "char_type": y[12],
-                "skill_id_uncap": y[11],
-                "skill_requires_uncap": int2b(y[10]),
-                "skill_unlock_level": y[9],
-                "skill_id": y[8],
-                "overdrive": y[7],
-                "prog": y[6],
-                "frag": y[5],
-                "level_exp": y[4],
-                "exp": y[3],
-                "level": y[2],
-                "name": char_name,
-                "character_id": y[1]
-            }
+        x = c.fetchone()
+
+        if x is not None and x[0] == 1:
+            c.execute('''update user set is_char_uncapped_override = :a where user_id = :b''', {
+                'a': b2int(x[1] == 0), 'b': user_id})
+            c.execute('''update user_char set is_uncapped_override = :a where user_id = :b and character_id = :c''', {
+                'a': b2int(x[1] == 0), 'b': user_id, 'c': character_id})
+            c.execute('''select * from user_char where user_id = :a and character_id = :b''',
+                      {'a': user_id, 'b': character_id})
+            y = c.fetchone()
+            c.execute(
+                '''select name from character where character_id = :x''', {'x': y[1]})
+            z = c.fetchone()
+            if z is not None:
+                char_name = z[0]
+            if y is not None:
+                r = {
+                    "is_uncapped_override": int2b(y[14]),
+                    "is_uncapped": int2b(y[13]),
+                    "uncap_cores": [],
+                    "char_type": y[12],
+                    "skill_id_uncap": y[11],
+                    "skill_requires_uncap": int2b(y[10]),
+                    "skill_unlock_level": y[9],
+                    "skill_id": y[8],
+                    "overdrive": y[7],
+                    "prog": y[6],
+                    "frag": y[5],
+                    "level_exp": y[4],
+                    "exp": y[3],
+                    "level": y[2],
+                    "name": char_name,
+                    "character_id": y[1]
+                }

-    conn.commit()
-    conn.close()
    return r


 def arc_sys_set(user_id, value, set_arg):
    # 三个设置，PTT隐藏、体力满通知、最爱角色，无返回
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    if 'favorite_character' in set_arg:
-        value = int(value)
-        c.execute('''update user set favorite_character = :a where user_id = :b''', {
-            'a': value, 'b': user_id})
+    with Connect() as c:
+        if 'favorite_character' in set_arg:
+            value = int(value)
+            c.execute('''update user set favorite_character = :a where user_id = :b''', {
+                'a': value, 'b': user_id})

-    else:
-        if value == 'false':
-            value = False
        else:
-            value = True
+            if value == 'false':
+                value = False
+            else:
+                value = True

-        if 'is_hide_rating' in set_arg:
-            c.execute('''update user set is_hide_rating = :a where user_id = :b''', {
-                      'a': b2int(value), 'b': user_id})
-        if 'max_stamina_notification_enabled' in set_arg:
-            c.execute('''update user set max_stamina_notification_enabled = :a where user_id = :b''', {
-                      'a': b2int(value), 'b': user_id})
+            if 'is_hide_rating' in set_arg:
+                c.execute('''update user set is_hide_rating = :a where user_id = :b''', {
+                    'a': b2int(value), 'b': user_id})
+            if 'max_stamina_notification_enabled' in set_arg:
+                c.execute('''update user set max_stamina_notification_enabled = :a where user_id = :b''', {
+                    'a': b2int(value), 'b': user_id})

-    conn.commit()
-    conn.close()
    return None


@@ -119,37 +111,32 @@ def arc_add_friend(user_id, friend_id):
    # 加好友，返回好友列表，或者是错误码602、604
    if user_id == friend_id:
        return 604
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select exists(select * from friend where user_id_me = :x and user_id_other = :y)''',
-              {'x': user_id, 'y': friend_id})
+
    r = None
-    if c.fetchone() == (0,):
-        c.execute('''insert into friend values(:a, :b)''',
-                  {'a': user_id, 'b': friend_id})
-        r = server.info.get_user_friend(c, user_id)
+    with Connect() as c:
+        c.execute('''select exists(select * from friend where user_id_me = :x and user_id_other = :y)''',
+                  {'x': user_id, 'y': friend_id})
+        if c.fetchone() == (0,):
+            c.execute('''insert into friend values(:a, :b)''',
+                      {'a': user_id, 'b': friend_id})
+            r = server.info.get_user_friend(c, user_id)
+        else:
+            r = 602

-    else:
-        return 602
-
-    conn.commit()
-    conn.close()
    return r


 def arc_delete_friend(user_id, friend_id):
    # 删好友，返回好友列表
-    conn = sqlite3.connect('./database/arcaea_database.db')
-    c = conn.cursor()
-    c.execute('''select exists(select * from friend where user_id_me = :x and user_id_other = :y)''',
-              {'x': user_id, 'y': friend_id})
    r = None
-    if c.fetchone() == (1,):
-        c.execute('''delete from friend where user_id_me = :x and user_id_other = :y''',
+    with Connect() as c:
+
+        c.execute('''select exists(select * from friend where user_id_me = :x and user_id_other = :y)''',
                  {'x': user_id, 'y': friend_id})
+        if c.fetchone() == (1,):
+            c.execute('''delete from friend where user_id_me = :x and user_id_other = :y''',
+                      {'x': user_id, 'y': friend_id})

-        r = server.info.get_user_friend(c, user_id)
+            r = server.info.get_user_friend(c, user_id)

-    conn.commit()
-    conn.close()
    return r
--- a/version/server/sql.py
+++ b/version/server/sql.py
@@ -0,0 +1,25 @@
+import sqlite3
+
+
+class Connect():
+    # 数据库连接类，上下文管理
+
+    def __init__(self, file_path='./database/arcaea_database.db'):
+        """
+        数据库连接，默认连接arcaea_database.db
+        接受：文件路径
+        返回：sqlite3连接操作对象
+        """
+        self.file_path = file_path
+
+    def __enter__(self):
+        self.conn = sqlite3.connect(self.file_path)
+        self.c = self.conn.cursor()
+        return self.c
+
+    def __exit__(self, exc_type, exc_val, exc_tb):
+        if self.conn:
+            self.conn.commit()
+            self.conn.close()
+
+        return True
--- a/version/setting.ini
+++ b/version/setting.ini
@@ -1,7 +0,0 @@
-[CONFIG]
-HOST = 192.168.1.113
-PORT = 80
-
-[WEB]
-USERNAME = admin
-PASSWORD = admin
--- a/version/setting.py
+++ b/version/setting.py
@@ -0,0 +1,67 @@
+class Config():
+    '''
+    This is the setting file. You can change some parameters here.
+    '''
+
+    '''
+    --------------------
+    主机的地址和端口号
+    Host and port of your server
+    '''
+    HOST = '192.168.1.101'
+    PORT = '80'
+    '''
+    --------------------
+    '''
+
+    '''
+    --------------------
+    Web后台管理页面的用户名和密码
+    Username and password of web background management page
+    '''
+    USERNAME = 'admin'
+    PASSWORD = 'admin'
+    '''
+    --------------------
+    '''
+
+    '''
+    --------------------
+    Web后台管理页面的session秘钥，如果不知道是什么，请不要修改
+    Session key of web background management page
+    If you don't know what it is, please don't modify it.
+    '''
+    SECRET_KEY = '1145141919810'
+    '''
+    --------------------
+    '''
+
+    '''
+    --------------------
+    玩家歌曲下载的24小时次数限制
+    Player's song download limit times in 24 hours
+    '''
+    DOWNLOAD_TIMES_LIMIT = 3000
+    '''
+    歌曲下载链接的有效时长，单位：秒
+    Effective duration of song download link, unit: seconds
+    '''
+    DOWNLOAD_TIME_GAP_LIMIT = 1000
+    '''
+    --------------------
+    '''
+
+    '''
+    --------------------
+    Arcaea登录的最大允许设备数量，最小值为1
+    The maximum number of devices allowed to log in Arcaea, minimum: 1
+    '''
+    LOGIN_DEVICE_NUMBER_LIMIT = 1
+    '''
+    是否允许同设备多应用共存登录
+    If multiple applications on the same device to log in is allowed
+    '''
+    ALLOW_LOGIN_SAME_DEVICE = False
+    '''
+    --------------------
+    '''
--- a/version/templates/web/allredeem.html
+++ b/version/templates/web/allredeem.html
@@ -0,0 +1,39 @@
+{% extends 'base.html' %}
+{% block header %}
+<h1>{% block title %}All redeem codes{% endblock %}</h1>
+{% endblock %}
+
+{% block content %}
+{% if posts %}<br />
+{% for redeem in posts %}
+
+<div class="char-redeem">
+    <span>Code: </span>
+    <span class="name">{{redeem['code']}}</span>
+    <br />
+
+    <span>Type: </span>
+    <span class="char-num">
+        {% if redeem['type'] == 0 %}
+        仅可使用一次 It can only be used once.
+        {% elif redeem['type'] == 1 %}
+        每个用户仅可以使用一次 Each user can only use it once.
+        {% endif %}
+    </span>
+    <br />
+
+    <span>Items: </span>
+    <span class="char-num" style='white-space:pre'>{{redeem['items']}}</span>
+    <br />
+    <div><a href="/web/redeem/{{redeem['code']}}">使用者 Players who have used it.</a></div>
+
+</div>
+{% if not loop.last %}
+<br />
+<hr />
+<br />
+{% endif %}
+{% endfor %}
+
+{% endif %}
+{% endblock %}
--- a/version/templates/web/banuser.html
+++ b/version/templates/web/banuser.html
@@ -0,0 +1,37 @@
+{% extends 'base.html' %}
+{% block header %}
+<h1>{% block title %}Ban the user{% endblock %}</h1>
+{% endblock %}
+
+{% block content %}
+<form action="/web/banuser" method="post">
+    <div class="title">Ban the user</div>
+    <label for="name">Arcaea Username</label>
+    <input name="name" id="name">
+    or<br />
+    <label for="user_code">Arcaea User Code</label>
+    <input name="user_code" id="user_code">
+
+    <br />
+    <div class="content">提示：重设用户密码即可解封账号</div>
+    <div class="content">Tip: Reset the user password to unseal the account.</div>
+    <br />
+    <input type="submit" value="Execute">
+</form>
+<br />
+<hr />
+<form action="/web/banuser/deleteuserscore" method="post">
+    <div class="title">Delete all of the user's scores</div>
+    <label for="name">Arcaea Username</label>
+    <input name="name" id="name">
+    or<br />
+    <label for="user_code">Arcaea User Code</label>
+    <input name="user_code" id="user_code">
+
+    <br />
+    <div class="content">警告！这个操作具有破坏性，且不可恢复。</div>
+    <div class="content">Warning! This operation is destructive and unrecoverable.</div>
+    <br />
+    <input type="submit" value="Execute">
+</form>
+{% endblock %}
--- a/version/templates/web/changeredeem.html
+++ b/version/templates/web/changeredeem.html
@@ -0,0 +1,50 @@
+{% extends 'base.html' %}
+{% block header %}
+<h1>{% block title %}Change the redeem codes{% endblock %}</h1>
+{% endblock %}
+
+{% block content %}
+<form action="/web/changeredeem/addredeem" method="post">
+    <div class="title">Add the redeem</div>
+    <div>指定生成 Specify generation</div>
+    <label for="code">The redeem code</label>
+    <input name="code" id="code">
+    <div>Or</div>
+    <div>随机批量生成 Batch generation at random</div>
+    <label for="amount">Amount</label>
+    <input name="amount" id="amount">
+    <br />
+    <div>Type:
+        <br />
+        <br />
+        <label><input type="radio" name="type" value="0" checked>仅可使用一次 It can only be used once.</label>
+        <br />
+        <label><input type="radio" name="type" value="1">每个用户仅可以使用一次 Each user can only use it once.</label>
+    </div>
+
+
+    <br />
+    <div>Items:</div>
+    <label for="fragment">Fragments</label>
+    <input name="fragment" id="fragment">
+    <label for="ticket">Memories</label>
+    <input name="ticket" id="ticket">
+
+    <div class="content">两种奖励可以都有，不需要请留空。</div>
+    <div class="content">You can have both kinds of items. Please leave it blank if you don't need it.</div>
+    <div class="content">兑换码长度为10~20。</div>
+    <div class="content">The length of redeem code is 10 ~ 20.</div>
+    <div class="content">随机生成数量不得超过1000。</div>
+    <div class="content">The amount of batch generation should not be more than 1000.</div>
+    <input type="submit" value="Add">
+</form>
+<br />
+<hr />
+<form action="/web/changeredeem/deleteredeem" method="post">
+    <div class="title">Delete the redeem</div>
+    <label for="code">The redeem code</label>
+    <input name="code" id="code" required>
+
+    <input type="submit" value="Delete">
+</form>
+{% endblock %}
--- a/version/templates/web/changeuserpwd.html
+++ b/version/templates/web/changeuserpwd.html
@@ -0,0 +1,24 @@
+{% extends 'base.html' %}
+{% block header %}
+<h1>{% block title %}Change user password{% endblock %}</h1>
+{% endblock %}
+
+{% block content %}
+<form action="/web/changeuserpwd" method="post">
+    <div class="title">Edit the user's password</div>
+    <label for="name">Arcaea Username</label>
+    <input name="name" id="name">
+    or<br />
+    <label for="user_code">Arcaea User Code</label>
+    <input name="user_code" id="user_code">
+    <br />
+    <br />
+
+    <label for="pwd">Password</label>
+    <input type="password" name="pwd" id="pwd" required>
+    <label for="pwd2">Enter again</label>
+    <input type="password" name="pwd2" id="pwd2" required>
+    
+    <input type="submit" value="Edit">
+</form>
+{% endblock %}
--- a/version/templates/web/index.html
+++ b/version/templates/web/index.html
@@ -17,10 +17,13 @@
 <a href="{{ url_for('index.all_character') }}">角色信息查询 All characters</a></br></br>
 <a href="{{ url_for('index.all_item') }}">购买信息查询 All items</a></br></br>
 <a href="{{ url_for('index.all_present') }}">奖励信息查询 All presents</a></br></br>
+<a href="{{ url_for('index.all_redeem') }}">兑换码信息查询 All redeem codes</a></br></br>
 <a href="{{ url_for('index.single_chart_top') }}">单个铺面排行榜查询 Single song chart tops</a>
 <hr>
 <h1>系统方面 System</h1>
 <a href="{{ url_for('index.update_database') }}">数据库更新 Update databases</a></br></br>
+<a href="{{ url_for('index.edit_userpwd') }}">用户密码修改 Change user password</a></br></br>
+<a href="{{ url_for('index.ban_user') }}">封禁用户 Ban the user</a></br></br>
 <a href="{{ url_for('index.update_user_save') }}">用户存档更新 Update user saves</a></br></br>
 <a href="{{ url_for('index.change_song') }}">歌曲修改 Change the songs</a></br></br>
 <a href="{{ url_for('index.change_character') }}">角色修改 Change the characters</a></br></br>
@@ -28,7 +31,9 @@
 <a href="{{ url_for('index.change_user') }}">用户信息修改 Change user information</a></br></br>
 <a href="{{ url_for('index.change_user_purchase') }}">用户购买信息修改 Change user purchase information</a></br></br>
 <a href="{{ url_for('index.change_present') }}">奖励修改 Change the presents</a></br></br>
-<a href="{{ url_for('index.deliver_present') }}">奖励分发 Deliver the presents</a>
+<a href="{{ url_for('index.deliver_present') }}">奖励分发 Deliver the presents</a></br></br>
+<a href="{{ url_for('index.change_redeem') }}">兑换码修改 Change the redeem codes</a>
+


 {% endblock %}
--- a/version/templates/web/redeem.html
+++ b/version/templates/web/redeem.html
@@ -0,0 +1,24 @@
+{% extends 'base.html' %}
+{% block header %}
+<h1>{% block title %}Redeem - {{code}}{% endblock %}</h1>
+{% endblock %}
+
+{% block content %}
+{% if posts %}
+{% for user in posts %}
+
+<div id="user-info">
+    <div class="name">{{user['name']}}
+        <span class="rank">UID: {{user['user_id']}}</span>
+        <span class="rank">User code: {{user['user_code']}}</span>
+    </div>
+</div>
+{% if not loop.last %}
+<br />
+{% endif %}
+{% endfor %}
+
+{% endif %}
+<br />
+<a href="{{ url_for('index.all_redeem') }}">Back</a>
+{% endblock %}
--- a/version/templates/web/updatedatabase.html
+++ b/version/templates/web/updatedatabase.html
@@ -12,10 +12,10 @@
 <div class="content">
    这里可以将旧版本的数据库同步到新版本的数据库，并刷新用户拥有的角色列表。<br />
    可上传文件: arcaea_database.db和arcsong.db<br />
-    新数据库不存在的数据会被添加，存在的数据将不会被改变。<br /><br />
+    新数据库不存在的数据会被添加，存在的重复数据也会被改变。<br /><br />
    Here you can synchronize the old version of the database to the new version of the database and refresh the list of
    characters owned by players.<br />
    Uploadable files: arcaea_database.db & arcsong.db<br />
-    Data that does not exist in the new database will be added and the existing data will not be changed.
+    Data that does not exist in the new database will be added and the existing duplicate data will also be changed.
 </div>
 {% endblock %}
--- a/version/web/index.py
+++ b/version/web/index.py
--- a/version/web/login.py
+++ b/version/web/login.py
@@ -2,7 +2,7 @@
 from flask import (Blueprint, flash, g, redirect,
                   render_template, request, session, url_for)
 import functools
-import configparser
+from setting import Config

 bp = Blueprint('login', __name__, url_prefix='/web')

@@ -15,18 +15,12 @@ def login():
        password = request.form['password']
        error = None

-        config = configparser.ConfigParser()
-        path = r'setting.ini'
-        config.read(path, encoding="utf-8")
-        USERNAME = config.get('WEB', 'USERNAME')
-        PASSWORD = config.get('WEB', 'PASSWORD')
-
-        if username != USERNAME and password != PASSWORD:
+        if username != Config.USERNAME or password != Config.PASSWORD:
            error = '错误的用户名或密码 Incorrect username or password.'

        if error is None:
            session.clear()
-            session['user_id'] = USERNAME + PASSWORD
+            session['user_id'] = Config.USERNAME + Config.PASSWORD
            return redirect(url_for('index.index'))

        flash(error)
@@ -48,16 +42,10 @@ def login_required(view):
    def wrapped_view(**kwargs):
        x = session.get('user_id')

-        config = configparser.ConfigParser()
-        path = r'setting.ini'
-        config.read(path, encoding="utf-8")
-        USERNAME = config.get('WEB', 'USERNAME')
-        PASSWORD = config.get('WEB', 'PASSWORD')
-
-        if x != USERNAME + PASSWORD:
+        if x != Config.USERNAME + Config.PASSWORD:
            return redirect(url_for('login.login'))

-        g.user = {'user_id': x, 'username': USERNAME}
+        g.user = {'user_id': x, 'username': Config.USERNAME}
        return view(**kwargs)

    return wrapped_view
--- a/version/web/system.py
+++ b/version/web/system.py
@@ -3,6 +3,8 @@ import sqlite3
 import time
 import json
 import server.arcscore
+import hashlib
+from random import Random


 def int2b(x):
@@ -13,6 +15,17 @@ def int2b(x):
        return True


+def random_str(randomlength=10):
+    # 随机生成字符串
+    s = ''
+    chars = 'AaBbCcDdEeFfGgHhIiJjKkLlMmNnOoPpQqRrSsTtUuVvWwXxYyZz0123456789'
+    length = len(chars) - 1
+    random = Random()
+    for i in range(randomlength):
+        s += chars[random.randint(0, length)]
+    return s
+
+
 def get_table_info(c, table_name):
    # 得到表结构，返回主键列表和字段名列表
    pk = []
@@ -85,8 +98,25 @@ def get_sql_insert_table(table_name, field, value):
    return sql, sql_dict


+def get_sql_delete_table(table_name, where_field=[], where_value=[]):
+    # sql语句拼接，delete from ... where ...
+    sql = 'delete from ' + table_name
+    sql_dict = {}
+
+    if where_field and where_value:
+        sql += ' where '
+        sql += where_field[0] + '=:' + where_field[0]
+        sql_dict[where_field[0]] = where_value[0]
+        if len(where_field) >= 1:
+            for i in range(1, len(where_field)):
+                sql_dict[where_field[i]] = where_value[i]
+                sql += ' and ' + where_field[i] + '=:' + where_field[i]
+
+    return sql, sql_dict
+
+
 def update_one_table(c1, c2, table_name):
-    # 从c1向c2更新数据表，c2中存在的信息不变
+    # 从c1向c2更新数据表，c1中存在的信息不变
    c1.execute(
        '''select * from sqlite_master where type = 'table' and name = :a''', {'a': table_name})
    c2.execute(
@@ -117,11 +147,15 @@ def update_one_table(c1, c2, table_name):
            sql = 'select exists(' + sql + ')'
            c2.execute(sql, sql_dict)

-            if c2.fetchone() == (0,):
-                sql, sql_dict = get_sql_insert_table(
-                    table_name, field, list(y[i]))
+            if c2.fetchone() == (1,):  # 如果c2里存在，先删除
+                sql, sql_dict = get_sql_delete_table(
+                    table_name, db1_pk, list(x[i]))
                c2.execute(sql, sql_dict)

+            sql, sql_dict = get_sql_insert_table(
+                table_name, field, list(y[i]))
+            c2.execute(sql, sql_dict)
+
    return None


@@ -142,7 +176,7 @@ def update_user_char(c):

 def update_database():
    # 将old数据库不存在数据加入到新数据库上，并删除old数据库
-    # 对于arcaea_datebase.db，更新best_score，friend，recent30，user，user_world, user_item, user_save, login, present, user_present并用character数据更新user_char
+    # 对于arcaea_datebase.db，更新一些表，并用character数据更新user_char
    # 对于arcsong.db，更新songs
    if os.path.isfile("database/old_arcaea_database.db") and os.path.isfile("database/arcaea_database.db"):
        conn1 = sqlite3.connect('./database/old_arcaea_database.db')
@@ -155,11 +189,14 @@ def update_database():
        update_one_table(c1, c2, 'best_score')
        update_one_table(c1, c2, 'recent30')
        update_one_table(c1, c2, 'user_world')
+        update_one_table(c1, c2, 'item')
        update_one_table(c1, c2, 'user_item')
        update_one_table(c1, c2, 'user_save')
        update_one_table(c1, c2, 'login')
        update_one_table(c1, c2, 'present')
        update_one_table(c1, c2, 'user_present')
+        update_one_table(c1, c2, 'redeem')
+        update_one_table(c1, c2, 'user_redeem')

        update_user_char(c2)

@@ -270,6 +307,8 @@ def update_one_save(c, user_id):
        for i in scores:
            rating = server.arcscore.get_one_ptt(
                i['song_id'], i['difficulty'], i['score'])
+            if rating < 0:
+                rating = 0
            try:
                index = clear_song_id_difficulty.index(
                    i['song_id'] + str(i['difficulty']))
@@ -378,3 +417,90 @@ def deliver_all_user_present(c, present_id):
                      {'a': i[0], 'b': present_id})

    return
+
+
+def add_one_redeem(code, redeem_type, items):
+    # 添加一个兑换码
+
+    message = None
+    conn = sqlite3.connect('./database/arcaea_database.db')
+    c = conn.cursor()
+    c.execute(
+        '''select exists(select * from redeem where code=:a)''', {'a': code})
+    if c.fetchone() == (0,):
+        c.execute('''insert into redeem values(:a,:b,:c)''', {
+                  'a': code, 'b': items, 'c': redeem_type})
+        message = '添加成功 Successfully add it.'
+    else:
+        message = '兑换码已存在 The redeem code exists.'
+
+    conn.commit()
+    conn.close()
+    return message
+
+
+def add_some_random_redeem(amount, redeem_type, items):
+    # 随机生成一堆10位的兑换码
+
+    message = None
+    conn = sqlite3.connect('./database/arcaea_database.db')
+    c = conn.cursor()
+    i = 1
+    while i <= amount:
+        code = random_str()
+        c.execute(
+            '''select exists(select * from redeem where code=:a)''', {'a': code})
+        if c.fetchone() == (0,):
+            c.execute('''insert into redeem values(:a,:b,:c)''',
+                      {'a': code, 'b': items, 'c': redeem_type})
+            i += 1
+
+    message = '添加成功 Successfully add it.'
+    conn.commit()
+    conn.close()
+    return message
+
+
+def delete_one_redeem(code):
+    # 删除一个兑换码
+
+    message = None
+    conn = sqlite3.connect('./database/arcaea_database.db')
+    c = conn.cursor()
+    c.execute(
+        '''select exists(select * from redeem where code=:a)''', {'a': code})
+    if c.fetchone() == (1,):
+        c.execute('''delete from redeem where code = :a''', {'a': code})
+        c.execute('''delete from user_redeem where code =:a''', {'a': code})
+        message = '删除成功 Successfully delete it.'
+    else:
+        message = '兑换码不存在 The redeem code does not exist.'
+
+    conn.commit()
+    conn.close()
+    return message
+
+
+def change_userpwd(c, user_id, password):
+    # 修改用户密码
+    hash_pwd = hashlib.sha256(password.encode("utf8")).hexdigest()
+    c.execute('''update user set password =:a where user_id=:b''',
+              {'a': hash_pwd, 'b': user_id})
+    return
+
+
+def ban_one_user(c, user_id):
+    # 封禁用户
+    c.execute('''update user set password = '' where user_id=:a''',
+              {'a': user_id})
+    c.execute('''delete from login where user_id=:a''', {'a': user_id})
+    return
+
+
+def clear_user_score(c, user_id):
+    # 清除用户所有成绩，包括best_score和recent30，以及recent数据，但不包括云端存档
+    c.execute('''update user set rating_ptt=0, song_id='', difficulty=0, score=0, shiny_perfect_count=0, perfect_count=0, near_count=0, miss_count=0, health=0, time_played=0, rating=0 where user_id=:a''',
+              {'a': user_id})
+    c.execute('''delete from best_score where user_id=:a''', {'a': user_id})
+    c.execute('''delete from recent30 where user_id=:a''', {'a': user_id})
+    return
Author	SHA1	Message	Date
Lost-MSth	df181f104e	Update to v2.2 close #13	2021-02-11 15:26:58 +08:00
Lost-MSth	a890a9af4a	Waiting for updating and fix some bugs It will be released soon because lowiro will update in some days. Fix many bugs and I forgot them. :< I push this because there's a small but serious safety problem. It should be fixed immediately. Oh, and this update needs you to login in arcaea again because a new function is added.	2021-02-08 14:45:10 +08:00
Lost-MSth	c6bb4c9afb	Update to v2.1	2021-01-21 14:42:57 +08:00
Lost-MSth	98358ad216	Fix two small bugs.	2021-01-10 16:29:18 +08:00
Lost-MSth	e0e6128826	Update README.md	2021-01-08 14:53:50 +08:00
Lost-MSth	08872399cc	Update to v2.0 close #11 close #10 close #9	2021-01-08 14:51:37 +08:00
Lost-MSth	29a6cfaac1	Fix a bug.	2021-01-02 15:09:34 +08:00
Lost-MSth	f25bd4130e	Update a midway version (waiting for offical update) Add some things and fix some bugs. It will not have a description.	2020-12-29 11:29:36 +08:00
Lost-MSth	68c757f9d7	Fix a bug	2020-12-22 13:07:49 +08:00