Update cache_db.py

cache_db.py

@@ -511,8 +511,27 @@ def get_content_cache() -> ContentVectorCache:
     return _content_cache_instance
 _indexing_thread = None
 _indexing_stop_flag = False
+def is_ongoing_check(req_dt: str) -> bool:
+    """진행중 공고인지 확인 (cache_db 내부용)"""
+    import re
+    if not req_dt:
+        return True
+    if any(kw in req_dt for kw in ["소진", "추후", "상시", "별도"]):
+        return True
+    try:
+        if "~" in req_dt:
+            end_date_str = req_dt.split("~")[-1].strip()
+        else:
+            end_date_str = req_dt.strip()
+        end_date_str = re.sub(r'[^0-9]', '', end_date_str)
+        if len(end_date_str) >= 8:
+            deadline = datetime.strptime(end_date_str[:8], "%Y%m%d")
+            return deadline >= datetime.now()
+    except:
+        pass
+    return True
 def background_content_indexer():
-    """백그라운드 본문 인덱싱 (서비스 무중단)"""
+    """백그라운드 본문 인덱싱 (서비스 무중단, 진행중 공고만)"""
     global _indexing_stop_flag
     from file_api import download_file, extract_text_from_file
     content_cache = get_content_cache()
@@ -526,10 +545,15 @@ def background_content_indexer():
         all_items = meta_cache.get_all()
         indexed_ids = content_cache.get_indexed_ids()
         items_to_index = []
+        skipped_expired = 0
         for item in all_items:
             pblanc_id = safe_str(item.get("pblancId") or item.get("seq"))
             print_url = safe_str(item.get("printFlpthNm"))
             print_name = safe_str(item.get("printFileNm"))
+            req_dt = safe_str(item.get("reqstDt") or item.get("reqstBeginEndDe"))
+            if not is_ongoing_check(req_dt):
+                skipped_expired += 1
+                continue
             if pblanc_id and print_url and print_name:
                 if pblanc_id not in indexed_ids:
                     items_to_index.append({
@@ -542,7 +566,7 @@ def background_content_indexer():
         content_cache.index_status["progress_total"] = total
         content_cache.index_status["progress_current"] = 0
         content_cache._save_index_status()
-        logger.info(f"Starting background content indexing: {total} items to process")
+        logger.info(f"Starting background content indexing: {total} items (skipped {skipped_expired} expired)")
         for i, item in enumerate(items_to_index):
             if _indexing_stop_flag:
                 logger.info("Content indexing stopped by flag")