{escape(message)}
', status=status, ) class BazaarVerifyPurchaseView(APIView): """ POST /api/payment/bazaar/verify — تایید پرداخت درون‌برنامه‌ای بازار GET /api/payment/bazaar/verify?code=… — Redirect URIِ OAuthِ بازار همین آدرس در پنلِ بازار Redirect URI ثبت شده (خواستِ مدیرِ حساب، ۲۰۲۶-۰۹-۲۶)، پس دو کار دارد که با متد از هم جدا می‌شوند: GET را مرورگرِ صاحبِ حساب بعد از «اجازه» می‌زند و بی‌احراز است (فقط داخلِ پنجره‌ای که start_authorization باز کرده اثر دارد)؛ POST را اپِ اندروید بعد از خرید. برخلاف درگاه معمولی که با webhook خودِ درگاه تایید می‌شه، در پرداخت درون‌برنامه‌ای بازار هیچ webhookی نیست: کلاینت اندروید بعد از خرید از SDK بازار (IInAppBillingService)، یک purchaseToken می‌گیره و باید همون رو برای این endpoint بفرسته تا بک‌اند با فراخوانی سرور-به-سرور به API رسمی بازار (bazaar.verify_purchase)، صحتش رو تایید کنه — مشابه دقیقاً همون چیزی که سند رسمی بازار توصیه می‌کنه: «هیچ‌وقت فقط به گفته‌ی کلاینت اعتماد نکنید، حتماً سمت سرور verify کنید». """ permission_classes = [IsAuthenticated] # این endpoint یک فراخوانیِ سرور-به-سرورِ واقعی به API بازار (verify_purchase) # تریگر می‌کنه، برای همین throttle_scope مجزا و نرخِ سخت‌گیرانه‌تر (۱۰/hour) # داره. throttle_scope = 'bazaar_verify' throttle_classes = [ScopedRateThrottle] def get_permissions(self): if self.request.method == 'GET': return [AllowAny()] return super().get_permissions() def get_throttles(self): if self.request.method == 'GET': self.throttle_scope = 'bazaar_oauth' return super().get_throttles() @extend_schema(exclude=True) def get(self, request): if request.query_params.get('error'): return _bazaar_oauth_page( f'بازار اجازه نداد: {request.query_params.get("error")}', status=400, ) code = request.query_params.get('code', '') if not code: return _bazaar_oauth_page( 'این آدرس برای برگشت از بازار است و بدون code کاری نمی‌کند.', status=400, ) try: bazaar.complete_authorization(code=code, state=request.query_params.get('state', '')) except bazaar.BazaarAuthorizationError as exc: return _bazaar_oauth_page(str(exc), status=400) return _bazaar_oauth_page('اتصال به بازار انجام شد. می‌توانید این صفحه را ببندید.', status=200) @extend_schema( request=BazaarVerifyRequestSerializer, responses=BazaarVerifyResponseSerializer, tags=['Payment (payment)'], ) def post(self, request): serializer = BazaarVerifyRequestSerializer(data=request.data) serializer.is_valid(raise_exception=True) v = serializer.validated_data # verify_purchase (تا ~۲۰ ثانیه، دو درخواستِ پشت‌سرهم) عمداً *قبل* از # بازشدنِ atomic/lock صدا زده می‌شه، نه داخلش — وگرنه ردیفِ Order (و هر # تراکنشِ دیگه‌ای روی همون Order/Subscription) تا برگشتِ پاسخِ بازار # قفل می‌موند. لاک فقط برای اعمالِ نتیجه (چند میلی‌ثانیه) گرفته می‌شه. order_lookup = get_object_or_404( Order, pk=v['orderId'], user_id=request.user.id, provider='bazaar', ) # SKU فقط از خودِ سفارش. تا ۲۰۲۶-۱۰-۰۳ اگر سفارش SKU نداشت، SKUِ فرستاده‌ی کلاینت سنجیده # می‌شد؛ یعنی توکنِ خریدِ ارزان‌ترین محصول سفارشِ گران‌ترین پلن را «paid» می‌کرد. if not order_lookup.bazaar_product_sku: raise ValidationError({'orderId': 'این سفارش محصولِ بازار ندارد.'}) if self._second_purchase_on_paid_order(order_lookup, v['purchaseToken']): return self._second_purchase_response() # فقط اشتراک از بازار فروخته می‌شود (subscription.0017)؛ سفارشِ بی‌اشتراک چیزی برای فعال کردن ندارد. if not order_lookup.subscription_id: raise ValidationError({'orderId': 'این سفارش اشتراکی ندارد.'}) result = bazaar.verify_purchase( product_sku=order_lookup.bazaar_product_sku, purchase_token=v['purchaseToken'], ) with transaction.atomic(): order = get_object_or_404( Order.objects.select_for_update(), pk=v['orderId'], user_id=request.user.id, provider='bazaar', ) if self._second_purchase_on_paid_order(order, v['purchaseToken']): return self._second_purchase_response() new_status = 'paid' if result.is_valid else 'failed' # توکن فقط با پاسخِ «معتبر» روی سفارش و تراکنش می‌نشیند. قیدِ یکتای (gateway, ref) همه‌ی # وضعیت‌ها را می‌گیرد؛ وقتی ردِ بازار (not_found، یا توکن با سفارشِ اشتباه) هم توکن را ثبت # می‌کرد، همان خرید دیگر روی هیچ سفارشی، حتی همین، «paid» نمی‌شد (بازتولید شد). if result.is_valid: order.bazaar_purchase_token = v['purchaseToken'] order.bazaar_valid_until = result.valid_until order.save(update_fields=['bazaar_purchase_token', 'bazaar_valid_until']) apply_order_payment_result( order=order, gateway='bazaar', gateway_ref_id=v['purchaseToken'] if result.is_valid else '', new_status=new_status, event='bazaar_verify', ) # apply_order_payment_result سفارش را از نو می‌خواند و همان را عوض می‌کند؛ این نمونه هنوز # وضعیتِ پیش از پرداخت را دارد. بدونِ این، پاسخ «pending» بود درحالی‌که سفارش «paid» شده بود. order.refresh_from_db(fields=['status']) data = {'orderId': str(order.id), 'status': order.status, 'valid': result.is_valid} return Response(BazaarVerifyResponseSerializer(data).data) @staticmethod def _second_purchase_on_paid_order(order, purchase_token: str) -> bool: """ خریدِ دیگری برای سفارشی که با یک خریدِ دیگر پرداخت شده. پیش‌تر پاسخ «paid» بود، چیزی داده نمی‌شد و توکنِ دوم هم برای هر سفارشِ بعدی سوخته بود؛ کاربر دو بار پول داده بود. """ # «refunded» هم: سفارشِ بازپرداخت‌شده با توکنِ تازه دوباره «paid» می‌شد ولی اعتبارش (که یک بار # برای همین سفارش داده شده بود) دیگر داده نمی‌شد؛ کاربر پولِ خریدِ دوم را بی‌هیچ چیزی می‌داد. return (order.status in ('paid', 'refunded') and bool(order.bazaar_purchase_token) and order.bazaar_purchase_token != purchase_token) @staticmethod def _second_purchase_response(): return Response({'detail': 'این سفارش با خریدِ دیگری پرداخت شده است؛ برای این خرید سفارشِ تازه بساز.'}, status=status.HTTP_409_CONFLICT) class BazaarStartPurchaseView(APIView): """ POST /api/payment/bazaar/orders/{id}/start — آنچه اپِ اندروید برای شروعِ خرید در بازار لازم دارد. پس از ساخت سفارش (`POST /api/subscription/purchase` با `paymentMethod: bazaar`) و کدِ تخفیفِ احتمالی (`POST /api/discount/redeem`) صدا زده می‌شود. اگر کدِ تخفیف مبلغ را کم کرده، `dynamicPriceToken` همان مبلغ را (به ریال) برای بازار امضا می‌کند؛ بی‌تخفیف null است و بازار قیمتِ پیشخان را می‌گیرد (عمداً: توکن روی بازارِ قدیمی‌تر از ۱۳.۳ خطا می‌دهد). بعد از این، کدِ تخفیفِ تازه روی سفارش نمی‌نشیند. """ permission_classes = [IsAuthenticated] throttle_scope = 'bazaar_start' throttle_classes = [ScopedRateThrottle] @extend_schema(request=None, responses=BazaarStartResponseSerializer, tags=['Payment (payment)']) def post(self, request, order_id): with transaction.atomic(): order = get_object_or_404( Order.objects.select_for_update(), pk=order_id, user_id=request.user.id, provider='bazaar') if order.status != 'pending': raise ValidationError({'orderId': 'این سفارش دیگر در انتظارِ پرداخت نیست.'}) if not order.bazaar_product_sku: raise ValidationError({'orderId': 'این سفارش محصولِ بازار ندارد.'}) token = None full_price = order.list_price if order.list_price is not None else order.amount if order.amount < full_price: if not bazaar.dynamic_price_configured(): # redeem بی‌کلید تخفیف را روی سفارشِ بازار نمی‌گذارد؛ رسیدن به این‌جا یعنی کلید بعد از آن # از .env رفته. بی‌توکن بازار قیمتِ کامل را می‌گرفت. logger.error('bazaar start: سفارشِ %s تخفیف دارد ولی BAZAAR_DYNAMIC_PRICE_KEY نیست', order.id) raise bazaar.BazaarAPIError() price_rial = _to_rial(order.amount, order.currency) token = bazaar.dynamic_price_token(sku=order.bazaar_product_sku, price_rial=price_rial) order.bazaar_price_rial = price_rial order.save(update_fields=['bazaar_price_rial']) elif order.bazaar_price_rial is None: # علامتِ «خرید شروع شد» تا کدِ تخفیفِ بعدی نیاید؛ قیمت همان قیمتِ کامل است. order.bazaar_price_rial = _to_rial(order.amount, order.currency) order.save(update_fields=['bazaar_price_rial']) events.record('bazaar_start', order=order, amount=order.amount, discounted=token is not None) data = { 'orderId': str(order.id), 'sku': order.bazaar_product_sku, 'amount': order.amount, 'dynamicPriceToken': token, } return Response(BazaarStartResponseSerializer(data).data) def _to_rial(amount: int, currency: str) -> int: if currency == 'IRT': return amount * 10 if currency == 'IRR': return amount raise ValueError(f'unknown currency {currency!r}') class OrderDetailView(APIView): """GET /api/payment/orders/{id} — وضعیت سفارش""" # سقفِ نرخِ این مسیر تا ۲۰۲۶-۱۰-۰۷ نبود؛ `read` همان نرخِ مسیرهای هم‌خانواده است. throttle_scope = 'read' throttle_classes = [ScopedRateThrottle] permission_classes = [IsAuthenticated] @extend_schema(responses=OrderDetailResponseSerializer, tags=['Payment (payment)']) def get(self, request, order_id): order = get_object_or_404(Order, pk=order_id, user_id=request.user.id) if reconcile_pending_order(order): order.refresh_from_db() data = { 'orderId': str(order.id), 'status': order.status, 'amount': order.amount, 'transactions': [ { 'id': str(t.id), 'gateway': t.gateway, 'status': t.status, 'paidAt': t.paid_at, } for t in order.transactions.all() ], } return Response(OrderDetailResponseSerializer(data).data) INVOICE_LIMIT = 50 def invoice_payload(order) -> dict: """یک سفارش به شکلِ فاکتور. کدِ تخفیف و کدِ پیگیری از جدول‌های خودشان خوانده می‌شوند.""" from discount.models import Redemption redemption = Redemption.objects.filter(order_id=order.id).select_related('discount_code').first() paid = next((t for t in order.transactions.all() if t.status == 'paid'), None) # کدِ تخفیفِ ۱۰۰٪ هم یک Transactionِ «paid» می‌سازد، با refی ساختگی (discount-…)؛ # آن کدِ پیگیریِ بانکی نیست و به کاربر نشان داده نمی‌شود. ref = paid.gateway_ref_id if paid and paid.gateway != 'discount' else '' return { 'orderId': str(order.id), 'invoiceNumber': f'TD-{order.id:06d}', 'status': order.status, 'provider': order.provider, 'planTitle': order.plan_title, 'listPrice': order.list_price, 'discountAmount': (order.list_price - order.amount) if order.list_price is not None else None, 'discountCode': redemption.discount_code.code if redemption else '', 'amount': order.amount, 'currency': order.currency, 'createdAt': order.created_at, 'paidAt': paid.paid_at if paid else None, 'refId': ref, } class InvoiceListView(APIView): """ GET /api/payment/invoices — پرداخت‌ها و فاکتورهای خودِ کاربر، تازه‌ترین اول. همه‌ی سفارش‌ها برمی‌گردند، نه فقط پرداخت‌شده‌ها، تا کسی که پولش کم شده ولی اشتراکش فعال نشده سفارشِ «در انتظار» یا «ناموفق» خودش را ببیند و کدش را به پشتیبانی بدهد. این‌جا از زرین‌پال بازسنجی نمی‌شود (برای ۵۰ سفارش ۵۰ فراخوانی می‌شد)؛ GET /api/payment/orders/{id} و وضعیتِ اشتراک این کار را می‌کنند. """ permission_classes = [IsAuthenticated] throttle_scope = 'read' throttle_classes = [ScopedRateThrottle] @extend_schema(responses=InvoiceListResponseSerializer, tags=['Payment (payment)']) def get(self, request): orders = (Order.objects.filter(user_id=request.user.id) .prefetch_related('transactions').order_by('-created_at', '-id')[:INVOICE_LIMIT]) return Response(InvoiceListResponseSerializer({'invoices': [invoice_payload(o) for o in orders]}).data)