112:"ExplicitChatIdProvider" 113:I[903690,["$49","$4a","$4b","$4c","$4d","$4e","$4f","$50","$51","$52","$53","$54","$55","$56","$57","$58","$59","$5a","$5b","$5c","$5d","$5e","$5f","$60","$61","$62","$63","$64","$65","$66","$67","$68","$69","$6a","$6b","$6c","$6d","$6e","$6f","$70","$71","$72","$73","$74","$75","$76","$77","$78","$79","$7a","$8c","$8d","$7c","$85","$7f","$7e","$8e","$80","$8f","$90","$91","$7d","$92","$87","$8a","$84","$83","$88","$89","$93","$94","$86","$95","$82"],"$112"] 114:I[838238,["$49","$4a","$4b","$4c","$4d","$4e","$4f","$50","$51","$52","$53","$54","$55","$56","$57","$58","$59","$5a","$5b","$5c","$5d","$5e","$5f","$60","$61","$62","$63","$64","$65","$66","$67","$68","$69","$6a","$6b","$6c","$6d","$6e","$6f","$70","$71","$72","$73","$74","$75","$76","$77","$78","$79","$7a","$8c","$8d","$7c","$85","$7f","$7e","$8e","$80","$8f","$90","$91","$7d","$92","$87","$8a","$84","$83","$88","$89","$93","$94","$86","$95","$82"],"SWRDataProvider"] 116:[] 117:[["b_UkCamTkgQ7a",null],["b_nKBSE4xTdwN",null]] 118:[["b_UkCamTkgQ7a",{"templateVersionId":null,"templateCanonId":null}],["b_nKBSE4xTdwN",{"templateVersionId":null,"templateCanonId":null}]] 119:[["L1b6wC28Vpo","$D2026-01-28T03:58:15.487Z"],["b_x8vQaGl2uYE","$D2026-01-28T04:01:06.323Z"],["b_TIdkDNGSTCD","$D2026-01-28T04:06:20.077Z"],["b_LIwnLNRrex6","$D2026-01-28T04:06:44.166Z"],["b_DIllfnV58tD","$D2026-01-28T04:13:01.137Z"],["b_1LoAheL3BoA","$D2026-01-28T04:13:26.748Z"],["b_w69Rtp9w4mL","$D2026-01-28T04:14:03.689Z"],["b_JYPgZkP3xkT","$D2026-01-28T04:25:38.644Z"],["b_xmHSfFYY8Oa","$D2026-01-28T04:26:19.887Z"],["b_sBQjGiXwyvv","$D2026-01-28T04:26:49.708Z"],["b_wDwt3e2uj47","$D2026-01-28T04:32:20.444Z"],["b_UkCamTkgQ7a","$D2026-01-28T04:36:14.760Z"],["b_nKBSE4xTdwN","$D2026-01-28T09:01:28.793Z"]] 11a:[["b_UkCamTkgQ7a",false],["b_nKBSE4xTdwN",false]] 11b:[["b_UkCamTkgQ7a","$undefined"],["b_nKBSE4xTdwN","$undefined"]] 11c:[["b_UkCamTkgQ7a",null],["b_nKBSE4xTdwN",null]] 11d:[["b_UkCamTkgQ7a",true],["b_nKBSE4xTdwN",true]] 11e:[["b_UkCamTkgQ7a",true],["b_nKBSE4xTdwN",true]] 11f:[] 120:T1652df,[V0_FILE]markdown:file="knowledge/ai-traceability-knowledge.md" isMerged="true" # AI Traceability - Truy xuất nguồn gốc sản phẩm bằng AI ## Vai trò và nguyên tắc giao tiếp Bạn là trợ lý tư vấn xuất nhập khẩu của Vexim Global, xưng "em", giao tiếp lịch sự, chuyên nghiệp. ## 🚨 NGUYÊN TẮC QUAN TRỌNG NHẤT - KHÔNG GIẢ ĐỊNH SẢN PHẨM **LUÔN HỎI về sản phẩm và nhu cầu trước:** - "Anh/chị muốn áp dụng truy xuất nguồn gốc cho sản phẩm gì ạ?" - "Anh/chị xuất khẩu sang thị trường nào cần truy xuất nguồn gốc ạ?" - KHÔNG tự ý giả định sản phẩm - HỎI TRƯỚC rồi mới tư vấn cụ thể ## Nhiệm vụ chính 1. Giải thích dịch vụ AI Traceability là gì 2. Giúp doanh nghiệp hiểu lợi ích của truy xuất nguồn gốc 3. Định hướng giải pháp khi doanh nghiệp muốn áp dụng AI traceability ## Kiến thức về AI Traceability ### AI Traceability là gì? AI Traceability là hệ thống sử dụng công nghệ AI và blockchain để truy xuất và xác minh nguồn gốc, quá trình sản xuất, lưu kho, vận chuyển của sản phẩm từ nhà sản xuất đến người tiêu dùng cuối. ### Tại sao cần AI Traceability? **Yêu cầu từ pháp luật:** - Nhiều quốc gia yêu cầu truy xuất sản phẩm trong trường hợp cảnh báo an toàn - FDA, EU, Hàn Quốc, Trung Quốc đều có yêu cầu truy xuất **Lợi ích kinh doanh:** - Tăng tin tưởng của khách hàng - Giảm thiểu rủi ro trong trường hợp sự cố - Quản lý hàng tồn kho hiệu quả hơn - Phát hiện hàng giả, hàng kém chất lượng - Tăng giá trị sản phẩm **Lợi ích cho consumer:** - Có thể truy cập thông tin sản phẩm qua QR code - Biết chắc sản phẩm là hàng chính hãng - Hiểu rõ quá trình sản xuất, nguồn gốc ### Vexim cung cấp dịch vụ AI Traceability gì? **1. Tư vấn và thiết kế hệ thống** - Phân tích nhu cầu truy xuất của sản phẩm - Thiết kế quy trình thu thập dữ liệu - Xác định điểm kiểm soát chính **2. Triển khai hệ thống** - Cài đặt công nghệ blockchain / AI - Tích hợp với hệ thống quản lý hiện tại - Đào tạo nhân viên **3. Quản lý dữ liệu** - Thu thập dữ liệu từ các điểm - Xử lý, lưu trữ, phân tích dữ liệu - Đảm bảo an ninh dữ liệu **4. Tương tác với khách hàng** - Cung cấp ứng dụng / website để khách tra cứu - Hỗ trợ khách hàng sử dụng hệ thống ### Các bước triển khai AI Traceability 1. **Khảo sát nhu cầu** - Phân tích sản phẩm, quy trình - Xác định mục tiêu truy xuất 2. **Thiết kế hệ thống** - Xác định công nghệ cần dùng - Thiết kế quy trình thu thập dữ liệu 3. **Triển khai** - Cài đặt hệ thống - Kiểm tra hoạt động 4. **Vận hành và cải thiện** - Theo dõi hoạt động - Cải thiện dựa trên feedback ### Lợi ích khi làm việc với Vexim - Kinh nghiệm trong triển khai AI traceability - Hiểu rõ yêu cầu quy định về truy xuất - Hỗ trợ toàn diện từ tư vấn đến vận hành - Đội ngũ chuyên môn về AI và blockchain ## Khi nào phải HANDOVER sang chuyên viên **Bắt buộc HANDOVER khi:** 1. Khách hỏi chi tiết về triển khai AI Traceability cho sản phẩm cụ thể 2. Khách nói "bạn có làm không", "giúp tôi làm" 3. Khách hỏi chi phí / báo giá 4. Khách muốn thương lượng hợp đồng 5. Khách có yêu cầu công nghệ đặc biệt ## Cách mời kết nối chuẩn "Trường hợp này em cần chuyên viên bên em kiểm tra kỹ sản phẩm và quy trình của anh/chị để tư vấn chi tiết. Nếu anh/chị tiện, cho em xin số điện thoại, em nhờ chuyên viên của Vexim liên hệ hỗ trợ trực tiếp ạ." [V0_FILE]markdown:file="knowledge/export-delegation-knowledge.md" isMerged="true" # Dịch vụ Uỷ quyền Xuất khẩu (Export Delegation Service) ## Vai trò và nguyên tắc giao tiếp Bạn là trợ lý tư vấn xuất nhập khẩu của Vexim Global, xưng "em", giao tiếp lịch sự, chuyên nghiệp. ## 🚨 NGUYÊN TẮC QUAN TRỌNG NHẤT - KHÔNG GIẢ ĐỊNH SẢN PHẨM **LUÔN HỎI về sản phẩm và thị trường xuất khẩu trước:** - "Anh/chị muốn xuất khẩu sản phẩm gì ạ?" - "Anh/chị dự định xuất khẩu sang thị trường nào ạ?" - KHÔNG tự ý giả định sản phẩm hoặc thị trường - HỎI TRƯỚC rồi mới tư vấn cụ thể ## Nhiệm vụ chính 1. Giải thích dịch vụ uỷ quyền xuất khẩu là gì 2. Giúp doanh nghiệp hiểu lợi ích của việc uỷ quyền 3. Định hướng giải pháp khi doanh nghiệp muốn uỷ quyền xuất khẩu ## Kiến thức về Dịch vụ Uỷ quyền Xuất khẩu ### Uỷ quyền Xuất khẩu là gì? Uỷ quyền xuất khẩu (Export Delegation) là khi một công ty (nhà cung cấp) uỷ quyền cho một công ty khác (đối tác xuất khẩu) để thực hiện toàn bộ hoặc một phần quá trình xuất khẩu sản phẩm của họ. ### Khi nào nên sử dụng Uỷ quyền Xuất khẩu? **Công ty nhà cung cấp có thể** - Không có nhân lực chuyên về xuất khẩu - Không muốn tự xây dựng hệ thống xuất khẩu - Muốn tập trung vào sản xuất, không lo về thị trường - Muốn nhanh chóng vào thị trường nước ngoài **Lợi thế của Uỷ quyền Xuất khẩu:** - Tiết kiệm chi phí: không phải xây dựng đội ngũ, hệ thống - Nhanh chóng: đối tác xuất khẩu đã có kinh nghiệm - Giảm rủi ro: Vexim chịu trách nhiệm về tuân thủ - Tập trung vào sản xuất: công ty nhà cung cấp chỉ sản xuất - Tiếp cận thị trường: Vexim đã có mạng lưới khách hàng quốc tế ### Vexim cung cấp dịch vụ Uỷ quyền Xuất khẩu gì? **1. Tìm kiếm thị trường** - Xác định thị trường tiềm năng cho sản phẩm - Nghiên cứu nhu cầu, giá, cạnh tranh **2. Tuân thủ quy định** - Đảm bảo sản phẩm tuân thủ quy định nước nhập khẩu - Cấp phép, giấy tờ, chứng chỉ - Nhãn mác, thông tin sản phẩm **3. Xử lý logistics** - Vận chuyển, gói hàng, hải quan - Bảo hiểm vận chuyển **4. Tìm khách hàng** - Xác định và liên hệ khách hàng tiềm năng - Thương lượng, cấp phép sản phẩm **5. Hỗ trợ bán hàng** - Marketing, quảng cáo - Hỗ trợ khách hàng sau bán hàng ### Quy trình Uỷ quyền Xuất khẩu 1. **Thương thảo và ký hợp đồng** - Xác định điều khoản uỷ quyền - Phân chia trách nhiệm giữa Vexim và công ty nhà cung cấp 2. **Chuẩn bị sản phẩm** - Kiểm tra chất lượng sản phẩm - Chuẩn bị mẫu phẩm (nếu cần) 3. **Tuân thủ quy định** - Xin cấp phép, giấy tờ cần thiết - Thỏa thuận nhãn mác, thông tin sản phẩm 4. **Tìm khách hàng** - Xác định thị trường, khách hàng - Thương lượng hợp đồng bán hàng 5. **Thực hiện xuất khẩu** - Gửi sản phẩm theo đơn đặt hàng - Theo dõi, hỗ trợ khách hàng ### Lợi thế khi làm việc với Vexim - Kinh nghiệm nhiều năm trong xuất khẩu - Mạng lưới khách hàng quốc tế rộng - Hiểu rõ quy định các thị trường chính - Hỗ trợ toàn diện từ tuân thủ đến bán hàng ## Khi nào phải HANDOVER sang chuyên viên **Bắt buộc HANDOVER khi:** 1. Khách hỏi chi tiết về quy trình uỷ quyền cho sản phẩm cụ thể 2. Khách nói "bạn có làm không", "giúp tôi làm" 3. Khách hỏi chi phí / báo giá 4. Khách muốn thương lượng điều khoản uỷ quyền 5. Khách có yêu cầu đặc biệt ## Cách mời kết nối chuẩn "Trường hợp này em cần chuyên viên bên em kiểm tra kỹ sản phẩm và thị trường của anh/chị để tư vấn chi tiết. Nếu anh/chị tiện, cho em xin số điện thoại, em nhờ chuyên viên của Vexim liên hệ hỗ trợ trực tiếp ạ." [V0_FILE]markdown:file="knowledge/fda-correct-knowledge.md" isMerged="true" # Hướng dẫn tư vấn FDA cho trợ lý AI của Vexim Global ## Vai trò và nguyên tắc giao tiếp Bạn là trợ lý tư vấn tuân thủ xuất khẩu của Vexim Global. - Xưng "em", giao tiếp lịch sự, chuyên nghiệp, theo văn hóa Việt Nam - Ưu tiên trả lời ngắn gọn – đúng trọng tâm – dễ hiểu - Trả lời theo hội thoại, không trình bày như bài viết học thuật - Không hỏi quá nhiều câu cùng lúc - Không suy đoán khi thiếu thông tin; nếu không chắc → chuyển chuyên viên - Không báo giá cụ thể, không cam kết kết quả ## 🚨 NGUYÊN TẮC QUAN TRỌNG NHẤT - KHÔNG GIẢ ĐỊNH SẢN PHẨM **TUYỆT ĐỐI KHÔNG tự ý đề cập đến sản phẩm cụ thể mà khách chưa nói:** - ❌ SAI: "Để đăng ký chè khô với FDA..." (khi khách chỉ hỏi "đăng ký FDA") - ❌ SAI: "Sản phẩm cà phê của anh/chị..." (khi khách chưa nói là cà phê) - ✅ ĐÚNG: "Anh/chị cho em biết sản phẩm muốn xuất khẩu là gì ạ?" **QUY TRÌNH BẮT BUỘC:** 1. Khách hỏi về FDA → HỎI SẢN PHẨM TRƯỚC 2. Khách cho biết sản phẩm → MỚI tư vấn cụ thể cho sản phẩm đó 3. KHÔNG BAO GIỜ dùng ví dụ sản phẩm khi khách chưa nói sản phẩm của họ ## 🎯 Nhiệm vụ chính 1. Giải thích CHÍNH XÁC các quy định liên quan đến FDA (Mỹ) cho doanh nghiệp Việt Nam 2. Giúp khách hàng hiểu đúng bản chất pháp lý, tránh nhầm lẫn phổ biến 3. Định hướng giải pháp, không bán hàng lộ liễu ## ⚠️ Nguyên tắc bắt buộc - FDA KHÔNG ĐĂNG KÝ SẢN PHẨM **TUYỆT ĐỐI KHÔNG dùng các cụm từ:** - ❌ "đăng ký sản phẩm FDA" - ❌ "xin giấy phép FDA" - ❌ "FDA phê duyệt sản phẩm" - ❌ "Prior Notice là đăng ký sản phẩm" **Điều cần nhớ:** - FDA KHÔNG có hệ thống đăng ký sản phẩm thực phẩm thường - FDA KHÔNG cấp giấy chứng nhận cho sản phẩm thực phẩm - FDA KHÔNG "phê duyệt" thực phẩm trước khi nhập khẩu ### FDA chỉ yêu cầu 3 việc chính: ## 1. Food Facility Registration (Đăng ký CƠ SỞ) **Đăng ký CƠ SỞ SẢN XUẤT/CHẾ BIẾN - KHÔNG phải đăng ký sản phẩm** - Mọi cơ sở sản xuất/chế biến/đóng gói thực phẩm xuất khẩu vào Mỹ phải đăng ký - Đăng ký 1 lần, gia hạn mỗi 2 năm (vào tháng 10-12 các năm chẵn) - FDA cấp số Registration Number cho cơ sở - Thông tin đăng ký: tên cơ sở, địa chỉ, loại hình hoạt động, loại sản phẩm **Lưu ý quan trọng:** - Đăng ký CƠ SỞ ≠ Đăng ký SẢN PHẨM - Có Registration Number ≠ Sản phẩm được "phê duyệt" - FDA không kiểm tra cơ sở trước khi cấp số ## 2. Prior Notice (Thông báo trước) **Khai báo TỪNG LÔ HÀNG trước khi xuất khẩu** - Phải khai báo trước mỗi lô hàng ít nhất 2-8 giờ (tùy phương thức vận chuyển) - Thông qua hệ thống Prior Notice System Interface (PNSI) - Thông tin cần có: sản phẩm, xuất xứ, số lượng, đóng gói, ngày dự kiến đến Mỹ **Prior Notice KHÔNG PHẢI:** - Không phải đăng ký sản phẩm - Không phải xin phép - Chỉ là thông báo để FDA biết lô hàng sắp đến ## 3. US FDA Agent (Đại diện tại Mỹ) **Bắt buộc cho cơ sở nước ngoài** - Cơ sở nước ngoài phải chỉ định 1 US Agent - US Agent là người liên lạc giữa FDA và cơ sở - US Agent phải có địa chỉ tại Mỹ, sẵn sàng 24/7 - Vai trò: nhận thông báo từ FDA, không chịu trách nhiệm pháp lý về sản phẩm ## Các quy định KHÁC liên quan FDA ### FSMA (Food Safety Modernization Act) **Quy định an toàn thực phẩm hiện đại** 1. **Preventive Controls (Kiểm soát phòng ngừa)** - Phân tích rủi ro - Xây dựng kế hoạch an toàn thực phẩm - Giám sát và ghi chép 2. **Foreign Supplier Verification Program (FSVP)** - Nhà nhập khẩu Mỹ phải xác minh nhà cung cấp nước ngoài - Không phải việc của nhà xuất khẩu 3. **FSMA 204 (Truy xuất nguồn gốc thực phẩm)** - Có hiệu lực từ 20/1/2026 - Áp dụng cho Food Traceability List (FTL) - Bao gồm: rau xanh, pho mát mềm, trứng, hải sản, các loại quả mọng,... ### Labeling (Nhãn mác) **Yêu cầu bắt buộc trên nhãn:** - Tên sản phẩm - Danh sách thành phần (theo thứ tự từ nhiều đến ít) - Nutrition Facts (thông tin dinh dưỡng) - Allergen Statement (cảnh báo dị ứng cho 8 allergen chính) - Net Weight (trọng lượng tịnh) - Tên và địa chỉ nhà sản xuất/đóng gói/phân phối **Lưu ý:** - Nhãn phải bằng tiếng Anh - Kích thước chữ, format phải tuân thủ quy định - Các claim (organic, non-GMO, healthy) có quy định riêng ## Quy trình xuất khẩu thực phẩm vào Mỹ ĐÚNG ### Bước 1: Đăng ký cơ sở với FDA - Online tại FDA website - Cung cấp thông tin cơ sở - Nhận số Registration Number - Chi phí: MIỄN PHÍ ### Bước 2: Chỉ định US FDA Agent - Tìm công ty cung cấp dịch vụ US Agent (như Vexim Global) - Ký hợp đồng US Agent - Cập nhật thông tin US Agent vào hệ thống FDA - Chi phí: Phụ thuộc nhà cung cấp dịch vụ ### Bước 3: Kiểm tra nhãn và công thức - Đảm bảo nhãn tuân thủ quy định FDA - Kiểm tra danh sách thành phần - Xác minh không có thành phần cấm - Review Nutrition Facts - Có thể thuê chuyên gia kiểm tra (như Vexim Global) ### Bước 4: Chuẩn bị Prior Notice - Trước mỗi lô hàng, khai báo Prior Notice - Thời gian: 2-8 giờ trước khi hàng đến cảng Mỹ - Thông qua PNSI system - Có thể thuê dịch vụ làm Prior Notice (như Vexim Global) ### Bước 5: Xuất khẩu - Hàng được phép nhập khẩu nếu Prior Notice được chấp nhận - FDA có thể inspect ngẫu nhiên tại cảng - Nếu bị giữ hàng: FDA gửi thông báo cho US Agent ## Các sản phẩm ĐẶC BIỆT ### Dietary Supplements (Thực phẩm bổ sung) - Phải đăng ký cơ sở - Phải nộp danh sách sản phẩm (NDI notification nếu có thành phần mới) - cGMP - Current Good Manufacturing Practice - Nhãn phải có "Supplement Facts" ### Low-Acid Canned Foods (Thực phẩm đóng hộp acid thấp) - Phải đăng ký quy trình (Process Filing) - FCE (Food Canning Establishment) và SID (Submission Identifier) - Yêu cầu cao về kiểm soát botulism ### Acidified Foods (Thực phẩm có tính acid) - Phải đăng ký quy trình - pH phải đạt yêu cầu ## CÂU TRẢ LỜI MẪU - Khi khách hỏi về FDA ### ❌ KHÔNG NÓI: - "Đăng ký sản phẩm với FDA" - "Prior Notice là đăng ký sản phẩm" - "FDA phê duyệt sản phẩm" - "Xin giấy phép FDA" ### ✅ NÊN NÓI: - "Đăng ký CƠ SỞ với FDA (Food Facility Registration)" - "Prior Notice là khai báo TỪNG LÔ HÀNG trước khi xuất" - "FDA không phê duyệt thực phẩm thường, chỉ yêu cầu tuân thủ quy định" - "Kiểm tra nhãn và thành phần để đảm bảo tuân thủ FDA" ## Ví dụ thực tế - CÁC TÌNH HUỐNG GIAO TIẾP ### TÌNH HUỐNG 1: Khách hỏi chung chung - CHƯA NÓI SẢN PHẨM **Khách:** "Tôi cần đăng ký FDA" **Trả lời ĐÚNG - HỎI SẢN PHẨM TRƯỚC:** "Dạ, em chào anh/chị! FDA là cơ quan quản lý thực phẩm và dược phẩm Mỹ. Để em hỗ trợ chính xác, anh/chị cho em biết: 1. Sản phẩm anh/chị muốn xuất khẩu là gì ạ? 2. Cơ sở sản xuất hiện tại có giấy phép ATTP nào chưa ạ?" **❌ TUYỆT ĐỐI KHÔNG trả lời:** "Để đăng ký chè khô với FDA..." (Khách chưa nói sản phẩm là gì!) ### TÌNH HUỐNG 2: Khách đã nói sản phẩm cụ thể **Khách:** "Tôi muốn đăng ký chè khô với FDA" **Trả lời ĐÚNG - SAU KHI BIẾT SẢN PHẨM:** "Dạ, chè khô là thực phẩm thường nên FDA không có hệ thống đăng ký sản phẩm ạ. Để xuất khẩu chè khô sang Mỹ, anh/chị cần: 1. **Đăng ký CƠ SỞ sản xuất** với FDA (miễn phí, online) 2. **Chỉ định US Agent** tại Mỹ (bắt buộc) 3. **Kiểm tra nhãn** theo quy định FDA (rất quan trọng!) 4. **Khai báo Prior Notice** cho mỗi lô hàng trước khi xuất Vexim có thể hỗ trợ anh/chị: - Làm US Agent (đại diện FDA tại Mỹ) - Kiểm tra và thiết kế nhãn chuẩn FDA - Làm Prior Notice cho từng lô hàng - Tư vấn quy trình xuất khẩu từ A-Z Anh/chị muốn mình hỗ trợ phần nào ạ?" ## 🔁 Khi NÀO phải chuyển chuyên viên (HANDOVER) **Bạn phải dừng tư vấn và mời kết nối chuyên viên khi khách hàng:** 1. Hỏi về sản phẩm cụ thể của họ 2. Hỏi chi phí / báo giá 3. Nói: "bạn có làm không", "giúp tôi làm", "kết nối giúp tôi" 4. Đã từng bị FDA giữ hàng / cảnh báo 5. Liên quan đến dietary supplement, low-acid canned food, acidified food ### 🗣️ Cách mời kết nối chuẩn: Khi cần chuyển chuyên viên, dùng văn phong sau: "Trường hợp này em cần chuyên viên bên em kiểm tra kỹ để tư vấn chính xác cho mình. Nếu anh/chị tiện, cho em xin số điện thoại, em nhờ chuyên viên của Vexim liên hệ hỗ trợ trực tiếp ạ." ### ✅ Có thể trả lời được: 1. Giải thích quy trình chung 2. Thông tin về Food Facility Registration 3. Giải thích Prior Notice là gì 4. Yêu cầu nhãn mác cơ bản 5. Phân biệt các loại sản phẩm ## 🚫 Giới hạn vai trò - Bạn không thay thế chuyên viên tư vấn - Bạn không đưa ra kết luận pháp lý cuối cùng - Nhiệm vụ của bạn là giải thích – định hướng – mở đường cho chuyên viên ## Chi phí dịch vụ (Thông tin chung) **Lưu ý: Không báo giá cụ thể, chỉ đưa thông tin tham khảo** - Food Facility Registration với FDA: MIỄN PHÍ (tự làm online) - US Agent Service: 300-1,000 USD/năm (tùy nhà cung cấp) - Label Review: 200-500 USD (tùy độ phức tạp) - Prior Notice: 5-20 USD/lần (hoặc trọn gói năm) - Tư vấn toàn diện: Liên hệ báo giá **Khi khách hỏi giá:** "Chi phí phụ thuộc vào nhiều yếu tố như loại sản phẩm, số lượng SKU, nhu cầu cụ thể ạ. Để tư vấn chính xác, em xin phép kết nối anh/chị với chuyên viên để báo giá chi tiết được không ạ?" [V0_FILE]markdown:file="knowledge/gacc-knowledge.md" isMerged="true" # GACC - Hải quan Trung Quốc (General Administration of Customs of the People's Republic of China) ## Vai trò và nguyên tắc giao tiếp Bạn là trợ lý tư vấn xuất nhập khẩu của Vexim Global, xưng "em", giao tiếp lịch sự, chuyên nghiệp. ## NGUYÊN TẮC BẮT BUỘC - KHÔNG ĐƯỢC GIẢ ĐỊNH SẢN PHẨM **⚠️ TUYỆT ĐỐI KHÔNG được tự ý giả định hoặc đề cập đến SẢN PHẨM CỤ THỂ mà khách chưa nói!** - ❌ SAI: "Để đăng ký chè khô với GACC..." - ❌ SAI: "Sản phẩm của anh/chị là..." - ✅ ĐÚNG: "Anh/chị cho em biết sản phẩm muốn xuất khẩu là gì ạ?" **Bắt đầu mọi cuộc hội thoại GACC bằng việc HỎI sản phẩm:** - "Anh/chị cho em biết sản phẩm muốn xuất khẩu sang Trung Quốc là gì ạ?" - Sau khi biết sản phẩm, mới đưa ra hướng dẫn cụ thể ## Nhiệm vụ chính 1. **HỎI TRƯỚC** về sản phẩm cụ thể của khách hàng 2. Giải thích quy định nhập khẩu thực phẩm vào Trung Quốc 3. Giúp doanh nghiệp hiểu đúng yêu cầu GACC cho SẢN PHẨM CỤ THỂ của họ 4. Định hướng giải pháp tuân thủ, tránh bị cảnh báo/giữ hàng ## Kiến thức chính xác về GACC (Cập nhật 2026) ### GACC là gì? General Administration of Customs (GACC) của Trung Quốc là cơ quan hải quan Trung Quốc, quản lý tất cả các hoạt động nhập khẩu vào nước này. **Website chính thức:** http://www.customs.gov.cn ### Yêu cầu chính nhập khẩu thực phẩm vào Trung Quốc (GACC Decree 280 - Có hiệu lực từ 1/6/2026) **1. Đăng ký cơ sở xuất khẩu (Bắt buộc - GACC Decree 280)** - **Tất cả** cơ sở sản xuất thực phẩm ở nước ngoài muốn xuất khẩu vào Trung Quốc phải đăng ký với GACC - Cung cấp đầy đủ thông tin: - Giấy phép an toàn thực phẩm địa phương - Chi tiết nguyên liệu thô - Quy trình chế biến và tiêu chuẩn - Điều kiện bảo quản - Bằng chứng quản lý chất lượng - GACC kiểm tra và phê duyệt trước khi cho phép xuất khẩu - **Danh sách cơ sở được phê duyệt** có thể tra cứu trên hệ thống GACC **2. Chứng chỉ vệ sinh và an toàn thực phẩm** - Cơ sở phải có chứng chỉ từ cơ quan có thẩm quyền nước xuất khẩu - Đối với Việt Nam: Thường là Bộ Nông nghiệp hoặc Bộ Y tế tùy sản phẩm - Trung Quốc có danh sách quốc gia và cơ quan được công nhận **3. Kiểm dịch và kiểm tra hàng (100% lô hàng)** - GACC yêu cầu kiểm dịch **toàn bộ lô hàng** nhập khẩu - Kiểm tra nhãn mác, thành phần, nguồn gốc - Kiểm tra mẫu thực tế về chất lượng và an toàn - **Lô hàng có thể bị giữ** nếu không đạt yêu cầu **4. Tuân thủ tiêu chuẩn Trung Quốc (GB Standards)** - Hàm lượng chất độc hại, kim loại nặng phải dưới giới hạn của Trung Quốc - Phụ gia thực phẩm phải nằm trong danh sách được phép (GB 2760) - Nhãn mác phải có **đầy đủ thông tin bằng tiếng Trung Quốc** (GB 7718): - Tên sản phẩm - Danh sách thành phần - Thông tin nhà sản xuất - Ngày sản xuất và hạn sử dụng - Điều kiện bảo quản - Cảnh báo (nếu có) ### Các loại sản phẩm có yêu cầu khắt khe hơn - Thực phẩm chiên rán, nước ngọt, nước ép trái cây - Sữa và sản phẩm từ sữa - Thịt và sản phẩm từ thịt - Hải sản - Ngũ cốc và các sản phẩm từ ngũ cốc ### Lợi thế khi làm việc với Vexim - Kinh nghiệm dài hạn với GACC - Hiểu rõ danh sách cơ sở được chấp thuận - Hỗ trợ chuẩn bị hồ sơ và tài liệu - Tư vấn về sửa đổi nhãn mác để tuân thủ ## Quy trình hỏi thông tin ĐÚNG **Bước 1: HỎI SẢN PHẨM (BẮT BUỘC)** Khi khách hỏi về GACC, LUÔN hỏi trước: - "Anh/chị cho em biết sản phẩm muốn xuất khẩu sang Trung Quốc là gì ạ?" - "Sản phẩm của anh/chị thuộc nhóm nào ạ? (Ví dụ: thực phẩm chế biến, nông sản, hải sản...)" **Bước 2: HỎI CHI TIẾT (tùy sản phẩm)** - Thành phần chính là gì? - Quy trình chế biến như thế nào? - Đã có giấy phép/chứng nhận nào chưa? **Bước 3: TƯ VẤN DỰA TRÊN SẢN PHẨM THỰC TẾ** Chỉ sau khi biết sản phẩm mới đưa ra hướng dẫn cụ thể. ## Ví dụ giao tiếp ĐÚNG **Khách:** "Tôi cần đăng ký GACC" **Bot (ĐÚNG):** "Dạ, em chào anh/chị. GACC là cơ quan hải quan Trung Quốc quản lý nhập khẩu thực phẩm vào Trung Quốc. Để em hỗ trợ chính xác, anh/chị cho em biết: 1. Sản phẩm anh/chị muốn xuất khẩu là gì ạ? 2. Hiện tại cơ sở sản xuất có giấy phép an toàn thực phẩm nào chưa ạ?" **Bot (SAI - TUYỆT ĐỐI TRÁNH):** "Để đăng ký chè khô với GACC..." ❌ (Khách chưa nói sản phẩm là chè!) ## Khi nào phải HANDOVER sang chuyên viên **Bắt buộc HANDOVER khi:** 1. Khách đã cho biết sản phẩm cụ thể và muốn tư vấn chi tiết 2. Khách nói "bạn có làm không", "giúp tôi làm", "hỗ trợ đăng ký" 3. Khách hỏi chi phí / báo giá 4. Khách nói đã bị GACC từ chối / cảnh báo / giữ hàng 5. Sản phẩm chứa thành phần phức tạp hoặc thuộc danh sách đặc biệt 6. Khách có lô hàng cụ thể đang cần xử lý gấp ## Cách mời kết nối chuẩn "Trường hợp này em cần chuyên viên bên em kiểm tra kỹ hồ sơ sản phẩm của anh/chị để tư vấn chính xác. Nếu anh/chị tiện, cho em xin số điện thoại, em nhờ chuyên viên của Vexim liên hệ hỗ trợ trực tiếp ạ." [V0_FILE]markdown:file="knowledge/mfds-knowledge.md" isMerged="true" # MFDS - Bộ Thực phẩm và An toàn Dược phẩm Hàn Quốc (Ministry of Food and Drug Safety) ## Vai trò và nguyên tắc giao tiếp Bạn là trợ lý tư vấn xuất nhập khẩu của Vexim Global, xưng "em", giao tiếp lịch sự, chuyên nghiệp. ## 🚨 NGUYÊN TẮC QUAN TRỌNG NHẤT - KHÔNG GIẢ ĐỊNH SẢN PHẨM **TUYỆT ĐỐI KHÔNG tự ý đề cập đến sản phẩm cụ thể mà khách chưa nói:** - ❌ SAI: "Để đăng ký [sản phẩm X] với MFDS..." (khi khách chỉ hỏi "đăng ký MFDS") - ✅ ĐÚNG: "Anh/chị cho em biết sản phẩm muốn xuất khẩu sang Hàn Quốc là gì ạ?" **QUY TRÌNH BẮT BUỘC:** 1. Khách hỏi về MFDS → HỎI SẢN PHẨM TRƯỚC 2. Khách cho biết sản phẩm → MỚI tư vấn cụ thể 3. KHÔNG BAO GIỜ giả định sản phẩm ## Nhiệm vụ chính 1. Giải thích quy định nhập khẩu thực phẩm vào Hàn Quốc 2. Giúp doanh nghiệp hiểu đúng yêu cầu MFDS 3. Định hướng giải pháp tuân thủ, tránh bị cảnh báo/giữ hàng ## Kiến thức chính xác về MFDS ### MFDS là gì? MFDS (Ministry of Food and Drug Safety) là bộ quản lý an toàn thực phẩm và dược phẩm của Hàn Quốc, yêu cầu tất cả thực phẩm nhập khẩu phải đáp ứng tiêu chuẩn khắt khe. ### Yêu cầu chính nhập khẩu thực phẩm vào Hàn Quốc **1. Đăng ký cơ sở sản xuất (Food Facility Registration)** - Cơ sở sản xuất phải được đăng ký trước với MFDS - MFDS yêu cầu kiểm toàn bộ quy trình sản xuất - Phải có người đại diện tại Hàn Quốc (importer hoặc local agent) **2. Kiểm tra và cấp phép (Approval System)** - Một số loại sản phẩm yêu cầu cấp phép riêng từ MFDS trước khi nhập khẩu - Bao gồm: thực phẩm chức năng, thực phẩm mới, phụ gia thực phẩm - Quy trình cấp phép rất kỹ và tốn thời gian (3-6 tháng) **3. Kiểm dịch (Quarantine Inspection)** - Mỗi lô hàng phải trải qua kiểm dịch tại Hàn Quốc - MFDS kiểm tra: nhãn mác, thành phần, giá trị dinh dưỡng, hạn sử dụng - Có thể kiểm tra mẫu chi tiết hoặc toàn bộ lô **4. Tuân thủ tiêu chuẩn Hàn Quốc** - Hàm lượng chất độc hại phải dưới giới hạn của Hàn Quốc - Phụ gia thực phẩm phải được phê duyệt bởi MFDS - Nhãn mác bắt buộc phải có thông tin bằng tiếng Hàn Quốc - Giá trị dinh dưỡng phải được ghi rõ theo chuẩn Hàn Quốc ### Các loại sản phẩm có yêu cầu khác nhau **Thực phẩm thường:** - Yêu cầu kiểm dịch cơ bản - Nhãn mác phù hợp quy định **Thực phẩm chức năng (Functional Foods):** - Yêu cầu cấp phép MFDS trước - Phải chứng minh tác dụng sức khỏe - Quá trình phê duyệt rất khắt khe **Thực phẩm mới (Novel Foods):** - Nếu chứa thành phần chưa từng dùng ở Hàn Quốc - Yêu cầu cấp phép riêng - Có thể cần các bài kiểm tra độc tính **Thực phẩm hữu cơ (Organic Foods):** - Phải có chứng chỉ hữu cơ được MFDS công nhận - Chứng chỉ từ một số nước cụ thể được thừa nhận ### Lợi thế khi làm việc với Vexim - Hiểu rõ tiêu chuẩn Hàn Quốc MFDS - Kinh nghiệm với các loại sản phẩm khác nhau - Hỗ trợ chuẩn bị hồ sơ cấp phép (nếu cần) - Tư vấn chỉnh sửa nhãn mác đúng tiêu chuẩn - Hỗ trợ tìm local importer nếu cần ## Khi nào phải HANDOVER sang chuyên viên **Bắt buộc HANDOVER khi:** 1. Khách hỏi về sản phẩm cụ thể của họ 2. Khách nói "bạn có làm không", "giúp tôi làm" 3. Khách hỏi chi phí / báo giá 4. Khách nói sản phẩm là "thực phẩm chức năng" hoặc "thực phẩm mới" 5. Khách nói đã bị MFDS từ chối / cảnh báo trước 6. Sản phẩm chứa thành phần phức tạp ## Cách mời kết nối chuẩn "Trường hợp này em cần chuyên viên bên em kiểm tra kỹ hồ sơ sản phẩm của anh/chị để tư vấn chính xác. Nếu anh/chị tiện, cho em xin số điện thoại, em nhờ chuyên viên của Vexim liên hệ hỗ trợ trực tiếp ạ." [V0_FILE]markdown:file="knowledge/us-agent-knowledge.md" isMerged="true" # US Agent - Đại diện Công ty Mỹ cho Xuất khẩu Thực phẩm ## Vai trò và nguyên tắc giao tiếp Bạn là trợ lý tư vấn xuất nhập khẩu của Vexim Global, xưng "em", giao tiếp lịch sự, chuyên nghiệp. ## 🚨 NGUYÊN TẮC QUAN TRỌNG NHẤT - KHÔNG GIẢ ĐỊNH SẢN PHẨM **LUÔN HỎI về sản phẩm trước khi tư vấn chi tiết:** - "Anh/chị xuất khẩu sản phẩm gì sang Mỹ ạ?" - KHÔNG tự ý đề cập sản phẩm cụ thể mà khách chưa nói - HỎI TRƯỚC rồi mới tư vấn về US Agent cho sản phẩm đó ## Nhiệm vụ chính 1. Giải thích yêu cầu US Agent là gì 2. Giúp doanh nghiệp hiểu tại sao cần US Agent 3. Định hướng giải pháp khi doanh nghiệp muốn xuất khẩu vào Mỹ ## Kiến thức về US Agent ### US Agent là gì? US Agent (Công ty Đại diện tại Mỹ) là một công ty hay cá nhân đặt tại Mỹ, được cấp quyền đại diện cho công ty nước ngoài để: - Nhận các thông báo từ FDA - Xử lý các vấn đề tuân thủ - Là điểm liên hệ chính thức với cơ quan Mỹ ### Tại sao cần US Agent? **Yêu cầu từ FDA:** - FDA yêu cầu tất cả cơ sở sản xuất thực phẩm nước ngoài phải có US Agent được đăng ký - US Agent là điểm liên hệ chính thức giữa cơ sở và FDA - FDA sẽ gửi tất cả các thông báo, cảnh báo, khuyến cáo tới US Agent **Lợi ích:** - Chịu trách nhiệm pháp lý: US Agent chịu trách nhiệm về tuân thủ - Liên hệ chuyên nghiệp: giảm hiểu lầm do ngôn ngữ, múi giờ - Quản lý tài liệu: US Agent lưu trữ tài liệu theo quy định FDA - Xử lý khẩn cấp: nếu có vấn đề, US Agent xử lý ngay tại Mỹ ### Yêu cầu của FDA về US Agent **Điều kiện:** - Phải là cá nhân hoặc công ty tại Mỹ - Phải có địa chỉ cụ thể tại Mỹ - Phải nói tiếng Anh, giao tiếp được với FDA - Phải là đại diện chính thức của cơ sở nước ngoài **Trách nhiệm của US Agent:** - Nhận các thông báo từ FDA - Liên hệ ngay với cơ sở nước ngoài khi có thông báo - Lưu trữ tài liệu liên quan - Xử lý các vấn đề tuân thủ - Có thể được yêu cầu cung cấp tài liệu cho FDA ### Vexim cung cấp dịch vụ US Agent gì? **1. Tìm US Agent** - Tìm kiếm US Agent phù hợp với sản phẩm - Thương lượng hợp đồng **2. Đăng ký US Agent với FDA** - Chuẩn bị hồ sơ - Đăng ký trên hệ thống FDA FURLS - Theo dõi quá trình phê duyệt **3. Hỗ trợ quản lý** - Giám sát hoạt động của US Agent - Hỗ trợ khi có vấn đề phát sinh - Đảm bảo US Agent tuân thủ yêu cầu **4. Liên lạc với FDA** - Hỗ trợ soạn thư gửi FDA - Xử lý các thông báo từ FDA - Tư vấn khi FDA cảnh báo ### Lợi ích khi làm việc với Vexim - Kinh nghiệm tìm US Agent uy tín - Hiểu rõ yêu cầu FDA về US Agent - Giải thích rõ ràng vai trò và trách nhiệm của US Agent - Hỗ trợ quản lý US Agent hiệu quả ## Khi nào phải HANDOVER sang chuyên viên **Bắt buộc HANDOVER khi:** 1. Khách hỏi chi tiết về tìm US Agent cho sản phẩm cụ thể 2. Khách nói "bạn có làm không", "giúp tôi làm" 3. Khách hỏi chi phí / báo giá 4. Khách muốn thương lượng hợp đồng với US Agent 5. Khách muốn đăng ký US Agent ngay ## Cách mời kết nối chuẩn "Trường hợp này em cần chuyên viên bên em kiểm tra kỹ sản phẩm và yêu cầu của anh/chị để tư vấn chi tiết. Nếu anh/chị tiện, cho em xin số điện thoại, em nhờ chuyên viên của Vexim liên hệ hỗ trợ trực tiếp ạ." [V0_FILE]typescript:file="lib/ai-service.ts" isMerged="true" import Groq from "groq-sdk" // Initialize Groq client let groq: Groq | null = null try { if (!process.env.GROQ_API_KEY) { console.error("[v0] GROQ_API_KEY is not set in environment variables") } else { groq = new Groq({ apiKey: process.env.GROQ_API_KEY, }) console.log("[v0] Groq client initialized successfully") } } catch (error) { console.error("[v0] Error initializing Groq client:", error) } export interface AIConfig { model: string maxTokens: number temperature: number systemPrompt: string } export interface KnowledgeChunk { id: string chunk_text: string document_title: string category: string } export interface AIResponse { message: string confidence: number sources: string[] shouldHandover: boolean handoverReason?: string } /** * Tạo embedding cho text (cần OpenAI hoặc alternative) * Đây là placeholder - bạn cần implement với OpenAI API hoặc local model */ export async function createEmbedding(text: string): Promise { // TODO: Implement với OpenAI API hoặc local embedding model // Hiện tại return mock embedding console.log("[v0] Creating embedding for:", text.substring(0, 100)) return Array(1536).fill(0) } /** * Tìm kiếm tài liệu liên quan từ knowledge base */ export async function searchKnowledge( query: string, topK: number = 5, supabase: any ): Promise { try { console.log("[v0] Searching knowledge base for:", query) // Tìm kiếm bằng ILIKE (case-insensitive pattern matching) // Phù hợp với tiếng Việt hơn full-text search const { data, error } = await supabase .from("knowledge_chunks") .select( ` id, content, knowledge_documents!inner(title, category, status) ` ) .ilike("content", `%${query}%`) .eq("knowledge_documents.status", "active") .limit(topK) if (error) { console.error("[v0] Knowledge search error:", error) throw error } console.log("[v0] Found knowledge chunks:", data?.length || 0) return ( data?.map((item: any) => ({ id: item.id, chunk_text: item.content, // Map content back to chunk_text for interface compatibility document_title: item.knowledge_documents.title, category: item.knowledge_documents.category, })) || [] ) } catch (error) { console.error("[v0] Error searching knowledge:", error) return [] } } /** * Xây dựng context từ knowledge chunks */ function buildContext(chunks: KnowledgeChunk[]): string { if (chunks.length === 0) return "" const context = chunks .map( (chunk, index) => `[Tài liệu ${index + 1}: ${chunk.document_title}]\n${chunk.chunk_text}` ) .join("\n\n") return `\n\nThông tin tham khảo:\n${context}` } /** * Phân tích intent và xác định cần chuyển sang agent không */ function analyzeIntent( message: string, aiResponse: string ): { confidence: number; shouldHandover: boolean; reason?: string } { const lowConfidenceKeywords = [ "không chắc", "có thể", "không rõ", "xin lỗi", "không hiểu", ] const urgentKeywords = [ "khẩn cấp", "gấp", "ngay", "urgent", "nhanh", ] const complexKeywords = [ "tư vấn chi tiết", "báo giá cụ thể", "hợp đồng", "thỏa thuận", "ký kết", ] let confidence = 0.8 // Default confidence // Check for low confidence indicators const hasLowConfidence = lowConfidenceKeywords.some((keyword) => aiResponse.toLowerCase().includes(keyword) ) if (hasLowConfidence) confidence = 0.3 // Check for urgent request const isUrgent = urgentKeywords.some((keyword) => message.toLowerCase().includes(keyword) ) if (isUrgent) { return { confidence: 0.2, shouldHandover: true, reason: "Yêu cầu khẩn cấp cần xử lý ngay", } } // Check for complex request const isComplex = complexKeywords.some((keyword) => message.toLowerCase().includes(keyword) ) if (isComplex) { return { confidence: 0.4, shouldHandover: true, reason: "Yêu cầu phức tạp cần chuyên gia tư vấn", } } return { confidence, shouldHandover: confidence < 0.5, reason: confidence < 0.5 ? "AI không đủ tin cậy để trả lời" : undefined, } } /** * Tạo response từ AI với RAG */ export async function generateAIResponse( message: string, conversationHistory: Array<{ role: string; content: string }>, config: AIConfig, supabase: any, ragEnabled: boolean = true ): Promise { try { // Check if Groq is initialized if (!groq) { throw new Error("Groq client is not initialized. Please check GROQ_API_KEY environment variable.") } let knowledgeChunks: KnowledgeChunk[] = [] let context = "" // RAG: Tìm kiếm knowledge base if (ragEnabled) { knowledgeChunks = await searchKnowledge(message, 5, supabase) context = buildContext(knowledgeChunks) } // Xây dựng messages cho Groq const messages: any[] = [ { role: "system", content: config.systemPrompt + context, }, ...conversationHistory, { role: "user", content: message, }, ] console.log("[v0] Calling Groq API with model:", config.model) // Gọi Groq API const completion = await groq.chat.completions.create({ model: config.model, messages, temperature: config.temperature, max_tokens: config.maxTokens, }) const aiMessage = completion.choices[0]?.message?.content || "" console.log("[v0] Received AI response:", aiMessage.substring(0, 100)) // Phân tích intent và confidence const analysis = analyzeIntent(message, aiMessage) return { message: aiMessage, confidence: analysis.confidence, sources: knowledgeChunks.map((c) => c.document_title), shouldHandover: analysis.shouldHandover, handoverReason: analysis.reason, } } catch (error) { console.error("[v0] Error generating AI response:", error) return { message: "Xin lỗi, tôi đang gặp sự cố kỹ thuật. Vui lòng thử lại sau hoặc liên hệ hotline để được hỗ trợ trực tiếp.", confidence: 0.0, sources: [], shouldHandover: true, handoverReason: "Lỗi hệ thống AI", } } } /** * Load AI config từ database */ export async function loadAIConfig(supabase: any): Promise { try { const { data, error } = await supabase .from("ai_config") .select("key, value") .in("key", [ "groq_model", "max_tokens", "temperature", "system_prompt", ]) if (error) throw error const config: any = {} data?.forEach((item: any) => { config[item.key] = item.value }) return { model: config.groq_model || "llama-3.3-70b-versatile", maxTokens: parseInt(config.max_tokens) || 1024, temperature: parseFloat(config.temperature) || 0.7, systemPrompt: config.system_prompt || `Bạn là trợ lý tư vấn tuân thủ xuất khẩu của Vexim Global. Bạn xưng "em", giao tiếp lịch sự, chuyên nghiệp, theo văn hóa Việt Nam, ưu tiên trả lời ngắn gọn – đúng trọng tâm – dễ hiểu. 📋 Dịch vụ chính của Vexim Global: 1. FDA (Mỹ) - Đăng ký cơ sở, Prior Notice, US Agent 2. GACC (Trung Quốc) - Đăng ký cơ sở Trung Quốc, kiểm dịch 3. MFDS (Hàn Quốc) - Cấp phép, kiểm dịch, tiêu chuẩn sản phẩm 4. Uỷ quyền Xuất khẩu (Export Delegation) - Xuất khẩu theo đơn đặt hàng 5. AI Traceability - Truy xuất nguồn gốc sản phẩm bằng AI 6. US Agent - Đại diện tại Mỹ cho FDA 🎯 Nhiệm vụ chính: - Giải thích CHÍNH XÁC quy định xuất nhập khẩu cho từng thị trường - Giúp khách hàng hiểu đúng bản chất pháp lý, tránh nhầm lẫn phổ biến - Định hướng giải pháp, không bán hàng lộ liễu - Biết khi nào phải chuyển chuyên viên 🚨 NGUYÊN TẮC QUAN TRỌNG NHẤT - KHÔNG GIẢ ĐỊNH SẢN PHẨM: - TUYỆT ĐỐI KHÔNG tự ý đề cập đến sản phẩm cụ thể mà khách chưa nói - TUYỆT ĐỐI KHÔNG dùng ví dụ sản phẩm như "chè khô", "cà phê", "hải sản" khi khách chưa nói - ❌ SAI: "Để đăng ký chè khô với GACC..." (khi khách chỉ hỏi "đăng ký GACC") - ✅ ĐÚNG: "Anh/chị cho em biết sản phẩm muốn xuất khẩu là gì ạ?" - LUÔN HỎI SẢN PHẨM TRƯỚC khi đưa ra hướng dẫn cụ thể ⚠️ Nguyên tắc bắt buộc - FDA: - FDA KHÔNG đăng ký sản phẩm thực phẩm thường - FDA chỉ yêu cầu: Đăng ký CƠ SỞ + Prior Notice + US Agent - TUYỆT ĐỐI KHÔNG dùng: "đăng ký sản phẩm", "xin giấy phép", "phê duyệt" - HỎI SẢN PHẨM trước khi tư vấn chi tiết ⚠️ Nguyên tắc bắt buộc - GACC (Cập nhật 2026): - HỎI SẢN PHẨM TRƯỚC: "Anh/chị cho em biết sản phẩm muốn xuất khẩu sang Trung Quốc là gì ạ?" - GACC Decree 280 (có hiệu lực 1/6/2026): Bắt buộc đăng ký cơ sở với GACC - Yêu cầu kiểm dịch toàn bộ lô hàng (100%) - Nhãn mác phải có tiếng Trung Quốc (GB 7718) - KHÔNG đề cập sản phẩm cụ thể nếu khách chưa nói ⚠️ Nguyên tắc bắt buộc - MFDS: - HỎI SẢN PHẨM trước khi tư vấn - MFDS yêu cầu đăng ký cơ sở trước - Thực phẩm chức năng / mới yêu cầu cấp phép riêng - Nhãn mác phải có tiếng Hàn Quốc 🧠 Cách trả lời: - Trả lời TỰ NHIÊN như trò chuyện thật, KHÔNG máy móc, KHÔNG rập khuôn - **TUYỆT ĐỐI CẤM** các câu máy móc sau: ❌ "Em có thể hỗ trợ anh/chị tìm hiểu thêm..." ❌ "Nếu anh/chị muốn, em có thể hỗ trợ kết nối..." ❌ "Anh/chị có thể tham khảo..." ❌ "Tuy nhiên, để có thông tin chính xác và cụ thể..." ❌ "Em nghĩ rằng anh/chị nên làm việc trực tiếp với chuyên viên..." ❌ BẤT KỲ câu nào bắt đầu bằng "Nếu anh/chị muốn..." - Kết thúc bằng CÂU HỎI CỤ THỂ về tình huống của khách, KHÔNG dùng câu chung chung - Ví dụ ĐÚNG: "Vậy cơ sở anh/chị đã có giấy phép ATTP chưa ạ?" - Ví dụ SAI: "Em có thể hỗ trợ anh/chị tìm hiểu thêm về GACC" ❌ - Không hỏi quá nhiều câu cùng lúc (tối đa 1-2 câu) - Không suy đoán khi thiếu thông tin; nếu không chắc → chuyển chuyên viên - Không báo giá cụ thể, không cam kết kết quả 🔁 Khi NÀO phải chuyển chuyên viên (HANDOVER): - Khách hỏi về sản phẩm cụ thể của họ - Khách nói: "bạn có làm không", "giúp tôi làm", "kết nối giúp tôi" - Khách hỏi chi phí / báo giá - Khách nói đã bị FDA/GACC/MFDS từ chối / cảnh báo - Sản phẩm là: dietary supplement, low-acid canned food, thực phẩm chức năng (MFDS) 🗣️ Cách mời kết nối chuẩn: "Trường hợp này em cần chuyên viên bên em kiểm tra kỹ để tư vấn chính xác cho mình. Nếu anh/chị tiện, cho em xin số điện thoại, em nhờ chuyên viên của Vexim liên hệ hỗ trợ trực tiếp ạ." 🚫 Giới hạn vai trò: - Bạn không thay thế chuyên viên tư vấn - Bạn không đưa ra kết luận pháp lý cuối cùng - Nhiệm vụ của bạn là giải thích – định hướng – mở đường cho chuyên viên`, } } catch (error) { console.error("[v0] Error loading AI config:", error) throw error } } [V0_FILE]typescriptreact:file="lib/blocks-to-html.tsx" isMerged="true" import type { Block } from "@/components/block-editor/types" /** * Convert block editor blocks to HTML string for display */ export function blocksToHTML(blocks: Block[]): string { if (!blocks || blocks.length === 0) { return "" } return blocks .map((block) => { const { type, data } = block const alignmentClass = { left: "text-left", center: "text-center", right: "text-right", justify: "text-justify", }[data.align || "left"] switch (type) { case "heading": { const level = data.level || 2 const sizeClass = level === 1 ? "text-4xl md:text-5xl" : level === 2 ? "text-3xl md:text-4xl" : level === 3 ? "text-2xl md:text-3xl" : level === 4 ? "text-xl md:text-2xl" : level === 5 ? "text-lg md:text-xl" : "text-base md:text-lg" return `${data.text || ""}` } case "paragraph": { return `

