admin/trendyol-analiz
1
0
Fork 0
mirror of https://github.com/nethunterzist/trendyol-analiz synced 2026-07-04 02:37:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: use CATEGORIES_DIR and REPORTS_DIR env vars instead of hardcoded paths

Browse Source 
All ../categories and ../reports references replaced with the
configurable CATEGORIES_DIR and REPORTS_DIR variables. This fixes
the Docker deployment where data directories are at /data/ not ../

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
furkanyigit34
2026-03-07 23:45:21 +03:00
parent f85fb75830
commit e6d47b89ee
1 changed files with 20 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
backend/main.py
View File

@@ -332,7 +332,7 @@ async def health_check():
db_exists = os.path.exists(db_path) db_exists = os.path.exists(db_path)
# Check data directories # Check data directories
categories_dir = os.getenv("CATEGORIES_DIR", os.path.join(BASE_DIR, "..", "categories")) categories_dir = CATEGORIES_DIR
reports_dir = os.getenv("REPORTS_DIR", REPORTS_DIR) reports_dir = os.getenv("REPORTS_DIR", REPORTS_DIR)
return { return {
@@ -1167,7 +1167,7 @@ def get_category_products(category_id: int, db: Session = Depends(get_db)):
raise HTTPException(status_code=400, detail="Category has no Trendyol ID") raise HTTPException(status_code=400, detail="Category has no Trendyol ID")
# Search for JSON file in categories folder # Search for JSON file in categories folder
categories_dir = os.path.join(os.path.dirname(__file__), "..", "categories") categories_dir = CATEGORIES_DIR
json_files = [f for f in os.listdir(categories_dir) if f.endswith(f"_{trendyol_id}.json")] json_files = [f for f in os.listdir(categories_dir) if f.endswith(f"_{trendyol_id}.json")]
if not json_files: if not json_files:
@@ -1424,8 +1424,8 @@ async def create_report(
if products: if products:
pass pass
# Save to file # Save to file
os.makedirs("../categories", exist_ok=True) os.makedirs(CATEGORIES_DIR, exist_ok=True)
filename = f"../categories/{cat_name.replace(' ', '_')}_{cat_id}.json" filename = f"{CATEGORIES_DIR}/{cat_name.replace(' ', '_')}_{cat_id}.json"
data = { data = {
"category_id": cat_id, "category_id": cat_id,
@@ -1602,7 +1602,7 @@ async def create_report(
timestamp = datetime.now().strftime("%Y%m%d_%H%M%S") timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
safe_name = name.lower().replace(" ", "_").replace("ı", "i").replace("ş", "s").replace("ğ", "g").replace("ü", "u").replace("ö", "o").replace("ç", "c") safe_name = name.lower().replace(" ", "_").replace("ı", "i").replace("ş", "s").replace("ğ", "g").replace("ü", "u").replace("ö", "o").replace("ç", "c")
reports_dir = "../reports" reports_dir = REPORTS_DIR
os.makedirs(reports_dir, exist_ok=True) os.makedirs(reports_dir, exist_ok=True)
json_filename = f"{reports_dir}/{safe_name}_{timestamp}.json" json_filename = f"{reports_dir}/{safe_name}_{timestamp}.json"
@@ -1639,7 +1639,7 @@ async def create_report(
# Save social proof data to persistent cache # Save social proof data to persistent cache
# print(f"\n🔍 DEBUG: Sosyal kanıt kaydetme bölümü - social_proof_data uzunluğu: {len(social_proof_data)}") # print(f"\n🔍 DEBUG: Sosyal kanıt kaydetme bölümü - social_proof_data uzunluğu: {len(social_proof_data)}")
if social_proof_data: if social_proof_data:
enrich_dir = f"../reports/enrich_{new_report.id}" enrich_dir = f"{REPORTS_DIR}/enrich_{new_report.id}"
os.makedirs(enrich_dir, exist_ok=True) os.makedirs(enrich_dir, exist_ok=True)
social_file = f"{enrich_dir}/social.json" social_file = f"{enrich_dir}/social.json"
@@ -1767,8 +1767,8 @@ def scrape_in_background(task_id: str, report_name: str, category_id: int, categ
if products: if products:
pass pass
# Save to file # Save to file
os.makedirs("../categories", exist_ok=True) os.makedirs(CATEGORIES_DIR, exist_ok=True)
filename = f"../categories/{cat_name.replace(' ', '_')}_{cat_id}.json" filename = f"{CATEGORIES_DIR}/{cat_name.replace(' ', '_')}_{cat_id}.json"
data = { data = {
"category_id": cat_id, "category_id": cat_id,
@@ -1829,7 +1829,7 @@ def scrape_in_background(task_id: str, report_name: str, category_id: int, categ
timestamp = datetime.now().strftime("%Y%m%d_%H%M%S") timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
safe_name = report_name.lower().replace(" ", "_").replace("ı", "i").replace("ş", "s").replace("ğ", "g").replace("ü", "u").replace("ö", "o").replace("ç", "c") safe_name = report_name.lower().replace(" ", "_").replace("ı", "i").replace("ş", "s").replace("ğ", "g").replace("ü", "u").replace("ö", "o").replace("ç", "c")
reports_dir = "../reports" reports_dir = REPORTS_DIR
os.makedirs(reports_dir, exist_ok=True) os.makedirs(reports_dir, exist_ok=True)
json_filename = f"{reports_dir}/{safe_name}_{timestamp}.json" json_filename = f"{reports_dir}/{safe_name}_{timestamp}.json"
@@ -1911,7 +1911,7 @@ def delete_report(report_id: int, db: Session = Depends(get_db)):
os.remove(report.html_file_path) os.remove(report.html_file_path)
# Delete enrich directory if exists # Delete enrich directory if exists
enrich_dir = f"../reports/enrich_{report_id}" enrich_dir = f"{REPORTS_DIR}/enrich_{report_id}"
if os.path.exists(enrich_dir): if os.path.exists(enrich_dir):
shutil.rmtree(enrich_dir) shutil.rmtree(enrich_dir)
@@ -2123,7 +2123,7 @@ def get_dashboard_data(report_id: int, db: Session = Depends(get_db)):
if not social_data: if not social_data:
pass pass
# print(f"[DEBUG] No social proof cache found, trying persisted JSON") # print(f"[DEBUG] No social proof cache found, trying persisted JSON")
persisted = _load_json(f"../reports/enrich_{report_id}/social.json") persisted = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/social.json")
if persisted: if persisted:
social_data = { social_data = {
"details": persisted.get("details", {}), "details": persisted.get("details", {}),
@@ -3059,7 +3059,7 @@ def reviews_summary_disabled(report_id: int, refresh: bool = False, db: Session
return {"error": "Reviews feature is disabled"} return {"error": "Reviews feature is disabled"}
# Try persistent cache first # Try persistent cache first
if not refresh: if not refresh:
persisted = _load_json(f"../reports/enrich_{report_id}/reviews.json") persisted = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/reviews.json")
if persisted: if persisted:
return {"source": "file", **persisted} return {"source": "file", **persisted}
cache_key = f"{report_id}" cache_key = f"{report_id}"
@@ -3150,7 +3150,7 @@ def social_proof_progress(report_id: int):
def social_proof(report_id: int, refresh: bool = False, batch_size: int = 5, db: Session = Depends(get_db)): def social_proof(report_id: int, refresh: bool = False, batch_size: int = 5, db: Session = Depends(get_db)):
# Try persistent cache first # Try persistent cache first
if not refresh: if not refresh:
persisted = _load_json(f"../reports/enrich_{report_id}/social.json") persisted = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/social.json")
if persisted: if persisted:
pass pass
# Transform cache data to frontend format # Transform cache data to frontend format
@@ -3315,7 +3315,7 @@ def sales_analytics(report_id: int):
""" """
try: try:
# Load social proof data # Load social proof data
social_data = _load_json(f"../reports/enrich_{report_id}/social.json") social_data = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/social.json")
if not social_data: if not social_data:
return {"error": "Social proof data not found"} return {"error": "Social proof data not found"}
@@ -4063,7 +4063,7 @@ def product_finder(
} }
# Load social proof data # Load social proof data
social_data = _load_json(f"../reports/enrich_{report_id}/social.json") social_data = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/social.json")
social_details = social_data.get("details", {}) if social_data else {} social_details = social_data.get("details", {}) if social_data else {}
print(f"✅ Social proof data yüklendi: {len(social_details)} ürün") print(f"✅ Social proof data yüklendi: {len(social_details)} ürün")
@@ -4311,7 +4311,7 @@ def product_finder(
# def questions_summary(report_id: int, refresh: bool = False, db: Session = Depends(get_db)): # def questions_summary(report_id: int, refresh: bool = False, db: Session = Depends(get_db)):
# # Try persistent cache first # # Try persistent cache first
# if not refresh: # if not refresh:
# persisted = _load_json(f"../reports/enrich_{report_id}/questions.json") # persisted = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/questions.json")
# if persisted: # if persisted:
# return {"source": "file", **persisted} # return {"source": "file", **persisted}
# cache_key = f"{report_id}" # cache_key = f"{report_id}"
@@ -4370,7 +4370,7 @@ def product_finder(
# def similar_summary(report_id: int, refresh: bool = False, db: Session = Depends(get_db)): # def similar_summary(report_id: int, refresh: bool = False, db: Session = Depends(get_db)):
# # Try persistent cache first # # Try persistent cache first
# if not refresh: # if not refresh:
# persisted = _load_json(f"../reports/enrich_{report_id}/similar.json") # persisted = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/similar.json")
# if persisted: # if persisted:
# return {"source": "file", **persisted} # return {"source": "file", **persisted}
# cache_key = f"{report_id}" # cache_key = f"{report_id}"
@@ -4415,7 +4415,7 @@ def product_finder(
# def merchant_followers(report_id: int, refresh: bool = False, db: Session = Depends(get_db)): # def merchant_followers(report_id: int, refresh: bool = False, db: Session = Depends(get_db)):
# # Try persistent cache first # # Try persistent cache first
# if not refresh: # if not refresh:
# persisted = _load_json(f"../reports/enrich_{report_id}/followers.json") # persisted = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/followers.json")
# if persisted: # if persisted:
# return {"source": "file", **persisted} # return {"source": "file", **persisted}
# cache_key = f"{report_id}" # cache_key = f"{report_id}"
@@ -4489,7 +4489,7 @@ def _enrich_report_task(report_id: int):
product_ids = [p.get("id") for p in all_products if p.get("id")] product_ids = [p.get("id") for p in all_products if p.get("id")]
product_info = _enrich_build_product_info(all_products) product_info = _enrich_build_product_info(all_products)
base_dir = f"../reports/enrich_{report_id}" base_dir = f"{REPORTS_DIR}/enrich_{report_id}"
_ensure_dir(base_dir) _ensure_dir(base_dir)
# DISABLED: Reviews feature removed per user request # DISABLED: Reviews feature removed per user request
@@ -4571,7 +4571,7 @@ def get_hidden_champions(
from analytics.champion_finder import HiddenChampionFinder from analytics.champion_finder import HiddenChampionFinder
all_products, categories_data = load_report_products(db, report_id) all_products, categories_data = load_report_products(db, report_id)
social_data = _load_json(f"../reports/enrich_{report_id}/social.json") or {} social_data = _load_json(f"{REPORTS_DIR}/enrich_{report_id}/social.json") or {}
finder = HiddenChampionFinder() finder = HiddenChampionFinder()