zengzy / rps · Files

import type {
  SnAction,
  SnActionPayload,
  SnExceptionStatus,
  SnImportPayload,
  SnImportResponse,
  SnItem,
  SnListQuery,
  SnMutationResponse,
  SnStatus
} from '../../app/types/sn'

const ALLOWED_ACTIONS_BY_STATUS: Record<SnStatus, SnAction[]> = {
  pending: ['freeze', 'scrap'],
  in_process: ['freeze', 'scrap'],
  completed: ['freeze', 'scrap'],
  frozen: ['unfreeze', 'scrap'],
  scrapped: []
}

let nextId = 1021

function now() {
  return new Date().toISOString()
}

function normalizeText(value: string | undefined) {
  if (!value) {
    return undefined
  }

  const trimmed = value.trim()
  return trimmed.length > 0 ? trimmed : undefined
}

function clone(item: SnItem): SnItem {
  return {
    ...item,
    audit: { ...item.audit },
    events: item.events.map(event => ({ ...event }))
  }
}

function withMutation(base: SnMutationResponse, item?: SnItem) {
  return {
    ...base,
    item: item ? clone(item) : undefined
  }
}

function buildEvent(
  action: SnAction,
  fromStatus: SnStatus | null,
  toStatus: SnStatus,
  operator: string,
  currentStep: string,
  exceptionStatus: SnExceptionStatus,
  reason?: string
) {
  return {
    id: `sn-evt-${Date.now()}-${Math.random().toString(36).slice(2, 8)}`,
    action,
    fromStatus,
    toStatus,
    operator,
    at: now(),
    reason: normalizeText(reason),
    currentStep,
    exceptionStatus
  }
}

function createSeed(input: {
  id: number
  sn: string
  workOrderNo: string
  status: SnStatus
  currentStep: string
  exceptionStatus: SnExceptionStatus
  operator: string
  freezeReason?: string
  scrapReason?: string
}) {
  const createdAt = now()
  const createdEvent = buildEvent(
    'import',
    null,
    input.status,
    input.operator,
    input.currentStep,
    input.exceptionStatus,
    '初始化导入'
  )

  return {
    id: input.id,
    sn: input.sn,
    workOrderNo: input.workOrderNo,
    status: input.status,
    currentStep: input.currentStep,
    exceptionStatus: input.exceptionStatus,
    freezeReason: normalizeText(input.freezeReason),
    scrapReason: normalizeText(input.scrapReason),
    audit: {
      createdBy: input.operator,
      createdAt,
      updatedBy: input.operator,
      updatedAt: createdAt,
      lastAction: 'import',
      lastActionAt: createdAt,
      lastActionBy: input.operator
    },
    events: [createdEvent]
  } satisfies SnItem
}