${data.text || ""}

` } case "image": { const imageAlign = { left: "justify-start", center: "justify-center", right: "justify-end", }[data.align || "center"] const widthClass = data.width === "100%" ? "w-full" : data.width === "80%" ? "w-4/5 mx-auto" : "w-3/5 mx-auto" const caption = data.caption ? `

${data.caption}

` : "" return `

` } case "quote": { const author = data.author ? `` : "" return `

${data.text || ""}
${author}

` } case "list": { const items = (data.items || []) .map((item: string) => `

${item}

`) .join("") const listTag = data.style === "ordered" ? "ol" : "ul" const listClass = data.style === "ordered" ? "list-decimal list-inside my-4 space-y-2" : "list-disc list-inside my-4 space-y-2" return `<${listTag} class="${listClass} ${alignmentClass}">${items}` } case "table": { if (!data.content || !Array.isArray(data.content)) { return "" } const rows = data.content .map((row: string[], rowIndex: number) => { const cells = row .map((cell: string, colIndex: number) => { const tag = rowIndex === 0 ? "th" : "td" const className = rowIndex === 0 ? "border p-3 bg-gray-100 font-semibold" : "border p-3" return `<${tag} class="${className}">${cell}` }) .join("") return `${cells}` }) .join("") return `

${rows}

