def refresh_video_LLM_all_content_by_sheet(sheet_url, sheet_qa_column, video_ids): # 移除 sheet_video_column

app.py

@@ -2157,10 +2157,135 @@ def summary_add_markdown_version(video_id):
 def get_sheet_data(sheet_url, range_name):
     data = SHEET_SERVICE.get_sheet_data_by_url(sheet_url, range_name)
     flattened_data = SHEET_SERVICE.flatten_column_data(data)
-    return flattened_data
+    flattened_data_string = ', '.join(flattened_data)
+    return flattened_data_string
 
+def update_sheet_data(sheet_url, qa_result, video_id):
+    # 根據 url 找到 sheet ，根據 video_id 找到 sheet 中的 video_id 的 row number
+    sheet_data = SHEET_SERVICE.get_sheet_data_by_url(sheet_url)
+    print(f"sheet_data: {sheet_data}")
 
-def refresh_video_LLM_all_content(video_ids):
+    if not sheet_data or len(sheet_data) < 1:
+        print("錯誤：工作表資料為空或缺少標頭列。")
+        return
+
+    header_row = sheet_data[0]
+    data_rows = sheet_data[1:] # 資料列（跳過標頭）
+
+    # 直接指定要尋找的欄位名稱
+    target_column_name = '均一平台 YT Readable ID'
+    target_qa_column_name = "QA"
+
+    try:
+        # 1. 找到 '均一平台 YT Readable ID' 所在的欄位索引 (column index)
+        video_id_col_index = header_row.index(target_column_name)
+    except ValueError:
+        # 如果找不到指定的欄位名稱，印出錯誤並返回
+        print(f"錯誤：在標頭列 {header_row} 中找不到指定的欄位名稱 '{target_column_name}'")
+        return
+
+    # 2. 遍歷資料列，尋找 video_id 匹配的列索引 (row index)
+    target_row_index = -1 # 初始化為 -1，表示未找到
+    for i, row in enumerate(data_rows):
+        # 確保該列有足夠的欄位，並且該欄位的值等於 video_id
+        if len(row) > video_id_col_index and row[video_id_col_index] == video_id:
+            target_row_index = i + 1 # 找到匹配的列，其在原始 sheet_data 中的索引是 i + 1
+            break # 找到後即可跳出迴圈
+
+    if target_row_index != -1:
+        print(f"找到 video_id '{video_id}' 於欄位 '{target_column_name}' 的第 {target_row_index + 1} 列 (工作表列號)") # +1 是為了顯示給人類看的行號
+
+        # --- 以下是更新邏輯 (需要取消註解並確保 qa_column 也正確) ---
+        try:
+            # 找到 QA 欄位的索引 (假設 qa_column 參數傳入的是正確的標題文字, e.g., 'QA')
+            qa_col_index = header_row.index(target_qa_column_name)
+
+            # 更新 sheet 中的 qa_column 和 qa_result
+            # 確保目標列有足夠的欄位可以更新
+            if len(sheet_data[target_row_index]) > qa_col_index:
+                # 注意：這裡直接修改 sheet_data 列表可能不會直接更新 Google Sheet
+                # 你需要使用 SHEET_SERVICE 的更新方法
+                # sheet_data[target_row_index][qa_col_index] = qa_result
+                print(f"準備更新 第 {target_row_index + 1} 列, 欄位 '{target_qa_column_name}' (索引 {qa_col_index}) 為 '{qa_result}'")
+                # --- 實際更新 Google Sheet 的程式碼
+                SHEET_SERVICE.update_sheet_cell(sheet_url, target_row_index, qa_col_index, qa_result)
+
+            else:
+                 print(f"錯誤：第 {target_row_index + 1} 列沒有足夠的欄位來更新 QA (索引 {qa_col_index})。")
+
+        except ValueError:
+            print(f"錯誤：在標頭列 {header_row} 中找不到 QA 欄位名稱 '{qa_column}'")
+        # --- 更新邏輯結束 ---
+
+    else:
+        # 如果找不到 video_id，印出錯誤訊息
+        print(f"錯誤：在欄位 '{target_column_name}' 中找不到 video_id '{video_id}'。")
+
+def refresh_video_LLM_all_content_by_sheet(sheet_url, sheet_qa_column, video_ids): # 移除 sheet_video_column
+    video_ids = video_ids.replace('\n', ',').split(',')
+    video_ids = [vid.strip() for vid in video_ids if vid.strip()]
+
+    success_video_ids = []
+    failed_video_ids = []
+
+    sheet_qa_success_tag = "OO"
+    sheet_qa_failed_tag = "XX"
+
+    for video_id in video_ids:
+        try:
+            # 確認 GCS 中是否存在 ID_transcript.json in GCS
+            # 如果存在就 pass
+            # 如果不存在就 refresh_video_LLM_all_content_by_id
+            bucket_name = 'video_ai_assistant'
+            file_name = f'{video_id}_transcript.json'
+            blob_name = f"{video_id}/{file_name}"
+            is_file_exists = GCS_SERVICE.check_file_exists(bucket_name, blob_name)
+            if not is_file_exists:
+                print(f"{video_id} 不存在逐字稿")
+                refresh_video_LLM_all_content_by_id(video_id)
+            else:
+                print(f"{video_id} 存在逐字稿")
+
+            qa_result = sheet_qa_success_tag
+            # 更新呼叫，不再傳遞 sheet_video_column
+            update_sheet_data(sheet_url, qa_result, video_id)
+            success_video_ids.append(video_id) # 假設 update_sheet_data 成功就加入 success
+        except Exception as e:
+            print(f"===refresh_video_LLM_all_content_by_sheet error===")
+            print(f"video_id: {video_id}")
+            print(f"error: {str(e)}")
+            print(f"===refresh_video_LLM_all_content_by_sheet error===")
+            failed_video_ids.append(video_id)
+            qa_result = sheet_qa_failed_tag
+            try:
+                # 即使前面出錯，還是嘗試更新 QA 狀態為 XX
+                update_sheet_data(sheet_url, qa_result, video_id)
+            except Exception as update_e:
+                 print(f"===更新 QA 狀態為 XX 時也發生錯誤===")
+                 print(f"video_id: {video_id}")
+                 print(f"error: {str(update_e)}")
+                 print(f"===更新 QA 狀態為 XX 時也發生錯誤===")
+
+
+    result = {
+        "success_video_ids": success_video_ids,
+        "failed_video_ids": failed_video_ids
+    }
+    return result
+
+def refresh_video_LLM_all_content_by_id(video_id):
+    print(f"===refresh_all_LLM_content===")
+    print(f"video_id: {video_id}")
+    print(f"===delete_blobs_by_folder_name: {video_id}===")
+    bucket_name = 'video_ai_assistant'
+    GCS_SERVICE.delete_blobs_by_folder_name(bucket_name, video_id)
+    print(f"所有以 {video_id} 開頭的檔案已刪除")
+
+    # process_youtube_link
+    video_link = f"https://www.youtube.com/watch?v={video_id}"
+    process_youtube_link(PASSWORD, video_link)
+
+def refresh_video_LLM_all_content_by_ids(video_ids):
     # 輸入影片 id，以 , 逗號分隔 或是 \n 換行
     video_id_list = video_ids.replace('\n', ',').split(',')
     video_id_list = [vid.strip() for vid in video_id_list if vid.strip()]