const mockSnItems: SnItem[] = [
  createSeed({
    id: 1001,
    sn: 'SN-RBTX5-0001',
    workOrderNo: 'WO-202605-001',
    status: 'in_process',
    currentStep: '装配',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1002,
    sn: 'SN-RBTX5-0002',
    workOrderNo: 'WO-202605-001',
    status: 'frozen',
    currentStep: '测试',
    exceptionStatus: 'open',
    operator: '质量经理',
    freezeReason: '测试电流波动超阈值'
  }),
  createSeed({
    id: 1003,
    sn: 'SN-RBTM2-0001',
    workOrderNo: 'WO-202605-003',
    status: 'completed',
    currentStep: '终检',
    exceptionStatus: 'closed',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1004,
    sn: 'SN-RBTM2-0002',
    workOrderNo: 'WO-202605-003',
    status: 'pending',
    currentStep: '装配',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1005,
    sn: 'SN-RBTQA-0001',
    workOrderNo: 'WO-202605-004',
    status: 'scrapped',
    currentStep: '返修',
    exceptionStatus: 'rework',
    operator: '质量经理',
    scrapReason: '主控板损坏无法修复'
  }),
  createSeed({
    id: 1006,
    sn: 'SN-RBTX5-0003',
    workOrderNo: 'WO-202605-002',
    status: 'in_process',
    currentStep: '测试',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1007,
    sn: 'SN-RBTX5-0004',
    workOrderNo: 'WO-202605-002',
    status: 'frozen',
    currentStep: '测试',
    exceptionStatus: 'rework',
    operator: '质量经理',
    freezeReason: '重复扫码冲突待复核'
  }),
  createSeed({
    id: 1008,
    sn: 'SN-RBTX5-0005',
    workOrderNo: 'WO-202605-002',
    status: 'completed',
    currentStep: '入库',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1009,
    sn: 'SN-RBTQX-0001',
    workOrderNo: 'WO-202605-005',
    status: 'scrapped',
    currentStep: '终检',
    exceptionStatus: 'closed',
    operator: '系统管理员',
    scrapReason: '外壳结构缺陷'
  }),
  createSeed({
    id: 1010,
    sn: 'SN-RBTQX-0002',
    workOrderNo: 'WO-202605-005',
    status: 'pending',
    currentStep: '装配',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1011,
    sn: 'SN-RBTX5-0006',
    workOrderNo: 'WO-202605-001',
    status: 'in_process',
    currentStep: '调试',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1012,
    sn: 'SN-RBTM2-0003',
    workOrderNo: 'WO-202605-003',
    status: 'frozen',
    currentStep: '返修',
    exceptionStatus: 'open',
    operator: '质量经理',
    freezeReason: '异常单 EX-202605-009 未关闭'
  }),
  createSeed({
    id: 1013,
    sn: 'SN-RBTM2-0004',
    workOrderNo: 'WO-202605-003',
    status: 'completed',
    currentStep: '入库',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1014,
    sn: 'SN-RBTQA-0002',
    workOrderNo: 'WO-202605-004',
    status: 'pending',
    currentStep: '装配',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1015,
    sn: 'SN-RBTQA-0003',
    workOrderNo: 'WO-202605-004',
    status: 'in_process',
    currentStep: '测试',
    exceptionStatus: 'open',
    operator: '质量经理'
  }),
  createSeed({
    id: 1016,
    sn: 'SN-RBTQA-0004',
    workOrderNo: 'WO-202605-004',
    status: 'completed',
    currentStep: '终检',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1017,
    sn: 'SN-RBTX5-0007',
    workOrderNo: 'WO-202605-001',
    status: 'frozen',
    currentStep: '调试',
    exceptionStatus: 'rework',
    operator: '质量经理',
    freezeReason: '电机抖动异常待返修'
  }),
  createSeed({
    id: 1018,
    sn: 'SN-RBTX5-0008',
    workOrderNo: 'WO-202605-001',
    status: 'pending',
    currentStep: '装配',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1019,
    sn: 'SN-RBTQX-0003',
    workOrderNo: 'WO-202605-005',
    status: 'in_process',
    currentStep: '测试',
    exceptionStatus: 'none',
    operator: '系统管理员'
  }),
  createSeed({
    id: 1020,
    sn: 'SN-RBTQX-0004',
    workOrderNo: 'WO-202605-005',
    status: 'completed',
    currentStep: '入库',
    exceptionStatus: 'closed',
    operator: '系统管理员'
  })
]

function findById(id: number) {
  return mockSnItems.find(item => item.id === id)
}

function findBySn(sn: string) {
  const normalized = sn.trim().toLowerCase()
  return mockSnItems.find(item => item.sn.toLowerCase() === normalized)
}

function parseText(input: string | undefined) {
  return normalizeText(input)?.toLowerCase()
}

function matchesFilter(item: SnItem, query: SnListQuery) {
  const sn = parseText(query.sn)
  const workOrderNo = parseText(query.workOrderNo)
  const currentStep = parseText(query.currentStep)

  if (sn && !item.sn.toLowerCase().includes(sn)) {
    return false
  }

  if (workOrderNo && !item.workOrderNo.toLowerCase().includes(workOrderNo)) {
    return false
  }

  if (query.status && item.status !== query.status) {
    return false
  }

  if (currentStep && !item.currentStep.toLowerCase().includes(currentStep)) {
    return false
  }

  if (query.exceptionStatus && item.exceptionStatus !== query.exceptionStatus) {
    return false
  }

  return true
}

function buildImportResult(
  base: SnMutationResponse,
  importedCount: number,
  skippedCount: number,
  duplicateSnList: string[]
): SnImportResponse {
  return {
    ...base,
    importedCount,
    skippedCount,
    duplicateSnList
  }
}