` } default: return "" } }) .join("\n") } /** * Parse HTML content and convert to blocks * Automatically detects H1-H6 headings and converts them to heading blocks */ export function htmlToBlocks(html: string): Block[] { const blocks: Block[] = [] const parser = new DOMParser() const doc = parser.parseFromString(html, "text/html") let blockCounter = 0 // Process all child nodes const processNode = (node: Node) => { if (node.nodeType === Node.ELEMENT_NODE) { const element = node as HTMLElement const tagName = element.tagName.toLowerCase() // Check for headings H1-H6 const headingMatch = tagName.match(/^h([1-6])$/) if (headingMatch) { const level = Number.parseInt(headingMatch[1]) blocks.push({ id: `block_${blockCounter++}_${Math.random().toString(36).substr(2, 9)}`, type: "heading", data: { level, text: element.innerHTML, align: "left", }, }) return } // Check for paragraphs if (tagName === "p") { const text = element.innerHTML.trim() if (text) { blocks.push({ id: `block_${blockCounter++}_${Math.random().toString(36).substr(2, 9)}`, type: "paragraph", data: { text, align: "justify", }, }) } return } // Check for blockquote if (tagName === "blockquote") { blocks.push({ id: `block_${blockCounter++}_${Math.random().toString(36).substr(2, 9)}`, type: "quote", data: { text: element.innerHTML, author: "", align: "left", }, }) return } // Check for lists (ul/ol) if (tagName === "ul" || tagName === "ol") { const items: string[] = [] const lis = element.querySelectorAll("li") lis.forEach((li) => { const text = li.innerHTML.trim() if (text) { items.push(text) } }) if (items.length > 0) { blocks.push({ id: `block_${blockCounter++}_${Math.random().toString(36).substr(2, 9)}`, type: "list", data: { style: tagName === "ol" ? "ordered" : "unordered", items, align: "left", }, }) } return } // Check for images if (tagName === "img") { blocks.push({ id: `block_${blockCounter++}_${Math.random().toString(36).substr(2, 9)}`, type: "image", data: { url: element.getAttribute("src") || "", caption: element.getAttribute("alt") || "", align: "center", width: "100%", }, }) return } // Check for tables if (tagName === "table") { const rows: string[][] = [] const trs = element.querySelectorAll("tr") trs.forEach((tr) => { const cells: string[] = [] const tds = tr.querySelectorAll("th, td") tds.forEach((td) => { cells.push(td.innerHTML) }) if (cells.length > 0) { rows.push(cells) } }) if (rows.length > 0) { blocks.push({ id: `block_${blockCounter++}_${Math.random().toString(36).substr(2, 9)}`, type: "table", data: { rows: rows.length, cols: rows[0]?.length || 0, content: rows, align: "left", }, }) } return } // Process child nodes recursively node.childNodes.forEach(processNode) } else if (node.nodeType === Node.TEXT_NODE) { const text = node.textContent?.trim() if (text) { // Create paragraph for standalone text blocks.push({ id: `block_${blockCounter++}_${Math.random().toString(36).substr(2, 9)}`, type: "paragraph", data: { text, align: "justify", }, }) } } } // Start processing from body doc.body.childNodes.forEach(processNode) // If no blocks were created, fallback to plain text paragraphs if (blocks.length === 0) { const text = html.trim() if (text) { const lines = text.split(/\n+/) lines.forEach((line) => { const trimmed = line.trim() if (trimmed) { blocks.push({ id: `block_${blockCounter++}_${Math.random().toString(36).substr(2, 9)}`, type: "paragraph", data: { text: trimmed, align: "justify", }, }) } }) } } return blocks } [V0_FILE]typescriptreact:file="lib/blog-data.tsx" isMerged="true" export interface BlogPost { id: string slug: string title: string excerpt: string content: string category: "FDA" | "GACC" | "MFDS" | "Tin tức thị trường" | "Xuất nhập khẩu" | "Kiến thức pháp lý" featuredImage: string metaTitle: string metaDescription: string author: string date: string status: "draft" | "published" } // Mock data cho blog posts export const blogPosts: BlogPost[] = [ { id: "1", slug: "huong-dan-dang-ky-fda-2026", title: "Hướng dẫn mới nhất về đăng ký FDA năm 2026", excerpt: "Cập nhật các quy định mới của FDA cho doanh nghiệp xuất khẩu thực phẩm và mỹ phẩm sang thị trường Mỹ trong năm 2026.", content: `

Tổng quan về đăng ký FDA 2026

Cơ quan Quản lý Thực phẩm và Dược phẩm Hoa Kỳ (FDA) đã công bố một loạt các quy định mới có hiệu lực từ đầu năm 2026...

Những thay đổi quan trọng

Các doanh nghiệp xuất khẩu thực phẩm, mỹ phẩm và thiết bị y tế cần lưu ý những điểm sau:

Thời gian xử lý hồ sơ được rút ngắn từ 60 xuống 45 ngày
Yêu cầu bổ sung thông tin về nguồn gốc nguyên liệu
Tăng cường kiểm tra về an toàn thực phẩm theo FSMA 204

Cách thức tuân thủ

Vexim Global khuyến nghị doanh nghiệp nên chuẩn bị hồ sơ sớm và đảm bảo đầy đủ các yêu cầu mới...

`, category: "FDA", featuredImage: "https://images.unsplash.com/photo-1450101499163-c8848c66ca85?q=80&w=1200", metaTitle: "Hướng dẫn đăng ký FDA 2026 - Cập nhật quy định mới nhất", metaDescription: "Tìm hiểu các quy định mới của FDA năm 2026 và cách thức tuân thủ cho doanh nghiệp xuất khẩu Việt Nam.", author: "Vexim Global", date: "15/01/2026", status: "published", }, { id: "2", slug: "thay-doi-quy-trinh-gacc", title: "Thay đổi trong quy trình đăng ký mã GACC Trung Quốc", excerpt: "Tổng cục Hải quan Trung Quốc công bố các điều chỉnh quan trọng trong quy trình cấp mã số GACC cho doanh nghiệp nước ngoài.", content: `

Quy trình GACC mới 2026

Tổng cục Hải quan Trung Quốc (GACC) đã thực hiện nhiều thay đổi quan trọng nhằm đơn giản hóa quy trình đăng ký...

`, category: "GACC", featuredImage: "https://images.unsplash.com/photo-1454165804606-c3d57bc86b40?q=80&w=1200", metaTitle: "Thay đổi quy trình đăng ký mã GACC Trung Quốc 2026", metaDescription: "Cập nhật các thay đổi mới nhất trong quy trình cấp mã GACC cho doanh nghiệp xuất khẩu vào thị trường Trung Quốc.", author: "Vexim Global", date: "12/01/2026", status: "published", }, { id: "3", slug: "xu-huong-xuat-khau-eu-2026", title: "Xu hướng xuất khẩu sang thị trường EU 2026", excerpt: "Phân tích các cơ hội và thách thức cho doanh nghiệp Việt Nam khi xuất khẩu sản phẩm sang thị trường châu Âu.", content: `

Thị trường EU - Cơ hội và thách thức

Liên minh châu Âu tiếp tục là một trong những thị trường xuất khẩu tiềm năng nhất cho doanh nghiệp Việt Nam...

`, category: "Tin tức thị trường", featuredImage: "https://images.unsplash.com/photo-1507679799987-c73779587ccf?q=80&w=1200", metaTitle: "Xu hướng xuất khẩu EU 2026 - Cơ hội cho doanh nghiệp Việt", metaDescription: "Phân tích chi tiết về xu hướng xuất khẩu sang thị trường EU và cách thức tận dụng hiệp định EVFTA.", author: "Vexim Global", date: "08/01/2026", status: "published", }, ] export function getBlogPosts(category?: string): BlogPost[] { if (category && category !== "all") { return blogPosts.filter((post) => post.category === category && post.status === "published") } return blogPosts.filter((post) => post.status === "published") } export function getBlogPost(slug: string): BlogPost | undefined { return blogPosts.find((post) => post.slug === slug) } [V0_FILE]typescriptreact:file="lib/email-gacc.tsx" isMerged="true" // Email template for GACC Submissions export interface GACCSubmissionParams { companyName: string productName: string hsCode: string submissionId: string submittedAt: string email?: string phone?: string taxCode?: string } // User Confirmation Email export function getGACCUserConfirmationHTML(params: GACCSubmissionParams): string { return ` Xác nhận gửi hồ sơ đánh giá GACC

Kính gửi ${params.companyName},

Chúng tôi đã nhận được hồ sơ đánh giá khả năng đăng ký GACC của quý công ty. Cảm ơn quý công ty đã tin tưởng và sử dụng dịch vụ của Vexim Global.

🎯 Hồ sơ đang được xử lý

📋 Thông tin hồ sơ

Mã hồ sơ: #${params.submissionId.slice(0, 8).toUpperCase()}

Doanh nghiệp: ${params.companyName}

Sản phẩm: ${params.productName}

Mã HS: ${params.hsCode}

Thời gian gửi: ${params.submittedAt}

📌 Các bước tiếp theo

Bước 1: Chuyên viên của chúng tôi sẽ xem xét hồ sơ trong vòng 1-2 ngày làm việc
Bước 2: Quý công ty sẽ nhận được báo cáo đánh giá sơ bộ qua email
Bước 3: Nếu cần bổ sung tài liệu, chúng tôi sẽ liên hệ trực tiếp
Bước 4: Sau khi hoàn thiện, chúng tôi sẽ hỗ trợ quý công ty nộp hồ sơ chính thức

Lưu ý quan trọng:

Vui lòng lưu giữ mã hồ sơ để tra cứu
Hệ thống sẽ tự động gửi thông báo khi có cập nhật
Mọi thắc mắc xin liên hệ hotline: 0373 685 634

`.trim() } // Admin Notification Email export function getGACCAdminNotificationHTML(params: GACCSubmissionParams): string { return ` Hồ sơ GACC mới cần xử lý

Hồ sơ đánh giá GACC mới từ khách hàng

Có một hồ sơ đánh giá GACC mới vừa được gửi và đang chờ xem xét.

Mã hồ sơ: #${params.submissionId.slice(0, 8).toUpperCase()}

Doanh nghiệp: ${params.companyName}

Sản phẩm: ${params.productName}

Mã HS: ${params.hsCode}

${params.taxCode ? `

Mã số thuế: ${params.taxCode}

` : ''} ${params.phone ? `

Số điện thoại: ${params.phone}

` : ''} ${params.email ? `

Email: ${params.email}

` : ''}

Thời gian gửi: ${params.submittedAt}

Xem chi tiết hồ sơ →

⏰ Lưu ý: Khách hàng mong đợi nhận được phản hồi trong vòng 1-2 ngày làm việc.

`.trim() } [V0_FILE]typescript:file="lib/email-service-zoho.ts" isMerged="true" // Email Service for FDA Alerts using Zoho SMTP // Alternative to Resend API - uses standard SMTP import { getVerificationEmailHTML, getAlertEmailHTML, getImmediateAlertEmailHTML, getUnsubscribeEmailHTML, } from "@/lib/email-templates" import type { FDAItem } from "@/types/fda" import nodemailer from "nodemailer" import type { SupabaseClient } from "@supabase/supabase-js" import { createServerClient } from "@/lib/supabase-server" // Declare the variable here // Zoho SMTP Configuration - Using existing Vercel env variables // Read at runtime to ensure env vars are available function getSmtpConfig() { console.log("[v0] Reading env vars:") console.log("[v0] MAIL_USERNAME:", process.env.MAIL_USERNAME ? `${process.env.MAIL_USERNAME.substring(0, 3)}***` : "undefined") console.log("[v0] MAIL_PASSWORD:", process.env.MAIL_PASSWORD ? `${process.env.MAIL_PASSWORD.substring(0, 2)}*** (length: ${process.env.MAIL_PASSWORD.length})` : "undefined") console.log("[v0] MAIL_HOST:", process.env.MAIL_HOST || "undefined") console.log("[v0] MAIL_PORT:", process.env.MAIL_PORT || "undefined") return { host: process.env.MAIL_HOST || process.env.SMTP_HOST || "smtp.zoho.com", port: Number.parseInt(process.env.MAIL_PORT || process.env.SMTP_PORT || "587", 10), user: process.env.MAIL_USERNAME || process.env.SMTP_USER || "", password: process.env.MAIL_PASSWORD || process.env.SMTP_PASSWORD || "", fromEmail: process.env.MAIL_FROM_ADDRESS || process.env.FROM_EMAIL || "contact@veximglobal.com", fromName: process.env.MAIL_FROM_NAME || process.env.FROM_NAME || "VEXIM GLOBAL", baseUrl: process.env.NEXT_PUBLIC_BASE_URL || "https://www.veximglobal.com", } } export class EmailServiceZoho { private getTransporter() { const config = getSmtpConfig() console.log("[v0] Creating transporter with config:", { host: config.host, port: config.port, user: config.user ? "configured" : "not configured", password: config.password ? `configured (length: ${config.password.length})` : "not configured", }) if (!config.user || !config.password) { return null } return nodemailer.createTransport({ host: config.host, port: config.port, secure: config.port === 465, // true for 465, false for other ports auth: { user: config.user, pass: config.password, }, tls: { // Required for Zoho SMTP ciphers: 'SSLv3', rejectUnauthorized: false, }, requireTLS: true, // Force TLS connectionTimeout: 10000, // 10 seconds timeout greetingTimeout: 10000, socketTimeout: 10000, }) } // Send verification email async sendVerificationEmail(email: string, token: string) { try { const config = getSmtpConfig() const verificationLink = `${config.baseUrl}/api/fda/verify?email=${encodeURIComponent(email)}&token=${token}` const unsubscribeLink = `${config.baseUrl}/api/fda/subscribe?email=${encodeURIComponent(email)}&token=${token}` const html = getVerificationEmailHTML({ email, verificationLink, unsubscribeLink, }) await this.sendEmail({ to: email, subject: "Xác nhận đăng ký cảnh báo FDA - Vexim Global", html, }) console.log(`[v0] Verification email sent to ${email}`) return true } catch (error) { console.error("[v0] Error sending verification email:", error) return false } } // Send daily/weekly alert digest async sendAlertDigest(frequency: "daily" | "weekly", supabase: SupabaseClient): Promise<{ emailsSent: number }> { let emailsSent = 0 try { const config = getSmtpConfig() // Get active subscribers with this frequency const { data: subscribers, error } = await supabase .from("fda_subscriptions") .select("*") .eq("is_active", true) .eq("verified", true) .eq("frequency", frequency) if (error || !subscribers || subscribers.length === 0) { console.log(`[v0] No active ${frequency} subscribers found`) return { emailsSent: 0 } } console.log(`[v0] Sending ${frequency} digest to ${subscribers.length} subscribers`) // Get latest alerts from cache or FDA API const alerts = await this.getLatestAlerts(supabase) // Send to each subscriber for (const subscriber of subscribers) { try { // Filter alerts by subscriber's categories const filteredAlerts = alerts.filter((alert) => subscriber.categories.includes(alert.category)) if (filteredAlerts.length === 0) { continue } const unsubscribeLink = `${config.baseUrl}/api/fda/subscribe?email=${encodeURIComponent(subscriber.email)}&token=${subscriber.verification_token}` const html = getAlertEmailHTML({ email: subscriber.email, alerts: filteredAlerts.slice(0, 5), alertCount: filteredAlerts.length, frequency, unsubscribeLink, }) await this.sendEmail({ to: subscriber.email, subject: `🚨 ${frequency === "daily" ? "Tóm tắt cảnh báo FDA hôm nay" : "Tóm tắt cảnh báo FDA tuần này"} - Vexim Global`, html, }) // Update last_sent_at await supabase .from("fda_subscriptions") .update({ last_sent_at: new Date().toISOString() }) .eq("id", subscriber.id) emailsSent++ console.log(`[v0] Sent ${frequency} digest to ${subscriber.email}`) } catch (error) { console.error(`[v0] Error sending to ${subscriber.email}:`, error) } } console.log(`[v0] Completed ${frequency} digest sending. Total sent: ${emailsSent}`) return { emailsSent } } catch (error) { console.error(`[v0] Error in sendAlertDigest ${frequency}:`, error) return { emailsSent } } } // Send immediate alert for critical items async sendImmediateAlert(alert: FDAItem, supabase: SupabaseClient) { try { const config = getSmtpConfig() // Get subscribers with immediate frequency and matching category const { data: subscribers, error } = await supabase .from("fda_subscriptions") .select("*") .eq("is_active", true) .eq("verified", true) .eq("frequency", "immediate") .contains("categories", [alert.category]) if (error || !subscribers || subscribers.length === 0) { console.log(`[v0] No immediate subscribers for category: ${alert.category}`) return } console.log(`[v0] Sending immediate alert to ${subscribers.length} subscribers`) for (const subscriber of subscribers) { try { const unsubscribeLink = `${config.baseUrl}/api/fda/subscribe?email=${encodeURIComponent(subscriber.email)}&token=${subscriber.verification_token}` const html = getImmediateAlertEmailHTML({ email: subscriber.email, alert, unsubscribeLink, }) await this.sendEmail({ to: subscriber.email, subject: `🚨 CẢNH BÁO FDA KHẨN CẤP: ${alert.title.substring(0, 50)} - Vexim Global`, html, }) // Update last_sent_at await supabase .from("fda_subscriptions") .update({ last_sent_at: new Date().toISOString() }) .eq("id", subscriber.id) console.log(`[v0] Sent immediate alert to ${subscriber.email}`) } catch (error) { console.error(`[v0] Error sending immediate alert to ${subscriber.email}:`, error) } } } catch (error) { console.error("[v0] Error in sendImmediateAlert:", error) } } // Send unsubscribe confirmation async sendUnsubscribeConfirmation(email: string) { try { const html = getUnsubscribeEmailHTML({ email }) await this.sendEmail({ to: email, subject: "Đã hủy đăng ký cảnh báo FDA - Vexim Global", html, }) console.log(`[v0] Unsubscribe confirmation sent to ${email}`) return true } catch (error) { console.error("[v0] Error sending unsubscribe confirmation:", error) return false } } // Core email sending function using Zoho SMTP with retry mechanism async sendEmail({ to, subject, html, retryCount = 0, }: { to: string subject: string html: string retryCount?: number }): Promise { const MAX_RETRIES = 3 const RETRY_DELAY_MS = 2000 try { const config = getSmtpConfig() console.log(`[v0] Starting email send process (attempt ${retryCount + 1}/${MAX_RETRIES + 1})...`) console.log(`[v0] SMTP Config: host=${config.host}, port=${config.port}`) console.log(`[v0] SMTP User configured: ${config.user ? "Yes" : "No"}`) console.log(`[v0] SMTP Password configured: ${config.password ? "Yes (length: " + config.password.length + ")" : "No"}`) // If SMTP credentials not set, log email instead (dev mode) if (!config.user || !config.password) { console.log("[v0] [DEV MODE] Email would be sent:") console.log(` To: ${to}`) console.log(` Subject: ${subject}`) console.log(` HTML length: ${html.length} chars`) return true } const transporter = this.getTransporter() if (!transporter) { console.error("[v0] Failed to create transporter - credentials missing") return false } console.log("[v0] Sending email...") const info = await transporter.sendMail({ from: `"${config.fromName}" <${config.fromEmail}>`, to, subject, html, }) console.log(`[v0] Email sent successfully via Zoho SMTP!`) console.log(`[v0] Message ID: ${info.messageId}`) console.log(`[v0] Response: ${info.response}`) return true } catch (error) { console.error(`[v0] Error sending email via Zoho (attempt ${retryCount + 1}):`, error) if (error instanceof Error) { console.error("[v0] Error message:", error.message) console.error("[v0] Error stack:", error.stack) } // Retry logic with exponential backoff if (retryCount < MAX_RETRIES) { const delay = RETRY_DELAY_MS * Math.pow(2, retryCount) console.log(`[v0] Retrying email send in ${delay}ms... (${retryCount + 1}/${MAX_RETRIES})`) await new Promise(resolve => setTimeout(resolve, delay)) return this.sendEmail({ to, subject, html, retryCount: retryCount + 1 }) } // All retries exhausted - log failed email to database for manual retry await this.logFailedEmail(to, subject, error instanceof Error ? error.message : String(error)) console.error("[v0] Failed to send email after all retries") throw error } } // Log failed emails to database for manual retry private async logFailedEmail(to: string, subject: string, errorMessage: string): Promise { try { // Just log to console - database logging can be added by caller if needed console.error(`[v0] FAILED EMAIL - To: ${to}, Subject: ${subject}, Error: ${errorMessage}`) } catch (error) { console.error("[v0] Error logging failed email:", error) } } // Helper: Get latest alerts (from cache or API) private async getLatestAlerts(supabase: SupabaseClient): Promise { try { // Try to get from cache first const { data: cached } = await supabase .from("fda_alerts_cache") .select("data, total_count") .gt("expires_at", new Date().toISOString()) .order("cached_at", { ascending: false }) .limit(1) .single() if (cached && cached.data) { console.log("[v0] Using cached FDA alerts") return cached.data as FDAItem[] } console.log("[v0] No cached alerts available") return [] } catch (error) { console.error("[v0] Error getting latest alerts:", error) return [] } } } // Singleton instance export const emailService = new EmailServiceZoho() [V0_FILE]typescript:file="lib/email-service.ts" isMerged="true" // Email Service for FDA Alerts // Uses Resend API for sending emails import { createServerClient } from "@/lib/supabase-server" import { getVerificationEmailHTML, getAlertEmailHTML, getImmediateAlertEmailHTML, getUnsubscribeEmailHTML, } from "@/lib/email-templates" import type { FDAItem } from "@/types/fda" const RESEND_API_KEY = process.env.RESEND_API_KEY || "" const FROM_EMAIL = "FDA Tracker " const BASE_URL = process.env.NEXT_PUBLIC_BASE_URL || "https://www.veximglobal.com" export class EmailService { // Send verification email async sendVerificationEmail(email: string, token: string) { try { const verificationLink = `${BASE_URL}/api/fda/verify?email=${encodeURIComponent(email)}&token=${token}` const unsubscribeLink = `${BASE_URL}/api/fda/subscribe?email=${encodeURIComponent(email)}&token=${token}` const html = getVerificationEmailHTML({ email, verificationLink, unsubscribeLink, }) await this.sendEmail({ to: email, subject: "Xác nhận đăng ký cảnh báo FDA - Vexim Global", html, }) console.log(`[v0] Verification email sent to ${email}`) return true } catch (error) { console.error("[v0] Error sending verification email:", error) return false } } // Send daily/weekly alert digest async sendAlertDigest(frequency: "daily" | "weekly") { try { const supabase = await createServerClient() // Get active subscribers with this frequency const { data: subscribers, error } = await supabase .from("fda_subscriptions") .select("*") .eq("is_active", true) .eq("verified", true) .eq("frequency", frequency) if (error || !subscribers || subscribers.length === 0) { console.log(`[v0] No active ${frequency} subscribers found`) return } console.log(`[v0] Sending ${frequency} digest to ${subscribers.length} subscribers`) // Get latest alerts from cache or FDA API const alerts = await this.getLatestAlerts() // Send to each subscriber for (const subscriber of subscribers) { try { // Filter alerts by subscriber's categories const filteredAlerts = alerts.filter((alert) => subscriber.categories.includes(alert.category)) if (filteredAlerts.length === 0) { continue } const unsubscribeLink = `${BASE_URL}/api/fda/subscribe?email=${encodeURIComponent(subscriber.email)}&token=${subscriber.verification_token}` const html = getAlertEmailHTML({ email: subscriber.email, alerts: filteredAlerts.slice(0, 5), alertCount: filteredAlerts.length, frequency, unsubscribeLink, }) await this.sendEmail({ to: subscriber.email, subject: `🚨 ${frequency === "daily" ? "Tóm tắt cảnh báo FDA hôm nay" : "Tóm tắt cảnh báo FDA tuần này"} - Vexim Global`, html, }) // Update last_sent_at await supabase .from("fda_subscriptions") .update({ last_sent_at: new Date().toISOString() }) .eq("id", subscriber.id) console.log(`[v0] Sent ${frequency} digest to ${subscriber.email}`) } catch (error) { console.error(`[v0] Error sending to ${subscriber.email}:`, error) } } console.log(`[v0] Completed ${frequency} digest sending`) } catch (error) { console.error(`[v0] Error in sendAlertDigest ${frequency}:`, error) } } // Send immediate alert for critical items async sendImmediateAlert(alert: FDAItem) { try { const supabase = await createServerClient() // Get subscribers with immediate frequency and matching category const { data: subscribers, error } = await supabase .from("fda_subscriptions") .select("*") .eq("is_active", true) .eq("verified", true) .eq("frequency", "immediate") .contains("categories", [alert.category]) if (error || !subscribers || subscribers.length === 0) { console.log(`[v0] No immediate subscribers for category: ${alert.category}`) return } console.log(`[v0] Sending immediate alert to ${subscribers.length} subscribers`) for (const subscriber of subscribers) { try { const unsubscribeLink = `${BASE_URL}/api/fda/subscribe?email=${encodeURIComponent(subscriber.email)}&token=${subscriber.verification_token}` const html = getImmediateAlertEmailHTML({ email: subscriber.email, alert, unsubscribeLink, }) await this.sendEmail({ to: subscriber.email, subject: `🚨 CẢNH BÁO FDA KHẨN CẤP: ${alert.title.substring(0, 50)} - Vexim Global`, html, }) // Update last_sent_at await supabase .from("fda_subscriptions") .update({ last_sent_at: new Date().toISOString() }) .eq("id", subscriber.id) console.log(`[v0] Sent immediate alert to ${subscriber.email}`) } catch (error) { console.error(`[v0] Error sending immediate alert to ${subscriber.email}:`, error) } } } catch (error) { console.error("[v0] Error in sendImmediateAlert:", error) } } // Send unsubscribe confirmation async sendUnsubscribeConfirmation(email: string) { try { const html = getUnsubscribeEmailHTML({ email }) await this.sendEmail({ to: email, subject: "Đã hủy đăng ký cảnh báo FDA - Vexim Global", html, }) console.log(`[v0] Unsubscribe confirmation sent to ${email}`) return true } catch (error) { console.error("[v0] Error sending unsubscribe confirmation:", error) return false } } // Core email sending function private async sendEmail({ to, subject, html, }: { to: string subject: string html: string }): Promise { try { // If RESEND_API_KEY is not set, log email instead of sending (dev mode) if (!RESEND_API_KEY) { console.log("[v0] [DEV MODE] Email would be sent:") console.log(` To: ${to}`) console.log(` Subject: ${subject}`) console.log(` HTML length: ${html.length} chars`) return true } // Send via Resend API const response = await fetch("https://api.resend.com/emails", { method: "POST", headers: { "Content-Type": "application/json", Authorization: `Bearer ${RESEND_API_KEY}`, }, body: JSON.stringify({ from: FROM_EMAIL, to, subject, html, }), }) if (!response.ok) { const errorText = await response.text() throw new Error(`Resend API error: ${response.status} ${errorText}`) } const data = await response.json() console.log(`[v0] Email sent successfully:`, data) return true } catch (error) { console.error("[v0] Error sending email:", error) throw error } } // Helper: Get latest alerts (from cache or API) private async getLatestAlerts(): Promise { try { const supabase = await createServerClient() // Try to get from cache first const { data: cached } = await supabase .from("fda_alerts_cache") .select("data, total_count") .gt("expires_at", new Date().toISOString()) .order("cached_at", { ascending: false }) .limit(1) .single() if (cached && cached.data) { console.log("[v0] Using cached FDA alerts") return cached.data as FDAItem[] } // If no cache, fetch from FDA API (would need to import fdaApi here) // For now, return empty array console.log("[v0] No cached alerts available") return [] } catch (error) { console.error("[v0] Error getting latest alerts:", error) return [] } } } // Singleton instance export const emailService = new EmailService() [V0_FILE]typescriptreact:file="lib/email-templates.tsx" isMerged="true" // Email templates for FDA Alert System and GACC Submissions export interface EmailTemplateParams { email: string verificationLink?: string unsubscribeLink?: string alerts?: any[] alertCount?: number } export interface GACCSubmissionParams { companyName: string productName: string hsCode: string submissionId: string submittedAt: string email?: string } // Verification Email Template export function getVerificationEmailHTML(params: EmailTemplateParams): string { return ` Xác nhận đăng ký cảnh báo FDA

Chào mừng bạn đến với Vexim Global FDA Tracker!

Cảm ơn bạn đã đăng ký nhận cảnh báo FDA. Để hoàn tất đăng ký, vui lòng xác nhận địa chỉ email của bạn:

Xác nhận email của tôi

Bạn sẽ nhận được:

✅ Cảnh báo thu hồi thực phẩm, dược phẩm, mỹ phẩm từ FDA
✅ Tóm tắt bằng tiếng Việt với AI
✅ Thông báo realtime hoặc tổng hợp theo tuần
✅ Hoàn toàn MIỄN PHÍ và có thể hủy bất cứ lúc nào

Lưu ý: Link xác nhận sẽ hết hạn sau 24 giờ.

Nếu bạn không đăng ký dịch vụ này, vui lòng bỏ qua email này.

`.trim() } // Daily/Weekly Alert Email Template export function getAlertEmailHTML(params: EmailTemplateParams & { frequency: "daily" | "weekly" }): string { const { alerts = [], alertCount = 0, frequency } = params const title = frequency === "daily" ? "Tóm tắt cảnh báo FDA hôm nay" : "Tóm tắt cảnh báo FDA tuần này" const alertsHTML = alerts .slice(0, 5) .map( (alert, index) => `

${index + 1}

${alert.title}

⚠️ ${alert.criticalInfo}

${ alert.aiSummary ? `

Tóm tắt AI: ${alert.aiSummary}

` : "" }

${alert.date ? `📅 ${new Date(alert.date).toLocaleDateString("vi-VN")}` : ""} ${alert.manufacturer ? `🏭 ${alert.manufacturer}` : ""} ${alert.classification ? `${alert.classification}` : ""}

`, ) .join("") return ` ${title}

${alertCount}

Tổng cảnh báo

${alerts.length}

Nổi bật

${alerts.filter((a) => a.classification?.includes("I")).length}

Mức độ cao

📋 Cảnh báo nổi bật

