From d379e30cb27927a388308fc3501ba8f5a7cd74c2 Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Wed, 10 Apr 2024 01:20:18 +0800
Subject: [PATCH 01/12] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=97=A0=E6=B3=95?=
 =?UTF-8?q?=E5=90=AF=E5=8A=A8=E6=8F=92=E4=BB=B6=E7=9A=84bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/plugins/review/reviewer.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tieba-admin-server/plugins/review/reviewer.py b/tieba-admin-server/plugins/review/reviewer.py
index 5714158..8e2e319 100644
--- a/tieba-admin-server/plugins/review/reviewer.py
+++ b/tieba-admin-server/plugins/review/reviewer.py
@@ -204,7 +204,7 @@ async def on_start(self):
     async def on_running(self):
         user: User = await self.FUP.user
         self.client = await Client(user.BDUSS, user.STOKEN).__aenter__()
-        await asyncio.gather(*[self.run_with_client(self.client)], return_exceptions=True)
+        await asyncio.gather(*[self.run_with_client(self.client)])
 
     async def on_stop(self):
         try:

From 23b7f752b52349165eb6253708829b61b95c6455 Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Wed, 10 Apr 2024 01:25:03 +0800
Subject: [PATCH 02/12] =?UTF-8?q?=E4=BF=AE=E5=A4=8D<class=20're.error'>:?=
 =?UTF-8?q?=20nothing=20to=20repeat=20at=20position=200?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/plugins/review/checker.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tieba-admin-server/plugins/review/checker.py b/tieba-admin-server/plugins/review/checker.py
index 9a5b10e..e1bdc7f 100644
--- a/tieba-admin-server/plugins/review/checker.py
+++ b/tieba-admin-server/plugins/review/checker.py
@@ -139,7 +139,7 @@ async def check_keyword(t: Union[Thread, Post, Comment], client: Client):
     if t.user.level in Level.LOW.value:
         keywords = await Keyword.all()
         for kw in keywords:
-            if re.search(kw.keyword, t.text):
+            if re.search(fr"[{kw.keyword}]", t.text):
                 return delete(client, t)
     return empty()
 

From 18d8d06876b545d6443753359f880d6b754d18a9 Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Wed, 10 Apr 2024 14:50:00 +0800
Subject: [PATCH 03/12] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=8F=92=E4=BB=B6?=
 =?UTF-8?q?=E9=A1=B5=E9=9D=A2=E6=98=BE=E7=A4=BAbug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-web/src/pages/Manager.vue | 2 +-
 tieba-admin-web/src/pages/Module.vue  | 6 +++++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/tieba-admin-web/src/pages/Manager.vue b/tieba-admin-web/src/pages/Manager.vue
