Franchise CRM Dashboard

\n \n

Loading CRM...

\n\n\n`;\n}\n\n// --- API ENDPOINTS & MAIN HANDLER ---\nexport default async function(req: Request) {\n const url = new URL(req.url);\n const action = url.searchParams.get(\"action\");\n const openai = new OpenAI({ apiKey: Deno.env.get(\"OPENAI_API_KEY\") });\n await initializeDatabase();\n try {\n if (req.method === \"GET\") {\n switch (action) {\n case \"getFranchiseData\": {\n const franchiseId = url.searchParams.get(\"franchiseId\");\n if (!franchiseId)\n return new Response(JSON.stringify({ error: \"Franchise ID is required.\" }), { status: 400 });\n const { rows: franchise } = await sqlite.execute({\n sql: \"SELECT * FROM franchises WHERE id = ?\",\n args: [franchiseId],\n row_mode: \"object\",\n });\n if (franchise.length === 0)\n return new Response(JSON.stringify({ error: `Franchise not found.` }), { status: 404 });\n const { rows: customers } = await sqlite.execute({\n sql: \"SELECT * FROM customers WHERE franchise_id = ? ORDER BY name\",\n args: [franchiseId],\n row_mode: \"object\",\n });\n return new Response(JSON.stringify({ franchise: franchise[0], customers }));\n }\n default:\n return new Response(generateHtml(req.url), { headers: { \"Content-Type\": \"text/html\" } });\n }\n }\n if (req.method === \"POST\") {\n const body = await req.json().catch(() => ({}));\n const { franchiseId } = body;\n if (!franchiseId && action !== \"seedDatabase\")\n return new Response(JSON.stringify({ error: \"Franchise ID is required.\" }), { status: 400 });\n switch (action) {\n case \"seedDatabase\":\n await seedDatabase(openai);\n return new Response(JSON.stringify({ success: true }));\n case \"ingestInteraction\": {\n const { customerData, transactionData } = body;\n const { rows } = await sqlite.execute({\n sql: \"SELECT id FROM customers WHERE franchise_id = ? AND pos_customer_id = ?\",\n args: [franchiseId, customerData.posId],\n row_mode: \"object\",\n });\n let customerId = rows[0]?.id;\n if (!customerId) {\n const { lastInsertRowid } = await sqlite.execute({\n sql: \"INSERT INTO customers (franchise_id, pos_customer_id, name, email) VALUES (?, ?, ?, ?)\",\n args: [franchiseId, customerData.posId, customerData.name, customerData.email],\n });\n customerId = lastInsertRowid;\n }\n await sqlite.execute({\n sql:\n \"INSERT INTO transactions (customer_id, transaction_date, total_amount, items_purchased, channel) VALUES (?, ?, ?, ?, ?)\",\n args: [\n customerId,\n transactionData.date,\n transactionData.total,\n JSON.stringify(transactionData.items),\n transactionData.channel,\n ],\n });\n await updateCustomerAiProfile(customerId, openai);\n return new Response(JSON.stringify({ success: true, customerId }));\n }\n case \"runSegmentation\": {\n const { rows } = await sqlite.execute({\n sql:\n \"SELECT id, name, (SELECT GROUP_CONCAT(items_purchased, '; ') FROM transactions WHERE customer_id = c.id) as history FROM customers c WHERE c.franchise_id = ?\",\n args: [franchiseId],\n row_mode: \"object\",\n });\n if (rows.length === 0) return new Response(JSON.stringify({ success: true, segments: [] }));\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [{ role: \"system\", content: ADVANCED_SEGMENTATION_PROMPT }, {\n role: \"user\",\n content: JSON.stringify(rows),\n }],\n response_format: { type: \"json_object\" },\n });\n const { segments, assignments } = extractJson(completion.choices[0].message.content);\n const batch = [{ sql: \"DELETE FROM segments WHERE franchise_id = ?\", args: [franchiseId] }];\n for (const s of segments) {\n batch.push({\n sql: \"INSERT INTO segments (franchise_id, name, description, criteria) VALUES (?, ?, ?, ?)\",\n args: [franchiseId, s.name, s.description, s.identifying_criteria],\n });\n }\n for (const a of assignments) {\n if (a.customerId && a.segmentName) {\n batch.push({\n sql: \"UPDATE customers SET ai_segment_name = ? WHERE id = ?\",\n args: [a.segmentName, a.customerId],\n });\n }\n }\n await sqlite.batch(batch);\n return new Response(JSON.stringify({ success: true, segments }));\n }\n }\n }\n return new Response(\"Not Found\", { status: 404 });\n } catch (error) {\n console.error(\"Handler Error:\", error);\n return new Response(JSON.stringify({ error: error.message }), { status: 500 });\n }\n}","deleted","label",[98],"permalink","https://www.val.town/x/join/crm/code/main.tsx","extension","actionData","errors"]