Skip to content

Commit

Permalink
feat: Transaction Processing logic & Wallet linking implementation (#…
Browse files Browse the repository at this point in the history 
…6399)

* feat: Transaction Processing logic & Wallet linking implementation

* Added jwt headers
  • Loading branch information
@mrsaicharan1 @uds5501
mrsaicharan1 authored and uds5501 committed Aug 23, 2019
1 parent a408e39 commit 23d0b57
Show file tree
Hide file tree
Showing 2 changed files with 127 additions and 12 deletions.
21 changes: 19 additions & 2 deletions app/api/helpers/payment.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
from app.api.helpers.utilities import represents_int
from app.models.stripe_authorization import StripeAuthorization
from app.settings import get_settings, Environment
from app.api.helpers.db import safe_query, save_to_db
from app.api.helpers.db import safe_query
from app.models import db
from app.models.order import Order

Expand Down Expand Up @@ -325,10 +325,27 @@ class PaytmPaymentsManager(object):
Class to manage PayTM payments
"""

@property
def paytm_endpoint(self):
if get_settings()['paytm_mode'] == 'test':
url = "https://securegw-stage.paytm.in/theia/api/v1/"
else:
url = "https://securegw.paytm.in/theia/api/v1/"
return url

@staticmethod
def generate_checksum(paytm_params):
if get_settings()['paytm_mode'] == 'sandbox':
if get_settings()['paytm_mode'] == 'test':
merchant_key = get_settings()['paytm_sandbox_secret']
else:
merchant_key = get_settings()['paytm_live_secret']
return checksum.generate_checksum_by_str(json.dumps(paytm_params["body"]), merchant_key)

@staticmethod
def hit_paytm_endpoint(url, head, body=None):
paytm_params = {}
paytm_params["body"] = body
paytm_params["head"] = head
post_data = json.dumps(paytm_params)
response = requests.post(url, data=post_data, headers={"Content-type": "application/json"}).json()
return response
118 changes: 108 additions & 10 deletions app/api/orders.py
View file
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
import logging
import json
import pytz
from datetime import datetime
import time
import omise
import requests


import omise
from datetime import datetime
from flask import request, jsonify, Blueprint, url_for, redirect
from flask_jwt_extended import current_user
from flask_rest_jsonapi import ResourceDetail, ResourceList, ResourceRelationship
Expand Down Expand Up @@ -41,6 +41,7 @@
from app.models.ticket_holder import TicketHolder
from app.models.user import User


order_misc_routes = Blueprint('order_misc', __name__, url_prefix='/v1')
alipay_blueprint = Blueprint('alipay_blueprint', __name__, url_prefix='/v1/alipay')

Expand Down Expand Up @@ -543,7 +544,6 @@ def create_paypal_payment(order_identifier):
else:
return jsonify(status=False, error=response)


@order_misc_routes.route('/orders/<string:order_identifier>/verify-mobile-paypal-payment', methods=['POST'])
@jwt_required
def verify_mobile_paypal_payment(order_identifier):
Expand Down Expand Up @@ -629,6 +629,7 @@ def omise_checkout(order_identifier):


@order_misc_routes.route('/orders/<string:order_identifier>/paytm/initiate-transaction', methods=['POST', 'GET'])
@jwt_required
def initiate_transaction(order_identifier):
"""
Initiating a PayTM transaction to obtain the txn token
Expand All @@ -641,14 +642,14 @@ def initiate_transaction(order_identifier):
# body parameters
paytm_params["body"] = {
"requestType": "Payment",
"mid": (get_settings()['paytm_sandbox_merchant'] if paytm_mode == 'sandbox'
"mid": (get_settings()['paytm_sandbox_merchant'] if paytm_mode == 'test'
else get_settings()['paytm_live_merchant']),
"websiteName": "eventyay",
"orderId": order.id,
"orderId": order_identifier,
"callbackUrl": "",
"txnAmount": {
"value": order.amount,
"currency": order.event.payment_currency,
"currency": "INR",
},
"userInfo": {
"custId": order.user.id,
Expand All @@ -660,11 +661,108 @@ def initiate_transaction(order_identifier):
"signature" : checksum
}
post_data = json.dumps(paytm_params)
if paytm_mode == 'sandbox':
if paytm_mode == 'test':
url = "https://securegw-stage.paytm.in/theia/api/v1/initiateTransaction?mid={}&orderId={}".\
format(get_settings()['paytm_sandbox_merchant'], order.id)
format(get_settings()['paytm_sandbox_merchant'], order_identifier)
else:
url = "https://securegw.paytm.in/theia/api/v1/initiateTransaction?mid={}&orderId={}".\
format(get_settings()['paytm_sandbox_merchant'], order.id)
format(get_settings()['paytm_live_merchant'], order_identifier)
response = requests.post(url, data=post_data, headers={"Content-type": "application/json"})
return response.json()


@order_misc_routes.route('/orders/<string:order_identifier>/paytm/fetch-payment-options/<string:txn_token>')
@jwt_required
def fetch_payment_options(order_identifier, txn_token):
paytm_mode = get_settings()['paytm_mode']
if paytm_mode == 'test':
url = "https://securegw-stage.paytm.in/theia/api/v1/fetchPaymentOptions?mid={}&orderId={}".\
format(get_settings()['paytm_sandbox_merchant'], order_identifier)
else:
url = "https://securegw.paytm.in/theia/api/v1/fetchPaymentOptions?mid={}&orderId={}".\
format(get_settings()['paytm_live_merchant'], order_identifier)
head = {
"clientId": "C11",
"version": "v1",
"requestTimestamp": str(int(time.time())),
"channelId": "WEB",
"txnToken": txn_token
}
response = PaytmPaymentsManager.hit_paytm_endpoint(url=url, head=head)
return response


@order_misc_routes.route('/orders/<string:order_identifier>/paytm/send_otp/<string:txn_token>', methods=['POST'])
@jwt_required
def send_otp(order_identifier, txn_token):
paytm_mode = get_settings()['paytm_mode']
if paytm_mode == 'test':
url = "https://securegw-stage.paytm.in/theia/api/v1/login/sendOtp?mid={}&orderId={}".\
format(get_settings()['paytm_sandbox_merchant'], order_identifier)
else:
url = "https://securegw.paytm.in/theia/api/v1/login/sendOtp?mid={}&orderId={}".\
format(get_settings()['paytm_live_merchant'], order_identifier)

head = {
"clientId": "C11",
"version": "v1",
"requestTimestamp": str(int(time.time())),
"channelId": "WEB",
"txnToken": txn_token
}
body = {"mobileNumber": request.json['data']['phone']}
response = PaytmPaymentsManager.hit_paytm_endpoint(url=url, head=head, body=body)
return response


@order_misc_routes.route('/orders/<string:order_identifier>/paytm/validate_otp/<string:txn_token>', methods=['POST'])
def validate_otp(order_identifier, txn_token):
paytm_mode = get_settings()['paytm_mode']
if paytm_mode == 'test':
url = "https://securegw-stage.paytm.in/theia/api/v1/login/validateOtp?mid={}&orderId={}".\
format(get_settings()['paytm_sandbox_merchant'], order_identifier)
else:
url = "https://securegw.paytm.in/theia/api/v1/login/validateOtp?mid={}&orderId={}".\
format(get_settings()['paytm_live_merchant'], order_identifier)
head = {
"clientId": "C11",
"version": "v1",
"requestTimestamp": str(int(time.time())),
"channelId": "WEB",
"txnToken": txn_token
}
body = {"otp": request.json['data']['otp']}
response = PaytmPaymentsManager.hit_paytm_endpoint(url=url, head=head, body=body)
return response


@order_misc_routes.route('/orders/<string:order_identifier>/paytm/process_transaction/<string:txn_token>')
@jwt_required
def process_transaction(order_identifier, txn_token):
paytm_mode = get_settings()['paytm_mode']
merchant_id = (get_settings()['paytm_sandbox_merchant'] if paytm_mode == 'test'
else get_settings()['paytm_live_merchant'])

if paytm_mode == 'test':
url = "https://securegw-stage.paytm.in/theia/api/v1/processTransaction?mid={}&orderId={}".\
format(get_settings()['paytm_sandbox_merchant'], order_identifier)
else:
url = "https://securegw.paytm.in/theia/api/v1/processTransaction?mid={}&orderId={}".\
format(get_settings()['paytm_live_merchant'], order_identifier)

head = {
"version": "v1",
"requestTimestamp": str(int(time.time())),
"channelId": "WEB",
"txnToken": txn_token
}

body = {
"requestType": "NATIVE",
"mid": merchant_id,
"orderId": order_identifier,
"paymentMode": "BALANCE"
}

response = PaytmPaymentsManager.hit_paytm_endpoint(url=url, head=head, body=body)
return response

0 comments on commit 23d0b57

Please sign in to comment.