', block + '\n
', 1)
mode = "inserted"
if s2 != s:
page_path.write_text(s2, encoding="utf-8")
return mode
def refresh_intl_blocks(rid, m, page):
"""按 manifest.anchors 刷新 TSA / OpenTimestamps 区块（幂等；无则跳过）。"""
acts = []
anchors = m.get("anchors") or {}
if anchors.get("tsa"):
txt = page.read_text(encoding="utf-8")
after = " " if " " in txt else None
mode = wc.upsert_block(page, " ", " ",
wc.render_tsa_block(rid, anchors["tsa"]), insert_after=after)
acts.append("page-tsa-" + mode)
if anchors.get("opentimestamps"):
txt = page.read_text(encoding="utf-8")
if " " in txt:
after = " "
elif " " in txt:
after = " "
else:
after = None
mode = wc.upsert_block(page, " ", " ",
wc.render_ots_block(rid, anchors["opentimestamps"]), insert_after=after)
acts.append("page-ots-" + mode)
return acts
# ───────────────────────── 单条处理 ─────────────────────────
def process(rec, cfg, mode=None, refresh_only=False, dry=False):
rid = rec["record_id"]
res = {"record_id": rid, "actions": [], "ok": True}
mpath, page = rec["manifest"], VERIFY / rid / "index.html"
m = json.loads(mpath.read_text(encoding="utf-8"))
anch = (m.get("anchors") or {}).get("zhixin")
if refresh_only:
anchors_all = m.get("anchors") or {}
if not anchors_all:
res["actions"].append("skip: 无锚定内容，无可刷新")
return res
if not page.exists():
res["actions"].append("skip: 无验证页")
return res
if anch:
res["actions"].append("page-" + upsert_anchor_block(page, render_anchor_block(rid, anch)))
res["actions"] += refresh_intl_blocks(rid, m, page)
return res
if anch and not dry:
res["actions"].append("skip: 已锚定（加 --force 可重锚）")
else:
if dry:
res["actions"].append(f"would-anchor: {rec['original']}")
return res
if not rec["original"]:
res["ok"] = False
res["actions"].append("FAIL: 找不到原件（无法按文件算 SM3）")
return res
r = zx.anchor(m["file"]["sha256"], rid, file_path=str(rec["original"]),
manifest_path=str(mpath), cfg=cfg, dry_run=False, get_cert=True)
if not r.get("ok"):
res["ok"] = False
res["actions"].append(f"FAIL: {r.get('error')}")
return res
res["anchors"] = {k: r.get(k) for k in ("evId", "txId", "blockHeight", "txTime", "chain_confirmed")}
res["actions"].append("anchored: evId=" + str(r.get("evId")))
zx.merge_into_manifest(str(mpath), r, str(ED_KEY), key_id="2026-rot1")
res["actions"].append("manifest 回写并重签")
m = json.loads(mpath.read_text(encoding="utf-8"))
anch = (m.get("anchors") or {}).get("zhixin")
# 发布 manifest.json（验证页同目录）
if page.exists() and (VERIFY / rid).is_dir():
(VERIFY / rid / "manifest.json").write_text(
json.dumps(m, ensure_ascii=False, indent=2), encoding="utf-8")
res["actions"].append("已发布 verify//manifest.json")
if anch:
res["actions"].append("page-" + upsert_anchor_block(page, render_anchor_block(rid, anch)))
res["actions"] += refresh_intl_blocks(rid, m, page)
else:
res["actions"].append("提示: 无验证页目录，跳过 manifest 发布与页面刷新（需先克隆模板出页）")
return res
def deploy():
p = subprocess.run([sys.executable, str(ROOT / "deploy_and_verify.py")],
cwd=str(ROOT), capture_output=True, text=True, encoding="utf-8", errors="replace")
tail = [l for l in (p.stdout or "").splitlines() if "VERIFY" in l or "checked" in l]
return p.returncode, tail
def main():
ap = argparse.ArgumentParser(description="WDY 链上锚定批处理")
ap.add_argument("--records", default=None, help="逗号分隔的记录号")
ap.add_argument("--all-unanchored", action="store_true")
ap.add_argument("--refresh-pages", action="store_true", help="只按 manifest 刷新页面锚定块")
ap.add_argument("--list", action="store_true", help="列出记录及状态")
ap.add_argument("--config", default=str(CONFIG_DEFAULT))
ap.add_argument("--mode", choices=["live", "mock"], default=None)
ap.add_argument("--dry-run", action="store_true")
ap.add_argument("--no-deploy", action="store_true")
ap.add_argument("--force", action="store_true", help="已锚定的也重锚")
a = ap.parse_args()
recs = list_records()
if a.list or not (a.records or a.all_unanchored or a.refresh_pages):
print(f"{'记录号':<26}{'已锚定':<8}{'有验证页':<9}{'原件':<7}标题")
for r in recs:
print(f"{r['record_id']:<26}{'是' if r['anchored'] else '否':<8}"
f"{'是' if r['page'] else '否':<9}{'有' if r['original'] else '缺':<7}{r['title'][:34]}")
print(f"\n合计 {len(recs)} 条，已锚定 {sum(1 for r in recs if r['anchored'])} 条，"
f"缺原件 {sum(1 for r in recs if not r['original'])} 条")
return
if a.records:
want = [x.strip() for x in a.records.split(",") if x.strip()]
recs = [r for r in recs if r["record_id"] in want or r["record_id"].split("-")[-1] in want]
elif a.all_unanchored:
recs = [r for r in recs if not r["anchored"] and r["original"] and r["page"]]
if not recs:
print("没有匹配的记录"); return
cfg = zx.load_config(explicit=a.config)
if a.mode:
cfg["mode"] = a.mode
print(f"模式={cfg['mode']}｜待处理 {len(recs)} 条：{[r['record_id'] for r in recs]}\n")
results = []
for r in recs:
res = process(r, cfg, refresh_only=a.refresh_pages, dry=a.dry_run)
results.append(res)
flag = "OK " if res["ok"] else "ERR"
print(f"[{flag}] {res['record_id']}")
for x in res["actions"]:
print(" -", x)
if a.force and res["ok"] and not a.dry_run and "skip: 已锚定" in res["actions"]:
pass
if not a.no_deploy and not a.dry_run:
print("\n=== 部署 ===")
rc, tail = deploy()
for l in tail:
print(" ", l.strip())
print("部署返回码:", rc)
if not a.dry_run:
hist = json.loads(REPORT.read_text(encoding="utf-8")) if REPORT.exists() else []
hist.append({"at": datetime.now(timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ"),
"mode": cfg["mode"], "records": results})
REPORT.write_text(json.dumps(hist, ensure_ascii=False, indent=2), encoding="utf-8")
print("报告已追加:", REPORT)
if __name__ == "__main__":
main()