108bf87225
补齐源快照、资料预演、正式导入及工资核算的依赖链路。 新增版本化输入、逐段 FIFO、生成锁和结构化当月调整， 并提供默认关闭的周期采集、有限重试及 Windows 托管。 原始客户资料、私有配置及首页改动不纳入本次提交。 BREAKING CHANGE: 升级前需应用新增迁移，并通过 PAYROLL_MAKER_USER_ID 绑定实际工资制作人，否则业务只读。 旧单批次核算默认关闭；历史兼容需显式启用 PAYROLL_ALLOW_LEGACY_CALCULATION。生产启用和真实金额待验收。
137 lines
3.9 KiB
Python
137 lines
3.9 KiB
Python
"""T+ 字段映射元数据。
|
||
|
||
这里记录候选字段和确认状态，不把字典中的候选直接当成业务契约。
|
||
高风险口径在客户确认前保持 ``PENDING``；源读取只写 staging，基础导入另经事实核对和预览。
|
||
"""
|
||
|
||
from dataclasses import dataclass
|
||
from enum import StrEnum
|
||
|
||
|
||
class MappingStatus(StrEnum):
|
||
"""字段映射的证据状态。"""
|
||
|
||
CONFIRMED = "CONFIRMED"
|
||
CANDIDATE = "CANDIDATE"
|
||
MISSING = "MISSING"
|
||
PENDING = "PENDING"
|
||
|
||
|
||
@dataclass(frozen=True, slots=True)
|
||
class TPlusMapping:
|
||
"""一个实体的源表、候选字段和目标表说明。"""
|
||
|
||
entity_type: str
|
||
source_table: str
|
||
source_fields: tuple[str, ...]
|
||
target_table: str
|
||
status: MappingStatus
|
||
unresolved: tuple[str, ...] = ()
|
||
version: str = "0.5"
|
||
schema_evidence: str = "ceshi20261026.bak，2026-10-27 恢复副本结构核验"
|
||
|
||
|
||
TPLUS_MAPPINGS: tuple[TPlusMapping, ...] = (
|
||
TPlusMapping(
|
||
"personnel",
|
||
"AA_Person",
|
||
("id", "code", "name", "disabled", "mobilePhoneNo", "officePhoneNo", "iddepartment"),
|
||
"personnel",
|
||
MappingStatus.CANDIDATE,
|
||
("名单缺失编号", "经理分管业务", "入职日期", "试用期"),
|
||
),
|
||
TPlusMapping(
|
||
"products",
|
||
"AA_Inventory",
|
||
("id", "code", "name", "specification", "idunit", "idinventoryclass"),
|
||
"products",
|
||
MappingStatus.CANDIDATE,
|
||
("人工核算分类", "指导价取值时点"),
|
||
),
|
||
TPlusMapping(
|
||
"customers",
|
||
"AA_Partner",
|
||
("id", "code", "name", "Contact", "representative", "disabled", "updated"),
|
||
"customers",
|
||
MappingStatus.CANDIDATE,
|
||
("源客户属性为空", "客户负责人资料"),
|
||
),
|
||
TPlusMapping(
|
||
"businesses",
|
||
"SA_SaleOrder",
|
||
("id", "code", "voucherdate", "idcustomer", "idclerk", "idbusinesstype", "updated"),
|
||
"businesses",
|
||
MappingStatus.PENDING,
|
||
("指导价取值时点", "业务交接依据", "平账范围"),
|
||
),
|
||
TPlusMapping(
|
||
"shipments",
|
||
"SA_SaleDelivery",
|
||
(
|
||
"id",
|
||
"code",
|
||
"voucherdate",
|
||
"SendDate",
|
||
"deliveryDate",
|
||
"auditeddate",
|
||
"SourceVoucherCode",
|
||
"updated",
|
||
),
|
||
"shipments",
|
||
MappingStatus.PENDING,
|
||
("退货/红冲规则", "运费实际金额", "发货归属"),
|
||
),
|
||
TPlusMapping(
|
||
"receipts",
|
||
"ARAP_ReceivePayment",
|
||
(
|
||
"id",
|
||
"code",
|
||
"voucherDate",
|
||
"auditedDate",
|
||
"createdTime",
|
||
"SaleOrderCode",
|
||
"SaleOrderID",
|
||
"ts",
|
||
),
|
||
"receipts",
|
||
MappingStatus.PENDING,
|
||
("凭证异常例单复核", "特殊款项识别", "平账范围"),
|
||
),
|
||
)
|
||
|
||
DETAIL_MAPPINGS: tuple[TPlusMapping, ...] = (
|
||
TPlusMapping(
|
||
"business_items",
|
||
"SA_SaleOrder_b",
|
||
("id", "idSaleOrderDTO", "LatestCost"),
|
||
"business_items",
|
||
MappingStatus.PENDING,
|
||
("不导入T+成本，仅保留追溯快照",),
|
||
),
|
||
TPlusMapping(
|
||
"shipment_items",
|
||
"SA_SaleDelivery_b",
|
||
("ID", "idSaleDeliveryDTO", "saleOrderId"),
|
||
"shipment_items",
|
||
MappingStatus.PENDING,
|
||
("发货归属", "红冲和退货"),
|
||
),
|
||
TPlusMapping(
|
||
"receipt_items",
|
||
"ARAP_ReceivePayment_b",
|
||
("id", "idArapReceivePaymentDTO", "saleorderid"),
|
||
"receipts",
|
||
MappingStatus.PENDING,
|
||
("回款拆分", "核销语义", "增量水位"),
|
||
),
|
||
)
|
||
|
||
|
||
def get_mapping(entity_type: str) -> TPlusMapping:
|
||
"""按实体类型取得映射；未知实体直接拒绝。"""
|
||
for mapping in (*TPLUS_MAPPINGS, *DETAIL_MAPPINGS):
|
||
if mapping.entity_type == entity_type:
|
||
return mapping
|
||
raise KeyError(f"未知 T+ 实体类型：{entity_type}")
|