# -*- coding: utf-8 -*- from flask import Flask, request, redirect, send_from_directory, make_response from werkzeug.utils import secure_filename import os import time import sys import shutil import py_compile import threading import html as html_lib import glob import zipfile import subprocess app = Flask(__name__) BASE_DIR = r"C:\TripServer" FOLDERS = { "JAPAN": os.path.join(BASE_DIR, "JAPAN"), "USA": os.path.join(BASE_DIR, "USA"), "Moneyapp": os.path.join(BASE_DIR, "Moneyapp"), "MoneyHome": os.path.join(BASE_DIR, "MoneyHome"), } APP_FOLDERS = {"JAPAN", "USA", "Moneyapp", "MoneyHome"} JAPAN_PRESENTATION_FILES = { "flight_intro": "japan-flight-intro.html", "japan_experience": "japan-experience.html", } USA_PRESENTATION_FILES = { "usa_presentation": "usa2027-presentation.html", } USA_MUSIC_FILES = { "usa_music": os.path.join("media", "usa-presentation", "music", "usa-roadtrip-theme.mp3"), "usa_music_part2": os.path.join("media", "usa-presentation", "music", "usa-part2-theme.mp3"), } USA_IMAGE_KEYS = ({"intro", "budget", "roadtrip-map", "summary", "extra-big-sur", "extra-diner", "extra-death-valley", "extra-mono-lake"} | {f"day-{i:02d}" for i in range(1, 37)}) USA_IMAGE_EXTENSIONS = {".jpg", ".jpeg", ".png", ".webp"} ADMIN_SERVER_PATH = os.path.abspath(__file__) ADMIN_BACKUP_DIR = os.path.join(BASE_DIR, "backups", "admin_server") ADMIN_UPLOAD_TMP_DIR = os.path.join(BASE_DIR, "tmp", "admin_server_uploads") ADMIN_MAX_UPLOAD_BYTES = 2 * 1024 * 1024 ADMIN_RESTART_CMD_PATH = os.path.join(BASE_DIR, "restart_admin_server.cmd") ADMIN_RESTART_LOG_PATH = os.path.join(BASE_DIR, "admin_restart.log") def save_usa_presentation_image(image_key, uploaded_file): if image_key not in USA_IMAGE_KEYS: return None image_dir = os.path.join(FOLDERS["USA"], "media", "usa-presentation", "images") os.makedirs(image_dir, exist_ok=True) # Keep the presentation predictable: every single-card upload is normalized to .jpg. # This is especially important for roadtrip-map, because the presentation expects: # media/usa-presentation/images/roadtrip-map.jpg target_ext = ".jpg" for old_ext in USA_IMAGE_EXTENSIONS: old_path = os.path.join(image_dir, image_key + old_ext) if os.path.exists(old_path): try: os.remove(old_path) except Exception: pass filename = image_key + target_ext target_path = os.path.join(image_dir, filename) # Prefer real JPEG conversion when Pillow exists; if not installed, save raw bytes with .jpg. try: from PIL import Image uploaded_file.stream.seek(0) img = Image.open(uploaded_file.stream) if img.mode not in ("RGB", "L"): img = img.convert("RGB") elif img.mode == "L": img = img.convert("RGB") img.save(target_path, "JPEG", quality=90, optimize=True) except Exception: try: uploaded_file.stream.seek(0) except Exception: pass uploaded_file.save(target_path) return os.path.join("media", "usa-presentation", "images", filename) def save_usa_presentation_images_zip(uploaded_file): """Upload a ZIP of presentation images from the phone/admin panel. Only known USA presentation image filenames are accepted. Files may be at ZIP root or under an images/ folder. """ image_dir = os.path.join(FOLDERS["USA"], "media", "usa-presentation", "images") os.makedirs(image_dir, exist_ok=True) stamp = time.strftime("%Y%m%d_%H%M%S") tmp_zip = os.path.join(ADMIN_UPLOAD_TMP_DIR, f"usa_images_{stamp}.zip") os.makedirs(ADMIN_UPLOAD_TMP_DIR, exist_ok=True) uploaded_file.save(tmp_zip) imported = [] skipped = [] try: with zipfile.ZipFile(tmp_zip, "r") as zf: for info in zf.infolist(): if info.is_dir(): continue raw_name = info.filename.replace("\\", "/") base = os.path.basename(raw_name) if not base or base.startswith(".") or raw_name.startswith("__MACOSX/"): continue stem, ext = os.path.splitext(base) stem = stem.strip() ext = ext.lower() if ext not in USA_IMAGE_EXTENSIONS: skipped.append(base) continue if stem not in USA_IMAGE_KEYS: skipped.append(base) continue for old_ext in USA_IMAGE_EXTENSIONS: old_path = os.path.join(image_dir, stem + old_ext) if os.path.exists(old_path): try: os.remove(old_path) except Exception: pass target = os.path.join(image_dir, stem + ".jpg") try: from PIL import Image with zf.open(info, "r") as source: img = Image.open(source) if img.mode not in ("RGB", "L"): img = img.convert("RGB") elif img.mode == "L": img = img.convert("RGB") img.save(target, "JPEG", quality=90, optimize=True) except Exception: with zf.open(info, "r") as source, open(target, "wb") as dest: shutil.copyfileobj(source, dest) imported.append(stem + ".jpg") finally: try: os.remove(tmp_zip) except Exception: pass return imported, skipped for folder_path in FOLDERS.values(): os.makedirs(folder_path, exist_ok=True) os.makedirs(os.path.join(FOLDERS["USA"], "media", "usa-presentation", "music"), exist_ok=True) os.makedirs(os.path.join(FOLDERS["USA"], "media", "usa-presentation", "images"), exist_ok=True) os.makedirs(ADMIN_BACKUP_DIR, exist_ok=True) os.makedirs(ADMIN_UPLOAD_TMP_DIR, exist_ok=True) def no_cache_response(response): response.headers["Cache-Control"] = "no-store, no-cache, must-revalidate, max-age=0" response.headers["Pragma"] = "no-cache" response.headers["Expires"] = "0" return response def find_html_file(folder_path): index_path = os.path.join(folder_path, "index.html") if os.path.exists(index_path): return "index.html" html_files = [f for f in os.listdir(folder_path) if f.lower().endswith((".html", ".htm"))] if html_files: return html_files[0] return None def clean_wrong_main_files(folder_path): wrong_names = {"html", "htm", "index", "index.htm", "download", "unknown"} for name in os.listdir(folder_path): full_path = os.path.join(folder_path, name) if not os.path.isfile(full_path): continue if name.lower().strip() in wrong_names: try: os.remove(full_path) except Exception: pass def save_uploaded_file(folder, uploaded_file): folder_path = FOLDERS[folder] os.makedirs(folder_path, exist_ok=True) original_filename = uploaded_file.filename or "" safe_name = secure_filename(original_filename) if folder in APP_FOLDERS: clean_wrong_main_files(folder_path) filename = "index.html" else: filename = safe_name or f"upload_{int(time.time())}" uploaded_file.save(os.path.join(folder_path, filename)) return filename def save_japan_presentation(presentation_key, uploaded_file): if presentation_key not in JAPAN_PRESENTATION_FILES: return None japan_folder = FOLDERS["JAPAN"] os.makedirs(japan_folder, exist_ok=True) filename = JAPAN_PRESENTATION_FILES[presentation_key] uploaded_file.save(os.path.join(japan_folder, filename)) return filename def save_usa_presentation(presentation_key, uploaded_file): if presentation_key not in USA_PRESENTATION_FILES: return None usa_folder = FOLDERS["USA"] os.makedirs(usa_folder, exist_ok=True) filename = USA_PRESENTATION_FILES[presentation_key] uploaded_file.save(os.path.join(usa_folder, filename)) return filename def save_usa_music(music_key, uploaded_file): if music_key not in USA_MUSIC_FILES: return None usa_folder = FOLDERS["USA"] rel_path = USA_MUSIC_FILES[music_key] full_path = os.path.join(usa_folder, rel_path) os.makedirs(os.path.dirname(full_path), exist_ok=True) uploaded_file.save(full_path) return rel_path def validate_admin_server_upload(tmp_path): size = os.path.getsize(tmp_path) if size <= 0: return False, "הקובץ ריק." if size > ADMIN_MAX_UPLOAD_BYTES: return False, f"הקובץ גדול מדי: {size:,} bytes. המגבלה היא {ADMIN_MAX_UPLOAD_BYTES:,} bytes." try: py_compile.compile(tmp_path, doraise=True) except py_compile.PyCompileError as exc: return False, "בדיקת קומפילציה נכשלה:\n" + str(exc) except Exception as exc: return False, "שגיאה בבדיקת הקובץ:\n" + repr(exc) try: with open(tmp_path, "r", encoding="utf-8", errors="ignore") as fh: content = fh.read(400000) except Exception as exc: return False, "לא ניתן לקרוא את הקובץ:\n" + repr(exc) required_tokens = ["Flask", "@app.route", "app.run"] missing = [token for token in required_tokens if token not in content] if missing: return False, "הקובץ עבר קומפילציה, אבל לא נראה כמו admin_server.py של TripServer. חסרים סימנים: " + ", ".join(missing) return True, "OK" def admin_status_page(title, message, ok=True, details=""): color = "#16a34a" if ok else "#dc2626" bg = "#052e1b" if ok else "#3f1d1d" safe_title = html_lib.escape(title) safe_message = html_lib.escape(message).replace("\n", "
") safe_details = html_lib.escape(details).replace("\n", "
") details_html = f"
{safe_details}
" if details else "" return f""" {safe_title}
TripServer Admin

