Front/src/utils/taskManager.js - main - BELEGO/GIS_APPLICATION

Front/src/utils/taskManager.js

102 строки3 KB

HACKER_LAPTOP

улучшил task-manager: задачи показывают type+productId в две строки с цветными статус-бейджами, индикатор остаётся видимым пока есть любые задачи (а не только активные), завершённые задачи сами исчезают через 30с через персональный таймер; плюс пофиксил «прыгающие» строки таблицы через сортировку features по entityid в App.vue и сделал чтобы подсветка ячейки изображения переходила на текущую строку при клике 🔍 «Переместиться»

20 май 2026, 05:23

20 май 2026, 05:2388219c5

const COMPLETED_TTL_MS = 30000 // через сколько удалять completed/failed задачи

class TaskManager {
    constructor() {
        this.tasks = []
        this.isProcessing = false
        this.subscribers = []
    }

    scheduleRemoval(taskId) {
        setTimeout(() => {
            const before = this.tasks.length
            this.tasks = this.tasks.filter(t => t.id !== taskId)
            if (this.tasks.length !== before) this.notify()
        }, COMPLETED_TTL_MS)
    }

    addTask(task) {
        const newTask = {
            ...task,
            id: Date.now() + Math.random(),
            status: 'pending',
            createdAt: new Date(),
            notified: false  // Добавьте это поле
        }

        this.tasks.push(newTask)
        this.notify()  // Уведомляем подписчиков о новой задаче
        this.processQueue()

        return newTask
    }

    subscribe(callback) {
        this.subscribers.push(callback)
        callback([...this.tasks]) // Инициализируем текущими задачами
        return () => {
            const index = this.subscribers.indexOf(callback)
            if (index > -1) this.subscribers.splice(index, 1)
        }
    }

    notify() {
        this.subscribers.forEach(cb => cb([...this.tasks]))
    }

    updateTask(id, updates) {
        const taskIndex = this.tasks.findIndex(t => t.id === id)
        if (taskIndex !== -1) {
            this.tasks[taskIndex] = { ...this.tasks[taskIndex], ...updates }
            this.notify()
        }
    }

    async processQueue() {
        if (this.isProcessing || this.tasks.length === 0) return

        this.isProcessing = true

        // Находим следующую задачу в статусе pending
        const nextTask = this.tasks.find(t => t.status === 'pending')

        if (!nextTask) {
            this.isProcessing = false
            return
        }

        this.updateTask(nextTask.id, { status: 'processing' })

        try {
            const result = await nextTask.execute()
            this.updateTask(nextTask.id, {
                status: 'completed',
                result,
                completedAt: new Date()
            })
            this.scheduleRemoval(nextTask.id)
        } catch (error) {
            this.updateTask(nextTask.id, {
                status: 'failed',
                error: error.message,
                completedAt: new Date()
            })
            this.scheduleRemoval(nextTask.id)
            console.error('Task failed:', error)
        } finally {
            this.isProcessing = false
            this.processQueue()
        }
    }

    getTasks() {
        return [...this.tasks]
    }

    clearCompleted() {
        this.tasks = this.tasks.filter(t => t.status === 'pending' || t.status === 'processing')
        this.notify()
    }
}

export const taskManager = new TaskManager()