change amount in payment service

backend/src/modules/authentication/authentication.service.ts

@@ -28,7 +28,7 @@ export class AuthenticationService {
     if (!compare) {
       throw new UnauthorizedException("Wrong password");
     }
-    const payload = { sub: user.id, username: user.full_name, roles: user.role};
+    const payload = { sub: user.id, username: user.full_name, role: user.role};
     return {
       access_token: await this.jwtService.signAsync(payload),
     };

backend/src/payment/dto/{create-payment.dto.ts → create-payment-url.dto.ts}

@@ -1,6 +1,6 @@
 import { IsNumber, IsOptional, IsString } from "class-validator"
 
-export class CreatePaymentDto {
+export class CreatePaymentUrlDto {
     @IsNumber()
     amount: number
 
@@ -8,6 +8,9 @@ export class CreatePaymentDto {
     @IsString()
     bankCode: string
 
+    @IsString()
+    orderId: string
+
     @IsString()
     orderDescription: string
 

backend/src/payment/dto/create-payment.dto..ts

@@ -0,0 +1,38 @@
+import { IsNumber, IsOptional, IsString } from 'class-validator';
+
+export class CreatePaymentDto {
+    @IsNumber()
+    payment_method: number;
+
+    @IsNumber()
+    vnp_amount: number
+
+    @IsString()
+    vnp_bank_code: string
+
+    @IsString()
+    vnp_bank_tran_no: string
+
+    @IsNumber()
+    vnp_card_type: number
+
+    @IsString()
+    @IsOptional()
+    vnp_order_info: string //Nội dung giao dịch
+
+    @IsString()
+    @IsOptional()
+    vnp_paydate: string
+
+    @IsString()
+    @IsOptional()
+    vnp_response_code: number
+
+    @IsString()
+    @IsOptional()
+    vnp_transaction_no: string
+
+    @IsString()
+    @IsOptional()
+    vnp_transaction_status: number
+}

backend/src/payment/dto/update-payment.dto.ts

@@ -1,4 +0,0 @@
-import { PartialType } from '@nestjs/mapped-types';
-import { CreatePaymentDto } from './create-payment.dto';
-
-export class UpdatePaymentDto extends PartialType(CreatePaymentDto) {}

backend/src/payment/payment.controller.ts

@@ -3,7 +3,7 @@ import { Controller, Post, Body, Req, Res, Get } from '@nestjs/common';
 import { PaymentService } from './payment.service.js';
 import { Request, Response } from 'express';
 import { Public } from '../modules/authentication/authentication.decorator.js';
-import { CreatePaymentDto } from './dto/create-payment.dto.js';
+import { CreatePaymentUrlDto } from './dto/create-payment-url.dto.js';
 
 @Controller('payment')
 export class PaymentController {
@@ -11,7 +11,7 @@ export class PaymentController {
 
   @Public()
   @Post('create_payment_url')
-  async createPaymentUrl(@Req() req: Request, @Body() body: CreatePaymentDto) {
+  async createPaymentUrl(@Req() req: Request, @Body() body: CreatePaymentUrlDto) {
 
     const ipAddr =
       req.headers['x-forwarded-for'] ||
@@ -20,7 +20,7 @@ export class PaymentController {
 
     return await this.paymentService.createPaymentUrl(
       body.amount,
-      body.bankCode,
+      body.orderId,
       body.orderDescription,
       body.orderType,
       body.language,

backend/src/payment/payment.module.ts

@@ -1,9 +1,11 @@
 import { Module } from '@nestjs/common';
 import { PaymentService } from './payment.service.js';
 import { PaymentController } from './payment.controller.js';
+import { OrderService } from '../modules/order/order.service.js';
+import { BranchService } from '../modules/branch/branch.service.js';
 
 @Module({
   controllers: [PaymentController],
-  providers: [PaymentService],
+  providers: [PaymentService, OrderService, BranchService],
 })
 export class PaymentModule {}

backend/src/payment/payment.service.ts

@@ -3,12 +3,20 @@ import { HttpStatus, Injectable } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
 import * as querystring from 'qs';
 import * as crypto from 'crypto';
+import { OrderService } from '../modules/order/order.service.js';
+import { PaymentEntity } from '../entities/payment.entity.js';
+import { CreatePaymentUrlDto } from './dto/create-payment-url.dto.js';
+import { CreatePaymentDto } from './dto/create-payment.dto..js';
+import { VnpCardType } from '../common/enums/VnpCardType.enum.js';
 
 @Injectable()
 export class PaymentService {
-  constructor(private readonly configService: ConfigService) {}
+  constructor(
+    private readonly configService: ConfigService,
+    private readonly orderService: OrderService
+  ) { }
 
-  async createPaymentUrl(amount: number, bankCode: string, orderDescription: string, orderType: string, language: string, ipAddr: string) {
+  async createPaymentUrl(amount: number, orderId: string, orderDescription: string, orderType: string, language: string, ipAddr: string) {
 
     const tmnCode = this.configService.get<string>('vnp_TmnCode');
     const secretKey = this.configService.get<string>('vnp_HashSecret');
@@ -17,7 +25,6 @@ export class PaymentService {
 
     const date = new Date();
     const createDate = this.formatDate(date, 'yyyymmddHHmmss');
-    const orderId = Date.now().toString();
     const locale = language || 'vn';
     const currCode = 'VND';
 
@@ -36,9 +43,6 @@ export class PaymentService {
       vnp_CreateDate: createDate,
     };
     console.log("3")
-    if (bankCode) {
-      vnp_Params['vnp_BankCode'] = bankCode;
-    }
 
     const sortedParams = this.sortObject(vnp_Params);
 
@@ -55,11 +59,11 @@ export class PaymentService {
   }
 
 
-  vnpayIpn(reqQuery){
+  async vnpayIpn(reqQuery) {
     console.log("helloooo")
     let vnp_Params = reqQuery;
     let secureHash = vnp_Params['vnp_SecureHash'];
-    
+
     let orderId = vnp_Params['vnp_TxnRef'];
     let rspCode = vnp_Params['vnp_ResponseCode'];
 
@@ -70,92 +74,122 @@ export class PaymentService {
     let secretKey = this.configService.get('vnp_HashSecret');
     let signData = querystring.stringify(vnp_Params, { encode: false });
     let hmac = crypto.createHmac("sha512", secretKey);
-    let signed = hmac.update(Buffer.from(signData, 'utf-8')).digest("hex");     
-    
+    let signed = hmac.update(Buffer.from(signData, 'utf-8')).digest("hex");
+
     let paymentStatus = '0'; // Giả sử '0' là trạng thái khởi tạo giao dịch, chưa có IPN. Trạng thái này được lưu khi yêu cầu thanh toán chuyển hướng sang Cổng thanh toán VNPAY tại đầu khởi tạo đơn hàng.
     //let paymentStatus = '1'; // Giả sử '1' là trạng thái thành công bạn cập nhật sau IPN được gọi và trả kết quả về nó
     //let paymentStatus = '2'; // Giả sử '2' là trạng thái thất bại bạn cập nhật sau IPN được gọi và trả kết quả về nó
-    
-    let checkOrderId = true; // Mã đơn hàng "giá trị của vnp_TxnRef" VNPAY phản hồi tồn tại trong CSDL của bạn
-    let checkAmount = true; // Kiểm tra số tiền "giá trị của vnp_Amout/100" trùng khớp với số tiền của đơn hàng trong CSDL của bạn
-    if(secureHash === signed){ //kiểm tra checksum
-        if(checkOrderId){
-            if(checkAmount){
-                if(paymentStatus=="0"){ //kiểm tra tình trạng giao dịch trước khi cập nhật tình trạng thanh toán
-                    if(rspCode=="00"){
-                        //thanh cong
-                        //paymentStatus = '1'
-                        // Ở đây cập nhật trạng thái giao dịch thanh toán thành công vào CSDL của bạn
-                        return {
-                          statusCode: HttpStatus.OK,
-                          message: 'Thành công!',
-                          data: { /* dữ liệu trả về nếu có */ },
-                        };
-                    }
-                    else {
-                        //that bai
-                        //paymentStatus = '2'
-                        // Ở đây cập nhật trạng thái giao dịch thanh toán thất bại vào CSDL của bạn
-                        return {
-                          statusCode: HttpStatus.OK,
-                          message: 'Thất bại',
-                          data: { /* dữ liệu trả về nếu có */ },
-                        };
-                    }
-                }
-                else{
-                  return {
-                    statusCode: HttpStatus.OK,
-                    message: 'This order has been updated to the payment status',
-                    data: { /* dữ liệu trả về nếu có */ },
-                  };
-                }
+    //Kiểm tra có đúng order id không
+    let checkOrderId = true;
+    let order;
+    try {
+      order = await this.orderService.findOne(orderId)
+    } catch (error) {
+      checkOrderId = false;
+    }
+    // Kiểm tra s��� tiền "giá trị của vnp_Amout/100" trùng khớp với số tiền của đơn hàng trong CSDL của bạn
+    let checkAmount = order.total_value == parseFloat(vnp_Params["vnp_Amount"])/100; 
+    if (secureHash === signed) { //kiểm tra checksum
+      if (checkOrderId) {
+        if (checkAmount) {
+          if (paymentStatus == "0") { //kiểm tra tình trạng giao dịch trước khi cập nhật tình trạng thanh toán
+            if (rspCode == "00") {
+              //thanh cong
+              //paymentStatus = '1'
+              // Ở đây cập nhật trạng thái giao dịch thanh toán thành công vào CSDL của bạn
+              const payment = await this.create({
+                payment_method: 2,
+                vnp_amount: parseFloat(vnp_Params["vnp_Amount"])/100,
+                vnp_bank_code: vnp_Params['vnp_BankCode'],
+                vnp_bank_tran_no: vnp_Params['vnp_BankTranNo'],
+                vnp_card_type: VnpCardType[vnp_Params['vnp_CardType'] as keyof typeof VnpCardType],
+                vnp_order_info: vnp_Params['vnp_BankTranNo'],
+                vnp_paydate: vnp_Params['vnp_PayDate'],
+                vnp_response_code: vnp_Params['vnp_ResponseCode'],
+                vnp_transaction_no: vnp_Params['vnp_TransactionNo'],
+                vnp_transaction_status: vnp_Params['vnp_TransactionStatus'],
+              });
+              await PaymentEntity.save(payment);
+              this.orderService.updateOrderPayment(orderId, payment.id)
+              return {
+                statusCode: HttpStatus.OK,
+                message: 'Thành công!',
+              };
             }
-            else{
+            else {
+              //that bai
+              //paymentStatus = '2'
+              // Ở đây cập nhật trạng thái giao dịch thanh toán thất bại vào CSDL của bạn
               return {
                 statusCode: HttpStatus.OK,
-                message: 'Amount invalid',
-                data: { /* dữ liệu trả về nếu có */ },
+                message: 'Thất bại',
               };
             }
-        }       
+          }
+          else {
+            return {
+              statusCode: HttpStatus.OK,
+              message: 'This order has been updated to the payment status',
+            };
+          }
+        }
         else {
           return {
             statusCode: HttpStatus.OK,
-            message: 'Order not found',
-            data: { /* dữ liệu trả về nếu có */ },
+            message: 'Amount invalid',
           };
         }
+      }
+      else {
+        return {
+          statusCode: HttpStatus.OK,
+          message: 'Order not found',
+        };
+      }
     }
     else {
       return {
         statusCode: HttpStatus.OK,
         message: 'Checksum failed!',
-        data: { /* dữ liệu trả về nếu có */ },
       };
     }
   }
 
-    // Format date helper function
-    formatDate(date: Date, format: string): string {
-      const yyyymmdd = date.toISOString().slice(0, 10).replace(/-/g, ''); // YYYYMMDD
-      const hhmmss = date.toTimeString().slice(0, 8).replace(/:/g, ''); // HHMMSS
-      return format === 'yyyymmddHHmmss' ? yyyymmdd + hhmmss : hhmmss;
-    }
-  
-    sortObject(obj) {
-      let sorted = {};
-      let str = [];
-      let key;
-      for (key in obj){
-        if (obj.hasOwnProperty(key)) {
+  // Format date helper function
+  formatDate(date: Date, format: string): string {
+    const yyyymmdd = date.toISOString().slice(0, 10).replace(/-/g, ''); // YYYYMMDD
+    const hhmmss = date.toTimeString().slice(0, 8).replace(/:/g, ''); // HHMMSS
+    return format === 'yyyymmddHHmmss' ? yyyymmdd + hhmmss : hhmmss;
+  }
+
+  sortObject(obj) {
+    let sorted = {};
+    let str = [];
+    let key;
+    for (key in obj) {
+      if (obj.hasOwnProperty(key)) {
         str.push(encodeURIComponent(key));
-        }
       }
-      str.sort();
-        for (key = 0; key < str.length; key++) {
-            sorted[str[key]] = encodeURIComponent(obj[str[key]]).replace(/%20/g, "+");
-        }
-        return sorted;
     }
+    str.sort();
+    for (key = 0; key < str.length; key++) {
+      sorted[str[key]] = encodeURIComponent(obj[str[key]]).replace(/%20/g, "+");
+    }
+    return sorted;
+  }
+
+  async create(createPaymentDto: CreatePaymentDto): Promise<PaymentEntity | undefined> {
+    return PaymentEntity.create({
+      payment_method: 2,
+      vnp_amount: createPaymentDto.vnp_amount,
+      vnp_bank_code: createPaymentDto.vnp_bank_code,
+      vnp_bank_tran_no: createPaymentDto.vnp_bank_tran_no,
+      vnp_card_type: createPaymentDto.vnp_card_type,
+      vnp_order_info: createPaymentDto.vnp_order_info,
+      vnp_paydate: createPaymentDto.vnp_paydate,
+      vnp_response_code: createPaymentDto.vnp_response_code,
+      vnp_transaction_no: createPaymentDto.vnp_transaction_no,
+      vnp_transaction_status: createPaymentDto.vnp_transaction_status
+    })
+  }
 }