[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_165":166,"_167":168},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":97,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",79,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","5fb0ef94-3d4f-11f1-a366-42b51c65c3df","name","fileType","http","content","import { GoogleGenerativeAI } from \"npm:@google/generative-ai\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport md5 from \"npm:md5\";\n\n// ==========================================\n// 🛠️ 數據庫初始化\n// ==========================================\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS pet_customers_v2 (\n phone TEXT PRIMARY KEY,\n chat_history TEXT,\n last_seen DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\n// ==========================================\n// 🔗 Involve Asia 聯盟引擎 (V4.0 變 Link 魔法)\n// ==========================================\nasync function getInvolveToken() {\n const apiKey = Deno.env.get(\"INVOLVE_API_KEY\");\n const apiSecret = Deno.env.get(\"INVOLVE_API_SECRET\");\n if (!apiKey || !apiSecret) {\n console.error(\"❌ 缺少 INVOLVE_API_KEY 或 SECRET\");\n return null;\n }\n\n const url = \"https://api.involve.asia/api/authenticate\";\n const payload = new URLSearchParams({\n key: apiKey,\n secret: apiSecret,\n });\n\n try {\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Accept\": \"application/json\",\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: payload,\n });\n const data = await res.json();\n if (data.status === \"success\") return data.data.token;\n console.error(\"❌ Involve 攞通行證失敗:\", data);\n return null;\n } catch (e) {\n console.error(\"❌ Involve 認證 Error:\", e);\n return null;\n }\n}\n\nasync function generateInvolveDeeplink(destinationUrl, offerId) {\n try {\n const token = await getInvolveToken();\n if (!token) return destinationUrl; // 攞唔到證，用返原 Link 頂住先\n\n const url = \"https://api.involve.asia/api/deeplink/generate\";\n const payload = new URLSearchParams({\n url: destinationUrl,\n offer_id: offerId,\n });\n\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Accept\": \"application/json\",\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: payload,\n });\n\n const data = await res.json();\n if (data.status === \"success\" && data.data && data.data.tracking_link) {\n console.log(\"✅ 成功變出發達 Link:\", data.data.tracking_link);\n return data.data.tracking_link;\n }\n console.error(\"⚠️ Deeplink 轉換失敗，使用原 Link:\", data);\n return destinationUrl;\n } catch (e) {\n console.error(\"⚠️ Involve Deeplink Error:\", e);\n return destinationUrl;\n }\n}\n\n// ==========================================\n// 🛠️ 淘寶引擎 (保留完美保底機制)\n// ==========================================\nfunction getTaobaoSign(params, secret) {\n const sortedKeys = Object.keys(params).sort();\n let signStr = secret;\n for (const key of sortedKeys) signStr += key + params[key];\n signStr += secret;\n return md5(signStr).toUpperCase();\n}\n\nasync function searchTaobao(keyword) {\n console.log(\"🚀 [幕後] 淘寶引擎啟動: 搵緊 [\" + keyword + \"]\");\n try {\n const appKey = Deno.env.get(\"TAOBAO_APP_KEY\");\n const appSecret = Deno.env.get(\"TAOBAO_APP_SECRET\");\n const adzoneId = Deno.env.get(\"TAOBAO_ADZONE_ID\");\n if (!appKey || !appSecret || !adzoneId) throw new Error(\"未設定淘寶密碼\");\n\n const tzOffset = 8 * 60 * 60 * 1000;\n const timestamp = new Date(Date.now() + tzOffset).toISOString().replace(\n \"T\",\n \" \",\n ).substring(0, 19);\n\n const params = {\n method: \"taobao.tbk.dg.material.optional.upgrade\",\n app_key: appKey,\n sign_method: \"md5\",\n timestamp: timestamp,\n format: \"json\",\n v: \"2.0\",\n adzone_id: adzoneId,\n q: keyword,\n page_no: \"1\",\n page_size: \"1\",\n };\n\n params.sign = getTaobaoSign(params, appSecret);\n const searchParams = new URLSearchParams(params);\n const url = \"https://eco.taobao.com/router/rest?\" + searchParams.toString();\n\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), 10000);\n\n let response;\n try {\n response = await fetch(url, {\n signal: controller.signal,\n headers: { \"User-Agent\": \"Mozilla/5.0\", \"Accept\": \"application/json\" },\n });\n } catch (e) {\n throw new Error(\"淘寶 Timeout\");\n } finally {\n clearTimeout(timeoutId);\n }\n\n const data = await response.json();\n if (data.error_response) {\n throw new Error(data.error_response.sub_msg || data.error_response.msg);\n }\n\n const items = data?.tbk_dg_material_optional_upgrade_response?.result_list\n ?.map_data;\n if (items && items.length > 0) {\n let rawItem = items[0];\n\n // 💰 金錢雷達：喺堆貨入面，優先搵有「專屬佣金連結 (click_url)」嗰件！\n let rawItem = null;\n for (let i = 0; i < items.length; i++) {\n if (items[i].coupon_share_url || items[i].click_url) {\n rawItem = items[i];\n break; // 搵到有佣金嘅貨！即刻停手！\n }\n }\n\n // 如果真係全場都冇佣金 Link，先焗住用第一件保底\n if (!rawItem) {\n rawItem = items[0];\n }\n\n let itemTitle = rawItem.title || rawItem.item_basic_info?.title ||\n rawItem.short_title || \"熱賣寵物好物\";\n if (typeof itemTitle === \"string\") {\n itemTitle = itemTitle.replace(/<[^>]+>/g, \"\");\n }\n\n let itemPrice = rawItem.zk_final_price ||\n rawItem.price_promo_info?.zk_final_price || rawItem.reserve_price ||\n rawItem.price || 0;\n if (itemPrice == 0) itemPrice = \"49.9\";\n\n // 💰 優先攞真正可以賺錢嘅 Link！\n let itemLink = rawItem.coupon_share_url || rawItem.click_url ||\n rawItem.url || rawItem.item_url || \"\";\n let itemId = rawItem.num_iid || rawItem.item_id || rawItem.auction_id ||\n \"\";\n\n if (String(itemId).length > 15) {\n itemId = \"\";\n }\n\n if (!itemLink && itemId) {\n itemLink = \"https://item.taobao.com/item.htm?id=\" + itemId;\n } else if (!itemLink) {\n itemLink = \"https://s.taobao.com/search?q=\" +\n encodeURIComponent(itemTitle);\n } else if (itemLink && !itemLink.startsWith(\"http\")) {\n itemLink = \"https:\" +\n (itemLink.startsWith(\"//\") ? itemLink : \"//\" + itemLink);\n }\n\n let itemImg = rawItem.pict_url || rawItem.item_basic_info?.pict_url || \"\";\n if (itemImg && !itemImg.startsWith(\"http\")) {\n itemImg = \"https:\" +\n (itemImg.startsWith(\"//\") ? itemImg : \"//\" + itemImg);\n }\n\n return {\n platform: \"淘寶\",\n price: parseFloat(itemPrice) || 0,\n title: itemTitle,\n link: itemLink,\n image: itemImg,\n };\n }\n throw new Error(\"搵唔到貨\");\n } catch (error) {\n console.error(\"❌ 淘寶出錯:\", error.message);\n return {\n platform: \"淘寶(系統更新中)\",\n price: 9999,\n link: \"https://taobao.com\",\n title: \"等待淘寶開通權限...\",\n image:\n \"https://i.ibb.co/sv022x3P/Gemini-Generated-Image-9vt2379vt2379vt2.png\",\n };\n }\n}\n\n// ==========================================\n// 📲 Twilio 推播 & 老闆求救\n// ==========================================\nasync function sendWhatsAppMessage(toPhone, messageBody, mediaUrl = null) {\n const sid = Deno.env.get(\"TWILIO_ACCOUNT_SID\");\n const token = Deno.env.get(\"TWILIO_AUTH_TOKEN\");\n const fromPhone = Deno.env.get(\"TWILIO_PHONE\");\n if (!sid || !token || !fromPhone) {\n console.error(\"❌ 缺少 Twilio 環境變數！\");\n return;\n }\n\n const url = \"https://api.twilio.com/2010-04-01/Accounts/\" + sid +\n \"/Messages.json\";\n const auth = btoa(sid + \":\" + token);\n const payload = new URLSearchParams({\n From: fromPhone,\n To: toPhone,\n Body: messageBody,\n });\n if (mediaUrl) payload.append(\"MediaUrl\", mediaUrl);\n\n try {\n console.log(\n `📲 [推播] 發送畀 ${toPhone} | 內容: ${messageBody.substring(0, 20)}...`,\n );\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Basic \" + auth,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: payload,\n });\n if (!res.ok) {\n const errText = await res.text();\n console.error(`❌ Twilio 拒絕發送 (HTTP ${res.status}):`, errText);\n } else {\n console.log(\"✅ Twilio 發送成功!\");\n }\n } catch (error) {\n console.error(\"❌ 推播 fetch 崩潰:\", error);\n }\n}\n\nasync function callTheBoss(customerPhone, customerMessage) {\n const bossPhone = Deno.env.get(\"BOSS_PHONE\");\n if (bossPhone) {\n await sendWhatsAppMessage(\n bossPhone,\n \"🚨 【老闆出動】\\n客(\" + customerPhone + \") 遇到狀況！\\n情況：「\" +\n customerMessage + \"」\",\n );\n }\n}\n\n// ==========================================\n// ⚡ AI 核心工具\n// ==========================================\nasync function askAI(prompt, fallbackText) {\n try {\n const apiKey = Deno.env.get(\"GEMINI_API_KEY\");\n const genAI = new GoogleGenerativeAI(apiKey);\n const model = genAI.getGenerativeModel({ model: \"gemini-2.5-flash\" });\n\n const aiPromise = model.generateContent(prompt);\n const timeoutPromise = new Promise((_, r) =>\n setTimeout(() => r(new Error(\"AI_TIMEOUT\")), 30000)\n );\n const result = await Promise.race([aiPromise, timeoutPromise]);\n\n let text = result.response.text().trim();\n if (text.startsWith(\"```json\")) {\n text = text.replace(/```json/g, \"\").replace(/```/g, \"\").trim();\n }\n return text;\n } catch (e) {\n console.error(\"⚠️ AI 發生錯誤，使用 Fallback:\", e.message);\n return fallbackText;\n }\n}\n\n// ==========================================\n// 🧠 幕後黑手 (V4.0 變形金剛版)\n// ==========================================\nasync function processRequestAsync(customerPhone, customerMessage) {\n try {\n // 1️⃣ 提取過往記憶\n let chatHistory = [];\n const dbResult = await sqlite.execute({\n sql: \"SELECT chat_history FROM pet_customers_v2 WHERE phone = ?\",\n args: [customerPhone],\n });\n if (dbResult.rows && dbResult.rows.length > 0) {\n try {\n const savedHistory = dbResult.rows.chat_history;\n if (savedHistory) chatHistory = JSON.parse(savedHistory);\n } catch (e) {\n console.error(\"記憶解析失敗\", e);\n }\n }\n let historyText = chatHistory.map((m) =>\n (m.role === \"user\" ? \"客: \" : \"阿喵: \") + m.content\n ).join(\"\\n\");\n if (!historyText) historyText = \"(無過往紀錄)\";\n\n // 2️⃣ 意圖與傾偈\n const megaPrompt = `你係香港寵物用品金牌Sales「阿喵」。\n【過往對話】：\n${historyText}\n\n【最新客人輸入】: \"${customerMessage}\"\n\n請分析客人嘅意圖，並嚴格以純 JSON 格式回覆 (唔好加任何 Markdown 標籤)：\n- 情況A (搵老闆/投訴) -> {\"intent\": \"HUMAN\", \"keyword\": \"無\", \"reply\": \"交俾老闆\"}\n- 情況B (想買嘢/搵產品/問價) -> {\"intent\": \"SEARCH\", \"keyword\": \"提取最準確嘅淘寶搜尋字\", \"reply\": \"無\"}\n- 情況C (普通傾偈/答OK/問養寵物知識) -> {\"intent\": \"CHAT\", \"keyword\": \"無\", \"reply\": \"用熱情廣東話直接解答客人問題、安撫或順住話題傾偈。展現你嘅專業知識！字數控制喺100字內。\"}\n\n純 JSON 回覆：`;\n\n const aiText = await askAI(\n megaPrompt,\n '{\"intent\":\"CHAT\", \"keyword\":\"無\", \"reply\":\"🤖 喵～收到！有咩隨時搵我傾偈呀！\"}',\n );\n let intentData = {\n intent: \"CHAT\",\n keyword: \"無\",\n reply: \"🤖 喵～收到！有咩隨時搵我！\",\n };\n try {\n intentData = JSON.parse(aiText);\n } catch (e) {}\n console.log(\n `🎯 [幕後] 意圖: ${intentData.intent} | 搜尋: ${intentData.keyword}`,\n );\n\n let replyMessage = \"\";\n let imageUrl = null;\n\n // 🧭 根據意圖分流處理：\n if (intentData.intent === \"HUMAN\") {\n await callTheBoss(customerPhone, \"要求真人對話: \" + customerMessage);\n replyMessage = \"🤖 收到主人！已經幫你呼叫緊老闆，佢會即刻親自覆你！🙇‍♂️\";\n await sendWhatsAppMessage(customerPhone, replyMessage);\n } else if (intentData.intent === \"CHAT\") {\n replyMessage = intentData.reply;\n await sendWhatsAppMessage(customerPhone, replyMessage);\n } else {\n // 🛒 【買嘢模式】：去淘寶摷貨\n const taobaoResult = await searchTaobao(intentData.keyword);\n\n // 🚀🚀🚀 V4.0 終極魔法：攔截普通 Link，變做發達 Link！\n if (taobaoResult.price !== 9999 && taobaoResult.link) {\n const taobaoOfferId = Deno.env.get(\"INVOLVE_OFFER_ID_TAOBAO\");\n if (taobaoOfferId) {\n console.log(\n \"🪄 [幕後] 正在將淘寶 Link 轉換為 Involve Asia 發達 Link...\",\n );\n // 交俾 Involve Asia 變法！\n // taobaoResult.link = await generateInvolveDeeplink(\n // taobaoResult.link,\n // taobaoOfferId,\n // );\n } else {\n console.log(\n \"⚠️ 缺少 INVOLVE_OFFER_ID_TAOBAO，無法變身，使用原本淘寶 Link\",\n );\n }\n } else if (taobaoResult.price === 9999) {\n await callTheBoss(\n customerPhone,\n \"淘寶系統出錯/未開通，客想搵: \" + intentData.keyword,\n );\n }\n let priceText = (taobaoResult.price === 49.9 || taobaoResult.price === 0)\n ? \"幾十蚊起\"\n : \"大約 HK$\" + taobaoResult.price;\n\n const salesPrompt = `你係香港寵物用品金牌Sales「阿喵」。\n\n 【過往對話】:\n ${historyText}\n\n 【最新客人輸入】: \"${customerMessage}\"\n 【系統搵到大合集】: 淘寶精選「${taobaoResult.title}」 (參考價: ${priceText})\n\n 【阿喵守則】:\n 1. 保持熱情廣東話，語氣要似金牌 Sales。\n 2. 💥【格價大師模式】：同客人講，你幫佢搵咗一個「特價大合集」！入面有齊唔同舖頭、唔同款式嘅選擇！\n 3. 絕！對！唔！好！講死「只係賣幾多錢」，你要話：「參考價 ${priceText}，不過撳入去仲有好多十幾廿蚊嘅超抵平價款式任你揀！」\n 4. 叫客人即刻撳入下面條 Link 慢慢格價同尋寶！\n 回覆：`;\n replyMessage = await askAI(\n salesPrompt,\n \"🤖 搵到啦！最抵係 \" + taobaoResult.platform + \" (HK$\" +\n taobaoResult.price + \")！\",\n );\n\n if (taobaoResult.price !== 9999) {\n replyMessage += \"\\n\\n📸 睇睇實物圖片: \" + taobaoResult.image;\n replyMessage += \"\\n\\n🛒 購買連結: \" + taobaoResult.link;\n }\n\n await sendWhatsAppMessage(\n customerPhone,\n replyMessage,\n \"\", // 徹底放棄用 Twilio 派圖，保證文字 100% 殺入 WhatsApp！\n );\n }\n\n // 4️⃣ 記憶庫更新\n if (replyMessage) {\n chatHistory.push({ role: \"user\", content: customerMessage });\n chatHistory.push({\n role: \"assistant\",\n content: replyMessage.replace(/\\n\\n🛒.*/, \"\"),\n });\n if (chatHistory.length > 6) {\n chatHistory = chatHistory.slice(chatHistory.length - 6);\n }\n await sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO pet_customers_v2 (phone, chat_history, last_seen) VALUES (?, ?, CURRENT_TIMESTAMP)\",\n args: [customerPhone, JSON.stringify(chatHistory)],\n });\n }\n } catch (error) {\n console.error(\"🔥 [幕後] 崩潰:\", error);\n }\n}\n\n// ==========================================\n// ⚡ 系統總指揮部\n// ==========================================\nexport default async function (req) {\n const url = new URL(req.url);\n\n if (req.method === \"POST\") {\n const rawText = await req.text();\n\n if (url.searchParams.get(\"role\") === \"background\") {\n const params = new URLSearchParams(rawText);\n await processRequestAsync(params.get(\"From\"), params.get(\"Body\"));\n return new Response(\"Task Completed\");\n }\n\n try {\n const params = new URLSearchParams(rawText);\n const customerMessage = params.get(\"Body\") || \"\";\n if (!customerMessage) return new Response(\"OK\");\n\n fetch(req.url + \"?role=background\", {\n method: \"POST\",\n body: rawText,\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n }).catch((e) => {});\n await new Promise((resolve) => setTimeout(resolve, 50));\n\n const waitMessages = [\n \"🤖 阿喵收到！個腦極速運轉中... (請稍候幾秒⏳)\",\n \"🤖 喵～收到！等阿喵極速幫你睇睇，俾幾秒時間我！🐾\",\n \"🤖 收到主人！大數據庫掃描中，轉頭即刻覆你！⏳\",\n \"🤖 收到你嘅訊息！阿喵為你服務緊... 稍等一下！✨\",\n ];\n const randomWait =\n waitMessages[Math.floor(Math.random() * waitMessages.length)];\n\n const quickReply = `\n ${randomWait}`;\n\n return new Response(quickReply, {\n headers: { \"Content-Type\": \"text/xml\" },\n });\n } catch (error) {\n return new Response(\"OK\");\n }\n }\n return new Response(\"🤖 V4.0 終極無敵變形金剛版上線中！\");\n}","import { GoogleGenerativeAI } from \"npm:@google/generative-ai\";\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport md5 from \"npm:md5\";\n\n// ==========================================\n// 🛠️ 數據庫初始化\n// ==========================================\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS pet_customers_v2 (\n phone TEXT PRIMARY KEY,\n chat_history TEXT,\n last_seen DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n`);\n\n// ==========================================\n// 🔗 Involve Asia 聯盟引擎 (V4.0 變 Link 魔法)\n// ==========================================\nasync function getInvolveToken() {\n const apiKey = Deno.env.get(\"INVOLVE_API_KEY\");\n const apiSecret = Deno.env.get(\"INVOLVE_API_SECRET\");\n if (!apiKey || !apiSecret) {\n console.error(\"❌ 缺少 INVOLVE_API_KEY 或 SECRET\");\n return null;\n }\n\n const url = \"https://api.involve.asia/api/authenticate\";\n const payload = new URLSearchParams({\n key: apiKey,\n secret: apiSecret,\n });\n\n try {\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Accept\": \"application/json\",\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: payload,\n });\n const data = await res.json();\n if (data.status === \"success\") return data.data.token;\n console.error(\"❌ Involve 攞通行證失敗:\", data);\n return null;\n } catch (e) {\n console.error(\"❌ Involve 認證 Error:\", e);\n return null;\n }\n}\n\nasync function generateInvolveDeeplink(destinationUrl, offerId) {\n try {\n const token = await getInvolveToken();\n if (!token) return destinationUrl; // 攞唔到證，用返原 Link 頂住先\n\n const url = \"https://api.involve.asia/api/deeplink/generate\";\n const payload = new URLSearchParams({\n url: destinationUrl,\n offer_id: offerId,\n });\n\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Accept\": \"application/json\",\n \"Authorization\": \"Bearer \" + token,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: payload,\n });\n\n const data = await res.json();\n if (data.status === \"success\" && data.data && data.data.tracking_link) {\n console.log(\"✅ 成功變出發達 Link:\", data.data.tracking_link);\n return data.data.tracking_link;\n }\n console.error(\"⚠️ Deeplink 轉換失敗，使用原 Link:\", data);\n return destinationUrl;\n } catch (e) {\n console.error(\"⚠️ Involve Deeplink Error:\", e);\n return destinationUrl;\n }\n}\n\n// ==========================================\n// 🛠️ 淘寶引擎 (保留完美保底機制)\n// ==========================================\nfunction getTaobaoSign(params, secret) {\n const sortedKeys = Object.keys(params).sort();\n let signStr = secret;\n for (const key of sortedKeys) signStr += key + params[key];\n signStr += secret;\n return md5(signStr).toUpperCase();\n}\n\nasync function searchTaobao(keyword) {\n console.log(\"🚀 [幕後] 淘寶引擎啟動: 搵緊 [\" + keyword + \"]\");\n try {\n const appKey = Deno.env.get(\"TAOBAO_APP_KEY\");\n const appSecret = Deno.env.get(\"TAOBAO_APP_SECRET\");\n const adzoneId = Deno.env.get(\"TAOBAO_ADZONE_ID\");\n if (!appKey || !appSecret || !adzoneId) throw new Error(\"未設定淘寶密碼\");\n\n const tzOffset = 8 * 60 * 60 * 1000;\n const timestamp = new Date(Date.now() + tzOffset).toISOString().replace(\n \"T\",\n \" \",\n ).substring(0, 19);\n\n const params = {\n method: \"taobao.tbk.dg.material.optional.upgrade\",\n app_key: appKey,\n sign_method: \"md5\",\n timestamp: timestamp,\n format: \"json\",\n v: \"2.0\",\n adzone_id: adzoneId,\n q: keyword,\n page_no: \"1\",\n page_size: \"1\",\n };\n\n params.sign = getTaobaoSign(params, appSecret);\n const searchParams = new URLSearchParams(params);\n const url = \"https://eco.taobao.com/router/rest?\" + searchParams.toString();\n\n const controller = new AbortController();\n const timeoutId = setTimeout(() => controller.abort(), 10000);\n\n let response;\n try {\n response = await fetch(url, {\n signal: controller.signal,\n headers: { \"User-Agent\": \"Mozilla/5.0\", \"Accept\": \"application/json\" },\n });\n } catch (e) {\n throw new Error(\"淘寶 Timeout\");\n } finally {\n clearTimeout(timeoutId);\n }\n\n const data = await response.json();\n if (data.error_response) {\n throw new Error(data.error_response.sub_msg || data.error_response.msg);\n }\n\n const items = data?.tbk_dg_material_optional_upgrade_response?.result_list\n ?.map_data;\n if (items && items.length > 0) {\n // 💰 金錢雷達：喺堆貨入面，優先搵有「專屬佣金連結 (click_url)」嗰件！\n let rawItem = null;\n for (let i = 0; i < items.length; i++) {\n if (items[i].coupon_share_url || items[i].click_url) {\n rawItem = items[i];\n break; // 搵到有佣金嘅貨！即刻停手！\n }\n }\n\n // 如果真係全場都冇佣金 Link，先焗住用第一件保底\n if (!rawItem) {\n rawItem = items[0];\n }\n\n let itemTitle = rawItem.title || rawItem.item_basic_info?.title ||\n rawItem.short_title || \"熱賣寵物好物\";\n if (typeof itemTitle === \"string\") {\n itemTitle = itemTitle.replace(/<[^>]+>/g, \"\");\n }\n\n let itemPrice = rawItem.zk_final_price ||\n rawItem.price_promo_info?.zk_final_price || rawItem.reserve_price ||\n rawItem.price || 0;\n if (itemPrice == 0) itemPrice = \"49.9\";\n\n // 💰 優先攞真正可以賺錢嘅 Link！\n let itemLink = rawItem.coupon_share_url || rawItem.click_url ||\n rawItem.url || rawItem.item_url || \"\";\n let itemId = rawItem.num_iid || rawItem.item_id || rawItem.auction_id ||\n \"\";\n\n if (String(itemId).length > 15) {\n itemId = \"\";\n }\n\n if (!itemLink && itemId) {\n itemLink = \"https://item.taobao.com/item.htm?id=\" + itemId;\n } else if (!itemLink) {\n itemLink = \"https://s.taobao.com/search?q=\" +\n encodeURIComponent(itemTitle);\n } else if (itemLink && !itemLink.startsWith(\"http\")) {\n itemLink = \"https:\" +\n (itemLink.startsWith(\"//\") ? itemLink : \"//\" + itemLink);\n }\n\n let itemImg = rawItem.pict_url || rawItem.item_basic_info?.pict_url || \"\";\n if (itemImg && !itemImg.startsWith(\"http\")) {\n itemImg = \"https:\" +\n (itemImg.startsWith(\"//\") ? itemImg : \"//\" + itemImg);\n }\n\n return {\n platform: \"淘寶\",\n price: parseFloat(itemPrice) || 0,\n title: itemTitle,\n link: itemLink,\n image: itemImg,\n };\n }\n throw new Error(\"搵唔到貨\");\n } catch (error) {\n console.error(\"❌ 淘寶出錯:\", error.message);\n return {\n platform: \"淘寶(系統更新中)\",\n price: 9999,\n link: \"https://taobao.com\",\n title: \"等待淘寶開通權限...\",\n image:\n \"https://i.ibb.co/sv022x3P/Gemini-Generated-Image-9vt2379vt2379vt2.png\",\n };\n }\n}\n\n// ==========================================\n// 📲 Twilio 推播 & 老闆求救\n// ==========================================\nasync function sendWhatsAppMessage(toPhone, messageBody, mediaUrl = null) {\n const sid = Deno.env.get(\"TWILIO_ACCOUNT_SID\");\n const token = Deno.env.get(\"TWILIO_AUTH_TOKEN\");\n const fromPhone = Deno.env.get(\"TWILIO_PHONE\");\n if (!sid || !token || !fromPhone) {\n console.error(\"❌ 缺少 Twilio 環境變數！\");\n return;\n }\n\n const url = \"https://api.twilio.com/2010-04-01/Accounts/\" + sid +\n \"/Messages.json\";\n const auth = btoa(sid + \":\" + token);\n const payload = new URLSearchParams({\n From: fromPhone,\n To: toPhone,\n Body: messageBody,\n });\n if (mediaUrl) payload.append(\"MediaUrl\", mediaUrl);\n\n try {\n console.log(\n `📲 [推播] 發送畀 ${toPhone} | 內容: ${messageBody.substring(0, 20)}...`,\n );\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Authorization\": \"Basic \" + auth,\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n },\n body: payload,\n });\n if (!res.ok) {\n const errText = await res.text();\n console.error(`❌ Twilio 拒絕發送 (HTTP ${res.status}):`, errText);\n } else {\n console.log(\"✅ Twilio 發送成功!\");\n }\n } catch (error) {\n console.error(\"❌ 推播 fetch 崩潰:\", error);\n }\n}\n\nasync function callTheBoss(customerPhone, customerMessage) {\n const bossPhone = Deno.env.get(\"BOSS_PHONE\");\n if (bossPhone) {\n await sendWhatsAppMessage(\n bossPhone,\n \"🚨 【老闆出動】\\n客(\" + customerPhone + \") 遇到狀況！\\n情況：「\" +\n customerMessage + \"」\",\n );\n }\n}\n\n// ==========================================\n// ⚡ AI 核心工具\n// ==========================================\nasync function askAI(prompt, fallbackText) {\n try {\n const apiKey = Deno.env.get(\"GEMINI_API_KEY\");\n const genAI = new GoogleGenerativeAI(apiKey);\n const model = genAI.getGenerativeModel({ model: \"gemini-2.5-flash\" });\n\n const aiPromise = model.generateContent(prompt);\n const timeoutPromise = new Promise((_, r) =>\n setTimeout(() => r(new Error(\"AI_TIMEOUT\")), 30000)\n );\n const result = await Promise.race([aiPromise, timeoutPromise]);\n\n let text = result.response.text().trim();\n if (text.startsWith(\"```json\")) {\n text = text.replace(/```json/g, \"\").replace(/```/g, \"\").trim();\n }\n return text;\n } catch (e) {\n console.error(\"⚠️ AI 發生錯誤，使用 Fallback:\", e.message);\n return fallbackText;\n }\n}\n\n// ==========================================\n// 🧠 幕後黑手 (V4.0 變形金剛版)\n// ==========================================\nasync function processRequestAsync(customerPhone, customerMessage) {\n try {\n // 1️⃣ 提取過往記憶\n let chatHistory = [];\n const dbResult = await sqlite.execute({\n sql: \"SELECT chat_history FROM pet_customers_v2 WHERE phone = ?\",\n args: [customerPhone],\n });\n if (dbResult.rows && dbResult.rows.length > 0) {\n try {\n const savedHistory = dbResult.rows.chat_history;\n if (savedHistory) chatHistory = JSON.parse(savedHistory);\n } catch (e) {\n console.error(\"記憶解析失敗\", e);\n }\n }\n let historyText = chatHistory.map((m) =>\n (m.role === \"user\" ? \"客: \" : \"阿喵: \") + m.content\n ).join(\"\\n\");\n if (!historyText) historyText = \"(無過往紀錄)\";\n\n // 2️⃣ 意圖與傾偈\n const megaPrompt = `你係香港寵物用品金牌Sales「阿喵」。\n【過往對話】：\n${historyText}\n\n【最新客人輸入】: \"${customerMessage}\"\n\n請分析客人嘅意圖，並嚴格以純 JSON 格式回覆 (唔好加任何 Markdown 標籤)：\n- 情況A (搵老闆/投訴) -> {\"intent\": \"HUMAN\", \"keyword\": \"無\", \"reply\": \"交俾老闆\"}\n- 情況B (想買嘢/搵產品/問價) -> {\"intent\": \"SEARCH\", \"keyword\": \"提取最準確嘅淘寶搜尋字\", \"reply\": \"無\"}\n- 情況C (普通傾偈/答OK/問養寵物知識) -> {\"intent\": \"CHAT\", \"keyword\": \"無\", \"reply\": \"用熱情廣東話直接解答客人問題、安撫或順住話題傾偈。展現你嘅專業知識！字數控制喺100字內。\"}\n\n純 JSON 回覆：`;\n\n const aiText = await askAI(\n megaPrompt,\n '{\"intent\":\"CHAT\", \"keyword\":\"無\", \"reply\":\"🤖 喵～收到！有咩隨時搵我傾偈呀！\"}',\n );\n let intentData = {\n intent: \"CHAT\",\n keyword: \"無\",\n reply: \"🤖 喵～收到！有咩隨時搵我！\",\n };\n try {\n intentData = JSON.parse(aiText);\n } catch (e) {}\n console.log(\n `🎯 [幕後] 意圖: ${intentData.intent} | 搜尋: ${intentData.keyword}`,\n );\n\n let replyMessage = \"\";\n let imageUrl = null;\n\n // 🧭 根據意圖分流處理：\n if (intentData.intent === \"HUMAN\") {\n await callTheBoss(customerPhone, \"要求真人對話: \" + customerMessage);\n replyMessage = \"🤖 收到主人！已經幫你呼叫緊老闆，佢會即刻親自覆你！🙇‍♂️\";\n await sendWhatsAppMessage(customerPhone, replyMessage);\n } else if (intentData.intent === \"CHAT\") {\n replyMessage = intentData.reply;\n await sendWhatsAppMessage(customerPhone, replyMessage);\n } else {\n // 🛒 【買嘢模式】：去淘寶摷貨\n const taobaoResult = await searchTaobao(intentData.keyword);\n\n // 🚀🚀🚀 V4.0 終極魔法：攔截普通 Link，變做發達 Link！\n if (taobaoResult.price !== 9999 && taobaoResult.link) {\n const taobaoOfferId = Deno.env.get(\"INVOLVE_OFFER_ID_TAOBAO\");\n if (taobaoOfferId) {\n console.log(\n \"🪄 [幕後] 正在將淘寶 Link 轉換為 Involve Asia 發達 Link...\",\n );\n // 交俾 Involve Asia 變法！\n // taobaoResult.link = await generateInvolveDeeplink(\n // taobaoResult.link,\n // taobaoOfferId,\n // );\n } else {\n console.log(\n \"⚠️ 缺少 INVOLVE_OFFER_ID_TAOBAO，無法變身，使用原本淘寶 Link\",\n );\n }\n } else if (taobaoResult.price === 9999) {\n await callTheBoss(\n customerPhone,\n \"淘寶系統出錯/未開通，客想搵: \" + intentData.keyword,\n );\n }\n let priceText = (taobaoResult.price === 49.9 || taobaoResult.price === 0)\n ? \"幾十蚊起\"\n : \"大約 HK$\" + taobaoResult.price;\n\n const salesPrompt = `你係香港寵物用品金牌Sales「阿喵」。\n\n 【過往對話】:\n ${historyText}\n\n 【最新客人輸入】: \"${customerMessage}\"\n 【系統搵到大合集】: 淘寶精選「${taobaoResult.title}」 (參考價: ${priceText})\n\n 【阿喵守則】:\n 1. 保持熱情廣東話，語氣要似金牌 Sales。\n 2. 💥【格價大師模式】：同客人講，你幫佢搵咗一個「特價大合集」！入面有齊唔同舖頭、唔同款式嘅選擇！\n 3. 絕！對！唔！好！講死「只係賣幾多錢」，你要話：「參考價 ${priceText}，不過撳入去仲有好多十幾廿蚊嘅超抵平價款式任你揀！」\n 4. 叫客人即刻撳入下面條 Link 慢慢格價同尋寶！\n 回覆：`;\n replyMessage = await askAI(\n salesPrompt,\n \"🤖 搵到啦！最抵係 \" + taobaoResult.platform + \" (HK$\" +\n taobaoResult.price + \")！\",\n );\n\n if (taobaoResult.price !== 9999) {\n replyMessage += \"\\n\\n📸 睇睇實物圖片: \" + taobaoResult.image;\n replyMessage += \"\\n\\n🛒 購買連結: \" + taobaoResult.link;\n }\n\n await sendWhatsAppMessage(\n customerPhone,\n replyMessage,\n \"\", // 徹底放棄用 Twilio 派圖，保證文字 100% 殺入 WhatsApp！\n );\n }\n\n // 4️⃣ 記憶庫更新\n if (replyMessage) {\n chatHistory.push({ role: \"user\", content: customerMessage });\n chatHistory.push({\n role: \"assistant\",\n content: replyMessage.replace(/\\n\\n🛒.*/, \"\"),\n });\n if (chatHistory.length > 6) {\n chatHistory = chatHistory.slice(chatHistory.length - 6);\n }\n await sqlite.execute({\n sql:\n \"INSERT OR REPLACE INTO pet_customers_v2 (phone, chat_history, last_seen) VALUES (?, ?, CURRENT_TIMESTAMP)\",\n args: [customerPhone, JSON.stringify(chatHistory)],\n });\n }\n } catch (error) {\n console.error(\"🔥 [幕後] 崩潰:\", error);\n }\n}\n\n// ==========================================\n// ⚡ 系統總指揮部\n// ==========================================\nexport default async function (req) {\n const url = new URL(req.url);\n\n if (req.method === \"POST\") {\n const rawText = await req.text();\n\n if (url.searchParams.get(\"role\") === \"background\") {\n const params = new URLSearchParams(rawText);\n await processRequestAsync(params.get(\"From\"), params.get(\"Body\"));\n return new Response(\"Task Completed\");\n }\n\n try {\n const params = new URLSearchParams(rawText);\n const customerMessage = params.get(\"Body\") || \"\";\n if (!customerMessage) return new Response(\"OK\");\n\n fetch(req.url + \"?role=background\", {\n method: \"POST\",\n body: rawText,\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n }).catch((e) => {});\n await new Promise((resolve) => setTimeout(resolve, 50));\n\n const waitMessages = [\n \"🤖 阿喵收到！個腦極速運轉中... (請稍候幾秒⏳)\",\n \"🤖 喵～收到！等阿喵極速幫你睇睇，俾幾秒時間我！🐾\",\n \"🤖 收到主人！大數據庫掃描中，轉頭即刻覆你！⏳\",\n \"🤖 收到你嘅訊息！阿喵為你服務緊... 稍等一下！✨\",\n ];\n const randomWait =\n waitMessages[Math.floor(Math.random() * waitMessages.length)];\n\n const quickReply = `\n ${randomWait}`;\n\n return new Response(quickReply, {\n headers: { \"Content-Type\": \"text/xml\" },\n });\n } catch (error) {\n return new Response(\"OK\");\n }\n }\n return new Response(\"🤖 V4.0 終極無敵變形金剛版上線中！\");\n}","createdAt",["D",1777100286620],"branchVersion","branchId","5fadccec-3d4f-11f1-a366-42b51c65c3df","id","5fad0c3a-3d4f-11f1-a366-42b51c65c3df","whatsapp-ai",["D",1776754654207],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","3b7950e2-0e50-4165-8161-e20baea55a15","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d9f45-2c67-757f-9bfa-164b251d1b1e","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",142,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Niord","handle","displayName","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":161,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":162,"_78":163,"_80":164,"_82":25},"tree",[152,153],"files",[152,153],"counts",{"_140":60,"_141":142,"_143":142,"_144":145,"_146":147},"contents",[124,125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":133,"_32":134,"_30":135,"_127":-5,"_41":42,"_40":136,"_128":119,"_38":137,"_13":60,"_33":20,"_35":138,"_24":25,"_131":-5,"_27":139},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"1ca91f3c-4074-11f1-bce9-42b51c65c3df","parentId","latest",["D",1777100286620],77,"label",[28],"2f8074f6-3d55-11f1-9833-42b51c65c3df","README.md","2f8075f0-3d55-11f1-9833-42b51c65c3df",5,["D",1776757150355],"# whatsapp-ai",[134],"pulls","branches",1,"forks","envVars",{"_148":150,"_151":60},"connections",{"_148":60,"_149":60},"count","unfilledCount",15,"emptyCount",{"_43":133,"_32":134,"_30":135,"_127":-5,"_41":42,"_40":136,"_128":119,"_38":158,"_13":60,"_33":20,"_35":138,"_24":25,"_131":-5,"_155":159,"_27":160},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":154,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_155":156,"_27":157},["D",1777100286620],"children",[],[28],["D",1776757150355],[],[134],["D",1776754654207],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_121":198,"_199":200,"_201":202,"_203":25,"_204":25,"_205":25,"_206":119,"_207":-5,"_208":-7,"_209":-7,"_210":60,"_211":25,"_212":25,"_213":-5,"_214":25,"_215":25,"_216":25,"_217":-5},"ENV",{"_169":170,"_171":172,"_173":84,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v79