Merge pull request #54 from sunmh207/feature/20250321-config

dashboard增加按项目名称查询

Author: sunmh207

biz/service/review_service.py

@@ -63,7 +63,7 @@ def insert_mr_review_log(entity: MergeRequestReviewEntity):
             print(f"Error inserting review log: {e}")
 
     @staticmethod
-    def get_mr_review_logs(authors: list = None, updated_at_gte: int = None,
+    def get_mr_review_logs(authors: list = None, project_names: list = None, updated_at_gte: int = None,
                            updated_at_lte: int = None) -> pd.DataFrame:
         """获取符合条件的合并请求审核日志"""
         try:
@@ -80,6 +80,11 @@ def get_mr_review_logs(authors: list = None, updated_at_gte: int = None,
                     query += f" AND author IN ({placeholders})"
                     params.extend(authors)
 
+                if project_names:
+                    placeholders = ','.join(['?'] * len(project_names))
+                    query += f" AND project_name IN ({placeholders})"
+                    params.extend(project_names)
+
                 if updated_at_gte is not None:
                     query += " AND updated_at >= ?"
                     params.append(updated_at_gte)

ui.py

@@ -16,13 +16,15 @@
     DASHBOARD_USER: DASHBOARD_PASSWORD
 }
 
+
 # 登录验证函数
 def authenticate(username, password):
     return username in USER_CREDENTIALS and USER_CREDENTIALS[username] == password
 
+
 # 获取数据函数
-def get_data(service_func, authors=None, updated_at_gte=None, updated_at_lte=None, columns=None):
-    df = service_func(authors=authors, updated_at_gte=updated_at_gte, updated_at_lte=updated_at_lte)
+def get_data(service_func, authors=None, project_names=None, updated_at_gte=None, updated_at_lte=None, columns=None):
+    df = service_func(authors=authors, project_names=project_names, updated_at_gte=updated_at_gte, updated_at_lte=updated_at_lte)
 
     if df.empty:
         return pd.DataFrame(columns=columns)
@@ -36,9 +38,11 @@ def get_data(service_func, authors=None, updated_at_gte=None, updated_at_lte=Non
     data = df[columns]
     return data
 
+
 # Streamlit 配置
 st.set_page_config(layout="wide")
 
+
 # 登录界面
 def login_page():
     # 使用 st.columns 创建居中布局
@@ -83,10 +87,9 @@ def main_page():
     else:
         mr_tab = st.container()
 
-
     def display_data(tab, service_func, columns, column_config):
         with tab:
-            col1, col2, col3 = st.columns(3)
+            col1, col2, col3, col4 = st.columns(4)
             with col1:
                 start_date = st.date_input("开始日期", start_date_default, key=f"{tab}_start_date")
             with col2:
@@ -100,10 +103,13 @@ def display_data(tab, service_func, columns, column_config):
             df = pd.DataFrame(data)
 
             unique_authors = sorted(df["author"].dropna().unique().tolist()) if not df.empty else []
+            unique_projects = sorted(df["project_name"].dropna().unique().tolist()) if not df.empty else []
             with col3:
                 authors = st.multiselect("用户名", unique_authors, default=[], key=f"{tab}_authors")
+            with col4:
+                project_names = st.multiselect("项目名", unique_projects, default=[], key=f"{tab}_projects")
 
-            data = get_data(service_func, authors=authors, updated_at_gte=int(start_datetime.timestamp()),
+            data = get_data(service_func, authors=authors,project_names=project_names, updated_at_gte=int(start_datetime.timestamp()),
                             updated_at_lte=int(end_datetime.timestamp()), columns=columns)
             df = pd.DataFrame(data)
 
@@ -117,7 +123,6 @@ def display_data(tab, service_func, columns, column_config):
             average_score = df["score"].mean() if not df.empty else 0
             st.markdown(f"**总记录数:** {total_records}，**平均分:** {average_score:.2f}")
 
-
     # Merge Request 数据展示
     mr_columns = ["project_name", "author", "source_branch", "target_branch", "updated_at", "commit_messages", "score",
                   "url"]
@@ -149,11 +154,13 @@ def display_data(tab, service_func, columns, column_config):
         }
 
         display_data(push_tab, ReviewService().get_push_review_logs, push_columns, push_column_config)
+
+
 # 应用入口
 if "authenticated" not in st.session_state:
     st.session_state["authenticated"] = False
 
 if st.session_state["authenticated"]:
     main_page()
 else:
-    login_page()
+    login_page()