Hãy viết một service 'BillingService' trong file 'src/billing/billing.service.ts':
- Sử dụng 'DataSource' để chạy các câu lệnh SQL thuần túy trực tiếp, không sử dụng Entity.
- Viết hàm 'calculateTax(subtotal, taxRate)': Gọi Database Function 'calculate_tax_amount($1, $2)' bằng lệnh SELECT.
- Viết hàm 'updatePaymentStatus(invoiceId, status)': Gọi Stored Procedure 'update_invoice_status_proc($1, $2)' bằng lệnh CALL.
- Hãy sử dụng ký tự giữ chỗ dạng $1, $2 đặc trưng của PostgreSQL để truyền tham số an toàn.

import { Injectable } from '@nestjs/common';
import { DataSource } from 'typeorm';

@Injectable()
export class BillingService {
  constructor(private readonly dataSource: DataSource) {}

  // 1. Gọi Database Function (SELECT)
  async calculateTax(subtotal: number, taxRate: number) {
    // PostgreSQL sử dụng SELECT để gọi Database Function
    const result = await this.dataSource.query(
      'SELECT * FROM calculate_tax_amount($1, $2)',
      [subtotal, taxRate]
    );
    return result;
  }

  // 2. Gọi Stored Procedure (CALL)
  async updatePaymentStatus(invoiceId: string, status: string) {
    // PostgreSQL sử dụng CALL để thực thi Stored Procedure (PG 11+)
    await this.dataSource.query(
      'CALL update_invoice_status_proc($1, $2)',
      [invoiceId, status]
    );
    return { success: true, message: `Đã chạy cập nhật cho hóa đơn #${invoiceId}` };
  }
}

Hãy viết một service 'RawProductsService' trong file 'src/products/raw-products.service.ts':
- Sử dụng 'DataSource' để chạy các câu lệnh SQL thuần túy (INSERT, UPDATE, DELETE) trực tiếp trên PostgreSQL, không dùng Entity.
- Hàm 'insertProduct' nhận vào name, price, description: Chạy lệnh INSERT INTO bảng 'products' và sử dụng RETURNING id, name, price để nhận về thông tin dòng vừa tạo.
- Hàm 'updateProductPrice' nhận vào id và newPrice: Chạy lệnh UPDATE.
- Hàm 'deleteProduct' nhận vào id: Chạy lệnh DELETE FROM.
- Bắt buộc dùng placeholders dạng $1, $2...

import { Injectable } from '@nestjs/common';
import { DataSource } from 'typeorm';

@Injectable()
export class RawProductsService {
  constructor(private readonly dataSource: DataSource) {}

  // 1. Thêm mới dữ liệu (INSERT)
  async insertProduct(name: string, price: number, description: string) {
    const sql = `
      INSERT INTO products (name, price, description)
      VALUES ($1, $2, $3)
      RETURNING id, name, price;
    `;
    // Thực thi lệnh và nhận lại dòng dữ liệu vừa thêm nhờ từ khóa RETURNING
    const result = await this.dataSource.query(sql, [name, price, description]);
    return result[0];
  }

  // 2. Cập nhật dữ liệu (UPDATE)
  async updateProductPrice(id: number, newPrice: number) {
    const sql = `
      UPDATE products
      SET price = $1
      WHERE id = $2;
    `;
    await this.dataSource.query(sql, [newPrice, id]);
    return { success: true, message: `Cập nhật thành công sản phẩm #${id}` };
  }

  // 3. Xóa dữ liệu (DELETE)
  async deleteProduct(id: number) {
    const sql = `
      DELETE FROM products
      WHERE id = $1;
    `;
    await this.dataSource.query(sql, [id]);
    return { success: true, message: `Xóa thành công sản phẩm #${id}` };
  }
}