{safe_title}

{safe_message}

{details_html} חזרה לפאנל
""" def backup_current_admin_server(prefix="admin_server_backup"): os.makedirs(ADMIN_BACKUP_DIR, exist_ok=True) stamp = time.strftime("%Y%m%d_%H%M%S") backup_path = os.path.join(ADMIN_BACKUP_DIR, f"{prefix}_{stamp}.py") shutil.copy2(ADMIN_SERVER_PATH, backup_path) return backup_path def latest_admin_backup(): os.makedirs(ADMIN_BACKUP_DIR, exist_ok=True) backups = glob.glob(os.path.join(ADMIN_BACKUP_DIR, "admin_server_backup_*.py")) if not backups: return None return max(backups, key=os.path.getmtime) def log_admin_restart(message): try: os.makedirs(BASE_DIR, exist_ok=True) with open(ADMIN_RESTART_LOG_PATH, "a", encoding="utf-8") as fh: fh.write(time.strftime("%Y-%m-%d %H:%M:%S") + " | " + str(message) + "\n") except Exception: pass def restart_process_later(): """Reliable self-restart for Windows/iPhone admin workflow.""" time.sleep(0.8) script_path = os.path.abspath(ADMIN_SERVER_PATH) python_exe = sys.executable or "python" work_dir = os.path.dirname(script_path) or BASE_DIR try: log_admin_restart(f"restart requested | script={script_path} | python={python_exe} | argv={sys.argv}") if os.name == "nt": # Use a detached helper so the server can exit first and free port 8000. cmd = "\r\n".join([ "@echo off", 'cd /d "{}"'.format(work_dir), "timeout /t 2 /nobreak >nul", 'start "TripServer Admin" /min "{}" "{}"'.format(python_exe, script_path), "" ]) with open(ADMIN_RESTART_CMD_PATH, "w", encoding="utf-8") as fh: fh.write(cmd) subprocess.Popen(["cmd", "/c", ADMIN_RESTART_CMD_PATH], cwd=work_dir, close_fds=True) os._exit(0) else: subprocess.Popen([python_exe, script_path], cwd=work_dir, close_fds=True, start_new_session=True) os._exit(0) except Exception as exc: # Fallback: do not silently die before recording what happened. log_admin_restart("restart failed: " + repr(exc)) try: os.execv(python_exe, [python_exe, script_path]) except Exception as exc2: log_admin_restart("execv fallback failed: " + repr(exc2)) os._exit(1) def serve_app(folder): file_name = find_html_file(FOLDERS[folder]) if not file_name: return f"No HTML file found in {folder} folder", 404 response = make_response(send_from_directory(FOLDERS[folder], file_name)) return no_cache_response(response) @app.route("/") def home(): return """ מרכז ניהול

