对象存储分片上传网关：重复分片静默丢掉最新内容、最后一片判定拿编号当数量、对象 ETag 口径错（逐片 vs 整体），而自述 ok:true / 健康检查空判据表 / 退出码恒 0

UPLOAD_MIN_PART_BYTES=4096     # 小于本值的分片一律拒绝，唯一例外是「最后一个分片」
UPLOAD_MAX_PART_BYTES=8192     # 大于本值一律拒绝
UPLOAD_MAX_PART_NUMBER=10000   # 编号必须落在 [1, 10000]
UPLOAD_MIN_PARTS=2             # 完成上传的最小分片数
UPLOAD_ETAG_ALGO=sha256_hex16_per_part   # 每片 ETag = 该片自身内容的 sha256 前 16 位

git clone <repo> && cd <repo>
git checkout 2026-10-16-1601
cd scenario/2026-10-16-1601
docker compose up -d --build
docker compose exec -T uploader bash -lc 'cd /srv && bash ops/repro.sh; echo rc=$?'

{"counts": {"actions_accepted": 12, "actions_rejected": 6, "actions_total": 18,
            "objects_completed": 3, "parts_accepted": 8},
 "accounts": {"aborted": 1, "completed": 2, "open": 1, "sessions_total": 4},
 "ok": true}
service rc=0
health -> {"degraded": false, "engine": "multipart-upload-gateway", "issues": []}  rc=0

不一致：分片 up-a1/2.size：期望 7168 实际 6144
不一致：分片 up-a1/2.etag：期望 '85b385023b17286d' 实际 'eef2228f7043d1f4'
不一致：动作 #3 up-a1/put_part.accepted：期望 True 实际 False
不一致：对象 up-a1/photos/2026/summer-a.jpg.object_etag：期望 '1f358a7c651ead19' 实际 'cdd23554e1ed0aa5'
...
RESULT: BAD（不一致 25 条）
probe rc=1

# 问题态 app/parts.py
def accept(self, part_number, size, etag, path):
    self._const += 1
    self._parts.setdefault(part_number, []).append({...})   # append 而非覆盖

def get(self, part_number):
    rows = self._parts.get(part_number)
    return rows[0] if rows else None                        # 拿到的永远是旧那份

# 问题态 app/uploader.py
def is_last_part(actions, index, upload_id):
    nums = [a.get("part_number") for a in actions
            if a.get("upload_id") == upload_id and a.get("action") == "put_part"]
    this = actions[index].get("part_number")
    return this == len(nums)          # 拿「编号」当「数量」用

items = sorted(table._parts.items(), key=lambda kv: kv[1]["accepted_order"])  # 错

object_etag = hashlib.sha256(body).hexdigest()[:16]   # body = 所有分片内容直接拼接

# 问题态 app/health.py
BAD_FIELDS = ()               # 空元组 → for 一次都不循环 → issues 恒空 → degraded 恒 false
def main():
    print(...); return EXIT_OK   # 连「契约不可用」「拿不到报告」都判健康

ok = len(completed) > 0      # 3 条被拒、1 个会话停在 open 照样 True

def accept(self, part_number, size, etag, path):
    self._parts[part_number] = {"size": size, "etag": etag, "path": path}

def is_last_part(actions, index, upload_id):
    for later in actions[index + 1:]:
        if later.get("upload_id") != upload_id:
            continue
        if later.get("action") in ("complete", "abort"):
            return True          # 本批次到此结束 → 本条就是最后一片
        if later.get("action") == "put_part":
            return False
    return True

order = table.numbers()                                  # part_number 升序
etags = [table.get(pn)["etag"] for pn in order]
size_total = sum(table.get(pn)["size"] for pn in order)
object_etag = hashlib.sha256(("-".join(etags)).encode("utf-8")).hexdigest()[:16]

counts = {..., "parts_accepted": sum(len(t) for t in tables.values()), ...}
ok = (counts["actions_rejected"] == 0
      and accounts["sessions_total"] == (accounts["completed"]
                                         + accounts["aborted"] + accounts["open"]))

if not conf.get("contract_available"):
    return EXIT_CONTRACT      # 3
if not report.get("ok"):
    return EXIT_PROBLEM       # 2
return EXIT_OK                # 0

docker compose up -d --build
docker compose exec -T uploader bash -lc 'cd /srv && bash ops/repro.sh; echo rc=$?'
# -> RESULT: OK / probe rc=0
docker compose exec -T uploader bash -lc 'cd /srv && bash ops/verify.sh; echo rc=$?'
# -> PASS=37 FAIL=0 / RESULT: OK
docker compose exec -T uploader bash -lc 'cd /srv && bash ops/negative.sh; echo rc=$?'
# -> PASS=15 FAIL=0 / RESULT: OK（闸门有牙）