@@ -2170,18 +2295,7 @@ def refresh_video_LLM_all_content(video_ids):
     
     for video_id in video_id_list:
         try:
-            print(f"===refresh_all_LLM_content===")
-            print(f"video_id: {video_id}")
-            # 刪除 GCS 中所有以 video_id 開頭的檔案
-            print(f"===delete_blobs_by_folder_name: {video_id}===")
-            bucket_name = 'video_ai_assistant'
-            GCS_SERVICE.delete_blobs_by_folder_name(bucket_name, video_id)
-            print(f"所有以 {video_id} 開頭的檔案已刪除")
-
-            # process_youtube_link
-            video_link = f"https://www.youtube.com/watch?v={video_id}"
-            process_youtube_link(PASSWORD, video_link)
-
+            refresh_video_LLM_all_content_by_id(video_id)
             success_video_ids.append(video_id)
         except Exception as e:
             print(f"===refresh_all_LLM_content error===")
@@ -3663,16 +3777,11 @@ def create_app():
                         refresh_btn = gr.Button("refresh", variant="primary")
                     with gr.Tab("by sheets"):
                         sheet_url = gr.Textbox(label="輸入 Google Sheets 的 URL")
+                        sheet_video_column = gr.Textbox(label="輸入要讀取的 youtube_id 欄位", value="D:D")
+                        sheet_QA_column = gr.Textbox(label="輸入要讀取的 QA 欄位", value="F:F")
                         sheet_get_value_btn = gr.Button("取得 ids", variant="primary")
                         sheet_get_value_result = gr.Textbox(label="ids", interactive=False)
