Biến danh sách khách hàng thành tiến độ nhìn thấy được.

# BUỔI 9: ĐỌC DỮ LIỆU KHÁCH HÀNG BẰNG PANDAS
import pandas as pd

# Đường dẫn file dữ liệu mẫu công trường
file_path = "khach_hang.csv"

try:
    # 1. Đọc file CSV vào biến df (DataFrame)
    df = pd.read_csv(file_path, encoding="utf-8")
    
    print("✅ ĐỌC DỮ LIỆU THÀNH CÔNG!")
    so_hang, so_cot = df.shape
    print(f"Tổng số hồ sơ khách hàng: {so_hang} dòng")
    print(f"Tổng số trường thông tin: {so_cot} cột\n")
    
    # 2. Xem nhanh 5 dòng đầu tiên
    print("--- 5 KHÁCH HÀNG MẪU ĐẦU TIÊN ---")
    print(df.head(5))
    
except FileNotFoundError:
    print(f"❌ Không tìm thấy file '{file_path}'. Hãy kiểm tra vị trí thư mục!")

# BUỔI 10: SOÁT LỖI VÀ LÀM SẠCH BẢNG DỮ LIỆU
import pandas as pd

# Ép kiểu Zip Code thành chuỗi để giữ nguyên định dạng số 0 đầu
df = pd.read_csv("khach_hang.csv", dtype={"Zip Code": str, "SĐT": str})

print("=== BÁO CÁO CẤU TRÚC BẢNG DỮ LIỆU ===")
df.info()

print("\n=== ĐẾM SỐ DÒNG BỊ THIẾU THÔNG TIN (NULL/EMPTY) ===")
o_rong = df.isna().sum()
print(o_rong)

# Xử lý làm sạch: Điền giá trị mặc định cho ô bị thiếu
if "Trạng thái liên hệ" in df.columns:
    df["Trạng thái liên hệ"] = df["Trạng thái liên hệ"].fillna("Chưa liên hệ")
    print("\n✅ Đã chuẩn hóa các dòng thiếu trạng thái về: 'Chưa liên hệ'")

# BUỔI 11: LỌC DỮ LIỆU THEO KHU VỰC VÀ SẮP XẾP
import pandas as pd

df = pd.read_csv("khach_hang.csv", dtype={"Zip Code": str})

# 1. Lọc khách hàng tại khu vực mục tiêu (vd: 77001 - Houston, Texas)
zip_muc_tieu = "77001"
danh_sach_khu_vuc = df[df["Zip Code"] == zip_muc_tieu]

print(f"=== DANH SÁCH KHÁCH HÀNG TẠI ZIP CODE {zip_muc_tieu} ===")
print(f"Tìm thấy: {len(danh_sach_khu_vuc)} khách hàng tiềm năng.")

# 2. Sắp xếp danh sách theo tên khách hàng chữ cái A-Z
danh_sach_sap_xep = danh_sach_khu_vuc.sort_values(by="Tên khách", ascending=True)

# 3. In kết quả chọn lọc
print(danh_sach_sap_xep[["ID", "Tên khách", "SĐT", "Zip Code", "Trạng thái liên hệ"]])

# BUỔI 12: BỘ LỌC MARKETING TELESALE CÔNG TRƯỜNG
import pandas as pd

df = pd.read_csv("khach_hang.csv", dtype={"Zip Code": str, "SĐT": str})

# Lọc đa điều kiện với dấu ngoặc tròn và toán tử &
dieu_kien = (
    (df["Zip Code"] == "77001") & 
    (df["Trạng thái liên hệ"] == "Chưa gọi") & 
    (df["SĐT"].notna())
)

leads_chuan = df[dieu_kien].head(50)

print(f"=== BỘ LỌC MARKETING: TÌM THẤY {len(leads_chuan)} KHÁCH HÀNG ĐẠT CHUẨN ===")
print(leads_chuan[["Tên khách", "SĐT", "Zip Code"]])

# Xuất file kết quả bàn giao cho nhân viên telesale
ten_file_xuat = "leads_telesale_hom_nay.csv"
leads_chuan.to_csv(ten_file_xuat, index=False, encoding="utf-8-sig")
print(f"\n✅ Đã xuất danh sách sẵn sàng gọi điện ra file: '{ten_file_xuat}'")

# BUỔI 13: KHỞI TẠO KHO LƯU TRỮ SQLITE CHO CÔNG TRÌNH
import sqlite3

# 1. Kết nối hoặc tự động tạo mới file database cong_trinh.db
conn = sqlite3.connect("cong_trinh.db")
cursor = conn.cursor()