${alertsHTML} ${ alertCount > 5 ? `

Còn ${alertCount - 5} cảnh báo khác chưa hiển thị trong email này.

Xem tất cả cảnh báo →

` : "" }

💡 Lưu ý quan trọng

Kiểm tra kỹ sản phẩm trước khi sử dụng
Thông tin từ FDA.gov, cập nhật realtime
Liên hệ Vexim Global để tư vấn chi tiết

`.trim() } // Immediate Alert Email Template (Single Alert) export function getImmediateAlertEmailHTML(params: EmailTemplateParams & { alert: any }): string { const { alert } = params return ` 🚨 Cảnh báo FDA khẩn cấp

Có một cảnh báo FDA mới vừa được phát hành:

${alert.title}

⚠️ ${alert.criticalInfo}

${ alert.aiSummary ? `

🤖 Tóm tắt AI

${alert.aiSummary}

` : "" }

${alert.date ? `

📅 Ngày: ${new Date(alert.date).toLocaleDateString("vi-VN")}

` : ""} ${alert.manufacturer ? `

🏭 Nhà sản xuất: ${alert.manufacturer}

` : ""} ${alert.classification ? `

⚠️ Phân loại: ${alert.classification}

` : ""} ${alert.distributionPattern ? `

🌍 Phân phối: ${alert.distributionPattern}

` : ""}

⚡ Hành động ngay để đảm bảo an toàn

Xem chi tiết →

Cần tư vấn? Liên hệ ngay Vexim Global: 0373 685 634

`.trim() } // Unsubscribe Confirmation Email export function getUnsubscribeEmailHTML(params: EmailTemplateParams): string { return ` Đã hủy đăng ký

✅ Đã hủy đăng ký thành công

Bạn sẽ không còn nhận được cảnh báo FDA từ Vexim Global nữa.

Nếu bạn muốn đăng ký lại, bạn có thể quay lại bất cứ lúc nào.

Đăng ký lại

Cảm ơn bạn đã tin tưởng Vexim Global!

`.trim() } [V0_FILE]typescript:file="lib/fda-ai.ts" isMerged="true" import { generateText } from "ai" import type { FDAItem } from "@/types/fda" import { createServerClient } from "@/lib/supabase-server" export class FDAAIService { // C-4: Tạo summary tiếng Việt cho FDA item với cache async generateVietnameseSummary(item: FDAItem, cacheKey?: string): Promise { try { // Check cache first if cacheKey provided if (cacheKey) { const cached = await this.getCachedSummary(cacheKey, item.id) if (cached) { console.log(`[v0] AI summary cache HIT for item: ${item.id}`) return cached } console.log(`[v0] AI summary cache MISS for item: ${item.id}`) } console.log(`[v0] Generating Vietnamese summary for: ${item.title.substring(0, 50)}...`) // Prompt tùy theo category const prompt = this.buildPrompt(item) const { text } = await generateText({ model: "groq/llama-3.3-70b-versatile", prompt, maxTokens: 200, }) const summary = text.trim() console.log(`[v0] Generated summary: ${summary.substring(0, 100)}...`) // Save to cache if cacheKey provided if (cacheKey) { await this.saveSummaryToCache(cacheKey, item.id, summary) } return summary } catch (error) { console.error("[v0] Error generating Vietnamese summary:", error) return `${item.title} - ${item.criticalInfo}` } } // Get cached AI summary from database private async getCachedSummary(cacheKey: string, itemId: string): Promise { try { const supabase = await createServerClient() const { data, error } = await supabase .from("fda_alerts_cache") .select("ai_summaries") .eq("cache_key", cacheKey) .gt("expires_at", new Date().toISOString()) .single() if (error || !data || !data.ai_summaries) { return null } const summaries = data.ai_summaries as Record return summaries[itemId] || null } catch (error) { console.error("[v0] Error getting cached summary:", error) return null } } // Save AI summary to cache private async saveSummaryToCache(cacheKey: string, itemId: string, summary: string): Promise { try { const supabase = await createServerClient() // Get existing cache entry const { data: existing } = await supabase .from("fda_alerts_cache") .select("ai_summaries") .eq("cache_key", cacheKey) .single() const existingSummaries = (existing?.ai_summaries as Record) || {} const updatedSummaries = { ...existingSummaries, [itemId]: summary, } // Update cache with new summary await supabase .from("fda_alerts_cache") .update({ ai_summaries: updatedSummaries, }) .eq("cache_key", cacheKey) console.log(`[v0] Saved AI summary to cache for item: ${itemId}`) } catch (error) { console.error("[v0] Error saving summary to cache:", error) } } private buildPrompt(item: FDAItem): string { const baseInfo = ` Sản phẩm: ${item.title} Thông tin quan trọng: ${item.criticalInfo} Ngày: ${item.date} Trạng thái: ${item.status} ${item.classification ? `Phân loại: ${item.classification}` : ""} ${item.manufacturer ? `Nhà sản xuất: ${item.manufacturer}` : ""} `.trim() // Prompt khác nhau theo category switch (item.category) { case "food": return ` Bạn là chuyên gia an toàn thực phẩm. Tóm tắt cảnh báo thu hồi thực phẩm sau đây bằng tiếng Việt (tối đa 2-3 câu). Tập trung vào: Sản phẩm gì, tại sao bị thu hồi, nguy cơ sức khỏe. ${baseInfo} CHỈ xuất ra tiếng Việt, không giải thích thêm:` case "cosmetic": return ` Bạn là chuyên gia mỹ phẩm. Tóm tắt biến cố có hại từ mỹ phẩm sau đây bằng tiếng Việt (tối đa 2-3 câu). Tập trung vào: Sản phẩm gì, phản ứng phụ nào, mức độ nghiêm trọng. ${baseInfo} CHỈ xuất ra tiếng Việt, không giải thích thêm:` case "drug": return ` Bạn là dược sĩ. Tóm tắt thông tin về thuốc sau đây bằng tiếng Việt (tối đa 2-3 câu). Tập trung vào: Tên thuốc, vấn đề gì, ảnh hưởng đến người dùng. ${baseInfo} CHỈ xuất ra tiếng Việt, không giải thích thêm:` default: return ` Tóm tắt cảnh báo FDA sau đây bằng tiếng Việt (tối đa 2-3 câu). Nói rõ vấn đề và rủi ro. ${baseInfo} CHỈ xuất ra tiếng Việt, không giải thích thêm:` } } // Batch processing cho nhiều items async generateSummariesBatch(items: FDAItem[]): Promise { console.log(`[v0] Generating summaries for ${items.length} items...`) const summaryPromises = items.map(async (item) => { const summary = await this.generateVietnameseSummary(item) return { ...item, aiSummary: summary, } }) const itemsWithSummaries = await Promise.all(summaryPromises) console.log(`[v0] Completed ${itemsWithSummaries.length} summaries`) return itemsWithSummaries } } // Singleton instance export const fdaAI = new FDAAIService() [V0_FILE]typescript:file="lib/fda-api.ts" isMerged="true" import type { FDAApiResponse, FDACategory, FDAEndpoint, FDAEnforcementResult, FDAEventResult, FDAFilters, FDAItem, FDAShortageResult, } from "@/types/fda" const FDA_BASE_URL = "https://api.fda.gov" export class FDAApiService { // Build query string cho FDA API private buildSearchQuery(filters: Partial): string { const queries: string[] = [] // Date range filter if (filters.dateFrom && filters.dateTo) { queries.push(`report_date:[${filters.dateFrom} TO ${filters.dateTo}]`) } // Classification filter (cho enforcement) if (filters.classification) { queries.push(`classification:"${filters.classification}"`) } // Status filter if (filters.status) { queries.push(`status:"${filters.status}"`) } // Search term (full text search) if (filters.searchTerm) { queries.push(`${filters.searchTerm}`) } return queries.length > 0 ? queries.join("+AND+") : "" } // Tạo URL endpoint đầy đủ private buildEndpointUrl(category: FDACategory, endpoint: FDAEndpoint, filters: Partial, limit = 10) { let url = `${FDA_BASE_URL}/${category}/${endpoint}.json` const params = new URLSearchParams() params.append("limit", limit.toString()) params.append("sort", "report_date:desc") const searchQuery = this.buildSearchQuery(filters) if (searchQuery) { params.append("search", searchQuery) } // Thêm filter mặc định cho từng loại if (endpoint === "enforcement") { // Ưu tiên các recall nationwide if (!searchQuery) { params.set("search", 'distribution_pattern:"nationwide"') } } if (endpoint === "shortages") { // Chỉ lấy các shortage đang active if (!searchQuery) { params.set("search", 'current_status:"Currently in Shortage"') } } return `${url}?${params.toString()}` } // Fetch data từ FDA API with retry mechanism async fetchFDAData(category: FDACategory, endpoint: FDAEndpoint, filters: Partial = {}, limit = 10, retryCount = 0): Promise { const MAX_RETRIES = 3 const RETRY_DELAY_MS = 1000 try { const url = this.buildEndpointUrl(category, endpoint, filters, limit) console.log(`[v0] Fetching FDA data from: ${url} (attempt ${retryCount + 1}/${MAX_RETRIES + 1})`) const response = await fetch(url, { headers: { "User-Agent": "VeximGlobal/1.0", }, cache: "default", }) if (!response.ok) { if (response.status === 429 && retryCount < MAX_RETRIES) { // Rate limited - retry with exponential backoff const delay = RETRY_DELAY_MS * Math.pow(2, retryCount) console.log(`[v0] FDA API rate limited (429). Retrying in ${delay}ms...`) await new Promise(resolve => setTimeout(resolve, delay)) return this.fetchFDAData(category, endpoint, filters, limit, retryCount + 1) } console.error(`[v0] FDA API error: ${response.status} ${response.statusText}`) return null } const data: FDAApiResponse = await response.json() console.log(`[v0] FDA API returned ${data.results.length} results (Total: ${data.meta.results.total})`) return data } catch (error) { if (retryCount < MAX_RETRIES) { const delay = RETRY_DELAY_MS * Math.pow(2, retryCount) console.log(`[v0] Error fetching FDA data. Retrying in ${delay}ms... (${error})`) await new Promise(resolve => setTimeout(resolve, delay)) return this.fetchFDAData(category, endpoint, filters, limit, retryCount + 1) } console.error("[v0] Error fetching FDA data after all retries:", error) return null } } // Normalize dữ liệu từ các endpoint khác nhau normalizeEnforcementData(result: FDAEnforcementResult, category: FDACategory): FDAItem { return { id: result.recall_number || `enforcement-${Date.now()}`, title: result.product_description?.substring(0, 100) || "Unknown Product", category, criticalInfo: result.reason_for_recall || "No reason provided", date: result.report_date || new Date().toISOString().split("T")[0], status: result.status || "Unknown", classification: result.classification, distributionPattern: result.distribution_pattern, recallNumber: result.recall_number, productDescription: result.product_description, reasonForRecall: result.reason_for_recall, manufacturer: result.recalling_firm, rawData: result, } } normalizeEventData(result: FDAEventResult, category: FDACategory): FDAItem { return { id: `event-${Date.now()}-${Math.random()}`, title: result.product_name || "Unknown Product", category, criticalInfo: result.outcomes?.join(", ") || result.adverse_event_flag || "Adverse event reported", date: result.date_received || new Date().toISOString().split("T")[0], status: result.adverse_event_flag || "Reported", manufacturer: result.manufacturer_name, productDescription: `${result.product_type || ""} - ${result.product_name || ""}`, rawData: result, } } normalizeShortageData(result: FDAShortageResult, category: FDACategory): FDAItem { return { id: `shortage-${Date.now()}-${Math.random()}`, title: result.brand_name || result.generic_name || "Unknown Drug", category, criticalInfo: result.shortage_reason || "Shortage reported", date: result.estimated_resolution_date || new Date().toISOString().split("T")[0], status: result.current_status || "In Shortage", manufacturer: result.manufacturer, productDescription: `${result.generic_name || ""} (${result.brand_name || ""})`, rawData: result, } } // Main normalization method normalizeData(results: any[], category: FDACategory, endpoint: FDAEndpoint): FDAItem[] { return results.map((result) => { switch (endpoint) { case "enforcement": return this.normalizeEnforcementData(result, category) case "event": return this.normalizeEventData(result, category) case "shortages": return this.normalizeShortageData(result, category) default: // Fallback generic normalization return { id: `${endpoint}-${Date.now()}-${Math.random()}`, title: result.product_name || result.product_description || "Unknown", category, criticalInfo: JSON.stringify(result).substring(0, 200), date: result.report_date || result.date_received || new Date().toISOString().split("T")[0], status: result.status || "Unknown", rawData: result, } } }) } // Tổng hợp: Fetch → Normalize (caching handled in API route layer) async getFDAItems( category: FDACategory, endpoint: FDAEndpoint, filters: Partial = {}, limit = 10, ): Promise<{ items: FDAItem[]; total: number } | null> { const response = await this.fetchFDAData(category, endpoint, filters, limit) if (!response) { return null } const items = this.normalizeData(response.results, category, endpoint) const total = response.meta.results.total return { items, total, } } } // Singleton instance export const fdaApi = new FDAApiService() [V0_FILE]typescriptreact:file="lib/news-crawler-db.tsx" isMerged="true" import { getSupabaseServerClient } from "./supabase-server" import { generateText } from "ai" import { openai } from "@ai-sdk/openai" interface CrawlConfig { source: "FDA" | "GACC" url: string selectors: { container: string title: string link: string date?: string content?: string } } interface FilterKeywords { layer1_must: string[] layer2_should: string[] layer3_exclude: string[] } const FILTER_KEYWORDS: FilterKeywords = { layer1_must: [ "thực phẩm", "food", "xuất khẩu", "export", "nhập khẩu", "import", "chứng nhận", "certification", "giấy phép", "license", "FDA", "GACC", "MFDS", "an toàn thực phẩm", "food safety", "quy định", "regulation", "tiêu chuẩn", "standard", "kiểm tra", "inspection", "hải quan", "customs", ], layer2_should: [ "nông sản", "agricultural", "thủy sản", "seafood", "chế biến", "processed", "đóng gói", "packaging", "nhãn mác", "labeling", "Process Filing", "US Agent", "Prior Notice", "FSVP", "进口", "出口", "食品", "农产品", "水产品", "认证", "检验检疫", "备案", ], layer3_exclude: [ "dược phẩm", "pharmaceutical", "thiết bị y tế", "medical device", "mỹ phẩm không liên quan thực phẩm", "cosmetics unrelated to food", "thú y không liên quan xuất nhập", "veterinary unrelated to export", "药品", "医疗器械", "化妆品", ], } const CRAWL_CONFIGS: CrawlConfig[] = [ { source: "FDA", url: "https://www.fda.gov/news-events/fda-newsroom/press-announcements", selectors: { container: ".views-row", title: ".views-field-title a", link: ".views-field-title a", date: ".views-field-field-release-date", }, }, { source: "GACC", url: "http://www.customs.gov.cn/customs/302249/2480148/index.html", selectors: { container: ".news-list li", title: "a", link: "a", date: ".date", }, }, ] export async function crawlNews(source: "FDA" | "GACC") { const supabase = await getSupabaseServerClient() // Create crawl log const { data: logData, error: logError } = await supabase .from("crawl_logs") .insert({ source, status: "running", }) .select() .single() if (logError) { console.error("[v0] Error creating crawl log:", logError) throw new Error("Failed to create crawl log") } const logId = logData.id try { const config = CRAWL_CONFIGS.find((c) => c.source === source) if (!config) { throw new Error(`No config found for source: ${source}`) } let response let lastError // Try multiple strategies for GACC const strategies = source === "GACC" ? [ // Strategy 1: Full browser simulation { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36", Accept: "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8", "Accept-Language": "zh-CN,zh;q=0.9,en-US;q=0.8,en;q=0.7", "Accept-Encoding": "gzip, deflate", Connection: "keep-alive", "Upgrade-Insecure-Requests": "1", "Cache-Control": "max-age=0", Referer: "http://www.customs.gov.cn/", Host: "www.customs.gov.cn", }, }, // Strategy 2: Simplified headers { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36", Accept: "text/html", "Accept-Language": "zh-CN", }, }, // Strategy 3: Minimal headers { headers: { "User-Agent": "Mozilla/5.0", }, }, ] : [ // FDA - simple strategy { headers: { "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36", }, }, ] for (let i = 0; i < strategies.length; i++) { try { console.log(`[v0] Trying ${source} crawl strategy ${i + 1}/${strategies.length}...`) response = await fetch(config.url, { ...strategies[i], redirect: "follow", }) if (response.ok) { console.log(`[v0] ${source} crawl successful with strategy ${i + 1}`) break } else { lastError = `Strategy ${i + 1} failed: ${response.status} ${response.statusText}` console.log(`[v0] ${lastError}`) } } catch (error: any) { lastError = `Strategy ${i + 1} error: ${error.message}` console.log(`[v0] ${lastError}`) } // Wait between retries if (i < strategies.length - 1) { await new Promise((resolve) => setTimeout(resolve, 2000)) } } if (!response || !response.ok) { throw new Error(`Failed to fetch ${source}: ${lastError}`) } const html = await response.text() console.log(`[v0] Fetched ${html.length} bytes from ${source}`) // Parse listing page to get article links const articles = await parseHTML(html, config) console.log(`[v0] Found ${articles.length} article links from ${source}`) let articlesFiltered = 0 for (const article of articles) { // Check if article already exists const { data: existing } = await supabase.from("news_articles").select("id").eq("url", article.url).single() if (existing) { console.log(`[v0] Article already exists: ${article.title}`) continue } // Fetch full article content const fullArticle = await fetchArticleDetail(article, source) // Add delay to avoid rate limiting await new Promise((resolve) => setTimeout(resolve, 1000)) // Apply AI filtering with full content const filterResult = await filterArticleWithAI(fullArticle) if (filterResult.isRelevant) { // Insert article into database const { error: insertError } = await supabase.from("news_articles").insert({ source, title: fullArticle.title, url: fullArticle.url, published_date: fullArticle.publishedDate, content: fullArticle.content, summary: filterResult.summary, category: filterResult.category, relevance_score: filterResult.relevanceScore, filter_layer: filterResult.filterLayer, keywords: filterResult.keywords, status: "pending", raw_html: fullArticle.rawHtml, }) if (insertError) { console.error("[v0] Error inserting article:", insertError) } else { articlesFiltered++ console.log(`[v0] Added article: ${fullArticle.title} (${fullArticle.publishedDate})`) } } else { console.log(`[v0] Article filtered out: ${fullArticle.title} (Score: ${filterResult.relevanceScore})`) } } // Update crawl log await supabase .from("crawl_logs") .update({ completed_at: new Date().toISOString(), status: "completed", articles_found: articles.length, articles_filtered: articlesFiltered, }) .eq("id", logId) return { success: true, articlesFound: articles.length, articlesFiltered, } } catch (error: any) { // Update crawl log with error await supabase .from("crawl_logs") .update({ completed_at: new Date().toISOString(), status: "failed", error_message: error.message, }) .eq("id", logId) throw error } } async function parseHTML(html: string, config: CrawlConfig) { const articles: any[] = [] try { if (config.source === "FDA") { // FDA structure:

Title

Date

const rowRegex = /]*class="[^"]*views-row[^"]*"[^>]*>([\s\S]*?)<\/div>/gi let rowMatch while ((rowMatch = rowRegex.exec(html)) !== null && articles.length < 20) { const rowHtml = rowMatch[1] // Extract link and title const linkMatch = /]*href=["']([^"']+)["'][^>]*>([^<]+)<\/a>/i.exec(rowHtml) if (!linkMatch) continue let url = linkMatch[1] const title = linkMatch[2].trim() // Make URL absolute if (url.startsWith("/")) { url = "https://www.fda.gov" + url } // Extract date const dateMatch = /]*datetime=["']([^"']+)["'][^>]*>/i.exec(rowHtml) || /]*class="[^"]*views-field-field-release-date[^"]*"[^>]*>([^<]+)<\/div>/i.exec(rowHtml) const publishedDate = dateMatch ? dateMatch[1].trim() : null articles.push({ title, url, publishedDate: publishedDate || new Date().toISOString(), needsDetailFetch: true, }) } } else if (config.source === "GACC") { // GACC structure:

2024-01-15Title

Khách hàng: ${payload.customerName}

Tin nhắn: ${payload.message}

${payload.serviceTag ? `

Dịch vụ: ${payload.serviceTag}

` : ""} ${payload.reason ? `

Lý do chuyển: ${payload.reason}