מרכז ניהול

מערכת מרכזית לניהול קבצים, תקציבים ולוחות זמנים

📁

ניהול קבצים

העלאת קבצים ישירות למחשב.
💰

תקציב טיולים

ניהול תקציב חופשות וסנכרון נתונים.
🏠

תקציב משפחתי

ניהול תקציב חודשי, Limits, הוצאות בפועל וארכיון חודשים.
🇯🇵

טיול יפן

לוז, ניווטים ומסמכי הטיול.
🇺🇸

טיול ארה״ב

טיול בר מצווה 2027.
TripServer
""" @app.route("/admin") @app.route("/admin/") def admin(): return """ ניהול קבצים
⬅ חזרה למסך הראשי

ניהול והעלאת קבצים

🇯🇵 טיול יפן

כל קובץ שתעלה כאן יישמר כ־index.html.

🎬 מצגות יפן

כאן מעלים רק את קבצי המצגות, לא את קובץ הטיול הראשי. הקבצים יישמרו אוטומטית בשמות הנכונים.

✈️ פתיח טיסה

יישמר אוטומטית בשם:
japan-flight-intro.html

🎌 מצגת יפן

יישמר אוטומטית בשם:
japan-experience.html

בדיקת פתיח טיסה בדיקת מצגת יפן פתיחת קובץ יפן

