diff --git a/Services/ark_nights.py b/Services/ark_nights.py
index a085114..e03316a 100644
--- a/Services/ark_nights.py
+++ b/Services/ark_nights.py
@@ -1,287 +1,3 @@
 """
-Arknights headhunt recruitment simulator.
+This function is waiting for a rewrite and is currently deprecated.
 """
-import random
-import sqlite3
-import time
-from typing import Union
-
-
-class ArknightsPity:
-    def __init__(self):
-        self.sanity_poll_dict = {}
-
-    def record_poll(self, group_id):
-        if group_id not in self.sanity_poll_dict:
-            self.sanity_poll_dict[group_id] = 10
-        else:
-            self.sanity_poll_dict[group_id] += 10
-
-    def get_offset_setting(self, group_id) -> int:
-        if group_id not in self.sanity_poll_dict:
-            self.record_poll(group_id)
-            return 0
-        else:
-            poll_count = self.sanity_poll_dict[group_id]
-            if poll_count <= 50:
-                return 0
-            else:
-                return (poll_count - 50) * 2
-
-    def reset_offset(self, group_id):
-        self.sanity_poll_dict[group_id] = 0
-
-
-class ArkHeadhunt:
-    """
-    Init data for arknights headhunt simulator.
-    """
-
-    def __init__(self, times=1):
-        self.times = times
-        self.count = 0
-        self.offset = 0
-        self.arknights_agent_db = sqlite3.connect('data/db/stats.db')
-
-        self._init()
-
-        self.random_agent = []
-        self.random_class = []
-
-    def _init(self) -> dict:
-        self.arknights_agent_db.execute(
-            """
-            create table if not exists arknights_op (
-                "ch_name" varchar(50) unique on conflict ignore,
-                "stars" integer, 
-                "is_limited" boolean,
-                "is_secondary_up" boolean,
-                "is_up" boolean
-            )
-            """
-        )
-        self.arknights_agent_db.commit()
-
-    def _get_if_limit_banner_on(self):
-        result = self.arknights_agent_db.execute(
-            """
-            select ch_name from arknights_op where is_limited = true
-            """
-        ).fetchone()
-
-        return result if result and result is not None else ''
-
-    def get_randomized_results(self, offset_setting=0):
-        """
-        Get randomized list for agent star numbers.
-        :param offset_setting: Offset that can set for rigging the result.
-        :return: void.
-        """
-        if self.times < 0:
-            raise ValueError("Pulling value cannot be less than 0")
-
-        random.seed(time.time_ns())
-        random_class = []
-        self.count += 1
-        for _ in range(0, self.times):
-            rand_num = random.randint(0, 100) + offset_setting
-            if rand_num >= 98:
-                random_class.append(6)
-                self.count = 0
-            elif rand_num >= 90:
-                random_class.append(5)
-            elif rand_num >= 40:
-                random_class.append(4)
-            else:
-                random_class.append(3)
-
-            time.sleep(0.05)
-
-        self.random_class = random_class
-        self.random_agent = self._get_ops()
-
-    def _get_uped_op(self, star: int):
-        result = self._get_op_from_db(star, is_up=True)
-        if result is None or not result:
-            return self._get_op_from_db(star)
-
-        return result
-
-    def _get_secondary_up_op(self, star: int):
-        result = self._get_op_from_db(star, is_secondary_up=True)
-        if result is None:
-            return self._get_op_from_db(star)
-
-        return result
-
-    def _get_op_count_by_stars(self, star: int) -> int:
-        result = self.arknights_agent_db.execute(
-            """
-            select count(ch_name) from arknights_op where stars = ?
-            """, (star,)
-        ).fetchone()
-
-        return int(result[0])
-
-    def _get_op_from_db(self, star: int, is_up=False, is_secondary_up=False):
-        if is_up or is_secondary_up:
-            where_query = f'where stars = ? and (is_up = {is_up.__str__().lower()} ' \
-                          f'or is_secondary_up = {is_secondary_up.__str__().lower()})'
-        else:
-            where_query = 'where stars = ?'
-        result = self.arknights_agent_db.execute(
-            f"""
-            select ch_name from arknights_op 
-            {where_query} order by random() limit 1
-            """, (star,)
-        ).fetchone()
-
-        return result if result and result is not None else ''
-
-    def _insert_op(self, star: int, name: str, is_limited=False, is_sec_up=False, is_up=False):
-        is_up = is_limited or is_sec_up or is_up
-        self.arknights_agent_db.execute(
-            """
-            insert or replace into arknights_op (ch_name, stars, is_limited, is_secondary_up, is_up) values (
-                ?, ?, ?, ?, ?
-            )
-            """, (name, star, is_limited, is_sec_up, is_up)
-        )
-        self._commit_change()
-
-    def _get_ops(self) -> list:
-        """
-        Get a list of agent's name.
-        :return: A list with all operator names.
-        """
-        random_agent = []
-        random.seed(time.time_ns())
-        for elements in self.random_class:
-            random_int = random.randint(0, 100)
-            if self._get_if_limit_banner_on() and elements == 6:
-                if random_int < 70:
-                    random_agent.append(self._get_uped_op(6))
-                else:
-                    # 30%中的五倍权值爆率。
-                    second_random = random.randint(0, self._get_op_count_by_stars(6))
-                    if second_random < 5 and self._get_if_limit_banner_on():
-                        random_agent.append(self._get_secondary_up_op(6))
-                    else:
-                        random_agent.append(self._get_op_from_db(6))
-
-            else:
-                if random_int < 50:
-                    random_agent.append(self._get_uped_op(elements))
-                else:
-                    random_agent.append(self._get_op_from_db(elements))
-
-        return random_agent
-
-    def _get_all_secondary_up_op(self, star: int):
-        result = self.arknights_agent_db.execute(
-            """
-            select ch_name, stars from arknights_op where stars = ? and is_secondary_up = true
-            """, (star,)
-        ).fetchall()
-
-        result = [x[0] for x in result if x is not None and x[0] is not None]
-        return result
-
-    def _get_all_uped_op(self, star: int):
-        result = self.arknights_agent_db.execute(
-            """
-            select ch_name, stars from arknights_op where stars = ? and is_up = true
-            """, (star,)
-        ).fetchall()
-
-        result = [x[0] for x in result if x is not None and x[0] is not None]
-        return result
-
-    def up_op(self, agent: str, star: Union[int, str], is_limited=False, is_second_up=False, is_up=True):
-        if isinstance(star, str) and not star.isdigit():
-            return '?'
-
-        star = int(star)
-        self._insert_op(star, agent, is_limited, is_second_up, is_up)
-        return 'Done'
-
-    def _commit_change(self):
-        self.arknights_agent_db.commit()
-
-    def clear_ups(self):
-        self.arknights_agent_db.execute(
-            """
-            delete from arknights_op where is_limited = true
-            """
-        )
-        self.arknights_agent_db.execute(
-            """
-            update arknights_op set is_secondary_up = false, is_up = false, is_limited = false
-            """
-        )
-        self._commit_change()
-
-    def add_op(self, agent: str, star: Union[int, str]):
-        if isinstance(star, str) and not star.isdigit():
-            return '?'
-
-        star = int(star)
-        self._insert_op(star, agent)
-        return f'成功将{agent}加入{star}星干员组'
-
-    def get_up(self) -> str:
-        result = ''
-        four_up = self._get_all_uped_op(4)
-        five_up = self._get_all_uped_op(5)
-        six_up = self._get_all_uped_op(6)
-
-        secondary_up = self._get_all_secondary_up_op(6)
-
-        result += '四星：' + '，'.join(four_up) + '\n'
-        result += '五星：' + '，'.join(five_up) + '\n'
-        result += '六星：' + '，'.join(six_up) + '\n'
-        result += ('六星小UP：' + '，'.join(secondary_up) + '\n') if self._get_if_limit_banner_on() else ''
-
-        return result if result else '无\n'
-
-    def __str__(self):
-        """
-        Generating the result of the headhunt.
-        :return: str, the result of the headhunt in Chinese.
-        """
-        response = ''
-
-        response += f'本次卡池UP：\n{self.get_up()}'
-        six_star = 0
-        for idx, elements in enumerate(self.random_class):
-            if elements == 6 or elements == -1:
-                six_star += 1
-
-            if elements == -1:
-                element = 6
-            else:
-                element = elements
-            response += str(element) + '星干员： %s\n' % self.random_agent[idx]
-
-        if 5 not in self.random_class and 6 not in self.random_class:
-            congrats = '哈↑哈↓紫气东来'
-
-        else:
-            if six_star > 6:
-                congrats = '你丫神仙吧草w'
-            elif six_star > 3:
-                congrats = '这个爆率感觉机器人应该是坏了吧'
-            elif six_star >= 1:
-                congrats = '有点幸运了啊'
-            else:
-                congrats = '没事这结果挺正常的，会好起来的，哈哈哈哈嗝~'
-
-        response += '本次寻访获得了%d个六星干员，%s' % (six_star, congrats)
-        return response
-
-
-# Test
-if __name__ == '__main__':
-    api = ArkHeadhunt(times=10)
-    api.get_randomized_results()
-    print(api.__str__())
diff --git a/Services/discord_service.py b/Services/discord_service.py
index 8f6896b..05bfbfc 100644
--- a/Services/discord_service.py
+++ b/Services/discord_service.py
@@ -1,7 +1,7 @@
 import sqlite3
 from datetime import datetime
 from json import dumps, loads