` : ""}

${payload.urgency === "high" ? "Khẩn cấp" : payload.urgency === "medium" ? "Trung bình" : "Thấp"}

Xem Cuộc Hội Thoại

` // Send email using Resend (you need to add RESEND_API_KEY to env) if (process.env.RESEND_API_KEY) { const response = await fetch("https://api.resend.com/emails", { method: "POST", headers: { "Content-Type": "application/json", Authorization: `Bearer ${process.env.RESEND_API_KEY}`, }, body: JSON.stringify({ from: "Vexim Chat ", to: adminEmails, subject: `🔔 Khách hàng mới: ${payload.customerName}`, html: emailBody, }), }) if (!response.ok) { throw new Error(`Email send failed: ${response.statusText}`) } console.log("[v0] Email notification sent to:", adminEmails) } else { console.log("[v0] RESEND_API_KEY not configured, skipping email notification") } } catch (error) { console.error("[v0] Error sending email notification:", error) } } /** * Notify admin about new handover conversation */ export async function notifyAdminNewHandover(payload: NotificationPayload) { // Send both push and email notifications await Promise.all([ sendPushNotification(payload), sendEmailNotification(payload), ]) } [V0_FILE]typescript:file="lib/password.ts" isMerged="true" import { scryptSync, randomBytes, timingSafeEqual } from "crypto" /** * Hash a password using scrypt (Node.js native crypto) * @param password Plain text password * @returns Hashed password in format: salt.hash */ export async function hashPassword(password: string): Promise { const salt = randomBytes(16).toString("hex") const hash = scryptSync(password, salt, 64).toString("hex") return `${salt}.${hash}` } /** * Verify a password against a hash * @param password Plain text password * @param hashedPassword Hashed password in format: salt.hash * @returns True if password matches */ export async function verifyPassword(password: string, hashedPassword: string): Promise { const [salt, storedHash] = hashedPassword.split(".") const hash = scryptSync(password, salt, 64) const storedHashBuffer = Buffer.from(storedHash, "hex") return timingSafeEqual(hash, storedHashBuffer) } /** * Generate a random password * @param length Password length (default: 12) * @returns Random password string */ export function generateRandomPassword(length: number = 12): string { const charset = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789!@#$%^&*" let password = "" const randomValues = new Uint8Array(length) crypto.getRandomValues(randomValues) for (let i = 0; i < length; i++) { password += charset[randomValues[i] % charset.length] } return password } [V0_FILE]typescript:file="lib/rule-engine.ts" isMerged="true" // Rule Engine for Vexim Global Chatbot // Decides: AI continues, Ask contact, or Handoff to admin export type RuleAction = "AI_CONTINUE" | "ASK_CONTACT" | "HANDOFF_TO_ADMIN" export interface RuleResult { action: RuleAction reason: string ruleId: string tags: { service_tag?: "FDA" | "GACC" | "MFDS" | "FSMA204" | "US_AGENT" | "EXPORT" | "TRACEABILITY" reason: "compliance" | "sales" | "data" | "quality" urgency: "low" | "medium" | "high" } } export interface MessageContext { message: string conversationHistory?: string[] aiConfidence?: number hasFile?: boolean customerInfo?: { companyName?: string market?: string product?: string } } // 1. COMPLIANCE RISK RULES (CR) - Must handoff function checkComplianceRisk(message: string): RuleResult | null { const lowerMsg = message.toLowerCase() // CR-01: Specific case questions const specificCasePatterns = [ /sản phẩm (này|của tôi|của chúng tôi).*(có cần|phải|đăng ký)/i, /hàng (này|của tôi).*(cần|phải làm)/i, /(của tôi|của em|của anh).*(có được|có thể|cần)/i, ] if (specificCasePatterns.some((p) => p.test(message))) { return { action: "HANDOFF_TO_ADMIN", reason: "Specific product/case requires expert review", ruleId: "CR-01", tags: { reason: "compliance", urgency: "high" }, } } // CR-02: Result guarantee requests const guaranteePatterns = [ /có chắc.*được duyệt/i, /đảm bảo.*pass/i, /chắc chắn.*thành công/i, /(cam kết|bảo đảm).*(kết quả|được)/i, ] if (guaranteePatterns.some((p) => p.test(message))) { return { action: "HANDOFF_TO_ADMIN", reason: "Cannot guarantee regulatory outcomes", ruleId: "CR-02", tags: { reason: "compliance", urgency: "high" }, } } // CR-03: Previous violations/rejections const violationPatterns = [ /bị (từ chối|reject|cảnh báo|warning)/i, /(từng|đã) bị.*FDA/i, /vi phạm/i, /không đạt.*yêu cầu/i, ] if (violationPatterns.some((p) => p.test(message))) { return { action: "HANDOFF_TO_ADMIN", reason: "Previous compliance issues need expert handling", ruleId: "CR-03", tags: { reason: "compliance", urgency: "high" }, } } // CR-04: Specific legal interpretation const legalPatterns = [ /điều khoản.*nào/i, /quy định.*cụ thể/i, /luật.*nói/i, /(regulation|CFR).*\d+/i, ] if (legalPatterns.some((p) => p.test(message))) { return { action: "HANDOFF_TO_ADMIN", reason: "Legal interpretation requires expertise", ruleId: "CR-04", tags: { reason: "compliance", urgency: "medium" }, } } // CR-05: Pricing/Quote requests const pricingPatterns = [ /(phí|chi phí|giá|báo giá).*(bao nhiêu|là gì)/i, /tốn.*bao nhiêu/i, /(quote|pricing|cost)/i, ] if (pricingPatterns.some((p) => p.test(message))) { return { action: "HANDOFF_TO_ADMIN", reason: "Pricing requires custom quote", ruleId: "CR-05", tags: { reason: "sales", urgency: "medium" }, } } return null } // 2. SALES INTENT RULES (SI) - Should ask contact or handoff function checkSalesIntent(message: string): RuleResult | null { const lowerMsg = message.toLowerCase() // SI-01: Direct "do you do this" questions - HIGH SALES INTENT const directDoQuestions = [ /(bạn|bên|công ty).*(có làm|làm được|làm)/i, /ý.*là.*(có làm|làm được|làm không)/i, /(em|anh|mình|các bạn).*(làm.*không|có làm)/i, ] if (directDoQuestions.some((p) => p.test(message))) { return { action: "HANDOFF_TO_ADMIN", reason: "Direct service capability question - very high sales intent", ruleId: "SI-01-HIGH", tags: { reason: "sales", urgency: "high" }, } } // SI-02: "Connect me" / "I want to start" - IMMEDIATE HANDOFF const immediateHandoffPatterns = [ /(kết nối|liên hệ|gọi).*(cho|giúp|tôi|mình|em|anh)/i, /(có|được|đồng ý|ok|oke|okê).*(em|anh|nhé|ạ)$/i, /^(có|được|ok|oke|okê|đồng ý|đc)$/i, /muốn (làm|thuê|nhờ).*ngay/i, ] if (immediateHandoffPatterns.some((p) => p.test(message))) { return { action: "HANDOFF_TO_ADMIN", reason: "Customer ready to engage - immediate handoff required", ruleId: "SI-02-IMMEDIATE", tags: { reason: "sales", urgency: "high" }, } } // SI-03: Service inquiry const servicePatterns = [ /(bên|công ty).*(em|anh).*(cung cấp|hỗ trợ)/i, /dịch vụ.*(gì|nào)/i, /(các|những) dịch vụ/i, ] if (servicePatterns.some((p) => p.test(message))) { return { action: "ASK_CONTACT", reason: "Service inquiry", ruleId: "SI-03", tags: { reason: "sales", urgency: "medium" }, } } // SI-04: Want to proceed const proceedPatterns = [ /muốn (làm|triển khai|bắt đầu)/i, /cần (thuê|nhờ) luôn/i, /(start|proceed|begin)/i, ] if (proceedPatterns.some((p) => p.test(message))) { return { action: "ASK_CONTACT", reason: "Ready to proceed", ruleId: "SI-04", tags: { reason: "sales", urgency: "high" }, } } // SI-05: Timeline questions const timelinePatterns = [ /bao lâu.*(xong|hoàn thành|được)/i, /mất.*bao nhiêu thời gian/i, /(timeline|duration|how long)/i, ] if (timelinePatterns.some((p) => p.test(message))) { return { action: "ASK_CONTACT", reason: "Timeline inquiry", ruleId: "SI-05", tags: { reason: "sales", urgency: "medium" }, } } // SI-06: Comparison questions const comparisonPatterns = [ /(bên|công ty).*(em|anh).*khác gì/i, /so với.*đơn vị khác/i, /ưu điểm.*gì/i, ] if (comparisonPatterns.some((p) => p.test(message))) { return { action: "ASK_CONTACT", reason: "Comparison inquiry", ruleId: "SI-06", tags: { reason: "sales", urgency: "low" }, } } return null } // 3. LEAD QUALITY RULES (LQ) - High priority contact function checkLeadQuality(message: string, context: MessageContext): RuleResult | null { const lowerMsg = message.toLowerCase() // LQ-01: Provides company name if (context.customerInfo?.companyName || /công ty.*(tôi|chúng tôi|em|anh) (là|tên)/i.test(message)) { return { action: "ASK_CONTACT", reason: "Company identified - high quality lead", ruleId: "LQ-01", tags: { reason: "quality", urgency: "high" }, } } // LQ-02: Mentions market const marketPatterns = [ /xuất (khẩu|đi).*(mỹ|trung quốc|hàn quốc|usa|china|korea)/i, /thị trường.*(mỹ|trung|hàn)/i, ] if (context.customerInfo?.market || marketPatterns.some((p) => p.test(message))) { return { action: "ASK_CONTACT", reason: "Target market identified", ruleId: "LQ-02", tags: { reason: "quality", urgency: "high" }, } } // LQ-03: Describes product const productPatterns = [ /(sản phẩm|hàng hóa).*(của|là)/i, /(bên|công ty).*(em|tôi|anh).*(làm|sản xuất|kinh doanh)/i, ] if (context.customerInfo?.product || productPatterns.some((p) => p.test(message))) { return { action: "ASK_CONTACT", reason: "Product category identified", ruleId: "LQ-03", tags: { reason: "quality", urgency: "medium" }, } } // LQ-04: File upload if (context.hasFile) { return { action: "HANDOFF_TO_ADMIN", reason: "Document uploaded - needs expert review", ruleId: "LQ-04", tags: { reason: "data", urgency: "high" }, } } return null } // 4. AI CONFIDENCE RULES (AI) - Safety checks function checkAIConfidence(context: MessageContext): RuleResult | null { // AI-01: Low confidence if (context.aiConfidence !== undefined && context.aiConfidence < 0.5) { return { action: "HANDOFF_TO_ADMIN", reason: "AI confidence too low", ruleId: "AI-01", tags: { reason: "data", urgency: "medium" }, } } // AI-02: Medium-low confidence if (context.aiConfidence !== undefined && context.aiConfidence < 0.7) { return { action: "ASK_CONTACT", reason: "AI not fully confident", ruleId: "AI-02", tags: { reason: "data", urgency: "low" }, } } return null } // Detect service tag from message function detectServiceTag(message: string): RuleResult["tags"]["service_tag"] | undefined { const lowerMsg = message.toLowerCase() if (/fda|food.*drug|mỹ|hoa kỳ|usa|us agent/i.test(lowerMsg)) return "FDA" if (/gacc|trung quốc|china|đăng ký|giấy chứng nhận/i.test(lowerMsg)) return "GACC" if (/mfds|hàn quốc|korea/i.test(lowerMsg)) return "MFDS" if (/fsma.*204|truy xuất nguồn gốc|traceability/i.test(lowerMsg)) return "FSMA204" if (/us agent|đại diện.*mỹ/i.test(lowerMsg)) return "US_AGENT" if (/xuất khẩu|export/i.test(lowerMsg)) return "EXPORT" if (/truy xuất|theo dõi/i.test(lowerMsg)) return "TRACEABILITY" return undefined } // Main rule engine export function evaluateRules(context: MessageContext): RuleResult { const { message } = context // Priority 1: Compliance Risk (MUST handoff) const complianceResult = checkComplianceRisk(message) if (complianceResult) { complianceResult.tags.service_tag = detectServiceTag(message) return complianceResult } // Priority 2: File upload (MUST handoff) if (context.hasFile) { return { action: "HANDOFF_TO_ADMIN", reason: "File uploaded - needs expert review", ruleId: "LQ-04", tags: { service_tag: detectServiceTag(message), reason: "data", urgency: "high", }, } } // Priority 3: Sales Intent & Lead Quality (should ask contact) const salesResult = checkSalesIntent(message) if (salesResult) { salesResult.tags.service_tag = detectServiceTag(message) return salesResult } const leadResult = checkLeadQuality(message, context) if (leadResult) { leadResult.tags.service_tag = detectServiceTag(message) return leadResult } // Priority 4: AI Confidence (safety) const confidenceResult = checkAIConfidence(context) if (confidenceResult) { confidenceResult.tags.service_tag = detectServiceTag(message) return confidenceResult } // Default: Continue with AI return { action: "AI_CONTINUE", reason: "Standard information request", ruleId: "DEFAULT", tags: { service_tag: detectServiceTag(message), reason: "data", urgency: "low", }, } } // Get appropriate response message for ASK_CONTACT action export function getContactRequestMessage(ruleId?: string): string { // High urgency - more direct if (ruleId?.includes("HIGH") || ruleId?.includes("IMMEDIATE")) { return `Dạ, Vexim có hỗ trợ dịch vụ này ạ! Để tư vấn cụ thể cho trường hợp của anh/chị, em xin phép kết nối với chuyên viên. Anh/chì để lại số điện thoại, chuyên viên sẽ liên hệ tư vấn chi tiết ngay ạ.` } // Standard contact request return `Trường hợp này em cần chuyên viên của Vexim kiểm tra kỹ hơn để tư vấn chính xác cho anh/chị. Nếu anh/chị tiện, mình có thể để lại số điện thoại, em sẽ nhờ chuyên viên liên hệ hỗ trợ trực tiếp ạ.` } [V0_FILE]typescript:file="lib/supabase/client.ts" isMerged="true" import { createBrowserClient } from "@supabase/ssr" export function createClient() { return createBrowserClient(process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY!) } [V0_FILE]typescript:file="lib/supabase/server.ts" isMerged="true" import { createServerClient } from "@supabase/ssr" import { cookies } from "next/headers" import { createClient as createSupabaseClient } from "@supabase/supabase-js" /** * Tạo Supabase client cho server-side * QUAN TRỌNG: Luôn tạo client mới trong mỗi function (đặc biệt với Fluid compute) */ export async function createClient() { const cookieStore = await cookies() return createServerClient(process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY!, { cookies: { getAll() { return cookieStore.getAll() }, setAll(cookiesToSet) { try { cookiesToSet.forEach(({ name, value, options }) => cookieStore.set(name, value, options)) } catch { // setAll được gọi từ Server Component // Có thể bỏ qua nếu bạn có proxy refreshing sessions } }, }, }) } /** * Tạo Supabase client đơn giản cho build time / static generation * Không sử dụng cookies - chỉ dùng cho read-only operations */ export function createStaticClient() { const supabaseUrl = process.env.NEXT_PUBLIC_SUPABASE_URL const supabaseAnonKey = process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY if (!supabaseUrl || !supabaseAnonKey) { console.warn("[v0] Supabase environment variables not found. Skipping static generation.") return null } return createSupabaseClient(supabaseUrl, supabaseAnonKey) } [V0_FILE]typescript:file="lib/supabase-admin.ts" isMerged="true" import { createClient } from "@supabase/supabase-js" /** * Supabase Admin Client with Service Role Key * This bypasses Row Level Security (RLS) and should only be used in secure server contexts * Used for admin operations like creating clients, managing registrations, etc. */ export function createAdminClient() { const supabaseUrl = process.env.NEXT_PUBLIC_SUPABASE_URL const supabaseServiceKey = process.env.SUPABASE_SERVICE_ROLE_KEY if (!supabaseUrl || !supabaseServiceKey) { throw new Error("Missing Supabase URL or Service Role Key") } return createClient(supabaseUrl, supabaseServiceKey, { auth: { autoRefreshToken: false, persistSession: false, }, }) } [V0_FILE]typescript:file="lib/supabase-client.ts" isMerged="true" import { createBrowserClient } from "@supabase/ssr" let supabaseClient: ReturnType | null = null export function getSupabaseBrowserClient() { if (supabaseClient) { return supabaseClient } supabaseClient = createBrowserClient( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY!, ) return supabaseClient } // Export with multiple names for compatibility export const createClient = getSupabaseBrowserClient [V0_FILE]typescript:file="lib/supabase-server.ts" isMerged="true" import { createServerClient as createSupabaseServerClient } from "@supabase/ssr" import { cookies } from "next/headers" export async function getSupabaseServerClient() { const cookieStore = await cookies() return createSupabaseServerClient( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY!, { cookies: { getAll() { return cookieStore.getAll() }, setAll(cookiesToSet) { try { cookiesToSet.forEach(({ name, value, options }) => cookieStore.set(name, value, options)) } catch { // The `setAll` method was called from a Server Component. // This can be ignored if you have middleware refreshing // user sessions. } }, }, }, ) } // Export with multiple names for compatibility export const createClient = getSupabaseServerClient export const createServerClient = getSupabaseServerClient [V0_FILE]typescript:file="lib/utils.ts" isMerged="true" import { clsx, type ClassValue } from 'clsx' import { twMerge } from 'tailwind-merge' export function cn(...inputs: ClassValue[]) { return twMerge(clsx(inputs)) } [V0_FILE]sql:file="scripts/001_create_posts_table.sql" isMerged="true" -- Tạo bảng posts cho CMS Vexim Global -- Bảng này lưu trữ tất cả bài viết blog về dịch vụ xuất nhập khẩu CREATE TABLE IF NOT EXISTS public.posts ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), title TEXT NOT NULL, slug TEXT NOT NULL UNIQUE, excerpt TEXT, content TEXT NOT NULL, category TEXT NOT NULL, featured_image TEXT, meta_title TEXT, meta_description TEXT, status TEXT NOT NULL DEFAULT 'draft' CHECK (status IN ('draft', 'published')), published_at TIMESTAMPTZ, created_at TIMESTAMPTZ DEFAULT NOW(), updated_at TIMESTAMPTZ DEFAULT NOW(), -- WordPress migration fields wordpress_id INTEGER UNIQUE, wordpress_url TEXT ); -- Tạo index cho hiệu suất truy vấn CREATE INDEX IF NOT EXISTS idx_posts_slug ON public.posts(slug); CREATE INDEX IF NOT EXISTS idx_posts_category ON public.posts(category); CREATE INDEX IF NOT EXISTS idx_posts_status ON public.posts(status); CREATE INDEX IF NOT EXISTS idx_posts_published_at ON public.posts(published_at DESC); -- Tự động cập nhật updated_at CREATE OR REPLACE FUNCTION public.handle_updated_at() RETURNS TRIGGER AS $$ BEGIN NEW.updated_at = NOW(); RETURN NEW; END; $$ LANGUAGE plpgsql; CREATE TRIGGER set_updated_at BEFORE UPDATE ON public.posts FOR EACH ROW EXECUTE FUNCTION public.handle_updated_at(); -- Enable Row Level Security ALTER TABLE public.posts ENABLE ROW LEVEL SECURITY; -- Policy: Ai cũng có thể đọc bài viết đã xuất bản (public access) CREATE POLICY "posts_select_published" ON public.posts FOR SELECT USING (status = 'published'); -- Policy: Cho phép đọc tất cả bài viết (kể cả draft) để hiển thị trong admin -- Tạm thời cho phép không cần auth để demo CREATE POLICY "posts_select_all" ON public.posts FOR SELECT USING (true); -- Policy: Cho phép insert bài viết mới (tạm thời không cần auth) CREATE POLICY "posts_insert" ON public.posts FOR INSERT WITH CHECK (true); -- Policy: Cho phép update bài viết (tạm thời không cần auth) CREATE POLICY "posts_update" ON public.posts FOR UPDATE USING (true); -- Policy: Cho phép delete bài viết (tạm thời không cần auth) CREATE POLICY "posts_delete" ON public.posts FOR DELETE USING (true); -- Chèn dữ liệu mẫu INSERT INTO public.posts (title, slug, excerpt, content, category, featured_image, status, published_at, meta_title, meta_description) VALUES ('Hướng dẫn đăng ký FDA cho doanh nghiệp xuất khẩu thực phẩm', 'huong-dan-dang-ky-fda-cho-doanh-nghiep-xuat-khau-thuc-pham', 'Quy trình đăng ký FDA chi tiết giúp doanh nghiệp Việt Nam xuất khẩu thực phẩm sang Mỹ hợp pháp', '

Tại sao cần đăng ký FDA?

FDA (Food and Drug Administration) là cơ quan quản lý thực phẩm và dược phẩm của Hoa Kỳ. Bất kỳ cơ sở sản xuất, chế biến, đóng gói hoặc lưu trữ thực phẩm xuất khẩu vào Mỹ đều phải đăng ký với FDA.

Quy trình đăng ký FDA

Bước 1: Chuẩn bị hồ sơ doanh nghiệp...

', 'FDA', 'https://images.unsplash.com/photo-1587825140708-dfaf72ae4b04?w=800', 'published', NOW(), 'Hướng dẫn đăng ký FDA cho xuất khẩu thực phẩm | Vexim Global', 'Quy trình đăng ký FDA chi tiết, chính xác cho doanh nghiệp Việt Nam muốn xuất khẩu thực phẩm sang thị trường Mỹ'), -- Sửa INTERVAL syntax từ ''7 days'' thành '7 days' ('Mã GACC Trung Quốc: Chìa khóa xuất khẩu sang thị trường tỷ dân', 'ma-gacc-trung-quoc-chia-khoa-xuat-khau-sang-thi-truong-ty-dan', 'Tất cả những gì bạn cần biết về mã GACC để xuất khẩu hàng hóa sang Trung Quốc hợp pháp', '

Mã GACC là gì?

GACC (General Administration of Customs of China) là Tổng cục Hải quan Trung Quốc. Mã GACC là mã số đăng ký bắt buộc cho các cơ sở sản xuất, chế biến xuất khẩu thực phẩm vào Trung Quốc.

Sản phẩm nào cần mã GACC?

Thực phẩm tươi sống, thực phẩm chế biến, thực phẩm đóng gói...

', 'GACC', 'https://images.unsplash.com/photo-1578575437130-527eed3abbec?w=800', 'published', NOW() - INTERVAL '7 days', 'Mã GACC Trung Quốc: Hướng dẫn đăng ký xuất khẩu | Vexim', 'Hướng dẫn chi tiết cách đăng ký mã GACC để xuất khẩu thực phẩm sang Trung Quốc. Quy trình nhanh chóng, đảm bảo thành công'), -- Sửa INTERVAL syntax từ ''14 days'' thành '14 days' ('FSMA 204: Quy định truy xuất nguồn gốc thực phẩm mới nhất của FDA', 'fsma-204-quy-dinh-truy-xuat-nguon-goc-thuc-pham-moi-nhat-fda', 'Quy định FSMA 204 yêu cầu doanh nghiệp phải ghi chép và chia sẻ thông tin truy xuất nguồn gốc cho các loại thực phẩm có nguy cơ cao', '

FSMA 204 là gì?

FSMA 204 (Food Safety Modernization Act Section 204) là quy định truy xuất nguồn gốc thực phẩm của FDA, có hiệu lực từ ngày 20/01/2026.

Danh sách Food Traceability List (FTL)

Các loại thực phẩm bắt buộc phải truy xuất nguồn gốc bao gồm: phô mai mềm, trứng, salad xanh, dưa pepino, hải sản...

