// Service for handling ClickUp API calls // Configuration for rate limiting and backoff const rateLimitConfig = { maxRetries: 5, initialBackoff: 1000, // 1 second backoffFactor: 2, // Double wait time on each retry maxBackoff: 30000, // Maximum 30 seconds lastRequestTime: 0, // Track the last API request time minTimeBetweenRequests: 100 // Minimum 100ms between requests }; // Cache configuration const cacheConfig = { enabled: true, defaultTTL: 90 * 1000, // 1 minute 30 seconds in milliseconds tasks: { ttl: 90 * 1000, // 1 minute 30 seconds for tasks maxAge: 90 * 1000 // Expire after 1 minute 30 seconds regardless of access }, customFields: { ttl: 90 * 1000, // 1 minute 30 seconds for custom fields maxAge: 90 * 1000 // Expire after 1 minute 30 seconds regardless of access } }; // Simple in-memory cache implementation const cache = { data: new Map(), // Set cache entry with a TTL set(key, value, ttl = cacheConfig.defaultTTL) { if (!cacheConfig.enabled) return; const now = Date.now(); this.data.set(key, { value, timestamp: now, expiry: now + ttl, maxAge: now + (ttl * 2) // Default maxAge is 2x the TTL }); }, // Get cache entry if not expired get(key) { if (!cacheConfig.enabled || !this.data.has(key)) return null; const entry = this.data.get(key); const now = Date.now(); // Check if entry has expired if (now > entry.expiry) { this.data.delete(key); return null; } // Check if entry has exceeded max age (regardless of recent access) if (now > entry.maxAge) { this.data.delete(key); return null; } // Extend expiry time on access, but not maxAge entry.expiry = now + (entry.expiry - entry.timestamp); entry.timestamp = now; return entry.value; }, // Remove a cache entry remove(key) { this.data.delete(key); }, // Clear all cache entries clear() { this.data.clear(); }, // Generate a cache key from parameters generateKey(method, params) { const paramsStr = JSON.stringify(params); return `${method}_${paramsStr}`; } }; export const clickupService = { // Helper method to implement exponential backoff async executeWithBackoff(apiCall, retryCount = 0) { try { // Ensure minimum time between requests const now = Date.now(); const timeSinceLastRequest = now - rateLimitConfig.lastRequestTime; if (timeSinceLastRequest < rateLimitConfig.minTimeBetweenRequests) { const waitTime = rateLimitConfig.minTimeBetweenRequests - timeSinceLastRequest; await new Promise(resolve => setTimeout(resolve, waitTime)); } // Update last request time rateLimitConfig.lastRequestTime = Date.now(); // Execute the API call return await apiCall(); } catch (error) { // Check if error is related to rate limiting const isRateLimit = error.message?.includes('rate limit') || error.message?.includes('429') || error.status === 429; if (isRateLimit && retryCount < rateLimitConfig.maxRetries) { const nextRetry = retryCount + 1; const backoffTime = Math.min( rateLimitConfig.initialBackoff * Math.pow(rateLimitConfig.backoffFactor, retryCount), rateLimitConfig.maxBackoff ); await new Promise(resolve => setTimeout(resolve, backoffTime)); return this.executeWithBackoff(apiCall, nextRetry); } // If not a rate limit error or we've exceeded retries, rethrow throw error; } }, // Get Custom Field IDs from a task async getCustomFieldsFromTask(apiKey, taskId) { if (!apiKey || !taskId) { throw new Error('API Key and Task ID are required'); } const headers = { 'Authorization': apiKey, 'Content-Type': 'application/json' }; try { // Generate cache key for this request const cacheKey = cache.generateKey('getCustomFieldsFromTask', { taskId }); // Check if we have a cached response const cachedData = cache.get(cacheKey); if (cachedData) { return cachedData; } // Use executeWithBackoff to handle rate limiting const response = await this.executeWithBackoff(async () => { const resp = await fetch(`https://api.clickup.com/api/v2/task/${taskId}`, { method: 'GET', headers }); if (!resp.ok) { const status = resp.status; const text = await resp.text(); throw new Error(`Failed to get task details: ${status} - ${text}`); } return resp; }); if (!response.ok) { throw new Error(`Failed to get task details: ${response.status} ${response.statusText}`); } const taskData = await response.json(); // Extract custom fields from the task data const customFields = taskData.custom_fields || []; // Format the custom fields const formattedFields = customFields.map(field => ({ id: field.id, name: field.name, type: field.type, value: field.value })); // Store in cache with the custom fields TTL cache.set(cacheKey, formattedFields, cacheConfig.customFields.ttl); return formattedFields; } catch (error) { throw error; } }, // Fetch full details for a single task async getTaskDetails(apiKey, taskId) { if (!apiKey || !taskId) { throw new Error('API Key and Task ID are required for getTaskDetails'); } const headers = { 'Authorization': apiKey, 'Content-Type': 'application/json' }; const cacheKey = cache.generateKey('getTaskDetails', { taskId }); const cachedTask = cache.get(cacheKey); if (cachedTask) { return cachedTask; } const url = `https://api.clickup.com/api/v2/task/${taskId}`; try { const response = await this.executeWithBackoff(async () => { const resp = await fetch(url, { method: 'GET', headers }); if (!resp.ok) { const status = resp.status; const text = await resp.text(); throw new Error(`Failed to get full task details for ${taskId}: ${status} - ${text}`); } return resp.json(); }); cache.set(cacheKey, response, cacheConfig.tasks.ttl); // Cache the full task details return response; } catch (error) { console.error(`Error fetching full details for task ${taskId}:`, error); throw error; // Re-throw to be handled by the caller } }, // Get data from ClickUp API async fetchData(credentials) { if (!credentials.apiKey) { throw new Error('API Key is required'); } const headers = { 'Authorization': credentials.apiKey, 'Content-Type': 'application/json' }; try { // Get workspace data first if needed if (!credentials.workspace) { const workspaces = await this.getWorkspaces(headers); if (workspaces.length > 0) { credentials.workspace = workspaces[0].id; } else { throw new Error('No workspaces found'); } } // Get data // Initialize stats object to include transformation gems let habitStats = { totalScholarship: 0, totalGiftPoints: 0, totalTransformationGems: 0 // Add Ngọc Chuyển Hóa }; if (credentials.listId) { // Get tasks from a specific list try { const listTasks = await this.executeWithBackoff(async () => { return await this.getTasksFromList(headers, credentials.listId); }); // Process tasks and update the habitStats object habitStats = this.processTasksForStats(listTasks, credentials.taskId); } catch (listError) { throw new Error(`Không thể lấy tasks từ list: ${listError.message}`); } } else { throw new Error('List ID là bắt buộc'); } // Read current balances from the target task if provided if (credentials.targetTaskId && (credentials.scholarshipFieldId || credentials.giftPointsFieldId || credentials.transformationGemsFieldId)) { try { const targetTaskFields = await this.getCustomFieldsFromTask(credentials.apiKey, credentials.targetTaskId); if (credentials.scholarshipFieldId) { const field = targetTaskFields.find(f => f.id === credentials.scholarshipFieldId); if (field) habitStats.scholarshipBalance = this.parseFieldValue(field.value); } if (credentials.giftPointsFieldId) { const field = targetTaskFields.find(f => f.id === credentials.giftPointsFieldId); if (field) habitStats.giftPointsBalance = this.parseFieldValue(field.value); } if (credentials.transformationGemsFieldId) { const field = targetTaskFields.find(f => f.id === credentials.transformationGemsFieldId); if (field) habitStats.transformationGemsBalance = this.parseFieldValue(field.value); // Read Ngọc balance } } catch (fetchBalanceError) { console.warn(`Could not fetch current balances from target task: ${fetchBalanceError.message}`); // Continue without initial balances if fetching fails } } // Trả về kết quả sau khi xử lý return { habitStats: habitStats // Return the updated habitStats }; } catch (error) { throw new Error(`Failed to fetch data from ClickUp: ${error.message}`); } }, // Get workspaces for the user async getWorkspaces(headers) { const response = await fetch('https://api.clickup.com/api/v2/team', { method: 'GET', headers }); if (!response.ok) { throw new Error(`Failed to get workspaces: ${response.status} ${response.statusText}`); } const data = await response.json(); return data.teams || []; }, // Get tasks from a space async getTasksFromSpace(headers, spaceId) { let allTasks = []; try { // Step 1: First get all folders in the space const foldersResponse = await fetch(`https://api.clickup.com/api/v2/space/${spaceId}/folder?archived=false`, { method: 'GET', headers }); if (!foldersResponse.ok) { throw new Error(`Failed to get folders: ${foldersResponse.status} ${foldersResponse.statusText}`); } const foldersData = await foldersResponse.json(); const folders = foldersData.folders || []; // Step 2: Get lists from each folder for (const folder of folders) { try { const folderListsResponse = await fetch(`https://api.clickup.com/api/v2/folder/${folder.id}/list?archived=false`, { method: 'GET', headers }); if (!folderListsResponse.ok) { continue; } const folderListsData = await folderListsResponse.json(); const folderLists = folderListsData.lists || []; // Get tasks from each list in the folder for (const list of folderLists) { try { const tasks = await this.getTasksFromList(headers, list.id); allTasks = [...allTasks, ...tasks]; } catch (error) { console.error(`Error fetching tasks from list ${list.id} in folder:`, error); // Continue with other lists even if one fails } } } catch (error) { console.error(`Error processing folder ${folder.id}:`, error); // Continue with other folders even if one fails } } // Step 3: Get lists that are directly in the space (not in any folder) const listsResponse = await fetch(`https://api.clickup.com/api/v2/space/${spaceId}/list?archived=false`, { method: 'GET', headers }); if (!listsResponse.ok) { throw new Error(`Failed to get lists: ${listsResponse.status} ${listsResponse.statusText}`); } const listsData = await listsResponse.json(); const lists = listsData.lists || []; // Get tasks from each list in the space for (const list of lists) { try { const tasks = await this.getTasksFromList(headers, list.id); allTasks = [...allTasks, ...tasks]; } catch (error) { console.error(`Error fetching tasks from list ${list.id}:`, error); // Continue with other lists even if one fails } } return allTasks; } catch (error) { console.error(`Error fetching data from space ${spaceId}:`, error); throw error; } }, // Get tasks from specific lists async getTasksFromLists(headers, listIds) { // Fetching tasks from specific lists let allTasks = []; let successCount = 0; for (const listId of listIds) { try { // Fetching tasks from list ID const tasks = await this.getTasksFromList(headers, listId); // Retrieved tasks from list allTasks = [...allTasks, ...tasks]; successCount++; } catch (error) { // Error handled silently, continue with other lists // Continue with other lists even if one fails } } // Successfully fetched from lists return allTasks; }, // Get tasks from a single list async getTasksFromList(headers, listId) { // Check cache first const cacheKey = cache.generateKey('getTasksFromList', { listId }); const cachedTasks = cache.get(cacheKey); if (cachedTasks) { return cachedTasks; } // If not in cache, fetch from API // Ensure we get all tasks, not just the first page let allTasks = []; let hasMoreTasks = true; let startIndex = 0; const PAGE_SIZE = 100; while (hasMoreTasks) { // Trying a different parameter: `expand[0]=attachments` or similar for deep inclusion. // ClickUp's API might have a specific way to request nested objects like attachments. // Removing `include_all_attachments=true` as it didn't work. // The `expand` parameter is a common pattern in APIs like Jira, for example. // This is an educated guess. The exact syntax for ClickUp might vary. // Removed order_direction=asc. We will sort manually using orderindex. const url = `https://api.clickup.com/api/v2/list/${listId}/task?archived=false&subtasks=true&include_closed=true&page=${startIndex/PAGE_SIZE}&limit=${PAGE_SIZE}&expand[0]=attachments`; const tasksResponse = await this.executeWithBackoff(async () => { const response = await fetch(url, { method: 'GET', headers }); if (!response.ok) { const status = response.status; const text = await response.text(); throw new Error(`Failed to get tasks: ${status} - ${text}`); } return response; }); if (!tasksResponse.ok) { throw new Error(`Failed to get tasks: ${tasksResponse.status} ${tasksResponse.statusText}`); } const tasksData = await tasksResponse.json(); const tasks = tasksData.tasks || []; allTasks = [...allTasks, ...tasks]; // Check if we need to fetch more pages if (tasks.length < PAGE_SIZE) { hasMoreTasks = false; } else { startIndex += PAGE_SIZE; } } // Sort tasks by orderindex to match manual sorting in ClickUp allTasks.sort((a, b) => { const orderIndexA = parseFloat(a.orderindex); const orderIndexB = parseFloat(b.orderindex); // Handle cases where orderindex might be missing or not a number if (isNaN(orderIndexA) && isNaN(orderIndexB)) return 0; if (isNaN(orderIndexA)) return 1; // Tasks without orderindex go to the end if (isNaN(orderIndexB)) return -1; // Tasks without orderindex go to the end if (orderIndexA < orderIndexB) return -1; if (orderIndexA > orderIndexB) return 1; // Fallback sort by task ID if orderindex is the same if (a.id < b.id) return -1; if (a.id > b.id) return 1; return 0; }); // Store in cache cache.set(cacheKey, allTasks, cacheConfig.tasks.ttl); return allTasks; }, // Cache control functions - exposed for external use cache: { // Invalidate specific cache entries invalidate(method, params) { const key = cache.generateKey(method, params); cache.remove(key); }, // Clear all cached data clearAll() { cache.clear(); }, // Enable or disable caching setEnabled(enabled) { cacheConfig.enabled = enabled; }, // Set TTL for a specific cache category setTTL(category, ttlInSeconds) { if (cacheConfig[category]) { cacheConfig[category].ttl = ttlInSeconds * 1000; } } }, // Process tasks to extract scholarship statistics processTasksForStats(tasks, specifiedTaskId) { // Calculate total scholarship, gift points and balances let totalScholarship = 0; let totalGiftPoints = 0; let totalTransformationGems = 0; // Initialize Ngọc Chuyển Hóa total // Balances will be fetched separately if targetTaskId is provided // Filter main tasks with LADDER status (excluding subtasks) const ladderTasks = tasks.filter(task => { if (!task.status) return false; // Kiểm tra xem có phải subtask không const isSubtask = task.parent !== undefined && task.parent !== null; // Nếu là subtask thì bỏ qua if (isSubtask) return false; // Lấy statusName và đảm bảo nó là string để tránh lỗi let statusName = ''; if (task.status) { if (typeof task.status === 'object' && task.status.status) { statusName = task.status.status.toString().toLowerCase(); } else if (typeof task.status === 'string') { statusName = task.status.toString().toLowerCase(); } else { statusName = ''; } } // Tìm kiếm cụ thể status có chứa "LADDER" const isLadder = statusName.includes('ladder'); return isLadder; }); // Calculate total scholarship value from "Học Bổng" custom field if (ladderTasks.length > 0) { ladderTasks.forEach((task) => { // Find custom field that may contain scholarship with various names if (task.custom_fields && Array.isArray(task.custom_fields)) { const scholarshipField = task.custom_fields.find(field => { // Convert field name to lowercase for case-insensitive comparison const fieldNameLower = field.name.toLowerCase(); // Check with various names that may contain scholarship information const isScholarshipField = fieldNameLower.includes('học bổng') || fieldNameLower.includes('hoc bong') || fieldNameLower.includes('scholarship') || fieldNameLower.includes('tiền') || fieldNameLower.includes('tien') || fieldNameLower === 'số tiền' || fieldNameLower === 'giá trị'; // Only consider numeric or currency fields const isSupportedType = field.type === "number" || field.type === "currency" || field.type === "text" || // Include text as sometimes money values are stored as text field.type === "label"; return isScholarshipField && isSupportedType; }); // Process scholarship field value reliably if (scholarshipField && scholarshipField.value !== null && scholarshipField.value !== undefined) { // Use the existing helper function for consistent parsing let parsedValue = this.parseFieldValue(scholarshipField.value); // Ensure NaN values are treated as 0 before adding to total if (!isNaN(parsedValue)) { totalScholarship += parsedValue; } else { // If parsing results in NaN (e.g., from '-'), treat it as 0 totalScholarship += 0; } } // Removed the part that searches for other numeric fields } }); } // Tính tổng điểm đổi quà từ custom field "Gift Points" if (ladderTasks.length > 0) { ladderTasks.forEach((task, index) => { // Tìm custom field Gift Points if (task.custom_fields && Array.isArray(task.custom_fields)) { // Tìm trường Gift Points const giftPointsField = task.custom_fields.find(field => { // Chuyển tên field sang chữ thường để so sánh không phân biệt hoa thường const fieldNameLower = field.name.toLowerCase(); // Kiểm tra với tên trường Gift Points const isGiftPointsField = fieldNameLower.includes('gift points') || fieldNameLower.includes('gift point') || fieldNameLower.includes('điểm đổi quà') || fieldNameLower.includes('diem doi qua') || fieldNameLower === 'points'; // Chỉ quan tâm đến các trường số const isSupportedType = field.type === "number" || field.type === "currency" || field.type === "text"; return isGiftPointsField && isSupportedType; }); // Process Gift Points value if (giftPointsField && giftPointsField.value !== null && giftPointsField.value !== undefined) { let value = this.parseFieldValue(giftPointsField.value); // Parse the value if (!isNaN(value)) { // Check the parsed value totalGiftPoints += value; } } // --- Find and add Transformation Gems field value --- const gemsField = this.findCustomField(task.custom_fields, ['ngọc chuyển hóa', 'ngoc chuyen hoa', 'transformation gems']); if (gemsField && gemsField.value !== null && gemsField.value !== undefined) { let parsedValue = this.parseFieldValue(gemsField.value); if (!isNaN(parsedValue)) { totalTransformationGems += parsedValue; // Add to the total from LADDER tasks } } // --- End Transformation Gems Calculation for this task --- } // End of: if (task.custom_fields && Array.isArray(task.custom_fields)) }); // End of: ladderTasks.forEach } // --- Transformation Gems calculation is now done within the LADDER task loop --- // The previous block filtering by 'chuyển hóa' status is removed. return { totalScholarship: totalScholarship, totalGiftPoints: totalGiftPoints, totalTransformationGems: totalTransformationGems // Include Ngọc Chuyển Hóa in the result }; }, // Các hàm đồng bộ dữ liệu từ app vào ClickUp đã được loại bỏ để giải phóng code // Lấy danh sách sản phẩm từ List ClickUp async getProductsFromList(credentials) { if (!credentials.apiKey || !credentials.productListId) { throw new Error('API Key và Product List ID là bắt buộc để lấy danh sách sản phẩm'); } const headers = { 'Authorization': credentials.apiKey, 'Content-Type': 'application/json' }; try { // Kiểm tra cache trước const cacheKey = cache.generateKey('getProductsFromList', { listId: credentials.productListId }); const cachedProducts = cache.get(cacheKey); if (cachedProducts) { return cachedProducts; } // Nếu không có trong cache, gọi API để lấy danh sách sản phẩm let tasks = await this.getTasksFromList(headers, credentials.productListId); // Xử lý và chuyển đổi tasks thành định dạng sản phẩm với hàm processProductTasks mới // processProductTasks will now potentially fetch more details if attachments are missing. // It needs the apiKey to do so. const products = await this.processProductTasks(tasks, credentials.apiKey); // Lưu vào cache cache.set(cacheKey, products, cacheConfig.tasks.ttl); return products; } catch (error) { console.error('Lỗi khi lấy sản phẩm:', error); throw new Error(`Không thể lấy danh sách sản phẩm: ${error.message}`); } }, // Xử lý các task từ ClickUp thành danh sách sản phẩm // Now accepts apiKey to fetch individual task details if needed async processProductTasks(tasks, apiKey) { const processedTasks = []; for (const initialTask of tasks) { let task = { ...initialTask }; // Work with a copy // --- IMAGE COLLECTION LOGIC PER TASK --- // Check if attachments are missing and fetch full task details if necessary if ((!task.attachments || task.attachments.length === 0) && apiKey && task.id) { try { const fullTaskDetails = await this.getTaskDetails(apiKey, task.id); // Merge attachments from full details if they exist if (fullTaskDetails && fullTaskDetails.attachments) { task.attachments = fullTaskDetails.attachments; // Update task with full attachments // Also, potentially update other fields if they were sparse in the list view task.description = fullTaskDetails.description || task.description; task.custom_fields = fullTaskDetails.custom_fields || task.custom_fields; } else { } } catch (error) { console.error(`[Debug ClickUp Service] Failed to fetch full details for task '${task.name}' (ID: ${task.id}) during image processing:`, error.message); // Continue with the potentially incomplete task data } } let imageUrlForThisTaskCard = ''; const collectedImagesForThisTaskSlideshow = new Set(); const imageFieldForThisTask = this.findCustomField(task.custom_fields || [], ['ảnh', 'anh', 'image', 'hình ảnh', 'hinh anh']); // --- DETAILED LOGGING (for this specific task) --- // 1. Prioritize image from "Ảnh" custom field for this task if (imageFieldForThisTask && imageFieldForThisTask.value && typeof imageFieldForThisTask.value === 'string' && imageFieldForThisTask.value.startsWith('http')) { const customFieldImage = imageFieldForThisTask.value.trim(); imageUrlForThisTaskCard = customFieldImage; collectedImagesForThisTaskSlideshow.add(customFieldImage); } // 2. Extract images from this task's description if (task.description) { const tempImgTags = []; const imgTagRegexDebug = /]+src="([^">]+)"/gi; let imgMatchDebug; imgTagRegexDebug.lastIndex = 0; while ((imgMatchDebug = imgTagRegexDebug.exec(task.description)) !== null) { if (imgMatchDebug[1]) { const imgSrc = imgMatchDebug[1].trim(); tempImgTags.push(imgSrc); collectedImagesForThisTaskSlideshow.add(imgSrc); if (!imageUrlForThisTaskCard) imageUrlForThisTaskCard = imgSrc; } } const tempGeneralUrls = []; const generalUrlRegexDebug = /(https?:\/\/(?:[^.]+\.clickup-attachments\.com\/[^\s<>"']+|[^\s<>"']+\.(?:jpg|jpeg|png|gif|webp|svg))(?:\?[^\s<>"']*)?)/gi; let urlMatchDebug; generalUrlRegexDebug.lastIndex = 0; while ((urlMatchDebug = generalUrlRegexDebug.exec(task.description)) !== null) { if (urlMatchDebug[1]) { const directUrl = urlMatchDebug[1].trim(); tempGeneralUrls.push(directUrl); collectedImagesForThisTaskSlideshow.add(directUrl); if (!imageUrlForThisTaskCard) imageUrlForThisTaskCard = directUrl; } } } else { } // 3. Extract from this task's attachments const tempAttachmentUrls = []; // Add a log to inspect the raw task.attachments object BEFORE attempting to process it if (task.attachments && Array.isArray(task.attachments)) { const imageMimeTypesDebug = ['image/jpeg', 'image/png', 'image/gif', 'image/webp', 'image/svg+xml']; const imageExtensionsDebug = ['jpg', 'jpeg', 'png', 'gif', 'webp', 'svg']; task.attachments.forEach(attachment => { if (attachment.url) { // Only process if there's a URL const attachmentUrl = attachment.url.trim(); // Attempt to determine the file extension more robustly let ext = (attachment.extension || '').toLowerCase(); if (!ext && attachment.title) { const titleParts = attachment.title.toLowerCase().split('.'); if (titleParts.length > 1) { ext = titleParts.pop(); } } if (!ext) { // Fallback to URL parsing if still no extension const urlPath = attachmentUrl.split('?')[0]; // Get path before query params const urlParts = urlPath.toLowerCase().split('.'); if (urlParts.length > 1) { const potentialExt = urlParts.pop(); // Sanity check for common image extension patterns from URL if (potentialExt.length > 0 && potentialExt.length <= 4 && /^[a-z0-9]+$/.test(potentialExt)) { ext = potentialExt; } } } const isMimeTypeImage = attachment.mimetype && imageMimeTypesDebug.includes(attachment.mimetype.toLowerCase()); const isExtensionImage = ext && imageExtensionsDebug.includes(ext); if (isMimeTypeImage || isExtensionImage) { tempAttachmentUrls.push(attachmentUrl); collectedImagesForThisTaskSlideshow.add(attachmentUrl); if (!imageUrlForThisTaskCard) imageUrlForThisTaskCard = attachmentUrl; } else { } } }); } const finalImagesForThisTaskSlideshow = Array.from(collectedImagesForThisTaskSlideshow); if (!imageUrlForThisTaskCard && finalImagesForThisTaskSlideshow.length > 0) { imageUrlForThisTaskCard = finalImagesForThisTaskSlideshow[0]; } // --- END IMAGE COLLECTION LOGIC PER TASK --- // Attach the collected image data directly to the task object for later use const taskWithImageData = { ...task, _processedImageData: { cardImage: imageUrlForThisTaskCard, slideshowImages: finalImagesForThisTaskSlideshow } }; processedTasks.push(taskWithImageData); } // End of for...of loop iterating through initial tasks return processedTasks .filter(task => { // Filter based on product criteria (same as before) if (!task.custom_fields || !Array.isArray(task.custom_fields)) { return false; } const scholarshipField = this.findCustomField(task.custom_fields, ['học bổng', 'hoc bong', 'scholarship', 'tiền', 'tien', 'số tiền', 'giá trị']); const giftPointsField = this.findCustomField(task.custom_fields, ['gift points', 'điểm đổi quà', 'diem doi qua', 'points']); const isScholarshipProduct = scholarshipField && this.isNegativeValue(scholarshipField.value); const isGiftPointsProduct = giftPointsField && this.isNegativeValue(giftPointsField.value); return isScholarshipProduct || isGiftPointsProduct; }) .map(task => { // Retrieve the pre-processed image data specific to this task const { cardImage, slideshowImages } = task._processedImageData; // Rest of the product processing logic (same as before) const scholarshipField = this.findCustomField(task.custom_fields, ['học bổng', 'hoc bong', 'scholarship', 'tiền', 'tien', 'số tiền', 'giá trị']); const giftPointsField = this.findCustomField(task.custom_fields, ['gift points', 'điểm đổi quà', 'diem doi qua', 'points']); const gemsField = this.findCustomField(task.custom_fields, ['ngọc chuyển hóa', 'ngoc chuyen hoa', 'transformation gems']); const price = scholarshipField ? Math.abs(this.parseFieldValue(scholarshipField.value)) : 0; const giftPoints = giftPointsField ? Math.abs(this.parseFieldValue(giftPointsField.value)) : 0; const transformationGemsRequired = gemsField ? Math.abs(this.parseFieldValue(gemsField.value)) : 0; let shortDescription = ''; if (task.description) { const tempDiv = document.createElement('div'); tempDiv.innerHTML = task.description; const textContent = tempDiv.textContent || tempDiv.innerText || ''; shortDescription = textContent.trim().substring(0, 150); if (shortDescription.length >= 150) { shortDescription += '...'; } } const canBuyWithScholarship = scholarshipField && price > 0; const canBuyWithGiftPoints = giftPointsField && giftPoints > 0; let productType = 'unknown'; if (canBuyWithScholarship && canBuyWithGiftPoints) { productType = 'both'; } else if (canBuyWithScholarship) { productType = 'scholarship'; } else if (canBuyWithGiftPoints) { productType = 'gift_points'; } return { id: task.id, name: task.name, description: shortDescription || 'Không có mô tả', fullDescription: task.description || '', price: price, giftPoints: giftPoints, productType: productType, canBuyWithScholarship: canBuyWithScholarship, canBuyWithGiftPoints: canBuyWithGiftPoints, image: cardImage, // Use the cardImage collected for this task descriptionImages: slideshowImages, // Use the slideshowImages collected for this task transformationGemsRequired: transformationGemsRequired, listId: task.list?.id || '', status: task.status?.status || '', createdDate: task.date_created, customFields: task.custom_fields || [], taskData: { ...task, _processedImageData: undefined } // Clean up temporary data }; }); }, // Tạo bản sao task khi mua hàng async duplicateTask(apiKey, taskId, targetListId, customData = {}) { if (!apiKey || !taskId || !targetListId) { throw new Error('API Key, Task ID và Target List ID là bắt buộc'); } const headers = { 'Authorization': apiKey, 'Content-Type': 'application/json' }; try { // Lấy thông tin chi tiết về task gốc const taskResponse = await this.executeWithBackoff(async () => { const resp = await fetch(`https://api.clickup.com/api/v2/task/${taskId}`, { method: 'GET', headers }); if (!resp.ok) { const status = resp.status; const text = await resp.text(); throw new Error(`Không thể lấy thông tin task: ${status} - ${text}`); } return resp; }); const taskData = await taskResponse.json(); // Chuẩn bị dữ liệu cho task mới const newTaskData = { name: `${taskData.name} - Đã mua`, description: taskData.description || '', status: 'LADDER', // Chuyển trạng thái sang LADDER custom_fields: [] }; // Thêm thông tin tùy chỉnh (nếu có) if (customData.userName) { newTaskData.description += `\n\n**Khách hàng:** ${customData.userName}`; } if (customData.purchaseDate) { newTaskData.description += `\n**Ngày mua:** ${customData.purchaseDate}`; } if (customData.price) { // Thêm thông tin giá vào mô tả newTaskData.description += `\n**Giá:** ${customData.price.toLocaleString('vi-VN')} VNĐ`; // Nếu có custom fields, thêm giá trị vào taskData.custom_fields.forEach(field => { if (field.name.toLowerCase().includes('học bổng') || field.name.toLowerCase().includes('hoc bong') || field.name.toLowerCase().includes('scholarship')) { newTaskData.custom_fields.push({ id: field.id, value: -Math.abs(customData.price) // Đảm bảo giá trị luôn là số âm }); } }); } if (customData.giftPoints) { // Thêm thông tin điểm đổi quà vào mô tả newTaskData.description += `\n**Điểm đổi quà:** ${customData.giftPoints.toLocaleString('vi-VN')} điểm`; // Nếu có custom fields cho điểm đổi quà, thêm giá trị vào taskData.custom_fields.forEach(field => { if (field.name.toLowerCase().includes('gift points') || field.name.toLowerCase().includes('điểm đổi quà') || field.name.toLowerCase().includes('diem doi qua') || field.name.toLowerCase() === 'points') { newTaskData.custom_fields.push({ id: field.id, value: -Math.abs(customData.giftPoints) // Đảm bảo giá trị luôn là số âm }); } }); } // Xử lý Ngọc Chuyển Hóa (Transformation Gems) if (customData.transformationGemsRequired > 0) { // Thêm thông tin Ngọc Chuyển Hóa vào mô tả newTaskData.description += `\n**Ngọc Chuyển Hóa:** ${customData.transformationGemsRequired.toLocaleString('vi-VN')} ngọc`; // Tìm và thêm giá trị âm vào custom field Ngọc Chuyển Hóa const gemsField = this.findCustomField(taskData.custom_fields, ['ngọc chuyển hóa', 'ngoc chuyen hoa', 'transformation gems']); if (gemsField) { newTaskData.custom_fields.push({ id: gemsField.id, value: -Math.abs(customData.transformationGemsRequired) // Đảm bảo giá trị luôn là số âm }); } } // Tạo task mới trong list đích const createResponse = await this.executeWithBackoff(async () => { const resp = await fetch(`https://api.clickup.com/api/v2/list/${targetListId}/task`, { method: 'POST', headers, body: JSON.stringify(newTaskData) }); if (!resp.ok) { const status = resp.status; const text = await resp.text(); throw new Error(`Không thể tạo task mới: ${status} - ${text}`); } return resp; }); const newTask = await createResponse.json(); return newTask; } catch (error) { console.error('Lỗi khi tạo bản sao task:', error); throw new Error(`Không thể tạo bản sao task: ${error.message}`); } }, // Helper method to find a custom field by name findCustomField(customFields, possibleNames) { return customFields.find(field => { const fieldNameLower = field.name.toLowerCase(); return possibleNames.some(name => fieldNameLower.includes(name.toLowerCase())); }); }, // Helper method to check if a value is negative isNegativeValue(value) { if (typeof value === 'string') { value = parseFloat(value.replace(/[^\d.-]/g, '')); } else if (typeof value === 'object' && value.value) { value = parseFloat(value.value.toString().replace(/[^\d.-]/g, '')); } else { value = Number(value); } return !isNaN(value) && value < 0; }, // Helper method to parse field values consistently parseFieldValue(value) { if (typeof value === 'string') { // Remove all non-numeric characters except decimal point and minus sign return parseFloat(value.replace(/[^\d.-]/g, '')); } else if (typeof value === 'object' && value.value !== undefined) { // Handle case where value is stored in a complex object return this.parseFieldValue(value.value); } else { return Number(value); } }, // Update custom fields of a specific task async updateTaskCustomFields(credentials, stats) { const { apiKey, targetTaskId, scholarshipFieldId, giftPointsFieldId, transformationGemsFieldId // Add Ngọc Chuyển Hóa field ID } = credentials; const { totalScholarship, totalGiftPoints, totalTransformationGems // Add Ngọc Chuyển Hóa total from stats } = stats; // Validate input if (!apiKey || !targetTaskId) { console.warn('Missing API Key or Target Task ID for updating custom fields.'); return; // Don't throw error, just log and return } // Update condition to include transformationGemsFieldId if (!scholarshipFieldId && !giftPointsFieldId && !transformationGemsFieldId) { console.warn('Missing all relevant Custom Field IDs. Nothing to update.'); return; } const headers = { 'Authorization': apiKey, 'Content-Type': 'application/json' }; // Function to update a single field const updateField = async (fieldId, value) => { if (!fieldId) { console.warn(`Skipping update for field ID ${fieldId} as it's missing.`); return; // Skip if field ID is not provided } if (value === undefined || value === null) { console.warn(`Skipping update for field ID ${fieldId} due to undefined/null value.`); return; // Skip if value is not valid } const url = `https://api.clickup.com/api/v2/task/${targetTaskId}/field/${fieldId}`; const body = JSON.stringify({ value: value }); try { await this.executeWithBackoff(async () => { const response = await fetch(url, { method: 'POST', // Use POST to set custom field value headers, body }); if (!response.ok) { const status = response.status; let errorText = ''; try { errorText = await response.text(); } catch (e) { // Ignore error reading response text } console.error(`Failed to update field ${fieldId} on task ${targetTaskId}: ${status} - ${errorText}`); throw new Error(`Failed to update field ${fieldId}: ${status}`); } }); } catch (error) { console.error(`Error updating field ${fieldId}:`, error.message); // Decide if you want to re-throw or just log // throw error; // Re-throwing might stop subsequent updates } }; // Update Scholarship field if (scholarshipFieldId) { await updateField(scholarshipFieldId, totalScholarship); } // Update Gift Points field if (giftPointsFieldId) { await updateField(giftPointsFieldId, totalGiftPoints); } // Update Transformation Gems field if (transformationGemsFieldId) { await updateField(transformationGemsFieldId, totalTransformationGems); } // Invalidate cache for the specific task if needed, or for general tasks this.cache.invalidate('getCustomFieldsFromTask', { taskId: targetTaskId }); // Invalidate cache for the updated task // cache.invalidate('getTasksFromList', { listId: credentials.listId }); // Optionally invalidate list if needed } };