Merge pull request 'feat: add printer types' (#40) from fix/point-payment-method-types into main

Reviewed-on: #40

Dockerfile

@@ -15,6 +15,6 @@ COPY --from=build /out/app /app
 ENV TZ=Asia/Jakarta
 EXPOSE 4000
 HEALTHCHECK --interval=30s --timeout=10s --start-period=30s --retries=3 \
-  CMD curl -fsS http://localhost:3300/health || exit 1
+  CMD curl -fsS http://localhost:4000/health || exit 1
 USER appuser
 ENTRYPOINT ["/app"]

deployment.sh

@@ -1,62 +1,177 @@
 #!/bin/bash
 set -euo pipefail
 
+# Usage:
+#   ./deployment.sh staging                 deploy staging (branch staging, port 4001)
+#   ./deployment.sh production              deploy production (branch main, port 4000)
+#   ./deployment.sh production --rollback   kembali ke image sebelum deploy terakhir
+#   Tambahkan --yes untuk melewati konfirmasi production.
+
 APP_NAME="apskel-pos"
+LEGACY_CONTAINER="apskel-pos" # nama lama sebelum nama container memakai environment
 
-# ─── Deteksi environment dari branch aktif ───────────────────────────────────
-CURRENT_BRANCH=$(git rev-parse --abbrev-ref HEAD)
+usage() {
+  echo "Usage: $0 <staging|production> [--rollback] [--yes]"
+  exit 1
+}
 
-case "$CURRENT_BRANCH" in
-  main)
-    ENV_MODE="production"
+fail() {
+  echo "❌ $*"
+  exit 1
+}
+
+# ─── Argumen ──────────────────────────────────────────────────────────────────
+ENV_MODE="${1:-}"
+shift || true
+
+ROLLBACK=false
+ASSUME_YES=false
+for arg in "$@"; do
+  case "$arg" in
+    --rollback) ROLLBACK=true ;;
+    --yes|-y)   ASSUME_YES=true ;;
+    *)          usage ;;
+  esac
+done
+
+# Environment wajib disebut eksplisit, tidak lagi ditebak dari branch aktif
+case "$ENV_MODE" in
+  production)
+    EXPECTED_BRANCH="main"
     PORT="4000"
     ;;
   staging)
-    ENV_MODE="staging"
+    EXPECTED_BRANCH="staging"
     PORT="4001"
     ;;
   *)
-    echo "❌ Branch '$CURRENT_BRANCH' tidak dikenali untuk deployment."
-    echo "   Gunakan branch 'main' (production) atau 'staging' (staging)."
-    exit 1
+    usage
     ;;
 esac
 
-CONTAINER_NAME="$APP_NAME"
+CONTAINER_NAME="$APP_NAME-$ENV_MODE"
 IMAGE_NAME="$APP_NAME:$ENV_MODE"
+PREVIOUS_IMAGE="$APP_NAME:$ENV_MODE-previous"
+CONFIG_FILE="infra/$ENV_MODE.yaml"
+
+# ─── Validasi repo ────────────────────────────────────────────────────────────
+CURRENT_BRANCH=$(git rev-parse --abbrev-ref HEAD)
+
+if [ "$CURRENT_BRANCH" = "HEAD" ]; then
+  fail "Repo sedang detached HEAD. Jalankan 'git checkout $EXPECTED_BRANCH' dulu."
+fi
+
+if [ "$CURRENT_BRANCH" != "$EXPECTED_BRANCH" ]; then
+  fail "Deploy $ENV_MODE harus dari branch '$EXPECTED_BRANCH', folder ini di branch '$CURRENT_BRANCH'.
+   Pakai folder terpisah per environment, jangan pindah branch di folder yang sedang dipakai container lain."
+fi
+
+if [ -n "$(git status --porcelain --untracked-files=no)" ]; then
+  fail "Ada perubahan yang belum di-commit di folder ini. Bersihkan dulu sebelum deploy."
+fi
+
+[ -f "$CONFIG_FILE" ] || fail "Config file '$CONFIG_FILE' tidak ditemukan."
+
+# ─── Pastikan port tidak dipakai container environment lain ──────────────────
+OTHER_ON_PORT=$(docker ps --filter "publish=$PORT" --format '{{.Names}}' \
+  | grep -vx "$CONTAINER_NAME" \
+  | { if [ "$ENV_MODE" = "production" ]; then grep -vx "$LEGACY_CONTAINER"; else cat; fi; } \
+  || true)
+if [ -n "$OTHER_ON_PORT" ]; then
+  fail "Port $PORT sedang dipakai container lain: $OTHER_ON_PORT"
+fi
 
 echo "📦 Environment : $ENV_MODE"
 echo "🌿 Branch      : $CURRENT_BRANCH"
 echo "🐳 Container   : $CONTAINER_NAME"
 echo "🔌 Port        : $PORT"
+echo "📁 Folder      : $(pwd)"
+[ "$ROLLBACK" = true ] && echo "⏪ Mode        : ROLLBACK ke $PREVIOUS_IMAGE"
 echo ""
 
-# ─── Pastikan config file ada ─────────────────────────────────────────────────
-CONFIG_FILE="infra/$ENV_MODE.yaml"
-if [ ! -f "$CONFIG_FILE" ]; then
-  echo "❌ Config file '$CONFIG_FILE' tidak ditemukan."
-  exit 1
+# ─── Konfirmasi production ────────────────────────────────────────────────────
+if [ "$ENV_MODE" = "production" ] && [ "$ASSUME_YES" != true ]; then
+  read -r -p "⚠️  Ini PRODUCTION. Ketik 'production' untuk lanjut: " CONFIRM
+  [ "$CONFIRM" = "production" ] || fail "Dibatalkan."
 fi
 
-echo "🔄 Pulling latest code..."
-git pull
+run_container() {
+  local image="$1"
+
+  echo "🛑 Stopping and removing old container..."
+  docker rm -f "$CONTAINER_NAME" 2>/dev/null || true
+  # Container production lama masih bernama 'apskel-pos'; staging tidak boleh menyentuhnya
+  if [ "$ENV_MODE" = "production" ]; then
+    docker rm -f "$LEGACY_CONTAINER" 2>/dev/null || true
+  fi
+
+  echo "🚀 Running container from $image..."
+  docker run -d --name "$CONTAINER_NAME" \
+    --restart unless-stopped \
+    -p "$PORT:4000" \
+    -e TZ=Asia/Jakarta \
+    -e ENV_MODE="$ENV_MODE" \
+    -v "$(pwd)/infra":/infra:ro \
+    -v "$(pwd)/templates":/templates:ro \
+    "$image" >/dev/null
+}
+
+wait_healthy() {
+  echo "🩺 Waiting for healthcheck..."
+  for _ in $(seq 1 36); do
+    local status
+    status=$(docker inspect -f '{{if .State.Health}}{{.State.Health.Status}}{{else}}{{.State.Status}}{{end}}' "$CONTAINER_NAME" 2>/dev/null || echo "missing")
+    case "$status" in
+      healthy)             return 0 ;;
+      unhealthy|exited|dead|missing) return 1 ;;
+    esac
+    sleep 5
+  done
+  return 1
+}
+
+# ─── Rollback ─────────────────────────────────────────────────────────────────
+if [ "$ROLLBACK" = true ]; then
+  docker image inspect "$PREVIOUS_IMAGE" >/dev/null 2>&1 || fail "Image '$PREVIOUS_IMAGE' tidak ada, tidak bisa rollback."
+  run_container "$PREVIOUS_IMAGE"
+  wait_healthy || fail "Container hasil rollback tidak healthy. Cek: docker logs $CONTAINER_NAME"
+  docker tag "$PREVIOUS_IMAGE" "$IMAGE_NAME"
+  echo "✅ Rollback $ENV_MODE complete."
+  exit 0
+fi
+
+# ─── Deploy ───────────────────────────────────────────────────────────────────
+echo "🔄 Pulling latest code (origin/$EXPECTED_BRANCH)..."
+git fetch origin "$EXPECTED_BRANCH"
+git merge --ff-only "origin/$EXPECTED_BRANCH"
+echo "   Commit: $(git log -1 --format='%h %s')"
+
+# Simpan image yang sedang jalan untuk rollback
+if docker image inspect "$IMAGE_NAME" >/dev/null 2>&1; then
+  docker tag "$IMAGE_NAME" "$PREVIOUS_IMAGE"
+fi
 
 echo "🐳 Building Docker image ($ENV_MODE)..."
 docker build --target production -t "$IMAGE_NAME" .
 
-echo "🛑 Stopping and removing old container..."
-docker rm -f "$CONTAINER_NAME" 2>/dev/null || true
+run_container "$IMAGE_NAME"
 
-echo "🚀 Running new container..."
-docker run -d --name "$CONTAINER_NAME" \
-  -p "$PORT:4000" \
-  -e TZ=Asia/Jakarta \
-  -e ENV_MODE="$ENV_MODE" \
-  -v "$(pwd)/infra":/infra:ro \
-  -v "$(pwd)/templates":/templates:ro \
-  "$IMAGE_NAME"
+if ! wait_healthy; then
+  echo "❌ Container baru tidak healthy. Log terakhir:"
+  docker logs --tail 50 "$CONTAINER_NAME" || true
+  if docker image inspect "$PREVIOUS_IMAGE" >/dev/null 2>&1; then
+    echo "⏪ Rolling back ke $PREVIOUS_IMAGE..."
+    run_container "$PREVIOUS_IMAGE"
+    wait_healthy || fail "Rollback juga tidak healthy. Cek manual: docker logs $CONTAINER_NAME"
+    # Jangan biarkan image rusak jadi 'previous' di deploy berikutnya
+    docker tag "$PREVIOUS_IMAGE" "$IMAGE_NAME"
+    fail "Deploy gagal, $ENV_MODE sudah dikembalikan ke image sebelumnya."
+  fi
+  fail "Deploy gagal dan tidak ada image sebelumnya untuk rollback."
+fi
 
 echo ""
 echo "✅ Deployment $ENV_MODE complete."
 echo "   Container : $CONTAINER_NAME"
 echo "   Port      : $PORT"
+echo "   Rollback  : $0 $ENV_MODE --rollback"

docs/api-enakpoint.md

