延長競價摘要快取並在更新後失效
This commit is contained in:
@@ -2131,6 +2131,7 @@ def run_competitor_price_feeder_task():
|
||||
try:
|
||||
from config import DATABASE_PATH
|
||||
from sqlalchemy import create_engine
|
||||
from services.competitor_intel_repository import clear_competitor_intel_cache
|
||||
from services.competitor_price_feeder import CompetitorPriceFeeder
|
||||
|
||||
now_str = datetime.now(TAIPEI_TZ).strftime('%Y-%m-%d %H:%M')
|
||||
@@ -2159,6 +2160,7 @@ def run_competitor_price_feeder_task():
|
||||
f"errors={result.errors} "
|
||||
f"耗時={result.duration_sec}s"
|
||||
)
|
||||
clear_competitor_intel_cache()
|
||||
_save_stats('competitor_price_feeder', stats)
|
||||
|
||||
except Exception as e:
|
||||
@@ -2191,6 +2193,7 @@ def run_pchome_match_backfill_task():
|
||||
from sqlalchemy import create_engine
|
||||
from services.ai_product_pick_agent import generate_product_pick_list
|
||||
from services.cache_manager import clear_dashboard_cache
|
||||
from services.competitor_intel_repository import clear_competitor_intel_cache
|
||||
from services.competitor_price_feeder import CompetitorPriceFeeder
|
||||
|
||||
now_str = datetime.now(TAIPEI_TZ).strftime('%Y-%m-%d %H:%M')
|
||||
@@ -2200,6 +2203,7 @@ def run_pchome_match_backfill_task():
|
||||
feeder_result = CompetitorPriceFeeder(engine=engine).run_unmatched_priority(limit=120)
|
||||
pick_result = generate_product_pick_list(engine, limit=50)
|
||||
clear_dashboard_cache()
|
||||
clear_competitor_intel_cache()
|
||||
|
||||
stats = {
|
||||
"total_skus": feeder_result.total_skus,
|
||||
|
||||
Reference in New Issue
Block a user