diff --git a/flows/shared/mappers.py b/flows/shared/mappers.py index ac14f61..83c7d1a 100644 --- a/flows/shared/mappers.py +++ b/flows/shared/mappers.py @@ -35,6 +35,8 @@ RIIN_GOODS_STATUS_MAP: dict[str, str] = { "CANCELLED": "已取消", "REFUNDING": "退款中", # 商品级状态复用平台状态枚举,COMPLETE/PAUSE 缺失曾导致 1/3 商品行 status 为 NULL "COMPLETE": "已完成", "PAUSE": "暂停", + # CLOSE 同为商品终态(Goods 约束无"已关闭",取"已取消");UNKNOWN 保留 NULL 并由告警暴露 + "CLOSE": "已取消", } RIIN_PLATFORM_STATUS_MAP: dict[str, str] = { diff --git a/tests/test_mappers.py b/tests/test_mappers.py index e74d248..ae5de8b 100644 --- a/tests/test_mappers.py +++ b/tests/test_mappers.py @@ -53,6 +53,7 @@ class RiinGoodsStatusTest(unittest.TestCase): "REFUNDING": "退款中", "COMPLETE": "已完成", # 本次补齐(曾导致 NULL) "PAUSE": "暂停", # 本次补齐(曾导致 NULL) + "CLOSE": "已取消", # 回填重拉时告警发现的新枚举 } for raw, want in cases.items(): with self.subTest(raw=raw):