-from os import getcwd, path
+from os import path
 from re import findall
 from time import time
 from typing import List
@@ -10,10 +10,12 @@
 from nonebot.adapters.onebot.v11 import MessageSegment
 from youtube_dl.utils import sanitize_filename
 
-from Services.util.common_util import HttpxHelperClient, DiscordGroupNotification, DiscordMessageStatus, time_to_literal
-from awesome.Constants.path_constants import BILIBILI_PIC_PATH
+from Services.util.common_util import HttpxHelperClient, time_to_literal
+from awesome.Constants.path_constants import BILIBILI_PIC_PATH, DB_PATH
 from awesome.Constants.vtuber_function_constants import GPT_4_MODEL_NAME
 from config import SUPER_USER, DISCORD_AUTH
+from model.common_model import DiscordMessageStatus, DiscordGroupNotification
+from util.db_utils import fetch_one_or_default
 from util.helper_util import construct_message_chain
 
 
@@ -25,7 +27,7 @@ def __init__(self):
                           ' AppleWebKit/537.36 (KHTML, like Gecko)'
                           ' Chrome/126.0.0.0 Safari/537.36'
         }
-        self.database = sqlite3.connect(f'{getcwd()}/data/db/live_notification_data.db')
+        self.database = sqlite3.connect(path.join(DB_PATH, 'live_notification_data.db'))
         self._init_database()
         self.client = HttpxHelperClient()
 
@@ -110,11 +112,7 @@ async def _get_the_latest_existing_discord_message(self, channel_id):
             """, (channel_id,)
         ).fetchone()
 
-        data = data if not isinstance(data, tuple) else data[0]
-        if data is None:
-            return 0
-
-        return data
+        return fetch_one_or_default(data, 0)
 
     async def check_discord_updates(self) -> List[DiscordGroupNotification]:
         notification_list = self._retrieve_all_record_in_db()
diff --git a/Services/rate_limiter.py b/Services/rate_limiter.py
index 7fdbf3c..be4eb79 100644
--- a/Services/rate_limiter.py
+++ b/Services/rate_limiter.py
@@ -3,6 +3,7 @@
 from typing import Union
 
 from Services.util.common_util import time_to_literal
+from model.common_model import RateLimitStatus
 
 
 class UserLimitModifier:
@@ -193,15 +194,16 @@ async def _query_permission(
         query_user_prompt, wait_time = await self._query_user_permission(function_name, user_id, user_limit_modifier)
         return query_user_prompt, wait_time
 
-    async def _assemble_limit_prompt(self, prompt, wait_time) -> [None, str]:
+    async def _assemble_limit_prompt(self, prompt, wait_time) -> RateLimitStatus:
         if prompt == self.LIMIT_BY_USER:
-            return f'别玩啦，过{await time_to_literal(wait_time)}再回来玩好不好？'
+            return RateLimitStatus(
+                True, f'别玩啦，过{await time_to_literal(wait_time if wait_time > 0 else 1)}再回来玩好不好？')
         elif prompt == self.LIMIT_BY_GROUP:
-            return f'群使用已到达允许上限，请稍等{await time_to_literal(wait_time)}重试'
+            return RateLimitStatus(True, f'群使用已到达允许上限，请稍等{await time_to_literal(wait_time)}重试')
         elif prompt == self.TEMPRORARY_DISABLED:
-            return f'该功能全局禁用中，请稍等{await time_to_literal(wait_time)}再试。'
+            return RateLimitStatus(True, f'该功能全局禁用中，请稍等{await time_to_literal(wait_time)}再试。')
 
-        return None
+        return RateLimitStatus(False, None)
 
     async def user_group_limit_check(
             self,
@@ -209,7 +211,7 @@ async def user_group_limit_check(
             user_id: Union[str, int],
             group_id: Union[str, int],
             user_limit_modifier: UserLimitModifier
-    ) -> Union[str, None]:
+    ) -> RateLimitStatus:
         user_id = str(user_id)
         group_id = str(group_id)
 
@@ -221,7 +223,7 @@ async def user_limit_check(
             function_name: str,
             user_id: Union[str, int],
             user_limit_modifier: UserLimitModifier
-    ):
+    ) -> RateLimitStatus:
         user_id = str(user_id)
         query_result, wait_time = await self._query_user_permission(function_name, user_id, user_limit_modifier)
         return await self._assemble_limit_prompt(query_result, wait_time)
@@ -232,7 +234,7 @@ async def group_limit_check(
             group_id: Union[str, int],
             time_period=60,
             function_limit=None
-    ):
+    ) -> RateLimitStatus:
         group_id = str(group_id)
         query_result, wait_time = await self._query_group_permission(
             function_name,
diff --git a/Services/twitch_service.py b/Services/twitch_service.py
index ce73188..1185510 100644
--- a/Services/twitch_service.py
+++ b/Services/twitch_service.py
@@ -18,8 +18,8 @@
 from youtube_dl.utils import sanitize_filename
 
 from Services.live_notification import LiveNotificationData
-from Services.util.common_util import OptionalDict, HttpxHelperClient, Status, TwitchDownloadStatus, \
-    ValidatedTimestampStatus
+from Services.util.common_util import OptionalDict, HttpxHelperClient
+from model.common_model import Status, ValidatedTimestampStatus, TwitchDownloadStatus
 from config import SUPER_USER, PATH_TO_ONEDRIVE, SHARE_LINK, CLOUD_STORAGE_SIZE_LIMIT_GB
 from util.helper_util import construct_message_chain
 
diff --git a/Services/util/common_util.py b/Services/util/common_util.py
index 1891af6..51e1bb4 100644
--- a/Services/util/common_util.py
+++ b/Services/util/common_util.py
@@ -1,5 +1,3 @@
-import dataclasses
-import time
 from asyncio import sleep, get_running_loop
 from functools import lru_cache
 from hashlib import sha1
@@ -9,7 +7,8 @@
 from os.path import exists
 from random import randint
 from ssl import SSLContext
-from typing import List, Literal, Dict, Any, Union
+from time import time
+from typing import List, Literal, Dict, Any, Union, TypeVar
 from uuid import uuid4
 
 import markdown2
@@ -34,42 +33,10 @@
 from webdriver_manager.chrome import ChromeDriverManager
 
 from Services.util.ctx_utility import get_user_id, get_group_id
+from awesome.Constants.path_constants import BOT_RESPONSE_PATH
 
 TEMP_FILE_DIRECTORY = path.join(getcwd(), 'data', 'temp')
-
-
-@dataclasses.dataclass
-class Status:
-    is_success: bool
-    message: any
-
-
-@dataclasses.dataclass
-class ValidatedTimestampStatus(Status):
-    validated_timestamp: str = ''
-
-
-@dataclasses.dataclass
-class TwitchDownloadStatus(Status):
-    file_path: str = ''
-
-
-@dataclasses.dataclass
-class DiscordMessageStatus(Status):
-    message: List[MessageSegment] = dataclasses.field(default_factory=lambda: [])
-    group_to_notify: str = ''
-    has_update: bool = False
-    is_edit: bool = False
-
-
-@dataclasses.dataclass
-class DiscordGroupNotification(Status):
-    message: Message
-    has_update: bool
-    group_to_notify: str
-    channel_name: str
-    channel_id: str
-    is_edit: bool
+T = TypeVar("T")
 
 
 def chunk_string(string, length):
@@ -246,7 +213,7 @@ def markdown_to_html(string: str):
     html_string = markdown2.markdown(
         string, extras=['fenced-code-blocks', 'strike', 'tables', 'task_list', 'code-friendly'])
 
-    file_name = f'{getcwd()}/data/bot/response/{int(time.time())}.html'
+    file_name = f'{getcwd()}/data/bot/response/{int(time())}.html'
     with open(file_name, 'w+', encoding='utf-8') as file:
         file.write(r"""
 <script type="text/x-mathjax-config">
