优化

src/modules/container-loading/smartLoadingPlanGroups.ts

@@ -0,0 +1,47 @@
+import { getLoadingAssociationSummaryByInboundId, type LoadingAssociationSummary } from '@/shared/api/inboundCodeRelations'
+import { groupSmartLoadingItems } from './smartLoadingItems'
+import type { SmartLoadingPlan } from './types'
+
+export interface SmartLoadingPlanCoLoadGroup {
+  groupId: string
+  groupNo: string
+  lockedPlanId: string
+  memberOrderCount: number
+  inboundFragmentCount: number
+  fullPackageCount: number
+}
+
+type AssociationLookup = (inboundId: string) => Promise<LoadingAssociationSummary>
+
+export async function loadSmartLoadingPlanCoLoadGroups(
+  plan: SmartLoadingPlan,
+  lookup: AssociationLookup = getLoadingAssociationSummaryByInboundId,
+) {
+  const inboundRows = groupSmartLoadingItems(plan.items || [])
+  if (!inboundRows.length) return new Map<string, SmartLoadingPlanCoLoadGroup>()
+
+  const associations = await Promise.all(inboundRows.map(async (row) => ({
+    row,
+    association: await lookup(row.inboundId),
+  })))
+  const membersByGroupId = new Map<string, typeof associations>()
+  for (const entry of associations) {
+    const groupId = String(entry.association.coLoadGroupId || '')
+    if (!groupId) continue
+    membersByGroupId.set(groupId, [...(membersByGroupId.get(groupId) || []), entry])
+  }
+
+  const groupsByInboundId = new Map<string, SmartLoadingPlanCoLoadGroup>()
+  for (const [groupId, members] of membersByGroupId) {
+    const group = {
+      groupId,
+      groupNo: members.find((entry) => entry.association.coLoadGroupNo)?.association.coLoadGroupNo || '同柜不可拆组',
+      lockedPlanId: members.find((entry) => entry.association.loadingPlanId)?.association.loadingPlanId || plan.id,
+      memberOrderCount: new Set(members.map((entry) => entry.row.orderId)).size,
+      inboundFragmentCount: members.length,
+      fullPackageCount: members.reduce((sum, entry) => sum + entry.row.packageCount, 0),
+    } satisfies SmartLoadingPlanCoLoadGroup
+    for (const { row } of members) groupsByInboundId.set(row.inboundId, group)
+  }
+  return groupsByInboundId
+}