ark_backend/app/api/api_v1/endpoints/linepay.py

import uuid

from fastapi import APIRouter
from fastapi.param_functions import Depends
from linepay import LinePayApi
from fastapi.templating import Jinja2Templates
from sqlalchemy.orm.session import Session
from app import crud, models, schemas
from app.api import deps
from app.db import session

# template
templates = Jinja2Templates(directory="templates")

router = APIRouter()

LINE_PAY_CHANNEL_ID = "1656387996"
SECRET_KEY = "37336af5452f74ee871a9fa38d81602e"

HOST_NAME = "https://api.ptt.cx:8750"
# Line Pay Config
LINE_PAY_CHANNEL_ID = LINE_PAY_CHANNEL_ID
LINE_PAY_CHANNEL_SECRET = "37336af5452f74ee871a9fa38d81602e"
# LINE_PAY_REQEST_BASE_URL = "https://{}".format(HOST_NAME)
LINE_PAY_REQEST_BASE_URL = "https://api.ptt.cx:8750"
line = LinePayApi(
    LINE_PAY_CHANNEL_ID, LINE_PAY_CHANNEL_SECRET, is_sandbox=True
)

# CACHE
CACHE = {}


# Request
@router.post('/request')
async def pay_request(nft_id: str, db: Session = Depends(deps.get_db)):
    order_id = str(uuid.uuid4())
    amount = "1"
    currency = "TWD"
    nft = crud.nft.get(db=db, id=nft_id)


    request_options = {
        "amount": amount,
        "currency": currency,
        "orderId": order_id,
        "packages": [
            {
                "id": "NFT",
                "amount": 1,
                "products": [
                    {
                        "name": nft.title,
                        "quantity": 1,
                        "price": 1,
                        "imageUrl": nft.imgurl
                    }
                ]
            }

        ],
        "redirectUrls": {
            "confirmUrl": LINE_PAY_REQEST_BASE_URL + "/confirm/"
            # "cancelUrl": LINE_PAY_REQEST_BASE_URL + "/cancel/"
        }
    }
    response = line.request(request_options)
    transaction_id = int(response.get("info", {}).get("transactionId", 0))
    check_result = line.check_payment_status(transaction_id)
    response["transaction_id"] = transaction_id
    response["paymentStatusCheckReturnCode"] = check_result.get(
        "returnCode", None
    )
    response["paymentStatusCheckReturnMessage"] = check_result.get(
        "returnMessage", None
    )
    # return response
    return response


# Confirm
@router.get('/confirm/')
async def pay_confirm(
    transactionId: int = "transactionId",
):
    CACHE["transaction_id"] = transactionId
    response = line.confirm(
        transactionId, float(CACHE.get("amount", 0)),
        CACHE.get("currency", "TWD"))
    check_result = line.check_payment_status(transactionId)
    payment_details = line.payment_details(transaction_id=transactionId)
    response["transaction_id"] = transactionId
    response["paymentStatusCheckReturnCode"] = check_result.get(
        "returnCode", None
    )
    response["paymentStatusCheckReturnMessage"] = check_result.get(
        "returnMessage", None
    )
    response["payment_details"] = payment_details
    if(response["paymentStatusCheckReturnCode"] == '0123'):
        # return response
        return "confirm.html", {"request": response}
    else:
        return "Not found"