feat: integrate chatbot's ability to create task

Author: tqha1011

src/lib/features/chatbot/services/chatbot_services.dart

@@ -41,6 +41,21 @@ class ChatBotAssistantService {
                     description:
                         'Danh sách các thẻ phân loại (ví dụ: ["Học tập", "Gấp", "Backend"]). Gửi mảng rỗng [] nếu không có.',
                   ),
+                  'start_time': Schema(
+                    SchemaType.string,
+                    description:
+                        'Thời gian bắt đầu công việc theo định dạng ISO 8601 (VD: 2026-04-18T15:00:00Z). Nếu người dùng không nói, hãy bỏ qua hoặc để rỗng.',
+                  ),
+                  'due_time': Schema(
+                    SchemaType.string,
+                    description:
+                        'Thời gian kết thúc (deadline) theo định dạng ISO 8601. Nếu không có, bỏ qua.',
+                  ),
+                  'category_name': Schema(
+                    SchemaType.string,
+                    description:
+                        'Phân loại công việc vào 1 trong 4 nhóm: "Cá nhân", "Học tập", "Công việc", hoặc "Giải trí". Nếu không phân loại được, mặc định trả về "Cá nhân".',
+                  ),
                 },
                 requiredProperties: ['title', 'priority', 'tags'],
               ),
@@ -77,26 +92,38 @@ class ChatBotAssistantService {
           final priority = (args['priority'] as num?)?.toInt() ?? 1;
           final rawTags = args['tags'] as List<dynamic>? ?? [];
           final tags = rawTags.map((e) => e.toString()).toList();
+          final startTime = args['start_time'] as String?;
+          final dueTime = args['due_time'] as String?;
 
           final userId = Supabase.instance.client.auth.currentUser?.id;
           if (userId == null) {
             return 'Vui lòng đăng nhập để tạo công việc.';
           }
-
+          final categoryName = args['category_name'] as String? ?? 'Cá nhân';
           final dbResponse = await Supabase.instance.client.rpc(
             'create_task_full',
             params: {
-              'p_title': title,
-              'p_priority': priority,
+              'p_title': args['title'],
+              'p_priority': (args['priority'] as num?)?.toInt() ?? 1,
               'p_profile_id': userId,
-              'p_tag_names': tags,
+              'p_tag_names':
+                  (args['tags'] as List?)?.map((e) => e.toString()).toList() ??
+                  [],
+              'p_category_name': categoryName,
+              'p_start_time': args['start_time'],
+              'p_due_time': args['due_time'],
             },
           );
 
           final isSuccess = dbResponse['success'] == true;
+          if (!isSuccess) {
+            debugPrint("Lỗi từ Supabase: ${dbResponse['error']}");
+          }
           final functionResponse = await _chatSession!.sendMessage(
             Content.functionResponse('create_task_full', {
               'status': isSuccess ? 'Thành công' : 'Thất bại',
+
+              'reason': isSuccess ? '' : dbResponse['error'].toString(),
             }),
           );
           return functionResponse.text ?? 'Đã xử lý xong yêu cầu của bạn!';

supabase/migrations/20260418111957_chatbot_add_task_with_category_rpc.sql

@@ -0,0 +1,64 @@
+CREATE OR REPLACE FUNCTION create_task_full(
+  p_title TEXT,
+  p_priority INT4,
+  p_profile_id UUID,
+  p_tag_names TEXT[],
+  p_category_name TEXT,
+  p_start_time TIMESTAMPTZ default null,
+  p_due_time TIMESTAMPTZ default null
+)
+RETURNS JSON
+LANGUAGE plpgsql
+AS $$
+DECLARE
+  v_task_id INT8;
+  v_tag_name TEXT;
+  v_tag_id INT8;
+  v_category_id INT8;
+BEGIN
+  SELECT id INTO v_category_id
+  FROM category
+  WHERE profile_id = p_profile_id AND name ILIKE p_category_name
+  LIMIT 1;
+
+  IF v_category_id IS NULL THEN
+     SELECT id INTO v_category_id FROM category WHERE profile_id = p_profile_id AND name = 'Cá nhân' LIMIT 1;
+  END IF;
+
+  INSERT INTO task (title, priority, profile_id, status, category_id,start_time,due_time)
+  VALUES (p_title, p_priority, p_profile_id, 0,v_category_id,p_start_time,p_due_time)
+  RETURNING id INTO v_task_id;
+
+  IF p_tag_names IS NOT NULL THEN
+    FOREACH v_tag_name IN ARRAY p_tag_names
+    LOOP
+      v_tag_name := trim(v_tag_name);
+
+      IF v_tag_name != '' THEN
+        INSERT INTO tag (name, profile_id, color_code)
+        VALUES (v_tag_name, p_profile_id, '#6200EE')
+        ON CONFLICT (name, profile_id)
+        DO UPDATE SET name = EXCLUDED.name
+        RETURNING id INTO v_tag_id;
+
+
+        INSERT INTO task_tags (task_id, tag_id)
+        VALUES (v_task_id, v_tag_id)
+        ON CONFLICT DO NOTHING;
+      END IF;
+    END LOOP;
+  END IF;
+
+  RETURN json_build_object(
+    'success', true,
+    'task_id', v_task_id,
+    'message', 'Đã tạo task với priority ' || p_priority
+  );
+
+EXCEPTION WHEN OTHERS THEN
+  RETURN json_build_object(
+    'success', false,
+    'error', SQLERRM
+  );
+END;
+$$;