function applyMutation(
  item: SnItem,
  action: Exclude<SnAction, 'import'>,
  nextStatus: SnStatus,
  payload: SnActionPayload
) {
  const at = now()
  const reason = payload.reason.trim()
  const event = buildEvent(
    action,
    item.status,
    nextStatus,
    payload.operator.trim(),
    item.currentStep,
    item.exceptionStatus,
    reason
  )

  if (action === 'freeze') {
    item.freezeReason = reason
  } else if (action === 'unfreeze') {
    item.freezeReason = undefined
  } else if (action === 'scrap') {
    item.scrapReason = reason
  }

  item.status = nextStatus
  item.audit.updatedAt = at
  item.audit.updatedBy = payload.operator.trim()
  item.audit.lastAction = action
  item.audit.lastActionAt = at
  item.audit.lastActionBy = payload.operator.trim()
  item.events.unshift(event)
}

export function getMockSnItems(query: SnListQuery) {
  return mockSnItems
    .filter(item => matchesFilter(item, query))
    .sort((a, b) => b.audit.updatedAt.localeCompare(a.audit.updatedAt))
    .map(item => clone(item))
}

export function importMockSnItems(payload: SnImportPayload): SnImportResponse {
  const snCandidates = payload.snList
    .map(item => item.trim().toUpperCase())
    .filter(item => item.length > 0)

  if (snCandidates.length === 0) {
    return buildImportResult({
      success: false,
      errorCode: 'VALIDATION_ERROR',
      message: '未提供可导入的 SN。'
    }, 0, 0, [])
  }

  const uniqueSnCandidates: string[] = []
  const duplicateInPayload = new Set<string>()
  const existsInSystem: string[] = []

  for (const sn of snCandidates) {
    if (uniqueSnCandidates.includes(sn)) {
      duplicateInPayload.add(sn)
      continue
    }

    if (findBySn(sn)) {
      existsInSystem.push(sn)
      continue
    }

    uniqueSnCandidates.push(sn)
  }

  const duplicateSnList = [...new Set([...duplicateInPayload, ...existsInSystem])]
  const createdAt = now()

  for (const sn of uniqueSnCandidates) {
    const event = buildEvent(
      'import',
      null,
      'pending',
      payload.operator.trim(),
      payload.currentStep.trim(),
      'none',
      '批量导入'
    )

    const item: SnItem = {
      id: nextId++,
      sn,
      workOrderNo: payload.workOrderNo.trim(),
      status: 'pending',
      currentStep: payload.currentStep.trim(),
      exceptionStatus: 'none',
      audit: {
        createdBy: payload.operator.trim(),
        createdAt,
        updatedBy: payload.operator.trim(),
        updatedAt: createdAt,
        lastAction: 'import',
        lastActionAt: createdAt,
        lastActionBy: payload.operator.trim()
      },
      events: [event]
    }

    mockSnItems.push(item)
  }

  const importedCount = uniqueSnCandidates.length
  const skippedCount = duplicateSnList.length
  const success = importedCount > 0

  return buildImportResult({
    success,
    errorCode: success ? null : 'SN_DUPLICATED',
    message: success
      ? `SN 导入完成，成功 ${importedCount} 条，跳过 ${skippedCount} 条重复记录。`
      : '导入失败，SN 全部重复。'
  }, importedCount, skippedCount, duplicateSnList)
}

export function mutateMockSnStatus(
  id: number,
  action: Exclude<SnAction, 'import'>,
  payload: SnActionPayload
) {
  const item = findById(id)

  if (!item) {
    return withMutation({
      success: false,
      errorCode: 'SN_NOT_FOUND',
      message: 'SN 不存在。'
    })
  }

  const allowedActions = ALLOWED_ACTIONS_BY_STATUS[item.status] ?? []
  if (!allowedActions.includes(action)) {
    return withMutation({
      success: false,
      errorCode: 'SN_ACTION_NOT_ALLOWED',
      message: '当前 SN 状态不支持该操作。'
    }, item)
  }

  if (action === 'freeze') {
    applyMutation(item, action, 'frozen', payload)
    return withMutation({
      success: true,
      errorCode: null,
      message: 'SN 已冻结。'
    }, item)
  }

  if (action === 'unfreeze') {
    const nextStatus: SnStatus = item.exceptionStatus === 'none' ? 'in_process' : 'pending'
    applyMutation(item, action, nextStatus, payload)
    return withMutation({
      success: true,
      errorCode: null,
      message: 'SN 已解冻。'
    }, item)
  }

  applyMutation(item, action, 'scrapped', payload)
  return withMutation({
    success: true,
    errorCode: null,
    message: 'SN 已报废。'
  }, item)
}