@@ -279,7 +246,8 @@ def markdown_to_html(string: str):
 
 
 def html_to_image(file_name) -> str:
-    file_name_png = f'{getcwd()}/data/bot/response/{int(time.time())}.png'
+    file_name_png = path.join(BOT_RESPONSE_PATH, f'{int(time())}.png')
+
     options = Options()
     options.add_argument('--headless')
     options.add_argument("--force-device-scale-factor=3.0")
@@ -365,7 +333,7 @@ def map(self, key) -> 'OptionalDict':
 
         return OptionalDict()
 
-    def or_else(self, data) -> any:
+    def or_else(self, data: T) -> T:
         if self.anything is None:
             return data
 
diff --git a/awesome/Constants/path_constants.py b/awesome/Constants/path_constants.py
index ac37315..5c9d7bf 100644
--- a/awesome/Constants/path_constants.py
+++ b/awesome/Constants/path_constants.py
@@ -1,11 +1,18 @@
 from os import path, getcwd
 
 _B_PIC = 'bilibiliPic'
+_BOT = 'bot'
 _DATA = 'data'
+_DB = 'db'
 _DL = 'dl'
+_FOLDER_LOL = 'lol'
 _OTHERS = 'others'
 _PIXIV_PIC = 'pixivPic'
+_RESPONSE = 'response'
 
 BILIBILI_PIC_PATH = path.join(getcwd(), _DATA, _B_PIC)
+DB_PATH = path.join(getcwd(), _DATA, _DB)
 DL_PATH = path.join(getcwd(), _DATA, _DL, _OTHERS)
+LOL_FOLDER_PATH = path.join(getcwd(), _DATA, _FOLDER_LOL)
 PIXIV_PIC_PATH = path.join(getcwd(), _DATA, _PIXIV_PIC)
+BOT_RESPONSE_PATH = path.join(getcwd(), _DATA, _BOT, _RESPONSE)
diff --git a/awesome/adminControl/group_control.py b/awesome/adminControl/group_control.py
index cecd08b..5e78b43 100644
--- a/awesome/adminControl/group_control.py
+++ b/awesome/adminControl/group_control.py
@@ -1,11 +1,13 @@
 import sqlite3
-from os import listdir, getcwd, path, remove
+from os import listdir, path, remove
 from os.path import exists
 from typing import Union
 
 from nonebot import logger
 
-from Services.util.common_util import Status, calculate_sha1
+from Services.util.common_util import calculate_sha1
+from model.common_model import Status
+from awesome.Constants.path_constants import LOL_FOLDER_PATH
 
 GROUP_PERMISSION_DEFAULT = {
     'IS_BANNED': False,
@@ -82,8 +84,8 @@ def _check_if_hash_collided(self, file_hash: str) -> bool:
         return result is not None and result
 
     def group_quote_startup_sanity_check(self):
-        for file in listdir(f'{getcwd()}/data/lol'):
-            quote_file_abs_path = path.join(getcwd(), 'data', 'lol', file).replace('\\', '/')
+        for file in listdir(LOL_FOLDER_PATH):
+            quote_file_abs_path = path.join(LOL_FOLDER_PATH, file).replace('\\', '/')
             if not self._check_if_file_exists_in_db(quote_file_abs_path):
                 remove(quote_file_abs_path)
                 logger.info(f'Deleting file {quote_file_abs_path} because it does not exist in db.')
@@ -95,8 +97,9 @@ def group_quote_startup_sanity_check(self):
         ).fetchall()
 
         for entry in all_results:
-            cq_image, qq_group, file_hash = entry
-            self._backfill_file_sha1_hash(cq_image, file_hash)
+            if entry:
+                cq_image, qq_group, file_hash = entry
+                self._backfill_file_sha1_hash(cq_image, file_hash)
 
     def _backfill_file_sha1_hash(self, cq_image, file_hash):
         if not file_hash and exists(cq_image):
diff --git a/awesome/adminControl/setu.py b/awesome/adminControl/setu.py
index 80a7cf1..dd01de6 100644
--- a/awesome/adminControl/setu.py
+++ b/awesome/adminControl/setu.py
@@ -1,7 +1,8 @@
 import sqlite3
