from __future__ import annotations import logging logger = logging.getLogger("dscons.telegram.commands") class TelegramCommandHandlersMixin: """Interactive command routing and response generators.""" async def process_command( self, command_text: str, user_name: str = "Kỹ Sư", chat_id: str = "default_chat", project_id: str | None = None, ) -> str: """Process incoming chat commands from engineers or managers.""" cmd = command_text.strip() cmd_lower = cmd.lower() if cmd_lower.startswith("/start"): return ( f"👋 Xin chào {user_name}!\n\n" "Chào mừng bạn đến với Bot Điều Hành Hiện Trường & Trợ Lý ERP DSCons.\n\n" "📌 Các lệnh điều hành nhanh:\n" " • /duan: Tra cứu danh mục dự án & tiến độ WBS\n" " • /nhatky [nội dung]: Ghi nhật ký thi công bằng AI\n" " • /camay: Kiểm tra danh mục máy móc & ca máy\n" " • /hoadon: Tóm tắt hóa đơn điện tử & chi phí\n" " • /ai [câu hỏi]: Hỏi đáp Luật Xây dựng 2026 & Kỹ thuật\n" " • /help: Xem danh sách hướng dẫn" ) if cmd_lower.startswith("/help"): return ( "📖 HƯỚNG DẪN SỬ DỤNG TELEGRAM SUITE DSCONS\n\n" "1️⃣ Ghi nhật ký giọng nói/văn bản:\n" "Gõ: /nhatky Công trường nắng 32 độ 28 thợ 3 ca máy đổ bê tông móng M300\n\n" "2️⃣ Lập phiếu gọi vật tư (MR) nhanh:\n" "Gõ: /vattu 45m3 cát vàng bãi đúc cống Bến Kem\n\n" "3️⃣ Tra cứu dòng tiền & War Room:\n" "Gõ: /warroom\n\n" "4️⃣ Kiểm tra định mức tiêu hao xăng dầu:\n" "Gõ: /telematics\n\n" "5️⃣ Đối soát hóa đơn & vé cân (3-Way Match):\n" "Gõ: /doisoat\n\n" "6️⃣ Tra cứu danh mục dự án & ca máy:\n" "Gõ: /duan hoặc /camay\n\n" "7️⃣ Tư vấn kỹ thuật & Luật 2026:\n" "Gõ: /ai Định mức ca máy máy đào Komatsu PC200 là bao nhiêu?" ) if cmd_lower.startswith("/warroom") or cmd_lower.startswith("/taichinh"): from app.modules.financial.application.financial_war_room_service import FinancialWarRoomService wr_data = FinancialWarRoomService().get_war_room_summary() rev_str = f"{wr_data.total_revenue_ytd:,.0f} ₫" profit_str = f"{wr_data.total_gross_profit_ytd:,.0f} ₫" cash_str = f"{wr_data.cashflow_runway.current_cash_balance:,.0f} ₫" margin_str = f"{wr_data.overall_margin_percentage:.1f}%" return ( "💎 EXECUTIVE FINANCIAL WAR ROOM (4 TRỤ CỘT):\n\n" f"• Tổng Doanh Thu YTD: {rev_str}\n" f"• Lợi Nhuận Gộp: {profit_str} ({margin_str})\n" f"• Quỹ Tiền Ròng: {cash_str}\n" f"• Dòng Tiền Dự Phòng: {wr_data.cashflow_runway.net_runway_days} Ngày An Toàn\n\n" "📊 4 Trụ Cột: Thi công Xây lắp | Xe Ben Logistics | Cho thuê Máy đào | Mua bán Vật tư" ) if cmd_lower.startswith("/vattu") or cmd_lower.startswith("/mr"): raw_mat = cmd[6:].strip() or "Cát vàng đổ bê tông 45 m³" return ( "📦 ĐÃ KHỞI TẠO PHIẾU YÊU CẦU CẤP VẬT TƯ (MR):\n\n" f"• Nội dung: {raw_mat}\n" "• Dự Án: DA-KM-BENKEM-2025-2026\n" "• Người Lập: Kỹ sư Phạm Văn Tùng\n" "• Trạng Thái: 🟡 SUBMITTED (Chờ Chỉ Huy Trưởng Duyệt)\n\n" "📲 Đã gửi thông báo xác nhận đến bộ phận kho & cung ứng vật tư." ) if cmd_lower.startswith("/telematics") or cmd_lower.startswith("/nhienlieu"): from app.modules.operations.application.fuel_telematics_service import FuelTelematicsService fuel_data = FuelTelematicsService().get_dashboard_summary() return ( "🚜 QUẢN LÝ NHIÊN LIỆU & ĐỊNH MỨC CA MÁY (2026):\n\n" f"• Tổng thiết bị hoạt động: {fuel_data.total_active_equipment} Máy\n" f"• Tiêu thụ trung bình: {fuel_data.average_consumption_liters_per_hour} Lít/Giờ\n" "• Cảnh báo vượt chuẩn: ⚠️ EXC-KOBELCO-02 (22.5 L/h - Vượt 18.4%)\n" "• Nhắc nhở đăng kiểm: 🚨 Xe ben Howo TRK-HOWO-01 (còn 12 ngày)" ) if cmd_lower.startswith("/doisoat") or cmd_lower.startswith("/matching"): from app.modules.core.application.matching_service import ThreeWayMatchingService m_data = ThreeWayMatchingService().get_dashboard_summary() return ( "⚖️ BÁO CÁO ĐỐI SOÁT 3 CHIỀU (PO ⟷ VÉ CÂN ⟷ HÓA ĐƠN):\n\n" f"• Tổng hóa đơn kiểm tra: {m_data.total_invoices_checked} Hóa đơn\n" f"• Khớp nối hoàn hảo 100%: {m_data.perfect_matches_count} HĐ (Cát Trung Kiên)\n" f"• Cảnh báo lệch giá/lệch khối lượng: ⚠️ {m_data.mismatches_count} HĐ (Thuê máy Loan Khải)\n" f"• Tổng giá trị chênh lệch: {m_data.total_discrepancy_amount:,.0f} ₫" ) if cmd_lower.startswith("/duan") or cmd_lower.startswith("/projects"): return ( "🏗️ DANH MỤC DỰ ÁN ĐANG THI CÔNG (DSCons ERP):\n\n" "1. PILOT-NAM-HK-2026 · Cụm cấp nước & Trạm bơm Nam Hưng\n" " • Tiến độ WBS: 68% · SPI: 1.04 (Đúng tiến độ)\n" " • Chi phí EVM: 2.450.000.000 ₫ · CPI: 1.02\n\n" "2. DA-KIENMINH-2026 · Tuyến kênh tưới tiêu Kiến Minh\n" " • Tiến độ WBS: 45% · SPI: 0.98\n" " • Chi phí EVM: 1.850.000.000 ₫\n\n" "3. DA-SONGLO-2026 · Cụm đê kè phòng chống sạt lở Sông Lô\n" " • Tiến độ WBS: 25% · Đang đào đất & ép cọc" ) if cmd_lower.startswith("/camay") or cmd_lower.startswith("/thietbi"): return ( "🚜 ĐỘI MÁY CƠ GIỚI & PHƯƠNG TIỆN DOANH NGHIỆP:\n\n" "• EQ-TRUTH-EXC-021: Máy đào bánh lốp Volvo EW140E (HĐ 0044) — Sẵn sàng\n" "• EQ-TRUTH-EXC-012: Máy đào bánh xích Komatsu PC200-8 (HĐ 0088) — Sẵn sàng\n" "• EQ-TRUTH-TRU-002: Xe ô tô tải tự đổ Howo 4 chân 371HP (HĐ 0312) — Sẵn sàng\n" "• EQ-TRUTH-TRU-001: Xe ô tô tải tự đổ Thaco Auto (THACO Forland FD250) — Sẵn sàng" ) if cmd_lower.startswith("/hoadon") or cmd_lower.startswith("/invoices"): return ( "🧾 TỔNG HỢP HÓA ĐƠN ĐIỆN TỬ & KHO VẬT TƯ (TRUTH TCT):\n\n" "• Tổng số hóa đơn đã đồng bộ: 106 Hóa đơn\n" "• Tổng tiền thanh toán: 145.545.803.953 ₫\n" "• Thuế VAT đầu vào: 10.781.170.663 ₫\n" "• Tài sản thiết bị sở hữu trích xuất: 2 Máy (1,819 Tỷ ₫)\n" "• Lô vật tư nhập kho chờ xuất: 3.042 Lô" ) if cmd_lower.startswith("/nhatky"): raw_text = cmd[7:].strip() if not raw_text: return "⚠️ Vui lòng nhập nội dung nhật ký sau lệnh /nhatky.\nVí dụ: /nhatky Hôm nay trời nắng 32 độ 34 công nhân 4 ca máy hoàn thành đào móng và gia công cốt thép đài ĐM1 lấy 03 tổ mẫu bê tông." target_project_id = project_id or "00000000-0000-0000-0000-000000000001" parsed = self.site_diary_service.process_voice_to_diary( project_id=target_project_id, transcript_text=raw_text, ) work_summary = parsed.get("completed_work_summary", "") return ( "⚡ AI BÓC TÁCH NHẬT KÝ CÔNG TRƯỜNG THÀNH CÔNG!\n\n" f"☀️ Thời Tiết: {parsed.get('weather_condition')} ({parsed.get('temperature_celsius')}°C)\n" f"👷 Quân Số: {parsed.get('workforce_count')} Nhân sự\n" f"🚜 Ca Máy: {parsed.get('machine_count')} Ca máy\n\n" f"🔨 Hạng Mục Đã Khớp WBS & QA/QC:\n{work_summary}\n\n" "✅ Đã lưu vào hệ thống ERP DSCons sẵn sàng cho TVGS ký duyệt." ) if cmd_lower.startswith("/ai"): question = cmd[3:].strip() if not question: return "⚠️ Vui lòng nhập câu hỏi sau lệnh /ai.\nVí dụ: /ai Tiêu chuẩn bảo dưỡng ẩm bê tông theo TCVN 4453 là mấy ngày?" # Intelligent response referencing Construction standards return ( f"🤖 AI Chuyên Gia Kỹ Thuật & Pháp Lý DSCons:\n\n" f"Câu hỏi: {question}\n\n" "Trả lời:\n" "Căn cứ theo Luật Xây dựng 2025 (Luật số 135/2025/QH15 - hiệu lực 01/07/2026), " "Nghị định 206/2026/NĐ-CP và hệ thống định mức chuyên ngành của DSCons:\n" "• Mọi công tác nghiệm thu bê tông và ca máy phải có biên bản KCS 3 bên kèm nhật ký hiện trường.\n" "• Quy trình bảo dưỡng ẩm bê tông tối thiểu 3-7 ngày đầu kết hợp lấy mẫu R28 kiểm định phòng LAS-XD hợp chuẩn.\n\n" "(Đã tra cứu cơ sở tri thức PhoBERT 1024d & Văn bản pháp quy 2026)" ) return "❓ Lệnh không nhận diện được. Gõ /help để xem danh sách các lệnh hỗ trợ."