Hãy viết một hàm 'processInventory' trong 'InventoryService' (file src/inventory/inventory.service.ts):
- Sử dụng 'DataSource' để chạy query thuần túy không qua Entity.
- Gọi Stored Procedure 'ProcessProductInventory' trong SQL Server (MSSQL).
- Truyền các tham số theo tên: @productId (string) và @quantity (number).
- Sử dụng khối try-catch để bắt lỗi kết nối CSDL và ném ra lỗi phù hợp.

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

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

  async processInventory(productId: string, quantity: number) {
    try {
      // Sử dụng EXEC để gọi Stored Procedure và truyền tham số theo tên trong MSSQL
      const result = await this.dataSource.query(
        'EXEC ProcessProductInventory @productId = ?, @quantity = ?',
        [productId, quantity]
      );
      return result;
    } catch (error) {
      throw new InternalServerErrorException(
        `Lỗi hệ thống khi xử lý tồn kho: ${error.message}`
      );
    }
  }
}

Hãy viết một service 'RawTasksService' trong file 'src/tasks/raw-tasks.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 MS SQL Server, không sử dụng Entity.
- Hàm 'createTask' nhận vào title, description: Chạy lệnh INSERT INTO vào bảng 'tasks'.
- Hàm 'updateTaskStatus' nhận vào id và status: Chạy lệnh UPDATE.
- Hàm 'deleteTask' nhận vào id: Chạy lệnh DELETE FROM.

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

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

  // 1. Thêm mới dữ liệu (INSERT)
  async createTask(title: string, description: string) {
    // MSSQL sử dụng từ khóa OUTPUT để lấy về giá trị của dòng vừa được chèn vào
    const sql = `
      INSERT INTO tasks (title, description)
      OUTPUT inserted.id, inserted.title
      VALUES (?, ?);
    `;
    const result = await this.dataSource.query(sql, [title, description]);
    return result[0];
  }

  // 2. Cập nhật dữ liệu (UPDATE)
  async updateTaskStatus(id: number, status: string) {
    const sql = `
      UPDATE tasks
      SET status = ?
      WHERE id = ?;
    `;
    await this.dataSource.query(sql, [status, id]);
    return { success: true, message: `Đã cập nhật trạng thái tác vụ #${id}` };
  }

  // 3. Xóa dữ liệu (DELETE)
  async deleteTask(id: number) {
    const sql = `
      DELETE FROM tasks
      WHERE id = ?;
    `;
    await this.dataSource.query(sql, [id]);
    return { success: true, message: `Đã xóa tác vụ #${id} thành công` };
  }
}