index c3cd19a..f8e9745 100644
--- a/tieba-admin-web/src/pages/Manager.vue
+++ b/tieba-admin-web/src/pages/Manager.vue
@@ -117,7 +117,7 @@ function submit(del = 0) {
 
 </script>
 
-<style>
+<style scoped>
 .min-width {
   min-width: 260px;
 }
diff --git a/tieba-admin-web/src/pages/Module.vue b/tieba-admin-web/src/pages/Module.vue
index 10fa93c..722489a 100644
--- a/tieba-admin-web/src/pages/Module.vue
+++ b/tieba-admin-web/src/pages/Module.vue
@@ -87,4 +87,8 @@ onMounted(() => {
 })
 </script>
 
-<style></style>
+<style scoped>
+.v-switch.v-input {
+  flex: 1 0 auto;
+}
+</style>

From 8911589597bd7b42b55efd0da54c393ced101782 Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Thu, 11 Apr 2024 21:47:05 +0800
Subject: [PATCH 04/12] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=AD=A3=E5=88=99?=
 =?UTF-8?q?=E8=A1=A8=E8=BE=BE=E5=BC=8F=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/plugins/review/checker.py | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/tieba-admin-server/plugins/review/checker.py b/tieba-admin-server/plugins/review/checker.py
index e1bdc7f..76f823f 100644
--- a/tieba-admin-server/plugins/review/checker.py
+++ b/tieba-admin-server/plugins/review/checker.py
@@ -1,4 +1,3 @@
-import re
 from enum import Enum
 from typing import Union, Callable, Coroutine, Dict, Any, Literal, List
 
@@ -139,7 +138,7 @@ async def check_keyword(t: Union[Thread, Post, Comment], client: Client):
     if t.user.level in Level.LOW.value:
         keywords = await Keyword.all()
         for kw in keywords:
-            if re.search(fr"[{kw.keyword}]", t.text):
+            if t.text.find(kw.keyword) != -1:
                 return delete(client, t)
     return empty()
 

From d1020bc00c20cb90c28974124e618982ecc42426 Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Thu, 11 Apr 2024 21:52:47 +0800
Subject: [PATCH 05/12] =?UTF-8?q?=E5=AF=B9=E7=AD=89=E7=BA=A7=E5=A2=99?=
 =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E6=9B=B4=E7=BB=86=E8=87=B4=E7=9A=84=E5=88=86?=
 =?UTF-8?q?=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/plugins/review/checker.py | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

diff --git a/tieba-admin-server/plugins/review/checker.py b/tieba-admin-server/plugins/review/checker.py
index 76f823f..858201b 100644
--- a/tieba-admin-server/plugins/review/checker.py
+++ b/tieba-admin-server/plugins/review/checker.py
@@ -151,8 +151,17 @@ async def check_black(t: Union[Thread, Post, Comment], client: Client):
     return empty()
 
 
-@manager.thread()
-async def ban_low_user(thread: Thread, client: Client):
-    if thread.user.level == 1:
+def _level_wall(level: int, thread: Thread, client: Client):
+    if thread.user.level == level:
         return delete(client, thread)
     return empty()
+
+
+@manager.thread()
+async def level_wall_1(thread: Thread, client: Client):
+    return _level_wall(1, thread, client)
+
+
+@manager.thread()
+async def level_wall_3(thread: Thread, client: Client):
+    return _level_wall(3, thread, client)

From 1192df892dd40bcd496090a3eb21898b7c03220f Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Thu, 11 Apr 2024 21:54:33 +0800
Subject: [PATCH 06/12] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E6=A0=B7=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/plugins/review/test_reviewer.py | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/tieba-admin-server/plugins/review/test_reviewer.py b/tieba-admin-server/plugins/review/test_reviewer.py
index 6516b5a..4e9d5f7 100644
--- a/tieba-admin-server/plugins/review/test_reviewer.py
+++ b/tieba-admin-server/plugins/review/test_reviewer.py
@@ -1,5 +1,7 @@
 import unittest
 
+from tortoise import Tortoise
+
 from .reviewer import Reviewer
 
 
@@ -7,9 +9,15 @@ class MyTestCase(unittest.IsolatedAsyncioTestCase):
     def __init__(self, method_name='runTest'):
         super().__init__(method_name)
 
+    async def test_init(self):
+        await Tortoise.init(db_url="sqlite://../../.cache/db.sqlite",
+                            modules={"models": ["core.models", "review.models"]})
+        await Reviewer.init_plugin()
+
     async def test_run(self):
         reviewer = Reviewer()
         reviewer.PLUGIN_MODEL = "review.models"
+
         await reviewer._start_plugin_with_process(
             db_url="sqlite://../../.cache/db.sqlite",
             log_level="DEBUG",

From d77ec10ff32d7428db0bc64c0f1a29208ff26475 Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Fri, 12 Apr 2024 17:33:24 +0800
Subject: [PATCH 07/12] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=BC=B9=E4=B8=AD?=
 =?UTF-8?q?=E6=96=87=E7=BF=BB=E8=AF=91=E7=9A=84=E9=97=AE=E9=A2=98=EF=BC=8C?=
 =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=A4=B4=E5=83=8F=E5=8A=A0=E8=BD=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-web/index.html       |  2 +-
 tieba-admin-web/src/App.vue      | 57 ++++++++++++++++++--------------
 tieba-admin-web/src/store/app.ts |  7 ++++
 3 files changed, 41 insertions(+), 25 deletions(-)

diff --git a/tieba-admin-web/index.html b/tieba-admin-web/index.html
index b7ecd6b..ad8d656 100644
--- a/tieba-admin-web/index.html
+++ b/tieba-admin-web/index.html
@@ -1,5 +1,5 @@
 <!DOCTYPE html>
-<html lang="en">
+<html lang="zh">
 
 <head>
     <meta charset="UTF-8"/>
diff --git a/tieba-admin-web/src/App.vue b/tieba-admin-web/src/App.vue
index adf8ae5..7808893 100644
--- a/tieba-admin-web/src/App.vue
+++ b/tieba-admin-web/src/App.vue
@@ -7,24 +7,24 @@
       </v-toolbar>
       <v-container>
         <v-navigation-drawer
-            mobile-breakpoint="sm"
-            v-model="drawer"
-            expand-on-hover rail width="260">
+          mobile-breakpoint="sm"
+          v-model="drawer"
+          expand-on-hover rail width="260">
           <v-list class="py-0">
-            <v-list-item :prepend-avatar="select_info[0][2]"
+            <v-list-item :prepend-avatar="select_info[0].icon"
                          :title="user.username"
                          :subtitle="user.permission"
-                         :to="'/'+select_info[0][0]"/>
+                         :to="'/'+select_info[0].uri"/>
           </v-list>
           <v-divider></v-divider>
 
           <v-list density="compact" nav>
             <v-list-item v-for="i in select_info.slice(1)"
-                         :prepend-icon="i[2]"
-                         :title="i[1]"
-                         :value="i[0]"
-                         :key="i[0]"
-                         :to="'/'+i[0]"></v-list-item>
+                         :prepend-icon="i.icon"
+                         :title="i.title"
+                         :value="i.uri"
+                         :key="i.uri"
+                         :to="'/'+i.uri"></v-list-item>
           </v-list>
           <template v-slot:append>
             <div class="pa-2">
@@ -49,7 +49,7 @@
 }
 </style>
 <script lang="ts" setup>
-import {onMounted, ref} from "vue";
+import {ref, watch} from "vue";
 import {useAppStore} from "@/store/app";
 import {storeToRefs} from "pinia";
 import {get_portrait} from "@/net/api";
@@ -57,26 +57,35 @@ import router from "@/router";
 
 const store = useAppStore()
 
-const select_info = ref([
-  ["profile", "概览", ""],
-  ["modules", "功能管理", "mdi-pencil"],
-  ["logcat", "操作日志", "mdi-history"],
-  ["manager", "成员管理", "mdi-account-cog"],
-  ["account", "个人中心", "mdi-home-account"]
+interface SelectInfo {
+  uri: string
+  title: string
+  icon: string
+}
+
+const select_info = ref<SelectInfo[]>([
+  {uri: "profile", title: "概览", icon: ""},
+  {uri: "modules", title: "功能管理", icon: "mdi-pencil"},
+  {uri: "logcat", title: "操作日志", icon: "mdi-history"},
+  {uri: "manager", title: "成员管理", icon: "mdi-account-cog"},
+  {uri: "account", title: "个人中心", icon: "mdi-home-account"}
 ])
 const drawer = ref(true)
-const {user} = storeToRefs(store)
-const {title} = storeToRefs(store)
+const {user, title} = storeToRefs(store)
 
 function exit() {
   store.exit()
-  router.push("/")
+  router.push("/login")
 }
 
-onMounted(() => {
-  get_portrait().then((res) => {
-    select_info.value[0][2] = "https://gss0.bdstatic.com/6LZ1dD3d1sgCo2Kml5_Y_D3/sys/portrait/item/" + res.data.data
-  })
+watch(() => store.is_login, (nv, ov) => {
+  if (nv) {
+    get_portrait().then((res) => {
+      select_info.value[0].icon = `http://tb.himg.baidu.com/sys/portraitn/item/${
+        res.data.data}?t=${Math.floor(Date.now() / 1000)}`
+    })
+  }
+
 })
 
 </script>
diff --git a/tieba-admin-web/src/store/app.ts b/tieba-admin-web/src/store/app.ts
index 8f78d22..ae056a4 100644
--- a/tieba-admin-web/src/store/app.ts
+++ b/tieba-admin-web/src/store/app.ts
@@ -11,6 +11,7 @@ interface User {
 export const useAppStore = defineStore('app', {
   state: () => ({
     title: '概览',
+    is_login: false,
     user: {
       token: '',
       uid: 0,
@@ -29,6 +30,7 @@ export const useAppStore = defineStore('app', {
     },
     set_token_access(token: string) {
       this.user.token = 'Bearer ' + token
+      this.is_login = true
     },
     set_user(object: User) {
       this.user.uid = object.uid
@@ -38,6 +40,11 @@ export const useAppStore = defineStore('app', {
     },
     exit() {
       this.user.token = ""
+      this.user.uid = 0
+      this.user.tuid = 0
+      this.user.username = ""
+      this.user.permission = ""
+      this.is_login = false
     },
   },
   persist: {

From 27c198e19a54e4120c23212f9bb7240aafc6a1f7 Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Fri, 12 Apr 2024 18:08:00 +0800
Subject: [PATCH 08/12] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=A4=B4=E5=83=8F?=
 =?UTF-8?q?=E5=8A=A0=E8=BD=BD=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-web/src/App.vue      | 18 +++++++++++++-----
 tieba-admin-web/src/store/app.ts | 10 ++++++----
 2 files changed, 19 insertions(+), 9 deletions(-)

diff --git a/tieba-admin-web/src/App.vue b/tieba-admin-web/src/App.vue
index 7808893..3021906 100644
--- a/tieba-admin-web/src/App.vue
+++ b/tieba-admin-web/src/App.vue
@@ -13,7 +13,6 @@
           <v-list class="py-0">
             <v-list-item :prepend-avatar="select_info[0].icon"
                          :title="user.username"
-                         :subtitle="user.permission"
                          :to="'/'+select_info[0].uri"/>
           </v-list>
           <v-divider></v-divider>
@@ -49,7 +48,7 @@
 }
 </style>
 <script lang="ts" setup>
-import {ref, watch} from "vue";
+import {onMounted, ref, watch} from "vue";
 import {useAppStore} from "@/store/app";
 import {storeToRefs} from "pinia";
 import {get_portrait} from "@/net/api";
@@ -78,14 +77,23 @@ function exit() {
   router.push("/login")
 }
 
+onMounted(() => {
+  set_portrait2icon()
+})
+
 watch(() => store.is_login, (nv, ov) => {
   if (nv) {
     get_portrait().then((res) => {
-      select_info.value[0].icon = `http://tb.himg.baidu.com/sys/portraitn/item/${
-        res.data.data}?t=${Math.floor(Date.now() / 1000)}`
+      store.set_portrait(res.data.data)
+      set_portrait2icon()
     })
+  } else {
+    select_info.value[0].icon = ""
   }
-
 })
 
+function set_portrait2icon() {
+  select_info.value[0].icon = `http://tb.himg.baidu.com/sys/portraitn/item/${
+    store.user.portrait}?t=${Math.floor(Date.now() / 1000)}`
+}
 </script>
diff --git a/tieba-admin-web/src/store/app.ts b/tieba-admin-web/src/store/app.ts
index ae056a4..06a1771 100644
--- a/tieba-admin-web/src/store/app.ts
+++ b/tieba-admin-web/src/store/app.ts
@@ -17,7 +17,7 @@ export const useAppStore = defineStore('app', {
       uid: 0,
       tuid: 0,
       username: '',
-      permission: '',
+      portrait: '',
     }
   }),
   actions: {
@@ -36,19 +36,21 @@ export const useAppStore = defineStore('app', {
       this.user.uid = object.uid
       this.user.tuid = object.tuid
       this.user.username = object.username
-      this.user.permission = object.permission
     },
     exit() {
       this.user.token = ""
       this.user.uid = 0
       this.user.tuid = 0
       this.user.username = ""
-      this.user.permission = ""
       this.is_login = false
+      this.user.portrait = ""
     },
+    set_portrait(portrait: string) {
+      this.user.portrait = portrait
+    }
   },
   persist: {
     storage: window.localStorage,
-    paths: ['user.token']
+    paths: ['user', 'is_login']
   }
 })

From 35ae362433b47d9232b69cef0b546ef0894610bc Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Fri, 12 Apr 2024 19:34:01 +0800
Subject: [PATCH 09/12] =?UTF-8?q?=E5=B0=86=E5=AE=A1=E6=9F=A5=E8=BF=87?=
 =?UTF-8?q?=E7=A8=8B=E5=85=A8=E9=9D=A2=E6=94=B9=E4=B8=BA=E5=BC=82=E6=AD=A5?=
 =?UTF-8?q?=E6=93=8D=E4=BD=9C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/plugins/review/execute.py  |  13 +
 tieba-admin-server/plugins/review/reviewer.py | 240 ++++++++++++------
 2 files changed, 169 insertions(+), 84 deletions(-)

diff --git a/tieba-admin-server/plugins/review/execute.py b/tieba-admin-server/plugins/review/execute.py
index 6219ab6..6de7114 100644
--- a/tieba-admin-server/plugins/review/execute.py
+++ b/tieba-admin-server/plugins/review/execute.py
@@ -110,6 +110,19 @@ def exec_compare(self, exec2):
         elif exec2.option == self.option and exec2.opt_day > self.opt_day:
             self.opt_day = exec2.opt_day
 
+    def __str__(self):
+        return str(self.__dict__)
+
+    @property
+    def __dict__(self):
+        return {
+            "obj": self.obj.__dict__,
+            "user_opt": self.user_opt.name,
+            "option": self.option.name,
+            "user_day": self.user_day,
+            "opt_day": self.opt_day
+        }
+
 
 def empty():
     """
diff --git a/tieba-admin-server/plugins/review/reviewer.py b/tieba-admin-server/plugins/review/reviewer.py
index 8e2e319..9d5b2a0 100644
--- a/tieba-admin-server/plugins/review/reviewer.py
+++ b/tieba-admin-server/plugins/review/reviewer.py
@@ -1,14 +1,14 @@
 import asyncio
 import random
 from asyncio import sleep
-from typing import Tuple, List
+from typing import List
 
 from aiotieba import Client, PostSortType, logging
-from aiotieba.typing import Threads, Thread, Posts, Post, Comment
+from aiotieba.typing import Threads, Thread, Posts, Post, Comments, Comment
 from sanic.log import logger
 from tortoise import Tortoise, connections, ConfigurationError
 
-from core.models import ForumUserPermission, User, Config, ExecuteType, Permission
+from core.models import ForumUserPermission, User, Config, Permission
 from core.plugin import BasePlugin
 from . import execute
 from .checker import CheckMap, manager
@@ -31,6 +31,7 @@ def __init__(self, **kwargs):
         self.FUP: ForumUserPermission = None
         self.no_exec = True
         self.check_name_map = manager.check_name_map
+        self.semaphore = asyncio.Semaphore(8)
 
     async def check_threads(self, client: Client, fname: str):
         """
@@ -40,42 +41,49 @@ async def check_threads(self, client: Client, fname: str):
             fname: 贴吧名
 
         """
-        threads: List[Tuple[Thread, bool]] = []
-        origin_threads: Threads = await client.get_threads(fname)
+        async with self.semaphore:
+            first_threads: Threads = await client.get_threads(fname)
 
-        for thread in origin_threads:
-            prev_thread = await RThread.filter(tid=thread.tid).get_or_none()
-            if prev_thread:
-                if thread.last_time < prev_thread.last_time:
-                    await RThread.filter(tid=thread.tid).update(last_time=thread.last_time)
-                elif thread.last_time > prev_thread.last_time:
-                    threads.append((thread, True))
-                    await RThread.filter(tid=thread.tid).update(last_time=thread.last_time)
-            else:
-                threads.append((thread, False))
-                await RThread.create(tid=thread.tid, fid=await client.get_fid(fname), last_time=thread.last_time)
-
-        need_check_post: List[Thread] = []
-        for thread, checked in threads:
-            executor = execute.Executor(client=client, obj=thread)
-            if not checked:
-                for check in self.check_map['thread']:
-                    func_enable = await RFunction.get(function=check['function'].__name__)
-                    if not func_enable.enable:
-                        continue
-                    _executor = await check['function'](thread, client)
-                    if not _executor:
-                        raise TypeError("Need to return Executor object")
-                    executor.exec_compare(_executor)
-
-            if executor.option != ExecuteType.ThreadDelete:
-                need_check_post.append(thread)
+        need_next_check: List[Thread] = []
+
+        async def check_and_execute(ce_thread: Thread):
+            executor = execute.Executor(client=client, obj=ce_thread)
+
+            async def get_execute(_check):
+                func_enable = await RFunction.get(function=_check['function'].__name__)
+                if not func_enable.enable:
+                    return None
+                _executor = await _check['function'](ce_thread, client)
+                if not _executor:
+                    raise TypeError("Need to return Executor object")
+                executor.exec_compare(_executor)
+
+            await asyncio.gather(*[get_execute(check) for check in self.check_map['thread']])
 
             if not self.no_exec:
                 await executor.run()
+            else:
+                logger.debug(f"[review] {executor}")
 
-        for thread in need_check_post:
-            await self.check_posts(client, thread.tid)
+        async def check_last_time(clt_thread: Thread):
+            if clt_thread.is_livepost:
+                return None
+            prev_thread = await RThread.filter(tid=clt_thread.tid).get_or_none()
+            if prev_thread:
+                if clt_thread.last_time < prev_thread.last_time:
+                    await RThread.filter(tid=clt_thread.tid).update(last_time=clt_thread.last_time)
+                elif clt_thread.last_time > prev_thread.last_time:
+                    need_next_check.append(clt_thread)
+                    await RThread.filter(tid=clt_thread.tid).update(last_time=clt_thread.last_time)
+            else:
+                need_next_check.append(clt_thread)
+                await check_and_execute(clt_thread)
+                await RThread.create(tid=clt_thread.tid, fid=await client.get_fid(fname),
+                                     last_time=clt_thread.last_time)
+
+        await asyncio.gather(*[check_last_time(thread) for thread in first_threads])
+
+        await asyncio.gather(*[self.check_posts(client, thread.tid) for thread in need_next_check])
 
     async def check_posts(self, client: Client, tid: int):
         """
@@ -84,73 +92,136 @@ async def check_posts(self, client: Client, tid: int):
             client: 传入了执行账号的贴吧客户端
             tid: 所在主题贴id
         """
-        posts: List[Tuple[Post, bool]] = []
-        last_posts: Posts = await client.get_posts(tid, sort=PostSortType.DESC)
-        for post in last_posts:
-            prev_post = await RPost.filter(pid=post.pid).get_or_none()
-            if prev_post:
-                if post.reply_num < prev_post.reply_num:
-                    await RPost.filter(pid=post.pid).update(reply_num=post.reply_num)
-                elif post.reply_num > prev_post.reply_num:
-                    posts.append((post, True))
-                    await RPost.filter(pid=post.pid).update(reply_num=post.reply_num)
+        async with self.semaphore:
+            last_posts: Posts = await client.get_posts(
+                tid,
+                pn=0xFFFF,
+                sort=PostSortType.DESC,
+                with_comments=True,
+                comment_rn=10
+            )
+
+        if last_posts and last_posts[-1].floor != 1:
+            last_floor = last_posts[0].floor
+            need_rn = last_floor - len(last_posts)
+            if need_rn > 0:
+                post_set = set(last_posts.objs)
+                rn_clamp = 30
+                if need_rn <= rn_clamp:
+                    async with self.semaphore:
+                        first_posts = await client.get_posts(
+                            tid, rn=need_rn, with_comments=True, comment_rn=10
+                        )
+
+                    post_set.update(first_posts.objs)
+                else:
+                    async with self.semaphore:
+                        first_posts = await client.get_posts(
+                            tid, rn=rn_clamp, with_comments=True, comment_rn=10
+                        )
+
+                    post_set.update(first_posts.objs)
+
+                    async with self.semaphore:
+                        hot_posts = await client.get_posts(
+                            tid, sort=PostSortType.HOT, with_comments=True, comment_rn=10
+                        )
+
+                    post_set.update(hot_posts.objs)
+                posts = list(post_set)
             else:
-                posts.append((post, False))
-                await RPost.create(pid=post.pid, tid=tid, reply_num=post.reply_num)
-
-        need_check_comment: List[Post] = []
-        for post, checked in posts:
-            executor = execute.Executor(client=client, obj=post)
-            if not checked:
-                for check in self.check_map['post']:
-                    func_enable = await RFunction.get(function=check['function'].__name__)
-                    if not func_enable.enable:
-                        continue
-                    _executor = await check['function'](post, client)
-                    if not _executor:
-                        raise TypeError("Need to return Executor object")
-                    executor.exec_compare(_executor)
-
-            if executor.option != ExecuteType.PostDelete:
-                need_check_comment.append(post)
+                posts = last_posts.objs
+        else:
+            posts = last_posts.objs
+
+        need_next_check: List[Post] = []
+
+        async def check_and_execute(ce_post: Post):
+            executor = execute.Executor(client=client, obj=ce_post)
+
+            async def get_execute(_check):
+                func_enable = await RFunction.get(function=_check['function'].__name__)
+                if not func_enable.enable:
+                    return None
+                _executor = await _check['function'](ce_post, client)
+                if not _executor:
+                    raise TypeError("Need to return Executor object")
+                executor.exec_compare(_executor)
+
+            await asyncio.gather(*[get_execute(check) for check in self.check_map['post']])
 
             if not self.no_exec:
                 await executor.run()
+            else:
+                logger.debug(f"[review] {executor}")
+
+        async def check_reply_num(crn_post: Post):
+            prev_post = await RPost.filter(pid=crn_post.pid).get_or_none()
+            if prev_post:
+                if crn_post.reply_num < prev_post.reply_num:
+                    await RPost.filter(pid=crn_post.pid).update(reply_num=crn_post.reply_num)
+                elif crn_post.reply_num > prev_post.reply_num:
+                    need_next_check.append(crn_post)
+                    await RPost.filter(pid=crn_post.pid).update(reply_num=crn_post.reply_num)
+            else:
+                need_next_check.append(crn_post)
+                await check_and_execute(crn_post)
+                await RPost.create(pid=crn_post.pid, tid=tid, reply_num=crn_post.reply_num)
 
-        for post in need_check_comment:
-            await self.check_comment(client, post.pid, post.tid)
+        await asyncio.gather(*[check_reply_num(post) for post in posts])
 
-    async def check_comment(self, client: Client, pid: int, tid: int):
+        await asyncio.gather(
+            *[self.check_comment(client, post) for post in need_next_check]
+        )
+
+    async def check_comment(self, client: Client, post: Post):
         """
         检查楼中楼内容
         Args:
             client: 传入了执行账号的贴吧客户端
-            pid: 楼层id
-            tid: 主题贴id
+            post: 楼层
         """
-        comments: List[Comment] = []
-        count = 1
-        while origin_comments := await client.get_comments(tid, pid, pn=count):
-            for comment in origin_comments:
-                prev_comment = await RPost.filter(pid=comment.pid).get_or_none()
-                if not prev_comment:
-                    comments.append(comment)
-                    await RPost.create(pid=comment.pid, tid=comment.tid, ppid=pid)
-            count += 1
-
-        for comment in comments:
-            executor = execute.Executor(client=client, obj=comment)
-            for check in self.check_map['comment']:
-                func_enable = await RFunction.get(function=check['function'].__name__)
+
+        if post.reply_num > 10 or \
+                (len(post.comments) != post.reply_num and post.reply_num <= 10):
+
+            async with self.semaphore:
+                last_comments: Comments = await client.get_comments(
+                    post.tid, post.pid, pn=post.reply_num // 30 + 1
+                )
+
+            comment_set = set(post.comments)
+            comment_set.update(last_comments.objs)
+            comments = list(comment_set)
+        else:
+            comments = post.comments
+
+        async def check_and_execute(cae_comment: Comment):
+            executor = execute.Executor(client=client, obj=cae_comment)
+
+            async def get_execute(_check):
+                func_enable = await RFunction.get(function=_check['function'].__name__)
                 if not func_enable.enable:
-                    continue
-                _executor = await check['function'](comment, client)
+                    return None
+                _executor = await _check['function'](cae_comment, client)
                 if not _executor:
                     raise TypeError("Need to return Executor object")
                 executor.exec_compare(_executor)
 
+            await asyncio.gather(*[get_execute(check) for check in self.check_map['comment']])
+
             if not self.no_exec:
                 await executor.run()
+            else:
+                logger.debug(f"[review] {executor}")
+
+        async def check_comment_of_db(ccod_comment: Comment):
+            prev_comment = await RPost.filter(pid=ccod_comment.pid).get_or_none()
+            if not prev_comment:
+                await check_and_execute(ccod_comment)
+                await RPost.create(pid=ccod_comment.pid, tid=ccod_comment.tid, ppid=post.pid)
+
+        await asyncio.gather(*[check_comment_of_db(comment) for comment in comments])
 
     async def run_with_client(self, client: Client, min_time=10.0, max_time=20.0):
         """
@@ -197,6 +268,7 @@ async def on_start(self):
         logging.set_logger(logger)
         await Tortoise.init(db_url=self.kwargs["db_url"],
                             modules={"models": self.kwargs["models"]})
+        await Tortoise.generate_schemas()
 
         self.no_exec = await Config.get_bool(key="REVIEW_NO_EXEC")
         await self.get_fup()
@@ -204,7 +276,7 @@ async def on_start(self):
     async def on_running(self):
         user: User = await self.FUP.user
         self.client = await Client(user.BDUSS, user.STOKEN).__aenter__()
-        await asyncio.gather(*[self.run_with_client(self.client)])
+        await asyncio.gather(self.run_with_client(self.client))
 
     async def on_stop(self):
         try:

From fd74fce9b7e9bcb191a4659fa083823bda44a95a Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Fri, 12 Apr 2024 19:40:01 +0800
Subject: [PATCH 10/12] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=B3=A8=E9=87=8A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/core/account.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/tieba-admin-server/core/account.py b/tieba-admin-server/core/account.py
index 966dad9..234ee0d 100644
--- a/tieba-admin-server/core/account.py
+++ b/tieba-admin-server/core/account.py
@@ -78,6 +78,10 @@ async def first_login_api(rqt: Request):
 @protected()
 @scoped(Permission.ordinary(), False)
 async def change_password(rqt: Request, user: User):
+    """用于修改自己密码的接口
+
+
+    """
     if not rqt.form.get("password"):
         return json("参数错误", status_code=400)
 

From aacf840aececf2c6c05f66e9f5e331035f46a52c Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Fri, 12 Apr 2024 20:11:00 +0800
Subject: [PATCH 11/12] =?UTF-8?q?=E7=BB=9F=E4=B8=80=E8=BF=9B=E8=A1=8Cexcep?=
 =?UTF-8?q?tion=5Fhandle?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/core/account.py   | 13 +++++--------
 tieba-admin-server/core/exception.py | 16 +++-------------
 tieba-admin-server/core/log.py       |  3 ++-
 tieba-admin-server/core/manager.py   |  4 ++--
 tieba-admin-server/server.py         | 12 ++++++++----
 5 files changed, 20 insertions(+), 28 deletions(-)

diff --git a/tieba-admin-server/core/account.py b/tieba-admin-server/core/account.py
index 234ee0d..e0ad0a5 100644
--- a/tieba-admin-server/core/account.py
+++ b/tieba-admin-server/core/account.py
@@ -83,12 +83,9 @@ async def change_password(rqt: Request, user: User):
 
     """
     if not rqt.form.get("password"):
-        return json("参数错误", status_code=400)
+        raise ArgException
 
-    try:
-        validate_password(rqt.form.get("password"))
-        user.password = rqt.app.shared_ctx.password_hasher.hash(rqt.form.get('password'))
-        await user.save()
-        return json("修改密码成功")
-    except ArgException as e:
-        return json(e.message, status_code=e.status_code)
+    validate_password(rqt.form.get("password"))
+    user.password = rqt.app.shared_ctx.password_hasher.hash(rqt.form.get('password'))
+    await user.save()
+    return json("修改密码成功")
diff --git a/tieba-admin-server/core/exception.py b/tieba-admin-server/core/exception.py
index da70f7d..4369da5 100644
--- a/tieba-admin-server/core/exception.py
+++ b/tieba-admin-server/core/exception.py
@@ -1,19 +1,9 @@
-from typing import Optional
-
-from sanic import SanicException, response
+from sanic import SanicException
 
 
 class ArgException(SanicException):
     status_code = 400
+    message = "参数错误"
 
-    def __init__(self, message: str = "参数错误"):
+    def __init__(self, message: str):
         self.message = message
-
-
-def err_rps(e: Optional[SanicException] = None):
-    """
-    快速返回发生错误时的response
-    Args:
-        e: 发生的错误
-    """
-    return response.json({"status": e.status_code, "msg": e.message}, e.status_code)
diff --git a/tieba-admin-server/core/log.py b/tieba-admin-server/core/log.py
index beb8013..d993090 100644
--- a/tieba-admin-server/core/log.py
+++ b/tieba-admin-server/core/log.py
@@ -5,6 +5,7 @@
 from sanic.log import LOGGING_CONFIG_DEFAULTS
 from sanic_jwt import protected, scoped
 
+from core.exception import ArgException
 from core.models import Permission, ExecuteLog
 from core.utils import json
 
@@ -58,7 +59,7 @@ async def get_log(rqt: Request):
         if pn < 1:
             pn = 1
     except (TypeError, ValueError):
-        return json("参数错误")
+        raise ArgException
     offset = (pn - 1) * limit
     logs = await ExecuteLog.all().offset(offset).limit(limit)
     return json(data={"items": [await log.to_dict() for log in logs], "total": await ExecuteLog.all().count()})
diff --git a/tieba-admin-server/core/manager.py b/tieba-admin-server/core/manager.py
index 75efb0f..ff6b280 100644
--- a/tieba-admin-server/core/manager.py
+++ b/tieba-admin-server/core/manager.py
@@ -25,9 +25,9 @@ async def get(self, rqt: Request):
     @scoped(Permission.super(), False)
     async def post(self, rqt: Request, user: User):
         if not rqt.form.get("user") or not rqt.form.get("forum") or not rqt.form.get("pm"):
-            return json("参数错误")
+            raise ArgException
         if rqt.form.get("pm") not in [i.value for i in Permission]:
-            return json("参数错误")
+            raise ArgException
 
         try:
             async with aiotieba.Client() as client:
diff --git a/tieba-admin-server/server.py b/tieba-admin-server/server.py
index bb2e86b..8ef256f 100644
--- a/tieba-admin-server/server.py
+++ b/tieba-admin-server/server.py
@@ -6,7 +6,7 @@
 import aiotieba
 from argon2 import PasswordHasher
 from environs import Env
-from sanic import Sanic, Request, FileNotFound
+from sanic import Sanic, Request, FileNotFound, SanicException
 from sanic.log import logger
 from sanic.response import file
 from sanic.views import HTTPMethodView
@@ -15,6 +15,7 @@
 from tortoise.contrib.sanic import register_tortoise
 
 from core.account import bp_account
+from core.exception import ArgException
 from core.jwt import authenticate, retrieve_user, JwtConfig, JwtResponse, scope_extender
 from core.log import LOGGING_CONFIG, bp_log
 from core.manager import bp_manager
@@ -122,9 +123,12 @@ async def post(self, rqt: Request):
 app.add_route(PluginsStatus.as_view(), "/api/plugins/status")
 
 
-@app.exception([FileNotFound])
-async def file_not_found(rqt: Request, e: FileNotFound):
-    return await file("./web/index.html", status=404)
+@app.exception([FileNotFound, ArgException])
+async def exception_handle(rqt: Request, e: SanicException):
+    if isinstance(e, FileNotFound):
+        return await file("./web/index.html", status=404)
+    elif isinstance(e, ArgException):
+        return json(e.message, status_code=e.status_code)
 
 
 if app.ctx.env.bool("WEB", True):

From 38750ad30692280fa21fa9ef58e4f0ddeb0bf56d Mon Sep 17 00:00:00 2001
From: adk23333 <2633103794@qq.com>
Date: Fri, 12 Apr 2024 20:15:25 +0800
Subject: [PATCH 12/12] =?UTF-8?q?=E7=BB=9F=E4=B8=80=E8=BF=9B=E8=A1=8Cexcep?=
 =?UTF-8?q?tion=5Fhandle=20fix.1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tieba-admin-server/core/exception.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tieba-admin-server/core/exception.py b/tieba-admin-server/core/exception.py
index 4369da5..5dbd426 100644
--- a/tieba-admin-server/core/exception.py
+++ b/tieba-admin-server/core/exception.py
@@ -5,5 +5,5 @@ class ArgException(SanicException):
     status_code = 400
     message = "参数错误"
 
-    def __init__(self, message: str):
+    def __init__(self, message: str = "参数错误"):
         self.message = message