# 2. Tạo bảng KhachHang nếu chưa tồn tại
sql_create_table = """
CREATE TABLE IF NOT EXISTS KhachHang (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    ho_ten TEXT NOT NULL,
    sdt TEXT,
    zip_code TEXT,
    ngay_tao TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);
"""
cursor.execute(sql_create_table)
conn.commit()

print("✅ ĐÃ KHỞI TẠO THÀNH CÔNG BẢNG 'KhachHang' TRONG cong_trinh.db!")
conn.close()

# BUỔI 14: THIẾT KẾ BẢNG DỰ ÁN VỚI KHÓA NGOẠI
import sqlite3

conn = sqlite3.connect("cong_trinh.db")
cursor = conn.cursor()

sql_create_du_an = """
CREATE TABLE IF NOT EXISTS DuAn (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    ten_du_an TEXT NOT NULL,
    khach_hang_id INTEGER NOT NULL,
    dien_tich_sqft REAL,
    gia_tri_usd REAL,
    trang_thai TEXT DEFAULT 'Khảo sát',
    FOREIGN KEY (khach_hang_id) REFERENCES KhachHang (id)
);
"""
cursor.execute(sql_create_du_an)
conn.commit()

print("✅ ĐÃ KHỞI TẠO THÀNH CÔNG BẢNG 'DuAn' LIÊN KẾT VỚI 'KhachHang'!")
conn.close()

# BUỔI 15: THÊM MỚI VÀ TRUY VẤN HỒ SƠ CÔNG TRÌNH
import sqlite3

def them_khach_hang(ho_ten, sdt, zip_code):
    """Hàm thêm khách hàng mới và trả về ID vừa sinh."""
    with sqlite3.connect("cong_trinh.db") as conn:
        cursor = conn.cursor()
        sql = "INSERT INTO KhachHang (ho_ten, sdt, zip_code) VALUES (?, ?, ?)"
        cursor.execute(sql, (ho_ten, sdt, zip_code))
        conn.commit()
        return cursor.lastrowid

def xem_danh_sach_khach():
    """Hàm truy vấn và in toàn bộ danh sách khách hàng."""
    with sqlite3.connect("cong_trinh.db") as conn:
        cursor = conn.cursor()
        cursor.execute("SELECT id, ho_ten, sdt, zip_code, ngay_tao FROM KhachHang")
        danh_sach = cursor.fetchall()
        print(f"\n{'ID':<4} | {'HỌ VÀ TÊN':<20} | {'SĐT':<12} | {'ZIP':<6}")
        print("-" * 50)
        for k in danh_sach:
            print(f"{k[0]:<4} | {k[1]:<20} | {k[2]:<12} | {k[3]:<6}")

# Thử nghiệm thêm khách hàng mới
id_moi = them_khach_hang("Anh Vũ - Căn hộ Vinhomes", "0988776655", "77001")
print(f"✅ Đã thêm khách hàng mới với mã ID: {id_moi}")
xem_danh_sach_khach()

# BUỔI 16: HỆ THỐNG CẬP NHẬT TIẾN ĐỘ THI CÔNG HOÀN CHỈNH
import sqlite3

def cap_nhat_tien_do(du_an_id, trang_thai_moi):
    """Cập nhật tiến độ công trình: Khảo sát -> Thi công -> Bàn giao."""
    trang_thai_hop_le = ["Khảo sát", "Thi công", "Bàn giao", "Đã thanh lý"]
    if trang_thai_moi not in trang_thai_hop_le:
        print(f"❌ Trạng thái '{trang_thai_moi}' không hợp lệ!")
        return False
        
    with sqlite3.connect("cong_trinh.db") as conn:
        cursor = conn.cursor()
        sql = "UPDATE DuAn SET trang_thai = ? WHERE id = ?"
        cursor.execute(sql, (trang_thai_moi, du_an_id))
        conn.commit()
        if cursor.rowcount > 0:
            print(f"✅ ĐÃ CẬP NHẬT DỰ ÁN #{du_an_id} SANG TRẠNG THÁI: '{trang_thai_moi}'")
            return True
        else:
            print(f"⚠️ Không tìm thấy dự án mang mã ID #{du_an_id}!")
            return False

def xoa_du_an(du_an_id):
    """Xóa an toàn một bản ghi dự án với điều kiện ID."""
    with sqlite3.connect("cong_trinh.db") as conn:
        cursor = conn.cursor()
        cursor.execute("DELETE FROM DuAn WHERE id = ?", (du_an_id,))
        conn.commit()
        print(f"🗑️ Đã xóa dự án #{du_an_id} khỏi hệ thống.")

# Thử nghiệm đổi trạng thái dự án sang Bàn giao
cap_nhat_tien_do(1, "Thi công")
cap_nhat_tien_do(1, "Bàn giao")