Hệ thống đối soát giao dịch tài chính với Full Outer Merge và Tolerance Check

Mục tiêu kiến thức

• Triển khai bài toán đối soát (Reconciliation) kinh điển trong ngành ngân hàng và fintech.
• Sử dụng pd.merge(how='outer', indicator=True) phát hiện các bản ghi thiếu hụt ở một trong hai hệ thống.
• So khớp giá trị số thực có xét đến sai số làm tròn (Floating-point Tolerance).

Mô tả bài toán

Viết hàm reconcile_transactions(ledger_a: pd.DataFrame, ledger_b: pd.DataFrame, key: str = "txn_id", amount_col: str = "amount", tolerance: float = 0.01) -> dict:

• Kiểm tra tính hợp lệ:
• Nếu key hoặc amount_col không tồn tại trong một trong hai DataFrame, raise KeyError("Khong tim thay khoa doi soat hoac cot so tien").
• Nếu tolerance < 0, raise ValueError("Tolerance phai khong am").
• Thực hiện Full Outer Join trên cột key với hậu tố _a và _b kèm indicator=True:
• Phân loại trạng thái cho từng giao dịch:
• "MATCHED": Xuất hiện ở cả hai bên (_merge == 'both') và sai lệch |amount_a - amount_b| ≤ tolerance.
• "DISCREPANCY": Xuất hiện ở cả hai bên nhưng sai lệch |amount_a - amount_b| > tolerance.
• "MISSING_IN_B": Chỉ xuất hiện ở ledger_a (_merge == 'left_only').
• "MISSING_IN_A": Chỉ xuất hiện ở ledger_b (_merge == 'right_only').
• Trả về dictionary có cấu trúc:

   {
       "summary": {
           "total_records": int,
           "matched_count": int,
           "discrepancy_count": int,
           "missing_in_b_count": int,
           "missing_in_a_count": int
       },
       "discrepancies": [
           {
               "txn_id": txn_id,
               "amount_a": float(amount_a),
               "amount_b": float(amount_b),
               "diff": float(abs(amount_a - amount_b))
           }
           # danh sach sap xep tang dan theo diff giam dan
       ]
   }

Ràng buộc

• Thời gian chạy tối đa: 1000ms.
• Giới hạn bộ nhớ: 256MB.
• Dữ liệu đầu vào tuân thủ đúng kiểu dữ liệu và miền giá trị được mô tả.