-                        sheet_refresh_btn = gr.Button("refresh by sheets", variant="primary")
-                
-                        sheet_get_value_btn.click(
-                            get_sheet_data,
-                            inputs=[sheet_url, gr.Textbox(value="D:D", visible=True)], # 將範圍修改為 D 欄
-                            outputs=[sheet_get_value_result]
-                        )
-                
+                        sheet_refresh_btn = gr.Button("refresh by sheets", variant="primary")                
                 with gr.Row():
                     refresh_result = gr.JSON()
     
@@ -3681,10 +3790,26 @@ def create_app():
                         inputs=[],
                         outputs=[refresh_btn]
                     ).then(
-                        refresh_video_LLM_all_content,
+                        refresh_video_LLM_all_content_by_ids,
                         inputs=[refresh_video_ids],
                         outputs=[refresh_result]
                     )
+
+                    sheet_get_value_btn.click(
+                        get_sheet_data,
+                        inputs=[sheet_url, sheet_video_column],
+                        outputs=[sheet_get_value_result]
+                    )
+
+                    sheet_refresh_btn.click(
+                        lambda: gr.update(interactive=False),
+                        inputs=[],
+                        outputs=[sheet_refresh_btn]
+                    ).then(
+                        refresh_video_LLM_all_content_by_sheet,
+                        inputs=[sheet_url, sheet_QA_column, sheet_get_value_result],
+                        outputs=[refresh_result]
+                    )
                 
             
         # OPEN AI CHATBOT SELECT

sheet_service.py

@@ -4,6 +4,7 @@ from google.oauth2 import service_account
 import json
 from urllib.parse import urlparse, parse_qs
 import logging # 建議使用 logging 而非 print
+import string # 導入 string 模組用於轉換欄位索引
 
 # 設定基本的 logging
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
@@ -12,7 +13,7 @@ class SheetService:
     """
     一個用於與 Google Sheets API 互動的服務類別。
     """
