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] = {

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):