-from typing import Union, List, Tuple
+from typing import Union, List, Tuple, Optional
 
 from awesome.Constants.function_key import USER_XP
+from util.db_utils import fetch_one_or_default
 
 
 class SetuFunctionControl:
@@ -123,7 +124,7 @@ def get_setu_usage(self) -> int:
             """
         ).fetchone()
 
-        return result[0] if result is not None and result[0] is not None else 0
+        return fetch_one_or_default(result, 0)
 
     def track_keyword(self, key_word: str):
         self.setu_db_connection.execute(
@@ -148,14 +149,14 @@ def get_user_xp_by_keyword(self, key_word: str, user_id: Union[int, str]) -> Lis
 
         return result
 
-    def _get_user_nickname(self, user_id: str) -> Union[str, None]:
+    def _get_user_nickname(self, user_id: str) -> Optional[str]:
         result = self.stat_db_connection.execute(
             """
             select nickname from user_activity_count where user_id = ? and nickname is not null limit 1;
             """, (user_id,)
         ).fetchone()
 
-        return result[0] if result is not None and result[0] is not None else None
+        return fetch_one_or_default(result, None)
 
     def _get_keyword_usage_expand(self, key_word: str):
         results = self.stat_db_connection.execute(
@@ -166,11 +167,11 @@ def _get_keyword_usage_expand(self, key_word: str):
             """, (f'%{key_word}%',)
         ).fetchall()
 
-        if results is None:
+        if not results:
             return ''
 
         for result in results:
-            if result[0] is not None and result[1] is not None:
+            if result[0] and result[1]:
                 user_id = result[0]
                 nickname = self._get_user_nickname(user_id)
                 if nickname is not None:
@@ -194,7 +195,7 @@ def _get_keyword_usage(self, key_word: str) -> int:
             """, (f'%{key_word}%',)
         ).fetchone()
 
-        return result[0] if result is not None and result[0] is not None else 0
+        return fetch_one_or_default(result, 0)
 
     def _keyword_filter_query(self):
         result = ['keyword != ?' for _ in self.blacklist_freq_keyword]
@@ -218,7 +219,7 @@ def get_bad_word_penalty(self, keyword: str) -> int:
             """, (keyword,)
         ).fetchone()
 
-        return result[0] if result is not None else -1
+        return fetch_one_or_default(result, -1)
 
     def add_bad_word_dict(self, key_word, multiplier):
         if multiplier == 1:
@@ -295,7 +296,7 @@ def get_user_pixiv(self, user_id) -> int:
             """, (user_id, 'pixiv_id')
         ).fetchone()
 
-        return result[0] if result is not None else -1
+        return fetch_one_or_default(result, -1)
 
     def _update_global_tag(self, tag: str):
         self.stat_db_connection.execute(
@@ -344,14 +345,14 @@ def set_user_data(
             else:
                 self._update_user_xp_data(user_id, keyword, user_nickname)
 
-    def get_global_stat(self, keyword) -> List[Tuple[str, int]]:
+    def get_global_stat(self, keyword) -> Optional[int]:
         result = self.stat_db_connection.execute(
             """
             select hit from global_stat where keyword = ? limit 1;
             """, (keyword,)
         ).fetchone()
 
-        return result if isinstance(result, int) else result[0] if result is not None and result[0] is not None else 0
+        return fetch_one_or_default(result, None)
 
     def get_user_xp(self, user_id: int | str) -> List[str]:
         if isinstance(user_id, int):
@@ -376,7 +377,7 @@ def get_user_data_by_tag(self, user_id, tag: str):
             """, (user_id, tag)
         ).fetchone()
 
-        return result[0] if result is not None else 0
+        return fetch_one_or_default(result, 0)
 
     def _get_data_rank(self, user_id: str, tag: str) -> int:
         result = self.stat_db_connection.execute(
@@ -389,7 +390,7 @@ def _get_data_rank(self, user_id: str, tag: str) -> int:
             """, (tag, user_id)
         ).fetchone()
 
-        return result[0] if result is not None and result[0] is not None else -1
+        return fetch_one_or_default(result, -1)
 
     def get_user_data(self, user_id: Union[int, str]) -> dict:
         if isinstance(user_id, int):
@@ -461,14 +462,14 @@ def set_group_xp(self, group_id, data):
     def set_group_data(self, group_id, tag, data=None):
         group_id = str(group_id)
 
-        if tag == 'setu' or tag == 'yanche' or tag == 'pull':
-            self._set_group_usage_helper(group_id, tag)
-
-        elif tag == 'pulls':
-            self._set_group_usage_helper(group_id, 'pulls3', data['3'])
-            self._set_group_usage_helper(group_id, 'pulls4', data['4'])
-            self._set_group_usage_helper(group_id, 'pulls5', data['5'])
-            self._set_group_usage_helper(group_id, 'pulls6', data['6'])
+        match tag:
+            case 'setu' | 'yanche' | 'pull':
+                self._set_group_usage_helper(group_id, tag)
+            case 'pulls':
+                self._set_group_usage_helper(group_id, 'pulls3', data['3'])
+                self._set_group_usage_helper(group_id, 'pulls4', data['4'])
+                self._set_group_usage_helper(group_id, 'pulls5', data['5'])
+                self._set_group_usage_helper(group_id, 'pulls6', data['6'])
 
         self.commit_change()
 
@@ -492,7 +493,7 @@ def compare_group_activity_rank(self, tag: str, original_rank: int, hit: int) ->
             """, (tag, original_rank)
         ).fetchone()
 
-        return abs(hit - result[0]) if result is not None else -1
+        return abs(hit - result[0]) if result else -1
 
     def get_group_activity_rank(self, group_id: Union[int, str], tag: str) -> int:
         group_id = str(group_id)
@@ -507,7 +508,7 @@ def get_group_activity_rank(self, group_id: Union[int, str], tag: str) -> int:
             """, (tag, group_id)
         ).fetchone()
 
-        return result[0] if result is not None else -1
+        return fetch_one_or_default(result, -1)
 
     def get_group_usage(self, group_id: Union[int, str], tag: str) -> int:
         group_id = str(group_id)
@@ -517,7 +518,7 @@ def get_group_usage(self, group_id: Union[int, str], tag: str) -> int:
             """, (group_id, tag)
         ).fetchone()
 
-        return result[0] if result is not None else 0
+        return fetch_one_or_default(result, 0)
 
     def get_group_top_xp(self, group_id: Union[int, str]) -> str:
         group_id = str(group_id)
