Update main.py

💣 地雷一：空購物車或異常資料會讓「庫存 API」直接崩潰 (Server Error 500)
💣 地雷二：「補付款 API」金額鎖死 1000 元，外帶掉單會虧錢！

main.py

@@ -63,7 +63,7 @@ class RepayPayload(BaseModel):
     order_id: str
 
 # ==========================================
-# 🌟 新增：背景自動救援掉單機器人 🌟
+# 🌟 背景自動救援掉單機器人 🌟
 # ==========================================
 async def auto_rescue_dropped_order(order_id: str, amount: int):
     # 讓程式在背景默默等待 3 分鐘 (180秒)
@@ -135,7 +135,6 @@ async def auto_rescue_dropped_order(order_id: str, amount: int):
 def read_root():
     return {"status": "online", "message": "Cié Cié FastAPI is running."}
 
-# 🌟 修改：加入 background_tasks 參數 🌟
 @app.post("/api/submit_booking")
 async def submit_booking(payload: OrderPayload, background_tasks: BackgroundTasks):
     if not supabase:
@@ -238,10 +237,7 @@ async def confirm_payment(payload: ConfirmPayload):
         res_data = res.json()
 
         if res_data.get("returnCode") == "0000":
-            # 1. 更新資料庫狀態為已付款
             update_res = supabase.table("bookings").update({"status": "待處理 (已付訂金)"}).ilike("remarks", f"%{payload.order_id}%").execute()
-            
-            # 2. 發送通知給老闆
             if update_res.data:
                 b = update_res.data[0]
                 notify_boss(b['name'], b['tel'], b['date'], b['time'], b['pax'], payload.amount)
@@ -252,7 +248,7 @@ async def confirm_payment(payload: ConfirmPayload):
     except Exception as e:
         raise HTTPException(status_code=500, detail=str(e))
 
-# 處理重新產生付款連結的 API
+# 處理重新產生付款連結的 API (防呆升級版)
 @app.post("/api/linepay/repay")
 async def repay_payment(payload: RepayPayload):
     if not supabase: raise HTTPException(status_code=500, detail="資料庫未連線")
@@ -265,7 +261,22 @@ async def repay_payment(payload: RepayPayload):
         if "已付" in booking.get("status", "") or "確認" in booking.get("status", ""):
             raise HTTPException(status_code=400, detail="此訂單已完成付款或確認，無需重新結帳")
 
-        amount = 1000 
+        # 🌟 修改：向 LINE Pay 查詢最初應付的正確金額，避免外帶單只收 1000 元 🌟
+        amount = 1000 # 預設防護底線
+        try:
+            chk_uri = "/v3/payments"
+            chk_query = urllib.parse.urlencode({"orderId": payload.order_id})
+            chk_nonce = str(uuid.uuid4())
+            chk_msg = LINE_PAY_CHANNEL_SECRET + chk_uri + chk_query + chk_nonce
+            chk_sig = base64.b64encode(hmac.new(LINE_PAY_CHANNEL_SECRET.encode(), chk_msg.encode(), hashlib.sha256).digest()).decode()
+            chk_headers = { "Content-Type": "application/json", "X-LINE-ChannelId": LINE_PAY_CHANNEL_ID, "X-LINE-Authorization-Nonce": chk_nonce, "X-LINE-Authorization": chk_sig }
+            chk_res = requests.get(f"{LINE_PAY_BASE_URL}{chk_uri}?{chk_query}", headers=chk_headers).json()
+            if chk_res.get("returnCode") == "0000" and chk_res.get("info"):
+                # 成功抓出這筆訂單原本設定的金額！
+                amount = chk_res["info"][0].get("payInfo", [{}])[0].get("amount", 1000)
+        except Exception as e:
+            print(f"無法取得原始金額，使用預設值: {e}")
+
         new_order_id = f"{payload.order_id}-R{int(time.time())}"
         
         request_body = {
@@ -273,8 +284,8 @@ async def repay_payment(payload: RepayPayload):
             "currency": "TWD",
             "orderId": new_order_id, 
             "packages": [{
-                "id": "pkg_repay", "amount": amount, "name": "Cié Cié Taipei 補繳訂金",
-                "products": [{"name": "餐飲訂金", "quantity": 1, "price": amount}]
+                "id": "pkg_repay", "amount": amount, "name": "Cié Cié Taipei 補繳結帳",
+                "products": [{"name": "餐飲訂金或外帶全額", "quantity": 1, "price": amount}]
             }],
             "redirectUrls": {
                 "confirmUrl": f"{RETURN_URL}?action=payment_confirm&amount={amount}&orderId={payload.order_id}", 
@@ -315,7 +326,7 @@ def notify_boss(name, tel, date, time, pax, amount):
     except: pass
 
 # ==========================================
-# 🌟 新增：計算某日庫存與銷量的 API 🌟
+# 🌟 計算某日庫存與銷量的 API (防護升級版) 🌟
 # ==========================================
 @app.get("/api/inventory/{query_date}")
 async def get_inventory(query_date: str):
@@ -330,15 +341,21 @@ async def get_inventory(query_date: str):
                 if "取消" in b.get("status", "") or "No-Show" in b.get("status", ""):
                     continue
                 
+                # 🌟 修改：加入型別檢查防護，避免 null 或 字串 引發當機
+                cart = b.get("cart")
+                if not cart:
+                    cart = {}
+                elif isinstance(cart, str):
+                    try: cart = json.loads(cart)
+                    except: cart = {}
+                
                 # 計算這筆訂單買了什麼
-                cart = b.get("cart", {})
                 for item_id, qty in cart.items():
-                    # 防呆：確保 qty 是整數
                     try: qty = int(qty)
                     except: qty = 0
                     sold_counts[item_id] = sold_counts.get(item_id, 0) + qty
                     
-        return sold_counts # 回傳格式如：{"steak": 2, "fries": 5}
+        return sold_counts 
     except Exception as e:
         print(f"Inventory Error: {e}")
-        return {}    
+        return {}