🇺🇸 טיול ארה״ב

כל קובץ שתעלה כאן יישמר כ־index.html.

פתיחת קובץ ארה״ב בדיקת מצגת ארה״ב

🎬 מצגת ארה״ב

כאן מעלים רק את קובץ המצגת של ארה״ב. גם אם שם הקובץ אצלך שגוי – הוא יישמר אוטומטית בשם התקין, כדי שכפתור המצגת בקובץ הטיול יעבוד מיד.

יישמר אוטומטית בשם:
usa2027-presentation.html

בדיקת מצגת ארה״ב פתיחת מצגת במסך מלא פתיחת קובץ ארה״ב

🖼️ תמונות מצגת ארה״ב

עודכן למצגת החדשה: הפאנל תומך עכשיו גם בשקף מפת הרוד־טריפ החדש — roadtrip-map — בנוסף לכל 36 הימים, פתיחה, תקציב, סיכום ושקפי הרוד־טריפ.
אפשר לעבוד מהטלפון בשתי דרכים: העלאת תמונה בודדת דרך הכרטיס המתאים, או העלאת ZIP אחד עם שמות הקבצים המדויקים. הפאנל ישמור אוטומטית בתיקיית התמונות הנכונה.

ב־ZIP יש לשים קבצים בשם מדויק, למשל: roadtrip-map.jpg, extra-big-sur.jpg, extra-diner.jpg, extra-death-valley.jpg, extra-mono-lake.jpg, או day-15.jpg להחלפת תמונת יום 15.

התמונות נשמרות אוטומטית בתיקייה:
C:\\TripServer\\USA\\media\\usa-presentation\\images
ובשם קבוע לפי השקף, למשל day-04.jpg, day-12.jpg, day-34.jpg, extra-big-sur.jpg, extra-diner.jpg, extra-death-valley.jpg, extra-mono-lake.jpg.

בדיקת המצגת אחרי העלאת תמונה

🎵 מוזיקת מצגת ארה״ב

עודכן למצגת שני השירים: אפשר להעלות מהפאנל את שיר חלק 1 ואת שיר חלק 2. לא משנה מה שם הקובץ בטלפון — הפאנל שומר בשם הקבוע שהמצגת מחפשת.

🎸 שיר חלק 1 — Road Trip

יישמר כ־C:\\TripServer\\USA\\media\\usa-presentation\\music\\usa-roadtrip-theme.mp3

🎧 שיר חלק 2 — Orlando / Miami / Cruise

יישמר כ־C:\\TripServer\\USA\\media\\usa-presentation\\music\\usa-part2-theme.mp3

בדיקת שיר חלק 1 בדיקת שיר חלק 2 בדיקת המצגת עם שני השירים

⚙️ עדכון קובץ הפאנל / admin_server.py

זהירות: זה הקובץ שמפעיל את הפאנל עצמו. ההעלאה תתבצע רק אחרי בדיקת קומפילציה, גיבוי אוטומטי, ורק אז החלפה.
הזרימה: העלאת admin_server.py חדש → בדיקת Python → גיבוי לקובץ הקיים → החלפה → אתחול פאנל.

הקובץ הפעיל: C:\\TripServer\\admin_server.py
גיבויים נשמרים אוטומטית בתיקייה: C:\\TripServer\\backups\\admin_server