@@ -529,7 +530,7 @@ def get_group_top_xp(self, group_id: Union[int, str]) -> str:
             """, (group_id, *self.blacklist_freq_keyword)
         ).fetchone()
 
-        return query_result[0] if query_result is not None and query_result[0] is not None else ''
+        return fetch_one_or_default(query_result, '')
 
     def get_group_usage_literal(self, group_id: Union[int, str]) -> dict:
         group_id = str(group_id)
diff --git a/awesome/adminControl/user_control.py b/awesome/adminControl/user_control.py
index 2c8dfe7..8daf0b9 100644
--- a/awesome/adminControl/user_control.py
+++ b/awesome/adminControl/user_control.py
@@ -1,9 +1,10 @@
 import json
 from os.path import exists
-from typing import Union
+from typing import Union, Optional
 
 from nonebot import logger
 
+from Services.util.common_util import OptionalDict
 from awesome.Constants.user_permission import *
 from config import SUPER_USER
 
@@ -63,13 +64,7 @@ def get_user_privilege(self, user_id: Union[int, str], tag: USER_T) -> bool:
         if isinstance(user_id, int):
             user_id = str(user_id)
 
-        if user_id not in self.user_privilege:
-            return False
-
-        if tag not in self.user_privilege[user_id]:
-            return False
-
-        return self.user_privilege[user_id][tag]
+        return OptionalDict(self.user_privilege).map(user_id).map(tag).or_else(False)
 
     def set_user_repeat_question(self, user_id):
         if user_id not in self.user_repeat_question_count:
@@ -78,19 +73,16 @@ def set_user_repeat_question(self, user_id):
             self.user_repeat_question_count[user_id] += 1
 
     def get_user_repeat_question(self, user_id):
-        if user_id not in self.user_repeat_question_count:
-            return 0
-
-        return self.user_repeat_question_count[user_id]
+        return OptionalDict(self.user_repeat_question_count).map(user_id).or_else(0)
 
     def get_last_question(self) -> dict:
         return self.last_question
 
-    def get_last_question_by_group(self, group_id: Union[str, int]):
+    def get_last_question_by_group(self, group_id: Union[str, int]) -> Optional[str]:
         if isinstance(group_id, int):
             group_id = str(group_id)
 
-        return self.last_question[group_id] if group_id in self.last_question else None
+        return OptionalDict(self.last_question).map(group_id).or_else(None)
 
     def set_last_question_by_group(self, group_id: Union[str, int], msg: str):
         if isinstance(group_id, int):
diff --git a/awesome/plugins/admin_setting/__init__.py b/awesome/plugins/admin_setting/__init__.py
index 441190e..d356304 100644
--- a/awesome/plugins/admin_setting/__init__.py
+++ b/awesome/plugins/admin_setting/__init__.py
@@ -21,13 +21,15 @@
 from awesome.adminControl import get_privilege, user_control, setu_function_control
 from util.helper_util import set_group_permission
 
+_LAZY_RESPONSE = '可是我不想动哎.jpg'
+
 free_speech_cmd = on_command('自由发言')
 
 
 @free_speech_cmd.handle()
 async def free_speech_switch(event: GroupMessageEvent, matcher: Matcher):
     group_id = event.group_id
-    role = event.sender.role if event.sender.role is not None else 'member'
+    role = event.sender.role if event.sender.role else 'member'
 
     if group_id == -1 or (role == 'member' and not get_privilege(event.get_user_id(), OWNER)):
         return
@@ -190,8 +192,7 @@ async def send_answer(bot: Bot, event: GroupMessageEvent, matcher: Matcher, args
     response = _prefetch(question, get_user_id(event))
     if response:
         await matcher.send(
-            response + '\n'
-                       f'回答用时：{(time() - start_time):.2f}s'
+            response + f'\n回答用时：{(time() - start_time):.2f}s'
         )
     else:
         # math processing
@@ -199,7 +200,6 @@ async def send_answer(bot: Bot, event: GroupMessageEvent, matcher: Matcher, args
             response = _math_fetch(question, get_user_id(event))
 
         except Exception as err:
-            await matcher.send('计算时遇到了问题，本事件已上报bot主人进行分析。')
             await bot.send_private_msg(
                 user_id=config.SUPER_USER,
                 message=f'[{datetime.now().strftime("%Y-%m-%d %H:%M:%S")}] '
@@ -209,13 +209,9 @@ async def send_answer(bot: Bot, event: GroupMessageEvent, matcher: Matcher, args
                         f'使用人：{event.get_user_id()}\n'
                         f'来自群：{event.group_id}\n'
             )
-            return
+            await matcher.finish('计算时遇到了问题，本事件已上报bot主人进行分析。')
 
         if response:
-            await matcher.send(
-                response + '\n'
-                           f'回答用时：{(time() - start_time):.2f}s'
-            )
             await bot.send_private_msg(
                 user_id=config.SUPER_USER,
                 message=f'[{datetime.now().strftime("%Y-%m-%d %H:%M:%S")}] '
@@ -225,12 +221,13 @@ async def send_answer(bot: Bot, event: GroupMessageEvent, matcher: Matcher, args
                         f'使用人：{event.get_user_id()}\n'
                         f'来自群：{event.group_id}'
             )
+            await matcher.finish(f'{response}\n回答用时：{(time() - start_time):.2f}s')
 
         else:
             logger.info("It is not a normal question.")
             ai_process = _simple_ai_process(question, event)
             if question != ai_process:
-                await matcher.send(ai_process + f'\n回答用时：{(time() - start_time):.2f}s')
+                await matcher.send(f'{ai_process}\n回答用时：{(time() - start_time):.2f}s')
 
 
 def _simple_ai_process(question: str, event: GroupMessageEvent) -> str:
@@ -306,47 +303,47 @@ def _math_fetch(question: str, user_id: str) -> str:
 
     if 'factorial' in question:
         if len(question) > 20:
-            return '可是我不想动哎.jpg'
+            return _LAZY_RESPONSE
 
         if '**' in question:
-            return '可是我不想动哎.jpg'
+            return _LAZY_RESPONSE
 
         if 'pow' in question:
-            return '可是我不想动哎.jpg'
+            return _LAZY_RESPONSE
 
         fact_number = findall(r'.*?factorial\((\d+)\)', question)
         if fact_number:
             if int(fact_number[0]) > 500:
-                return '可是我不想动哎.jpg'
+                return _LAZY_RESPONSE
 
     if match(r'.*?<<', question):
         overflow_fetch = findall(r'.*?<<(\d+)', question)
         if overflow_fetch:
             if len(overflow_fetch) != 1:
-                return '可是我不想动哎.jpg'
+                return _LAZY_RESPONSE
             if int(overflow_fetch[0]) > 100:
-                return '可是我不想动哎.jpg'
+                return _LAZY_RESPONSE
 
     if match(r'.*?\*\*', question):
         if len(question) > 10:
-            return '可是我不想动哎.jpg'
+            return _LAZY_RESPONSE
 
         overflow_fetch = findall(r'.*?\*\*(\d+)', question)
         if overflow_fetch:
             if len(overflow_fetch) > 2:
-                return '可是我不想动哎.jpg'
+                return _LAZY_RESPONSE
             else:
                 if int(overflow_fetch[0]) > 99:
-                    return '可是我不想动哎.jpg'
+                    return _LAZY_RESPONSE
                 if len(overflow_fetch) == 2 and int(overflow_fetch[1]) > 2:
-                    return '可是我不想动哎.jpg'
+                    return _LAZY_RESPONSE
 
     if match(r'.*?pow\(\d+,\d+\)', question):
         if len(question) > 10:
-            return '可是我不想动哎.jpg'
+            return _LAZY_RESPONSE
 
         if int(findall(r'.*?pow\(\d+,(\d+)\)', question)[0]) > 99:
-            return '可是我不想动哎.jpg'
+            return _LAZY_RESPONSE
 
     if match(r'.*?\\u\d+', question) or match(r'.*?\\\w{3}', question):
         return '你说你马呢（'
@@ -368,11 +365,9 @@ def _math_fetch(question: str, user_id: str) -> str:
         return ''
 
     if is_float(answer):
-        return f'运算结果是：{answer:.2f}' \
-               '\n我算的对吧~'
+        return f'运算结果是：{answer:.2f}\n我算的对吧~'
     else:
-        return f'计算结果：{answer}\n' \
-               f'请注意，本次计算已被汇报。'
+        return f'计算结果：{answer}\n请注意，本次计算已被汇报。'
 
 
 def _prefetch(question: str, user_id: str) -> str:
diff --git a/awesome/plugins/chitchat/__init__.py b/awesome/plugins/chitchat/__init__.py
index 814f859..5bcaffa 100644
--- a/awesome/plugins/chitchat/__init__.py
+++ b/awesome/plugins/chitchat/__init__.py
@@ -1,7 +1,6 @@
 from os import getcwd, listdir
 from os.path import exists
-from random import seed, randint, choice
-from time import time_ns
+from random import choice
 
 from nonebot import on_command
 from nonebot.adapters.onebot.v11 import GroupMessageEvent, Message, MessageSegment
@@ -12,7 +11,6 @@
 
 from Services import global_rate_limiter
 from Services.rate_limiter import UserLimitModifier
-from Services.util.ctx_utility import get_nickname
 from Services.util.download_helper import download_image
 from awesome.Constants import user_permission as perm
 from awesome.Constants.plugins_command_constants import ADD_PIC_PROMPT, CHITCHAT_PIC_TYPES, CHITCHAT_PIC_DICT
@@ -50,23 +48,6 @@ async def change_question_mark(event: GroupMessageEvent, matcher: Matcher):
     await matcher.finish('¿?¿?')
 
 
-neigui_cmd = on_command('内鬼', aliases={'有没有内鬼'})
-
-
-@neigui_cmd.handle()
-async def nei_gui_response(event: GroupMessageEvent, matcher: Matcher):
-    seed(time_ns())
-    rand_num = randint(0, 50)
-    if rand_num >= 26 and not get_privilege(event.get_user_id(), perm.OWNER):
-        qq_num = event.get_user_id()
-        await matcher.send(f'哦屑！有内鬼！终止交易！！ \n'
-                           f'TA的QQ号是：{qq_num}！！！ \n'
-                           f'QQ昵称是：{get_nickname(event)}')
-
-    else:
-        await matcher.send('一切安全！开始交易！')
-
-
 useless_cmd = on_command('我什么都不行', aliases={'什么都不行', '都不行', '不行', '流泪猫猫头'})
 
 
diff --git a/awesome/plugins/games/__init__.py b/awesome/plugins/games/__init__.py
index 21c6260..64eed1e 100644
--- a/awesome/plugins/games/__init__.py
+++ b/awesome/plugins/games/__init__.py
@@ -1,6 +1,6 @@
-import datetime
-import re
+from datetime import datetime
 from random import randint, seed
+from re import split, findall, fullmatch
 from time import time_ns
 from typing import List
 
@@ -78,24 +78,25 @@ def __init__(self, throw_times: int, result_sum: int, max_val: int, result_list:
 
 async def _dice_expr_evaluation(expression: str, result_sum: int, evaluation_target: float) -> bool:
     evaluation_result = False
-    if expression == '大于' or expression == '>':
-        evaluation_result = result_sum > evaluation_target
-    elif expression == '小于' or expression == '<':
-        evaluation_result = result_sum < evaluation_target
-    elif expression == '大于等于' or expression == '>=':
-        evaluation_result = result_sum >= evaluation_target
-    elif expression == '小于等于' or expression == '<=':
-        evaluation_result = result_sum <= evaluation_target
-    elif expression == '等于' or expression == '=' or expression == '==':
-        evaluation_result = result_sum == evaluation_target
-    elif expression == '不等于' or expression == '≠' or expression == '!=':
-        evaluation_result = result_sum != evaluation_target
+    match expression:
+        case '大于' | '>':
+            evaluation_result = result_sum > evaluation_target
+        case '小于' | '<':
+            evaluation_result = result_sum < evaluation_target
+        case '大于等于' | '>=':
+            evaluation_result = result_sum >= evaluation_target
+        case '小于等于' | '<=':
+            evaluation_result = result_sum <= evaluation_target
+        case '等于' | '=' | '==':
+            evaluation_result = result_sum == evaluation_target
+        case '不等于' | '≠' | '!=':
+            evaluation_result = result_sum != evaluation_target
 
     return evaluation_result
 
 
 async def _get_dice_result(text: str) -> DiceResult:
-    args = re.split(r'[dD]', text)
+    args = split(r'[dD]', text)
     throw_times = int(args[0])
     if throw_times > 30:
         throw_times = 30
@@ -167,7 +168,7 @@ async def _multiple_row_result(text_args: list) -> str:
 
 
 async def _evaluate_dice_expression(text: str):
-    all_dice_role_evaluation = re.findall(r'\d+[dD]\d+', text)
+    all_dice_role_evaluation = findall(r'\d+[dD]\d+', text)
     evaluation_list_result = [(await _get_dice_result(x)) for x in all_dice_role_evaluation]
     for idx, dice_text in enumerate(all_dice_role_evaluation):
         text = text.replace(dice_text, str(evaluation_list_result[idx].result_sum))
@@ -189,18 +190,18 @@ async def _evaluate_dice_expression(text: str):
 @dice_roll_cmd.handle()
 async def pao_tuan_shai_zi(event: GroupMessageEvent, matcher: Matcher, args: Message = CommandArg()):
     raw_message = args.extract_plain_text()
-    text_args = re.split(r'[,，\s]', raw_message)
+    text_args = split(r'[,，\s]', raw_message)
     text_args = [x.strip() for x in text_args if x]
 
     normal_decision = True
-    if all(re.fullmatch(r'^\d+[dD]\d+$', x) for x in text_args):
+    if all(fullmatch(r'^\d+[dD]\d+$', x) for x in text_args):
         await matcher.finish(await _multiple_row_result(text_args))
 
-    if re.fullmatch(r'^\d+[dD]\d+([+\-*/]\d+([dD]\d+)?)+$', text_args[0]):
+    if fullmatch(r'^\d+[dD]\d+([+\-*/]\d+([dD]\d+)?)+$', text_args[0]):
         await matcher.finish(await _evaluate_dice_expression(text_args[0]))
 
-    if not re.fullmatch(r'^\d+[dD]\d+$', text_args[0]):
-        if not re.fullmatch(r'^\d+([dD]\d+)?/\d+([dD]\d+)?$', text_args[0]):
+    if not fullmatch(r'^\d+[dD]\d+$', text_args[0]):
+        if not fullmatch(r'^\d+([dD]\d+)?/\d+([dD]\d+)?$', text_args[0]):
             await matcher.finish('用法错误：应为“xdy”, x 可以 = y，示例：1d100。如需自动判定，则可添加表达式：1d100 < 5')
         else:
             normal_decision = False
@@ -257,7 +258,7 @@ async def russian_roulette(event: GroupMessageEvent, matcher: Matcher):
             return
 
         rand_num = 60 * 2
-        if 0 < datetime.datetime.now().hour < 4 and config.ENABLE_GOOD_NIGHT_MODE:
+        if 0 < datetime.now().hour < 4 and config.ENABLE_GOOD_NIGHT_MODE:
             rand_num = 60 * 60 * 6
             await matcher.send('晚安')
 
diff --git a/awesome/plugins/little_helper/__init__.py b/awesome/plugins/little_helper/__init__.py
index 92d5fb9..6a7ac10 100644
--- a/awesome/plugins/little_helper/__init__.py
+++ b/awesome/plugins/little_helper/__init__.py
@@ -44,8 +44,7 @@ async def search_command(_event: GroupMessageEvent, matcher: Matcher):
 @global_help_cmd.handle()
 async def send_help(_event: GroupMessageEvent, matcher: Matcher):
     await matcher.send(
-        '请移步\n'
-        'https://github.com/remiliacn/Lingye-Bot/blob/master/README.md\n'
+        '请移步\nhttps://github.com/remiliacn/Lingye-Bot/blob/master/README.md\n'
         '如果有新功能想要添加，请提交issue!'
     )
 
diff --git a/awesome/plugins/natural_language/__init__.py b/awesome/plugins/natural_language/__init__.py
index 097cf8f..4a95462 100644
--- a/awesome/plugins/natural_language/__init__.py
+++ b/awesome/plugins/natural_language/__init__.py
@@ -1,7 +1,6 @@
-import re
 from os import getcwd
 from random import seed, randint
-from re import fullmatch, match
+from re import fullmatch, match, findall, sub
 from time import time_ns
 from typing import List
 
@@ -93,11 +92,11 @@ async def natural_language_proc(bot: Bot, event: GroupMessageEvent, matcher: Mat
 
 async def _check_if_asking_definition(message: str) -> str:
     keyword_regex = r'(.*?)是个?(什么|啥)'
-    if re.match(keyword_regex, message) and '不是' not in message:
+    if match(keyword_regex, message) and '不是' not in message:
         logger.success(f'hit asking definition. {message}')
         if randint(0, 10) < 5:
             logger.success('hit random chance.')
-            extracted_keyword = re.findall(keyword_regex, message)
+            extracted_keyword = findall(keyword_regex, message)
 
             if not extracted_keyword:
                 return ''
@@ -138,7 +137,7 @@ def _extract_keyword_from_sentence(key_word: str) -> str:
         return ''
 
     key_word = words[-1][0]
-    key_word = re.sub(r'[，。、；’【】！￥…（）《》？：”“‘]', '', key_word)
+    key_word = sub(r'[，。、；’【】！￥…（）《》？：”“‘]', '', key_word)
     return key_word
 
 
diff --git a/awesome/plugins/setu/__init__.py b/awesome/plugins/setu/__init__.py
index ce7b41d..e08d65c 100644
--- a/awesome/plugins/setu/__init__.py
+++ b/awesome/plugins/setu/__init__.py
@@ -159,9 +159,9 @@ async def pixiv_send(bot: Bot, event: GroupMessageEvent | PrivateMessageEvent, m
     # 限流5秒单用户只能请求一次。
     user_limit = UserLimitModifier(5.0, 1.0, True)
     rate_limiter_check = await global_rate_limiter.user_limit_check(SETU, user_id, user_limit)
-    if isinstance(rate_limiter_check, str):
+    if rate_limiter_check.is_limited:
         await matcher.finish(
-            construct_message_chain(MessageSegment.reply(message_id), rate_limiter_check))
+            construct_message_chain(MessageSegment.reply(message_id), rate_limiter_check.prompt))
 
     monitored = False
 
diff --git a/awesome/plugins/shadiao/__init__.py b/awesome/plugins/shadiao/__init__.py
index 1b3851f..4f7ff51 100644
--- a/awesome/plugins/shadiao/__init__.py
+++ b/awesome/plugins/shadiao/__init__.py
@@ -14,19 +14,16 @@
 from nonebot.message import event_preprocessor
 from nonebot.params import CommandArg
 
-from Services import ark_nights, shadiao, global_rate_limiter
+from Services import shadiao, global_rate_limiter
 from Services.util.common_util import HttpxHelperClient
-from Services.util.ctx_utility import get_nickname, get_user_id, get_group_id
+from Services.util.ctx_utility import get_user_id, get_group_id
 from Services.util.download_helper import download_image
 from awesome.Constants import user_permission as perm, group_permission
-from awesome.Constants.function_key import ARKNIGHTS_PULLS, ARKNIGHTS_SINGLE_PULL, ARKNIGHTS_SIX_STAR_PULL, \
+from awesome.Constants.function_key import ARKNIGHTS_SIX_STAR_PULL, \
     YULU_CHECK, ARKNIGHTS_BAD_LUCK_PULL, POKER_GAME, SETU, QUESTION, HIT_XP, ROULETTE_GAME, HORSE_RACE
 from awesome.adminControl import get_privilege, group_control, setu_function_control
 from config import SUPER_USER
-from util.helper_util import ark_helper, set_group_permission, construct_message_chain
-
-arknights_api = ark_nights.ArkHeadhunt(times=10)
-ark_pool_pity = ark_nights.ArknightsPity()
+from util.helper_util import set_group_permission, construct_message_chain
 
 timeout = aiohttp.ClientTimeout(total=5)
 
@@ -48,8 +45,6 @@
 ocr = on_command('图片识别')
 how_lewd_cmd = on_command('你群有多色')
 set_r18_cmd = on_command('设置R18')
-ten_roll_cmd_arknights = on_command('方舟十连')
-arknights_up = on_command('方舟up', aliases={'方舟UP'})
 help_me_choose_cmd = on_command('帮我做选择')
 
 
@@ -97,8 +92,8 @@ async def get_group_quotes(session: GroupMessageEvent, matcher: Matcher):
         group_id,
         time_period=15,
         function_limit=2)
-    if isinstance(rate_limiter_check, str):
-        await matcher.finish(construct_message_chain(MessageSegment.reply(message_id), rate_limiter_check))
+    if rate_limiter_check.is_limited:
+        await matcher.finish(construct_message_chain(MessageSegment.reply(message_id), rate_limiter_check.prompt))
 
     nickname = session.sender.nickname
 
@@ -217,66 +212,6 @@ async def set_r18(session: GroupMessageEvent, matcher: Matcher, stats: Annotated
     await matcher.finish('Done!')
 
 
-@ten_roll_cmd_arknights.handle()
-async def ten_polls(bot: Bot, session: GroupMessageEvent):
-    if get_privilege(get_user_id(session), perm.OWNER):
-        arknights_api.get_randomized_results(98)
-
-    else:
-        offset = ark_pool_pity.get_offset_setting(get_group_id(session))
-        arknights_api.get_randomized_results(offset)
-        class_list = arknights_api.random_class
-        six_star_count = class_list.count(6) + class_list.count(-1)
-        if 6 in class_list or -1 in class_list:
-            ark_pool_pity.reset_offset(get_group_id(session))
-
-        five_star_count = class_list.count(5)
-
-        data = {
-            "6": six_star_count,
-            "5": five_star_count,
-            "4": class_list.count(4),
-            "3": class_list.count(3)
-        }
-
-        nickname = get_nickname(session)
-
-        if six_star_count == 0 and five_star_count == 0:
-            setu_function_control.set_user_data(get_user_id(session), ARKNIGHTS_BAD_LUCK_PULL, nickname)
-
-        setu_function_control.set_group_data(group_id=get_group_id(session), tag=ARKNIGHTS_PULLS, data=data)
-        setu_function_control.set_group_data(group_id=get_group_id(session), tag=ARKNIGHTS_SINGLE_PULL)
-        setu_function_control.set_user_data(get_user_id(session), ARKNIGHTS_SIX_STAR_PULL, six_star_count)
-
-    qq_num = get_user_id(session)
-    await bot.send_group_msg(
-        group_id=session.group_id,
-        message=construct_message_chain(MessageSegment.at(qq_num), arknights_api.__str__()))
-
-
-@arknights_up.got(
-    'key_word',
-    prompt='使用方法：！方舟up 干员名 星级（数字）是否限定(y/n) 是否二级限定(y/n)')
-async def up_ten_polls(session: GroupMessageEvent, matcher: Matcher,
-                       key_word: Annotated[str, ArgStr('key_word')]):
-    if not get_privilege(get_user_id(session), perm.OWNER):
-        await matcher.finish('您无权使用本功能')
-
-    args = key_word.split()
-    validation = ark_helper(args)
-    if validation:
-        await matcher.finish(validation)
-
-    await matcher.finish(
-        arknights_api.up_op(
-            args[0],
-            args[1],
-            args[2].lower() == 'y',
-            args[3].lower() == 'y'
-        )
-    )
-
-
 @help_me_choose_cmd.handle()
 async def do_mcq(bot: Bot, session: GroupMessageEvent):
     raw_message = session.raw_message
@@ -295,35 +230,6 @@ async def do_mcq(bot: Bot, session: GroupMessageEvent):
     await bot.send_group_msg(group_id=session.group_id, message=answer + '。')
 
 
-up_reset_cmd = on_command('方舟up重置', aliases={'方舟UP重置', 'UP重置'})
-
-
-@up_reset_cmd.handle()
-async def reset_ark_up(session: GroupMessageEvent, matcher: Matcher):
-    if not get_privilege(get_user_id(session), perm.OWNER):
-        await matcher.finish('您无权使用本功能')
-
-    arknights_api.clear_ups()
-    await matcher.finish('Done!')
-
-
-add_arknights_operator_cmd = on_command('添加干员')
-
-
-@add_arknights_operator_cmd.got('key_word', prompt='使用方法：！方舟up 干员名 星级（数字）')
-async def add_ark_op(session: GroupMessageEvent, matcher: Matcher,
-                     key_word: Annotated[str, ArgStr('key_word')]):
-    if not get_privilege(get_user_id(session), perm.OWNER):
-        await matcher.finish('您无权使用本功能')
-
-    args = key_word.split()
-    validation = ark_helper(args)
-    if validation:
-        await matcher.finish(validation)
-
-    await matcher.finish(arknights_api.add_op(args[0], args[1]))
-
-
 def get_stat(key: str, lis: dict) -> (int, int):
     return lis[key]['count'] if key in lis else 0, lis[key]['rank'] if key in lis else 0
 
diff --git a/awesome/plugins/stonk/stonk.py b/awesome/plugins/stonk/stonk.py
index 54de4be..b1e3918 100644
--- a/awesome/plugins/stonk/stonk.py
+++ b/awesome/plugins/stonk/stonk.py
@@ -1,3 +1,6 @@
+"""
+This function is currently deprecated and waiting for a rewrite.
+"""
 # import re
 # import traceback
 # from asyncio.log import logger
diff --git a/awesome/plugins/vtuber_functions/__init__.py b/awesome/plugins/vtuber_functions/__init__.py
index 8827742..589caf3 100644
--- a/awesome/plugins/vtuber_functions/__init__.py
+++ b/awesome/plugins/vtuber_functions/__init__.py
@@ -90,7 +90,8 @@ async def twitch_live_tracking(bot: Bot, event: GroupMessageEvent, matcher: Matc
     await matcher.send(download_status.message)
     try:
         temp_group_filename = f'{str(int(time()))}.mp4'
-        temp_group_filename = twitch_clip_instruction.file_name if twitch_clip_instruction.file_name else temp_group_filename
+        temp_group_filename = \
+            twitch_clip_instruction.file_name if twitch_clip_instruction.file_name else temp_group_filename
         if download_status.is_success and download_status.file_path:
             logger.info(f'Trying to upload the group file. {download_status.file_path}')
             await bot.call_api(
diff --git a/awesome/plugins/remilia_adventure/__init__.py b/data/bot/response/.gitkeep
similarity index 100%
rename from awesome/plugins/remilia_adventure/__init__.py
rename to data/bot/response/.gitkeep
diff --git a/awesome/plugins/remilia_adventure/remilia_adventure.py b/data/bot/stock/.gitkeep
similarity index 100%
rename from awesome/plugins/remilia_adventure/remilia_adventure.py
rename to data/bot/stock/.gitkeep
diff --git a/data/db/.gitkeep b/data/db/.gitkeep
new file mode 100644
index 0000000..e69de29
diff --git a/model/common_model.py b/model/common_model.py
new file mode 100644
index 0000000..36b0c2c
--- /dev/null
+++ b/model/common_model.py
@@ -0,0 +1,44 @@
+from dataclasses import dataclass, field
+from typing import Optional, List
+
+from nonebot.adapters.onebot.v11 import MessageSegment, Message
+
+
+@dataclass
+class Status:
+    is_success: bool
+    message: any
+
+
+@dataclass
+class RateLimitStatus:
+    is_limited: bool
+    prompt: Optional[str]
+
+
+@dataclass
+class ValidatedTimestampStatus(Status):
+    validated_timestamp: str = ''
+
+
+@dataclass
+class TwitchDownloadStatus(Status):
+    file_path: str = ''
+
+
+@dataclass
+class DiscordMessageStatus(Status):
+    message: List[MessageSegment] = field(default_factory=lambda: [])
+    group_to_notify: str = ''
+    has_update: bool = False
+    is_edit: bool = False
+
+
+@dataclass
+class DiscordGroupNotification(Status):
+    message: Message
+    has_update: bool
+    group_to_notify: str
+    channel_name: str
+    channel_id: str
+    is_edit: bool
diff --git a/util/db_utils.py b/util/db_utils.py
new file mode 100644
index 0000000..61cad18
--- /dev/null
+++ b/util/db_utils.py
@@ -0,0 +1,5 @@
+from typing import Any, Union
+
+
+def fetch_one_or_default(fetch_one_result: Union[list, tuple], default_value: Any) -> Any:
+    return fetch_one_result[0] if fetch_one_result and fetch_one_result[0] else default_value