{_tax_name}: {_fmt(pricing.tax_total)}
" if pricing.tax_total else "", "shipping_line": f"Shipping: {_fmt(pricing.shipping_total)}
" if pricing.shipping_total else "", "total": _fmt(order.grand_total), "prices_include_tax": "1" if pricing.prices_include_tax else "", "purchase_order_number": purchase_order_number or "", "adjustments": adjustments, "items_table": build_items_table( items_for_email, adjustments=adjustments, locale=table_locale, currency_symbol=_sym, ), # Keep every address value independent so each template controls its own order and layout. "shipping_address": shipping_addr["address"], "recv_street": shipping_addr["address"], "recv_district": shipping_addr["district"], "recv_city": shipping_addr["city"], "recv_state": shipping_addr["province"], "recv_postcode": shipping_addr["zip_code"], "recv_country": shipping_addr["country"], "recv_email": shipping_addr["email"], "store_name": ts.store_name if ts else "SME Store", "note": order.note or "", }, smtp_config=build_smtp_config(ts), ) except Exception: pass # 10. 发送 order_created 信号 order_created.send(sender=Order, order=order, tenant_id=tenant_id) return { "id": order.id, "order_no": order.order_no, "status": order.status, "grand_total": float(order.grand_total), "subtotal": float(order.subtotal), "shipping_total": float(order.shipping_total), "discount_total": float(order.discount_total), "adjustments": [ {"type": adj.type, "label": adj.label, "amount": float(adj.amount)} for adj in pricing.adjustments ], "created_at": order.created_at.isoformat() if order.created_at else None, } # ── 订单价格预览 ─────────────────────────────────────────────────────────── class PreviewIn(BaseModel): items: List[CartItemIn] coupon_code: Optional[str] = None points_to_use: int = Field(0, ge=0) country: str = "" province: str = "" # 新增字段全部有默认值：老调用方（购物车抽屉、cart 页）不传也照常工作。 # 但运费规则可以按郊区/邮编收附加费，不传就会出现"预览便宜、下单变贵"。 city: str = "" district: str = "" zip_code: str = "" shipping_method_id: Optional[int] = None delivery_type: Optional[int] = None delivery_mode: Optional[str] = None pay_method: Optional[str] = None advanced_quote: Optional[dict] = None @router.post("/preview", summary="订单价格预览") async def preview_order( body: PreviewIn, tid: int = Depends(get_tenant_by_domain), customer: Optional[Customer] = Depends(get_optional_customer), db: AsyncSession = Depends(get_db), ): eff_tenant = tid from app.core.services.plugin_helper import is_plugin_active _is_pickup = await resolve_is_pickup(db, eff_tenant, body.delivery_type) # 与下单同一套单位换算：预览少换算一次，unit_split 租户会被预览一个价、下单另一个价 cart_items = await build_pricing_cart_items( db, eff_tenant, body.items, unit_split_active=await is_plugin_active("unit_split", db, eff_tenant), ) # 与下单同一个入口、同一套地址事实：预览报的价就是下单要收的价 from app.plugins.advanced_shipping_rules.store_quote import quote_checkout_pricing quote = await quote_checkout_pricing( db, eff_tenant, customer=customer, items=cart_items, address=shipping_facts_address(body, prefix=""), # PreviewIn 用裸字段名 is_pickup=_is_pickup, coupon_code=body.coupon_code, points_to_use=body.points_to_use, shipping_method_id=body.shipping_method_id, delivery_mode=body.delivery_mode, selection=body.advanced_quote, payment_method=body.pay_method, # 预览：只读，没有地址时不强制（购物车抽屉/aqua/b2b 都只传 items），也不记影子事件 require_quote=False, record_shadow=False, ) pricing = quote.pricing # 如果提供了地址，返回所有可用运费方案供用户选择 # 强制模式下运费只能来自高级规则引擎，这里绝不再列 legacy 方案： # 列出来客户也选不了（下单会被判 stale_quote），只会看到"预览有、下单没有"的方案。 shipping_methods: list[dict] = [] if body.country and quote.mode != "enforced": # 强制租户（含自提）一律不列 legacy 方案 try: calc = ShippingCalculator(db, eff_tenant) zones = await calc._load_zones() matched_zone = calc._match_zone(zones, body.country, body.province or "") logger.info( "preview shipping: tenant=%s country=%s province=%s zones=%d matched_zone=%s", eff_tenant, body.country, body.province, len(zones), matched_zone.id if matched_zone else None, ) options = await calc.get_available_methods( country=body.country, province=body.province, subtotal=pricing.subtotal, total_weight_kg=pricing.total_weight_kg, total_items=pricing.total_items, ) logger.info( "preview shipping: methods_found=%d weight_kg=%s subtotal=%s shipping_total=%s", len(options), pricing.total_weight_kg, pricing.subtotal, pricing.shipping_total, ) shipping_methods = [ { "method_id": o.method_id, "name": o.name, "carrier_name": o.carrier_name, "estimated_days": o.estimated_days, "fee": float(o.fee), "is_free": o.is_free, } for o in options ] except Exception: logger.warning("get_available_methods failed in preview", exc_info=True) return { "lines": [ { "product_id": line.product_id, "variant_id": line.variant_id, "unit_name": body.items[index].unit_name if index < len(body.items) else None, "name": line.name, "sku": line.sku, "qty": line.qty, "unit_price": float(line.unit_price), "line_total": float(line.line_total), "snapshot": line.snapshot, } for index, line in enumerate(pricing.lines) ], "subtotal": float(pricing.subtotal), "member_discount": float(pricing.member_discount), "coupon_discount": float(pricing.coupon_discount), "points_discount": float(pricing.points_discount), "shipping_total": float(pricing.shipping_total), "tax_total": float(pricing.tax_total), "prices_include_tax": pricing.prices_include_tax, "grand_total": float(pricing.grand_total), "shipping_methods": shipping_methods, # 高级运费候选（强制模式才有）。展示文案与选中态由 Task 8 处理，这里只给结构化数据。 "advanced_shipping": None if quote.mode != "enforced" else { "mode": quote.mode, "reason_keys": list(quote.reason_keys), "quotes": [ { "shipping_method_id": q.shipping_method_id, "quote_group": q.quote_group, "delivery_mode": q.delivery_mode, "fee": float(q.fee), "currency": q.currency, "title_map": dict(q.title_map), "description_map": dict(q.description_map), } for q in quote.quotes ], }, "adjustments": [ {"type": adj.type, "label": adj.label, "amount": float(adj.amount)} for adj in pricing.adjustments ], } # ── 我的订单列表 ─────────────────────────────────────────────────────────── @router.get("", summary="我的订单（需顾客登录）") async def my_orders( page: int = Query(1, ge=1), page_size: int = Query(10, ge=1, le=200), status: Optional[str] = None, tid: int = Depends(get_tenant_by_domain), customer: Customer = Depends(get_current_customer), db: AsyncSession = Depends(get_db), ): tenant_id = tid filters = [Order.customer_id == customer.id, Order.tenant_id == tenant_id] if status: filters.append(Order.status == status) count_q = select(func.count(Order.id)).where(*filters) total = (await db.execute(count_q)).scalar() or 0 q = ( select(Order) .where(*filters) .order_by(Order.created_at.desc()) .offset((page - 1) * page_size) .limit(page_size) ) orders = (await db.execute(q)).scalars().all() order_ids = [o.id for o in orders] # 批量加载所有订单的商品明细 all_items: dict[int, list] = {o.id: [] for o in orders} if order_ids: ir = await db.execute( select(OrderItem).where(OrderItem.order_id.in_(order_ids)) ) for oi in ir.scalars().all(): all_items[oi.order_id].append(_item_out(oi)) return { "total": total, "page": page, "page_size": page_size, "items": [ { "id": o.id, "order_no": o.order_no, "status": o.status, "total": float(o.grand_total or 0), "grand_total": float(o.grand_total or 0), "created_at": o.created_at.isoformat() if o.created_at else None, "items_count": len(all_items[o.id]), "items": [item.model_dump() for item in all_items[o.id]], } for o in orders ], } # ── 订单详情（按 order_no）────────────────────────────────────────────────── @router.get("/{order_no}", summary="订单详情（按订单号）") async def order_detail( order_no: str, tid: int = Depends(get_tenant_by_domain), customer: Customer = Depends(get_current_customer), db: AsyncSession = Depends(get_db), ): tenant_id = tid r = await db.execute( select(Order).where( Order.order_no == order_no, Order.customer_id == customer.id, Order.tenant_id == tenant_id, ) ) order = r.scalar_one_or_none() if not order: raise HTTPException(status_code=404, detail="订单不存在") ir = await db.execute(select(OrderItem).where(OrderItem.order_id == order.id)) order_items = ir.scalars().all() return _order_to_detail(order, order_items) # ── 订单详情（按 order_id） — 合并自 orders_extended ─────────────────────── @router.get("/id/{order_id}", summary="订单详情（按 ID）") async def get_order_by_id( order_id: int, tid: int = Depends(get_tenant_by_domain), customer: Customer = Depends(get_current_customer), db: AsyncSession = Depends(get_db), ): tenant_id = tid r = await db.execute( select(Order).where( Order.id == order_id, Order.customer_id == customer.id, Order.tenant_id == tenant_id, ) ) order = r.scalar_one_or_none() if not order: raise HTTPException(status_code=404, detail="订单不存在") ir = await db.execute(select(OrderItem).where(OrderItem.order_id == order.id)) order_items = ir.scalars().all() return _order_to_detail(order, order_items) def _item_out(oi: OrderItem) -> OrderItemOut: snap = oi.product_snapshot or {} variant_text = snap.get("variant_text", "") return OrderItemOut( id=oi.id, product_id=oi.product_id, product_name=snap.get("name", f"商品#{oi.product_id}"), quantity=oi.quantity, unit_price=float(oi.unit_price or 0), total_price=float(oi.total_price or 0), variant_id=oi.variant_id, cover_url=snap.get("cover"), variant_text=variant_text, unit_name=snap.get("display_unit_name"), product_snapshot={ "name": snap.get("name", f"商品#{oi.product_id}"), "cover": snap.get("cover"), "variant": variant_text, "sku": snap.get("sku", ""), "attributes": snap.get("attributes", {}), "display_unit_name": snap.get("display_unit_name"), }, ) def _order_to_detail(order: Order, order_items) -> OrderDetailOut: extra = order.extra_attributes or {} grand_total = float(order.grand_total or 0) wallet_amount = float(extra.get("wallet_amount") or 0) payable_total = round(max(0.0, grand_total - wallet_amount), 2) member_discount = float(extra.get("member_discount") or 0) return OrderDetailOut( id=order.id, order_no=order.order_no, status=order.status, subtotal=float(order.subtotal or 0), discount_total=float(order.discount_total or 0), shipping_total=float(order.shipping_total or 0), grand_total=grand_total, member_discount=member_discount, wallet_amount=wallet_amount, payable_total=payable_total, created_at=order.created_at.isoformat() if order.created_at else None, paid_at=order.paid_at.isoformat() if order.paid_at else None, items=[_item_out(oi) for oi in order_items], shipping_address=order.shipping_address, purchase_order_number=extra.get("purchase_order_number"), delivery_type=extra.get("delivery_type"), pickup_code=extra.get("pickup_code"), shipping_method_id=order.shipping_method_id, note=order.note, coupon_code=extra.get("coupon_code"), coupon_label=extra.get("coupon_label") or extra.get("coupon_code"), pay_method=extra.get("pay_method"), promotions=extra.get("promotions") or [], points_used=extra.get("points_used") or 0, carrier=order.carrier, tracking_no=order.tracking_no, estimated_delivery=str(order.estimated_delivery) if order.estimated_delivery else None, shipments=extra.get("shipments") or [], adjustments=extra.get("adjustments") or [], ) # ── 取消订单 — 合并自 orders_extended ────────────────────────────────────── @router.post("/{order_no}/cancel", summary="取消订单（按订单号，仅 pending）") async def cancel_order_by_no( order_no: str, body: OrderCancelIn, tid: int = Depends(get_tenant_by_domain), customer: Customer = Depends(get_current_customer), db: AsyncSession = Depends(get_db), ): tenant_id = tid r = await db.execute( select(Order).where( Order.order_no == order_no, Order.customer_id == customer.id, Order.tenant_id == tenant_id, ).with_for_update() ) order = r.scalar_one_or_none() if not order: raise HTTPException(status_code=404, detail="订单不存在") return await _do_cancel_order(order, body.reason, customer, db) @router.post("/id/{order_id}/cancel", summary="取消订单（按 ID，仅 pending）") async def cancel_order_by_id( order_id: int, body: OrderCancelIn, tid: int = Depends(get_tenant_by_domain), customer: Customer = Depends(get_current_customer), db: AsyncSession = Depends(get_db), ): tenant_id = tid r = await db.execute( select(Order).where( Order.id == order_id, Order.customer_id == customer.id, Order.tenant_id == tenant_id, ).with_for_update() ) order = r.scalar_one_or_none() if not order: raise HTTPException(status_code=404, detail="订单不存在") return await _do_cancel_order(order, body.reason, customer, db) async def _do_cancel_order( order: Order, reason: Optional[str], customer: Customer, db: AsyncSession, ): if order.status != "pending": raise HTTPException(status_code=400, detail=f"当前状态「{order.status}」无法取消，仅能取消待付款订单") old_status = order.status order.status = "cancelled" if reason: order.extra_attributes = {**(order.extra_attributes or {}), "cancel_reason": reason} # 恢复库存（仅当旧状态属于扣库存状态时才恢复） _ts_r = await db.execute(select(TenantSettings).where(TenantSettings.tenant_id == order.tenant_id)) _ts = _ts_r.scalar_one_or_none() _deduct_statuses = inv_svc.get_deduct_statuses(_ts.extra if _ts else None) if old_status in _deduct_statuses: ir = await db.execute(select(OrderItem).where(OrderItem.order_id == order.id)) order_items = ir.scalars().all() restore_items = [ {"product_id": oi.product_id, "variant_id": oi.variant_id, "qty": oi.quantity} for oi in order_items ] await inv_svc.restore_stock(db=db, tenant_id=order.tenant_id, items=restore_items, order_id=order.id) # 恢复积分 points_used = (order.extra_attributes or {}).get("points_used", 0) if points_used: customer.points_balance += points_used await db.commit() order_status_changed.send( sender=Order, order=order, old_status=old_status, new_status="cancelled", tenant_id=order.tenant_id, ) return {"message": "订单已取消", "order_no": order.order_no, "status": "cancelled"} # ── 模拟付款 ────────────────────────────────────────────────────────────── @router.post("/{order_no}/pay", summary="模拟支付（仅开发环境可用）") async def pay_order( order_no: str, tid: int = Depends(get_tenant_by_domain), customer: Customer = Depends(get_current_customer), db: AsyncSession = Depends(get_db), ): if not _settings.DEBUG: raise HTTPException(status_code=404, detail="Not found") tenant_id = tid r = await db.execute( select(Order).where( Order.order_no == order_no, Order.customer_id == customer.id, Order.tenant_id == tenant_id, ).with_for_update() ) order = r.scalar_one_or_none() if not order: raise HTTPException(status_code=404, detail="订单不存在") # 幂等：已经是 paid 直接返回 if order.status == "paid": return {"message": "支付成功", "order_no": order.order_no, "status": "paid"} if order.status != "pending": raise HTTPException(status_code=400, detail=f"当前订单状态为「{order.status}」，无法付款") # 获取会员等级（含积分倍率） member_level: Optional[MemberLevel] = None if customer.member_level_id: ml_r = await db.execute( select(MemberLevel).where(MemberLevel.id == customer.member_level_id) ) member_level = ml_r.scalar_one_or_none() points_multiplier = Decimal("1.0000") if member_level: points_multiplier = member_level.points_multiplier # 计算本次订单积分 points_earned = int(math.floor(order.grand_total * points_multiplier)) # 更新订单状态 old_status = order.status order.status = "paid" order.paid_at = datetime.now() db.add(order) # 更新顾客积分和消费统计 customer.points_balance += points_earned customer.total_spent += order.grand_total customer.orders_count += 1 db.add(customer) # 写入积分流水 ledger = MemberPointsLedger( tenant_id=order.tenant_id, customer_id=customer.id, order_id=order.id, change_amount=points_earned, balance_after=customer.points_balance, reason="订单消费", note=f"订单 {order.order_no}", ) db.add(ledger) # 检查会员升级条件 if member_level and member_level.upgrade_spend: if customer.total_spent >= member_level.upgrade_spend: # 查下一等级 next_r = await db.execute( select(MemberLevel).where( MemberLevel.tenant_id == order.tenant_id, MemberLevel.rank > member_level.rank, MemberLevel.is_active == 1, ).order_by(MemberLevel.rank.asc()).limit(1) ) next_level = next_r.scalar_one_or_none() if next_level: customer.member_level_id = next_level.id await db.commit() order_paid.send(sender=Order, order=order, tenant_id=order.tenant_id) order_status_changed.send( sender=Order, order=order, old_status=old_status, new_status="paid", tenant_id=order.tenant_id, ) return { "message": "支付成功", "order_no": order.order_no, "status": "paid", "points_earned": points_earned, "points_balance": customer.points_balance, } # ── 确认收货 ────────────────────────────────────────────────────────────── @router.post("/{order_no}/confirm", summary="确认收货（将 shipped 订单改为 completed）") async def confirm_receipt( order_no: str, tid: int = Depends(get_tenant_by_domain), customer: Customer = Depends(get_current_customer), db: AsyncSession = Depends(get_db), ): tenant_id = tid r = await db.execute( select(Order).where( Order.order_no == order_no, Order.customer_id == customer.id, Order.tenant_id == tenant_id, ) ) order = r.scalar_one_or_none() if not order: raise HTTPException(status_code=404, detail="订单不存在") if order.status != "shipped": raise HTTPException(status_code=400, detail="订单尚未发货，无法确认收货") old_status = order.status order.status = "completed" db.add(order) await db.commit() order_status_changed.send( sender=Order, order=order, old_status=old_status, new_status="completed", tenant_id=order.tenant_id, ) return {"message": "确认收货成功", "order_no": order.order_no, "status": "completed"}