הערה: אחרי החלפת הקובץ, חובה ללחוץ “אתחל פאנל” כדי שהשרת יעבור לגרסה החדשה. עד האתחול, הפאנל שרץ בזיכרון ממשיך לעבוד על הגרסה הישנה.

💰 תקציב טיולים

כל קובץ שתעלה כאן יישמר כ־index.html.

🏠 תקציב משפחתי

כל קובץ שתעלה כאן יישמר כ־index.html.

""" @app.route("/health") def health(): return {"ok": True, "service": "TripServer Admin", "version": "USA2027 panel v3 reliable restart", "slides": 43} @app.route("/upload_admin_server", methods=["POST"]) def upload_admin_server(): file = request.files.get("file") if not file or file.filename == "": return admin_status_page("לא נבחר קובץ", "בחר קובץ admin_server.py להעלאה.", ok=False), 400 original_name = file.filename or "" if not original_name.lower().endswith(".py"): return admin_status_page("קובץ לא תקין", "ניתן להעלות כאן רק קובץ Python עם סיומת .py", ok=False), 400 if request.content_length and request.content_length > ADMIN_MAX_UPLOAD_BYTES + 250000: return admin_status_page("קובץ גדול מדי", f"הקובץ גדול מהמותר. המגבלה היא בערך {ADMIN_MAX_UPLOAD_BYTES:,} bytes.", ok=False), 413 os.makedirs(ADMIN_UPLOAD_TMP_DIR, exist_ok=True) stamp = time.strftime("%Y%m%d_%H%M%S") tmp_path = os.path.join(ADMIN_UPLOAD_TMP_DIR, f"admin_server_upload_{stamp}.py") try: file.save(tmp_path) valid, details = validate_admin_server_upload(tmp_path) if not valid: try: os.remove(tmp_path) except Exception: pass return admin_status_page("העלאת admin_server.py נדחתה", "הקובץ הקיים לא הוחלף. נמצאה בעיה בקובץ שהעלית.", ok=False, details=details), 400 backup_path = backup_current_admin_server("admin_server_backup") os.replace(tmp_path, ADMIN_SERVER_PATH) message = ( "הקובץ החדש עבר בדיקת קומפילציה והחליף את admin_server.py הפעיל.\n" "נוצר גיבוי לקובץ הקודם.\n\n" "כדי שהשינוי ייכנס בפועל, לחץ עכשיו על אתחל פאנל." ) details = f"קובץ פעיל:\n{ADMIN_SERVER_PATH}\n\nגיבוי:\n{backup_path}" return admin_status_page("admin_server.py עודכן בהצלחה", message, ok=True, details=details) except Exception as exc: try: if os.path.exists(tmp_path): os.remove(tmp_path) except Exception: pass return admin_status_page("שגיאה בעדכון admin_server.py", "הקובץ הקיים לא הוחלף.", ok=False, details=repr(exc)), 500 @app.route("/restart_admin_server", methods=["POST"]) def restart_admin_server(): threading.Thread(target=restart_process_later, daemon=True).start() return admin_status_page( "הפאנל מופעל מחדש", "האיפוס התחיל דרך מנגנון Restart חיצוני. המתן 5–10 שניות ואז רענן את הפאנל. אם לא עולה, בדוק את C:\\TripServer\\admin_restart.log.", ok=True, ) @app.route("/restore_admin_server_backup", methods=["POST"]) def restore_admin_server_backup(): backup_path = latest_admin_backup() if not backup_path: return admin_status_page("אין גיבוי לשחזור", "לא נמצא קובץ גיבוי בתיקיית הגיבויים.", ok=False), 404 try: valid, details = validate_admin_server_upload(backup_path) if not valid: return admin_status_page("הגיבוי האחרון לא תקין", "הגיבוי לא שוחזר כי הוא לא עבר בדיקת תקינות.", ok=False, details=details), 400 safety_backup = backup_current_admin_server("admin_server_before_restore") shutil.copy2(backup_path, ADMIN_SERVER_PATH) msg = "הגיבוי האחרון שוחזר אל admin_server.py. לחץ אתחל פאנל כדי להפעיל אותו." det = f"שוחזר מתוך:\n{backup_path}\n\nגיבוי בטיחות לגרסה שהייתה פעילה לפני השחזור:\n{safety_backup}" return admin_status_page("שחזור גיבוי בוצע", msg, ok=True, details=det) except Exception as exc: return admin_status_page("שגיאה בשחזור גיבוי", "לא בוצע שחזור.", ok=False, details=repr(exc)), 500 @app.route("/upload/", methods=["POST"]) def upload(folder): if folder not in FOLDERS: return "Folder not found", 404 file = request.files.get("file") if not file or file.filename == "": return "No file selected", 400 save_uploaded_file(folder, file) return redirect("/admin") @app.route("/upload_presentation/", methods=["POST"]) def upload_presentation(presentation_key): file = request.files.get("file") if not file or file.filename == "": return "No file selected", 400 filename = save_japan_presentation(presentation_key, file) if not filename: return "Presentation type not found", 404 return redirect("/admin") @app.route("/upload_usa_presentation/", methods=["POST"]) def upload_usa_presentation(presentation_key): file = request.files.get("file") if not file or file.filename == "": return "No file selected", 400 filename = save_usa_presentation(presentation_key, file) if not filename: return "USA presentation type not found", 404 return redirect("/admin") @app.route("/upload_usa_image", methods=["POST"]) def upload_usa_image(): image_key = request.form.get("image_key", "").strip() file = request.files.get("file") if not file or file.filename == "": return "No file selected", 400 filename = save_usa_presentation_image(image_key, file) if not filename: return "USA image key not found", 404 return redirect("/admin") @app.route("/upload_usa_images_zip", methods=["POST"]) def upload_usa_images_zip(): file = request.files.get("file") if not file or file.filename == "": return "No file selected", 400 original_name = file.filename or "" if not original_name.lower().endswith(".zip"): return admin_status_page("קובץ לא תקין", "ניתן להעלות כאן רק קובץ ZIP של תמונות מצגת.", ok=False), 400 try: imported, skipped = save_usa_presentation_images_zip(file) details = "הועלו:\n" + ("\n".join(imported) if imported else "לא הועלו תמונות.") if skipped: details += "\n\nדולגו כי השם לא מתאים למצגת או שהסיומת לא נתמכת:\n" + "\n".join(skipped[:80]) return admin_status_page( "ZIP תמונות ארה״ב נטען", f"הועלו {len(imported)} תמונות למצגת. עכשיו אפשר לבדוק את המצגת מהפאנל.", ok=True, details=details, ) except zipfile.BadZipFile: return admin_status_page("ZIP לא תקין", "הקובץ שהועלה אינו ZIP תקין או שלא ניתן לפתוח אותו.", ok=False), 400 except Exception as exc: return admin_status_page("שגיאה בהעלאת ZIP", "לא ניתן היה לעבד את קובץ התמונות.", ok=False, details=repr(exc)), 500 @app.route("/upload_usa_music/", methods=["POST"]) def upload_usa_music(music_key): file = request.files.get("file") if not file or file.filename == "": return "No file selected", 400 filename = save_usa_music(music_key, file) if not filename: return "USA music type not found", 404 return redirect("/admin") @app.route("/JAPAN") @app.route("/JAPAN/") def japan(): return serve_app("JAPAN") @app.route("/USA") @app.route("/USA/") def usa(): return serve_app("USA") @app.route("/Moneyapp") @app.route("/Moneyapp/") def moneyapp(): return serve_app("Moneyapp") @app.route("/MoneyHome") @app.route("/MoneyHome/") def moneyhome(): return serve_app("MoneyHome") @app.route("/JAPAN/") def japan_static(path): response = make_response(send_from_directory(FOLDERS["JAPAN"], path)) return no_cache_response(response) @app.route("/USA/") def usa_static(path): response = make_response(send_from_directory(FOLDERS["USA"], path)) return no_cache_response(response) @app.route("/Moneyapp/") def money_static(path): response = make_response(send_from_directory(FOLDERS["Moneyapp"], path)) return no_cache_response(response) @app.route("/MoneyHome/") def moneyhome_static(path): response = make_response(send_from_directory(FOLDERS["MoneyHome"], path)) return no_cache_response(response) if __name__ == "__main__": app.run(host="0.0.0.0", port=8000, threaded=True, use_reloader=False)