-    SCOPES = ['https://www.googleapis.com/auth/spreadsheets.readonly']
+    SCOPES = ['https://www.googleapis.com/auth/spreadsheets']
 
     def __init__(self, service_account_key_string: str, api_service_name: str = 'sheets', api_version: str = 'v4'):
         """
@@ -266,4 +267,129 @@ class SheetService:
         # 添加 if sublist and sublist[0] is not None 確保子列表非空且第一個元素存在
         # 並將其轉換為字串 str() 以確保類型一致性
         flattened = [str(sublist[0]) for sublist in data if sublist and sublist[0] is not None]
-        return flattened
+        return flattened
+    
+    def update_sheet_data_by_url(self, sheet_url, data):
+        spreadsheet_id = self.get_sheet_id_by_url(sheet_url)
+        self.sheet.values().update(
+            spreadsheetId=spreadsheet_id,
+            range='A1:Z1000',
+            valueInputOption='USER_ENTERED',
+            body={'values': data}
+        ).execute()
+
+        return True
+    
+    @staticmethod
+    def _col_index_to_letter(col_index: int) -> str:
+        """將 0-based 的欄位索引轉換為 A1 表示法的字母。"""
+        if col_index < 0:
+            raise ValueError("Column index must be non-negative")
+        letters = ''
+        while col_index >= 0:
+            col_index, remainder = divmod(col_index, 26)
+            letters = string.ascii_uppercase[remainder] + letters
+            col_index -= 1 # 因為 divmod 是 0-based，但 A=1, Z=26, AA=27 的轉換需要調整
+            if col_index < -1: # 修正邊界條件
+                 break
+        # 修正：上面的邏輯有點複雜且可能有誤，改用更簡單的方式
+        letters = ''
+        dividend = col_index + 1 # 轉為 1-based
+        while dividend > 0:
+            module = (dividend - 1) % 26
+            letters = string.ascii_uppercase[module] + letters
+            dividend = (dividend - module) // 26
+        return letters if letters else "A" # 確保至少返回 "A"
+
+    @staticmethod
+    def _col_index_to_letter_simple(col_index: int) -> str:
+        """將 0-based 的欄位索引轉換為 A1 表示法的字母 (簡化版，適用於 A-ZZ)。"""
+        if col_index < 0:
+            raise ValueError("Column index must be non-negative")
+        letters = ""
+        while col_index >= 0:
+            letters = string.ascii_uppercase[col_index % 26] + letters
+            col_index = col_index // 26 - 1
+        return letters
+
+    #                 SHEET_SERVICE.update_sheet_cell(sheet_url, target_row_index, qa_col_index, qa_result)
+    def update_sheet_cell(self, sheet_url: str, target_row_index_in_data: int, qa_col_index: int, qa_result: str) -> bool:
+        """
+        更新指定 URL 的 Google Sheet 中的單一儲存格。
+
+        Args:
+            sheet_url (str): Google 試算表的完整 URL。
+            target_row_index_in_data (int): 目標列在 get_sheet_data_by_url 返回的列表中的索引
+                                            (從 1 開始算，因為 0 是標頭)。
+            qa_col_index (int): 目標欄位的索引 (從 0 開始算)。
+            qa_result (str): 要寫入儲存格的值。
+
+        Returns:
+            bool: 更新是否成功。
+        """
+        if not self.sheet:
+            logging.error("Sheet API 服務未成功初始化。")
+            return False
+
+        spreadsheet_id = self.get_sheet_id_by_url(sheet_url)
+        if not spreadsheet_id:
+            logging.error(f"無法從 URL 獲取 Spreadsheet ID: {sheet_url}")
+            return False
+
+        gid = self.get_sheet_gid_by_url(sheet_url)
+        sheet_name = self.get_sheet_name_by_gid(spreadsheet_id, gid)
+        if not sheet_name:
+            logging.error(f"無法根據 URL ({sheet_url}) 確定要更新的工作表名稱。")
+            return False
+
+        # 將 0-based 的欄位索引轉換為字母
+        try:
+            col_letter = self._col_index_to_letter_simple(qa_col_index)
+        except ValueError as e:
+            logging.error(f"無效的欄位索引 {qa_col_index}: {e}")
+            return False
+
+        # 計算實際的工作表列號
+        # target_row_index_in_data 是 sheet_data 中的索引 (1-based)
+        # 實際列號是 target_row_index_in_data + 1 (因為工作表通常從第 1 列開始)
+        actual_sheet_row = target_row_index_in_data + 1
+
+        # 構建 A1 表示法的範圍，例如 '測試'!F3
+        # 需要正確處理工作表名稱中的特殊字符（例如空格）
+        if ' ' in sheet_name or '!' in sheet_name or ':' in sheet_name or "'" in sheet_name:
+             # 修正：使用三引號定義 f-string 以避免引號衝突
+             safe_sheet_name = f"""'{sheet_name.replace("'", "''")}'""" # 單引號用兩個單引號轉義
+        else:
+             safe_sheet_name = sheet_name
+        range_name = f"{safe_sheet_name}!{col_letter}{actual_sheet_row}"
+
+        logging.info(f"準備更新 Spreadsheet ID: {spreadsheet_id}, Range: {range_name}, Value: {qa_result}")
+
+        try:
+            body = {
+                'values': [[qa_result]] # 更新單一儲存格的值需要是 list of lists
+            }
+            result = self.sheet.values().update(
+                spreadsheetId=spreadsheet_id,
+                range=range_name,
+                valueInputOption='USER_ENTERED', # 或者 'RAW' 如果你不需要 Google Sheets 解釋輸入
+                body=body
+            ).execute()
+            logging.info(f"成功更新儲存格 {range_name}。 更新了 {result.get('updatedCells')} 個儲存格。")
+            return True
+        except googleapiclient.errors.HttpError as error:
+            # 記錄更詳細的錯誤
+            error_details = error.resp.get('content', '{}')
+            try:
+                error_json = json.loads(error_details)
+                error_message = error_json.get('error', {}).get('message', str(error))
+            except json.JSONDecodeError:
+                error_message = str(error)
+            logging.error(f"更新儲存格時發生 API 錯誤 (ID: {spreadsheet_id}, Range: {range_name}): {error_message}")
+            # 檢查是否是權限錯誤
+            if error.resp.status == 403:
+                 logging.error("錯誤 403：權限不足。請檢查服務帳戶是否有目標工作表的編輯權限，以及 API 金鑰是否啟用了正確的範圍 (scopes)。")
+            return False
+        except Exception as e:
+            logging.error(f"更新儲存格時發生未知錯誤 (ID: {spreadsheet_id}, Range: {range_name}): {e}")
+            return False