#!/bin/bash
# /order slash command handler
# Args: $1 = subcommand
# Env: OPTION_ID, OPTION_STATUS, OPTION_SHIP_DATE, DISCORD_USER_ID, etc.

SUBCOMMAND="$1"

# Helper: call admin status update API
update_status() {
  local id="$1"
  local status="$2"
  local ship_date="$3"

  if [ -n "$ship_date" ]; then
    BODY="{\"status\":\"$status\",\"expected_ship_date\":\"$ship_date\"}"
  else
    BODY="{\"status\":\"$status\"}"
  fi

  RESPONSE=$(curl -s -w "\n%{http_code}" -X PATCH \
    "$WORKER_URL/admin/order/$id/status" \
    -H "Authorization: Bearer $ADMIN_TOKEN" \
    -H "Content-Type: application/json" \
    -d "$BODY")

  HTTP_CODE=$(echo "$RESPONSE" | tail -1)
  BODY_RESP=$(echo "$RESPONSE" | head -1)

  if [ "$HTTP_CODE" = "200" ]; then
    echo "訂單 #$id 已更新為 $status"
  else
    echo "錯誤 ($HTTP_CODE): $BODY_RESP"
    exit 1
  fi
}

# Helper: format order row
format_order() {
  local json="$1"
  echo "$json" | python3 -c "
import json, sys
o = json.load(sys.stdin)
status_label = {
  'pending_payment': '待付款',
  'payment_submitted': '已付款待確認',
  'confirmed': '已確認待出貨',
  'shipped': '已出貨',
  'completed': '已完成',
  'payment_issue': '付款異常',
  'cancelled': '已取消',
}
def fmt(o):
  s = status_label.get(o.get('status',''), o.get('status',''))
  items = json.loads(o.get('items','[]')) if isinstance(o.get('items'), str) else o.get('items',[])
  item_str = ', '.join(f\"{i['spec']} x{i['quantity']}\" for i in items)
  line = f\"#{o['id']} {o['name']} [{s}] {item_str}\"
  if o.get('note'):
    line += f\" 備註:{o['note']}\"
  return line

data = json.load(open('/dev/stdin')) if False else o
if isinstance(data, list):
  for row in data:
    print(fmt(row))
else:
  o2 = data
  s = status_label.get(o2.get('status',''), o2.get('status',''))
  items = json.loads(o2.get('items','[]')) if isinstance(o2.get('items'), str) else o2.get('items',[])
  item_str = '\n'.join(f\"  {i['spec']} x{i['quantity']}\" for i in items)
  print(f\"訂單 #{o2['id']}\")
  print(f\"姓名：{o2.get('name','')}\")
  print(f\"電話：{o2.get('phone','')}\")
  print(f\"地址：{o2.get('address','')}\")
  print(f\"品項：\n{item_str}\")
  print(f\"狀態：{s}\")
  if o2.get('transfer_last5'): print(f\"匯款末五碼：{o2['transfer_last5']}\")
  if o2.get('expected_ship_date'): print(f\"預計出貨：{o2['expected_ship_date']}\")
  if o2.get('shipped_at'): print(f\"出貨時間：{o2['shipped_at']}\")
  if o2.get('note'): print(f\"備註：{o2['note']}\")
  print(f\"下單時間：{o2.get('created_at','')}\")
"
}

case "$SUBCOMMAND" in
  list)
    if [ -n "$OPTION_STATUS" ]; then
      WHERE="WHERE status='$OPTION_STATUS'"
    else
      WHERE=""
    fi
    RESULT=$(wrangler d1 execute x --remote \
      --command="SELECT id, name, items, status, note, created_at FROM orders $WHERE ORDER BY created_at DESC" \
      --json 2>/dev/null | python3 -c "
import json, sys
data = json.load(sys.stdin)
rows = data[0].get('results', []) if data else []
if not rows:
    print('沒有訂單')
    sys.exit(0)
status_label = {
  'pending_payment': '待付款',
  'payment_submitted': '已付款待確認',
  'confirmed': '已確認待出貨',
  'shipped': '已出貨',
  'completed': '已完成',
  'payment_issue': '付款異常',
  'cancelled': '已取消',
}
lines = []
for o in rows:
    s = status_label.get(o.get('status',''), o.get('status',''))
    try:
        items = json.loads(o.get('items','[]'))
        item_str = ', '.join(f\"{i['spec']} x{i['quantity']}\" for i in items)
    except:
        item_str = o.get('items','')
    line = f\"#{o['id']} {o['name']} [{s}] {item_str}\"
    if o.get('note'):
        line += f\" 備:{o['note']}\"
    lines.append(line)
print('\n'.join(lines))
")
    echo "$RESULT"
    ;;

  view)
    ID="${OPTION_ID}"
    if [ -z "$ID" ]; then echo "缺少 id"; exit 1; fi
    wrangler d1 execute x --remote \
      --command="SELECT * FROM orders WHERE id=$ID" \
      --json 2>/dev/null | python3 -c "
import json, sys
data = json.load(sys.stdin)
rows = data[0].get('results', []) if data else []
if not rows:
    print('找不到訂單')
    sys.exit(0)
o = rows[0]
status_label = {
  'pending_payment': '待付款',
  'payment_submitted': '已付款待確認',
  'confirmed': '已確認待出貨',
  'shipped': '已出貨',
  'completed': '已完成',
  'payment_issue': '付款異常',
  'cancelled': '已取消',
}
s = status_label.get(o.get('status',''), o.get('status',''))
try:
    items = json.loads(o.get('items','[]'))
    item_str = '\n'.join(f\"  {i['spec']} x{i['quantity']}\" for i in items)
except:
    item_str = o.get('items','')
print(f\"訂單 #{o['id']}\")
print(f\"姓名：{o.get('name','')}\")
print(f\"電話：{o.get('phone','')}\")
print(f\"Email：{o.get('email','')}\")
print(f\"地址：{o.get('address','')}\")
print(f\"品項：\n{item_str}\")
print(f\"狀態：{s}\")
if o.get('transfer_last5'): print(f\"匯款末五碼：{o['transfer_last5']}\")
if o.get('expected_ship_date'): print(f\"預計出貨：{o['expected_ship_date']}\")
if o.get('shipped_at'): print(f\"出貨時間：{o['shipped_at']}\")
if o.get('note'): print(f\"備註：{o['note']}\")
print(f\"下單時間：{o.get('created_at','')}\")
"
    ;;

  confirm)
    update_status "${OPTION_ID}" "confirmed" "${OPTION_SHIP_DATE:-}"
    ;;

  ship)
    update_status "${OPTION_ID}" "shipped"
    ;;

  done)
    update_status "${OPTION_ID}" "completed"
    ;;

  issue)
    update_status "${OPTION_ID}" "payment_issue"
    ;;

  cancel)
    update_status "${OPTION_ID}" "cancelled"
    ;;

  *)
    echo "未知的 subcommand: $SUBCOMMAND"
    exit 1
    ;;
esac