Next.js Server Actions + Prisma Transaction: ทำ Mutation ให้ Atomic

// แบบผิด: ถ้าบรรทัดที่ 3 โยน error จะได้ order เปล่าที่ไม่มี lines
const order = await prisma.order.create({ data: { shopId, total } });
for (const line of lines) {
  await prisma.orderLine.create({ data: { orderId: order.id, ...line } });
}
await prisma.stock.update({ where: { id: stockId }, data: { qty: { decrement: 1 } } });

'use server';

import { z } from 'zod';
import { auth } from '@/server/auth';
import { prisma } from '@/server/db';

const lineSchema = z.object({
  productId: z.string().min(1),
  qty: z.number().int().positive().max(999),
});

const createOrderSchema = z.object({
  shopId: z.string().min(1),
  lines: z.array(lineSchema).min(1).max(50),
});

export async function createOrder(input: unknown) {
  const session = await auth();
  if (!session?.user) return { ok: false, error: 'กรุณาเข้าสู่ระบบ' };

  const parsed = createOrderSchema.safeParse(input);
  if (!parsed.success) return { ok: false, error: 'ข้อมูลไม่ถูกต้อง' };

  const { shopId, lines } = parsed.data;

  // ด่าน authorization: user ต้องเป็นสมาชิกของ shop นี้
  const membership = await prisma.shopMember.findUnique({
    where: { shopId_userId: { shopId, userId: session.user.id } },
  });
  if (!membership) return { ok: false, error: 'ไม่พบข้อมูล' };

  try {
    const order = await prisma.$transaction(async (tx) => {
      // อ่านและเช็กสิทธิ์ซ้ำ *ใน* transaction กันข้อมูลเปลี่ยนระหว่างทาง
      const shop = await tx.shop.findUnique({ where: { id: shopId } });
      if (!shop) throw new Error('SHOP_NOT_FOUND');

      const created = await tx.order.create({
        data: { shopId, createdById: session.user.id, total: 0 },
      });

      let total = 0;
      for (const line of lines) {
        const product = await tx.product.findUnique({
          where: { id: line.productId },
        });
        if (!product || product.shopId !== shopId) throw new Error('BAD_PRODUCT');
        await tx.orderLine.create({
          data: {
            orderId: created.id,
            productId: product.id,
            qty: line.qty,
            price: product.price,
          },
        });
        total += product.price * line.qty;
      }

      return tx.order.update({
        where: { id: created.id },
        data: { total },
      });
    });

    return { ok: true, orderId: order.id };
  } catch {
    console.error('createOrder failed', { shopId });
    return { ok: false, error: 'เกิดข้อผิดพลาด กรุณาลองใหม่' };
  }
}

// แบบ array: เร็ว เหมาะกับ write อิสระที่ไม่ต้องอ่านผลขั้นกลาง
await prisma.$transaction([
  prisma.order.update({ where: { id }, data: { total } }),
  prisma.auditLog.create({ data: { orderId: id, action: 'CONFIRMED' } }),
]);