first commit

wangzhibo

2026-05-09 53418655c061ac26f66058253f39200aced1ab1d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
import type { WarehousePlanEntry } from "../config/types.js"; 
import { formatDateKey } from "../utils/calendarMonth.js"; 
import { executeDataSourceById } from "./sqlDataSource.js"; 
 
export const WAREHOUSE_CALENDAR_DATASRC_ID = "warehouse_calendar_events"; 
 
function rowVal( 
  row: Record<string, unknown>, 
  ...names: string[] 
): unknown { 
  const keys = Object.keys(row); 
  for (const name of names) { 
    const k = keys.find((x) => x.toLowerCase() === name.toLowerCase()); 
    if (k !== undefined) { 
      return row[k]; 
    } 
  } 
  return undefined; 
} 
 
function dateKeyFromDatestr(v: unknown): string | null { 
  if (v instanceof Date) { 
    return formatDateKey(v.getFullYear(), v.getMonth() + 1, v.getDate()); 
  } 
  if (typeof v === "string") { 
    const t = v.trim(); 
    if (/^\d{4}-\d{2}-\d{2}/.test(t)) { 
      return t.slice(0, 10); 
    } 
    const d = new Date(t); 
    if (!Number.isNaN(d.getTime())) { 
      return formatDateKey(d.getFullYear(), d.getMonth() + 1, d.getDate()); 
    } 
  } 
  return null; 
} 
 
function strOpt(v: unknown): string | undefined { 
  if (v == null) { 
    return undefined; 
  } 
  const s = String(v).trim(); 
  return s === "" ? undefined : s; 
} 
 
function rowToPlanEntry( 
  row: Record<string, unknown> 
): WarehousePlanEntry { 
  const datestrRaw = rowVal(row, "datestr", "DispatchDate"); 
  const key = dateKeyFromDatestr(datestrRaw); 
  const datestr = key ?? String(datestrRaw ?? ""); 
  return { 
    datestr, 
    eventstr: strOpt(rowVal(row, "eventstr", "ShipmentCode")) ?? "(无单号)", 
    note_a: strOpt(rowVal(row, "note_a", "C1")), 
    note_b: strOpt(rowVal(row, "note_b")), 
    event_status: strOpt(rowVal(row, "event_status")), 
    event_src: strOpt(rowVal(row, "event_src", "CustomerShortName")), 
    event_to: strOpt(rowVal(row, "event_to", "ShippingToCountry")), 
  }; 
} 
 
/** 
 * 从 SQL Server（经 datasrc 配置）读取指定年月的计划，按 YYYY-MM-DD 分组。 
 */ 
export async function loadWarehousePlansGroupedByDate( 
  year: number, 
  month: number 
): Promise<Record<string, WarehousePlanEntry[]>> { 
  const startDate = new Date(year, month - 1, 1); 
  const endDate = new Date(year, month, 1); 
  const rows = await executeDataSourceById(WAREHOUSE_CALENDAR_DATASRC_ID, { 
    startDate, 
    endDate, 
  }); 
  const map: Record<string, WarehousePlanEntry[]> = {}; 
  for (const r of rows) { 
    const key = dateKeyFromDatestr( 
      rowVal(r, "datestr", "DispatchDate") 
    ); 
    if (!key) { 
      continue; 
    } 
    if (!map[key]) { 
      map[key] = []; 
    } 
    const entry = rowToPlanEntry(r); 
    entry.datestr = key; 
    map[key].push(entry); 
  } 
  return map; 
}