@@ -41,6 +41,11 @@ Semua endpoint EnakPoint (`POINT`, bisa bayar order) dan EnakCoin (`COIN`, untuk
 | GET | `/customer/wallet/expiring` | Saldo yang akan kedaluwarsa, per currency dan tanggal |
 | PUT | `/customer/devices` | Daftarkan token FCM device |
 | DELETE | `/customer/devices/:device_id` | Hapus device saat logout |
+| GET | `/customer/outlets` | Outlet aktif di organisasi customer, dengan `accepts_point_payment`, `earns_points`, `earns_coins` |
+| GET | `/customer/orders` | Riwayat order customer (`page`, `limit`), dengan `points_earned` / `coins_earned` |
+| GET | `/customer/orders/:id` | Detail order: item, pembayaran, EnakPoint yang dipakai; order customer lain → `404` |
+
+Registrasi (`POST /customer-auth/register/start`) menerima `organization_id` opsional: bila tidak dikirim dan hanya ada satu organisasi, customer masuk ke organisasi itu. Contoh request dan response lengkap untuk outlet dan order ada di [`mobile-customer-enakpoint.md`](./mobile-customer-enakpoint.md) §4.4–§4.5.
 
 ### GET /customer/wallet
 
@@ -426,14 +431,11 @@ Semua nilai `data` berupa string. Push hanya sampai ke device yang terdaftar lew
 
 ### Endpoint dan field deprecated
 
-Masih jalan dan membaca wallet, tapi akan dihapus setelah semua versi aplikasi pindah.
+Masih jalan dan membaca wallet, tapi akan dihapus setelah semua versi aplikasi pindah. Semua yang bernama token (`/customer/tokens`, `total_tokens`, `tokens_history`, `token_used`, `tokens_remaining`, campaign `TOKENS`) sudah dihapus; pakai `coin_balance`, `coins_used`, `coins_remaining`, dan `COINS`.
 
 | Lama | Pengganti |
 | --- | --- |
 | `GET /customer/points` | `GET /customer/wallet` → `point_balance` |
-| `GET /customer/tokens` | `GET /customer/wallet` → `coin_balance` |
-| `total_points`, `total_tokens`, `points_history`, `tokens_history`, `last_updated` di `/customer/wallet` | `point_balance`, `coin_balance`, `recent_transactions` |
-| `token_used`, `tokens_remaining` di response game | `coins_used`, `coins_remaining` |
-| `sort_by=token_used` di daftar game play | `sort_by=coins_used` |
+| `total_points`, `points_history`, `last_updated` di `/customer/wallet` | `point_balance`, `recent_transactions` |
 
 Panduan alur lengkap per tim ada di [`integration-enakpoint.md`](./integration-enakpoint.md).

docs/integration-enakpoint.md

@@ -474,16 +474,14 @@ Response:
 
 ```json
 {
-  "game_play": { "id": "…", "game_id": "…", "coins_used": 1, "token_used": 1, "created_at": "…" },
+  "game_play": { "id": "…", "game_id": "…", "coins_used": 1, "created_at": "…" },
   "prize_won": { "id": "…", "name": "Voucher 10rb", … },
-  "coins_remaining": 7,
-  "tokens_remaining": 7
+  "coins_remaining": 7
 }
 ```
 
 EnakCoin kurang, game nonaktif, atau hadiah baru saja habis dijawab `304`; tidak ada
-EnakCoin yang terpotong. Baca `coins_used` dan `coins_remaining`; `token_used` dan
-`tokens_remaining` hanya salinan untuk versi aplikasi lama.
+EnakCoin yang terpotong.
 
 Di dashboard, `metadata.coin_cost` diisi per game dengan bilangan bulat ≥ 1.
 
@@ -497,13 +495,14 @@ pindah. Aplikasi baru jangan memakainya.
 | Lama | Ganti dengan |
 |---|---|
 | `GET /customer/points` | `GET /customer/wallet` (`point_balance`) |
-| `GET /customer/tokens` | `GET /customer/wallet` (`coin_balance`) |
-| `total_points`, `total_tokens`, `points_history`, `tokens_history`, `last_updated` di `/customer/wallet` | `point_balance`, `coin_balance`, `recent_transactions` |
-| `token_used`, `tokens_remaining` di respons game | `coins_used`, `coins_remaining` |
-| `sort_by=token_used` di daftar game play | `sort_by=coins_used` |
+| `total_points`, `points_history`, `last_updated` di `/customer/wallet` | `point_balance`, `recent_transactions` |
 
 Beri tahu tim backend setelah aplikasi yang beredar tidak lagi memakai kolom kiri,
-supaya alias dan tabel lama (`customer_points`, `customer_tokens`) bisa dihapus.
+supaya alias ini bisa dihapus.
+
+Semua yang bernama token sudah dihapus: `GET /customer/tokens`, `total_tokens`,
+`tokens_history`, `token_used`, `tokens_remaining`, dan nilai `TOKENS` di campaign. Pakai
+`coin_balance`, `coins_used`, `coins_remaining`, dan `COINS`.
 
 ---
 

docs/migrasi-printer-types.md

@@ -0,0 +1,143 @@
+# Migrasi printer_type ke printer_types
+
+1 Oktober 2026
+
+## Ringkasan
+
+`printer_type` (string) dihapus dan diganti `printer_types` (array string), sehingga satu produk bisa dicetak ke lebih dari satu printer. Contohnya "Paket Makan Minum" dengan `["kitchen", "bar"]` tercetak di kitchen dan bar sekaligus.
+
+Ini breaking change. Setelah backend baru dirilis, client yang masih membaca `printer_type` tidak menerima printer apa pun. Karena itu app POS dan dashboard harus diupdate lebih dulu, lihat [Urutan rilis](#database-dan-urutan-rilis).
+
+Yang perlu bertindak:
+
+- **App POS**: baca `printer_types` dan cetak tiap item ke semua printer di dalamnya.
+- **Dashboard admin**: ganti pilihan printer di form produk jadi multi-select yang mengirim `printer_types`.
+
+## Perubahan response
+
+`printer_type` hilang dari semua response dan digantikan `printer_types`, yang nilainya selalu array dan tidak pernah `null`.
+
+| Endpoint | Letak field |
+| --- | --- |
+| `POST /api/v1/products`, `PUT /api/v1/products/:id`, `GET /api/v1/products`, `GET /api/v1/products/all`, `GET /api/v1/products/:id` | objek produk |
+| `POST /api/v1/orders`, `GET /api/v1/orders`, `GET /api/v1/orders/:id`, `PUT /api/v1/orders/:id` | `order_items[]` |
+| `POST /api/v1/orders/:id/add-items` | `added_items[]` dan `updated_order.order_items[]` |
+| `POST /api/v1/self-order/orders`, `GET /api/v1/self-order/orders/:session_id` | `order_items[]` |
+| `/api/v1/product-recipes` (semua yang mengembalikan recipe) | `product` |
+| `/api/v1/inventory` | `product`, selalu `[]` karena produk di sini hanya berisi id dan nama |
+
+Contoh satu item di `order_items[]`:
+
+```json
+{
+  "product_name": "Paket Makan Minum",
+  "printer_types": ["kitchen", "bar"],
+  "print_to_checker": true
+}
+```
+
+Aturan nilainya:
+
+- `printer_types: []` artinya produk tidak dicetak ke printer mana pun.
+- Urutan printer sesuai yang disimpan admin, tanpa duplikat.
+- Void, refund, payment, split bill, dan set customer tidak membawa data printer, sama seperti sebelumnya.
+
+## Perubahan request produk
+
+`POST /api/v1/products` dan `PUT /api/v1/products/:id` menerima `printer_types` sebagai pengganti `printer_type`. Kalau `printer_type` masih dikirim, field itu diabaikan tanpa error.
+
+```json
+{
+  "name": "Paket Makan Minum",
+  "category_id": "<uuid>",
+  "price": 25000,
+  "printer_types": ["kitchen", "bar"]
+}
+```
+
+| Request | `printer_types` yang dikirim | Hasil |
+| --- | --- | --- |
+| Create | tidak dikirim | `["kitchen"]` |
+| Create | `["kitchen", "bar"]` | `["kitchen", "bar"]` |
+| Create | `[]` atau hanya string kosong | `["kitchen"]` |
+| Update | tidak dikirim | tidak berubah |
+| Update | `["bar"]` | `["bar"]`, seluruh daftar diganti |
+| Update | `[]` | `[]`, produk tidak dicetak ke mana pun |
+
+Sebelum disimpan, spasi di awal dan akhir tiap entri dibuang, lalu entri kosong dan duplikat dihapus. Urutan dipertahankan.
+
+Tiap entri maksimal 50 karakter. Kalau lebih, request ditolak dengan error code `310` dan pesan `each printer_types entry cannot exceed 50 characters`.
+
+## Migrasi app POS
+
+App POS harus mengirim tiap item ke semua printer di `printer_types`, sehingga satu item bisa muncul di lebih dari satu tiket.
+
+1. Ganti `printer_type` dengan `printer_types` (list string) di model order item dan produk.
+2. Selama backend lama masih jalan, `printer_types` belum ada di response. Pakai `[printer_type]` kalau `printer_types` tidak ada, supaya app baru bisa dirilis sebelum backend.
+3. Saat mencetak, kelompokkan item per printer dengan mengulang setiap entri `printer_types` milik item.
+4. Item dengan `printer_types: []` tidak dicetak ke printer station mana pun.
+5. `print_to_checker` tidak berubah dan tetap diperlakukan terpisah.
+6. Untuk tambahan pesanan dari `POST /api/v1/orders/:id/add-items`, cetak dari `added_items[]`.
+
+```text
+tiket = {}
+untuk setiap item di order_items:
+    printers = item.printer_types ?? [item.printer_type]   // fallback hanya untuk backend lama
+    untuk setiap printer di printers:
+        tiket[printer].tambah(item)
+untuk setiap (printer, items) di tiket:
+    cetak items ke printer
+```
+
+Perbaikan di `added_items[]`: sebelumnya field ini selalu berisi `product_name` dan printer kosong, serta `print_to_checker: true`. Sekarang isinya lengkap seperti item di `updated_order.order_items[]`, dengan urutan sesuai request. Kalau app selama ini mengakali dengan mencari item baru di `updated_order`, cara itu bisa diganti dengan `added_items[]` langsung.
+
+## Migrasi dashboard
+
+Form produk di dashboard harus memakai multi-select printer dan selalu mengirim daftar lengkapnya lewat `printer_types`.
+
+1. Ganti dropdown printer tunggal dengan multi-select, misalnya checkbox, berisi pilihan printer yang sama.
+2. Saat membuka form edit, isi pilihan dari `printer_types`. Selama backend lama masih jalan, pakai `[printer_type]` kalau `printer_types` tidak ada.
+3. Saat menyimpan, kirim `printer_types` berisi semua printer yang dipilih.
+4. Selama backend lama masih jalan, kirim juga `printer_type` berisi printer pertama. Backend lama hanya membaca `printer_type`, dan backend baru mengabaikannya.
+5. Di daftar produk, tampilkan semua printer dari `printer_types`.
+
+Backend tidak membatasi nilai printer. Nilainya harus sama persis dengan nama printer yang dikenal app POS, termasuk huruf besar dan kecilnya.
+
+Create dengan `printer_types: []` tetap menghasilkan `["kitchen"]`. Produk tanpa printer dibuat dulu, lalu di-update dengan `printer_types: []`.
+
+## Database dan urutan rilis
+
+Migration `000099_add_printer_types_to_products` menambah kolom `products.printer_types` (JSONB, `NOT NULL`, default `["kitchen"]`), mengisinya dari `printer_type`, lalu menghapus kolom `printer_type` beserta index-nya.
+
+- Produk dengan `printer_type` berisi nilai menjadi `[printer_type]`.
+- Produk dengan `printer_type` `NULL` atau kosong menjadi `[]`.
+
+Urutan rilis:
+
+1. Rilis app POS baru, yang membaca `printer_types` dengan fallback ke `printer_type`, ke semua outlet.
+2. Rilis dashboard baru, yang mengirim `printer_types` dan `printer_type`.
+3. Jalankan migration `000099` tepat sebelum deploy backend baru. Di antara keduanya, backend lama gagal menyimpan produk karena kolom `printer_type` sudah tidak ada.
+4. Setelah backend baru jalan, dashboard boleh berhenti mengirim `printer_type`, dan fallback di app POS boleh dihapus.
+5. Atur produk multi-printer, misalnya "Paket Makan Minum" ke `["kitchen", "bar"]`.
+
+Outlet yang masih memakai app POS lama setelah langkah 3 tidak menerima printer untuk semua item. Pastikan langkah 1 sudah selesai di semua outlet.
+
+Rollback: jalankan down migration dan deploy backend lama bersamaan. Down migration membuat ulang kolom `printer_type` berisi printer pertama, lalu menghapus `printer_types`, jadi yang hilang hanya printer tambahan.
+
+## Checklist
+
+- [ ] App POS baru (dengan fallback) terpasang di semua outlet
+- [ ] Dashboard baru mengirim `printer_types` dan `printer_type`
+- [ ] Migration `000099` dan backend baru dirilis di staging
+- [ ] Uji "Paket Makan Minum" dengan `["kitchen", "bar"]` tercetak di dua printer, saat order baru dan saat tambah pesanan
+- [ ] Migration `000099` dan backend baru dirilis di production
+- [ ] Dashboard berhenti mengirim `printer_type`
+- [ ] Fallback `printer_type` di app POS dihapus
+
+## FAQ
+
+**Kenapa `printer_type` dihapus, bukan dipertahankan?** Supaya hanya ada satu sumber data printer. Dua field yang menyimpan hal yang sama bisa saling berbeda.
+
+**Apakah kitchen dan bar menerima tiket yang sama?** Ya. Keduanya mencetak "Paket Makan Minum" lengkap dengan varian dan modifier-nya. Memecah isi paket per station butuh fitur bundle, yang di luar rilis ini.
+
+**Apakah nilai printer dibatasi?** Tidak. Nilainya string bebas sampai 50 karakter, dan harus sama dengan nama printer di app POS.

docs/mobile-customer-enakpoint.md

@@ -0,0 +1,614 @@
+# Prompt: fitur EnakPoint & EnakCoin di Mobile App Customer
+
+Kamu mengerjakan aplikasi mobile untuk **customer** (bukan kasir, bukan backoffice).
+Tugasmu: membangun fitur loyalitas EnakPoint & EnakCoin di aplikasi, memakai API backend
+yang sudah jadi dan dijelaskan di dokumen ini. Jangan mengarang endpoint, field, atau
+aturan yang tidak tertulis di sini; kalau ada yang kurang jelas, tanyakan dulu.
+
+---
+
+## 1. Konteks bisnis
+
+| | EnakPoint (`POINT`) | EnakCoin (`COIN`) |
+|---|---|---|
+| Didapat dari | Belanja (order lunas), koreksi admin, tukar EnakCoin | Belanja, koreksi admin |
+| Dipakai untuk | **Membayar order** | **Main game**, ditukar ke EnakPoint |
+| Bisa dikirim ke customer lain | Ya | Ya |
+| Bisa kedaluwarsa | Ya, bila owner mengaktifkan | Ya, bila owner mengaktifkan |
+
+Tidak ada lagi "token". Semua yang dulu token sekarang EnakCoin, dan endpoint serta
+field bernama token sudah dihapus dari API.
+
+### Aturan yang wajib dipatuhi di UI
+
+1. **Semua jumlah bilangan bulat.** Tidak ada desimal pada EnakPoint atau EnakCoin.
+2. **Saldo bukan uang.** Nilai rupiah EnakPoint selalu ditulis **"setara potongan
+   Rp …"**, tidak pernah "saldo Rp …" atau "uang". Tidak ada fitur tarik tunai.
+3. **PIN 6 digit wajib** untuk: membuat kode bayar, tukar
+   EnakCoin, dan transfer. **Main game tidak butuh PIN.** Melihat saldo dan riwayat
+   tidak butuh PIN.
+4. **PIN terpisah dari password login** dan selalu dikirim sebagai **string** (supaya
+   nol di depan tidak hilang). Jangan pernah menyimpan PIN di perangkat, log, atau
+   analytics.
+5. **Satu akun customer = satu organisasi.** Saldo berlaku di semua outlet organisasi itu.
+6. **Waktu memakai WIB.** Tanggal kedaluwarsa berarti saldo masih bisa dipakai sampai
+   23:59:59 WIB di tanggal itu.
+
+---
+
+## 2. Koneksi ke API
+
+- Base URL: `/api/v1`
+- Semua endpoint customer: header `Authorization: Bearer <token login customer>`
+- Semua jumlah di request dan response berupa integer.
+
+### Registrasi customer
+
+`POST /api/v1/customer-auth/register/start` menerima `organization_id` (opsional):
+
+```json
+{ "phone_number": "0812…", "name": "Budi", "birth_date": "2000-01-31", "organization_id": "648b96a0-1d1d-414e-baee-37e9d6317b4e" }
+```
+
+- Customer terdaftar di satu organisasi, dan saldonya berlaku di semua outlet organisasi itu.
+- Bila `organization_id` tidak dikirim dan backend hanya punya satu organisasi, customer
+  otomatis masuk ke organisasi itu. Bila ada lebih dari satu, registrasi ditolak
+  ("organization_id is required"), jadi sebaiknya app selalu mengirimnya dari config per
+  environment/brand.
+- `organization_id` yang dikirim harus ada; bila tidak, registrasi ditolak sebelum OTP dikirim.
+- Wallet customer baru belum punya baris sampai saldo pertama kali bergerak;
+  `GET /customer/wallet` tetap menjawab saldo 0.
+
+### Format response
+
+Sukses:
+
+```json
+{ "success": true, "data": { … }, "errors": null }
+```
+
+Gagal:
+
+```json
+{ "success": false, "data": null, "errors": [{ "code": "304", "entity": "wallet_service", "cause": "wallet move refused: not enough EnakCoin" }] }
+```
+
+| `errors[0].code` | HTTP | Arti | Yang dilakukan app |
+|---|---|---|---|
+| `303`, `310` | 400 | Request tidak lengkap / salah format | Bug di app; tampilkan pesan umum |
+| `304` | 400 | Ditolak aturan bisnis | Tampilkan pesan yang ramah (lihat tiap fitur); `cause` berbahasa Inggris, jangan tampilkan mentah |
+| `404` | 404 | Tidak ditemukan | Tampilkan "tidak ditemukan" |
+| `429` | 429 | Minta OTP terlalu cepat | Tampilkan hitung mundur sebelum boleh minta lagi |
+| `PIN_NOT_SET` | 403 | Belum punya PIN | Buka alur buat PIN (§6.2) |
+| `PIN_INVALID` | 400 | PIN salah | §6.5 |
+| `PIN_LOCKED` | 423 | PIN terkunci | §6.5 |
+| `TRANSFER_BLOCKED` | 403 | Transfer ditahan setelah reset PIN | §6.5 |
+| `900` | 500 | Error server | "Terjadi kesalahan, coba lagi" |
+
+### Idempotency-Key
+
+Endpoint **tukar** dan **transfer** wajib header `Idempotency-Key` (string unik, maks.
+50 karakter, mis. UUID v4).
+
+- Buat **satu key baru saat customer menekan tombol konfirmasi**.
+- Bila request gagal karena jaringan/timeout, **kirim ulang dengan key yang sama**.
+  Server mengembalikan hasil pertama dengan `"replayed": true` dan tidak memotong saldo
+  dua kali.
+- Jangan pakai ulang key untuk transaksi yang berbeda; server menolaknya (`304`).
+
+---
+
+## 3. Layar yang perlu dibuat
+
+| Layar | Endpoint utama | Butuh PIN |
+|---|---|---|
+| Beranda wallet | `GET /customer/wallet` | – |
+| Riwayat mutasi | `GET /customer/wallet/transactions` | – |
+| Saldo akan kedaluwarsa | `GET /customer/wallet/expiring` | – |
+| Daftar outlet | `GET /customer/outlets` | – |
+| Riwayat order + detail | `GET /customer/orders`, `GET /customer/orders/:id` | – |
+| Kode bayar (angka + QR) | `POST /customer/wallet/payment-code` | Ya |
+| Tukar EnakCoin | `GET …/exchange/preview`, `POST /customer/wallet/exchange` | Ya |
+| Transfer | `GET …/transfer/recipient`, `POST /customer/wallet/transfer` | Ya |
+| PIN (buat, ganti, lupa) | `/customer/pin/*` | – |
+| Game | `POST /customer/spin` | – |
+| (latar belakang) registrasi push | `PUT` / `DELETE /customer/devices` | – |
+
+---
+
+## 4. Beranda wallet, riwayat, kedaluwarsa
+
+### 4.1 Beranda — `GET /customer/wallet`
+
+```json
+{
+  "point_balance": 12500,
+  "coin_balance": 8,
+  "point_value": 1,
+  "point_discount_value": 12500,
+  "nearest_expiring": {
+    "point": { "amount": 150, "date": "2026-12-31" },
+    "coin": null
+  },
+  "recent_transactions": [ /* sama dengan item riwayat §4.2, maksimal 5 */ ]
+}
+```
+
+Tampilkan:
+- Saldo EnakPoint (`point_balance`) dengan keterangan "setara potongan Rp
+  {point_discount_value}" (format ribuan Indonesia: `Rp 12.500`).
+- Saldo EnakCoin (`coin_balance`).
+- Bila `nearest_expiring.point` / `.coin` tidak `null`: banner "{amount} EnakPoint akan
+  kedaluwarsa pada {date}" yang membuka layar §4.3.
+- 5 mutasi terakhir dari `recent_transactions`, dengan tautan "Lihat semua" ke §4.2.
+- Tombol aksi: Bayar di kasir (§7.1), Tukar EnakCoin (§8.1), Transfer (§8.2), Main game (§9).
+
+Muat ulang beranda setelah setiap transaksi dan saat menerima push (§5).
+
+Field `total_points`, `points_history`, `last_updated` di response ini **deprecated**;
+jangan dipakai.
+
+### 4.2 Riwayat — `GET /customer/wallet/transactions`
+
+Query (semua opsional):
+
+| Query | Contoh | Keterangan |
+|---|---|---|
+| `page` | `1` | Mulai dari 1 |
+| `limit` | `20` | 1–100, default 20 |
+| `currency` | `POINT` | `POINT` atau `COIN`; untuk tab EnakPoint / EnakCoin |
+| `type` | `EARN,PAYMENT` | Satu atau beberapa tipe dipisah koma, untuk filter |
+| `from`, `to` | `2026-09-01` | Tanggal WIB, inklusif |
+
+```json
+{
+  "data": [
+    {
+      "id": "…",
+      "currency": "POINT",
+      "type": "EARN",
+      "amount": 875,
+      "balance_after": 12500,
+      "description": "Belanja #ORD-0123 di Outlet Kemang",
+      "source": { "type": "ORDER", "id": "…" },
+      "outlet_id": "…",
+      "group_id": null,
+      "expires_at": "2026-12-31T23:59:59+07:00",
+      "lots": [{ "amount": 875, "remaining": 875, "expires_at": "2026-12-31T23:59:59+07:00" }],
+      "created_at": "2026-09-30T12:01:00Z"
+    }
+  ],
+  "pagination": { "page": 1, "limit": 20, "total_count": 42, "total_pages": 3 }
+}
+```
+
+Aturan tampilan:
+- `amount` bertanda: positif tampil hijau dengan `+`, negatif merah dengan `−`.
+- `description` sudah siap tampil (nama lawan transfer sudah disamarkan). Tampilkan apa
+  adanya.
+- Mutasi masuk yang punya `expires_at` menampilkan "Berlaku sampai {tanggal}".
+- Infinite scroll memakai `pagination.total_pages`.
+- Riwayat tidak pernah berubah atau hilang; koreksi muncul sebagai baris baru.
+
+Label tipe:
+
+| `type` | Label | Arah |
+|---|---|---|
+| `EARN` | Dari belanja | + |
+| `EARN_REVERSAL` | Dibatalkan (order di-void/refund) | − |
+| `PAYMENT` | Bayar pesanan | − |
+| `PAYMENT_REFUND` | Pengembalian pembayaran | + |
+| `EXCHANGE_OUT` | Ditukar ke EnakPoint | − |
+| `EXCHANGE_IN` | Hasil tukar EnakCoin | + |
+| `TRANSFER_OUT` | Transfer keluar | − |
+| `TRANSFER_IN` | Transfer masuk | + |
+| `GAME_SPEND` | Main game | − |
+| `EXPIRE` | Kedaluwarsa | − |
+| `ADJUSTMENT` | Koreksi | + / − |
+| `MIGRATION` | Saldo awal | + |
+
+### 4.3 Akan kedaluwarsa — `GET /customer/wallet/expiring`
+
+```json
+{
+  "point": [
+    { "amount": 150, "date": "2026-10-31" },
+    { "amount": 200, "date": "2026-12-31" }
+  ],
+  "coin": []
+}
+```
+
+Daftar per tanggal, paling dekat di atas. Daftar kosong: tampilkan "Tidak ada saldo
+yang akan kedaluwarsa". Saldo yang kedaluwarsa hangus tanpa kompensasi.
+
+---
+
+### 4.4 Daftar outlet — `GET /customer/outlets`
+
+Outlet aktif di organisasi customer, tempat saldo EnakPoint & EnakCoin berlaku. Urut
+berdasarkan nama.
+
+```json
+[
+  {
+    "id": "…",
+    "name": "Gokuna Kemang",
+    "address": "Jl. Kemang Raya 10",
+    "accepts_point_payment": true,
+    "earns_points": true,
+    "earns_coins": false
+  }
+]
+```
+
+- `address` bisa `null`.
+- `accepts_point_payment`: kasir di outlet ini menerima pembayaran EnakPoint. Pakai
+  untuk label "Bisa bayar pakai EnakPoint".
+- `earns_points` / `earns_coins`: belanja di outlet ini memberi EnakPoint / EnakCoin.
+- Belum ada telepon, koordinat, atau jam buka; data itu belum disimpan di backend.
+
+
+### 4.5 Riwayat order — `GET /customer/orders` dan `GET /customer/orders/:id`
+
+Order milik customer yang login di semua outlet organisasinya, terbaru di atas. Order
+hanya masuk ke sini bila kasir mengaitkannya ke customer.
+
+`GET /api/v1/customer/orders?page=1&limit=20` (`limit` 1–100, default 20):
+
+```json
+{
+  "data": [
+    {
+      "id": "…",
+      "order_number": "ORD-0123",
+      "outlet_id": "…",
+      "outlet_name": "Gokuna 1",
+      "order_type": "dine_in",
+      "status": "completed",
+      "payment_status": "completed",
+      "total_amount": 99000,
+      "item_count": 2,
+      "is_void": false,
+      "is_refund": false,
+      "points_earned": 865,
+      "coins_earned": 3,
+      "created_at": "2026-09-30T12:01:00Z"
+    }
+  ],
+  "pagination": { "page": 1, "limit": 20, "total_count": 42, "total_pages": 3 }
+}
+```
+
+`GET /api/v1/customer/orders/{id}` mengembalikan field yang sama, ditambah:
+
+```json
+{
+  "table_number": "A3",
+  "subtotal": 90000,
+  "discount_amount": 0,
+  "tax_amount": 9000,
+  "refund_amount": 0,
+  "items": [
+    {
+      "id": "…",
+      "product_id": "…",
+      "product_name": "Kopi Susu",
+      "variant_name": "Large",
+      "quantity": 2,
+      "unit_price": 25000,
+      "total_price": 50000,
+      "refund_quantity": 0,
+      "modifiers": [],
+      "status": "completed"
+    },
+    {
+      "id": "…",
+      "product_id": "…",
+      "product_name": "Ikan Tude",
+      "variant_name": null,
+      "quantity": 1,
+      "weight": 4.2,
+      "unit_name": "ons",
+      "unit_price": 4500,
+      "total_price": 18900,
+      "refund_quantity": 0,
+      "modifiers": [],
+      "status": "completed"
+    }
+  ],
+  "payments": [
+    { "id": "…", "method_name": "EnakPoint", "method_type": "point", "amount": 12500, "status": "completed", "refund_amount": 0, "points_used": 12500, "point_value": 1, "created_at": "…" },
+    { "id": "…", "method_name": "Cash", "method_type": "cash", "amount": 86500, "status": "completed", "refund_amount": 0, "created_at": "…" }
+  ]
+}
+```
+
+- Order customer lain atau yang tidak ada → `404`.
+- `points_earned` / `coins_earned`: yang didapat dari order ini; 0 bila tidak ada.
+- Item timbangan membawa `weight` dan `unit_name`; tampilkan "1 × 4,2 ons".
+- Pembayaran EnakPoint membawa `points_used`; tampilkan "EnakPoint 12.500 (Rp 12.500)".
+- Order yang `is_void` atau `is_refund` tetap tampil, beri label "Dibatalkan" /
+  "Direfund".
+
+
+## 5. Notifikasi push (FCM)
+
+### 5.1 Registrasi device
+
+Setelah login berhasil **dan** setiap kali FCM memberi token baru (`onTokenRefresh`):
+
+`PUT /api/v1/customer/devices`
+
+```json
+{ "device_id": "<id unik & stabil per instalasi>", "fcm_token": "<token FCM>", "platform": "android", "app_version": "2.4.0" }
+```
+
+- `device_id` wajib, stabil untuk satu instalasi (simpan di secure storage).
+- `platform`: `android`, `ios`, atau `web`.
+- Saat **logout**, panggil `DELETE /api/v1/customer/devices/{device_id}` sebelum
+  menghapus token login, supaya HP itu tidak lagi menerima notifikasi akun ini.
+
+Tanpa registrasi ini, customer tidak menerima push apa pun.
+
+### 5.2 Tipe push
+
+Semua nilai di `data` berupa string.
+
+| `data.type` | Kapan | Isi `data` lain | Aksi saat di-tap |
+|---|---|---|---|
+| `WALLET_TRANSFER_IN` | Menerima transfer | `transaction_id`, `group_id`, `currency`, `amount` | Buka riwayat, sorot transaksi itu |
+| `WALLET_EXPIRING` | Beberapa hari sebelum saldo hangus | `currency`, `amount`, `expiry_date` | Buka layar kedaluwarsa (§4.3) |
+| `WALLET_EXPIRED` | Saldo baru saja hangus | `currency`, `amount` | Buka riwayat |
+| `PIN_LOCKED` | PIN terkunci setelah 5 kali salah | `locked_until` (RFC3339 UTC) | Buka layar lupa PIN (§6.4) |
+
+Saat app terbuka dan menerima push wallet, muat ulang beranda.
+
+---
+
+## 6. PIN
+
+### 6.1 Kapan diminta
+
+Jangan minta PIN saat registrasi. Minta saat customer **pertama kali** melakukan aksi
+yang butuh PIN. Cek dengan:
+
+`GET /api/v1/customer/pin/status` → `{ "has_pin": false, "locked_until": null, "transfer_blocked_until": null }`
+
+Bila `has_pin: false`, arahkan ke alur buat PIN, lalu kembali ke aksi semula.
+
+### 6.2 Buat PIN
+
+1. `POST /api/v1/customer/pin/otp` dengan `{ "purpose": "pin_setup" }`.
+   Response: `{ "purpose": "pin_setup", "otp_token": "…", "expires_at": "…" }`.
+   OTP dikirim ke WhatsApp customer.
+2. Customer memasukkan kode OTP, lalu PIN dua kali.
+3. `POST /api/v1/customer/pin` dengan
+   `{ "otp_token": "…", "otp_code": "123456", "pin": "482913", "confirm_pin": "482913" }`.
+   Response: status PIN.
+
+Validasi di app sebelum kirim (server juga memeriksa, jawab `304`):
+- Tepat 6 digit angka, dan konfirmasi sama.
+- Bukan satu digit berulang (`111111`).
+- Bukan berurutan naik/turun (`123456`, `654321`).
+- Bukan tanggal lahir customer (`DDMMYY` atau `YYMMDD`).
+
+Minta OTP lagi terlalu cepat → `429`: tampilkan hitung mundur.
+
+### 6.3 Ganti PIN
+
+`PUT /api/v1/customer/pin` dengan `{ "old_pin": "…", "pin": "…", "confirm_pin": "…" }`.
+
+### 6.4 Lupa PIN
+
+1. `POST /customer/pin/otp` dengan `{ "purpose": "pin_reset" }`.
+2. `POST /customer/pin/reset` dengan `{ "otp_token", "otp_code", "pin", "confirm_pin" }`.
+
+Reset juga membuka PIN yang terkunci. Setelah reset, **transfer keluar ditahan 24 jam**;
+bayar dan tukar tetap bisa. Beri tahu customer hal ini di layar sukses.
+
+### 6.5 Menangani error PIN
+
+Semua endpoint yang menerima `pin` bisa menjawab error PIN. Pada error ini **`data`
+tidak `null`**:
+
+```json
+{ "success": false, "data": { "code": "PIN_INVALID", "remaining_attempts": 3 }, "errors": [ … ] }
+```
+
+| `data.code` | Field tambahan | Tampilan |
+|---|---|---|
+| `PIN_NOT_SET` | – | Buka alur buat PIN (§6.2) |
+| `PIN_INVALID` | `remaining_attempts` | "PIN salah, sisa {n} percobaan." Kosongkan input PIN |
+| `PIN_LOCKED` | `locked_until` | "PIN terkunci sampai {jam}." Tombol "Lupa PIN" |
+| `TRANSFER_BLOCKED` | `transfer_blocked_until` | "Transfer bisa dilakukan lagi pada {waktu}." |
+
+5 kali salah berturut-turut mengunci PIN 30 menit; selama terkunci PIN yang benar pun
+ditolak. Penghitung ada di server, jadi jangan membuat penghitung sendiri di app.
+
+---
+
+## 7. Membayar dengan EnakPoint
+
+App customer tidak membuat atau membayar order; order hanya bisa dilihat (§4.5).
+EnakPoint hanya dipakai membayar di kasir, lewat kode bayar dari app. Jangan membangun
+layar checkout atau memanggil `POST /customer/orders/:id/pay-with-points`.
+
+### 7.1 Di kasir — kode bayar
+
+Customer tidak pernah mengetik PIN di mesin kasir. Alurnya:
+
+1. Customer membuka "Bayar di kasir" dan memasukkan PIN.
+2. `POST /api/v1/customer/wallet/payment-code` dengan `{ "pin": "482913" }`:
+
+   ```json
+   { "code": "482913", "qr_payload": "enakpoint:482913", "expires_at": "2026-09-30T05:02:00Z" }
+   ```
+
+3. Tampilkan `code` besar (angka) **dan** QR dari `qr_payload` (string apa adanya).
+4. Tampilkan hitung mundur ke `expires_at` (2 menit). Setelah habis, sembunyikan kode
+   dan tampilkan tombol "Buat kode baru".
+5. Kasir memindai/mengetik kode dan memilih jumlah EnakPoint. App tidak menerima
+   callback; setelah customer kembali ke beranda, muat ulang saldo.
+
+Kode sekali pakai. Membuat kode baru membatalkan kode lama.
+
+### 7.2 Refund
+
+Bila order yang dibayar EnakPoint dibatalkan atau direfund, EnakPoint kembali sebagai
+EnakPoint (tidak pernah tunai) dan muncul di riwayat sebagai `PAYMENT_REFUND`.
+
+---
+
+## 8. Tukar dan transfer
+
+### 8.1 Tukar EnakCoin → EnakPoint
+
+1. Customer mengetik jumlah EnakCoin. Panggil preview (debounce saat mengetik):
+
+   `GET /api/v1/customer/wallet/exchange/preview?coins=30`
+
+   ```json
+   { "coin_amount": 10, "point_amount": 3, "coin_balance": 35, "coins": 30, "points": 9, "valid": true }
+   ```
+
+   - Kurs: `coin_amount` EnakCoin = `point_amount` EnakPoint. Tampilkan "10 EnakCoin =
+     3 EnakPoint".
+   - Bila `valid: false`, tampilkan `reason` sebagai alasan dan nonaktifkan tombol. Jumlah
+     harus kelipatan `coin_amount`.
+   - Tampilkan "Kamu akan mendapat {points} EnakPoint".
+
+2. Konfirmasi (tukar tidak bisa dibatalkan) → minta PIN →
+
+   `POST /api/v1/customer/wallet/exchange` + header `Idempotency-Key`
+
+   ```json
+   { "coins": 30, "pin": "482913" }
+   ```
+
+   ```json
+   {
+     "group_id": "…",
+     "coins": 30,
+     "points": 9,
+     "coin_amount": 10,
+     "point_amount": 3,
+     "lots": [{ "amount": 9, "expires_at": "2026-12-31T23:59:59+07:00" }],
+     "coin_balance": 5,
+     "point_balance": 9,
+     "replayed": false
+   }
+   ```
+
+3. Layar sukses: saldo baru, dan bila `lots[].expires_at` ada, "EnakPoint ini berlaku
+   sampai {tanggal}".
+
+### 8.2 Transfer
+
+1. Pilih mata uang (EnakPoint / EnakCoin), isi nomor HP penerima dan jumlah.
+2. Cek penerima:
+
+   `GET /api/v1/customer/wallet/transfer/recipient?phone=081234561234`
+
+   ```json
+   { "name": "Bu*** Sa***", "phone_number": "08**-****-1234" }
+   ```
+
+   | Hasil | Tampilan |
+   |---|---|
+   | Sukses | "Kirim ke Bu*** Sa*** (08**-****-1234)?" |
+   | `404` | "Nomor ini tidak terdaftar" |
+   | `304` | "Tidak bisa mengirim ke nomor ini" (diri sendiri, akun nonaktif) |
+
+3. Konfirmasi (transfer final, tidak bisa dibatalkan) → minta PIN →
+
+   `POST /api/v1/customer/wallet/transfer` + header `Idempotency-Key`
+
+   ```json
+   { "currency": "POINT", "amount": 120, "recipient_phone": "081234561234", "pin": "482913" }
+   ```
+
+   ```json
+   {
+     "group_id": "…",
+     "currency": "POINT",
+     "amount": 120,
+     "recipient": { "name": "Bu*** Sa***", "phone_number": "08**-****-1234" },
+     "lots": [
+       { "amount": 100, "expires_at": "2026-12-31T23:59:59+07:00" },
+       { "amount": 20, "expires_at": null }
+     ],
+     "balance": 30,
+     "replayed": false
+   }
+   ```
+
+4. Layar sukses: saldo tersisa (`balance`). Bila ada `lots[].expires_at`, tampilkan
+   "Saldo yang dikirim berlaku sampai {tanggal}" (tanggal kedaluwarsa ikut terbawa ke
+   penerima).
+
+Penolakan `304` yang mungkin: transfer dimatikan owner, di bawah minimal, di atas
+maksimal per transaksi, melewati batas harian (reset tengah malam WIB), saldo tidak
+cukup. Tampilkan pesan umum "Transfer tidak bisa diproses" plus alasan yang sesuai
+bila bisa dikenali. Bila kena `TRANSFER_BLOCKED`, ikuti §6.5.
+
+Penerima mendapat push `WALLET_TRANSFER_IN`.
+
+---
+
+## 9. Game (memakai EnakCoin)
+
+`POST /api/v1/customer/spin` dengan `{ "spin_id": "<id game>" }`. Tanpa PIN.
+
+```json
+{
+  "game_play": { "id": "…", "game_id": "…", "coins_used": 1, "created_at": "…" },
+  "prize_won": { "id": "…", "name": "Voucher 10rb" },
+  "coins_remaining": 7
+}
+```
+
+- Setiap game punya biaya sendiri: `metadata.coin_cost` pada data game dari
+  `GET /api/v1/customer/games` (atau `GET /customer/ferris-wheel`), default 1 bila kosong.
+  Tampilkan biaya sebelum main, dan nonaktifkan tombol bila `coin_balance` kurang.
+- `304`: EnakCoin kurang, game nonaktif, atau hadiah baru saja habis. Tidak ada
+  EnakCoin yang terpotong; tampilkan pesan dan biarkan customer mencoba lagi.
+- Setelah main, perbarui saldo EnakCoin dari `coins_remaining`.
+
+---
+
+## 10. Yang sudah dihapus / deprecated
+
+Sudah **dihapus** dari API (jangan dipanggil, akan error / tidak ada):
+
+| Lama | Pengganti |
+|---|---|
+| `GET /customer/tokens` | `GET /customer/wallet` → `coin_balance` |
+| `total_tokens`, `tokens_history` | `coin_balance`, `GET /customer/wallet/transactions?currency=COIN` |
+| `token_used`, `tokens_remaining` di response game | `coins_used`, `coins_remaining` |
+
+Masih ada tapi **deprecated** (akan dihapus, jangan dipakai di kode baru):
+
+| Lama | Pengganti |
+|---|---|
+| `GET /customer/points` | `GET /customer/wallet` → `point_balance` |
+| `total_points`, `points_history`, `last_updated` di `/customer/wallet` | `point_balance`, `recent_transactions` |
+
+---
+
+## 11. Checklist selesai
+
+- [ ] Beranda menampilkan saldo EnakPoint ("setara potongan Rp …"), EnakCoin, dan banner kedaluwarsa terdekat.
+- [ ] Riwayat dengan tab per mata uang, filter tipe/tanggal, infinite scroll, label tipe sesuai §4.2.
+- [ ] Layar saldo akan kedaluwarsa.
+- [ ] Registrasi device FCM setelah login dan saat token berganti; unregister saat logout.
+- [ ] Penanganan tap untuk keempat tipe push.
+- [ ] PIN diminta hanya saat aksi yang membutuhkan; alur buat, ganti, dan lupa PIN lewat OTP.
+- [ ] Keempat error PIN ditangani di semua layar yang meminta PIN.
+- [ ] Kode bayar: angka + QR, hitung mundur 2 menit, tombol buat ulang.
+- [ ] Tukar dengan preview, kelipatan kurs, konfirmasi, `Idempotency-Key`, retry dengan key sama.
+- [ ] Transfer dengan cek penerima tersamar, konfirmasi, `Idempotency-Key`, retry dengan key sama.
+- [ ] Game memakai `coins_used` / `coins_remaining` dan menampilkan biaya per game.
+- [ ] Riwayat order dengan pagination dan layar detail (item, pembayaran, EnakPoint/EnakCoin yang didapat).
+- [ ] Tidak ada pemakaian endpoint atau field di §10.
+- [ ] PIN tidak pernah disimpan, di-log, atau dikirim ke analytics.

docs/tasks-point-coin.md

@@ -0,0 +1,438 @@
+# Task Breakdown: EnakPoint & EnakCoin
+
+**Sumber:** [PRD EnakPoint & EnakCoin](prd-point-coin.md)
+**Tanggal:** 2026-09-29
+
+Setiap task menyebut bagian PRD yang dikerjakan, lapisan kode yang disentuh, task yang
+harus selesai lebih dulu, dan kriteria selesai. Ukuran: **S** ≤ 1 hari, **M** 2–3 hari,
+**L** 4–5 hari.
+
+Konvensi kode mengikuti yang sudah ada: `migrations/` (lanjut dari `000089`),
+`entities` → `repository` → `processor` → `service` → `handler` / `validator` →
+`router`, dan wiring di `internal/app/app.go`.
+
+---
+
+## Ringkasan
+
+| Fase | Task | Terblokir oleh catatan PRD |
+|---|---|---|
+| 1. Fondasi | PC-101 – PC-109 | – |
+| 2. Earning | PC-201 – PC-205 | – |
+| 3. Pembayaran EnakPoint | PC-301 – PC-308 | N2 (keuangan), N3 (legal) sebelum **rilis** |
+| 4. Pergerakan saldo | PC-401 – PC-404 | N3 (legal) sebelum **rilis** |
+| 5. Kedaluwarsa | PC-501 – PC-504 | N4 (model kedaluwarsa) sebelum **dikerjakan** |
+| 6. Bersih-bersih | PC-601 – PC-602 | – |
+
+Catatan N2 dan N3 hanya memblokir **rilis** fase 3–4, bukan pengerjaannya. N4
+memblokir pengerjaan fase 5, karena rumus kedaluwarsanya belum ditentukan.
+
+```
+PC-101 ─┬─ PC-103 ── PC-104 ─┬─ PC-105 ── PC-106
+        │                    ├─ PC-107
+        │                    ├─ PC-108
+        │                    ├─ PC-203 ── PC-204 ── PC-205
+        │                    ├─ PC-305 ── PC-306 / PC-307
+        │                    ├─ PC-401 / PC-402 / PC-403 / PC-404
+        │                    └─ PC-502 ── PC-503
+PC-102 ── PC-109 ─┬─ PC-201 ── PC-202 ── PC-203
+                  └─ PC-302
+PC-301 ── PC-304 ── PC-305
+PC-303 ── PC-305
+```
+
+---
+
+## Fase 1 — Fondasi
+
+Semua fase lain bergantung pada fase ini. **PC-104 (wallet engine) adalah inti.** Tidak
+ada kode lain yang boleh mengubah saldo tanpa lewat engine ini.
+
+### PC-101 · Migrasi tabel wallet, ledger, dan lot · M
+- **PRD:** §8 (`customer_wallets`, `wallet_transactions`, `wallet_lots`,
+  `wallet_lot_allocations`), K5, K9
+- **Kerjakan:** migrasi `000090_create_wallet_tables` (up & down) dengan semua
+  `CHECK` constraint dan index persis seperti di §8.
+- **Selesai jika:**
+  - Up dan down berjalan bersih di database kosong dan di salinan staging.
+  - Uji constraint langsung di SQL, masing-masing harus ditolak:
+    `PAYMENT` bercurrency `COIN`; `TRANSFER_IN` tanpa `counterparty_customer_id`;
+    `EARN_REVERSAL` tanpa `reverses_transaction_id`; `ADJUSTMENT` tanpa `reason`;
+    `EXPIRE` dengan `reference_type` selain `LOT`; saldo negatif; lot dengan
+    `remaining_amount > original_amount`.
+- **Bergantung pada:** –
+
+### PC-102 · Migrasi pengaturan organisasi dan riwayat perubahan setting · S
+- **PRD:** F2, `loyalty_setting_changes` di §8
+- **Kerjakan:** tabel `organization_settings` (key–value, pola sama dengan
+  `outlet_settings`, `UNIQUE(organization_id, key)`) dan `loyalty_setting_changes`.
+  Saat ini belum ada tempat menyimpan setting per organisasi.
+- **Selesai jika:** up/down bersih.
+- **Bergantung pada:** –
+
+### PC-103 · Entities dan repository wallet · M
+- **PRD:** §7.1–§7.4
+- **Kerjakan:**
+  - Entities untuk empat tabel PC-101.
+  - Repository yang **selalu** memakai `DBFromContext` (berbeda dari repository
+    gamification yang sekarang memakai `r.db` langsung).
+  - `LockWallet(ctx, customerID)` dengan `SELECT … FOR UPDATE`. Membuat baris wallet
+    jika belum ada (`INSERT … ON CONFLICT DO NOTHING`, lalu lock).
+  - `LockWallets(ctx, a, b)` yang selalu mengunci berurutan berdasarkan `customer_id`.
+  - Update saldo bersyarat yang **mengembalikan error jika 0 baris ter-update**.
+  - Query lot aktif sesuai urutan K9: `expires_at NULLS LAST, created_at`.
+- **Selesai jika:** test repository menunjukkan update bersyarat gagal saat saldo
+  kurang, dan dua goroutine yang mengunci wallet yang sama berjalan bergantian.
+- **Bergantung pada:** PC-101
+
+### PC-104 · Wallet engine (credit / debit / lot / idempotensi) · L
+- **PRD:** K5, K6, K9, §7, §8.1
+- **Kerjakan:** processor `WalletProcessor` sebagai **satu-satunya pintu** perubahan
+  saldo:
+  - `Credit(ctx, CreditInput)`: menulis ledger, membuat lot (dengan `expires_at` dan
+    `origin_lot_id` dari input), dan menambah saldo.
+  - `Debit(ctx, DebitInput)`: mengambil dari lot sesuai urutan K9 (atau dari lot
+    tertentu lebih dulu, untuk reversal di F10), menulis alokasi dan ledger, lalu
+    mengurangi saldo. Mengembalikan daftar alokasi, supaya transfer/exchange bisa
+    membuat lot penerima dengan `expires_at` yang sama.
+  - `DebitUpTo`: mengambil sebanyak yang tersedia, untuk reversal dengan shortfall
+    (F10, Q3).
+  - Idempotensi: jika `idempotency_key` sudah ada, kembalikan hasil pertama tanpa
+    mutasi baru.
+  - Validasi di level kode untuk aturan §8.1 (tipe ↔ currency ↔ referensi wajib),
+    sebagai lapisan kedua di atas constraint database.
+  - Semua method mewajibkan caller sudah berada di dalam transaksi dan wallet sudah
+    dikunci.
+- **Selesai jika:** unit test mencakup debit yang melewati beberapa lot, urutan lot
+  dengan dan tanpa `expires_at`, debit melebihi saldo (ditolak), `DebitUpTo` dengan
+  shortfall, idempotency key ganda, dan saldo = `SUM(ledger)` = `SUM(lot.remaining)`
+  setelah setiap skenario.
+- **Bergantung pada:** PC-103
+
+### PC-105 · Migrasi data Point & Token lama · M
+- **PRD:** §10, Q6
+- **Kerjakan:** migrasi data (atau command satu kali) yang:
+  - Membuat wallet dari `customer_points` dan penjumlahan semua jenis
+    `customer_tokens`.
+  - Menulis ledger `MIGRATION` dan lot tanpa `expires_at` per customer per currency,
+    dengan rincian per jenis token di `metadata`.
+  - Mengganti `TOKENS` menjadi `COINS` di `campaigns.type` dan
+    `campaign_rules.reward_type`.
+- **Selesai jika:** jumlah total Point dan Token sebelum = jumlah total saldo wallet
+  sesudah (diuji pada salinan data staging), dan migrasi aman dijalankan dua kali
+  (tidak menggandakan).
+- **Bergantung pada:** PC-104
+
+### PC-106 · Endpoint saldo & riwayat customer · M
+- **PRD:** F6, §9 (customer app)
+- **Kerjakan:** `GET /customer/wallet` dan `GET /customer/wallet/transactions`
+  (pagination, filter currency/tipe/tanggal). Ganti isi `/customer/points` dan
+  `/customer/tokens` menjadi alias yang membaca `customer_wallets`. Hapus pemakaian
+  `customer_points_repository` untuk saldo.
+- **Selesai jika:** response menampilkan asal/tujuan setiap mutasi sesuai §8.1, dan
+  aplikasi lama yang memanggil `/points` / `/tokens` tetap mendapat angka yang benar.
+- **Bergantung pada:** PC-105
+
+### PC-107 · Wallet customer dan adjustment di dashboard · M
+- **PRD:** F7
+- **Kerjakan:** `GET /marketing/customers/:id/wallet` (saldo, lot aktif, mutasi) dan
+  `POST /marketing/customers/:id/wallet/adjust` (alasan wajib, tidak boleh membuat saldo
+  negatif, tercatat `created_by_user`).
+- **Selesai jika:** adjustment muncul di riwayat customer dengan nama admin dan alasan.
+  Adjustment yang melebihi saldo ditolak.
+- **Bergantung pada:** PC-104
+
+### PC-108 · Job rekonsiliasi · S
+- **PRD:** §7.5
+- **Kerjakan:** query dan job terjadwal yang memeriksa semua invarian §7.5 dan
+  melaporkan selisih ke log dan notifikasi admin.
+- **Selesai jika:** job menemukan selisih yang sengaja dibuat di data test, dan diam
+  saat data konsisten.
+- **Bergantung pada:** PC-104
+
+### PC-109 · Pembaca setting loyalitas dan riwayat perubahan · M
+- **PRD:** F1, F2 (bagian mekanisme, bukan UI), §8 `loyalty_setting_changes`
+- **Kerjakan:** service yang membaca setting outlet dan organisasi dengan nilai default
+  PRD bila key belum diisi, mengembalikan struct bertipe (bukan string mentah), dan
+  menulis `loyalty_setting_changes` setiap kali setting loyalitas diubah.
+- **Selesai jika:** outlet tanpa setting mendapat semua default PRD, dan setiap
+  perubahan tercatat nilai lama, nilai baru, dan pelakunya.
+- **Bergantung pada:** PC-102
+
+---
+
+## Fase 2 — Earning
+
+### PC-201 · API pengaturan loyalitas outlet · M
+- **PRD:** F1
+- **Kerjakan:** `GET/PUT /outlets/:id/loyalty-settings` dengan validasi F1. Response
+  menyertakan **persentase cashback efektif** (`earn_value × nilai EnakPoint /
+  earn_per_amount`).
+- **Selesai jika:** validasi menolak nilai di luar batas, dan hanya Admin/Manager yang
+  bisa mengubah.
+- **Bergantung pada:** PC-109
+
+### PC-202 · Kalkulator earning · S
+- **PRD:** F1 (rumus), Q1, Q10
+- **Kerjakan:** fungsi murni `CalculateEarning(order, pointPaidAmount, settings)` yang
+  mengembalikan Point, Coin, basis, dan snapshot setting.
+- **Selesai jika:** unit test mencakup contoh di PRD (Rp 87.500 → 875 Point, 3 Coin;
+  dengan Rp 20.000 dibayar EnakPoint → 675 Point, 2 Coin), basis di bawah minimum,
+  `max_per_order`, setting nonaktif, dan pajak tidak ikut dihitung.
+- **Bergantung pada:** PC-201
+
+### PC-203 · Earning saat order lunas · L
+- **PRD:** F3
+- **Kerjakan:**
+  - **Satukan titik "order menjadi lunas".** Saat ini `payment_status = completed`
+    di-set di empat tempat: `OrderProcessorImpl.UpdateOrder`,
+    `OrderProcessorImpl.updateOrderStatus`, dan dua tempat di `split_bill_processor.go`.
+    Buat satu hook `onOrderPaid(orderID)` yang dipanggil dari keempatnya.
+  - Hook menjalankan earning **setelah** transaksi pembayaran commit, sehingga
+    kegagalan earning tidak menggagalkan pembayaran.
+  - Idempotency key `earn:{order_id}:{currency}`.
+  - Lewati order tanpa customer, customer default, atau customer nonaktif.
+  - **Jaring pengaman:** job yang mencari order lunas beberapa hari terakhir yang belum
+    punya `EARN` (dan seharusnya punya), lalu menjalankan ulang earning.
+- **Selesai jika:** test untuk pembayaran penuh, split bill (lunas di pembayaran
+  terakhir), self-order, dan pemanggilan ganda (hasilnya tetap satu earning). Earning
+  yang sengaja digagalkan tidak menggagalkan pembayaran dan terambil oleh job.
+- **Bergantung pada:** PC-104, PC-202
+
+### PC-204 · Reversal earning saat void / refund · M
+- **PRD:** F10, Q3
+- **Kerjakan:** panggil reversal dari `VoidOrder`, `RefundOrder`, dan `RefundPayment`.
+  Ambil pertama dari lot `EARN` order tersebut, lalu lot lain. Gunakan `DebitUpTo` dan
+  catat `shortfall`. Refund tidak pernah diblokir.
+- **Selesai jika:** test untuk void penuh, refund sebagian (proporsional, akumulasi tidak
+  melebihi earning), dan saldo yang sudah terpakai (shortfall tercatat, saldo 0).
+- **Bergantung pada:** PC-203
+
+### PC-205 · Tampilkan earning di order dan struk · S
+- **PRD:** F3
+- **Kerjakan:** tambah `points_earned` dan `coins_earned` ke response order dan data
+  struk.
+- **Selesai jika:** nilai sama dengan baris `EARN` di ledger, dan bernilai 0 untuk order
+  tanpa earning.
+- **Bergantung pada:** PC-203
+
+---
+
+## Fase 3 — Pembayaran EnakPoint
+
+> Boleh dikerjakan sekarang. **Tidak boleh dirilis** sebelum catatan N2 (keuangan) dan
+> N3 (legal) ditutup.
+
+### PC-301 · PIN customer · L
+- **PRD:** K8, F11, Q16, Q17
+- **Kerjakan:**
+  - Migrasi kolom PIN di `customers` dan tabel `customer_security_events`.
+  - Purpose OTP baru `pin_setup` dan `pin_reset` di `OtpProcessor`.
+  - Endpoint `/customer/pin/*` (status, OTP, buat, ganti, reset).
+  - Hash bcrypt, tolak PIN lemah (digit sama, berurutan, tanggal lahir).
+  - Kunci 30 menit setelah 5 kali salah, dengan penghitung di database.
+  - Tahan transfer keluar 24 jam setelah reset.
+  - `VerifyPin(ctx, customerID, pin)` untuk dipakai task lain, dengan error
+    `PIN_NOT_SET`, `PIN_INVALID`, `PIN_LOCKED`, `TRANSFER_BLOCKED`.
+  - Hapus PIN oleh admin: `DELETE /marketing/customers/:id/pin`, dan
+    `GET /marketing/customers/:id/security-events`.
+  - PIN tidak pernah muncul di log (termasuk log request body).
+- **Selesai jika:** test untuk semua aturan di atas, termasuk 5 kali salah lalu PIN
+  benar tetap ditolak selama terkunci, dan reset OTP membuka kunci.
+- **Bergantung pada:** –
+
+### PC-302 · API pengaturan loyalitas organisasi · S
+- **PRD:** F2
+- **Kerjakan:** `GET/PUT /marketing/loyalty-settings` untuk nilai EnakPoint, kurs
+  exchange, dan batas transfer, serta `GET /marketing/loyalty-settings/history`.
+  Sebelum menyimpan perubahan nilai EnakPoint atau kurs, response preview menampilkan
+  total saldo beredar dan nilai rupiahnya sebelum/sesudah.
+- **Selesai jika:** perubahan tercatat di riwayat, dan transaksi lama tetap memakai nilai
+  yang dibekukan.
+- **Bergantung pada:** PC-109
+
+### PC-303 · Payment method EnakPoint · M
+- **PRD:** F9 (payment method), §8 (perubahan `payments`), §10.5
+- **Kerjakan:**
+  - Tambah tipe `point` ke `PaymentMethodType` dan validator (`oneof=cash card
+    digital_wallet point`).
+  - Migrasi kolom `points_used` dan `point_value` di `payments`.
+  - Buat payment method sistem "EnakPoint" untuk setiap organisasi yang sudah ada, dan
+    otomatis untuk organisasi baru.
+  - Tolak hapus / ubah tipe method sistem.
+  - Sembunyikan method ini di kasir jika outlet tidak mengaktifkan `accept_payment`.
+- **Selesai jika:** setiap organisasi punya tepat satu method EnakPoint yang tidak bisa
+  dihapus.
+- **Bergantung pada:** –
+
+### PC-304 · Kode bayar sekali pakai · M
+- **PRD:** F9 (persetujuan customer), K8
+- **Kerjakan:** `POST /customer/wallet/payment-code` (butuh PIN) menghasilkan kode 6
+  digit dan QR yang berlaku 2 menit, disimpan di Redis dengan TTL dan diambil
+  sekali-pakai (`GETDEL`). Kode terikat ke `customer_id`.
+- **Selesai jika:** kode kedaluwarsa, kode yang sudah dipakai, dan kode milik customer
+  lain semuanya ditolak.
+- **Bergantung pada:** PC-301
+
+### PC-305 · Bayar EnakPoint di kasir · L
+- **PRD:** F9 (perhitungan, pencatatan), K7
+- **Kerjakan:**
+  - `GET /orders/:id/point-payment/preview`.
+  - Cabang method `point` di `CreatePayment`: validasi kode bayar, cocokkan customer
+    order, hitung `maks_point`, lalu lakukan langkah 1–6 F9 dalam **satu transaksi**
+    bersama pembuatan baris `payments`.
+  - Idempotency `payment:{payment_id}`.
+  - Tolak jika `nominal_rupiah > remaining_amount` (tidak ada kembalian).
+- **Selesai jika:** test untuk pembayaran penuh, sebagian + tunai (split), batas
+  `max_payment_percent`, order walk-in (ditolak), kode salah (ditolak), dan dua
+  pembayaran bersamaan untuk customer yang sama (saldo tidak terpakai dua kali).
+  Earning (PC-203) menghitung basis tanpa bagian EnakPoint.
+- **Bergantung pada:** PC-104, PC-303, PC-304
+
+### PC-306 · Bayar EnakPoint dari app / self-order · M
+- **PRD:** F9
+- **Kerjakan:** `POST /customer/orders/:id/pay-with-points` (butuh PIN, hanya untuk
+  order milik customer itu sendiri), memakai logika yang sama dengan PC-305.
+- **Selesai jika:** customer tidak bisa membayar order milik customer lain.
+- **Bergantung pada:** PC-305
+
+### PC-307 · Refund pembayaran EnakPoint · M
+- **PRD:** F9 (void/refund), K7, Q13
+- **Kerjakan:** `PAYMENT_REFUND` di jalur void dan refund memakai `point_value` yang
+  dibekukan, dengan pembulatan ke bawah. Kembalikan ke lot dengan `expires_at` asal
+  (aturan perpanjangan 7 hari mengikuti N4, jadi untuk sekarang cukup pakai tanggal
+  asal). **Tolak** permintaan refund bagian EnakPoint lewat method lain.
+- **Selesai jika:** test untuk void penuh, refund sebagian, perubahan nilai EnakPoint di
+  antara bayar dan refund (jumlah EnakPoint yang kembali tetap sama), dan percobaan
+  refund tunai atas pembayaran EnakPoint (ditolak).
+- **Bergantung pada:** PC-305
+
+### PC-308 · EnakPoint di laporan · S
+- **PRD:** F9 (laporan)
+- **Kerjakan:** laporan per payment method menampilkan EnakPoint terpisah dan tidak
+  menghitungnya sebagai kas masuk. Cek laporan analytics yang menjumlahkan pembayaran.
+- **Selesai jika:** total kas masuk di laporan tidak berubah saat sebagian order dibayar
+  EnakPoint. Perlakuan akuntansi lanjutan menunggu N2.
+- **Bergantung pada:** PC-305
+
+---
+
+## Fase 4 — Pergerakan Saldo
+
+> Boleh dikerjakan sekarang. Transfer (PC-402) **tidak boleh dirilis** sebelum N3
+> (legal) ditutup.
+
+### PC-401 · Exchange EnakCoin → EnakPoint · M
+- **PRD:** F4, K3
+- **Kerjakan:** `GET /customer/wallet/exchange/preview` dan
+  `POST /customer/wallet/exchange` (butuh PIN, `Idempotency-Key`). Jumlah harus
+  kelipatan `coin_amount`. Kurs dibekukan di metadata. Lot EnakPoint kedaluwarsa pada
+  `min(lot EnakCoin asal, sekarang + masa berlaku EnakPoint)`.
+- **Selesai jika:** test untuk kurs default 1:1, kurs 10:3, jumlah bukan kelipatan
+  (ditolak), dan `expires_at` lot hasil exchange tidak pernah lebih lama dari lot asal.
+- **Bergantung pada:** PC-104, PC-301, PC-302
+
+### PC-402 · Transfer antar customer · L
+- **PRD:** F5, Q4, Q16
+- **Kerjakan:** `GET /customer/wallet/transfer/recipient` (nama disamarkan) dan
+  `POST /customer/wallet/transfer` (butuh PIN, `Idempotency-Key`). Kunci dua wallet
+  berurutan, cek batas organisasi (per transaksi dan harian), cek
+  `transfer_blocked_until`. Lot penerima mewarisi `expires_at` dan `origin_lot_id` dari
+  lot pengirim. Kirim notifikasi push ke penerima.
+- **Selesai jika:** test untuk transfer ke diri sendiri / customer lain organisasi /
+  customer default (semua ditolak), batas harian, transfer dua arah bersamaan (tidak
+  deadlock), dan `expires_at` di penerima sama persis dengan pengirim.
+- **Bergantung pada:** PC-104, PC-301, PC-302
+
+### PC-403 · Semua game memakai EnakCoin · M
+- **PRD:** F8, K1
+- **Kerjakan:**
+  - `GamePlayProcessor.PlayGame` memotong EnakCoin lewat wallet engine sesuai
+    `games.metadata.coin_cost`.
+  - Seluruh permainan dalam satu transaksi: ubah repository game, game play, dan game
+    prize ke `DBFromContext`. Gagal mengurangi stok hadiah membatalkan permainan (saat
+    ini hanya di-`Printf`), dan rollback manual `AddTokens` dihapus.
+  - Rename `game_plays.token_used` menjadi `coins_used`.
+- **Selesai jika:** test untuk saldo kurang (ditolak, tidak ada `game_plays` yang
+  tercatat), stok hadiah gagal (semua dibatalkan), dan `GAME_SPEND` menunjuk
+  `game_plays.id`.
+- **Bergantung pada:** PC-104
+
+### PC-404 · Telusuri per butir di dashboard · S
+- **PRD:** F7, §8.1 (per butir)
+- **Kerjakan:** `GET /marketing/wallet-transactions/:id/trace` yang mengembalikan
+  alokasi lot dan rantai `origin_lot_id` sampai ke lot pertama.
+- **Selesai jika:** contoh di §8 (A transfer 120 ke B, B bayar 30) menelusuri ke order
+  #ORD-1 milik A.
+- **Bergantung pada:** PC-402
+
+---
+
+## Fase 5 — Kedaluwarsa
+
+> **Jangan dikerjakan sebelum catatan N4 (model kedaluwarsa) diputuskan.** Struktur lot
+> sudah ada sejak PC-101, jadi yang tersisa hanya rumus, job, dan tampilan.
+
+### PC-501 · Setting kedaluwarsa · M
+- **PRD:** F12 (pengaturan), N4
+- **Kerjakan:** key setting sesuai model yang dipilih di N4, dengan validasi dan preview
+  "saldo yang didapat hari ini kedaluwarsa pada …".
+- **Bergantung pada:** PC-302, **N4**
+
+### PC-502 · Hitung `expires_at` saat lot dibuat · M
+- **PRD:** F12 (tabel kedaluwarsa per lot), N4
+- **Kerjakan:** satu fungsi `ComputeExpiry(currency, receivedAt, settings)` yang dipakai
+  oleh `EARN` dan `ADJUSTMENT`, serta aturan aktivasi pertama untuk lot lama (termasuk
+  lot `MIGRATION`).
+- **Bergantung pada:** PC-104, PC-501
+
+### PC-503 · Job kedaluwarsa · M
+- **PRD:** F12 (proses kedaluwarsa)
+- **Kerjakan:** job per jam yang memproses lot lewat tanggal dengan `EXPIRE`
+  (idempotency `expire:{lot_id}`) di bawah lock wallet.
+  - **Jangan menyalin pola `OmsetMilestoneScheduler`.** Scheduler itu menyimpan state di
+    memori, dan menurut komentarnya sendiri bisa mengirim ulang notifikasi setelah
+    restart. Job ini harus aman dijalankan di banyak instance sekaligus: pilih lot
+    dengan `FOR UPDATE SKIP LOCKED`, dan andalkan idempotency key.
+- **Selesai jika:** dua instance yang berjalan bersamaan tidak menghanguskan lot yang
+  sama dua kali, dan tidak ada lot yang lewat tanggal lebih dari 1 jam tanpa diproses.
+- **Bergantung pada:** PC-502
+
+### PC-504 · Pengingat dan tampilan saldo yang akan kedaluwarsa · M
+- **PRD:** F6 (`/wallet/expiring`), F12 (pengingat)
+- **Kerjakan:** endpoint `GET /customer/wallet/expiring`, field saldo kedaluwarsa
+  terdekat di `/wallet`, dan notifikasi pengingat yang dikelompokkan per tanggal.
+  Jadwal pengingat mengikuti N4.
+- **Bergantung pada:** PC-503
+
+---
+
+## Fase 6 — Bersih-bersih
+
+### PC-601 · Hapus tabel dan kode lama · S
+- **PRD:** §10.7
+- **Kerjakan:** satu rilis setelah PC-105 berjalan di production, drop
+  `customer_points` dan `customer_tokens`. Hapus `CustomerPointsProcessor` dan
+  `CustomerTokensProcessor` beserta stub `not implemented`, rute yang di-comment di
+  `router.go`, dan alias `/customer/points` / `/customer/tokens` setelah aplikasi
+  diperbarui.
+- **Bergantung pada:** PC-106, PC-403, dan konfirmasi bahwa aplikasi sudah tidak
+  memanggil endpoint lama.
+
+### PC-602 · Dokumentasi integrasi · S
+- **Kerjakan:** panduan integrasi untuk tim aplikasi dan POS (seperti
+  `integration-weight-based-products.md`): endpoint, kode error PIN, alur kode bayar, dan
+  contoh request/response.
+- **Bergantung pada:** PC-305, PC-402
+
+---
+
+## Yang Bisa Dimulai Sekarang
+
+Bisa dikerjakan paralel tanpa menunggu apa pun:
+- **PC-101** (migrasi wallet) → langsung lanjut **PC-103**, lalu **PC-104**
+- **PC-102** (setting organisasi) → **PC-109**
+- **PC-301** (PIN customer)
+- **PC-303** (payment method EnakPoint)
+
+PC-104 adalah jalur kritis: hampir semua task lain menunggunya.

internal/app/app.go

@@ -165,6 +165,8 @@ func (a *App) Initialize(cfg *config.Config) error {
 		services.customerOrderPaymentService,
 		services.customerWalletService,
 		services.customerDeviceService,
+		services.customerOutletService,
+		services.customerOrderService,
 		a.redisClient,
 	)
 
@@ -403,6 +405,8 @@ type processors struct {
 	walletTransferProcessor             *processor.WalletTransferProcessor
 	walletTraceProcessor                *processor.WalletTraceProcessor
 	customerDeviceProcessor             *processor.CustomerDeviceProcessor
+	customerOutletProcessor             *processor.CustomerOutletProcessor
+	customerOrderProcessor              *processor.CustomerOrderProcessor
 }
 
 func (a *App) initProcessors(cfg *config.Config, repos *repositories) *processors {
@@ -484,6 +488,8 @@ func (a *App) initProcessors(cfg *config.Config, repos *repositories) *processor
 		walletTransferProcessor:             walletTransferProcessor,
 		walletTraceProcessor:                processor.NewWalletTraceProcessor(repository.NewWalletTraceRepository(a.db)),
 		customerDeviceProcessor:             customerDeviceProcessor,
+		customerOutletProcessor:             processor.NewCustomerOutletProcessor(repository.NewCustomerOutletRepository(a.db), loyaltySettingsProcessor),
+		customerOrderProcessor:              processor.NewCustomerOrderProcessor(repository.NewCustomerOrderRepository(a.db), earningProcessor),
 		walletAdminProcessor:                processor.NewWalletAdminProcessor(repository.NewWalletAdminRepository(a.db), repos.walletQueryRepo, processor.NewWalletProcessor(repos.walletRepo), loyaltySettingsProcessor, repos.txManager),
 	}
 }
@@ -534,6 +540,8 @@ type services struct {
 	customerOrderPaymentService       *service.CustomerOrderPaymentServiceImpl
 	customerWalletService             *service.CustomerWalletServiceImpl
 	customerDeviceService             *service.CustomerDeviceServiceImpl
+	customerOutletService             *service.CustomerOutletServiceImpl
+	customerOrderService              *service.CustomerOrderServiceImpl
 }
 
 func (a *App) initServices(processors *processors, repos *repositories, cfg *config.Config) *services {
@@ -622,6 +630,8 @@ func (a *App) initServices(processors *processors, repos *repositories, cfg *con
 		customerOrderPaymentService:       service.NewCustomerOrderPaymentService(processors.orderProcessor),
 		customerWalletService:             service.NewCustomerWalletService(processors.walletExchangeProcessor, processors.walletTransferProcessor),
 		customerDeviceService:             service.NewCustomerDeviceService(processors.customerDeviceProcessor),
+		customerOutletService:             service.NewCustomerOutletService(processors.customerOutletProcessor),
+		customerOrderService:              service.NewCustomerOrderService(processors.customerOrderProcessor),
 	}
 }
 

internal/constants/error.go

@@ -52,7 +52,6 @@ const (
 	TableEntity                          = "table"
 	// Gamification entities
 	CustomerPointsEntity            = "customer_points"
-	CustomerTokensEntity            = "customer_tokens"
 	TierEntity                      = "tier"
 	GameEntity                      = "game"
 	GamePrizeEntity                 = "game_prize"

internal/contract/campaign_contract.go

@@ -12,7 +12,7 @@ import (
 type CreateCampaignRequest struct {
 	Name        string             `json:"name" binding:"required,min=1,max=150"`
 	Description *string            `json:"description,omitempty"`
-	Type        string             `json:"type" binding:"required,oneof=REWARD POINTS COINS TOKENS MIXED"`
+	Type        string             `json:"type" binding:"required,oneof=REWARD POINTS COINS MIXED"`
 	StartDate   time.Time          `json:"start_date" binding:"required"`
 	EndDate     time.Time          `json:"end_date" binding:"required"`
 	IsActive    bool               `json:"is_active"`
@@ -25,7 +25,7 @@ type UpdateCampaignRequest struct {
 	ID          uuid.UUID          `json:"id" binding:"required"`
 	Name        string             `json:"name" binding:"required,min=1,max=150"`
 	Description *string            `json:"description,omitempty"`
-	Type        string             `json:"type" binding:"required,oneof=REWARD POINTS COINS TOKENS MIXED"`
+	Type        string             `json:"type" binding:"required,oneof=REWARD POINTS COINS MIXED"`
 	StartDate   time.Time          `json:"start_date" binding:"required"`
 	EndDate     time.Time          `json:"end_date" binding:"required"`
 	IsActive    bool               `json:"is_active"`
@@ -58,7 +58,7 @@ type CreateCampaignRuleRequest struct {
 	CampaignID     uuid.UUID          `json:"campaign_id" binding:"required"`
 	RuleType       string             `json:"rule_type" binding:"required,oneof=TIER SPEND PRODUCT CATEGORY DAY LOCATION"`
 	ConditionValue *string            `json:"condition_value,omitempty"`
-	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS TOKENS REWARD"`
+	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS REWARD"`
 	RewardValue    *int64             `json:"reward_value,omitempty"`
 	RewardSubtype  *string            `json:"reward_subtype,omitempty"`
 	RewardRefID    *uuid.UUID         `json:"reward_ref_id,omitempty"`
@@ -70,7 +70,7 @@ type UpdateCampaignRuleRequest struct {
 	CampaignID     uuid.UUID          `json:"campaign_id" binding:"required"`
 	RuleType       string             `json:"rule_type" binding:"required,oneof=TIER SPEND PRODUCT CATEGORY DAY LOCATION"`
 	ConditionValue *string            `json:"condition_value,omitempty"`
-	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS TOKENS REWARD"`
+	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS REWARD"`
 	RewardValue    *int64             `json:"reward_value,omitempty"`
 	RewardSubtype  *string            `json:"reward_subtype,omitempty"`
 	RewardRefID    *uuid.UUID         `json:"reward_ref_id,omitempty"`
@@ -142,7 +142,7 @@ type ListCampaignRulesResponse struct {
 type CampaignRuleStruct struct {
 	RuleType       string             `json:"rule_type" binding:"required,oneof=TIER SPEND PRODUCT CATEGORY DAY LOCATION"`
 	ConditionValue *string            `json:"condition_value,omitempty"`
-	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS TOKENS REWARD"`
+	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS REWARD"`
 	RewardValue    *int64             `json:"reward_value,omitempty"`
 	RewardSubtype  *string            `json:"reward_subtype,omitempty"`
 	RewardRefID    *uuid.UUID         `json:"reward_ref_id,omitempty"`

internal/contract/customer_auth_contract.go

@@ -16,6 +16,10 @@ type RegisterStartRequest struct {
 	PhoneNumber string `json:"phone_number" binding:"required"`
 	Name        string `json:"name" binding:"required"`
 	BirthDate   string `json:"birth_date" binding:"required"`
+	// The organization (brand) the customer registers with. A customer belongs to one
+	// organization. Optional: when it is left out and the database has exactly one
+	// organization, the customer joins that one.
+	OrganizationID string `json:"organization_id,omitempty"`
 }
 
 type RegisterVerifyOtpRequest struct {

internal/contract/customer_points_contract.go

@@ -25,26 +25,6 @@ type PointsHistoryItem struct {
 	CreatedAt   time.Time `json:"created_at"`
 }
 
-type GetCustomerTokensResponse struct {
-	Status  string                         `json:"status"`
-	Message string                         `json:"message"`
-	Data    *GetCustomerTokensResponseData `json:"data,omitempty"`
-}
-
-type GetCustomerTokensResponseData struct {
-	TotalTokens   int64               `json:"total_tokens"`
-	TokensHistory []TokensHistoryItem `json:"tokens_history,omitempty"`
-	LastUpdated   time.Time           `json:"last_updated"`
-}
-
-type TokensHistoryItem struct {
-	ID          string    `json:"id"`
-	Tokens      int64     `json:"tokens"`
-	Type        string    `json:"type"` // EARNED, REDEEMED, EXPIRED
-	Description string    `json:"description"`
-	CreatedAt   time.Time `json:"created_at"`
-}
-
 type GetCustomerWalletResponse struct {
 	Status  string                         `json:"status"`
 	Message string                         `json:"message"`
@@ -53,8 +33,6 @@ type GetCustomerWalletResponse struct {
 
 type GetCustomerWalletResponseData struct {
 	TotalPoints   int64               `json:"total_points"`
-	TotalTokens   int64               `json:"total_tokens"`
 	PointsHistory []PointsHistoryItem `json:"points_history,omitempty"`
-	TokensHistory []TokensHistoryItem `json:"tokens_history,omitempty"`
 	LastUpdated   time.Time           `json:"last_updated"`
 }

internal/contract/game_play_contract.go

@@ -14,13 +14,11 @@ type CreateGamePlayRequest struct {
 }
 
 type GamePlayResponse struct {
-	ID         uuid.UUID  `json:"id"`
-	GameID     uuid.UUID  `json:"game_id"`
-	CustomerID uuid.UUID  `json:"customer_id"`
-	PrizeID    *uuid.UUID `json:"prize_id,omitempty"`
-	CoinsUsed  int        `json:"coins_used"`
-	// Deprecated: the same as CoinsUsed, kept until the apps read coins_used.
-	TokenUsed  int                `json:"token_used"`
+	ID         uuid.UUID          `json:"id"`
+	GameID     uuid.UUID          `json:"game_id"`
+	CustomerID uuid.UUID          `json:"customer_id"`
+	PrizeID    *uuid.UUID         `json:"prize_id,omitempty"`
+	CoinsUsed  int                `json:"coins_used"`
 	RandomSeed *string            `json:"random_seed,omitempty"`
 	CreatedAt  time.Time          `json:"created_at"`
 	Game       *GameResponse      `json:"game,omitempty"`
@@ -35,7 +33,7 @@ type ListGamePlaysRequest struct {
 	GameID     *uuid.UUID `json:"game_id"`
 	CustomerID *uuid.UUID `json:"customer_id"`
 	PrizeID    *uuid.UUID `json:"prize_id"`
-	SortBy     string     `json:"sort_by" validate:"omitempty,oneof=created_at coins_used token_used"`
+	SortBy     string     `json:"sort_by" validate:"omitempty,oneof=created_at coins_used"`
 	SortOrder  string     `json:"sort_order" validate:"omitempty,oneof=asc desc"`
 }
 
@@ -58,6 +56,4 @@ type PlayGameResponse struct {
 	GamePlay       GamePlayResponse   `json:"game_play"`
 	PrizeWon       *GamePrizeResponse `json:"prize_won,omitempty"`
 	CoinsRemaining int64              `json:"coins_remaining"`
-	// Deprecated: the same as CoinsRemaining, kept until the apps read coins_remaining.
-	TokensRemaining int64 `json:"tokens_remaining"`
 }

internal/contract/order_contract.go

@@ -121,7 +121,7 @@ type OrderItemResponse struct {
 	Status           string                   `json:"status"`
 	CreatedAt        time.Time                `json:"created_at"`
 	UpdatedAt        time.Time                `json:"updated_at"`
-	PrinterType      string                   `json:"printer_type"`
+	PrinterTypes     []string                 `json:"printer_types"`
 	PrintToChecker   bool                     `json:"print_to_checker"`
 	PaidQuantity     int                      `json:"paid_quantity"`
 }

internal/contract/product_contract.go

@@ -16,7 +16,7 @@ type CreateProductRequest struct {
 	Cost            *float64                      `json:"cost,omitempty" validate:"omitempty,min=0"`
 	BusinessType    *string                       `json:"business_type,omitempty"`
 	ImageURL        *string                       `json:"image_url,omitempty" validate:"omitempty,max=500"`
-	PrinterType     *string                       `json:"printer_type,omitempty" validate:"omitempty,max=50"`
+	PrinterTypes    []string                      `json:"printer_types,omitempty" validate:"omitempty,dive,max=50"`
 	PrintToChecker  *bool                         `json:"print_to_checker,omitempty"`
 	UnitID          *uuid.UUID                    `json:"unit_id,omitempty"`
 	SellBy          *string                       `json:"sell_by,omitempty" validate:"omitempty,oneof=unit weight"`
@@ -38,7 +38,7 @@ type UpdateProductRequest struct {
 	Cost           *float64               `json:"cost,omitempty" validate:"omitempty,min=0"`
 	BusinessType   *string                `json:"business_type,omitempty"`
 	ImageURL       *string                `json:"image_url,omitempty" validate:"omitempty,max=500"`
-	PrinterType    *string                `json:"printer_type,omitempty" validate:"omitempty,max=50"`
+	PrinterTypes   []string               `json:"printer_types,omitempty" validate:"omitempty,dive,max=50"` // Replaces the whole list when sent
 	PrintToChecker *bool                  `json:"print_to_checker,omitempty"`
 	UnitID         *uuid.UUID             `json:"unit_id,omitempty"`
 	SellBy         *string                `json:"sell_by,omitempty" validate:"omitempty,oneof=unit weight"`
@@ -76,7 +76,7 @@ type ProductResponse struct {
 	Cost           float64                      `json:"cost"`
 	BusinessType   string                       `json:"business_type"`
 	ImageURL       *string                      `json:"image_url"`
-	PrinterType    string                       `json:"printer_type"`
+	PrinterTypes   []string                     `json:"printer_types"`
 	UnitID         *uuid.UUID                   `json:"unit_id,omitempty"`
 	SellBy         string                       `json:"sell_by"`
 	PrintToChecker bool                         `json:"print_to_checker"`

internal/contract/spin_game_contract.go

@@ -17,6 +17,4 @@ type SpinGameResponseData struct {
 	GamePlay       GamePlayResponse           `json:"game_play"`
 	PrizeWon       *CustomerGamePrizeResponse `json:"prize_won,omitempty"`
 	CoinsRemaining int64                      `json:"coins_remaining"`
-	// Deprecated: the same as CoinsRemaining, kept until the apps read coins_remaining.
-	TokensRemaining int64 `json:"tokens_remaining"`
 }

internal/entities/campaign.go

@@ -16,27 +16,6 @@ const (
 	CampaignTypeMixed  CampaignType = "MIXED"
 )
 
-// legacyCampaignTokens is what COINS was called before tokens became EnakCoin
-// (docs/prd-point-coin.md §10). Requests may still send it; it is stored as COINS.
-const legacyCampaignTokens = "TOKENS"
-
-// NormalizeCampaignType maps the legacy TOKENS to COINS and leaves anything else as is.
-func NormalizeCampaignType(t string) CampaignType {
-	if t == legacyCampaignTokens {
-		return CampaignTypeCoins
-	}
-	return CampaignType(t)
-}
-
-// NormalizeCampaignRewardType maps the legacy TOKENS to COINS and leaves anything
-// else as is.
-func NormalizeCampaignRewardType(t string) CampaignRewardType {
-	if t == legacyCampaignTokens {
-		return CampaignRewardTypeCoins
-	}
-	return CampaignRewardType(t)
-}
-
 type RuleType string
 
 const (

internal/entities/campaign_test.go

@@ -1,18 +0,0 @@
-package entities
-
-import (
-	"testing"
-
-	"github.com/stretchr/testify/assert"
-)
-
-func TestNormalizeCampaignTypesMapsLegacyTokensToCoins(t *testing.T) {
-	assert.Equal(t, CampaignTypeCoins, NormalizeCampaignType("TOKENS"))
-	assert.Equal(t, CampaignTypeCoins, NormalizeCampaignType("COINS"))
-	assert.Equal(t, CampaignTypePoints, NormalizeCampaignType("POINTS"))
-	assert.Equal(t, CampaignType(""), NormalizeCampaignType(""), "an empty filter stays empty")
-
-	assert.Equal(t, CampaignRewardTypeCoins, NormalizeCampaignRewardType("TOKENS"))
-	assert.Equal(t, CampaignRewardTypeReward, NormalizeCampaignRewardType("REWARD"))
-	assert.Equal(t, CampaignRewardType(""), NormalizeCampaignRewardType(""))
-}

internal/entities/product.go

@@ -1,6 +1,7 @@
 package entities
 
 import (
+	"strings"
 	"time"
 
 	"github.com/google/uuid"
@@ -8,24 +9,26 @@ import (
 )
 
 type Product struct {
-	ID             uuid.UUID  `gorm:"type:uuid;primary_key;default:gen_random_uuid()" json:"id"`
-	OrganizationID uuid.UUID  `gorm:"type:uuid;not null;index" json:"organization_id" validate:"required"`
-	CategoryID     uuid.UUID  `gorm:"type:uuid;not null;index" json:"category_id" validate:"required"`
-	SKU            *string    `gorm:"size:100;index" json:"sku"`
-	Name           string     `gorm:"not null;size:255" json:"name" validate:"required,min=1,max=255"`
-	Description    *string    `gorm:"type:text" json:"description"`
-	Price          float64    `gorm:"type:decimal(10,2);not null" json:"price" validate:"required,min=0"`
-	Cost           float64    `gorm:"type:decimal(10,2);default:0.00" json:"cost" validate:"min=0"`
-	BusinessType   string     `gorm:"size:50;default:'restaurant'" json:"business_type"`
-	ImageURL       *string    `gorm:"size:500" json:"image_url"`
-	PrinterType    string     `gorm:"size:50;default:'kitchen'" json:"printer_type"`
-	UnitID         *uuid.UUID `gorm:"type:uuid;index" json:"unit_id"`
-	SellBy         string     `gorm:"size:20;default:'unit'" json:"sell_by"`
-	HasIngredients bool       `gorm:"default:false" json:"has_ingredients"`
-	Metadata       Metadata   `gorm:"type:jsonb;default:'{}'" json:"metadata"`
-	IsActive       bool       `gorm:"default:true" json:"is_active"`
-	CreatedAt      time.Time  `gorm:"autoCreateTime" json:"created_at"`
-	UpdatedAt      time.Time  `gorm:"autoUpdateTime" json:"updated_at"`
+	ID             uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()" json:"id"`
+	OrganizationID uuid.UUID `gorm:"type:uuid;not null;index" json:"organization_id" validate:"required"`
+	CategoryID     uuid.UUID `gorm:"type:uuid;not null;index" json:"category_id" validate:"required"`
+	SKU            *string   `gorm:"size:100;index" json:"sku"`
+	Name           string    `gorm:"not null;size:255" json:"name" validate:"required,min=1,max=255"`
+	Description    *string   `gorm:"type:text" json:"description"`
+	Price          float64   `gorm:"type:decimal(10,2);not null" json:"price" validate:"required,min=0"`
+	Cost           float64   `gorm:"type:decimal(10,2);default:0.00" json:"cost" validate:"min=0"`
+	BusinessType   string    `gorm:"size:50;default:'restaurant'" json:"business_type"`
+	ImageURL       *string   `gorm:"size:500" json:"image_url"`
+	// PrinterTypes are the stations the product is printed at. Set them through
+	// SetPrinterTypes.
+	PrinterTypes   StringSlice `gorm:"type:jsonb;not null;default:'[\"kitchen\"]'" json:"printer_types"`
+	UnitID         *uuid.UUID  `gorm:"type:uuid;index" json:"unit_id"`
+	SellBy         string      `gorm:"size:20;default:'unit'" json:"sell_by"`
+	HasIngredients bool        `gorm:"default:false" json:"has_ingredients"`
+	Metadata       Metadata    `gorm:"type:jsonb;default:'{}'" json:"metadata"`
+	IsActive       bool        `gorm:"default:true" json:"is_active"`
+	CreatedAt      time.Time   `gorm:"autoCreateTime" json:"created_at"`
+	UpdatedAt      time.Time   `gorm:"autoUpdateTime" json:"updated_at"`
 
 	Organization        Organization         `gorm:"foreignKey:OrganizationID" json:"organization,omitempty"`
 	Category            Category             `gorm:"foreignKey:CategoryID" json:"category,omitempty"`
@@ -48,6 +51,32 @@ func (Product) TableName() string {
 	return "products"
 }
 
+// SetPrinterTypes records the stations the product is printed at, in order, dropping
+// blanks and repeats.
+func (p *Product) SetPrinterTypes(printerTypes []string) {
+	cleaned := StringSlice{}
+	seen := make(map[string]bool, len(printerTypes))
+	for _, printerType := range printerTypes {
+		printerType = strings.TrimSpace(printerType)
+		if printerType == "" || seen[printerType] {
+			continue
+		}
+		seen[printerType] = true
+		cleaned = append(cleaned, printerType)
+	}
+
+	p.PrinterTypes = cleaned
+}
+
+// GetPrinterTypes returns the stations the product is printed at, never nil, so a
+// response always carries a list. A product that was not loaded has none.
+func (p *Product) GetPrinterTypes() []string {
+	if p.PrinterTypes == nil {
+		return []string{}
+	}
+	return []string(p.PrinterTypes)
+}
+
 type ProductVariant struct {
 	ID            uuid.UUID `gorm:"type:uuid;primary_key;default:gen_random_uuid()" json:"id"`
 	ProductID     uuid.UUID `gorm:"type:uuid;not null;index" json:"product_id" validate:"required"`

internal/handler/customer_order_handler.go

@@ -0,0 +1,49 @@
+package handler
+
+import (
+	"github.com/gin-gonic/gin"
+
+	"apskel-pos-be/internal/constants"
+	"apskel-pos-be/internal/contract"
+	"apskel-pos-be/internal/models"
+	"apskel-pos-be/internal/service"
+	"apskel-pos-be/internal/util"
+)
+
+// CustomerOrderHandler serves the customer app's order history.
+type CustomerOrderHandler struct {
+	orders service.CustomerOrderService
+}
+
+func NewCustomerOrderHandler(orders service.CustomerOrderService) *CustomerOrderHandler {
+	return &CustomerOrderHandler{orders: orders}
+}
+
+// List is GET /customer/orders?page=&limit=.
+func (h *CustomerOrderHandler) List(c *gin.Context) {
+	customerID, ok := customerIDFromGin(c, "CustomerOrderHandler::List")
+	if !ok {
+		return
+	}
+	var query models.ListCustomerOrdersQuery
+	if err := c.ShouldBindQuery(&query); err != nil {
+		util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{
+			contract.NewResponseError(constants.MalformedFieldErrorCode, constants.RequestEntity, "page and limit must be whole numbers"),
+		}), "CustomerOrderHandler::List")
+		return
+	}
+	util.HandleResponse(c.Writer, c.Request, h.orders.List(c.Request.Context(), customerID, query), "CustomerOrderHandler::List")
+}
+
+// Detail is GET /customer/orders/:id.
+func (h *CustomerOrderHandler) Detail(c *gin.Context) {
+	customerID, ok := customerIDFromGin(c, "CustomerOrderHandler::Detail")
+	if !ok {
+		return
+	}
+	orderID, ok := parseUUIDParam(c, "id", "CustomerOrderHandler::Detail")
+	if !ok {
+		return
+	}
+	util.HandleResponse(c.Writer, c.Request, h.orders.Detail(c.Request.Context(), customerID, orderID), "CustomerOrderHandler::Detail")
+}

internal/handler/customer_outlet_handler.go

@@ -0,0 +1,26 @@
+package handler
+
+import (
+	"github.com/gin-gonic/gin"
+
+	"apskel-pos-be/internal/service"
+	"apskel-pos-be/internal/util"
+)
+
+// CustomerOutletHandler serves GET /customer/outlets.
+type CustomerOutletHandler struct {
+	outlets service.CustomerOutletService
+}
+
+func NewCustomerOutletHandler(outlets service.CustomerOutletService) *CustomerOutletHandler {
+	return &CustomerOutletHandler{outlets: outlets}
+}
+
+// List returns the active outlets of the customer's organization.
+func (h *CustomerOutletHandler) List(c *gin.Context) {
+	customerID, ok := customerIDFromGin(c, "CustomerOutletHandler::List")
+	if !ok {
+		return
+	}
+	util.HandleResponse(c.Writer, c.Request, h.outlets.List(c.Request.Context(), customerID), "CustomerOutletHandler::List")
+}

internal/handler/customer_points_handler.go

@@ -59,40 +59,6 @@ func (h *CustomerPointsHandler) GetCustomerPoints(c *gin.Context) {
 	util.HandleResponse(c.Writer, c.Request, contract.BuildSuccessResponse(response), "CustomerPointsHandler::GetCustomerPoints")
 }
 
-func (h *CustomerPointsHandler) GetCustomerTokens(c *gin.Context) {
-	ctx := c.Request.Context()
-
-	// Get customer ID from context (set by middleware)
-	customerID, exists := c.Get("customer_id")
-	if !exists {
-		logger.FromContext(ctx).Error("Customer ID not found in context")
-		util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{
-			contract.NewResponseError(constants.ValidationErrorCode, constants.AuthHandlerEntity, "Customer ID not found"),
-		}), "CustomerPointsHandler::GetCustomerTokens")
-		return
-	}
-
-	customerIDStr, ok := customerID.(string)
-	if !ok {
-		logger.FromContext(ctx).Error("Invalid customer ID type in context")
-		util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{
-			contract.NewResponseError(constants.ValidationErrorCode, constants.AuthHandlerEntity, "Invalid customer ID"),
-		}), "CustomerPointsHandler::GetCustomerTokens")
-		return
-	}
-
-	response, err := h.customerPointsService.GetCustomerTokens(ctx, customerIDStr)
-	if err != nil {
-		logger.FromContext(ctx).WithError(err).Error("CustomerPointsHandler::GetCustomerTokens -> service call failed")
-		util.HandleResponse(c.Writer, c.Request, contract.BuildErrorResponse([]*contract.ResponseError{
-			contract.NewResponseError(walletErrorCode(err), constants.RequestEntity, err.Error()),
-		}), "CustomerPointsHandler::GetCustomerTokens")
-		return
-	}
-
-	util.HandleResponse(c.Writer, c.Request, contract.BuildSuccessResponse(response), "CustomerPointsHandler::GetCustomerTokens")
-}
-
 func (h *CustomerPointsHandler) GetCustomerWallet(c *gin.Context) {
 	ctx := c.Request.Context()
 

internal/handler/customer_wallet_db_test.go

@@ -25,7 +25,7 @@ import (
 )
 
 // Drives the customer wallet endpoints over HTTP down to Postgres, to show the app
-// gets the right numbers from the new endpoints and from the old /points, /tokens
+// gets the right numbers from the new endpoints and from the old /points
 // and /wallet shapes. Needs TEST_DATABASE_URL pointing at a migrated database; see
 // internal/repository/wallet_repository_test.go.
 func TestCustomerWalletEndpoints_AgainstPostgres(t *testing.T) {
@@ -111,7 +111,6 @@ func TestCustomerWalletEndpoints_AgainstPostgres(t *testing.T) {
 	}{{"/a", customer}, {"/b", other}, {"/gone", uuid.New()}} {
 		g := router.Group(who.prefix, as(who.id))
 		g.GET("/points", h.GetCustomerPoints)
-		g.GET("/tokens", h.GetCustomerTokens)
 		g.GET("/wallet", h.GetCustomerWallet)
 		g.GET("/wallet/transactions", h.GetCustomerWalletTransactions)
 	}
@@ -128,16 +127,12 @@ func TestCustomerWalletEndpoints_AgainstPostgres(t *testing.T) {
 		return body["data"].(map[string]any)["data"].(map[string]any)
 	}
 
-	// Old app: /points and /tokens keep their shape and show the spendable balance.
+	// Old app: /points keeps its shape and shows the spendable balance.
 	status, body := get("/a/points")
 	require.Equal(t, http.StatusOK, status, body)
 	assert.EqualValues(t, 250, inner(body)["total_points"], "300 - 50; the expired 20 is not spendable")
 	assert.Len(t, inner(body)["points_history"], 3)
 
-	status, body = get("/a/tokens")
-	require.Equal(t, http.StatusOK, status, body)
-	assert.EqualValues(t, 8, inner(body)["total_tokens"])
-
 	// /wallet: new fields, with the old ones still there.
 	status, body = get("/a/wallet")
 	require.Equal(t, http.StatusOK, status, body)
@@ -151,9 +146,10 @@ func TestCustomerWalletEndpoints_AgainstPostgres(t *testing.T) {
 	assert.Equal(t, map[string]any{"amount": float64(250), "date": time.Date(next, 7, 2, 0, 0, 0, 0, time.UTC).Format("2006-01-02")},
 		nearest["point"], "both lots fall on 2 July in Jakarta although they are on different UTC days")
 	assert.Nil(t, nearest["coin"])
-	for _, legacy := range []string{"total_points", "total_tokens", "points_history", "tokens_history", "last_updated"} {
+	for _, legacy := range []string{"total_points", "points_history", "last_updated"} {
 		assert.Contains(t, w, legacy)
 	}
+	assert.NotContains(t, w, "total_tokens", "tokens are gone; EnakCoin is coin_balance")
 	assert.EqualValues(t, 250, w["total_points"])
 
 	recent := w["recent_transactions"].([]any)

internal/mappers/campaign_mapper.go

@@ -71,7 +71,7 @@ func ToCampaignEntity(request *contract.CreateCampaignRequest) *entities.Campaig
 	return &entities.Campaign{
 		Name:        request.Name,
 		Description: request.Description,
-		Type:        entities.NormalizeCampaignType(request.Type),
+		Type:        entities.CampaignType(request.Type),
 		StartDate:   request.StartDate,
 		EndDate:     request.EndDate,
 		IsActive:    request.IsActive,
@@ -91,7 +91,7 @@ func ToCampaignEntityFromUpdate(request *contract.UpdateCampaignRequest) *entiti
 		ID:          request.ID,
 		Name:        request.Name,
 		Description: request.Description,
-		Type:        entities.NormalizeCampaignType(request.Type),
+		Type:        entities.CampaignType(request.Type),
 		StartDate:   request.StartDate,
 		EndDate:     request.EndDate,
 		IsActive:    request.IsActive,
@@ -118,7 +118,7 @@ func ToCampaignRuleEntity(request *contract.CampaignRuleStruct, campaignID uuid.
 		CampaignID:     campaignID,
 		RuleType:       entities.RuleType(request.RuleType),
 		ConditionValue: request.ConditionValue,
-		RewardType:     entities.NormalizeCampaignRewardType(request.RewardType),
+		RewardType:     entities.CampaignRewardType(request.RewardType),
 		RewardValue:    request.RewardValue,
 		RewardSubtype:  rewardSubtype,
 		RewardRefID:    request.RewardRefID,
@@ -142,7 +142,7 @@ func ToCampaignRuleEntityFromUpdate(request *contract.CampaignRuleStruct, campai
 		CampaignID:     campaignID,
 		RuleType:       entities.RuleType(request.RuleType),
 		ConditionValue: request.ConditionValue,
-		RewardType:     entities.NormalizeCampaignRewardType(request.RewardType),
+		RewardType:     entities.CampaignRewardType(request.RewardType),
 		RewardValue:    request.RewardValue,
 		RewardSubtype:  rewardSubtype,
 		RewardRefID:    request.RewardRefID,

internal/mappers/order_mapper.go

@@ -149,7 +149,7 @@ func OrderItemEntityToResponse(item *entities.OrderItem, outletID uuid.UUID) *mo
 		Status:              constants.OrderItemStatus(item.Status),
 		CreatedAt:           item.CreatedAt,
 		UpdatedAt:           item.UpdatedAt,
-		PrinterType:         item.Product.PrinterType,
+		PrinterTypes:        item.Product.GetPrinterTypes(),
 		PrintToChecker:      printToChecker,
 	}
 

internal/mappers/product_mapper.go

@@ -24,7 +24,7 @@ func ProductEntityToModel(entity *entities.Product) *models.Product {
 		Cost:           entity.Cost,
 		BusinessType:   constants.BusinessType(entity.BusinessType),
 		ImageURL:       entity.ImageURL,
-		PrinterType:    entity.PrinterType,
+		PrinterTypes:   entity.GetPrinterTypes(),
 		UnitID:         entity.UnitID,
 		SellBy:         entity.SellBy,
 		HasIngredients: entity.HasIngredients,
@@ -51,7 +51,7 @@ func ProductModelToEntity(model *models.Product) *entities.Product {
 		Cost:           model.Cost,
 		BusinessType:   string(model.BusinessType),
 		ImageURL:       model.ImageURL,
-		PrinterType:    model.PrinterType,
+		PrinterTypes:   entities.StringSlice(model.PrinterTypes),
 		UnitID:         model.UnitID,
 		SellBy:         model.SellBy,
 		HasIngredients: model.HasIngredients,
@@ -77,11 +77,6 @@ func CreateProductRequestToEntity(req *models.CreateProductRequest) *entities.Pr
 		businessType = string(req.BusinessType)
 	}
 
-	printerType := "kitchen"
-	if req.PrinterType != nil && *req.PrinterType != "" {
-		printerType = *req.PrinterType
-	}
-
 	sellBy := constants.SellByUnit
 	if constants.IsValidSellBy(req.SellBy) {
 		sellBy = req.SellBy
@@ -92,7 +87,7 @@ func CreateProductRequestToEntity(req *models.CreateProductRequest) *entities.Pr
 		metadata = entities.Metadata(req.Metadata)
 	}
 
-	return &entities.Product{
+	product := &entities.Product{
 		OrganizationID: req.OrganizationID,
 		CategoryID:     req.CategoryID,
 		SKU:            req.SKU,
@@ -102,12 +97,18 @@ func CreateProductRequestToEntity(req *models.CreateProductRequest) *entities.Pr
 		Cost:           cost,
 		BusinessType:   businessType,
 		ImageURL:       req.ImageURL,
-		PrinterType:    printerType,
 		UnitID:         req.UnitID,
 		SellBy:         sellBy,
 		Metadata:       metadata,
 		IsActive:       true, // Default to active
 	}
+
+	product.SetPrinterTypes(req.PrinterTypes)
+	if len(product.PrinterTypes) == 0 {
+		product.SetPrinterTypes([]string{"kitchen"})
+	}
+
+	return product
 }
 
 func ProductEntityToResponse(entity *entities.Product) *models.ProductResponse {
@@ -152,7 +153,7 @@ func ProductEntityToResponse(entity *entities.Product) *models.ProductResponse {
 		Cost:           entity.Cost,
 		BusinessType:   constants.BusinessType(entity.BusinessType),
 		ImageURL:       entity.ImageURL,
-		PrinterType:    entity.PrinterType,
+		PrinterTypes:   entity.GetPrinterTypes(),
 		UnitID:         entity.UnitID,
 		SellBy:         entity.SellBy,
 		Metadata:       map[string]interface{}(entity.Metadata),
@@ -196,8 +197,8 @@ func UpdateProductEntityFromRequest(entity *entities.Product, req *models.Update
 		entity.ImageURL = req.ImageURL
 	}
 
-	if req.PrinterType != nil {
-		entity.PrinterType = *req.PrinterType
+	if req.PrinterTypes != nil {
+		entity.SetPrinterTypes(req.PrinterTypes)
 	}
 
 	if req.UnitID != nil {

internal/mappers/product_mapper_printer_types_test.go

@@ -0,0 +1,102 @@
+package mappers
+
+import (
+	"testing"
+
+	"apskel-pos-be/internal/entities"
+	"apskel-pos-be/internal/models"
+
+	"github.com/google/uuid"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestCreateProductRequestToEntityPrinterTypes(t *testing.T) {
+	tests := []struct {
+		name         string
+		printerTypes []string
+		want         []string
+	}{
+		{
+			name: "nothing sent prints in the kitchen",
+			want: []string{"kitchen"},
+		},
+		{
+			name:         "a meal-and-drink package prints in the kitchen and the bar",
+			printerTypes: []string{"kitchen", "bar"},
+			want:         []string{"kitchen", "bar"},
+		},
+		{
+			name:         "blanks and repeats are dropped",
+			printerTypes: []string{" kitchen ", "", "kitchen", "bar"},
+			want:         []string{"kitchen", "bar"},
+		},
+		{
+			name:         "a list of only blanks falls back to the kitchen",
+			printerTypes: []string{" ", ""},
+			want:         []string{"kitchen"},
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			product := CreateProductRequestToEntity(&models.CreateProductRequest{
+				OrganizationID: uuid.New(),
+				CategoryID:     uuid.New(),
+				Name:           "Paket Makan Minum",
+				PrinterTypes:   tt.printerTypes,
+			})
+
+			assert.Equal(t, entities.StringSlice(tt.want), product.PrinterTypes)
+		})
+	}
+}
+
+func TestUpdateProductEntityFromRequestPrinterTypes(t *testing.T) {
+	tests := []struct {
+		name         string
+		printerTypes []string
+		want         []string
+	}{
+		{
+			name: "a save that does not send printers keeps them",
+			want: []string{"kitchen", "bar"},
+		},
+		{
+			name:         "printer_types replaces the whole list",
+			printerTypes: []string{"bar"},
+			want:         []string{"bar"},
+		},
+		{
+			name:         "an empty printer_types prints nowhere",
+			printerTypes: []string{},
+			want:         []string{},
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			product := &entities.Product{}
+			product.SetPrinterTypes([]string{"kitchen", "bar"})
+
+			UpdateProductEntityFromRequest(product, &models.UpdateProductRequest{PrinterTypes: tt.printerTypes})
+
+			assert.Equal(t, entities.StringSlice(tt.want), product.PrinterTypes)
+		})
+	}
+}
+
+func TestOrderItemEntityToResponsePrinterTypes(t *testing.T) {
+	product := entities.Product{ID: uuid.New(), Name: "Paket Makan Minum"}
+	product.SetPrinterTypes([]string{"kitchen", "bar"})
+
+	response := OrderItemEntityToResponse(&entities.OrderItem{ProductID: product.ID, Product: product}, uuid.New())
+
+	assert.Equal(t, []string{"kitchen", "bar"}, response.PrinterTypes)
+}
+
+func TestProductEntityToResponseAlwaysHasAList(t *testing.T) {
+	// The POS reads printer_types as a list, so a product without one sends [] not null.
+	response := ProductEntityToResponse(&entities.Product{})
+
+	assert.Equal(t, []string{}, response.PrinterTypes)
+}

internal/mappers/spin_game_mapper.go

@@ -36,10 +36,9 @@ func SpinGameResponseDataModelToContract(data *models.SpinGameResponseData) *con
 	}
 
 	return &contract.SpinGameResponseData{
-		GamePlay:        GamePlayResponseModelToContract(&data.GamePlay),
-		PrizeWon:        CustomerGamePrizeResponseModelToContract(data.PrizeWon),
-		CoinsRemaining:  data.CoinsRemaining,
-		TokensRemaining: data.CoinsRemaining,
+		GamePlay:       GamePlayResponseModelToContract(&data.GamePlay),
+		PrizeWon:       CustomerGamePrizeResponseModelToContract(data.PrizeWon),
+		CoinsRemaining: data.CoinsRemaining,
 	}
 }
 
@@ -55,7 +54,6 @@ func GamePlayResponseModelToContract(resp *models.GamePlayResponse) contract.Gam
 		CustomerID: resp.CustomerID,
 		PrizeID:    resp.PrizeID,
 		CoinsUsed:  resp.CoinsUsed,
-		TokenUsed:  resp.CoinsUsed,
 		RandomSeed: resp.RandomSeed,
 		CreatedAt:  resp.CreatedAt,
 		Game:       nil, // Optional field - can be populated separately if needed

internal/models/campaign.go

@@ -11,7 +11,7 @@ import (
 type CreateCampaignRequest struct {
 	Name        string               `json:"name" binding:"required,min=1,max=150"`
 	Description *string              `json:"description,omitempty"`
-	Type        string               `json:"type" binding:"required,oneof=REWARD POINTS COINS TOKENS MIXED"`
+	Type        string               `json:"type" binding:"required,oneof=REWARD POINTS COINS MIXED"`
 	StartDate   time.Time            `json:"start_date" binding:"required"`
 	EndDate     time.Time            `json:"end_date" binding:"required"`
 	IsActive    bool                 `json:"is_active"`
@@ -25,7 +25,7 @@ type UpdateCampaignRequest struct {
 	ID          uuid.UUID            `json:"id" binding:"required"`
 	Name        string               `json:"name" binding:"required,min=1,max=150"`
 	Description *string              `json:"description,omitempty"`
-	Type        string               `json:"type" binding:"required,oneof=REWARD POINTS COINS TOKENS MIXED"`
+	Type        string               `json:"type" binding:"required,oneof=REWARD POINTS COINS MIXED"`
 	StartDate   time.Time            `json:"start_date" binding:"required"`
 	EndDate     time.Time            `json:"end_date" binding:"required"`
 	IsActive    bool                 `json:"is_active"`
@@ -88,7 +88,7 @@ type CreateCampaignRuleRequest struct {
 	CampaignID     uuid.UUID          `json:"campaign_id" binding:"required"`
 	RuleType       string             `json:"rule_type" binding:"required,oneof=TIER SPEND PRODUCT CATEGORY DAY LOCATION"`
 	ConditionValue *string            `json:"condition_value,omitempty"`
-	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS TOKENS REWARD"`
+	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS REWARD"`
 	RewardValue    *int64             `json:"reward_value,omitempty"`
 	RewardSubtype  *string            `json:"reward_subtype,omitempty"`
 	RewardRefID    *uuid.UUID         `json:"reward_ref_id,omitempty"`
@@ -100,7 +100,7 @@ type UpdateCampaignRuleRequest struct {
 	CampaignID     uuid.UUID          `json:"campaign_id" binding:"required"`
 	RuleType       string             `json:"rule_type" binding:"required,oneof=TIER SPEND PRODUCT CATEGORY DAY LOCATION"`
 	ConditionValue *string            `json:"condition_value,omitempty"`
-	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS TOKENS REWARD"`
+	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS REWARD"`
 	RewardValue    *int64             `json:"reward_value,omitempty"`
 	RewardSubtype  *string            `json:"reward_subtype,omitempty"`
 	RewardRefID    *uuid.UUID         `json:"reward_ref_id,omitempty"`
@@ -126,7 +126,7 @@ type ListCampaignRulesResponse struct {
 type CampaignRuleStruct struct {
 	RuleType       string             `json:"rule_type" binding:"required,oneof=TIER SPEND PRODUCT CATEGORY DAY LOCATION"`
 	ConditionValue *string            `json:"condition_value,omitempty"`
-	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS TOKENS REWARD"`
+	RewardType     string             `json:"reward_type" binding:"required,oneof=POINTS COINS REWARD"`
 	RewardValue    *int64             `json:"reward_value,omitempty"`
 	RewardSubtype  *string            `json:"reward_subtype,omitempty"`
 	RewardRefID    *uuid.UUID         `json:"reward_ref_id,omitempty"`

internal/models/customer_order.go

@@ -0,0 +1,74 @@
+package models
+
+import (
+	"time"
+
+	"github.com/google/uuid"
+)
+
+// CustomerOrderSummary is one order in GET /customer/orders.
+type CustomerOrderSummary struct {
+	ID            uuid.UUID `json:"id"`
+	OrderNumber   string    `json:"order_number"`
+	OutletID      uuid.UUID `json:"outlet_id"`
+	OutletName    string    `json:"outlet_name"`
+	OrderType     string    `json:"order_type"`
+	Status        string    `json:"status"`
+	PaymentStatus string    `json:"payment_status"`
+	TotalAmount   float64   `json:"total_amount"`
+	ItemCount     int64     `json:"item_count"`
+	IsVoid        bool      `json:"is_void"`
+	IsRefund      bool      `json:"is_refund"`
+	// EnakPoint and EnakCoin the order earned; 0 when it earned nothing.
+	PointsEarned int64     `json:"points_earned"`
+	CoinsEarned  int64     `json:"coins_earned"`
+	CreatedAt    time.Time `json:"created_at"`
+}
+
+// CustomerOrderDetail is GET /customer/orders/:id.
+type CustomerOrderDetail struct {
+	CustomerOrderSummary
+	TableNumber    *string                `json:"table_number"`
+	Subtotal       float64                `json:"subtotal"`
+	DiscountAmount float64                `json:"discount_amount"`
+	TaxAmount      float64                `json:"tax_amount"`
+	RefundAmount   float64                `json:"refund_amount"`
+	Items          []CustomerOrderItem    `json:"items"`
+	Payments       []CustomerOrderPayment `json:"payments"`
+}
+
+type CustomerOrderItem struct {
+	ID          uuid.UUID `json:"id"`
+	ProductID   uuid.UUID `json:"product_id"`
+	ProductName string    `json:"product_name"`
+	VariantName *string   `json:"variant_name"`
+	Quantity    int       `json:"quantity"`
+	// Set for products sold by weight, in UnitName.
+	Weight         *float64                 `json:"weight,omitempty"`
+	UnitName       *string                  `json:"unit_name,omitempty"`
+	UnitPrice      float64                  `json:"unit_price"`
+	TotalPrice     float64                  `json:"total_price"`
+	RefundQuantity int                      `json:"refund_quantity"`
+	Modifiers      []map[string]interface{} `json:"modifiers"`
+	Notes          *string                  `json:"notes,omitempty"`
+	Status         string                   `json:"status"`
+}
+
+type CustomerOrderPayment struct {
+	ID           uuid.UUID `json:"id"`
+	MethodName   string    `json:"method_name"`
+	MethodType   string    `json:"method_type"`
+	Amount       float64   `json:"amount"`
+	Status       string    `json:"status"`
+	RefundAmount float64   `json:"refund_amount"`
+	// Set for a payment with EnakPoint.
+	PointsUsed *int64    `json:"points_used,omitempty"`
+	PointValue *float64  `json:"point_value,omitempty"`
+	CreatedAt  time.Time `json:"created_at"`
+}
+
+// ListCustomerOrdersQuery is GET /customer/orders.
+type ListCustomerOrdersQuery struct {
+	Page  int `form:"page"`
+	Limit int `form:"limit"`
+}

internal/models/customer_outlet.go

@@ -0,0 +1,16 @@
+package models
+
+import "github.com/google/uuid"
+
+// CustomerOutlet is one outlet in GET /customer/outlets: where the customer can shop,
+// and what the outlet does with EnakPoint and EnakCoin.
+type CustomerOutlet struct {
+	ID      uuid.UUID `json:"id"`
+	Name    string    `json:"name"`
+	Address *string   `json:"address"`
+	// The cashier accepts EnakPoint as payment here.
+	AcceptsPointPayment bool `json:"accepts_point_payment"`
+	// Orders here earn EnakPoint / EnakCoin.
+	EarnsPoints bool `json:"earns_points"`
+	EarnsCoins  bool `json:"earns_coins"`
+}

internal/models/customer_points.go

@@ -25,26 +25,6 @@ type PointsHistoryItem struct {
 	CreatedAt   time.Time `json:"created_at"`
 }
 
-type GetCustomerTokensResponse struct {
-	Status  string                         `json:"status"`
-	Message string                         `json:"message"`
-	Data    *GetCustomerTokensResponseData `json:"data,omitempty"`
-}
-
-type GetCustomerTokensResponseData struct {
-	TotalTokens   int64               `json:"total_tokens"`
-	TokensHistory []TokensHistoryItem `json:"tokens_history,omitempty"`
-	LastUpdated   time.Time           `json:"last_updated"`
-}
-
-type TokensHistoryItem struct {
-	ID          string    `json:"id"`
-	Tokens      int64     `json:"tokens"`
-	Type        string    `json:"type"` // EARNED, REDEEMED, EXPIRED
-	Description string    `json:"description"`
-	CreatedAt   time.Time `json:"created_at"`
-}
-
 type GetCustomerWalletResponse struct {
 	Status  string                         `json:"status"`
 	Message string                         `json:"message"`
@@ -66,8 +46,6 @@ type GetCustomerWalletResponseData struct {
 	// Deprecated: the shape of this endpoint before the wallet, kept for app versions
 	// that still read it. Filled from the wallet like the fields above.
 	TotalPoints   int64               `json:"total_points"`
-	TotalTokens   int64               `json:"total_tokens"`
 	PointsHistory []PointsHistoryItem `json:"points_history,omitempty"`
-	TokensHistory []TokensHistoryItem `json:"tokens_history,omitempty"`
 	LastUpdated   time.Time           `json:"last_updated"`
 }

internal/models/game_play.go

@@ -33,7 +33,7 @@ type ListGamePlaysQuery struct {
 	GameID     *uuid.UUID `query:"game_id"`
 	CustomerID *uuid.UUID `query:"customer_id"`
 	PrizeID    *uuid.UUID `query:"prize_id"`
-	SortBy     string     `query:"sort_by" validate:"omitempty,oneof=created_at coins_used token_used"`
+	SortBy     string     `query:"sort_by" validate:"omitempty,oneof=created_at coins_used"`
 	SortOrder  string     `query:"sort_order" validate:"omitempty,oneof=asc desc"`
 }
 

internal/models/order.go

@@ -218,7 +218,7 @@ type OrderItemResponse struct {
 	Status              constants.OrderItemStatus
 	CreatedAt           time.Time
 	UpdatedAt           time.Time
-	PrinterType         string
+	PrinterTypes        []string
 	PrintToChecker      bool
 	PaidQuantity        int
 }

internal/models/product.go

@@ -18,7 +18,7 @@ type Product struct {
 	Cost           float64
 	BusinessType   constants.BusinessType
 	ImageURL       *string
-	PrinterType    string
+	PrinterTypes   []string
 	SellBy         string
 	UnitID         *uuid.UUID
 	HasIngredients bool
@@ -50,7 +50,7 @@ type CreateProductRequest struct {
 	Cost           float64                `validate:"min=0"`
 	BusinessType   constants.BusinessType `validate:"required"`
 	ImageURL       *string                `validate:"omitempty,max=500"`
-	PrinterType    *string                `validate:"omitempty,max=50"`
+	PrinterTypes   []string               `validate:"omitempty,dive,max=50"`
 	PrintToChecker *bool                  `validate:"omitempty"`
 	UnitID         *uuid.UUID             `validate:"omitempty"`
 	SellBy         string                 `validate:"omitempty,oneof=unit weight"`
@@ -72,7 +72,7 @@ type UpdateProductRequest struct {
 	Price          *float64   `validate:"omitempty,min=0"`
 	Cost           *float64   `validate:"omitempty,min=0"`
 	ImageURL       *string    `validate:"omitempty,max=500"`
-	PrinterType    *string    `validate:"omitempty,max=50"`
+	PrinterTypes   []string   `validate:"omitempty,dive,max=50"` // Replaces the whole list when not nil
 	PrintToChecker *bool      `validate:"omitempty"`
 	UnitID         *uuid.UUID `validate:"omitempty"`
 	SellBy         *string    `validate:"omitempty,oneof=unit weight"`
@@ -112,7 +112,7 @@ type ProductResponse struct {
 	Cost           float64
 	BusinessType   constants.BusinessType
 	ImageURL       *string
-	PrinterType    string
+	PrinterTypes   []string
 	SellBy         string
 	PrintToChecker bool
 	UnitID         *uuid.UUID

internal/processor/campaign_processor.go

@@ -70,7 +70,7 @@ func (p *campaignProcessor) ListCampaigns(ctx context.Context, req *contract.Lis
 		Page:      req.Page,
 		Limit:     req.Limit,
 		Search:    req.Search,
-		Type:      string(entities.NormalizeCampaignType(req.Type)),
+		Type:      req.Type,
 		IsActive:  req.IsActive,
 		ShowOnApp: req.ShowOnApp,
 		StartDate: req.StartDate,
@@ -178,7 +178,7 @@ func (p *campaignRuleProcessor) CreateCampaignRule(ctx context.Context, req *con
 		CampaignID:     req.CampaignID,
 		RuleType:       entities.RuleType(req.RuleType),
 		ConditionValue: req.ConditionValue,
-		RewardType:     entities.NormalizeCampaignRewardType(req.RewardType),
+		RewardType:     entities.CampaignRewardType(req.RewardType),
 		RewardValue:    req.RewardValue,
 		RewardSubtype:  (*entities.RewardSubtype)(req.RewardSubtype),
 		RewardRefID:    req.RewardRefID,
@@ -218,7 +218,7 @@ func (p *campaignRuleProcessor) ListCampaignRules(ctx context.Context, req *cont
 		Limit:      req.Limit,
 		CampaignID: req.CampaignID,
 		RuleType:   req.RuleType,
-		RewardType: string(entities.NormalizeCampaignRewardType(req.RewardType)),
+		RewardType: req.RewardType,
 	}
 
 	// Get from repository
@@ -247,7 +247,7 @@ func (p *campaignRuleProcessor) UpdateCampaignRule(ctx context.Context, req *con
 		CampaignID:     req.CampaignID,
 		RuleType:       entities.RuleType(req.RuleType),
 		ConditionValue: req.ConditionValue,
-		RewardType:     entities.NormalizeCampaignRewardType(req.RewardType),
+		RewardType:     entities.CampaignRewardType(req.RewardType),
 		RewardValue:    req.RewardValue,
 		RewardSubtype:  (*entities.RewardSubtype)(req.RewardSubtype),
 		RewardRefID:    req.RewardRefID,

internal/processor/customer_auth_processor.go

@@ -3,6 +3,7 @@ package processor
 import (
 	"context"
 	"fmt"
+	"strings"
 	"time"
 
 	"apskel-pos-be/internal/contract"
@@ -142,6 +143,13 @@ func (p *customerAuthProcessor) StartRegistration(ctx context.Context, req *cont
 		return nil, fmt.Errorf("phone number already registered")
 	}
 
+	// Resolve the organization before an OTP is sent, rather than failing on a foreign
+	// key at the last step.
+	organizationID, err := p.registrationOrganization(ctx, req.OrganizationID)
+	if err != nil {
+		return nil, err
+	}
+
 	// Generate registration token and create OTP session
 	registrationToken := uuid.New().String()
 
@@ -156,6 +164,7 @@ func (p *customerAuthProcessor) StartRegistration(ctx context.Context, req *cont
 		"registration_token": registrationToken,
 		"name":               req.Name,
 		"birth_date":         req.BirthDate,
+		"organization_id":    organizationID.String(),
 		"step":               "otp_sent",
 	}
 
@@ -294,10 +303,14 @@ func (p *customerAuthProcessor) SetPassword(ctx context.Context, req *contract.R
 		return nil, fmt.Errorf("invalid birth date format: %w", err)
 	}
 
-	defaultOrgID := uuid.MustParse("87bec7c1-e274-4f66-bac5-84e632208470") // This should be configurable
+	orgIDStr, _ := otpSession.Metadata["organization_id"].(string)
+	organizationID, err := uuid.Parse(orgIDStr)
+	if err != nil {
+		return nil, fmt.Errorf("invalid registration data: organization not found, start the registration again")
+	}
 
 	customer := &entities.Customer{
-		OrganizationID: defaultOrgID,
+		OrganizationID: organizationID,
 		Name:           name,
 		PhoneNumber:    &otpSession.PhoneNumber,
 		BirthDate:      &birthDate,
@@ -438,3 +451,37 @@ func (p *customerAuthProcessor) ResendOtp(ctx context.Context, req *contract.Res
 }
 
 // Helper functions - OTP generation is now handled by OtpProcessor
+
+// registrationOrganization is the organization a new customer joins: the one the app
+// sent, which must exist, or, when the app sent none, the only organization there is.
+// With several organizations and none sent there is no way to choose, so it refuses.
+func (p *customerAuthProcessor) registrationOrganization(ctx context.Context, requested string) (uuid.UUID, error) {
+	requested = strings.TrimSpace(requested)
+	if requested != "" {
+		id, err := uuid.Parse(requested)
+		if err != nil {
+			return uuid.Nil, fmt.Errorf("organization_id must be a valid UUID")
+		}
+		exists, err := p.customerAuthRepo.OrganizationExists(ctx, id)
+		if err != nil {
+			return uuid.Nil, err
+		}
+		if !exists {
+			return uuid.Nil, fmt.Errorf("organization not found")
+		}
+		return id, nil
+	}
+
+	ids, err := p.customerAuthRepo.OrganizationIDs(ctx, 2)
+	if err != nil {
+		return uuid.Nil, err
+	}
+	switch len(ids) {
+	case 1:
+		return ids[0], nil
+	case 0:
+		return uuid.Nil, fmt.Errorf("no organization exists to register customers into")
+	default:
+		return uuid.Nil, fmt.Errorf("organization_id is required: there is more than one organization")
+	}
+}

internal/processor/customer_order_processor.go

@@ -0,0 +1,157 @@
+package processor
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/google/uuid"
+
+	"apskel-pos-be/internal/models"
+	"apskel-pos-be/internal/repository"
+)
+
+const (
+	customerOrdersPageLimit = 20
+	customerOrdersMaxLimit  = 100
+)
+
+type orderEarnedReader interface {
+	EarnedByOrders(ctx context.Context, orderIDs []uuid.UUID) (map[uuid.UUID]OrderEarned, error)
+}
+
+// CustomerOrderProcessor serves the customer app's order history: the customer's own
+// orders only, without costs or staff details.
+type CustomerOrderProcessor struct {
+	repo   repository.CustomerOrderRepository
+	earned orderEarnedReader
+}
+
+func NewCustomerOrderProcessor(repo repository.CustomerOrderRepository, earned orderEarnedReader) *CustomerOrderProcessor {
+	return &CustomerOrderProcessor{repo: repo, earned: earned}
+}
+
+// List is GET /customer/orders: the customer's orders across all outlets, newest first.
+func (p *CustomerOrderProcessor) List(ctx context.Context, customerID uuid.UUID, query models.ListCustomerOrdersQuery) (*models.PaginatedResponse[models.CustomerOrderSummary], error) {
+	page, limit := query.Page, query.Limit
+	if page == 0 {
+		page = 1
+	}
+	if limit == 0 {
+		limit = customerOrdersPageLimit
+	}
+	if page < 1 || limit < 1 || limit > customerOrdersMaxLimit {
+		return nil, fmt.Errorf("%w: page must be at least 1 and limit between 1 and %d", ErrInvalidWalletQuery, customerOrdersMaxLimit)
+	}
+
+	rows, total, err := p.repo.ListOrders(ctx, customerID, (page-1)*limit, limit)
+	if err != nil {
+		return nil, err
+	}
+	ids := make([]uuid.UUID, 0, len(rows))
+	for _, r := range rows {
+		ids = append(ids, r.ID)
+	}
+	earned, err := p.earned.EarnedByOrders(ctx, ids)
+	if err != nil {
+		return nil, err
+	}
+	data := make([]models.CustomerOrderSummary, 0, len(rows))
+	for _, r := range rows {
+		data = append(data, customerOrderSummary(r, earned[r.ID]))
+	}
+	return &models.PaginatedResponse[models.CustomerOrderSummary]{
+		Data: data,
+		Pagination: models.Pagination{
+			Page:       page,
+			Limit:      limit,
+			Total:      total,
+			TotalPages: int((total + int64(limit) - 1) / int64(limit)),
+		},
+	}, nil
+}
+
+// Detail is GET /customer/orders/:id. Another customer's order is
+// repository.ErrCustomerOrderNotFound, like one that does not exist.
+func (p *CustomerOrderProcessor) Detail(ctx context.Context, customerID, orderID uuid.UUID) (*models.CustomerOrderDetail, error) {
+	row, err := p.repo.GetOrder(ctx, customerID, orderID)
+	if err != nil {
+		return nil, err
+	}
+	items, err := p.repo.ListItems(ctx, orderID)
+	if err != nil {
+		return nil, err
+	}
+	payments, err := p.repo.ListPayments(ctx, orderID)
+	if err != nil {
+		return nil, err
+	}
+	earned, err := p.earned.EarnedByOrders(ctx, []uuid.UUID{orderID})
+	if err != nil {
+		return nil, err
+	}
+
+	detail := &models.CustomerOrderDetail{
+		CustomerOrderSummary: customerOrderSummary(*row, earned[orderID]),
+		TableNumber:          row.TableNumber,
+		Subtotal:             row.Subtotal,
+		DiscountAmount:       row.DiscountAmount,
+		TaxAmount:            row.TaxAmount,
+		RefundAmount:         row.RefundAmount,
+		Items:                make([]models.CustomerOrderItem, 0, len(items)),
+		Payments:             make([]models.CustomerOrderPayment, 0, len(payments)),
+	}
+	for _, it := range items {
+		modifiers := []map[string]interface{}(it.Modifiers)
+		if modifiers == nil {
+			modifiers = []map[string]interface{}{}
+		}
+		detail.Items = append(detail.Items, models.CustomerOrderItem{
+			ID:             it.ID,
+			ProductID:      it.ProductID,
+			ProductName:    it.ProductName,
+			VariantName:    it.VariantName,
+			Quantity:       it.Quantity,
+			Weight:         it.Weight,
+			UnitName:       it.UnitName,
+			UnitPrice:      it.UnitPrice,
+			TotalPrice:     it.TotalPrice,
+			RefundQuantity: it.RefundQuantity,
+			Modifiers:      modifiers,
+			Notes:          it.Notes,
+			Status:         it.Status,
+		})
+	}
+	for _, pay := range payments {
+		detail.Payments = append(detail.Payments, models.CustomerOrderPayment{
+			ID:           pay.ID,
+			MethodName:   pay.MethodName,
+			MethodType:   pay.MethodType,
+			Amount:       pay.Amount,
+			Status:       pay.Status,
+			RefundAmount: pay.RefundAmount,
+			PointsUsed:   pay.PointsUsed,
+			PointValue:   pay.PointValue,
+			CreatedAt:    pay.CreatedAt,
+		})
+	}
+	return detail, nil
+}
+
+func customerOrderSummary(r repository.CustomerOrderRow, earned OrderEarned) models.CustomerOrderSummary {
+	return models.CustomerOrderSummary{
+		ID:            r.ID,
+		OrderNumber:   r.OrderNumber,
+		OutletID:      r.OutletID,
+		OutletName:    r.OutletName,
+		OrderType:     r.OrderType,
+		Status:        r.Status,
+		PaymentStatus: r.PaymentStatus,
+		TotalAmount:   r.TotalAmount,
+		ItemCount:     r.ItemCount,
+		IsVoid:        r.IsVoid,
+		IsRefund:      r.IsRefund,
+		PointsEarned:  earned.Points,
+		CoinsEarned:   earned.Coins,
+		CreatedAt:     r.CreatedAt,
+	}
+}

internal/processor/customer_order_processor_test.go

@@ -0,0 +1,145 @@
+package processor
+
+import (
+	"context"
+	"testing"
+	"time"
+
+	"github.com/google/uuid"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+
+	"apskel-pos-be/internal/models"
+	"apskel-pos-be/internal/repository"
+)
+
+type customerOrderRepoFake struct {
+	owner    map[uuid.UUID]uuid.UUID // order -> customer
+	orders   []repository.CustomerOrderRow
+	items    map[uuid.UUID][]repository.CustomerOrderItemRow
+	payments map[uuid.UUID][]repository.CustomerOrderPaymentRow
+	offset   int
+	limit    int
+}
+
+func (f *customerOrderRepoFake) ListOrders(_ context.Context, customerID uuid.UUID, offset, limit int) ([]repository.CustomerOrderRow, int64, error) {
+	f.offset, f.limit = offset, limit
+	var mine []repository.CustomerOrderRow
+	for _, o := range f.orders {
+		if f.owner[o.ID] == customerID {
+			mine = append(mine, o)
+		}
+	}
+	return mine, int64(len(mine)), nil
+}
+
+func (f *customerOrderRepoFake) GetOrder(_ context.Context, customerID, orderID uuid.UUID) (*repository.CustomerOrderRow, error) {
+	for _, o := range f.orders {
+		if o.ID == orderID && f.owner[o.ID] == customerID {
+			c := o
+			return &c, nil
+		}
+	}
+	return nil, repository.ErrCustomerOrderNotFound
+}
+
+func (f *customerOrderRepoFake) ListItems(_ context.Context, orderID uuid.UUID) ([]repository.CustomerOrderItemRow, error) {
+	return f.items[orderID], nil
+}
+
+func (f *customerOrderRepoFake) ListPayments(_ context.Context, orderID uuid.UUID) ([]repository.CustomerOrderPaymentRow, error) {
+	return f.payments[orderID], nil
+}
+
+type earnedFake map[uuid.UUID]OrderEarned
+
+func (f earnedFake) EarnedByOrders(_ context.Context, ids []uuid.UUID) (map[uuid.UUID]OrderEarned, error) {
+	out := map[uuid.UUID]OrderEarned{}
+	for _, id := range ids {
+		if e, ok := f[id]; ok {
+			out[id] = e
+		}
+	}
+	return out, nil
+}
+
+func newCustomerOrderTest() (*customerOrderRepoFake, uuid.UUID, uuid.UUID, uuid.UUID) {
+	customer, other := uuid.New(), uuid.New()
+	mine, theirs := uuid.New(), uuid.New()
+	repo := &customerOrderRepoFake{
+		owner: map[uuid.UUID]uuid.UUID{mine: customer, theirs: other},
+		orders: []repository.CustomerOrderRow{
+			{ID: mine, OrderNumber: "ORD-1", OutletName: "Gokuna 1", Status: "completed", PaymentStatus: "completed", Subtotal: 90000, TotalAmount: 99000, ItemCount: 2, CreatedAt: time.Now()},
+			{ID: theirs, OrderNumber: "ORD-2"},
+		},
+	}
+	return repo, customer, mine, theirs
+}
+
+func TestCustomerOrders_ListShowsOnlyTheCustomersOrdersWithEarning(t *testing.T) {
+	repo, customer, mine, _ := newCustomerOrderTest()
+	p := NewCustomerOrderProcessor(repo, earnedFake{mine: {Points: 900, Coins: 3}})
+
+	got, err := p.List(context.Background(), customer, models.ListCustomerOrdersQuery{Page: 2, Limit: 10})
+	require.NoError(t, err)
+	require.Len(t, got.Data, 1)
+	assert.Equal(t, "ORD-1", got.Data[0].OrderNumber)
+	assert.Equal(t, int64(900), got.Data[0].PointsEarned)
+	assert.Equal(t, int64(3), got.Data[0].CoinsEarned)
+	assert.Equal(t, 10, repo.offset, "page 2 of 10 skips the first 10")
+	assert.Equal(t, 10, repo.limit)
+	assert.Equal(t, 2, got.Pagination.Page)
+}
+
+func TestCustomerOrders_ListDefaultsAndLimits(t *testing.T) {
+	repo, customer, _, _ := newCustomerOrderTest()
+	p := NewCustomerOrderProcessor(repo, earnedFake{})
+
+	got, err := p.List(context.Background(), customer, models.ListCustomerOrdersQuery{})
+	require.NoError(t, err)
+	assert.Equal(t, 1, got.Pagination.Page)
+	assert.Equal(t, 20, got.Pagination.Limit)
+
+	for _, q := range []models.ListCustomerOrdersQuery{{Page: -1}, {Limit: 101}, {Limit: -5}} {
+		_, err := p.List(context.Background(), customer, q)
+		assert.ErrorIs(t, err, ErrInvalidWalletQuery, "%+v", q)
+	}
+}
+
+func TestCustomerOrders_DetailHasItemsPaymentsAndEarning(t *testing.T) {
+	repo, customer, mine, _ := newCustomerOrderTest()
+	variant, unit := "Large", "ons"
+	weight := 4.2
+	points, value := int64(12500), 1.0
+	repo.items = map[uuid.UUID][]repository.CustomerOrderItemRow{
+		mine: {
+			{ProductName: "Kopi Susu", VariantName: &variant, Quantity: 2, UnitPrice: 25000, TotalPrice: 50000, Status: "completed"},
+			{ProductName: "Ikan Tude", Quantity: 1, Weight: &weight, UnitName: &unit, UnitPrice: 4500, TotalPrice: 18900, Status: "completed"},
+		},
+	}
+	repo.payments = map[uuid.UUID][]repository.CustomerOrderPaymentRow{
+		mine: {
+			{MethodName: "EnakPoint", MethodType: "point", Amount: 12500, Status: "completed", PointsUsed: &points, PointValue: &value},
+			{MethodName: "Cash", MethodType: "cash", Amount: 86500, Status: "completed"},
+		},
+	}
+	p := NewCustomerOrderProcessor(repo, earnedFake{mine: {Points: 865}})
+
+	got, err := p.Detail(context.Background(), customer, mine)
+	require.NoError(t, err)
+	assert.Equal(t, "Gokuna 1", got.OutletName)
+	assert.Equal(t, float64(90000), got.Subtotal)
+	assert.Equal(t, int64(865), got.PointsEarned)
+	require.Len(t, got.Items, 2)
+	assert.Equal(t, "Large", *got.Items[0].VariantName)
+	assert.Equal(t, []map[string]interface{}{}, got.Items[0].Modifiers, "no modifiers is an empty list, not null")
+	assert.Equal(t, 4.2, *got.Items[1].Weight)
+	require.Len(t, got.Payments, 2)
+	assert.Equal(t, int64(12500), *got.Payments[0].PointsUsed)
+}
+
+func TestCustomerOrders_AnotherCustomersOrderIsNotFound(t *testing.T) {
+	repo, customer, _, theirs := newCustomerOrderTest()
+	_, err := NewCustomerOrderProcessor(repo, earnedFake{}).Detail(context.Background(), customer, theirs)
+	assert.ErrorIs(t, err, repository.ErrCustomerOrderNotFound)
+}

internal/processor/customer_outlet_processor.go

@@ -0,0 +1,49 @@
+package processor
+
+import (
+	"context"
+
+	"github.com/google/uuid"
+
+	"apskel-pos-be/internal/models"
+	"apskel-pos-be/internal/repository"
+)
+
+// CustomerOutletProcessor lists the outlets the customer app shows: the active
+// outlets of the customer's organization, where their wallet can be used (K4).
+type CustomerOutletProcessor struct {
+	repo     repository.CustomerOutletRepository
+	settings outletSettingsReader
+}
+
+func NewCustomerOutletProcessor(repo repository.CustomerOutletRepository, settings outletSettingsReader) *CustomerOutletProcessor {
+	return &CustomerOutletProcessor{repo: repo, settings: settings}
+}
+
+// List is GET /customer/outlets.
+func (p *CustomerOutletProcessor) List(ctx context.Context, customerID uuid.UUID) ([]models.CustomerOutlet, error) {
+	organizationID, err := p.repo.CustomerOrganizationID(ctx, customerID)
+	if err != nil {
+		return nil, err
+	}
+	outlets, err := p.repo.ListActiveOutlets(ctx, organizationID)
+	if err != nil {
+		return nil, err
+	}
+	list := make([]models.CustomerOutlet, 0, len(outlets))
+	for _, o := range outlets {
+		settings, err := p.settings.Outlet(ctx, o.ID)
+		if err != nil {
+			return nil, err
+		}
+		list = append(list, models.CustomerOutlet{
+			ID:                  o.ID,
+			Name:                o.Name,
+			Address:             o.Address,
+			AcceptsPointPayment: settings.PointPayment.AcceptPayment,
+			EarnsPoints:         settings.Point.Enabled,
+			EarnsCoins:          settings.Coin.Enabled,
+		})
+	}
+	return list, nil
+}

internal/processor/customer_outlet_processor_test.go

@@ -0,0 +1,77 @@
+package processor
+
+import (
+	"context"
+	"testing"
+
+	"github.com/google/uuid"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+
+	"apskel-pos-be/internal/models"
+	"apskel-pos-be/internal/repository"
+)
+
+type customerOutletRepoFake struct {
+	orgs    map[uuid.UUID]uuid.UUID
+	outlets map[uuid.UUID][]repository.CustomerOutlet
+}
+
+func (f customerOutletRepoFake) CustomerOrganizationID(_ context.Context, id uuid.UUID) (uuid.UUID, error) {
+	org, ok := f.orgs[id]
+	if !ok {
+		return uuid.Nil, repository.ErrWalletNotFound
+	}
+	return org, nil
+}
+
+func (f customerOutletRepoFake) ListActiveOutlets(_ context.Context, org uuid.UUID) ([]repository.CustomerOutlet, error) {
+	return f.outlets[org], nil
+}
+
+type outletSettingsFake map[uuid.UUID]models.OutletLoyaltySettings
+
+func (f outletSettingsFake) Outlet(_ context.Context, id uuid.UUID) (*models.OutletLoyaltySettings, error) {
+	s := f[id]
+	return &s, nil
+}
+
+func TestCustomerOutlets_ListsTheCustomersOrganizationWithLoyaltyFlags(t *testing.T) {
+	customer, org, other := uuid.New(), uuid.New(), uuid.New()
+	kemang, blokm := uuid.New(), uuid.New()
+	addr := "Jl. Kemang Raya 10"
+	repo := customerOutletRepoFake{
+		orgs: map[uuid.UUID]uuid.UUID{customer: org},
+		outlets: map[uuid.UUID][]repository.CustomerOutlet{
+			org:   {{ID: blokm, Name: "Blok M"}, {ID: kemang, Name: "Kemang", Address: &addr}},
+			other: {{ID: uuid.New(), Name: "Not mine"}},
+		},
+	}
+	settings := outletSettingsFake{
+		kemang: {
+			Point:        models.LoyaltyEarnSettings{Enabled: true},
+			PointPayment: models.LoyaltyPointPaymentSettings{AcceptPayment: true},
+		},
+	}
+
+	got, err := NewCustomerOutletProcessor(repo, settings).List(context.Background(), customer)
+	require.NoError(t, err)
+	assert.Equal(t, []models.CustomerOutlet{
+		{ID: blokm, Name: "Blok M"},
+		{ID: kemang, Name: "Kemang", Address: &addr, AcceptsPointPayment: true, EarnsPoints: true},
+	}, got)
+}
+
+func TestCustomerOutlets_UnknownCustomer(t *testing.T) {
+	_, err := NewCustomerOutletProcessor(customerOutletRepoFake{}, outletSettingsFake{}).List(context.Background(), uuid.New())
+	assert.ErrorIs(t, err, repository.ErrWalletNotFound)
+}
+
+func TestCustomerOutlets_NoOutletsIsAnEmptyList(t *testing.T) {
+	customer := uuid.New()
+	repo := customerOutletRepoFake{orgs: map[uuid.UUID]uuid.UUID{customer: uuid.New()}}
+	got, err := NewCustomerOutletProcessor(repo, outletSettingsFake{}).List(context.Background(), customer)
+	require.NoError(t, err)
+	assert.NotNil(t, got)
+	assert.Empty(t, got)
+}

internal/processor/customer_points_processor.go

@@ -22,7 +22,7 @@ func NewCustomerPointsProcessor(walletQuery *WalletQueryProcessor, gameRepo *rep
 	}
 }
 
-// The three endpoints below are the customer app's balance screens. They read the
+// The endpoints below are the customer app's balance screens. They read the
 // EnakPoint & EnakCoin wallet; customer_points and customer_tokens are no longer used
 // for balances (docs/prd-point-coin.md §9).
 
@@ -42,22 +42,6 @@ func (p *CustomerPointsProcessor) GetCustomerTotalPointsAPI(ctx context.Context,
 	}, nil
 }
 
-func (p *CustomerPointsProcessor) GetCustomerTotalTokensAPI(ctx context.Context, customerID string) (*models.GetCustomerTokensResponse, error) {
-	id, err := parseWalletCustomerID(customerID)
-	if err != nil {
-		return nil, err
-	}
-	data, err := p.walletQuery.LegacyTokens(ctx, id)
-	if err != nil {
-		return nil, fmt.Errorf("failed to get customer tokens: %w", err)
-	}
-	return &models.GetCustomerTokensResponse{
-		Status:  "SUCCESS",
-		Message: "Customer tokens retrieved successfully.",
-		Data:    data,
-	}, nil
-}
-
 func (p *CustomerPointsProcessor) GetCustomerWalletAPI(ctx context.Context, customerID string) (*models.GetCustomerWalletResponse, error) {
 	id, err := parseWalletCustomerID(customerID)
 	if err != nil {

internal/processor/game_play_processor.go

@@ -99,10 +99,6 @@ func (p *GamePlayProcessor) ListGamePlays(ctx context.Context, query *models.Lis
 	}
 
 	offset := (query.Page - 1) * query.Limit
-	// The column was renamed; the old name still sorts the same way.
-	if query.SortBy == "token_used" {
-		query.SortBy = "coins_used"
-	}
 
 	// Get game plays from repository
 	gamePlays, total, err := p.gamePlayRepo.List(

internal/processor/order_add_items_test.go

@@ -0,0 +1,46 @@
+package processor
+
+import (
+	"testing"
+
+	"apskel-pos-be/internal/entities"
+
+	"github.com/google/uuid"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+)
+
+// The items AddToOrder creates have no product loaded, so their responses used to go out
+// without a name or a printer, and the POS could not print them.
+func TestAddedItemsFromOrderUsesTheReloadedProduct(t *testing.T) {
+	outletID := uuid.New()
+
+	paket := entities.Product{ID: uuid.New(), Name: "Paket Makan Minum"}
+	paket.SetPrinterTypes([]string{"kitchen", "bar"})
+	paket.ProductOutletPrices = []entities.ProductOutletPrice{{OutletID: outletID, PrintToChecker: false}}
+	esTeh := entities.Product{ID: uuid.New(), Name: "Es Teh"}
+	esTeh.SetPrinterTypes([]string{"bar"})
+
+	existing := entities.OrderItem{ID: uuid.New(), ProductID: esTeh.ID, Product: esTeh}
+	addedPaket := &entities.OrderItem{ID: uuid.New(), ProductID: paket.ID}
+	addedEsTeh := &entities.OrderItem{ID: uuid.New(), ProductID: esTeh.ID}
+
+	order := &entities.Order{
+		OutletID: outletID,
+		OrderItems: []entities.OrderItem{
+			existing,
+			{ID: addedEsTeh.ID, ProductID: esTeh.ID, Product: esTeh},
+			{ID: addedPaket.ID, ProductID: paket.ID, Product: paket},
+		},
+	}
+
+	responses := addedItemsFromOrder([]*entities.OrderItem{addedPaket, addedEsTeh}, order)
+
+	require.Len(t, responses, 2, "only the added items, not the ones already on the order")
+	assert.Equal(t, addedPaket.ID, responses[0].ID, "in the order they were requested")
+	assert.Equal(t, "Paket Makan Minum", responses[0].ProductName)
+	assert.Equal(t, []string{"kitchen", "bar"}, responses[0].PrinterTypes)
+	assert.False(t, responses[0].PrintToChecker, "the outlet's print_to_checker is loaded too")
+	assert.Equal(t, addedEsTeh.ID, responses[1].ID)
+	assert.Equal(t, []string{"bar"}, responses[1].PrinterTypes)
+}

internal/processor/order_processor.go

@@ -316,6 +316,18 @@ func resolveLineQuantity(product *entities.Product, quantity int, weight *float6
 }
 
 func (p *OrderProcessorImpl) CreateOrder(ctx context.Context, req *models.CreateOrderRequest, organizationID uuid.UUID) (*models.OrderResponse, error) {
+	// The order's customer earns EnakPoint and EnakCoin once it is paid, so it must be
+	// one of the organization's own; orders.customer_id has no foreign key to catch it.
+	customerID := req.CustomerID
+	if customerID != nil && *customerID == uuid.Nil {
+		customerID = nil
+	}
+	if customerID != nil {
+		if _, err := p.customerRepo.GetByIDAndOrganization(ctx, *customerID, organizationID); err != nil {
+			return nil, fmt.Errorf("customer not found or does not belong to the organization: %w", err)
+		}
+	}
+
 	orderNumber, err := p.orderRepo.GetNextOrderNumber(ctx, organizationID, req.OutletID)
 	if err != nil {
 		return nil, fmt.Errorf("failed to generate order number: %w", err)
@@ -401,7 +413,7 @@ func (p *OrderProcessorImpl) CreateOrder(ctx context.Context, req *models.Create
 		OrganizationID:  organizationID,
 		OutletID:        req.OutletID,
 		UserID:          req.UserID,
-		CustomerID:      req.CustomerID,
+		CustomerID:      customerID,
 		OrderNumber:     orderNumber,
 		TableNumber:     req.TableNumber,
 		OrderType:       entities.OrderType(req.OrderType),
@@ -556,16 +568,10 @@ func (p *OrderProcessorImpl) AddToOrder(ctx context.Context, orderID uuid.UUID,
 		return nil, fmt.Errorf("failed to update order: %w", err)
 	}
 
-	var addedItemResponses []models.OrderItemResponse
 	for _, orderItem := range addedOrderItems {
 		if err := p.orderItemRepo.Create(ctx, orderItem); err != nil {
 			return nil, fmt.Errorf("failed to create order item: %w", err)
 		}
-
-		itemResponse := mappers.OrderItemEntityToResponse(orderItem, order.OutletID)
-		if itemResponse != nil {
-			addedItemResponses = append(addedItemResponses, *itemResponse)
-		}
 	}
 
 	orderWithRelations, err := p.orderRepo.GetWithRelations(ctx, orderID)
@@ -573,6 +579,10 @@ func (p *OrderProcessorImpl) AddToOrder(ctx context.Context, orderID uuid.UUID,
 		return nil, fmt.Errorf("failed to retrieve updated order: %w", err)
 	}
 
+	// The items just created carry no product, so take them from the reloaded order: the
+	// POS prints added items from this response and needs their name and printers.
+	addedItemResponses := addedItemsFromOrder(addedOrderItems, orderWithRelations)
+
 	updatedOrderResponse := mappers.OrderEntityToResponse(orderWithRelations)
 	p.attachEarnings(ctx, updatedOrderResponse)
 
@@ -584,6 +594,26 @@ func (p *OrderProcessorImpl) AddToOrder(ctx context.Context, orderID uuid.UUID,
 	}, nil
 }
 
+// addedItemsFromOrder maps the added items in the order they were requested, using their
+// copies in the reloaded order, which have the product and its outlet prices loaded.
+func addedItemsFromOrder(added []*entities.OrderItem, order *entities.Order) []models.OrderItemResponse {
+	reloaded := make(map[uuid.UUID]*entities.OrderItem, len(order.OrderItems))
+	for i := range order.OrderItems {
+		reloaded[order.OrderItems[i].ID] = &order.OrderItems[i]
+	}
+
+	var responses []models.OrderItemResponse
+	for _, item := range added {
+		if loaded, ok := reloaded[item.ID]; ok {
+			item = loaded
+		}
+		if response := mappers.OrderItemEntityToResponse(item, order.OutletID); response != nil {
+			responses = append(responses, *response)
+		}
+	}
+	return responses
+}
+
 func (p *OrderProcessorImpl) UpdateOrder(ctx context.Context, id uuid.UUID, req *models.UpdateOrderRequest) (*models.OrderResponse, error) {
 	// Get existing order
 	order, err := p.orderRepo.GetByID(ctx, id)

internal/processor/product_recipe_processor.go

@@ -199,7 +199,7 @@ func (p *ProductRecipeProcessorImpl) entityToResponse(entity *entities.ProductRe
 			Cost:           entity.Product.Cost,
 			BusinessType:   string(entity.Product.BusinessType),
 			ImageURL:       entity.Product.ImageURL,
-			PrinterType:    entity.Product.PrinterType,
+			PrinterTypes:   entity.Product.GetPrinterTypes(),
 			Metadata:       entity.Product.Metadata,
 			IsActive:       entity.Product.IsActive,
 			CreatedAt:      entity.Product.CreatedAt,

internal/processor/wallet_query_processor.go

@@ -82,10 +82,6 @@ func (p *WalletQueryProcessor) Summary(ctx context.Context, customerID uuid.UUID
 	if err != nil {
 		return nil, err
 	}
-	tokens, err := p.legacyTokens(ctx, customerID, balances)
-	if err != nil {
-		return nil, err
-	}
 
 	data := &models.GetCustomerWalletResponseData{
 		PointBalance:       balances[constants.WalletCurrencyPoint],
@@ -94,13 +90,10 @@ func (p *WalletQueryProcessor) Summary(ctx context.Context, customerID uuid.UUID
 		PointDiscountValue: balances[constants.WalletCurrencyPoint] * pointValue,
 		RecentTransactions: recent,
 		TotalPoints:        points.TotalPoints,
-		TotalTokens:        tokens.TotalTokens,
 		PointsHistory:      points.PointsHistory,
-		TokensHistory:      tokens.TokensHistory,
-		LastUpdated:        points.LastUpdated,
 	}
-	if tokens.LastUpdated.After(data.LastUpdated) {
-		data.LastUpdated = tokens.LastUpdated
+	if len(recent) > 0 {
+		data.LastUpdated = recent[0].CreatedAt
 	}
 	for _, e := range expiring {
 		entry := &models.CustomerWalletExpiring{Amount: e.Amount, Date: e.Date}
@@ -161,32 +154,6 @@ func (p *WalletQueryProcessor) legacyPoints(ctx context.Context, customerID uuid
 	return data, nil
 }
 
-// LegacyTokens is the pre-wallet GET /customer/tokens. Tokens are EnakCoin now.
-func (p *WalletQueryProcessor) LegacyTokens(ctx context.Context, customerID uuid.UUID) (*models.GetCustomerTokensResponseData, error) {
-	balances, err := p.repo.SpendableBalances(ctx, customerID, p.now())
-	if err != nil {
-		return nil, err
-	}
-	return p.legacyTokens(ctx, customerID, balances)
-}
-
-func (p *WalletQueryProcessor) legacyTokens(ctx context.Context, customerID uuid.UUID, balances map[string]int64) (*models.GetCustomerTokensResponseData, error) {
-	recent, err := p.recent(ctx, customerID, constants.WalletCurrencyCoin, walletLegacyHistorySize)
-	if err != nil {
-		return nil, err
-	}
-	data := &models.GetCustomerTokensResponseData{TotalTokens: balances[constants.WalletCurrencyCoin]}
-	for _, tx := range recent {
-		data.TokensHistory = append(data.TokensHistory, models.TokensHistoryItem{
-			ID: tx.ID.String(), Tokens: tx.Amount, Type: tx.Type, Description: tx.Description, CreatedAt: tx.CreatedAt,
-		})
-	}
-	if len(recent) > 0 {
-		data.LastUpdated = recent[0].CreatedAt
-	}
-	return data, nil
-}
-
 func (p *WalletQueryProcessor) recent(ctx context.Context, customerID uuid.UUID, currency string, limit int) ([]models.CustomerWalletTransaction, error) {
 	rows, _, err := p.repo.ListTransactions(ctx, repository.WalletTransactionFilter{
 		CustomerID: customerID, Currency: currency, Limit: limit,

internal/processor/wallet_query_processor_test.go

@@ -122,7 +122,6 @@ func TestWalletQueryProcessor_SummaryShowsWhereEachRowCameFromOrWent(t *testing.
 
 	// The pre-wallet fields are still filled, from the wallet.
 	assert.Equal(t, int64(250), data.TotalPoints)
-	assert.Equal(t, int64(8), data.TotalTokens)
 	require.Len(t, data.PointsHistory, 2)
 	assert.Equal(t, int64(-50), data.PointsHistory[0].Points)
 	assert.Equal(t, constants.WalletTxTypePayment, data.PointsHistory[0].Type)
@@ -174,12 +173,6 @@ func TestWalletQueryProcessor_LegacyEndpointsSplitByCurrency(t *testing.T) {
 	assert.Equal(t, int64(100), points.TotalPoints)
 	require.Len(t, points.PointsHistory, 1)
 	assert.Equal(t, int64(100), points.PointsHistory[0].Points)
-
-	tokens, err := p.LegacyTokens(context.Background(), uuid.New())
-	require.NoError(t, err)
-	assert.Equal(t, int64(8), tokens.TotalTokens)
-	require.Len(t, tokens.TokensHistory, 1)
-	assert.Equal(t, int64(8), tokens.TokensHistory[0].Tokens)
 }
 
 func TestWalletQueryProcessor_TransactionsQuery(t *testing.T) {

internal/repository/customer_auth_repository.go

@@ -6,6 +6,7 @@ import (
 
 	"apskel-pos-be/internal/entities"
 
+	"github.com/google/uuid"
 	"gorm.io/gorm"
 )
 
@@ -16,6 +17,10 @@ type CustomerAuthRepository interface {
 	UpdateCustomer(ctx context.Context, customer *entities.Customer) error
 	CheckPhoneNumberExists(ctx context.Context, phoneNumber string) (bool, error)
 	SetCustomerPassword(ctx context.Context, customerID string, passwordHash string) error
+	// OrganizationExists reports whether an organization with this id exists.
+	OrganizationExists(ctx context.Context, organizationID uuid.UUID) (bool, error)
+	// OrganizationIDs returns up to limit organization ids.
+	OrganizationIDs(ctx context.Context, limit int) ([]uuid.UUID, error)
 }
 
 type customerAuthRepository struct {
@@ -78,3 +83,21 @@ func (r *customerAuthRepository) SetCustomerPassword(ctx context.Context, custom
 	}
 	return nil
 }
+
+func (r *customerAuthRepository) OrganizationExists(ctx context.Context, organizationID uuid.UUID) (bool, error) {
+	var count int64
+	err := r.db.WithContext(ctx).Table("organizations").Where("id = ?", organizationID).Count(&count).Error
+	if err != nil {
+		return false, fmt.Errorf("failed to check organization: %w", err)
+	}
+	return count > 0, nil
+}
+
+func (r *customerAuthRepository) OrganizationIDs(ctx context.Context, limit int) ([]uuid.UUID, error) {
+	var ids []uuid.UUID
+	err := r.db.WithContext(ctx).Table("organizations").Order("created_at").Limit(limit).Pluck("id", &ids).Error
+	if err != nil {
+		return nil, fmt.Errorf("failed to list organizations: %w", err)
+	}
+	return ids, nil
+}

internal/repository/customer_order_repository.go

@@ -0,0 +1,157 @@
+package repository
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"time"
+
+	"github.com/google/uuid"
+	"gorm.io/gorm"
+
+	"apskel-pos-be/internal/entities"
+)
+
+// ErrCustomerOrderNotFound means the order does not exist or belongs to another
+// customer; the two are not told apart.
+var ErrCustomerOrderNotFound = errors.New("order not found")
+
+// CustomerOrderRow is one order as the customer app lists it.
+type CustomerOrderRow struct {
+	ID             uuid.UUID
+	OrderNumber    string
+	OutletID       uuid.UUID
+	OutletName     string
+	OrderType      string
+	TableNumber    *string
+	Status         string
+	PaymentStatus  string
+	Subtotal       float64
+	DiscountAmount float64
+	TaxAmount      float64
+	TotalAmount    float64
+	RefundAmount   float64
+	IsVoid         bool
+	IsRefund       bool
+	ItemCount      int64
+	CreatedAt      time.Time
+}
+
+// CustomerOrderItemRow is one line of an order, without costs.
+type CustomerOrderItemRow struct {
+	ID             uuid.UUID
+	ProductID      uuid.UUID
+	ProductName    string
+	VariantName    *string
+	Quantity       int
+	Weight         *float64
+	UnitName       *string
+	UnitPrice      float64
+	TotalPrice     float64
+	RefundQuantity int
+	Modifiers      entities.Modifiers `gorm:"type:jsonb"`
+	Notes          *string
+	Status         string
+}
+
+// CustomerOrderPaymentRow is one payment of an order.
+type CustomerOrderPaymentRow struct {
+	ID           uuid.UUID
+	MethodName   string
+	MethodType   string
+	Amount       float64
+	Status       string
+	RefundAmount float64
+	PointsUsed   *int64
+	PointValue   *float64
+	CreatedAt    time.Time
+}
+
+// CustomerOrderRepository reads a customer's own orders for the customer app. Every
+// read is scoped to the customer, so one customer can never see another's order.
+type CustomerOrderRepository interface {
+	// ListOrders returns a page of the customer's orders, newest first, and the total.
+	ListOrders(ctx context.Context, customerID uuid.UUID, offset, limit int) ([]CustomerOrderRow, int64, error)
+	// GetOrder returns ErrCustomerOrderNotFound unless the order is the customer's.
+	GetOrder(ctx context.Context, customerID, orderID uuid.UUID) (*CustomerOrderRow, error)
+	ListItems(ctx context.Context, orderID uuid.UUID) ([]CustomerOrderItemRow, error)
+	ListPayments(ctx context.Context, orderID uuid.UUID) ([]CustomerOrderPaymentRow, error)
+}
+
+type customerOrderRepository struct {
+	db *gorm.DB
+}
+
+func NewCustomerOrderRepository(db *gorm.DB) CustomerOrderRepository {
+	return &customerOrderRepository{db: db}
+}
+
+const customerOrderColumns = `o.id, o.order_number, o.outlet_id, COALESCE(ol.name, '') AS outlet_name,
+	o.order_type, o.table_number, o.status, o.payment_status, o.subtotal, o.discount_amount,
+	o.tax_amount, o.total_amount, o.refund_amount, o.is_void, o.is_refund,
+	(SELECT COUNT(*) FROM order_items oi WHERE oi.order_id = o.id) AS item_count, o.created_at`
+
+func (r *customerOrderRepository) ListOrders(ctx context.Context, customerID uuid.UUID, offset, limit int) ([]CustomerOrderRow, int64, error) {
+	db := DBFromContext(ctx, r.db).WithContext(ctx)
+	var total int64
+	if err := db.Table("orders").Where("customer_id = ?", customerID).Count(&total).Error; err != nil {
+		return nil, 0, fmt.Errorf("failed to count customer orders: %w", err)
+	}
+	var rows []CustomerOrderRow
+	err := db.Raw(`SELECT `+customerOrderColumns+`
+		FROM orders o LEFT JOIN outlets ol ON ol.id = o.outlet_id
+		WHERE o.customer_id = ?
+		ORDER BY o.created_at DESC, o.id
+		LIMIT ? OFFSET ?`, customerID, limit, offset).Scan(&rows).Error
+	if err != nil {
+		return nil, 0, fmt.Errorf("failed to list customer orders: %w", err)
+	}
+	return rows, total, nil
+}
+
+func (r *customerOrderRepository) GetOrder(ctx context.Context, customerID, orderID uuid.UUID) (*CustomerOrderRow, error) {
+	var rows []CustomerOrderRow
+	err := DBFromContext(ctx, r.db).WithContext(ctx).Raw(`SELECT `+customerOrderColumns+`
+		FROM orders o LEFT JOIN outlets ol ON ol.id = o.outlet_id
+		WHERE o.id = ? AND o.customer_id = ?`, orderID, customerID).Scan(&rows).Error
+	if err != nil {
+		return nil, fmt.Errorf("failed to get customer order: %w", err)
+	}
+	if len(rows) == 0 {
+		return nil, ErrCustomerOrderNotFound
+	}
+	return &rows[0], nil
+}
+
+func (r *customerOrderRepository) ListItems(ctx context.Context, orderID uuid.UUID) ([]CustomerOrderItemRow, error) {
+	var rows []CustomerOrderItemRow
+	err := DBFromContext(ctx, r.db).WithContext(ctx).Raw(`
+		SELECT oi.id, oi.product_id, COALESCE(p.name, '') AS product_name, pv.name AS variant_name,
+			oi.quantity, oi.weight, COALESCE(u.abbreviation, u.name) AS unit_name,
+			oi.unit_price, oi.total_price, oi.refund_quantity, oi.modifiers, oi.notes, oi.status
+		FROM order_items oi
+		LEFT JOIN products p ON p.id = oi.product_id
+		LEFT JOIN product_variants pv ON pv.id = oi.product_variant_id
+		LEFT JOIN units u ON u.id = oi.unit_id
+		WHERE oi.order_id = ?
+		ORDER BY oi.created_at, oi.id`, orderID).Scan(&rows).Error
+	if err != nil {
+		return nil, fmt.Errorf("failed to list order items: %w", err)
+	}
+	return rows, nil
+}
+
+func (r *customerOrderRepository) ListPayments(ctx context.Context, orderID uuid.UUID) ([]CustomerOrderPaymentRow, error) {
+	var rows []CustomerOrderPaymentRow
+	err := DBFromContext(ctx, r.db).WithContext(ctx).Raw(`
+		SELECT pay.id, COALESCE(pm.name, '') AS method_name, COALESCE(pm.type, '') AS method_type,
+			pay.amount, pay.status, pay.refund_amount, pay.points_used, pay.point_value, pay.created_at
+		FROM payments pay
+		LEFT JOIN payment_methods pm ON pm.id = pay.payment_method_id
+		WHERE pay.order_id = ?
+		ORDER BY pay.created_at, pay.id`, orderID).Scan(&rows).Error
+	if err != nil {
+		return nil, fmt.Errorf("failed to list order payments: %w", err)
+	}
+	return rows, nil
+}

internal/repository/customer_outlet_repository.go

@@ -0,0 +1,60 @@
+package repository
+
+import (
+	"context"
+	"errors"
+	"fmt"
+
+	"github.com/google/uuid"
+	"gorm.io/gorm"
+)
+
+// CustomerOutlet is what the customer app may see of an outlet.
+type CustomerOutlet struct {
+	ID      uuid.UUID
+	Name    string
+	Address *string
+}
+
+// CustomerOutletRepository reads the outlets a customer can visit: the active outlets
+// of their organization.
+type CustomerOutletRepository interface {
+	// CustomerOrganizationID returns ErrWalletNotFound when the customer does not exist.
+	CustomerOrganizationID(ctx context.Context, customerID uuid.UUID) (uuid.UUID, error)
+	// ListActiveOutlets returns the organization's active outlets, by name.
+	ListActiveOutlets(ctx context.Context, organizationID uuid.UUID) ([]CustomerOutlet, error)
+}
+
+type customerOutletRepository struct {
+	db *gorm.DB
+}
+
+func NewCustomerOutletRepository(db *gorm.DB) CustomerOutletRepository {
+	return &customerOutletRepository{db: db}
+}
+
+func (r *customerOutletRepository) CustomerOrganizationID(ctx context.Context, customerID uuid.UUID) (uuid.UUID, error) {
+	var row struct{ OrganizationID uuid.UUID }
+	err := DBFromContext(ctx, r.db).WithContext(ctx).
+		Table("customers").Select("organization_id").Where("id = ?", customerID).Take(&row).Error
+	if err != nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) {
+			return uuid.Nil, ErrWalletNotFound
+		}
+		return uuid.Nil, fmt.Errorf("failed to get customer organization: %w", err)
+	}
+	return row.OrganizationID, nil
+}
+
+func (r *customerOutletRepository) ListActiveOutlets(ctx context.Context, organizationID uuid.UUID) ([]CustomerOutlet, error) {
+	var outlets []CustomerOutlet
+	err := DBFromContext(ctx, r.db).WithContext(ctx).
+		Table("outlets").Select("id, name, address").
+		Where("organization_id = ? AND is_active = ?", organizationID, true).
+		Order("name, id").
+		Scan(&outlets).Error
+	if err != nil {
+		return nil, fmt.Errorf("failed to list outlets: %w", err)
+	}
+	return outlets, nil
+}

internal/repository/product_ingredient_repository.go

@@ -39,7 +39,7 @@ func (r *ProductIngredientRepository) Create(ctx context.Context, productIngredi
 func (r *ProductIngredientRepository) GetByID(ctx context.Context, id, organizationID uuid.UUID) (*entities.ProductIngredient, error) {
 	query := `
 		SELECT pi.id, pi.organization_id, pi.outlet_id, pi.product_id, pi.ingredient_id, pi.quantity, pi.created_at, pi.updated_at,
-		       p.id, p.organization_id, p.category_id, p.sku, p.name, p.description, p.price, p.cost, p.business_type, p.image_url, p.printer_type, p.unit_id, p.has_ingredients, p.metadata, p.is_active, p.created_at, p.updated_at,
+		       p.id, p.organization_id, p.category_id, p.sku, p.name, p.description, p.price, p.cost, p.business_type, p.image_url, p.printer_types, p.unit_id, p.has_ingredients, p.metadata, p.is_active, p.created_at, p.updated_at,
 		       i.id, i.organization_id, i.outlet_id, i.name, i.unit_id, i.cost, i.stock, i.is_semi_finished, i.is_active, i.metadata, i.created_at, i.updated_at
 		FROM product_ingredients pi
 		LEFT JOIN products p ON pi.product_id = p.id
@@ -70,7 +70,7 @@ func (r *ProductIngredientRepository) GetByID(ctx context.Context, id, organizat
 		&product.Cost,
 		&product.BusinessType,
 		&product.ImageURL,
-		&product.PrinterType,
+		&product.PrinterTypes,
 		&product.UnitID,
 		&product.HasIngredients,
 		&product.Metadata,
@@ -103,7 +103,7 @@ func (r *ProductIngredientRepository) GetByID(ctx context.Context, id, organizat
 func (r *ProductIngredientRepository) GetByProductID(ctx context.Context, productID, organizationID uuid.UUID) ([]*entities.ProductIngredient, error) {
 	query := `
 		SELECT pi.id, pi.organization_id, pi.outlet_id, pi.product_id, pi.ingredient_id, pi.quantity, pi.created_at, pi.updated_at,
-		       p.id, p.organization_id, p.category_id, p.sku, p.name, p.description, p.price, p.cost, p.business_type, p.image_url, p.printer_type, p.unit_id, p.has_ingredients, p.metadata, p.is_active, p.created_at, p.updated_at,
+		       p.id, p.organization_id, p.category_id, p.sku, p.name, p.description, p.price, p.cost, p.business_type, p.image_url, p.printer_types, p.unit_id, p.has_ingredients, p.metadata, p.is_active, p.created_at, p.updated_at,
 		       i.id, i.organization_id, i.outlet_id, i.name, i.unit_id, i.cost, i.stock, i.is_semi_finished, i.is_active, i.metadata, i.created_at, i.updated_at
 		FROM product_ingredients pi
 		LEFT JOIN products p ON pi.product_id = p.id
@@ -143,7 +143,7 @@ func (r *ProductIngredientRepository) GetByProductID(ctx context.Context, produc
 			&product.Cost,
 			&product.BusinessType,
 			&product.ImageURL,
-			&product.PrinterType,
+			&product.PrinterTypes,
 			&product.UnitID,
 			&product.HasIngredients,
 			&product.Metadata,
@@ -178,7 +178,7 @@ func (r *ProductIngredientRepository) GetByProductID(ctx context.Context, produc
 func (r *ProductIngredientRepository) GetByIngredientID(ctx context.Context, ingredientID, organizationID uuid.UUID) ([]*entities.ProductIngredient, error) {
 	query := `
 		SELECT pi.id, pi.organization_id, pi.outlet_id, pi.product_id, pi.ingredient_id, pi.quantity, pi.created_at, pi.updated_at,
-		       p.id, p.organization_id, p.category_id, p.sku, p.name, p.description, p.price, p.cost, p.business_type, p.image_url, p.printer_type, p.unit_id, p.has_ingredients, p.metadata, p.is_active, p.created_at, p.updated_at,
+		       p.id, p.organization_id, p.category_id, p.sku, p.name, p.description, p.price, p.cost, p.business_type, p.image_url, p.printer_types, p.unit_id, p.has_ingredients, p.metadata, p.is_active, p.created_at, p.updated_at,
 		       i.id, i.organization_id, i.outlet_id, i.name, i.unit_id, i.cost, i.stock, i.is_semi_finished, i.is_active, i.metadata, i.created_at, i.updated_at
 		FROM product_ingredients pi
 		LEFT JOIN products p ON pi.product_id = p.id
@@ -218,7 +218,7 @@ func (r *ProductIngredientRepository) GetByIngredientID(ctx context.Context, ing
 			&product.Cost,
 			&product.BusinessType,
 			&product.ImageURL,
-			&product.PrinterType,
+			&product.PrinterTypes,
 			&product.UnitID,
 			&product.HasIngredients,
 			&product.Metadata,

internal/repository/product_repository_printer_types_test.go

@@ -0,0 +1,48 @@
+package repository
+
+import (
+	"context"
+	"testing"
+
+	"github.com/google/uuid"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+
+	"apskel-pos-be/internal/entities"
+)
+
+// Needs TEST_DATABASE_URL pointing at a migrated database; see walletTestDB.
+func TestProductPrinterTypes_AgainstPostgres(t *testing.T) {
+	db := walletTestDB(t)
+	ctx := context.Background()
+
+	org, category := uuid.New(), uuid.New()
+	require.NoError(t, db.Exec(`INSERT INTO organizations (id, name, plan_type) VALUES (?, 'printer test', 'basic')`, org).Error)
+	require.NoError(t, db.Exec(`INSERT INTO categories (id, organization_id, name) VALUES (?, ?, 'Paket')`, category, org).Error)
+	t.Cleanup(func() {
+		db.Exec(`DELETE FROM products WHERE organization_id = ?`, org)
+		db.Exec(`DELETE FROM categories WHERE id = ?`, category)
+		db.Exec(`DELETE FROM organizations WHERE id = ?`, org)
+	})
+
+	repo := NewProductRepositoryImpl(db)
+	product := &entities.Product{OrganizationID: org, CategoryID: category, Name: "Paket Makan Minum", Price: 25000}
+	product.SetPrinterTypes([]string{"kitchen", "bar"})
+	require.NoError(t, repo.Create(ctx, product))
+
+	stored, err := repo.GetByID(ctx, product.ID)
+	require.NoError(t, err)
+	assert.Equal(t, entities.StringSlice{"kitchen", "bar"}, stored.PrinterTypes)
+
+	stored.SetPrinterTypes([]string{"bar"})
+	require.NoError(t, repo.Update(ctx, stored))
+
+	var printerTypes string
+	require.NoError(t, db.Raw(`SELECT printer_types::text FROM products WHERE id = ?`, product.ID).Scan(&printerTypes).Error)
+	assert.Equal(t, `["bar"]`, printerTypes)
+
+	// The old single column is gone.
+	var columns int64
+	require.NoError(t, db.Raw(`SELECT COUNT(*) FROM information_schema.columns WHERE table_name = 'products' AND column_name = 'printer_type'`).Scan(&columns).Error)
+	assert.Zero(t, columns)
+}

internal/router/router.go

@@ -61,12 +61,14 @@ type Router struct {
 	customerOrderPaymentHandler       *handler.CustomerOrderPaymentHandler
 	customerWalletHandler             *handler.CustomerWalletHandler
 	customerDeviceHandler             *handler.CustomerDeviceHandler
+	customerOutletHandler             *handler.CustomerOutletHandler
+	customerOrderHandler              *handler.CustomerOrderHandler
 	authMiddleware                   *middleware.AuthMiddleware
 	customerAuthMiddleware            *middleware.CustomerAuthMiddleware
 	redisClient                       *redis.Client
 }
 
-func NewRouter(cfg *config.Config, healthHandler *handler.HealthHandler, authService service.AuthService, authMiddleware *middleware.AuthMiddleware, userService *service.UserServiceImpl, userValidator *validator.UserValidatorImpl, organizationService service.OrganizationService, organizationValidator validator.OrganizationValidator, outletService service.OutletService, outletValidator validator.OutletValidator, outletSettingService service.OutletSettingService, categoryService service.CategoryService, categoryValidator validator.CategoryValidator, productService service.ProductService, productValidator validator.ProductValidator, productVariantService service.ProductVariantService, productVariantValidator validator.ProductVariantValidator, inventoryService service.InventoryService, inventoryValidator validator.InventoryValidator, orderService service.OrderService, orderValidator validator.OrderValidator, fileService service.FileService, fileValidator validator.FileValidator, customerService service.CustomerService, customerValidator validator.CustomerValidator, paymentMethodService service.PaymentMethodService, paymentMethodValidator validator.PaymentMethodValidator, analyticsService *service.AnalyticsServiceImpl, reportService service.ReportService, tableService *service.TableServiceImpl, tableValidator *validator.TableValidator, unitService handler.UnitService, ingredientService handler.IngredientService, productRecipeService service.ProductRecipeService, vendorService service.VendorService, vendorValidator validator.VendorValidator, purchaseOrderService service.PurchaseOrderService, purchaseOrderValidator validator.PurchaseOrderValidator, purchaseCategoryService service.PurchaseCategoryService, purchaseCategoryValidator validator.PurchaseCategoryValidator, unitConverterService service.IngredientUnitConverterService, unitConverterValidator validator.IngredientUnitConverterValidator, chartOfAccountTypeService service.ChartOfAccountTypeService, chartOfAccountTypeValidator validator.ChartOfAccountTypeValidator, chartOfAccountService service.ChartOfAccountService, chartOfAccountValidator validator.ChartOfAccountValidator, accountService service.AccountService, accountValidator validator.AccountValidator, orderIngredientTransactionService service.OrderIngredientTransactionService, orderIngredientTransactionValidator validator.OrderIngredientTransactionValidator, gamificationService service.GamificationService, gamificationValidator validator.GamificationValidator, rewardService service.RewardService, rewardValidator validator.RewardValidator, campaignService service.CampaignService, campaignValidator validator.CampaignValidator, customerAuthService service.CustomerAuthService, customerAuthValidator validator.CustomerAuthValidator, customerPointsService service.CustomerPointsService, spinGameService service.SpinGameService, customerAuthMiddleware *middleware.CustomerAuthMiddleware, userDeviceService service.UserDeviceService, userDeviceValidator validator.UserDeviceValidator, notificationService service.NotificationService, notificationValidator validator.NotificationValidator, productOutletPriceService service.ProductOutletPriceService, productOutletPriceValidator validator.ProductOutletPriceValidator, selfOrderHandler *handler.SelfOrderHandler, expenseService *service.ExpenseServiceImpl, expenseValidator *validator.ExpenseValidatorImpl, cashAdvanceService service.CashAdvanceService, cashAdvanceValidator validator.CashAdvanceValidator, walletAdminService service.WalletAdminService, walletValidator validator.WalletValidator, loyaltySettingsService service.LoyaltySettingsService, customerPinService service.CustomerPinService, pointPaymentService service.PointPaymentService, customerOrderPaymentService service.CustomerOrderPaymentService, customerWalletService service.CustomerWalletService, customerDeviceService service.CustomerDeviceService, redisClient *redis.Client) *Router {
+func NewRouter(cfg *config.Config, healthHandler *handler.HealthHandler, authService service.AuthService, authMiddleware *middleware.AuthMiddleware, userService *service.UserServiceImpl, userValidator *validator.UserValidatorImpl, organizationService service.OrganizationService, organizationValidator validator.OrganizationValidator, outletService service.OutletService, outletValidator validator.OutletValidator, outletSettingService service.OutletSettingService, categoryService service.CategoryService, categoryValidator validator.CategoryValidator, productService service.ProductService, productValidator validator.ProductValidator, productVariantService service.ProductVariantService, productVariantValidator validator.ProductVariantValidator, inventoryService service.InventoryService, inventoryValidator validator.InventoryValidator, orderService service.OrderService, orderValidator validator.OrderValidator, fileService service.FileService, fileValidator validator.FileValidator, customerService service.CustomerService, customerValidator validator.CustomerValidator, paymentMethodService service.PaymentMethodService, paymentMethodValidator validator.PaymentMethodValidator, analyticsService *service.AnalyticsServiceImpl, reportService service.ReportService, tableService *service.TableServiceImpl, tableValidator *validator.TableValidator, unitService handler.UnitService, ingredientService handler.IngredientService, productRecipeService service.ProductRecipeService, vendorService service.VendorService, vendorValidator validator.VendorValidator, purchaseOrderService service.PurchaseOrderService, purchaseOrderValidator validator.PurchaseOrderValidator, purchaseCategoryService service.PurchaseCategoryService, purchaseCategoryValidator validator.PurchaseCategoryValidator, unitConverterService service.IngredientUnitConverterService, unitConverterValidator validator.IngredientUnitConverterValidator, chartOfAccountTypeService service.ChartOfAccountTypeService, chartOfAccountTypeValidator validator.ChartOfAccountTypeValidator, chartOfAccountService service.ChartOfAccountService, chartOfAccountValidator validator.ChartOfAccountValidator, accountService service.AccountService, accountValidator validator.AccountValidator, orderIngredientTransactionService service.OrderIngredientTransactionService, orderIngredientTransactionValidator validator.OrderIngredientTransactionValidator, gamificationService service.GamificationService, gamificationValidator validator.GamificationValidator, rewardService service.RewardService, rewardValidator validator.RewardValidator, campaignService service.CampaignService, campaignValidator validator.CampaignValidator, customerAuthService service.CustomerAuthService, customerAuthValidator validator.CustomerAuthValidator, customerPointsService service.CustomerPointsService, spinGameService service.SpinGameService, customerAuthMiddleware *middleware.CustomerAuthMiddleware, userDeviceService service.UserDeviceService, userDeviceValidator validator.UserDeviceValidator, notificationService service.NotificationService, notificationValidator validator.NotificationValidator, productOutletPriceService service.ProductOutletPriceService, productOutletPriceValidator validator.ProductOutletPriceValidator, selfOrderHandler *handler.SelfOrderHandler, expenseService *service.ExpenseServiceImpl, expenseValidator *validator.ExpenseValidatorImpl, cashAdvanceService service.CashAdvanceService, cashAdvanceValidator validator.CashAdvanceValidator, walletAdminService service.WalletAdminService, walletValidator validator.WalletValidator, loyaltySettingsService service.LoyaltySettingsService, customerPinService service.CustomerPinService, pointPaymentService service.PointPaymentService, customerOrderPaymentService service.CustomerOrderPaymentService, customerWalletService service.CustomerWalletService, customerDeviceService service.CustomerDeviceService, customerOutletService service.CustomerOutletService, customerOrderService service.CustomerOrderService, redisClient *redis.Client) *Router {
 
 	return &Router{
 		config:                            cfg,
@@ -119,6 +121,8 @@ func NewRouter(cfg *config.Config, healthHandler *handler.HealthHandler, authSer
 		customerOrderPaymentHandler:       handler.NewCustomerOrderPaymentHandler(customerOrderPaymentService),
 		customerWalletHandler:             handler.NewCustomerWalletHandler(customerWalletService),
 		customerDeviceHandler:             handler.NewCustomerDeviceHandler(customerDeviceService),
+		customerOutletHandler:             handler.NewCustomerOutletHandler(customerOutletService),
+		customerOrderHandler:              handler.NewCustomerOrderHandler(customerOrderService),
 		redisClient:                       redisClient,
 	}
 }
@@ -169,7 +173,6 @@ func (r *Router) addAppRoutes(rg *gin.Engine) {
 		customer.Use(r.customerAuthMiddleware.ValidateCustomerToken())
 		{
 			customer.GET("/points", r.customerPointsHandler.GetCustomerPoints)
-			customer.GET("/tokens", r.customerPointsHandler.GetCustomerTokens)
 			customer.GET("/wallet", r.customerPointsHandler.GetCustomerWallet)
 			customer.GET("/wallet/transactions", r.customerPointsHandler.GetCustomerWalletTransactions)
 			customer.GET("/wallet/expiring", r.customerPointsHandler.GetCustomerWalletExpiring)
@@ -180,6 +183,9 @@ func (r *Router) addAppRoutes(rg *gin.Engine) {
 			customer.POST("/wallet/transfer", r.customerWalletHandler.Transfer)
 			customer.PUT("/devices", r.customerDeviceHandler.Register)
 			customer.DELETE("/devices/:device_id", r.customerDeviceHandler.Unregister)
+			customer.GET("/outlets", r.customerOutletHandler.List)
+			customer.GET("/orders", r.customerOrderHandler.List)
+			customer.GET("/orders/:id", r.customerOrderHandler.Detail)
 			customer.POST("/orders/:id/pay-with-points", r.customerOrderPaymentHandler.PayWithPoints)
 			// PIN that approves moving EnakPoint and EnakCoin (docs/prd-point-coin.md F11)
 			customer.GET("/pin/status", r.customerPinHandler.Status)

internal/router/router_test.go

@@ -44,6 +44,9 @@ func TestAllRoutesRegister(t *testing.T) {
 		"POST /api/v1/customer/wallet/transfer",
 		"PUT /api/v1/customer/devices",
 		"DELETE /api/v1/customer/devices/:device_id",
+		"GET /api/v1/customer/outlets",
+		"GET /api/v1/customer/orders",
+		"GET /api/v1/customer/orders/:id",
 		"GET /api/v1/orders/:id/point-payment/preview",
 		"POST /api/v1/customer/orders/:id/pay-with-points",
 		"GET /api/v1/customer/pin/status",

internal/service/campaign_service.go

@@ -177,7 +177,7 @@ func (s *campaignService) CreateCampaignRule(ctx context.Context, req *contract.
 	}
 
 	// Validate reward value based on reward type
-	if req.RewardType == "POINTS" || req.RewardType == "COINS" || req.RewardType == "TOKENS" {
+	if req.RewardType == "POINTS" || req.RewardType == "COINS" {
 		if req.RewardValue == nil || *req.RewardValue <= 0 {
 			return nil, fmt.Errorf("reward value must be positive for %s type", req.RewardType)
 		}
@@ -247,7 +247,7 @@ func (s *campaignService) UpdateCampaignRule(ctx context.Context, req *contract.
 	}
 
 	// Validate reward value based on reward type
-	if req.RewardType == "POINTS" || req.RewardType == "COINS" || req.RewardType == "TOKENS" {
+	if req.RewardType == "POINTS" || req.RewardType == "COINS" {
 		if req.RewardValue == nil || *req.RewardValue <= 0 {
 			return nil, fmt.Errorf("reward value must be positive for %s type", req.RewardType)
 		}
@@ -295,7 +295,7 @@ func (s *campaignService) GetCampaignRulesByCampaignID(ctx context.Context, camp
 }
 
 func (s *campaignService) validateCampaignType(campaignType string) error {
-	validTypes := []string{"REWARD", "POINTS", "COINS", "TOKENS", "MIXED"}
+	validTypes := []string{"REWARD", "POINTS", "COINS", "MIXED"}
 	for _, validType := range validTypes {
 		if campaignType == validType {
 			return nil
@@ -335,7 +335,7 @@ func (s *campaignService) validateCampaignRules(rules []contract.CampaignRuleStr
 		}
 
 		// Validate reward value based on reward type
-		if rule.RewardType == "POINTS" || rule.RewardType == "COINS" || rule.RewardType == "TOKENS" {
+		if rule.RewardType == "POINTS" || rule.RewardType == "COINS" {
 			if rule.RewardValue == nil || *rule.RewardValue <= 0 {
 				return fmt.Errorf("reward value must be positive for %s type in rule %d", rule.RewardType, i+1)
 			}
@@ -365,7 +365,7 @@ func (s *campaignService) validateRuleType(ruleType string) error {
 }
 
 func (s *campaignService) validateRewardType(rewardType string) error {
-	validTypes := []string{"POINTS", "COINS", "TOKENS", "REWARD"}
+	validTypes := []string{"POINTS", "COINS", "REWARD"}
 	for _, validType := range validTypes {
 		if rewardType == validType {
 			return nil

internal/service/customer_order_service.go

@@ -0,0 +1,57 @@
+package service
+
+import (
+	"context"
+	"errors"
+
+	"github.com/google/uuid"
+
+	"apskel-pos-be/internal/constants"
+	"apskel-pos-be/internal/contract"
+	"apskel-pos-be/internal/models"
+	"apskel-pos-be/internal/processor"
+	"apskel-pos-be/internal/repository"
+)
+
+// CustomerOrderService serves the customer app's order history.
+type CustomerOrderService interface {
+	List(ctx context.Context, customerID uuid.UUID, query models.ListCustomerOrdersQuery) *contract.Response
+	Detail(ctx context.Context, customerID, orderID uuid.UUID) *contract.Response
+}
+
+type CustomerOrderServiceImpl struct {
+	orders *processor.CustomerOrderProcessor
+}
+
+func NewCustomerOrderService(orders *processor.CustomerOrderProcessor) *CustomerOrderServiceImpl {
+	return &CustomerOrderServiceImpl{orders: orders}
+}
+
+func (s *CustomerOrderServiceImpl) List(ctx context.Context, customerID uuid.UUID, query models.ListCustomerOrdersQuery) *contract.Response {
+	orders, err := s.orders.List(ctx, customerID, query)
+	if err != nil {
+		return customerOrderErrorResponse(err)
+	}
+	return contract.BuildSuccessResponse(orders)
+}
+
+func (s *CustomerOrderServiceImpl) Detail(ctx context.Context, customerID, orderID uuid.UUID) *contract.Response {
+	order, err := s.orders.Detail(ctx, customerID, orderID)
+	if err != nil {
+		return customerOrderErrorResponse(err)
+	}
+	return contract.BuildSuccessResponse(order)
+}
+
+func customerOrderErrorResponse(err error) *contract.Response {
+	code := constants.InternalServerErrorCode
+	switch {
+	case errors.Is(err, repository.ErrCustomerOrderNotFound):
+		code = constants.NotFoundErrorCode
+	case errors.Is(err, processor.ErrInvalidWalletQuery):
+		code = constants.ValidationErrorCode
+	}
+	return contract.BuildErrorResponse([]*contract.ResponseError{
+		contract.NewResponseError(code, constants.RequestEntity, err.Error()),
+	})
+}

internal/service/customer_outlet_service.go

@@ -0,0 +1,40 @@
+package service
+
+import (
+	"context"
+	"errors"
+
+	"github.com/google/uuid"
+
+	"apskel-pos-be/internal/constants"
+	"apskel-pos-be/internal/contract"
+	"apskel-pos-be/internal/processor"
+	"apskel-pos-be/internal/repository"
+)
+
+// CustomerOutletService serves the outlets list of the customer app.
+type CustomerOutletService interface {
+	List(ctx context.Context, customerID uuid.UUID) *contract.Response
+}
+
+type CustomerOutletServiceImpl struct {
+	outlets *processor.CustomerOutletProcessor
+}
+
+func NewCustomerOutletService(outlets *processor.CustomerOutletProcessor) *CustomerOutletServiceImpl {
+	return &CustomerOutletServiceImpl{outlets: outlets}
+}
+
+func (s *CustomerOutletServiceImpl) List(ctx context.Context, customerID uuid.UUID) *contract.Response {
+	outlets, err := s.outlets.List(ctx, customerID)
+	if err != nil {
+		code := constants.InternalServerErrorCode
+		if errors.Is(err, repository.ErrWalletNotFound) {
+			code = constants.NotFoundErrorCode
+		}
+		return contract.BuildErrorResponse([]*contract.ResponseError{
+			contract.NewResponseError(code, constants.RequestEntity, err.Error()),
+		})
+	}
+	return contract.BuildSuccessResponse(outlets)
+}

internal/service/customer_points_service.go

@@ -10,7 +10,6 @@ import (
 
 type CustomerPointsService interface {
 	GetCustomerPoints(ctx context.Context, customerID string) (*models.GetCustomerPointsResponse, error)
-	GetCustomerTokens(ctx context.Context, customerID string) (*models.GetCustomerTokensResponse, error)
 	GetCustomerWallet(ctx context.Context, customerID string) (*models.GetCustomerWalletResponse, error)
 	GetCustomerWalletTransactions(ctx context.Context, customerID string, query models.ListCustomerWalletTransactionsQuery) (*models.PaginatedResponse[models.CustomerWalletTransaction], error)
 	GetCustomerWalletExpiring(ctx context.Context, customerID string) (*models.CustomerWalletExpiringList, error)
@@ -41,19 +40,6 @@ func (s *customerPointsService) GetCustomerPoints(ctx context.Context, customerI
 	return response, nil
 }
 
-func (s *customerPointsService) GetCustomerTokens(ctx context.Context, customerID string) (*models.GetCustomerTokensResponse, error) {
-	if customerID == "" {
-		return nil, fmt.Errorf("customer ID is required")
-	}
-
-	response, err := s.customerPointsProcessor.GetCustomerTotalTokensAPI(ctx, customerID)
-	if err != nil {
-		return nil, fmt.Errorf("failed to get customer tokens: %w", err)
-	}
-
-	return response, nil
-}
-
 func (s *customerPointsService) GetCustomerWallet(ctx context.Context, customerID string) (*models.GetCustomerWalletResponse, error) {
 	if customerID == "" {
 		return nil, fmt.Errorf("customer ID is required")

internal/transformer/gamification_transformer.go

@@ -276,7 +276,6 @@ func GamePlayModelToResponse(model *models.GamePlayResponse) *contract.GamePlayR
 		CustomerID: model.CustomerID,
 		PrizeID:    model.PrizeID,
 		CoinsUsed:  model.CoinsUsed,
-		TokenUsed:  model.CoinsUsed,
 		RandomSeed: model.RandomSeed,
 		CreatedAt:  model.CreatedAt,
 		Game:       game,
@@ -306,10 +305,9 @@ func PlayGameModelToResponse(model *models.PlayGameResponse) *contract.PlayGameR
 	}
 
 	return &contract.PlayGameResponse{
-		GamePlay:        gamePlayValue,
-		PrizeWon:        prizeWon,
-		CoinsRemaining:  model.CoinsRemaining,
-		TokensRemaining: model.CoinsRemaining,
+		GamePlay:       gamePlayValue,
+		PrizeWon:       prizeWon,
+		CoinsRemaining: model.CoinsRemaining,
 	}
 }
 

internal/transformer/inventory_transformer.go

@@ -44,8 +44,9 @@ func InventoryModelResponseToResponse(inv *models.InventoryResponse) *contract.I
 		IsLowStock:   inv.IsLowStock,
 		UpdatedAt:    inv.UpdatedAt,
 		Product: &contract.ProductResponse{
-			ID:   inv.ProductID,
-			Name: inv.ProductName,
+			ID:           inv.ProductID,
+			Name:         inv.ProductName,
+			PrinterTypes: []string{},
 		},
 	}
 }

internal/transformer/order_transformer.go

@@ -27,6 +27,7 @@ func CreateOrderContractToModel(req *contract.CreateOrderRequest) *models.Create
 	return &models.CreateOrderRequest{
 		OutletID:     req.OutletID,
 		UserID:       req.UserID,
+		CustomerID:   req.CustomerID,
 		TableID:      req.TableID,
 		TableNumber:  req.TableNumber,
 		OrderType:    constants.OrderType(req.OrderType),
@@ -117,7 +118,7 @@ func OrderModelToContract(resp *models.OrderResponse) *contract.OrderResponse {
 			Status:             string(item.Status),
 			CreatedAt:          item.CreatedAt,
 			UpdatedAt:          item.UpdatedAt,
-			PrinterType:        item.PrinterType,
+			PrinterTypes:       item.PrinterTypes,
 			PrintToChecker:     item.PrintToChecker,
 			PaidQuantity:       item.PaidQuantity,
 		}
@@ -194,6 +195,7 @@ func AddToOrderModelToContract(resp *models.AddToOrderResponse) *contract.AddToO
 			Status:             string(item.Status),
 			CreatedAt:          item.CreatedAt,
 			UpdatedAt:          item.UpdatedAt,
+			PrinterTypes:       item.PrinterTypes,
 			PrintToChecker:     item.PrintToChecker,
 		}
 	}

internal/transformer/order_transformer_printer_types_test.go

@@ -0,0 +1,50 @@
+package transformer
+
+import (
+	"encoding/json"
+	"testing"
+
+	"apskel-pos-be/internal/entities"
+	"apskel-pos-be/internal/mappers"
+	"apskel-pos-be/internal/models"
+
+	"github.com/google/uuid"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+)
+
+// The POS prints items added to an open order from this response, so each one has to
+// say where it is printed.
+func TestAddToOrderModelToContractCarriesPrinters(t *testing.T) {
+	result := AddToOrderModelToContract(&models.AddToOrderResponse{
+		AddedItems: []models.OrderItemResponse{{PrinterTypes: []string{"kitchen", "bar"}}},
+	})
+
+	require.Len(t, result.AddedItems, 1)
+	assert.Equal(t, []string{"kitchen", "bar"}, result.AddedItems[0].PrinterTypes)
+}
+
+// Follows an order from the database row to the JSON the POS reads.
+func TestOrderJSONCarriesPrinters(t *testing.T) {
+	paket := entities.Product{ID: uuid.New(), Name: "Paket Makan Minum"}
+	paket.SetPrinterTypes([]string{"kitchen", "bar"})
+	order := &entities.Order{
+		ID:         uuid.New(),
+		OrderItems: []entities.OrderItem{{ID: uuid.New(), ProductID: paket.ID, Product: paket, Quantity: 1}},
+	}
+
+	body, err := json.Marshal(OrderModelToContract(mappers.OrderEntityToResponse(order)))
+	require.NoError(t, err)
+
+	assert.Contains(t, string(body), `"printer_types":["kitchen","bar"]`)
+	assert.NotContains(t, string(body), `"printer_type":`, "printer_types replaced it")
+}
+
+func TestOrderModelToContractCarriesPrinters(t *testing.T) {
+	result := OrderModelToContract(&models.OrderResponse{
+		OrderItems: []models.OrderItemResponse{{PrinterTypes: []string{"kitchen", "bar"}}},
+	})
+
+	require.Len(t, result.OrderItems, 1)
+	assert.Equal(t, []string{"kitchen", "bar"}, result.OrderItems[0].PrinterTypes)
+}

internal/transformer/order_transformer_test.go

@@ -32,6 +32,20 @@ func TestCreateOrderContractToModelCarriesWeight(t *testing.T) {
 	require.Equal(t, weight, *result.OrderItems[0].Weight)
 }
 
+func TestCreateOrderContractToModelCarriesCustomer(t *testing.T) {
+	customerID := uuid.New()
+
+	result := CreateOrderContractToModel(&contract.CreateOrderRequest{
+		OutletID:   uuid.New(),
+		UserID:     uuid.New(),
+		CustomerID: &customerID,
+		OrderItems: []contract.CreateOrderItemRequest{{ProductID: uuid.New(), Quantity: 1}},
+	})
+
+	require.NotNil(t, result.CustomerID, "the order's customer is who earns EnakPoint and EnakCoin")
+	require.Equal(t, customerID, *result.CustomerID)
+}
+
 func TestAddToOrderContractToModelCarriesWeight(t *testing.T) {
 	weight := 0.8
 

internal/transformer/product_transformer.go

@@ -61,7 +61,7 @@ func CreateProductRequestToModel(apctx *appcontext.ContextInfo, req *contract.Cr
 		Cost:           cost,
 		BusinessType:   businessType,
 		ImageURL:       req.ImageURL,
-		PrinterType:    req.PrinterType,
+		PrinterTypes:   req.PrinterTypes,
 		PrintToChecker: req.PrintToChecker,
 		UnitID:         req.UnitID,
 		SellBy:         sellBy,
@@ -91,7 +91,7 @@ func UpdateProductRequestToModel(apctx *appcontext.ContextInfo, req *contract.Up
 		Price:          req.Price,
 		Cost:           req.Cost,
 		ImageURL:       req.ImageURL,
-		PrinterType:    req.PrinterType,
+		PrinterTypes:   req.PrinterTypes,
 		PrintToChecker: req.PrintToChecker,
 		UnitID:         req.UnitID,
 		SellBy:         req.SellBy,
@@ -152,7 +152,7 @@ func ProductModelResponseToResponse(prod *models.ProductResponse) *contract.Prod
 		Cost:           prod.Cost,
 		BusinessType:   string(prod.BusinessType),
 		ImageURL:       prod.ImageURL,
-		PrinterType:    prod.PrinterType,
+		PrinterTypes:   prod.PrinterTypes,
 		PrintToChecker: prod.PrintToChecker,
 		UnitID:         prod.UnitID,
 		SellBy:         prod.SellBy,

internal/validator/campaign_validator.go

@@ -254,7 +254,7 @@ func (v *CampaignValidatorImpl) ValidateDeleteCampaignRuleRequest(req *contract.
 }
 
 func (v *CampaignValidatorImpl) isValidCampaignType(campaignType string) bool {
-	validTypes := []string{"REWARD", "POINTS", "COINS", "TOKENS", "MIXED"}
+	validTypes := []string{"REWARD", "POINTS", "COINS", "MIXED"}
 	return contains(validTypes, campaignType)
 }
 
@@ -264,7 +264,7 @@ func (v *CampaignValidatorImpl) isValidRuleType(ruleType string) bool {
 }
 
 func (v *CampaignValidatorImpl) isValidRewardType(rewardType string) bool {
-	validTypes := []string{"POINTS", "COINS", "TOKENS", "REWARD"}
+	validTypes := []string{"POINTS", "COINS", "REWARD"}
 	return contains(validTypes, rewardType)
 }
 
@@ -297,7 +297,7 @@ func (v *CampaignValidatorImpl) validateCampaignRule(rule *contract.CampaignRule
 	}
 
 	// Validate reward value based on reward type
-	if rule.RewardType == "POINTS" || rule.RewardType == "COINS" || rule.RewardType == "TOKENS" {
+	if rule.RewardType == "POINTS" || rule.RewardType == "COINS" {
 		if rule.RewardValue == nil || *rule.RewardValue <= 0 {
 			return errors.New("reward value must be positive for " + rule.RewardType + " type in rule " + string(rune(ruleNumber)))
 		}

internal/validator/customer_auth_validator.go

@@ -5,6 +5,8 @@ import (
 	"regexp"
 	"strings"
 
+	"github.com/google/uuid"
+
 	"apskel-pos-be/internal/constants"
 	"apskel-pos-be/internal/contract"
 )
@@ -68,6 +70,13 @@ func (v *CustomerAuthValidatorImpl) ValidateRegisterStartRequest(req *contract.R
 		return errors.New("name cannot exceed 100 characters"), constants.ValidationErrorCode
 	}
 
+	// Validate organization
+	if orgID := strings.TrimSpace(req.OrganizationID); orgID != "" {
+		if _, err := uuid.Parse(orgID); err != nil {
+			return errors.New("organization_id must be a valid UUID"), constants.ValidationErrorCode
+		}
+	}
+
 	// Validate birth date
 	if strings.TrimSpace(req.BirthDate) == "" {
 		return errors.New("birth date is required"), constants.ValidationErrorCode

internal/validator/product_validator.go

@@ -59,8 +59,8 @@ func (v *ProductValidatorImpl) ValidateCreateProductRequest(req *contract.Create
 		return errors.New("image_url cannot exceed 500 characters"), constants.MalformedFieldErrorCode
 	}
 
-	if req.PrinterType != nil && len(*req.PrinterType) > 50 {
-		return errors.New("printer_type cannot exceed 50 characters"), constants.MalformedFieldErrorCode
+	if err, code := validatePrinterTypes(req.PrinterTypes); err != nil {
+		return err, code
 	}
 
 	if err, code := validateSellBy(req.SellBy, req.UnitID); err != nil {
@@ -70,6 +70,18 @@ func (v *ProductValidatorImpl) ValidateCreateProductRequest(req *contract.Create
 	return nil, ""
 }
 
+// validatePrinterTypes holds each printer to the 50 characters the single printer_type
+// column allowed.
+func validatePrinterTypes(printerTypes []string) (error, string) {
+	for _, printerType := range printerTypes {
+		if len(strings.TrimSpace(printerType)) > 50 {
+			return errors.New("each printer_types entry cannot exceed 50 characters"), constants.MalformedFieldErrorCode
+		}
+	}
+
+	return nil, ""
+}
+
 // validateSellBy checks how a product is sold and that it carries what that choice
 // needs. A weight-based product without a unit would produce order lines with no unit
 // to print, so the receipt could show "4,2" with no idea of what.
@@ -100,7 +112,7 @@ func (v *ProductValidatorImpl) ValidateUpdateProductRequest(req *contract.Update
 	// At least one field should be provided for update
 	if req.CategoryID == nil && req.SKU == nil && req.Name == nil && req.Description == nil &&
 		req.Price == nil && req.Cost == nil && req.BusinessType == nil && req.ImageURL == nil &&
-		req.PrinterType == nil && req.PrintToChecker == nil && req.UnitID == nil &&
+		req.PrinterTypes == nil && req.PrintToChecker == nil && req.UnitID == nil &&
 		req.SellBy == nil && req.Metadata == nil && req.IsActive == nil {
 		return errors.New("at least one field must be provided for update"), constants.MissingFieldErrorCode
 	}
@@ -134,8 +146,8 @@ func (v *ProductValidatorImpl) ValidateUpdateProductRequest(req *contract.Update
 		return errors.New("image_url cannot exceed 500 characters"), constants.MalformedFieldErrorCode
 	}
 
-	if req.PrinterType != nil && len(*req.PrinterType) > 50 {
-		return errors.New("printer_type cannot exceed 50 characters"), constants.MalformedFieldErrorCode
+	if err, code := validatePrinterTypes(req.PrinterTypes); err != nil {
+		return err, code
 	}
 
 	// Only the value is checked here. Whether the product ends up with a unit depends on

internal/validator/product_validator_printer_types_test.go

@@ -0,0 +1,35 @@
+package validator
+
+import (
+	"strings"
+	"testing"
+
+	"apskel-pos-be/internal/contract"
+)
+
+func TestValidateProductRequestPrinterTypes(t *testing.T) {
+	v := NewProductValidator()
+	tooLong := strings.Repeat("a", 51)
+
+	create := baseCreateRequest()
+	create.PrinterTypes = []string{"kitchen", "bar"}
+	if err, _ := v.ValidateCreateProductRequest(create); err != nil {
+		t.Fatalf("kitchen and bar should be accepted, got: %v", err)
+	}
+
+	create.PrinterTypes = []string{"kitchen", tooLong}
+	if err, _ := v.ValidateCreateProductRequest(create); err == nil {
+		t.Fatal("expected an error for a printer longer than 50 characters")
+	}
+
+	err, _ := v.ValidateUpdateProductRequest(&contract.UpdateProductRequest{PrinterTypes: []string{tooLong}})
+	if err == nil {
+		t.Fatal("expected an error for a printer longer than 50 characters on update")
+	}
+
+	// An update that only changes the printers is a real update.
+	err, _ = v.ValidateUpdateProductRequest(&contract.UpdateProductRequest{PrinterTypes: []string{"kitchen", "bar"}})
+	if err != nil {
+		t.Fatalf("an update of only printer_types should be accepted, got: %v", err)
+	}
+}

migrations/000094_add_point_payment_method.down.sql

@@ -13,4 +13,4 @@ DROP INDEX IF EXISTS uq_payment_methods_point_per_organization;
 
 ALTER TABLE payment_methods DROP CONSTRAINT IF EXISTS payment_methods_type_check;
 ALTER TABLE payment_methods ADD CONSTRAINT payment_methods_type_check
-    CHECK (type IN ('cash', 'card', 'digital_wallet'));
+    CHECK (type IN ('cash', 'card', 'digital_wallet', 'qr', 'edc', 'delivery'));

migrations/000094_add_point_payment_method.up.sql

@@ -1,10 +1,11 @@
 -- Paying with EnakPoint (docs/prd-point-coin.md F9, §8, §10.5).
 
--- A new payment method type. Every organization has exactly one method of it, made by
+-- A new payment method type, next to the existing ones (edc and delivery were added to
+-- the constraint outside the migrations). Every organization has exactly one method of it, made by
 -- the system, which cannot be deleted or change type.
 ALTER TABLE payment_methods DROP CONSTRAINT IF EXISTS payment_methods_type_check;
 ALTER TABLE payment_methods ADD CONSTRAINT payment_methods_type_check
-    CHECK (type IN ('cash', 'card', 'digital_wallet', 'point'));
+    CHECK (type IN ('cash', 'card', 'digital_wallet', 'qr', 'edc', 'delivery', 'point'));
 
 CREATE UNIQUE INDEX uq_payment_methods_point_per_organization ON payment_methods(organization_id)
     WHERE type = 'point';

migrations/000098_allow_edc_delivery_payment_methods.down.sql

@@ -0,0 +1,2 @@
+-- Nothing to undo: 000094 now allows the same types.
+SELECT 1;

migrations/000098_allow_edc_delivery_payment_methods.up.sql

@@ -0,0 +1,7 @@
+-- Production also has edc and delivery payment methods, allowed by a constraint changed
+-- outside the migrations, and the code also accepts qr, which no constraint allowed.
+-- 000094 first rewrote the constraint without them, which
+-- failed on production and, where it ran, dropped them. Keep every type in use.
+ALTER TABLE payment_methods DROP CONSTRAINT IF EXISTS payment_methods_type_check;
+ALTER TABLE payment_methods ADD CONSTRAINT payment_methods_type_check
+    CHECK (type IN ('cash', 'card', 'digital_wallet', 'qr', 'edc', 'delivery', 'point'));

migrations/000099_add_printer_types_to_products.down.sql

@@ -0,0 +1,8 @@
+-- Only the first printer fits back into printer_type; the extra stations are lost.
+ALTER TABLE products ADD COLUMN printer_type VARCHAR(50) DEFAULT 'kitchen';
+
+UPDATE products SET printer_type = COALESCE(printer_types->>0, '');
+
+CREATE INDEX idx_products_printer_type ON products(printer_type);
+
+ALTER TABLE products DROP COLUMN printer_types;

migrations/000099_add_printer_types_to_products.up.sql

@@ -0,0 +1,12 @@
+-- A product can be prepared at more than one station: a meal-and-drink package goes to
+-- the kitchen and to the bar. printer_types replaces the single printer_type.
+ALTER TABLE products ADD COLUMN printer_types JSONB NOT NULL DEFAULT '["kitchen"]';
+
+UPDATE products
+SET printer_types = CASE
+    WHEN COALESCE(printer_type, '') = '' THEN '[]'::jsonb
+    ELSE jsonb_build_array(printer_type)
+END;
+
+-- Dropping the column drops idx_products_printer_type with it.
+ALTER TABLE products DROP COLUMN printer_type;

postman.json

@@ -500,7 +500,7 @@
 						],
 						"body": {
 							"mode": "raw",
-							"raw": "{\n  \"name\": \"Cappuccino\",\n  \"description\": \"Classic Italian coffee drink\",\n  \"category_id\": \"{{category_id}}\",\n  \"sku\": \"CAP001\",\n  \"barcode\": \"1234567890123\",\n  \"price\": 4.50,\n  \"cost\": 1.20,\n  \"is_active\": true,\n  \"has_variants\": false,\n  \"image_url\": \"https://example.com/cappuccino.jpg\",\n  \"printer_type\": \"kitchen\"\n}"
+							"raw": "{\n  \"name\": \"Cappuccino\",\n  \"description\": \"Classic Italian coffee drink\",\n  \"category_id\": \"{{category_id}}\",\n  \"sku\": \"CAP001\",\n  \"barcode\": \"1234567890123\",\n  \"price\": 4.50,\n  \"cost\": 1.20,\n  \"is_active\": true,\n  \"has_variants\": false,\n  \"image_url\": \"https://example.com/cappuccino.jpg\",\n  \"printer_types\": [\"kitchen\"]\n}"
 						},
 						"url": {
 							"raw": "{{base_url}}/api/v1/products",
@@ -563,7 +563,7 @@
 						],
 						"body": {
 							"mode": "raw",
-							"raw": "{\n  \"name\": \"Premium Cappuccino\",\n  \"description\": \"Premium Italian coffee drink with extra foam\",\n  \"price\": 5.50,\n  \"cost\": 1.50,\n  \"is_active\": true,\n  \"image_url\": \"https://example.com/premium-cappuccino.jpg\",\n  \"printer_type\": \"kitchen\"\n}"
+							"raw": "{\n  \"name\": \"Premium Cappuccino\",\n  \"description\": \"Premium Italian coffee drink with extra foam\",\n  \"price\": 5.50,\n  \"cost\": 1.50,\n  \"is_active\": true,\n  \"image_url\": \"https://example.com/premium-cappuccino.jpg\",\n  \"printer_types\": [\"kitchen\"]\n}"
 						},
 						"url": {
 							"raw": "{{base_url}}/api/v1/products/{{product_id}}",