import { pool } from '../db'; import { sendMail } from '../email'; const thb = (n: number) => `฿${n.toLocaleString('th-TH', { minimumFractionDigits: 2 })}`; const thaiMonth = (date: Date) => date.toLocaleDateString('th-TH', { month: 'long', year: 'numeric' }); // ── Query ───────────────────────────────────────────────────────────────────── interface MachineRow { machine_id: string; serial_number: string; color: string | null; cash_total: string; promptpay_total: string; grand_total: string; tx_count: string; } interface CustomerRow { id: string; name: string; email: string; phone: string; } async function getMonthlyData(year: number, month: number) { // month is 1-based const from = `${year}-${String(month).padStart(2, '0')}-01`; const to = new Date(year, month, 0).toISOString().slice(0, 10); // last day const customers = await pool.query( `SELECT id, name, email, phone FROM simo_customers WHERE email IS NOT NULL AND email != '' ORDER BY name`, ); const results = []; for (const c of customers.rows) { const machines = await pool.query( `SELECT m.id AS machine_id, m.serial_number, m.color, COALESCE(SUM(ap.coin), 0)::float AS cash_total, COALESCE(SUM(ap.pay_by_wechat + ap.pay_by_rabbit_line_pay + ap.pay_by_promptpay + ap.pay_by_truemoney + ap.pay_by_point), 0)::float AS promptpay_total, COALESCE(SUM(ap.coin + ap.pay_by_wechat + ap.pay_by_rabbit_line_pay + ap.pay_by_promptpay + ap.pay_by_truemoney + ap.pay_by_point), 0)::float AS grand_total, COUNT(ap.id)::int AS tx_count FROM simo_machines m LEFT JOIN amount_payment ap ON ap.serial_no = m.serial_number AND ap.time1 >= m.purchase_date AND ap.time1 BETWEEN $1 AND $2::date + INTERVAL '1 day' WHERE m.customer_id = $3 GROUP BY m.id, m.serial_number, m.color ORDER BY m.serial_number`, [from, to, c.id], ); const totalRevenue = machines.rows.reduce((s, m) => s + Number(m.grand_total), 0); results.push({ customer: c, machines: machines.rows, totalRevenue, from, to }); } return results; } // ── Email HTML Template ─────────────────────────────────────────────────────── function buildHtml( customer: CustomerRow, machines: MachineRow[], totalRevenue: number, monthLabel: string, ) { const machineRows = machines.map((m, i) => { const cash = Number(m.cash_total); const promptpay = Number(m.promptpay_total); const total = Number(m.grand_total); const txCount = Number(m.tx_count); return ` เครื่องที่ ${i + 1}
${m.serial_number} ${m.color ? `(${m.color})` : ''} ${txCount} รายการ ${thb(cash)} ${thb(promptpay)} ${thb(total)} `; }).join(''); const totalTx = machines.reduce((s, m) => s + Number(m.tx_count), 0); return `

SIMO 1

สรุปยอดรายรับประจำเดือน

${monthLabel}

เรียน คุณ${customer.name}

ขอนำส่งสรุปยอดรายรับสาขาของท่านประจำเดือน${monthLabel} โดยมีรายละเอียดดังต่อไปนี้

ยอดรายรับรวมทั้งหมด

${thb(totalRevenue)}

${totalTx} รายการ · ${machines.length} เครื่อง

รายละเอียดแยกตามเครื่อง

${machineRows}

เครื่อง	รายการ	เงินสด	พร้อมเพย์	รวม
รวมทั้งสิ้น		${thb(machines.reduce((s, m) => s + Number(m.cash_total), 0))}	${thb(machines.reduce((s, m) => s + Number(m.promptpay_total), 0))}	${thb(totalRevenue)}

หากพบข้อมูลไม่ถูกต้อง กรุณาติดต่อเจ้าหน้าที่เพื่อตรวจสอบ

© 2026 SIMO 1 Massage Chair System · อีเมลนี้ถูกส่งโดยอัตโนมัติ กรุณาอย่าตอบกลับ

`; } // ── Main export ─────────────────────────────────────────────────────────────── export async function sendMonthlyReports(year: number, month: number) { const data = await getMonthlyData(year, month); const date = new Date(year, month - 1, 1); const label = thaiMonth(date); const subject = `SIMO 1 — สรุปยอดรายรับ ${label}`; let sent = 0; let skipped = 0; const errors: string[] = []; for (const { customer, machines, totalRevenue } of data) { if (machines.length === 0) { skipped++; continue; } try { const html = buildHtml(customer, machines, totalRevenue, label); await sendMail(customer.email, subject, html); sent++; console.log(`✅ ส่งให้ ${customer.name} (${customer.email})`); } catch (e) { errors.push(`${customer.email}: ${String(e)}`); console.error(`❌ ส่งไม่สำเร็จ ${customer.email}:`, e); } } return { sent, skipped, errors, total: data.length }; }