admin-web/src/modules/self-operated/components/CollectionAccountMonitor.test.ts

import { mount } from '@vue/test-utils'
import { describe, expect, it } from 'vitest'
import CollectionAccountMonitor from './CollectionAccountMonitor.vue'
import CollectionTaskProgress from './CollectionTaskProgress.vue'
import type { Overview, Task, WarehouseOverview } from '../types'

const child: Task = { taskNo: 'CHILD', warehouseCode: 'US01', dataFamily: 'OUTBOUND', taskStatus: 'WAITING_SOURCE', allowedActions: [], progress: null, taskType: 'BACKFILL', queryFrom: null, queryUntil: null, applyState: null, attemptCount: 0, latestAttemptNo: null, resultPublicationState: 'NOT_PUBLISHED', nextRetryAt: null, actionBlockReason: null }
const source: Task = { ...child, taskNo: 'SOURCE', warehouseCode: '', taskStatus: 'RUNNING', progress: { phase: 'DETAIL', progressScope: 'ACCOUNT_SHARED', countBasis: 'TASK_CUMULATIVE', completed: 339, total: 2787, totalKnown: true, unit: 'ORDER' } }
function overview(account: Task | null = source): Overview {
  return { sourceAccount: 'lingxing-primary', collectionMode: 'BUSINESS', environmentLabel: 'TEST', observedAt: '2026-10-13T08:00:00Z', accountActivity: account,
    warehouses: [{ warehouseCode: 'US01', dataFamily: 'OUTBOUND', activeTasks: [child], sharedUpstream: account }, { warehouseCode: 'US02', dataFamily: 'OUTBOUND', activeTasks: [{ ...child, taskNo: 'CHILD-2', warehouseCode: 'US02' }], sharedUpstream: account }] as WarehouseOverview[] }
}
const options = { global: { stubs: { 'el-button': true } } }
describe('single account collection monitor', () => {
  it('does not claim idle or an empty queue when the first status read fails', () => {
    const w = mount(CollectionAccountMonitor, { ...options, props: { overview: null, stale: true } })
    expect(w.text()).toContain('暂未取得账号状态')
    expect(w.text()).toContain('暂未取得安排')
    expect(w.text()).not.toContain('待机')
    expect(w.text()).not.toContain('保留最后一次')
    expect(w.text()).not.toContain('暂无其他待处理项')
    w.unmount()
  })
  it('shows account work once despite two waiting warehouses and keeps the phase counts', () => {
    const w = mount(CollectionAccountMonitor, { ...options, props: { overview: overview() } })
    expect(w.findAllComponents(CollectionTaskProgress)).toHaveLength(1)
    expect(w.findComponent(CollectionTaskProgress).props('task').taskNo).toBe('SOURCE')
    expect(w.text()).toContain('12.1%'); expect(w.text()).toContain('2448')
    expect(w.text()).toContain('US01 · 出库销量'); expect(w.text()).toContain('US02 · 出库销量')
    expect(w.text()).toContain('完整队列数量及下一任务顺序尚未提供')
    expect(w.text()).not.toContain('查看配置'); expect(w.text()).not.toContain('执行心跳')
    w.unmount()
  })
  it('moves on when account work ends and does not present historical completion as running', async () => {
    const w = mount(CollectionAccountMonitor, { ...options, props: { overview: overview() } })
    const next = overview({ ...source, taskStatus: 'SUCCEEDED' })
    const inventory = { ...child, taskNo: 'STOCK', warehouseCode: 'US02', dataFamily: 'INVENTORY', taskStatus: 'RUNNING' }
    next.warehouses[1]!.activeTasks = [inventory]
    await w.setProps({ overview: next })
    expect(w.findComponent(CollectionTaskProgress).props('task').taskNo).toBe('STOCK')
    await w.setProps({ overview: { ...next, warehouses: [] } })
    expect(w.text()).toContain('当前没有正在运行的采集')
    expect(w.findComponent(CollectionTaskProgress).exists()).toBe(false)
    w.unmount()
  })
  it('preserves real last counts when stale without claiming an estimate', () => {
    const w = mount(CollectionAccountMonitor, { ...options, props: { overview: overview(), stale: true } })
    expect(w.text()).toContain('339'); expect(w.text()).toContain('状态更新失败')
    expect(w.text()).toContain('已暂停估算')
    w.unmount()
  })
})