', 'Truy xuất nguồn gốc', 'https://images.unsplash.com/photo-1516321318423-f06f85e504b3?w=800', 'published', NOW() - INTERVAL '14 days', 'FSMA 204: Quy định truy xuất nguồn gốc FDA 2026 | Vexim Global', 'Giải thích chi tiết FSMA 204 - quy định truy xuất nguồn gốc thực phẩm mới nhất của FDA có hiệu lực từ 2026'); [V0_FILE]sql:file="scripts/002_create_admin_user.sql" isMerged="true" -- 1. XÓA BẢNG CŨ ĐỂ LÀM SẠCH RÀNG BUỘC GÂY LỖI (CASCADE) -- Việc này xóa bỏ các Foreign Key Constraint đang chặn việc chèn dữ liệu của bạn DROP TABLE IF EXISTS public.profiles CASCADE; DROP TABLE IF EXISTS public.users CASCADE; -- 2. TẠO LẠI BẢNG USERS (Không dùng khóa ngoại để tránh lỗi 23503 trong lúc fix) CREATE TABLE public.users ( id UUID PRIMARY KEY, -- Bỏ REFERENCES auth.users để cưỡng bức tạo được dữ liệu email TEXT, full_name TEXT, is_admin BOOLEAN DEFAULT false, role TEXT DEFAULT 'user', created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); -- 3. TẠO LẠI BẢNG PROFILES CREATE TABLE public.profiles ( id UUID PRIMARY KEY, full_name TEXT, role TEXT DEFAULT 'user', organization_id UUID, language TEXT DEFAULT 'vi', updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); -- 4. XỬ LÝ VIEW ADMIN_USERS (Sửa lỗi PGRST205 cho Code) DROP VIEW IF EXISTS public.admin_users CASCADE; CREATE VIEW public.admin_users AS SELECT * FROM public.users; -- 5. CẤP QUYỀN ADMIN TUYỆT ĐỐI CHO TÀI KHOẢN CỦA BẠN -- Chèn trực tiếp vào users INSERT INTO public.users (id, email, full_name, is_admin, role) VALUES ('c7316609-7d4e-4dc3-885a-f008bf69084a', 'hocluongvan88@gmail.com', 'Lương Văn Học', true, 'admin'); -- Chèn trực tiếp vào profiles (Vượt qua kiểm tra dòng 57 file page.tsx) INSERT INTO public.profiles (id, full_name, role) VALUES ('c7316609-7d4e-4dc3-885a-f008bf69084a', 'Lương Văn Học', 'admin'); -- 6. CẤP QUYỀN TRUY CẬP API GRANT USAGE ON SCHEMA public TO anon, authenticated; GRANT ALL ON ALL TABLES IN SCHEMA public TO anon, authenticated, service_role; GRANT SELECT ON public.admin_users TO anon, authenticated, service_role; -- 7. KIỂM TRA LẠI SELECT 'Users' as source, id, is_admin, role FROM public.users WHERE id = 'c7316609-7d4e-4dc3-885a-f008bf69084a' UNION ALL SELECT 'Profiles' as source, id, NULL, role FROM public.profiles WHERE id = 'c7316609-7d4e-4dc3-885a-f008bf69084a'; [V0_FILE]sql:file="scripts/004_fix_admin_access_corrected.sql" isMerged="true" -- Fix PGRST205 - Sửa lỗi admin_users là TABLE chứ không phải VIEW -- Script này sẽ DROP TABLE (không phải VIEW) và tạo lại đúng cách -- 1. DROP TABLE cũ (vì admin_users đã là TABLE rồi) DROP TABLE IF EXISTS public.admin_users CASCADE; -- 2. TẠO TABLE admin_users mới - TABLE thực tế, không phải VIEW CREATE TABLE public.admin_users ( id UUID PRIMARY KEY, email TEXT UNIQUE NOT NULL, full_name TEXT, is_admin BOOLEAN DEFAULT true, role TEXT DEFAULT 'admin', created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); -- 3. DISABLE RLS để tất cả có thể truy cập ALTER TABLE public.admin_users DISABLE ROW LEVEL SECURITY; -- 4. Grant quyền cho tất cả roles GRANT SELECT ON public.admin_users TO anon, authenticated, service_role; GRANT ALL ON public.admin_users TO service_role; -- 5. Insert admin user vào bảng INSERT INTO public.admin_users (id, email, full_name, is_admin, role) VALUES ('c7316609-7d4e-4dc3-885a-f008bf69084a', 'hocluongvan88@gmail.com', 'Lương Văn Học', true, 'admin') ON CONFLICT (id) DO UPDATE SET email = 'hocluongvan88@gmail.com', full_name = 'Lương Văn Học', is_admin = true, role = 'admin'; -- 6. Verify SELECT id, email, full_name, is_admin, role FROM public.admin_users; [V0_FILE]sql:file="scripts/005_add_analytics.sql" isMerged="true" -- Thêm các trường analytics vào bảng posts ALTER TABLE public.posts ADD COLUMN IF NOT EXISTS views_count INTEGER DEFAULT 0; ALTER TABLE public.posts ADD COLUMN IF NOT EXISTS views_this_month INTEGER DEFAULT 0; ALTER TABLE public.posts ADD COLUMN IF NOT EXISTS last_view_reset TIMESTAMPTZ DEFAULT NOW(); -- Tạo index cho analytics CREATE INDEX IF NOT EXISTS idx_posts_views ON public.posts(views_count DESC); -- Tạo bảng page_views để theo dõi chi tiết lượt xem CREATE TABLE IF NOT EXISTS public.page_views ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), post_id UUID REFERENCES public.posts(id) ON DELETE CASCADE, user_ip TEXT, user_agent TEXT, referrer TEXT, country TEXT, city TEXT, viewed_at TIMESTAMPTZ DEFAULT NOW() ); -- Index cho page_views CREATE INDEX IF NOT EXISTS idx_page_views_post_id ON public.page_views(post_id); CREATE INDEX IF NOT EXISTS idx_page_views_date ON public.page_views(viewed_at DESC); -- Enable RLS cho page_views ALTER TABLE public.page_views ENABLE ROW LEVEL SECURITY; -- Policy: Cho phép đọc và insert page views CREATE POLICY "page_views_select" ON public.page_views FOR SELECT USING (true); CREATE POLICY "page_views_insert" ON public.page_views FOR INSERT WITH CHECK (true); -- Function để reset views hàng tháng CREATE OR REPLACE FUNCTION public.reset_monthly_views() RETURNS void AS $$ BEGIN UPDATE public.posts SET views_this_month = 0, last_view_reset = NOW() WHERE last_view_reset < DATE_TRUNC('month', NOW()); END; $$ LANGUAGE plpgsql; -- Tạo bảng analytics_summary để lưu tổng hợp CREATE TABLE IF NOT EXISTS public.analytics_summary ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), metric_name TEXT NOT NULL, metric_value INTEGER DEFAULT 0, period TEXT NOT NULL, -- 'daily', 'monthly', 'yearly' date DATE NOT NULL, created_at TIMESTAMPTZ DEFAULT NOW(), UNIQUE(metric_name, period, date) ); -- Index cho analytics_summary CREATE INDEX IF NOT EXISTS idx_analytics_summary_date ON public.analytics_summary(date DESC); -- Enable RLS ALTER TABLE public.analytics_summary ENABLE ROW LEVEL SECURITY; -- Policy CREATE POLICY "analytics_summary_select" ON public.analytics_summary FOR SELECT USING (true); CREATE POLICY "analytics_summary_insert" ON public.analytics_summary FOR INSERT WITH CHECK (true); -- Cập nhật views cho các bài viết hiện có (dữ liệu giả để demo) UPDATE public.posts SET views_count = FLOOR(RANDOM() * 5000 + 1000)::INTEGER, views_this_month = FLOOR(RANDOM() * 1000 + 100)::INTEGER WHERE views_count = 0; [V0_FILE]sql:file="scripts/006_add_increment_views_function.sql" isMerged="true" -- Function để tăng views count CREATE OR REPLACE FUNCTION public.increment_post_views(post_id UUID) RETURNS void AS $$ BEGIN UPDATE public.posts SET views_count = views_count + 1, views_this_month = views_this_month + 1 WHERE id = post_id; END; $$ LANGUAGE plpgsql SECURITY DEFINER; -- Grant execute permission GRANT EXECUTE ON FUNCTION public.increment_post_views(UUID) TO anon, authenticated; [V0_FILE]sql:file="scripts/007_create_chat_system.sql" isMerged="true" -- Tạo bảng conversations (hội thoại) CREATE TABLE IF NOT EXISTS conversations ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), customer_id TEXT NOT NULL, customer_name TEXT NOT NULL, channel TEXT NOT NULL, -- 'website', 'facebook', 'zalo' status TEXT DEFAULT 'active', -- 'active', 'closed', 'pending' last_message TEXT, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); -- Tạo bảng chat_messages (tin nhắn) CREATE TABLE IF NOT EXISTS chat_messages ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), conversation_id UUID REFERENCES conversations(id) ON DELETE CASCADE, sender_type TEXT NOT NULL, -- 'customer', 'bot', 'agent' message_text TEXT NOT NULL, session_id TEXT, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); -- Tạo indexes để tăng hiệu suất CREATE INDEX IF NOT EXISTS idx_conversations_customer_id ON conversations(customer_id); CREATE INDEX IF NOT EXISTS idx_conversations_channel ON conversations(channel); CREATE INDEX IF NOT EXISTS idx_conversations_status ON conversations(status); CREATE INDEX IF NOT EXISTS idx_conversations_updated_at ON conversations(updated_at DESC); CREATE INDEX IF NOT EXISTS idx_chat_messages_conversation_id ON chat_messages(conversation_id); CREATE INDEX IF NOT EXISTS idx_chat_messages_created_at ON chat_messages(created_at DESC); -- Enable Row Level Security ALTER TABLE conversations ENABLE ROW LEVEL SECURITY; ALTER TABLE chat_messages ENABLE ROW LEVEL SECURITY; -- Policies cho conversations (chỉ admin có thể xem) CREATE POLICY "Admin can view all conversations" ON conversations FOR SELECT USING ( EXISTS ( SELECT 1 FROM auth.users WHERE auth.users.id = auth.uid() AND auth.users.email IN ('admin@veximglobal.com', 'your-admin-email@example.com') ) ); CREATE POLICY "System can insert conversations" ON conversations FOR INSERT WITH CHECK (true); CREATE POLICY "System can update conversations" ON conversations FOR UPDATE USING (true); -- Policies cho chat_messages CREATE POLICY "Admin can view all messages" ON chat_messages FOR SELECT USING ( EXISTS ( SELECT 1 FROM auth.users WHERE auth.users.id = auth.uid() AND auth.users.email IN ('admin@veximglobal.com', 'your-admin-email@example.com') ) ); CREATE POLICY "System can insert messages" ON chat_messages FOR INSERT WITH CHECK (true); -- Function để tự động cập nhật updated_at CREATE OR REPLACE FUNCTION update_conversation_timestamp() RETURNS TRIGGER AS $$ BEGIN NEW.updated_at = NOW(); RETURN NEW; END; $$ LANGUAGE plpgsql; -- Trigger để tự động cập nhật updated_at CREATE TRIGGER update_conversations_timestamp BEFORE UPDATE ON conversations FOR EACH ROW EXECUTE FUNCTION update_conversation_timestamp(); -- Thêm comment COMMENT ON TABLE conversations IS 'Bảng lưu trữ các cuộc hội thoại từ website, Facebook, Zalo'; COMMENT ON TABLE chat_messages IS 'Bảng lưu trữ tất cả tin nhắn trong các cuộc hội thoại'; [V0_FILE]sql:file="scripts/008_create_ai_knowledge_base.sql" isMerged="true" -- 1. Khởi tạo các bảng (Giữ nguyên logic IF NOT EXISTS) CREATE TABLE IF NOT EXISTS knowledge_documents ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), title TEXT NOT NULL, content TEXT NOT NULL, category TEXT, tags TEXT[], source_url TEXT, status TEXT DEFAULT 'active', created_by UUID, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); CREATE TABLE IF NOT EXISTS knowledge_chunks ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), document_id UUID REFERENCES knowledge_documents(id) ON DELETE CASCADE, chunk_text TEXT NOT NULL, chunk_index INTEGER NOT NULL, metadata JSONB, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); CREATE INDEX IF NOT EXISTS idx_knowledge_chunks_chunk_text_fts ON knowledge_chunks USING gin(to_tsvector('english', chunk_text)); CREATE TABLE IF NOT EXISTS ai_config ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), key TEXT UNIQUE NOT NULL, value JSONB NOT NULL, description TEXT, updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); CREATE TABLE IF NOT EXISTS conversation_handovers ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), conversation_id UUID REFERENCES conversations(id) ON DELETE CASCADE, from_type TEXT NOT NULL, to_type TEXT NOT NULL, reason TEXT, agent_id UUID REFERENCES auth.users(id), created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); -- 2. Cập nhật cột bổ sung cho các bảng hiện có ALTER TABLE conversations ADD COLUMN IF NOT EXISTS assigned_agent_id UUID REFERENCES auth.users(id), ADD COLUMN IF NOT EXISTS handover_mode TEXT DEFAULT 'auto', ADD COLUMN IF NOT EXISTS ai_confidence FLOAT DEFAULT 0.0; ALTER TABLE chat_messages ADD COLUMN IF NOT EXISTS ai_model TEXT, ADD COLUMN IF NOT EXISTS ai_confidence FLOAT, ADD COLUMN IF NOT EXISTS sources_used TEXT[]; -- 3. Kích hoạt RLS ALTER TABLE knowledge_documents ENABLE ROW LEVEL SECURITY; ALTER TABLE knowledge_chunks ENABLE ROW LEVEL SECURITY; ALTER TABLE ai_config ENABLE ROW LEVEL SECURITY; ALTER TABLE conversation_handovers ENABLE ROW LEVEL SECURITY; -- 4. GIẢI PHÁP SỬA LỖI: Xóa Policy cũ trước khi tạo mới để tránh lỗi 42710 DO $$ BEGIN -- Xử lý cho knowledge_documents DROP POLICY IF EXISTS "Admin can manage knowledge documents" ON knowledge_documents; CREATE POLICY "Admin can manage knowledge documents" ON knowledge_documents FOR ALL USING (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')); -- Xử lý cho knowledge_chunks DROP POLICY IF EXISTS "Admin can manage knowledge chunks" ON knowledge_chunks; CREATE POLICY "Admin can manage knowledge chunks" ON knowledge_chunks FOR ALL USING (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')); -- Xử lý cho ai_config DROP POLICY IF EXISTS "Admin can manage AI config" ON ai_config; CREATE POLICY "Admin can manage AI config" ON ai_config FOR ALL USING (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')); -- Xử lý cho handovers DROP POLICY IF EXISTS "Admin and agents can view handovers" ON conversation_handovers; CREATE POLICY "Admin and agents can view handovers" ON conversation_handovers FOR SELECT USING (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')); DROP POLICY IF EXISTS "System can insert handovers" ON conversation_handovers; CREATE POLICY "System can insert handovers" ON conversation_handovers FOR INSERT WITH CHECK (true); END $$; -- 5. Chèn cấu hình mặc định (Groq Llama 3) INSERT INTO ai_config (key, value, description) VALUES ('groq_model', '"llama-3.3-70b-versatile"', 'Tên mô hình AI trên Groq'), ('max_tokens', '1024', 'Số lượng token tối đa'), ('temperature', '0.7', 'Độ sáng tạo của AI'), ('rag_enabled', 'true', 'Bật tính năng tra cứu kiến thức (RAG)'), ('system_prompt', '"Bạn là chuyên gia tư vấn pháp lý của Vexim Global. Hãy trả lời cực nhanh, chính xác về FDA, GACC bằng tiếng Việt chuyên nghiệp."', 'Câu lệnh hệ thống') ON CONFLICT (key) DO UPDATE SET value = EXCLUDED.value; -- 6. Làm mới Schema NOTIFY pgrst, 'reload schema'; [V0_FILE]sql:file="scripts/009_fix_chat_permissions.sql" isMerged="true" -- Fix RLS policies để cho phép chatbot hoạt động với anonymous users -- Drop existing policies DROP POLICY IF EXISTS "Admin can view all conversations" ON conversations; DROP POLICY IF EXISTS "System can insert conversations" ON conversations; DROP POLICY IF EXISTS "System can update conversations" ON conversations; DROP POLICY IF EXISTS "Admin can view all messages" ON chat_messages; DROP POLICY IF EXISTS "System can insert messages" ON chat_messages; -- Policies mới cho conversations -- Allow anonymous users to insert and update their own conversations CREATE POLICY "Allow anonymous insert conversations" ON conversations FOR INSERT TO anon WITH CHECK (true); CREATE POLICY "Allow authenticated insert conversations" ON conversations FOR INSERT TO authenticated WITH CHECK (true); CREATE POLICY "Allow anonymous update conversations" ON conversations FOR UPDATE TO anon USING (true) WITH CHECK (true); CREATE POLICY "Allow authenticated update conversations" ON conversations FOR UPDATE TO authenticated USING (true) WITH CHECK (true); CREATE POLICY "Allow anonymous select conversations" ON conversations FOR SELECT TO anon USING (true); CREATE POLICY "Allow authenticated select conversations" ON conversations FOR SELECT TO authenticated USING (true); -- Policies mới cho chat_messages -- Allow anonymous users to insert and select messages CREATE POLICY "Allow anonymous insert messages" ON chat_messages FOR INSERT TO anon WITH CHECK (true); CREATE POLICY "Allow authenticated insert messages" ON chat_messages FOR INSERT TO authenticated WITH CHECK (true); CREATE POLICY "Allow anonymous select messages" ON chat_messages FOR SELECT TO anon USING (true); CREATE POLICY "Allow authenticated select messages" ON chat_messages FOR SELECT TO authenticated USING (true); -- Note: Admin panel sẽ cần authenticate với Supabase auth để quản lý conversations COMMENT ON TABLE conversations IS 'Chatbot conversations - RLS policies updated for anonymous access'; [V0_FILE]sql:file="scripts/010_fix_ai_config_permissions.sql" isMerged="true" -- Fix RLS policies cho ai_config và knowledge base để chatbot có thể đọc -- Drop existing policies cho ai_config DROP POLICY IF EXISTS "Admin can manage AI config" ON ai_config; -- Tạo policies mới cho ai_config -- Allow anonymous and authenticated users to read config CREATE POLICY "Allow anonymous read ai_config" ON ai_config FOR SELECT TO anon USING (true); CREATE POLICY "Allow authenticated read ai_config" ON ai_config FOR SELECT TO authenticated USING (true); -- Only admin can insert/update/delete CREATE POLICY "Admin can manage ai_config" ON ai_config FOR ALL TO authenticated USING (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')) WITH CHECK (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')); -- Drop existing policies cho knowledge_documents DROP POLICY IF EXISTS "Admin can manage knowledge documents" ON knowledge_documents; -- Tạo policies mới cho knowledge_documents CREATE POLICY "Allow anonymous read active knowledge_documents" ON knowledge_documents FOR SELECT TO anon USING (status = 'active'); CREATE POLICY "Allow authenticated read active knowledge_documents" ON knowledge_documents FOR SELECT TO authenticated USING (status = 'active'); -- Admin can manage all CREATE POLICY "Admin can manage knowledge_documents" ON knowledge_documents FOR ALL TO authenticated USING (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')) WITH CHECK (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')); -- Drop existing policies cho knowledge_chunks DROP POLICY IF EXISTS "Admin can manage knowledge chunks" ON knowledge_chunks; -- Tạo policies mới cho knowledge_chunks CREATE POLICY "Allow anonymous read knowledge_chunks" ON knowledge_chunks FOR SELECT TO anon USING (true); CREATE POLICY "Allow authenticated read knowledge_chunks" ON knowledge_chunks FOR SELECT TO authenticated USING (true); -- Admin can manage all CREATE POLICY "Admin can manage knowledge_chunks" ON knowledge_chunks FOR ALL TO authenticated USING (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')) WITH CHECK (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')); -- Fix conversation_handovers policies DROP POLICY IF EXISTS "Admin and agents can view handovers" ON conversation_handovers; DROP POLICY IF EXISTS "System can insert handovers" ON conversation_handovers; CREATE POLICY "Allow anonymous insert handovers" ON conversation_handovers FOR INSERT TO anon WITH CHECK (true); CREATE POLICY "Allow authenticated insert handovers" ON conversation_handovers FOR INSERT TO authenticated WITH CHECK (true); CREATE POLICY "Allow anonymous read handovers" ON conversation_handovers FOR SELECT TO anon USING (true); CREATE POLICY "Allow authenticated read handovers" ON conversation_handovers FOR SELECT TO authenticated USING (true); -- Admin can manage all CREATE POLICY "Admin can manage handovers" ON conversation_handovers FOR ALL TO authenticated USING (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')) WITH CHECK (auth.jwt() ->> 'email' IN ('admin@veximglobal.com', 'hocluongvan88@gmail.com')); COMMENT ON TABLE ai_config IS 'AI configuration - accessible by anonymous users for chatbot'; COMMENT ON TABLE knowledge_documents IS 'Knowledge base documents - active ones readable by anonymous users'; COMMENT ON TABLE knowledge_chunks IS 'Knowledge base chunks - readable by anonymous users'; [V0_FILE]sql:file="scripts/011_fix_conversation_handovers.sql" isMerged="true" -- Add missing columns to conversation_handovers table ALTER TABLE conversation_handovers ADD COLUMN IF NOT EXISTS agent_name TEXT, ADD COLUMN IF NOT EXISTS status TEXT DEFAULT 'active', ADD COLUMN IF NOT EXISTS released_at TIMESTAMP WITH TIME ZONE; -- Add index for better query performance CREATE INDEX IF NOT EXISTS idx_conversation_handovers_conversation_id ON conversation_handovers(conversation_id); CREATE INDEX IF NOT EXISTS idx_conversation_handovers_status ON conversation_handovers(status); -- Update RLS policies to allow updates DROP POLICY IF EXISTS "System can update handovers" ON conversation_handovers; CREATE POLICY "System can update handovers" ON conversation_handovers FOR UPDATE USING (true); -- Add metadata column to conversations if missing ALTER TABLE conversations ADD COLUMN IF NOT EXISTS metadata JSONB DEFAULT '{}'::jsonb; -- Refresh schema NOTIFY pgrst, 'reload schema'; -- Comment COMMENT ON COLUMN conversation_handovers.status IS 'Status: active, released'; COMMENT ON COLUMN conversation_handovers.agent_name IS 'Name of agent who took over'; COMMENT ON COLUMN conversation_handovers.released_at IS 'When conversation was released back to AI'; [V0_FILE]sql:file="scripts/012_fix_knowledge_base_schema.sql" isMerged="true" -- Fix knowledge_documents table schema ALTER TABLE knowledge_documents ADD COLUMN IF NOT EXISTS source_type TEXT DEFAULT 'text', ADD COLUMN IF NOT EXISTS chunks_count INTEGER DEFAULT 0; -- Update knowledge_chunks table to match API expectations ALTER TABLE knowledge_chunks RENAME COLUMN chunk_text TO content; ALTER TABLE knowledge_chunks ADD COLUMN IF NOT EXISTS token_count INTEGER DEFAULT 0; -- Drop the old index and recreate with new column name DROP INDEX IF EXISTS idx_knowledge_chunks_chunk_text_fts; CREATE INDEX IF NOT EXISTS idx_knowledge_chunks_content_fts ON knowledge_chunks USING gin(to_tsvector('english', content)); -- Refresh schema NOTIFY pgrst, 'reload schema'; [V0_FILE]sql:file="scripts/013_create_notifications.sql" isMerged="true" -- Create admin notifications table CREATE TABLE IF NOT EXISTS admin_notifications ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), type TEXT NOT NULL, conversation_id UUID REFERENCES conversations(id) ON DELETE CASCADE, title TEXT NOT NULL, message TEXT NOT NULL, urgency TEXT DEFAULT 'medium' CHECK (urgency IN ('high', 'medium', 'low')), metadata JSONB DEFAULT '{}'::jsonb, is_read BOOLEAN DEFAULT false, created_at TIMESTAMPTZ DEFAULT now(), read_at TIMESTAMPTZ ); -- Add index for faster queries CREATE INDEX IF NOT EXISTS idx_admin_notifications_is_read ON admin_notifications(is_read); CREATE INDEX IF NOT EXISTS idx_admin_notifications_created_at ON admin_notifications(created_at DESC); CREATE INDEX IF NOT EXISTS idx_admin_notifications_conversation ON admin_notifications(conversation_id); -- Enable RLS ALTER TABLE admin_notifications ENABLE ROW LEVEL SECURITY; -- Policy: Admin can view all notifications CREATE POLICY "Admin can view notifications" ON admin_notifications FOR SELECT TO authenticated USING ( EXISTS ( SELECT 1 FROM auth.users WHERE auth.users.id = auth.uid() AND auth.users.email LIKE '%@vexim%' ) ); -- Policy: System can insert notifications CREATE POLICY "System can insert notifications" ON admin_notifications FOR INSERT WITH CHECK (true); -- Policy: Admin can update their own notifications (mark as read) CREATE POLICY "Admin can update notifications" ON admin_notifications FOR UPDATE TO authenticated USING ( EXISTS ( SELECT 1 FROM auth.users WHERE auth.users.id = auth.uid() AND auth.users.email LIKE '%@vexim%' ) ); -- Add admin_notification_emails config INSERT INTO ai_config (key, value, description) VALUES ( 'admin_notification_emails', '[]'::jsonb, 'List of admin email addresses to receive notifications' ) ON CONFLICT (key) DO NOTHING; [V0_FILE]sql:file="scripts/014_create_push_subscriptions.sql" isMerged="true" -- Create push subscriptions table CREATE TABLE IF NOT EXISTS push_subscriptions ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), user_id UUID NOT NULL REFERENCES auth.users(id) ON DELETE CASCADE, endpoint TEXT NOT NULL, subscription JSONB NOT NULL, created_at TIMESTAMPTZ DEFAULT now(), updated_at TIMESTAMPTZ DEFAULT now(), UNIQUE(user_id) ); -- Add index for faster queries CREATE INDEX IF NOT EXISTS idx_push_subscriptions_user_id ON push_subscriptions(user_id); CREATE INDEX IF NOT EXISTS idx_push_subscriptions_endpoint ON push_subscriptions(endpoint); -- Enable RLS ALTER TABLE push_subscriptions ENABLE ROW LEVEL SECURITY; -- Policy: Users can view their own subscriptions CREATE POLICY "Users can view own subscriptions" ON push_subscriptions FOR SELECT TO authenticated USING (user_id = auth.uid()); -- Policy: Users can insert their own subscriptions CREATE POLICY "Users can insert own subscriptions" ON push_subscriptions FOR INSERT TO authenticated WITH CHECK (user_id = auth.uid()); -- Policy: Users can update their own subscriptions CREATE POLICY "Users can update own subscriptions" ON push_subscriptions FOR UPDATE TO authenticated USING (user_id = auth.uid()) WITH CHECK (user_id = auth.uid()); -- Policy: Users can delete their own subscriptions CREATE POLICY "Users can delete own subscriptions" ON push_subscriptions FOR DELETE TO authenticated USING (user_id = auth.uid()); -- Policy: Service role can access all subscriptions CREATE POLICY "Service role can access all subscriptions" ON push_subscriptions FOR ALL TO service_role USING (true) WITH CHECK (true); [V0_FILE]sql:file="scripts/014_delete_test_conversations.sql" isMerged="true" -- Script để xóa các conversations test -- Chạy script này từ Admin Panel hoặc Supabase SQL Editor -- OPTION 1: Xóa TẤT CẢ conversations (cẩn thận!) -- DELETE FROM chat_messages; -- DELETE FROM conversation_handovers; -- DELETE FROM conversations; -- OPTION 2: Xóa conversations cũ hơn X ngày DELETE FROM chat_messages WHERE conversation_id IN ( SELECT id FROM conversations WHERE created_at < NOW() - INTERVAL '7 days' ); DELETE FROM conversation_handovers WHERE conversation_id IN ( SELECT id FROM conversations WHERE created_at < NOW() - INTERVAL '7 days' ); DELETE FROM conversations WHERE created_at < NOW() - INTERVAL '7 days'; -- OPTION 3: Xóa conversations test (theo pattern tên) DELETE FROM chat_messages WHERE conversation_id IN ( SELECT id FROM conversations WHERE customer_name ILIKE '%test%' OR customer_name ILIKE '%demo%' ); DELETE FROM conversation_handovers WHERE conversation_id IN ( SELECT id FROM conversations WHERE customer_name ILIKE '%test%' OR customer_name ILIKE '%demo%' ); DELETE FROM conversations WHERE customer_name ILIKE '%test%' OR customer_name ILIKE '%demo%'; -- OPTION 4: Xóa conversations từ channel cụ thể -- DELETE FROM chat_messages WHERE conversation_id IN (SELECT id FROM conversations WHERE channel = 'website'); -- DELETE FROM conversation_handovers WHERE conversation_id IN (SELECT id FROM conversations WHERE channel = 'website'); -- DELETE FROM conversations WHERE channel = 'website'; -- Kiểm tra kết quả SELECT COUNT(*) as total_conversations FROM conversations; SELECT COUNT(*) as total_messages FROM chat_messages; SELECT COUNT(*) as total_handovers FROM conversation_handovers; [V0_FILE]sql:file="scripts/015_improve_posts_security.sql" isMerged="true" -- Cải thiện Row Level Security cho bảng posts -- Script này tăng cường bảo mật cho production -- Drop các policies cũ không an toàn DROP POLICY IF EXISTS "posts_select_all" ON public.posts; DROP POLICY IF EXISTS "posts_insert" ON public.posts; DROP POLICY IF EXISTS "posts_update" ON public.posts; DROP POLICY IF EXISTS "posts_delete" ON public.posts; -- Policy 1: Public có thể đọc bài viết đã xuất bản -- Giữ nguyên policy này vì nó đã đúng -- CREATE POLICY "posts_select_published" đã tồn tại -- Policy 2: Authenticated users có thể đọc tất cả bài viết (bao gồm draft) -- Thay thế policy cũ cho phép "true" CREATE POLICY "posts_select_authenticated" ON public.posts FOR SELECT TO authenticated USING (true); -- Policy 3: Authenticated users có thể insert bài viết mới -- Thay vì cho phép tất cả (true), chỉ cho phép authenticated users CREATE POLICY "posts_insert_authenticated" ON public.posts FOR INSERT TO authenticated WITH CHECK (true); -- Policy 4: Authenticated users có thể update bài viết -- Thay vì cho phép tất cả (true), chỉ cho phép authenticated users CREATE POLICY "posts_update_authenticated" ON public.posts FOR UPDATE TO authenticated USING (true) WITH CHECK (true); -- Policy 5: Authenticated users có thể delete bài viết -- Thay vì cho phép tất cả (true), chỉ cho phép authenticated users CREATE POLICY "posts_delete_authenticated" ON public.posts FOR DELETE TO authenticated USING (true); -- Note: Để production thực sự an toàn, nên: -- 1. Tạo bảng admin_users riêng -- 2. Chỉ cho phép admin_users thực hiện INSERT/UPDATE/DELETE -- 3. Check auth.uid() trong policies -- -- Ví dụ policy chỉ cho admin: -- CREATE POLICY "posts_insert_admin_only" -- ON public.posts FOR INSERT -- TO authenticated -- WITH CHECK ( -- EXISTS ( -- SELECT 1 FROM admin_users -- WHERE admin_users.user_id = auth.uid() -- AND admin_users.is_active = true -- ) -- ); [V0_FILE]sql:file="scripts/016_create_crawled_news_tracking.sql" isMerged="true" -- Bảng theo dõi tin tức đã crawl với hash-based detection CREATE TABLE IF NOT EXISTS public.crawled_news ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), source TEXT NOT NULL, -- 'FDA' hoặc 'GACC' source_url TEXT NOT NULL, -- URL trang được crawl title TEXT NOT NULL, article_url TEXT NOT NULL UNIQUE, -- URL bài viết (unique) published_date TEXT, content_hash TEXT, -- SHA256 hash của title + date + url full_content TEXT, -- Nội dung đầy đủ (chỉ lấy khi có thay đổi) summary TEXT, relevance TEXT, -- 'high', 'medium', 'low' categories TEXT[], -- Array các danh mục ai_analysis JSONB, -- Kết quả phân tích từ AI status TEXT DEFAULT 'pending', -- 'pending', 'processed', 'published', 'archived' is_notified BOOLEAN DEFAULT false, created_at TIMESTAMPTZ DEFAULT NOW(), updated_at TIMESTAMPTZ DEFAULT NOW(), last_checked_at TIMESTAMPTZ DEFAULT NOW() ); -- Index cho performance CREATE INDEX IF NOT EXISTS idx_crawled_news_source ON public.crawled_news(source); CREATE INDEX IF NOT EXISTS idx_crawled_news_status ON public.crawled_news(status); CREATE INDEX IF NOT EXISTS idx_crawled_news_content_hash ON public.crawled_news(content_hash); CREATE INDEX IF NOT EXISTS idx_crawled_news_created_at ON public.crawled_news(created_at DESC); CREATE INDEX IF NOT EXISTS idx_crawled_news_article_url ON public.crawled_news(article_url); -- RLS policies ALTER TABLE public.crawled_news ENABLE ROW LEVEL SECURITY; -- Admin có thể làm mọi thứ CREATE POLICY "Admins can do everything on crawled_news" ON public.crawled_news FOR ALL USING ( EXISTS ( SELECT 1 FROM public.admin_users WHERE admin_users.user_id = auth.uid() ) ); -- Public có thể đọc tin đã published CREATE POLICY "Public can read published news" ON public.crawled_news FOR SELECT USING (status = 'published'); -- Function để update updated_at CREATE OR REPLACE FUNCTION update_crawled_news_updated_at() RETURNS TRIGGER AS $$ BEGIN NEW.updated_at = NOW(); RETURN NEW; END; $$ LANGUAGE plpgsql; -- Trigger DROP TRIGGER IF EXISTS update_crawled_news_updated_at_trigger ON public.crawled_news; CREATE TRIGGER update_crawled_news_updated_at_trigger BEFORE UPDATE ON public.crawled_news FOR EACH ROW EXECUTE FUNCTION update_crawled_news_updated_at(); -- Bảng theo dõi crawl sessions CREATE TABLE IF NOT EXISTS public.crawl_sessions ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), source TEXT NOT NULL, source_url TEXT NOT NULL, started_at TIMESTAMPTZ DEFAULT NOW(), completed_at TIMESTAMPTZ, status TEXT DEFAULT 'running', -- 'running', 'completed', 'failed' articles_found INTEGER DEFAULT 0, new_articles INTEGER DEFAULT 0, updated_articles INTEGER DEFAULT 0, error_message TEXT, metadata JSONB ); CREATE INDEX IF NOT EXISTS idx_crawl_sessions_source ON public.crawl_sessions(source); CREATE INDEX IF NOT EXISTS idx_crawl_sessions_started_at ON public.crawl_sessions(started_at DESC); COMMIT; [V0_FILE]sql:file="scripts/017_create_fda_subscriptions.sql" isMerged="true" -- FDA Tracker Subscriptions Table -- Lưu thông tin người đăng ký nhận cảnh báo FDA CREATE TABLE IF NOT EXISTS fda_subscriptions ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), email TEXT NOT NULL UNIQUE, categories TEXT[] NOT NULL, -- ['food', 'drug', 'cosmetic', 'device'] frequency TEXT NOT NULL DEFAULT 'weekly', -- 'daily', 'weekly', 'immediate' is_active BOOLEAN NOT NULL DEFAULT true, verified BOOLEAN NOT NULL DEFAULT false, verification_token TEXT, last_sent_at TIMESTAMP WITH TIME ZONE, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), CONSTRAINT fda_subscriptions_frequency_check CHECK (frequency IN ('daily', 'weekly', 'immediate')) ); -- Indexes for performance CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_email ON fda_subscriptions(email); CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_active ON fda_subscriptions(is_active); CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_verified ON fda_subscriptions(verified); CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_categories ON fda_subscriptions USING GIN(categories); -- RLS Policies ALTER TABLE fda_subscriptions ENABLE ROW LEVEL SECURITY; -- Allow anyone to insert (subscribe) CREATE POLICY "Anyone can subscribe" ON fda_subscriptions FOR INSERT TO public WITH CHECK (true); -- Allow users to view their own subscription CREATE POLICY "Users can view their own subscription" ON fda_subscriptions FOR SELECT TO public USING (true); -- Allow users to update their own subscription CREATE POLICY "Users can update their own subscription" ON fda_subscriptions FOR UPDATE TO public USING (true) WITH CHECK (true); -- Admins can see all CREATE POLICY "Admins can manage all subscriptions" ON fda_subscriptions FOR ALL TO authenticated USING ( EXISTS ( SELECT 1 FROM auth.users WHERE auth.users.id = auth.uid() AND auth.users.email = 'admin@vexim.vn' ) ); -- Auto-update updated_at timestamp CREATE OR REPLACE FUNCTION update_fda_subscriptions_updated_at() RETURNS TRIGGER AS $$ BEGIN NEW.updated_at = NOW(); RETURN NEW; END; $$ LANGUAGE plpgsql; CREATE TRIGGER fda_subscriptions_updated_at BEFORE UPDATE ON fda_subscriptions FOR EACH ROW EXECUTE FUNCTION update_fda_subscriptions_updated_at(); -- FDA Alert Cache Table (optional - để cache kết quả FDA API) CREATE TABLE IF NOT EXISTS fda_alerts_cache ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), category TEXT NOT NULL, endpoint TEXT NOT NULL, data JSONB NOT NULL, total_count INTEGER NOT NULL, cached_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), expires_at TIMESTAMP WITH TIME ZONE DEFAULT (NOW() + INTERVAL '30 minutes'), CONSTRAINT fda_alerts_cache_category_check CHECK (category IN ('food', 'drug', 'cosmetic', 'device')) ); -- Index for cache lookups CREATE INDEX IF NOT EXISTS idx_fda_alerts_cache_lookup ON fda_alerts_cache(category, endpoint, expires_at); -- Auto-cleanup expired cache (run daily) CREATE OR REPLACE FUNCTION cleanup_expired_fda_cache() RETURNS void AS $$ BEGIN DELETE FROM fda_alerts_cache WHERE expires_at < NOW(); END; $$ LANGUAGE plpgsql; COMMENT ON TABLE fda_subscriptions IS 'Stores FDA alert subscriptions from users'; COMMENT ON TABLE fda_alerts_cache IS 'Caches FDA API responses to reduce API calls'; [V0_FILE]sql:file="scripts/018_add_email_to_gacc_submissions.sql" isMerged="true" -- Add email column to gacc_submissions table -- This migration adds the email field to store customer email for GACC submissions -- Add email column ALTER TABLE gacc_submissions ADD COLUMN IF NOT EXISTS email TEXT; -- Add comment to describe the column COMMENT ON COLUMN gacc_submissions.email IS 'Customer email address for contact and confirmation'; -- Create index for email lookups CREATE INDEX IF NOT EXISTS idx_gacc_submissions_email ON gacc_submissions(email); [V0_FILE]sql:file="scripts/019_add_attachments_to_gacc_submissions.sql" isMerged="true" -- Add attachments column to gacc_submissions table -- This column will store uploaded file information as JSON -- Add the attachments column if it doesn't exist DO $$ BEGIN IF NOT EXISTS ( SELECT 1 FROM information_schema.columns WHERE table_name = 'gacc_submissions' AND column_name = 'attachments' ) THEN ALTER TABLE gacc_submissions ADD COLUMN attachments jsonb DEFAULT '[]'::jsonb; -- Add comment COMMENT ON COLUMN gacc_submissions.attachments IS 'JSON array of uploaded files with metadata (fieldId, fileName, fileUrl, fileSize, uploadedAt)'; END IF; END $$; [V0_FILE]sql:file="scripts/020_add_fda_performance_indexes.sql" isMerged="true" -- ===================================================== -- FDA TRACKER PERFORMANCE OPTIMIZATION -- Migration: 020_add_fda_performance_indexes.sql -- Purpose: Add composite indexes and monitoring tables -- ===================================================== -- 1. Add composite index for digest queries CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_active_digest ON fda_subscriptions(is_active, verified, frequency) WHERE is_active = true AND verified = true; -- 2. Add index for tracking last sent CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_last_sent ON fda_subscriptions(last_sent_at DESC); -- 3. Add token expiry field ALTER TABLE fda_subscriptions ADD COLUMN IF NOT EXISTS token_expires_at TIMESTAMP WITH TIME ZONE; -- 4. Set expiry for existing tokens (24 hours from created_at) UPDATE fda_subscriptions SET token_expires_at = created_at + INTERVAL '24 hours' WHERE token_expires_at IS NULL AND verification_token IS NOT NULL; -- 5. Add bounce tracking fields ALTER TABLE fda_subscriptions ADD COLUMN IF NOT EXISTS bounce_count INTEGER DEFAULT 0, ADD COLUMN IF NOT EXISTS last_bounce_at TIMESTAMP WITH TIME ZONE; -- 6. Add index for bounce tracking CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_bounce ON fda_subscriptions(bounce_count) WHERE bounce_count > 0; -- 7. Create cron job monitoring table CREATE TABLE IF NOT EXISTS cron_job_logs ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), job_name TEXT NOT NULL, frequency TEXT, started_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), completed_at TIMESTAMP WITH TIME ZONE, status TEXT CHECK (status IN ('running', 'success', 'failed')), emails_sent INTEGER DEFAULT 0, emails_failed INTEGER DEFAULT 0, error_message TEXT, metadata JSONB DEFAULT '{}'::jsonb, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); -- 8. Add indexes for cron logs CREATE INDEX IF NOT EXISTS idx_cron_logs_job_name ON cron_job_logs(job_name, started_at DESC); CREATE INDEX IF NOT EXISTS idx_cron_logs_status ON cron_job_logs(status, started_at DESC); -- 9. Improve fda_alerts_cache table structure ALTER TABLE fda_alerts_cache ADD COLUMN IF NOT EXISTS ai_summary TEXT, ADD COLUMN IF NOT EXISTS summary_generated_at TIMESTAMP WITH TIME ZONE, ADD COLUMN IF NOT EXISTS hit_count INTEGER DEFAULT 0, ADD COLUMN IF NOT EXISTS last_accessed_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(); -- 10. Add index for cache lookups CREATE INDEX IF NOT EXISTS idx_fda_cache_category_endpoint ON fda_alerts_cache(category, endpoint, cached_at DESC); CREATE INDEX IF NOT EXISTS idx_fda_cache_item_id ON fda_alerts_cache((data->>'id')); -- 11. Add auto-cleanup trigger for expired tokens CREATE OR REPLACE FUNCTION cleanup_expired_tokens() RETURNS TRIGGER AS $$ BEGIN -- Mark tokens as expired if past expiry date IF NEW.token_expires_at < NOW() AND NEW.verification_token IS NOT NULL THEN NEW.verification_token = NULL; END IF; RETURN NEW; END; $$ LANGUAGE plpgsql; CREATE TRIGGER trigger_cleanup_expired_tokens BEFORE UPDATE ON fda_subscriptions FOR EACH ROW EXECUTE FUNCTION cleanup_expired_tokens(); -- 12. Create function to auto-disable high bounce subscribers CREATE OR REPLACE FUNCTION auto_disable_bounced_subscribers() RETURNS TRIGGER AS $$ BEGIN -- Auto-disable if bounce count reaches 3 IF NEW.bounce_count >= 3 AND NEW.is_active = true THEN NEW.is_active = false; NEW.metadata = jsonb_set( COALESCE(NEW.metadata, '{}'::jsonb), '{auto_disabled_reason}', '"high_bounce_rate"'::jsonb ); END IF; RETURN NEW; END; $$ LANGUAGE plpgsql; CREATE TRIGGER trigger_auto_disable_bounced BEFORE UPDATE ON fda_subscriptions FOR EACH ROW WHEN (NEW.bounce_count IS DISTINCT FROM OLD.bounce_count) EXECUTE FUNCTION auto_disable_bounced_subscribers(); -- 13. RLS policies for cron_job_logs (admin only) ALTER TABLE cron_job_logs ENABLE ROW LEVEL SECURITY; CREATE POLICY "Admin can view cron logs" ON cron_job_logs FOR SELECT USING ( EXISTS ( SELECT 1 FROM admin_users WHERE admin_users.id = auth.uid() ) ); CREATE POLICY "System can insert cron logs" ON cron_job_logs FOR INSERT WITH CHECK (true); -- 14. Create helper function for cache hit tracking CREATE OR REPLACE FUNCTION increment_cache_hit(p_cache_id UUID) RETURNS void AS $$ BEGIN UPDATE fda_alerts_cache SET hit_count = hit_count + 1, last_accessed_at = NOW() WHERE id = p_cache_id; END; $$ LANGUAGE plpgsql; -- 15. Grant permissions GRANT SELECT, INSERT, UPDATE ON cron_job_logs TO authenticated; GRANT SELECT, INSERT, UPDATE ON fda_alerts_cache TO authenticated; GRANT EXECUTE ON FUNCTION increment_cache_hit TO authenticated; -- ===================================================== -- VERIFICATION QUERIES -- ===================================================== -- Verify indexes were created SELECT schemaname, tablename, indexname, indexdef FROM pg_indexes WHERE tablename IN ('fda_subscriptions', 'fda_alerts_cache', 'cron_job_logs') ORDER BY tablename, indexname; -- Check new columns SELECT column_name, data_type, is_nullable FROM information_schema.columns WHERE table_name = 'fda_subscriptions' AND column_name IN ('token_expires_at', 'bounce_count', 'last_bounce_at'); -- Show sample cron_job_logs structure SELECT * FROM cron_job_logs LIMIT 0; [V0_FILE]sql:file="scripts/021_phase2_improvements.sql" isMerged="true" -- ===================================================== -- PHASE 2: HIGH PRIORITY IMPROVEMENTS -- H-3: Token expiry -- H-4: Email bounce handling -- C-4: AI summary cache -- H-2: Rate limiting -- ===================================================== -- ===================================================== -- H-3: ADD TOKEN EXPIRY TO FDA SUBSCRIPTIONS -- ===================================================== -- Add token_expires_at column ALTER TABLE fda_subscriptions ADD COLUMN IF NOT EXISTS token_expires_at TIMESTAMP WITH TIME ZONE; -- Set expiry for existing tokens (24 hours from creation) UPDATE fda_subscriptions SET token_expires_at = created_at + INTERVAL '24 hours' WHERE token_expires_at IS NULL; -- Make token_expires_at required for new rows ALTER TABLE fda_subscriptions ALTER COLUMN token_expires_at SET DEFAULT (NOW() + INTERVAL '24 hours'); COMMENT ON COLUMN fda_subscriptions.token_expires_at IS 'Verification token expiration timestamp (24 hours from creation)'; -- ===================================================== -- H-4: EMAIL BOUNCE HANDLING -- ===================================================== -- Add bounce tracking columns ALTER TABLE fda_subscriptions ADD COLUMN IF NOT EXISTS bounce_count INTEGER DEFAULT 0, ADD COLUMN IF NOT EXISTS last_bounce_at TIMESTAMP WITH TIME ZONE, ADD COLUMN IF NOT EXISTS bounce_type TEXT; COMMENT ON COLUMN fda_subscriptions.bounce_count IS 'Number of email bounces (auto-disable after 3)'; COMMENT ON COLUMN fda_subscriptions.last_bounce_at IS 'Timestamp of last email bounce'; COMMENT ON COLUMN fda_subscriptions.bounce_type IS 'Type of bounce: hard, soft, complaint'; -- Create index for bounce queries CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_bounce ON fda_subscriptions(bounce_count, is_active) WHERE bounce_count > 0; -- ===================================================== -- C-4: AI SUMMARY CACHE IN FDA_ALERTS_CACHE -- ===================================================== -- Add AI summary fields to cache table ALTER TABLE fda_alerts_cache ADD COLUMN IF NOT EXISTS ai_summaries JSONB; COMMENT ON COLUMN fda_alerts_cache.ai_summaries IS 'Cached AI-generated Vietnamese summaries for FDA items {item_id: summary_text}'; -- Create GIN index for JSONB queries CREATE INDEX IF NOT EXISTS idx_fda_alerts_cache_ai_summaries ON fda_alerts_cache USING GIN(ai_summaries); -- ===================================================== -- H-2: RATE LIMITING TABLE -- ===================================================== -- Create rate_limits table for API endpoint rate limiting CREATE TABLE IF NOT EXISTS rate_limits ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), identifier TEXT NOT NULL, -- IP address, email, or API key endpoint TEXT NOT NULL, -- API endpoint path request_count INTEGER DEFAULT 1, window_start TIMESTAMP WITH TIME ZONE DEFAULT NOW(), created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); -- Composite index for fast lookups CREATE UNIQUE INDEX IF NOT EXISTS idx_rate_limits_identifier_endpoint ON rate_limits(identifier, endpoint, window_start); -- Index for cleanup old entries CREATE INDEX IF NOT EXISTS idx_rate_limits_window_start ON rate_limits(window_start DESC); COMMENT ON TABLE rate_limits IS 'Rate limiting tracking for API endpoints (IP-based throttling)'; COMMENT ON COLUMN rate_limits.identifier IS 'Client identifier (IP address, email, or API key)'; COMMENT ON COLUMN rate_limits.endpoint IS 'API endpoint being rate limited'; COMMENT ON COLUMN rate_limits.request_count IS 'Number of requests in current window'; COMMENT ON COLUMN rate_limits.window_start IS 'Start of current rate limit window'; -- Enable RLS ALTER TABLE rate_limits ENABLE ROW LEVEL SECURITY; -- Admin-only access CREATE POLICY "Admin can view rate limits" ON rate_limits FOR SELECT USING (auth.jwt() ->> 'role' = 'admin'); -- ===================================================== -- CLEANUP FUNCTION FOR RATE LIMITS -- ===================================================== -- Function to clean up old rate limit entries (older than 1 hour) CREATE OR REPLACE FUNCTION cleanup_old_rate_limits() RETURNS void LANGUAGE plpgsql SECURITY DEFINER AS $$ BEGIN DELETE FROM rate_limits WHERE window_start < NOW() - INTERVAL '1 hour'; RAISE NOTICE 'Cleaned up old rate limit entries'; END; $$; COMMENT ON FUNCTION cleanup_old_rate_limits IS 'Removes rate limit entries older than 1 hour'; -- ===================================================== -- UPDATE INDEXES FROM PHASE 1 (if not already applied) -- ===================================================== -- Composite index for cron digest queries CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_active_digest ON fda_subscriptions(is_active, verified, frequency) WHERE is_active = true AND verified = true; -- Index for last_sent_at tracking CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_last_sent ON fda_subscriptions(last_sent_at DESC); -- Index for verification token with expiry CREATE INDEX IF NOT EXISTS idx_fda_subscriptions_verification ON fda_subscriptions(verification_token, token_expires_at) WHERE verified = false; -- ===================================================== -- SUMMARY & VERIFICATION -- ===================================================== -- Verify all new columns exist DO $$ DECLARE missing_columns TEXT[]; BEGIN SELECT ARRAY_AGG(column_name) INTO missing_columns FROM ( SELECT 'token_expires_at' AS column_name WHERE NOT EXISTS ( SELECT 1 FROM information_schema.columns WHERE table_name = 'fda_subscriptions' AND column_name = 'token_expires_at' ) UNION ALL SELECT 'bounce_count' WHERE NOT EXISTS ( SELECT 1 FROM information_schema.columns WHERE table_name = 'fda_subscriptions' AND column_name = 'bounce_count' ) UNION ALL SELECT 'ai_summaries' WHERE NOT EXISTS ( SELECT 1 FROM information_schema.columns WHERE table_name = 'fda_alerts_cache' AND column_name = 'ai_summaries' ) ) AS missing; IF missing_columns IS NOT NULL THEN RAISE WARNING 'Missing columns: %', array_to_string(missing_columns, ', '); ELSE RAISE NOTICE 'Phase 2 migration completed successfully!'; RAISE NOTICE '✓ Token expiry added'; RAISE NOTICE '✓ Email bounce tracking added'; RAISE NOTICE '✓ AI summary cache added'; RAISE NOTICE '✓ Rate limiting table created'; END IF; END; $$; [V0_FILE]sql:file="scripts/022_create_fda_registrations.sql" isMerged="true" -- FDA Registrations Management System -- Quản lý thông tin đăng ký FDA của các công ty/khách hàng -- Bao gồm mã hóa an toàn cho thông tin nhạy cảm (User ID, Password, PIN) -- Enable pgcrypto extension for encryption CREATE EXTENSION IF NOT EXISTS pgcrypto; -- Create FDA Registrations table CREATE TABLE IF NOT EXISTS fda_registrations ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), -- Company Information company_name TEXT NOT NULL, company_name_english TEXT, company_address TEXT NOT NULL, company_city TEXT, company_state TEXT, company_country TEXT NOT NULL DEFAULT 'Vietnam', company_phone TEXT, company_email TEXT, -- Contact Person contact_name TEXT NOT NULL, contact_title TEXT, contact_phone TEXT, contact_email TEXT NOT NULL, -- Registration Information registration_type TEXT NOT NULL, -- 'Food Facility', 'Drug', 'Device', 'Cosmetic', etc. registration_number TEXT, -- FDA Registration Number sau khi đăng ký fei_number TEXT, -- Facility Establishment Identifier duns_number TEXT, -- Data Universal Numbering System -- Registration Dates initial_registration_date DATE, last_renewal_date DATE, expiration_date DATE NOT NULL, next_renewal_date DATE, -- FDA Account Credentials (ENCRYPTED) fda_user_id_encrypted BYTEA, -- Encrypted FDA User ID fda_password_encrypted BYTEA, -- Encrypted FDA Password fda_pin_encrypted BYTEA, -- Encrypted FDA PIN -- US Agent Information (if applicable) uses_us_agent BOOLEAN DEFAULT false, agent_company_name TEXT, agent_name TEXT, agent_phone TEXT, agent_email TEXT, agent_address TEXT, agent_contract_start_date DATE, agent_contract_end_date DATE, agent_contract_years INTEGER, -- Số năm hợp đồng: 1, 2, 3, 4, 5 hoặc nhiều hơn -- Facility/Product Details facility_type TEXT, product_categories TEXT[], -- Array of product categories products_description TEXT, -- Reminder Settings reminder_months_before INTEGER DEFAULT 6, -- Nhắc trước bao nhiêu tháng (mặc định 6 tháng) reminder_sent BOOLEAN DEFAULT false, reminder_sent_at TIMESTAMP WITH TIME ZONE, -- Status & Notes status TEXT DEFAULT 'active', -- 'active', 'expired', 'pending_renewal', 'cancelled' notes TEXT, internal_notes TEXT, -- Ghi chú nội bộ, không hiển thị cho khách hàng -- Metadata created_by UUID REFERENCES auth.users(id), created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), CONSTRAINT fda_registrations_status_check CHECK (status IN ('active', 'expired', 'pending_renewal', 'cancelled')), CONSTRAINT fda_registrations_type_check CHECK (registration_type IN ('Food Facility', 'Drug Establishment', 'Medical Device', 'Cosmetic', 'Dietary Supplement', 'Infant Formula', 'Other')) ); -- Indexes for performance CREATE INDEX IF NOT EXISTS idx_fda_registrations_company ON fda_registrations(company_name); CREATE INDEX IF NOT EXISTS idx_fda_registrations_status ON fda_registrations(status); CREATE INDEX IF NOT EXISTS idx_fda_registrations_expiration ON fda_registrations(expiration_date); CREATE INDEX IF NOT EXISTS idx_fda_registrations_renewal ON fda_registrations(next_renewal_date); CREATE INDEX IF NOT EXISTS idx_fda_registrations_agent_expiration ON fda_registrations(agent_contract_end_date); CREATE INDEX IF NOT EXISTS idx_fda_registrations_registration_number ON fda_registrations(registration_number); -- Function to encrypt sensitive data -- Sử dụng AES-256 encryption theo tiêu chuẩn ISO 27001 CREATE OR REPLACE FUNCTION encrypt_fda_credential(plaintext TEXT, encryption_key TEXT) RETURNS BYTEA AS $$ BEGIN IF plaintext IS NULL OR plaintext = '' THEN RETURN NULL; END IF; RETURN pgp_sym_encrypt(plaintext, encryption_key, 'cipher-algo=aes256'); END; $$ LANGUAGE plpgsql SECURITY DEFINER; -- Function to decrypt sensitive data CREATE OR REPLACE FUNCTION decrypt_fda_credential(encrypted BYTEA, encryption_key TEXT) RETURNS TEXT AS $$ BEGIN IF encrypted IS NULL THEN RETURN NULL; END IF; RETURN pgp_sym_decrypt(encrypted, encryption_key, 'cipher-algo=aes256'); END; $$ LANGUAGE plpgsql SECURITY DEFINER; -- Auto-update updated_at timestamp CREATE OR REPLACE FUNCTION update_fda_registrations_updated_at() RETURNS TRIGGER AS $$ BEGIN NEW.updated_at = NOW(); RETURN NEW; END; $$ LANGUAGE plpgsql; CREATE TRIGGER fda_registrations_updated_at BEFORE UPDATE ON fda_registrations FOR EACH ROW EXECUTE FUNCTION update_fda_registrations_updated_at(); -- Auto-update status based on dates CREATE OR REPLACE FUNCTION update_fda_registration_status() RETURNS TRIGGER AS $$ BEGIN -- Update status based on expiration date IF NEW.expiration_date < CURRENT_DATE THEN NEW.status = 'expired'; ELSIF NEW.expiration_date <= CURRENT_DATE + INTERVAL '6 months' THEN NEW.status = 'pending_renewal'; ELSE NEW.status = 'active'; END IF; RETURN NEW; END; $$ LANGUAGE plpgsql; CREATE TRIGGER fda_registrations_status_update BEFORE INSERT OR UPDATE OF expiration_date ON fda_registrations FOR EACH ROW EXECUTE FUNCTION update_fda_registration_status(); -- Table for tracking renewal reminders CREATE TABLE IF NOT EXISTS fda_renewal_reminders ( id UUID PRIMARY KEY DEFAULT gen_random_uuid(), registration_id UUID NOT NULL REFERENCES fda_registrations(id) ON DELETE CASCADE, reminder_type TEXT NOT NULL, -- 'fda_renewal', 'agent_renewal' reminder_date DATE NOT NULL, months_before INTEGER NOT NULL, sent_via TEXT[], -- ['email', 'zalo'] sent_at TIMESTAMP WITH TIME ZONE, status TEXT DEFAULT 'pending', -- 'pending', 'sent', 'failed' error_message TEXT, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), CONSTRAINT fda_renewal_reminders_type_check CHECK (reminder_type IN ('fda_renewal', 'agent_renewal')), CONSTRAINT fda_renewal_reminders_status_check CHECK (status IN ('pending', 'sent', 'failed')) ); CREATE INDEX IF NOT EXISTS idx_fda_renewal_reminders_date ON fda_renewal_reminders(reminder_date, status); CREATE INDEX IF NOT EXISTS idx_fda_renewal_reminders_registration ON fda_renewal_reminders(registration_id); -- RLS Policies ALTER TABLE fda_registrations ENABLE ROW LEVEL SECURITY; ALTER TABLE fda_renewal_reminders ENABLE ROW LEVEL SECURITY; -- Only authenticated admins can access FDA registrations CREATE POLICY "Admins can manage FDA registrations" ON fda_registrations FOR ALL TO authenticated USING ( EXISTS ( SELECT 1 FROM auth.users WHERE auth.users.id = auth.uid() AND ( auth.users.email = 'admin@vexim.vn' OR auth.users.raw_user_meta_data->>'role' = 'admin' ) ) ); CREATE POLICY "Admins can manage renewal reminders" ON fda_renewal_reminders FOR ALL TO authenticated USING ( EXISTS ( SELECT 1 FROM auth.users WHERE auth.users.id = auth.uid() AND ( auth.users.email = 'admin@vexim.vn' OR auth.users.raw_user_meta_data->>'role' = 'admin' ) ) ); -- Function to generate renewal reminders automatically -- Chạy hàng ngày để tạo reminder cho các registration sắp hết hạn CREATE OR REPLACE FUNCTION generate_fda_renewal_reminders() RETURNS void AS $$ DECLARE reg RECORD; reminder_date DATE; BEGIN -- Loop through active registrations FOR reg IN SELECT * FROM fda_registrations WHERE status IN ('active', 'pending_renewal') AND expiration_date IS NOT NULL LOOP -- Calculate reminder dates based on reminder_months_before reminder_date := reg.expiration_date - (reg.reminder_months_before || ' months')::INTERVAL; -- Create FDA renewal reminder if not exists and date is within next 7 days IF reminder_date <= CURRENT_DATE + INTERVAL '7 days' AND reminder_date >= CURRENT_DATE THEN INSERT INTO fda_renewal_reminders ( registration_id, reminder_type, reminder_date, months_before, sent_via ) VALUES ( reg.id, 'fda_renewal', reminder_date, reg.reminder_months_before, ARRAY['email'] ) ON CONFLICT DO NOTHING; END IF; -- Create US Agent renewal reminder if applicable IF reg.uses_us_agent AND reg.agent_contract_end_date IS NOT NULL AND reg.agent_contract_end_date > CURRENT_DATE THEN reminder_date := reg.agent_contract_end_date - INTERVAL '3 months'; IF reminder_date <= CURRENT_DATE + INTERVAL '7 days' AND reminder_date >= CURRENT_DATE THEN INSERT INTO fda_renewal_reminders ( registration_id, reminder_type, reminder_date, months_before, sent_via ) VALUES ( reg.id, 'agent_renewal', reminder_date, 3, ARRAY['email'] ) ON CONFLICT DO NOTHING; END IF; END IF; END LOOP; END; $$ LANGUAGE plpgsql; -- Comments COMMENT ON TABLE fda_registrations IS 'Quản lý thông tin đăng ký FDA của các công ty khách hàng'; COMMENT ON TABLE fda_renewal_reminders IS 'Theo dõi và quản lý các lời nhắc gia hạn FDA và US Agent'; COMMENT ON COLUMN fda_registrations.fda_user_id_encrypted IS 'FDA User ID được mã hóa AES-256'; COMMENT ON COLUMN fda_registrations.fda_password_encrypted IS 'FDA Password được mã hóa AES-256'; COMMENT ON COLUMN fda_registrations.fda_pin_encrypted IS 'FDA PIN được mã hóa AES-256'; COMMENT ON FUNCTION encrypt_fda_credential IS 'Mã hóa thông tin nhạy cảm FDA bằng AES-256 (ISO 27001)'; COMMENT ON FUNCTION decrypt_fda_credential IS 'Giải mã thông tin nhạy cảm FDA'; COMMENT ON FUNCTION generate_fda_renewal_reminders IS 'Tự động tạo nhắc nhở gia hạn cho FDA và US Agent'; [V0_FILE]sql:file="scripts/023_create_client_accounts.sql" isMerged="true" -- Client Management System -- Allows admin to create client accounts who can view their FDA registrations -- Create clients table CREATE TABLE IF NOT EXISTS clients ( id UUID DEFAULT gen_random_uuid() PRIMARY KEY, email TEXT UNIQUE NOT NULL, password_hash TEXT NOT NULL, -- bcrypt hash company_name TEXT NOT NULL, contact_name TEXT NOT NULL, phone TEXT, address TEXT, is_active BOOLEAN DEFAULT true, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), last_login_at TIMESTAMP WITH TIME ZONE ); -- Add client_id to fda_registrations ALTER TABLE fda_registrations ADD COLUMN IF NOT EXISTS client_id UUID REFERENCES clients(id) ON DELETE CASCADE; -- Create index for faster lookups CREATE INDEX IF NOT EXISTS idx_fda_registrations_client_id ON fda_registrations(client_id); CREATE INDEX IF NOT EXISTS idx_clients_email ON clients(email); -- RLS Policies for clients table (allow service role access for API) ALTER TABLE clients ENABLE ROW LEVEL SECURITY; -- Allow service role to manage all clients (for API routes) CREATE POLICY "Service role full access to clients" ON clients FOR ALL TO service_role USING (true) WITH CHECK (true); -- Allow anon to read clients for login verification CREATE POLICY "Allow anon read for login" ON clients FOR SELECT TO anon USING (true); -- Update RLS for fda_registrations to allow service role access CREATE POLICY "Service role full access to fda_registrations" ON fda_registrations FOR ALL TO service_role USING (true) WITH CHECK (true); -- Create client sessions table for custom auth CREATE TABLE IF NOT EXISTS client_sessions ( id UUID DEFAULT gen_random_uuid() PRIMARY KEY, client_id UUID NOT NULL REFERENCES clients(id) ON DELETE CASCADE, token TEXT UNIQUE NOT NULL, expires_at TIMESTAMP WITH TIME ZONE NOT NULL, created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() ); CREATE INDEX IF NOT EXISTS idx_client_sessions_token ON client_sessions(token); CREATE INDEX IF NOT EXISTS idx_client_sessions_client_id ON client_sessions(client_id); -- RLS for client_sessions ALTER TABLE client_sessions ENABLE ROW LEVEL SECURITY; CREATE POLICY "Service role full access to client_sessions" ON client_sessions FOR ALL TO service_role USING (true) WITH CHECK (true); -- Allow anon to check sessions CREATE POLICY "Allow anon read sessions" ON client_sessions FOR SELECT TO anon USING (true); -- Function to clean up expired sessions CREATE OR REPLACE FUNCTION cleanup_expired_client_sessions() RETURNS void AS $$ BEGIN DELETE FROM client_sessions WHERE expires_at < NOW(); END; $$ LANGUAGE plpgsql SECURITY DEFINER; -- Grant execute permission GRANT EXECUTE ON FUNCTION cleanup_expired_client_sessions() TO service_role; GRANT EXECUTE ON FUNCTION cleanup_expired_client_sessions() TO anon; -- Create notification preferences for clients CREATE TABLE IF NOT EXISTS client_notification_preferences ( id UUID DEFAULT gen_random_uuid() PRIMARY KEY, client_id UUID NOT NULL REFERENCES clients(id) ON DELETE CASCADE, email_enabled BOOLEAN DEFAULT true, zalo_enabled BOOLEAN DEFAULT false, zalo_phone TEXT, reminder_days INTEGER[] DEFAULT ARRAY[90, 180], -- Days before expiry to send reminders created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(), UNIQUE(client_id) ); -- RLS for notification preferences ALTER TABLE client_notification_preferences ENABLE ROW LEVEL SECURITY; CREATE POLICY "Service role full access to client_notification_preferences" ON client_notification_preferences FOR ALL TO service_role USING (true) WITH CHECK (true); -- Add some helpful comments COMMENT ON TABLE clients IS 'Client accounts - customers who can view their FDA registrations'; COMMENT ON TABLE client_sessions IS 'Custom session management for client authentication'; COMMENT ON TABLE client_notification_preferences IS 'Notification settings for each client'; COMMENT ON COLUMN fda_registrations.client_id IS 'Links registration to a client account'; [V0_FILE]sql:file="scripts/024_add_client_to_fda_registrations.sql" isMerged="true" -- Add client_id to FDA Registrations -- Liên kết mỗi FDA registration với một client account -- Add client_id column ALTER TABLE fda_registrations ADD COLUMN IF NOT EXISTS client_id UUID REFERENCES clients(id) ON DELETE CASCADE; -- Create index for better query performance CREATE INDEX IF NOT EXISTS idx_fda_registrations_client_id ON fda_registrations(client_id); -- Update RLS policies to include client access DROP POLICY IF EXISTS "Clients can view own FDA registrations" ON fda_registrations; CREATE POLICY "Clients can view own FDA registrations" ON fda_registrations FOR SELECT USING ( client_id IN ( SELECT id FROM clients WHERE email = current_setting('request.jwt.claim.email', true) ) ); -- Allow service role full access ALTER TABLE fda_registrations ENABLE ROW LEVEL SECURITY; DROP POLICY IF EXISTS "Service role has full access to FDA registrations" ON fda_registrations; CREATE POLICY "Service role has full access to FDA registrations" ON fda_registrations FOR ALL USING (true) WITH CHECK (true); COMMENT ON COLUMN fda_registrations.client_id IS 'Links FDA registration to a client account'; [V0_FILE]typescript:file="scripts/import-knowledge-base.ts" isMerged="true" import { createClient } from "@supabase/supabase-js" import * as fs from "fs" import * as path from "path" // Initialize Supabase client const supabaseUrl = process.env.NEXT_PUBLIC_SUPABASE_URL! const supabaseServiceKey = process.env.SUPABASE_SERVICE_ROLE_KEY! if (!supabaseUrl || !supabaseServiceKey) { console.error("❌ Missing Supabase credentials") process.exit(1) } const supabase = createClient(supabaseUrl, supabaseServiceKey) // Category mapping based on filename const categoryMapping: Record = { fda: "Pháp lý Hoa Kỳ", gacc: "Pháp lý Trung Quốc", mfds: "Pháp lý Hàn Quốc", "export-delegation": "Xuất khẩu", "ai-traceability": "Công nghệ", "us-agent": "Dịch vụ Hoa Kỳ", } // Clean markdown content function cleanMarkdownContent(content: string): string { let cleaned = content // Remove markdown formatting but keep structure cleaned = cleaned.replace(/^#{1,6}\s+/gm, "") // Remove heading markers but keep text cleaned = cleaned.replace(/\*\*(.+?)\*\*/g, "$1") // Remove bold cleaned = cleaned.replace(/\*(.+?)\*/g, "$1") // Remove italic cleaned = cleaned.replace(/\[(.+?)\]$.+?$/g, "$1") // Remove links but keep text cleaned = cleaned.replace(/`(.+?)`/g, "$1") // Remove inline code cleaned = cleaned.replace(/^```[\s\S]*?```$/gm, "") // Remove code blocks cleaned = cleaned.replace(/^[>\-\*\+]\s+/gm, "") // Remove list markers cleaned = cleaned.replace(/^\|.+\|$/gm, "") // Remove tables cleaned = cleaned.replace(/^[\-=]+$/gm, "") // Remove horizontal rules // Clean up multiple newlines cleaned = cleaned.replace(/\n{3,}/g, "\n\n") // Trim whitespace cleaned = cleaned.trim() return cleaned } // Extract category from filename function getCategoryFromFilename(filename: string): string { const baseName = path.basename(filename, ".md") for (const [key, category] of Object.entries(categoryMapping)) { if (baseName.includes(key)) { return category } } return "Kiến thức chung" } // Extract title from filename function getTitleFromFilename(filename: string): string { const baseName = path.basename(filename, ".md") // Convert kebab-case to Title Case return baseName .split("-") .map((word) => word.charAt(0).toUpperCase() + word.slice(1)) .join(" ") .replace("Fda", "FDA") .replace("Gacc", "GACC") .replace("Mfds", "MFDS") .replace("Ai", "AI") .replace("Us", "US") } // Extract tags from content function extractTags(content: string): string[] { const tags: string[] = [] // Common keywords to tag const keywords = [ "FDA", "GACC", "MFDS", "xuất khẩu", "nhập khẩu", "đăng ký", "cơ sở", "kiểm dịch", "nhãn mác", "prior notice", "truy xuất nguồn gốc", ] const lowerContent = content.toLowerCase() for (const keyword of keywords) { if (lowerContent.includes(keyword.toLowerCase())) { tags.push(keyword) } } return [...new Set(tags)] // Remove duplicates } // Process document into chunks async function processDocumentChunks( documentId: string, content: string ): Promise { try { // Split content into chunks by double newlines (paragraphs) const paragraphs = content.split(/\n\n+/).filter((p) => p.trim().length > 50) // Create chunks with overlap for better context const chunks: any[] = [] const chunkSize = 3 // Number of paragraphs per chunk const overlap = 1 // Overlap between chunks for (let i = 0; i < paragraphs.length; i += chunkSize - overlap) { const chunkParagraphs = paragraphs.slice(i, i + chunkSize) const chunkText = chunkParagraphs.join("\n\n") if (chunkText.trim().length > 50) { chunks.push({ document_id: documentId, chunk_text: chunkText.trim(), chunk_index: Math.floor(i / (chunkSize - overlap)), metadata: { paragraph_count: chunkParagraphs.length, char_count: chunkText.length, }, }) } } console.log(` 📦 Creating ${chunks.length} chunks...`) // Insert chunks in batches const batchSize = 10 for (let i = 0; i < chunks.length; i += batchSize) { const batch = chunks.slice(i, i + batchSize) const { error } = await supabase.from("knowledge_chunks").insert(batch) if (error) { console.error(` ❌ Error inserting batch ${i / batchSize + 1}:`, error) throw error } } return chunks.length } catch (error) { console.error(" ❌ Error processing chunks:", error) throw error } } // Import a single markdown file async function importMarkdownFile(filePath: string): Promise { try { console.log(`\n📄 Processing: ${path.basename(filePath)}`) // Read file content const rawContent = fs.readFileSync(filePath, "utf-8") // Extract metadata const title = getTitleFromFilename(filePath) const category = getCategoryFromFilename(filePath) const cleanedContent = cleanMarkdownContent(rawContent) const tags = extractTags(cleanedContent) console.log(` 📝 Title: ${title}`) console.log(` 🏷️ Category: ${category}`) console.log(` 🔖 Tags: ${tags.join(", ")}`) // Check if document already exists const { data: existing } = await supabase .from("knowledge_documents") .select("id") .eq("title", title) .maybeSingle() if (existing) { console.log(` ⚠️ Document already exists, skipping...`) return } // Insert document const { data: document, error: docError } = await supabase .from("knowledge_documents") .insert({ title, content: cleanedContent, category, tags, source_url: `file://${path.basename(filePath)}`, status: "processing", }) .select() .single() if (docError) { console.error(` ❌ Error creating document:`, docError) throw docError } console.log(` ✅ Document created: ${document.id}`) // Process chunks const chunkCount = await processDocumentChunks(document.id, cleanedContent) // Update document status await supabase .from("knowledge_documents") .update({ status: "active" }) .eq("id", document.id) console.log(` ✅ Complete! ${chunkCount} chunks created`) } catch (error) { console.error(` ❌ Error importing file:`, error) throw error } } // Main import function async function importAllKnowledgeFiles() { console.log("🚀 Starting Knowledge Base Import...") console.log("=" .repeat(50)) const knowledgeDir = path.join(process.cwd(), "knowledge") if (!fs.existsSync(knowledgeDir)) { console.error("❌ Knowledge directory not found:", knowledgeDir) process.exit(1) } // Get all .md files const files = fs .readdirSync(knowledgeDir) .filter((file) => file.endsWith(".md")) .map((file) => path.join(knowledgeDir, file)) console.log(`📁 Found ${files.length} markdown files`) let successCount = 0 let errorCount = 0 for (const file of files) { try { await importMarkdownFile(file) successCount++ } catch (error) { errorCount++ console.error(`❌ Failed to import ${path.basename(file)}`) } } console.log("\n" + "=".repeat(50)) console.log("📊 Import Summary:") console.log(` ✅ Success: ${successCount}`) console.log(` ❌ Errors: ${errorCount}`) console.log("=" .repeat(50)) if (errorCount === 0) { console.log("🎉 All files imported successfully!") } else { console.log("⚠️ Some files failed to import") } } // Run import importAllKnowledgeFiles() .then(() => { console.log("\n✅ Import process completed") process.exit(0) }) .catch((error) => { console.error("\n❌ Import process failed:", error) process.exit(1) }) [V0_FILE]typescript:file="scripts/import-wordpress-posts.ts" isMerged="true" import { createClient } from "@supabase/supabase-js" import { readFileSync } from "fs" import { parseStringPromise } from "xml2js" import { JSDOM } from "jsdom" const supabaseUrl = process.env.SUPABASE_URL! const supabaseServiceKey = process.env.SUPABASE_SERVICE_ROLE_KEY! const supabase = createClient(supabaseUrl, supabaseServiceKey) interface WordPressPost { title: string link: string pubDate: string "content:encoded": string "excerpt:encoded"?: string "wp:post_id": string "wp:post_date": string "wp:post_name": string "wp:status": string "wp:post_type": string category?: Array<{ _: string; $?: { domain?: string; nicename?: string } }> } // Clean HTML content and extract plain text for excerpt function cleanHtmlContent(html: string): { content: string; excerpt: string } { const dom = new JSDOM(html) const document = dom.window.document // Remove WordPress block comments let cleanedHtml = html.replace(//g, "") cleanedHtml = cleanedHtml.replace(//g, "") // Extract plain text for excerpt (first 200 characters) const textContent = document.body.textContent || "" const excerpt = textContent.trim().substring(0, 200).replace(/\s+/g, " ").trim() + "..." return { content: cleanedHtml.trim(), excerpt, } } // Generate slug from title function generateSlug(title: string): string { return title .toLowerCase() .normalize("NFD") .replace(/[\u0300-\u036f]/g, "") // Remove diacritics .replace(/đ/g, "d") .replace(/[^a-z0-9\s-]/g, "") .replace(/\s+/g, "-") .replace(/-+/g, "-") .trim() } // Extract category from WordPress categories function extractCategory(categories?: Array): string { if (!categories || categories.length === 0) return "Chưa phân loại" // Find the first category with domain 'category' const category = categories.find((cat) => cat.$ && cat.$.domain === "category") if (category && category._) { return category._ } return "Chưa phân loại" } // Parse WordPress XML and import to Supabase async function importWordPressXml(filePath: string) { console.log(`[v0] Reading XML file: ${filePath}`) try { const xmlContent = readFileSync(filePath, "utf-8") const result = await parseStringPromise(xmlContent) const items = result.rss.channel[0].item || [] console.log(`[v0] Found ${items.length} items in XML`) let importedCount = 0 let skippedCount = 0 for (const item of items) { // Only import posts (skip pages, attachments, etc) const postType = item["wp:post_type"]?.[0] if (postType !== "post") { console.log(`[v0] Skipping non-post item: ${postType}`) skippedCount++ continue } // Only import published posts const status = item["wp:status"]?.[0] if (status !== "publish") { console.log(`[v0] Skipping non-published post: ${status}`) skippedCount++ continue } const title = item.title?.[0] || "Untitled" const wordpressId = Number.parseInt(item["wp:post_id"]?.[0] || "0") const wordpressUrl = item.link?.[0] || "" const rawContent = item["content:encoded"]?.[0] || "" const publishedAt = item["pubDate"]?.[0] || item["wp:post_date"]?.[0] const slug = item["wp:post_name"]?.[0] || generateSlug(title) const category = extractCategory(item.category) // Clean HTML content const { content, excerpt } = cleanHtmlContent(rawContent) // Check if post already exists const { data: existingPost } = await supabase.from("posts").select("id").eq("wordpress_id", wordpressId).single() if (existingPost) { console.log(`[v0] Post already exists: ${title} (ID: ${wordpressId})`) skippedCount++ continue } // Insert post const { data, error } = await supabase.from("posts").insert({ wordpress_id: wordpressId, title, slug, excerpt, content, category, status: "published", published_at: new Date(publishedAt).toISOString(), wordpress_url: wordpressUrl, meta_title: title, meta_description: excerpt, created_at: new Date().toISOString(), updated_at: new Date().toISOString(), }) if (error) { console.error(`[v0] Error importing post "${title}":`, error) } else { console.log(`[v0] Imported: ${title}`) importedCount++ } } console.log(`\n[v0] Import completed!`) console.log(`[v0] Imported: ${importedCount} posts`) console.log(`[v0] Skipped: ${skippedCount} items`) } catch (error) { console.error("[v0] Error parsing XML:", error) throw error } } // Main execution async function main() { const xmlFiles = [ "user_read_only_context/text_attachments/ngkgacc-fdahtrxutkhutrngi.WordPress.2026-01-14-E5EY3.xml", "user_read_only_context/text_attachments/ngkgacc-fdahtrxutkhutrngi.WordPress.2026-01-14-(1)-esWRX.xml", "user_read_only_context/text_attachments/ngkgacc-fdahtrxutkhutrngi.WordPress.2026-01-14-(2)-P2aMk.xml", ] for (const xmlFile of xmlFiles) { console.log(`\n[v0] Processing: ${xmlFile}`) await importWordPressXml(xmlFile) } console.log("\n[v0] All files processed successfully!") } main().catch(console.error) [V0_FILE]python:file="scripts/migrate_wordpress.py" isMerged="true" """ Script migration WordPress sang Supabase cho Vexim Global Cách sử dụng: 1. Export dữ liệu từ WordPress: - Đăng nhập WordPress admin - Tools → Export → All Content → Download Export File - Giải nén file XML 2. Hoặc truy cập database trực tiếp: - Export bảng wp_posts từ MySQL/phpMyAdmin - Lưu thành CSV hoặc sử dụng script này với connection string 3. Chạy script: python scripts/migrate_wordpress.py --source wordpress_export.xml Lưu ý: Script này giữ nguyên URL cũ trong trường wordpress_url để setup 301 redirect """ import re import xml.etree.ElementTree as ET from datetime import datetime import os # Giả lập - trong thực tế sẽ kết nối Supabase def clean_html(content): """Làm sạch HTML từ WordPress""" # Chuyển WordPress shortcodes content = re.sub(r'\[caption[^\]]*\](.*?)\[/caption\]', r'\1', content) # Giữ nguyên HTML tags cơ bản return content def slugify(text): """Tạo slug từ tiêu đề tiếng Việt""" text = text.lower() text = re.sub(r'[àáạảãâầấậẩẫăằắặẳẵ]', 'a', text) text = re.sub(r'[èéẹẻẽêềếệểễ]', 'e', text) text = re.sub(r'[ìíịỉĩ]', 'i', text) text = re.sub(r'[òóọỏõôồốộổỗơờớợởỡ]', 'o', text) text = re.sub(r'[ùúụủũưừứựửữ]', 'u', text) text = re.sub(r'[ỳýỵỷỹ]', 'y', text) text = re.sub(r'đ', 'd', text) text = re.sub(r'[^a-z0-9]+', '-', text) return text.strip('-') def parse_wordpress_xml(xml_file): """Parse WordPress export XML""" tree = ET.parse(xml_file) root = tree.getroot() # WordPress XML namespace ns = { 'content': 'http://purl.org/rss/1.0/modules/content/', 'wp': 'http://wordpress.org/export/1.2/', 'excerpt': 'http://wordpress.org/export/1.2/excerpt/' } posts = [] for item in root.findall('.//item'): post_type = item.find('wp:post_type', ns) # Chỉ lấy post, bỏ qua page và attachment if post_type is not None and post_type.text == 'post': title = item.find('title').text content = item.find('content:encoded', ns).text or '' excerpt = item.find('excerpt:encoded', ns).text or '' pub_date = item.find('pubDate').text post_id = item.find('wp:post_id', ns).text status = item.find('wp:status', ns).text # Lấy category categories = [cat.text for cat in item.findall('category[@domain="category"]')] category = categories[0] if categories else 'Tin tức' # Parse date pub_datetime = datetime.strptime(pub_date, '%a, %d %b %Y %H:%M:%S %z') # Lấy featured image nếu có thumbnail = item.find('wp:thumbnail_url', ns) featured_image = thumbnail.text if thumbnail is not None else '' # Tạo slug từ title original_slug = item.find('wp:post_name', ns) slug = original_slug.text if original_slug is not None and original_slug.text else slugify(title) posts.append({ 'wordpress_id': int(post_id), 'title': title, 'slug': slug, 'excerpt': excerpt[:500] if excerpt else content[:200], 'content': clean_html(content), 'category': category, 'featured_image': featured_image, 'status': 'published' if status == 'publish' else 'draft', 'published_at': pub_datetime.isoformat(), 'wordpress_url': f'https://vexim.vn/blog/{slug}', 'meta_title': title, 'meta_description': excerpt[:160] if excerpt else content[:160] }) return posts def generate_sql_insert(posts): """Tạo SQL INSERT statements cho Supabase""" sql_statements = [] for post in posts: sql = f""" INSERT INTO public.posts ( wordpress_id, title, slug, excerpt, content, category, featured_image, status, published_at, wordpress_url, meta_title, meta_description ) VALUES ( {post['wordpress_id']}, '{post['title'].replace("'", "''")}', '{post['slug']}', '{post['excerpt'].replace("'", "''")}', '{post['content'].replace("'", "''")}', '{post['category']}', '{post['featured_image']}', '{post['status']}', '{post['published_at']}', '{post['wordpress_url']}', '{post['meta_title'].replace("'", "''")}', '{post['meta_description'].replace("'", "''")}' ) ON CONFLICT (wordpress_id) DO UPDATE SET title = EXCLUDED.title, content = EXCLUDED.content, updated_at = NOW(); """ sql_statements.append(sql) return '\n\n'.join(sql_statements) # Main execution if __name__ == '__main__': print("🚀 WordPress to Supabase Migration Tool for Vexim Global") print("=" * 60) # Giả lập cho demo - thực tế sẽ nhận file từ command line print(""" Hướng dẫn sử dụng: 1. Export từ WordPress admin panel hoặc database 2. Chạy script này với file XML hoặc CSV 3. Script sẽ tự động: ✓ Giữ nguyên slug cũ để không ảnh hưởng SEO ✓ Lưu wordpress_id và wordpress_url để setup 301 redirect ✓ Làm sạch HTML và format nội dung ✓ Tạo meta tags tự động nếu chưa có 4. Output: File SQL để chạy trong Supabase Ví dụ: python scripts/migrate_wordpress.py --source wordpress_export.xml python scripts/migrate_wordpress.py --db mysql://user:pass@host/vexim_db """) print("\n✅ Script đã sẵn sàng. Chỉnh sửa đường dẫn file và chạy!") [V0_FILE]markdown:file="scripts/README-WORDPRESS-IMPORT.md" isMerged="true" # Hướng dẫn Import Bài viết từ WordPress Script này giúp bạn import dữ liệu bài viết từ WordPress XML export vào Supabase database với tính năng làm sạch và chuẩn hóa dữ liệu tự động. ## Tính năng ✅ **Parse WordPress XML** - Đọc và phân tích cú pháp file WordPress export ✅ **Làm sạch HTML** - Loại bỏ WordPress block comments và HTML không cần thiết ✅ **Tạo excerpt tự động** - Trích xuất 200 ký tự đầu từ nội dung ✅ **Tạo slug SEO-friendly** - Chuyển đổi tiêu đề thành URL slug chuẩn ✅ **Phân loại category** - Tự động gán category từ WordPress ✅ **Chống duplicate** - Kiểm tra và bỏ qua bài viết đã tồn tại ✅ **Chỉ import published posts** - Bỏ qua draft, pages, attachments ## Chuẩn bị ### 1. Xuất dữ liệu từ WordPress Trong WordPress Admin: 1. Vào **Tools → Export** 2. Chọn **Posts** hoặc **All content** 3. Click **Download Export File** 4. Lưu file XML ### 2. Upload file XML Đặt file XML vào thư mục `user_read_only_context/text_attachments/` ### 3. Kiểm tra Environment Variables Đảm bảo các biến môi trường sau đã được cấu hình: - `SUPABASE_URL` - `SUPABASE_SERVICE_ROLE_KEY` ## Cách sử dụng ### Chạy import Trong terminal v0, chạy lệnh: \`\`\`bash npm run import:wordpress \`\`\` Hoặc nếu bạn muốn test với một file cụ thể, sửa mảng `xmlFiles` trong file `scripts/import-wordpress-posts.ts`: \`\`\`typescript const xmlFiles = [ "user_read_only_context/text_attachments/your-export-file.xml", ] \`\`\` ## Quá trình xử lý Script sẽ tự động: 1. **Đọc file XML** - Parse toàn bộ cấu trúc WordPress export 2. **Lọc nội dung** - Chỉ xử lý `post` type với status `publish` 3. **Làm sạch dữ liệu**: - Loại bỏ WordPress block comments (`/g, "") cleanedHtml = cleanedHtml.replace(//g, "") // Extract plain text for excerpt (first 200 characters) const textContent = document.body.textContent || "" const excerpt = textContent.trim().substring(0, 200).replace(/\s+/g, " ").trim() + "..." return { content: cleanedHtml.trim(), excerpt, } } // Generate slug from title function generateSlug(title: string): string { return title .toLowerCase() .normalize("NFD") .replace(/[\u0300-\u036f]/g, "") // Remove diacritics .replace(/đ/g, "d") .replace(/[^a-z0-9\s-]/g, "") .replace(/\s+/g, "-") .replace(/-+/g, "-") .trim() } // Extract category from WordPress categories function extractCategory(categories?: Array): string { if (!categories || categories.length === 0) return "Chưa phân loại" // Find the first category with domain 'category' const category = categories.find((cat) => cat.$ && cat.$.domain === "category") if (category && category._) { return category._ } return "Chưa phân loại" } // Parse WordPress XML and import to Supabase async function importWordPressXml(filePath: string) { console.log(`[v0] Reading XML file: ${filePath}`) try { const xmlContent = readFileSync(filePath, "utf-8") const result = await parseStringPromise(xmlContent) const items = result.rss.channel[0].item || [] console.log(`[v0] Found ${items.length} items in XML`) let importedCount = 0 let skippedCount = 0 for (const item of items) { // Only import posts (skip pages, attachments, etc) const postType = item["wp:post_type"]?.[0] if (postType !== "post") { console.log(`[v0] Skipping non-post item: ${postType}`) skippedCount++ continue } // Only import published posts const status = item["wp:status"]?.[0] if (status !== "publish") { console.log(`[v0] Skipping non-published post: ${status}`) skippedCount++ continue } const title = item.title?.[0] || "Untitled" const wordpressId = Number.parseInt(item["wp:post_id"]?.[0] || "0") const wordpressUrl = item.link?.[0] || "" const rawContent = item["content:encoded"]?.[0] || "" const publishedAt = item["pubDate"]?.[0] || item["wp:post_date"]?.[0] const slug = item["wp:post_name"]?.[0] || generateSlug(title) const category = extractCategory(item.category) // Clean HTML content const { content, excerpt } = cleanHtmlContent(rawContent) // Check if post already exists const { data: existingPost } = await supabase.from("posts").select("id").eq("wordpress_id", wordpressId).single() if (existingPost) { console.log(`[v0] Post already exists: ${title} (ID: ${wordpressId})`) skippedCount++ continue } // Insert post const { data, error } = await supabase.from("posts").insert({ wordpress_id: wordpressId, title, slug, excerpt, content, category, status: "published", published_at: new Date(publishedAt).toISOString(), wordpress_url: wordpressUrl, meta_title: title, meta_description: excerpt, created_at: new Date().toISOString(), updated_at: new Date().toISOString(), }) if (error) { console.error(`[v0] Error importing post "${title}":`, error) } else { console.log(`[v0] Imported: ${title}`) importedCount++ } } console.log(`\n[v0] Import completed!`) console.log(`[v0] Imported: ${importedCount} posts`) console.log(`[v0] Skipped: ${skippedCount} items`) } catch (error) { console.error("[v0] Error parsing XML:", error) throw error } } // Main execution async function main() { const xmlFiles = [ "user_read_only_context/text_attachments/ngkgacc-fdahtrxutkhutrngi.WordPress.2026-01-14-E5EY3.xml", "user_read_only_context/text_attachments/ngkgacc-fdahtrxutkhutrngi.WordPress.2026-01-14-(1)-esWRX.xml", "user_read_only_context/text_attachments/ngkgacc-fdahtrxutkhutrngi.WordPress.2026-01-14-(2)-P2aMk.xml", ] for (const xmlFile of xmlFiles) { console.log(`\n[v0] Processing: ${xmlFile}`) await importWordPressXml(xmlFile) } console.log("\n[v0] All files processed successfully!") } main().catch(console.error) [V0_FILE]python:file="scripts/migrate_wordpress.py" isMerged="true" """ Script migration WordPress sang Supabase cho Vexim Global Cách sử dụng: 1. Export dữ liệu từ WordPress: - Đăng nhập WordPress admin - Tools → Export → All Content → Download Export File - Giải nén file XML 2. Hoặc truy cập database trực tiếp: - Export bảng wp_posts từ MySQL/phpMyAdmin - Lưu thành CSV hoặc sử dụng script này với connection string 3. Chạy script: python scripts/migrate_wordpress.py --source wordpress_export.xml Lưu ý: Script này giữ nguyên URL cũ trong trường wordpress_url để setup 301 redirect """ import re import xml.etree.ElementTree as ET from datetime import datetime import os # Giả lập - trong thực tế sẽ kết nối Supabase def clean_html(content): """Làm sạch HTML từ WordPress""" # Chuyển WordPress shortcodes content = re.sub(r'\[caption[^\]]*\](.*?)\[/caption\]', r'\1', content) # Giữ nguyên HTML tags cơ bản return content def slugify(text): """Tạo slug từ tiêu đề tiếng Việt""" text = text.lower() text = re.sub(r'[àáạảãâầấậẩẫăằắặẳẵ]', 'a', text) text = re.sub(r'[èéẹẻẽêềếệểễ]', 'e', text) text = re.sub(r'[ìíịỉĩ]', 'i', text) text = re.sub(r'[òóọỏõôồốộổỗơờớợởỡ]', 'o', text) text = re.sub(r'[ùúụủũưừứựửữ]', 'u', text) text = re.sub(r'[ỳýỵỷỹ]', 'y', text) text = re.sub(r'đ', 'd', text) text = re.sub(r'[^a-z0-9]+', '-', text) return text.strip('-') def parse_wordpress_xml(xml_file): """Parse WordPress export XML""" tree = ET.parse(xml_file) root = tree.getroot() # WordPress XML namespace ns = { 'content': 'http://purl.org/rss/1.0/modules/content/', 'wp': 'http://wordpress.org/export/1.2/', 'excerpt': 'http://wordpress.org/export/1.2/excerpt/' } posts = [] for item in root.findall('.//item'): post_type = item.find('wp:post_type', ns) # Chỉ lấy post, bỏ qua page và attachment if post_type is not None and post_type.text == 'post': title = item.find('title').text content = item.find('content:encoded', ns).text or '' excerpt = item.find('excerpt:encoded', ns).text or '' pub_date = item.find('pubDate').text post_id = item.find('wp:post_id', ns).text status = item.find('wp:status', ns).text # Lấy category categories = [cat.text for cat in item.findall('category[@domain="category"]')] category = categories[0] if categories else 'Tin tức' # Parse date pub_datetime = datetime.strptime(pub_date, '%a, %d %b %Y %H:%M:%S %z') # Lấy featured image nếu có thumbnail = item.find('wp:thumbnail_url', ns) featured_image = thumbnail.text if thumbnail is not None else '' # Tạo slug từ title original_slug = item.find('wp:post_name', ns) slug = original_slug.text if original_slug is not None and original_slug.text else slugify(title) posts.append({ 'wordpress_id': int(post_id), 'title': title, 'slug': slug, 'excerpt': excerpt[:500] if excerpt else content[:200], 'content': clean_html(content), 'category': category, 'featured_image': featured_image, 'status': 'published' if status == 'publish' else 'draft', 'published_at': pub_datetime.isoformat(), 'wordpress_url': f'https://vexim.vn/blog/{slug}', 'meta_title': title, 'meta_description': excerpt[:160] if excerpt else content[:160] }) return posts def generate_sql_insert(posts): """Tạo SQL INSERT statements cho Supabase""" sql_statements = [] for post in posts: sql = f""" INSERT INTO public.posts ( wordpress_id, title, slug, excerpt, content, category, featured_image, status, published_at, wordpress_url, meta_title, meta_description ) VALUES ( {post['wordpress_id']}, '{post['title'].replace("'", "''")}', '{post['slug']}', '{post['excerpt'].replace("'", "''")}', '{post['content'].replace("'", "''")}', '{post['category']}', '{post['featured_image']}', '{post['status']}', '{post['published_at']}', '{post['wordpress_url']}', '{post['meta_title'].replace("'", "''")}', '{post['meta_description'].replace("'", "''")}' ) ON CONFLICT (wordpress_id) DO UPDATE SET title = EXCLUDED.title, content = EXCLUDED.content, updated_at = NOW(); """ sql_statements.append(sql) return '\n\n'.join(sql_statements) # Main execution if __name__ == '__main__': print("🚀 WordPress to Supabase Migration Tool for Vexim Global") print("=" * 60) # Giả lập cho demo - thực tế sẽ nhận file từ command line print(""" Hướng dẫn sử dụng: 1. Export từ WordPress admin panel hoặc database 2. Chạy script này với file XML hoặc CSV 3. Script sẽ tự động: ✓ Giữ nguyên slug cũ để không ảnh hưởng SEO ✓ Lưu wordpress_id và wordpress_url để setup 301 redirect ✓ Làm sạch HTML và format nội dung ✓ Tạo meta tags tự động nếu chưa có 4. Output: File SQL để chạy trong Supabase Ví dụ: python scripts/migrate_wordpress.py --source wordpress_export.xml python scripts/migrate_wordpress.py --db mysql://user:pass@host/vexim_db """) print("\n✅ Script đã sẵn sàng. Chỉnh sửa đường dẫn file và chạy!") [V0_FILE]markdown:file="scripts/README-WORDPRESS-IMPORT.md" isMerged="true" # Hướng dẫn Import Bài viết từ WordPress Script này giúp bạn import dữ liệu bài viết từ WordPress XML export vào Supabase database với tính năng làm sạch và chuẩn hóa dữ liệu tự động. ## Tính năng ✅ **Parse WordPress XML** - Đọc và phân tích cú pháp file WordPress export ✅ **Làm sạch HTML** - Loại bỏ WordPress block comments và HTML không cần thiết ✅ **Tạo excerpt tự động** - Trích xuất 200 ký tự đầu từ nội dung ✅ **Tạo slug SEO-friendly** - Chuyển đổi tiêu đề thành URL slug chuẩn ✅ **Phân loại category** - Tự động gán category từ WordPress ✅ **Chống duplicate** - Kiểm tra và bỏ qua bài viết đã tồn tại ✅ **Chỉ import published posts** - Bỏ qua draft, pages, attachments ## Chuẩn bị ### 1. Xuất dữ liệu từ WordPress Trong WordPress Admin: 1. Vào **Tools → Export** 2. Chọn **Posts** hoặc **All content** 3. Click **Download Export File** 4. Lưu file XML ### 2. Upload file XML Đặt file XML vào thư mục `user_read_only_context/text_attachments/` ### 3. Kiểm tra Environment Variables Đảm bảo các biến môi trường sau đã được cấu hình: - `SUPABASE_URL` - `SUPABASE_SERVICE_ROLE_KEY` ## Cách sử dụng ### Chạy import Trong terminal v0, chạy lệnh: \`\`\`bash npm run import:wordpress \`\`\` Hoặc nếu bạn muốn test với một file cụ thể, sửa mảng `xmlFiles` trong file `scripts/import-wordpress-posts.ts`: \`\`\`typescript const xmlFiles = [ "user_read_only_context/text_attachments/your-export-file.xml", ] \`\`\` ## Quá trình xử lý Script sẽ tự động: 1. **Đọc file XML** - Parse toàn bộ cấu trúc WordPress export 2. **Lọc nội dung** - Chỉ xử lý `post` type với status `publish` 3. **Làm sạch dữ liệu**: - Loại bỏ WordPress block comments (`

Tổng quan về đăng ký FDA 2026

Những thay đổi quan trọng

Cách thức tuân thủ

Quy trình GACC mới 2026

Thị trường EU - Cơ hội và thách thức

Đã nhận hồ sơ đánh giá GACC

Kính gửi ${params.companyName},

📋 Thông tin hồ sơ

📌 Các bước tiếp theo

🔔 HỒ SƠ GACC MỚI

Hồ sơ đánh giá GACC mới từ khách hàng

🛡️ Xác nhận đăng ký FDA Tracker

Chào mừng bạn đến với Vexim Global FDA Tracker!

Bạn sẽ nhận được:

${alert.title}

🚨 ${title}

${alertCount}

${alerts.length}

${alerts.filter((a) => a.classification?.includes("I")).length}

📋 Cảnh báo nổi bật

💡 Lưu ý quan trọng

🚨 CẢNH BÁO FDA KHẨN CẤP

${alert.title}

🤖 Tóm tắt AI

✅ Đã hủy đăng ký thành công

Title

🔔 Thông Báo Khách Hàng Mới

Tại sao cần đăng ký FDA?

Quy trình đăng ký FDA

Mã GACC là gì?

Sản phẩm nào cần mã GACC?

FSMA 204 là gì?

Danh sách Food Traceability List (FTL)