from __future__ import annotations
|
|
import csv
|
import hashlib
|
import json
|
from datetime import datetime
|
from pathlib import Path
|
from zoneinfo import ZoneInfo
|
|
|
RUN_ID = "RUN-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-001"
|
TASK_ID = "ANA-WUJI-V1-FINAL-CONCLUSION-20260610"
|
SOURCE_RUN_ID = "RUN-ANA-WUJI-STRICT-SELL-ROLLING-REPAIR-20260609-001"
|
SOURCE_EXEC_AUDIT_ID = "AUDIT-ANA-WUJI-STRICT-SELL-ROLLING-REPAIR-20260610-EXEC-REREVIEW-003"
|
DESIGN_AUDIT_ID = "AUDIT-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-DESIGN-001"
|
EXEC_AUDIT_ID = "AUDIT-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-EXEC-001"
|
EXEC_REVIEW_MESSAGE_ID = "msg_20260610215718079_7732c8c2"
|
EXEC_REVIEW_REQUEST_ID = "msg_20260610215112659_4d34e4c7"
|
EXEC_REVIEW_TIME = "2026-06-10T21:57:18+08:00"
|
|
OUT_DIR = Path(__file__).resolve().parents[1]
|
PROJECT_ROOT = Path(__file__).resolve().parents[4]
|
SOURCE_DIR = PROJECT_ROOT / "ana-data" / "result" / SOURCE_RUN_ID
|
|
|
def now_iso() -> str:
|
return datetime.now(ZoneInfo("Asia/Shanghai")).isoformat(timespec="seconds")
|
|
|
def read_csv(path: Path) -> list[dict[str, str]]:
|
with path.open("r", encoding="utf-8-sig", newline="") as f:
|
return list(csv.DictReader(f))
|
|
|
def write_csv(path: Path, rows: list[dict[str, object]], fieldnames: list[str] | None = None) -> None:
|
if fieldnames is None:
|
fieldnames = list(rows[0].keys()) if rows else []
|
with path.open("w", encoding="utf-8-sig", newline="") as f:
|
writer = csv.DictWriter(f, fieldnames=fieldnames)
|
writer.writeheader()
|
writer.writerows(rows)
|
|
|
def write_json(path: Path, data: object) -> None:
|
path.write_text(json.dumps(data, ensure_ascii=False, indent=2) + "\n", encoding="utf-8")
|
|
|
def sha256_file(path: Path) -> str:
|
h = hashlib.sha256()
|
with path.open("rb") as f:
|
for chunk in iter(lambda: f.read(1024 * 1024), b""):
|
h.update(chunk)
|
return h.hexdigest()
|
|
|
def file_row(path: Path) -> dict[str, object]:
|
return {
|
"path": path.relative_to(OUT_DIR).as_posix(),
|
"size": path.stat().st_size,
|
"sha256": sha256_file(path),
|
}
|
|
|
def case_line(row: dict[str, str]) -> str:
|
case_id = row["case_id"]
|
ret = row.get("account_return_closed_lots", "")
|
return (
|
f"- `{case_id}`：账户贡献 `{ret}`；"
|
f"[图片板](../{SOURCE_RUN_ID}/cases/{case_id}/case_image_board.md)；"
|
f"[故事板](../{SOURCE_RUN_ID}/cases/{case_id}/case_story_board.md)"
|
)
|
|
|
def main() -> None:
|
summary_path = OUT_DIR / "v1_final_conclusion_summary.json"
|
summary = json.loads(summary_path.read_text(encoding="utf-8-sig"))
|
readouts = read_csv(OUT_DIR / "v1_final_readouts.csv")
|
case_rows = read_csv(OUT_DIR / "v1_case_readout_index.csv")
|
boundary_rows = read_csv(OUT_DIR / "v1_boundary_table.csv")
|
|
primary = [r for r in case_rows if r["v1_return_scope"] == "V1_PRIMARY_STRICT_CLOSED_CASE"]
|
positive = [r for r in primary if r["success_flag"] == "1"]
|
non_positive = [r for r in primary if r["success_flag"] != "1"]
|
boundary_cases = [r for r in case_rows if r["v1_return_scope"] != "V1_PRIMARY_STRICT_CLOSED_CASE"]
|
top_positive = sorted(positive, key=lambda r: float(r["account_return_closed_lots"] or 0), reverse=True)[:3]
|
top_negative = sorted(non_positive, key=lambda r: float(r["account_return_closed_lots"] or 0))[:3]
|
boundary_example = boundary_cases[:1]
|
|
readout_map = {r["readout_id"]: r for r in readouts}
|
primary_readout = readout_map["V1_PRIMARY_STRICT_CLOSED_CASE"]
|
coverage_readout = readout_map["V1_ALL_BUY_CASE_COVERAGE"]
|
lot_readout = readout_map["V1_STRICT_CLOSED_LOT_RECALC_ONLY"]
|
rolling_readout = readout_map["V1_ROLLING_LOW_BUY"]
|
|
summary.update(
|
{
|
"execution_review_status": "EXECUTION_REVIEW_PASSED_LAYERED_V1_CITATION_ALLOWED",
|
"execution_review_audit_id": EXEC_AUDIT_ID,
|
"execution_review_message_id": EXEC_REVIEW_MESSAGE_ID,
|
"execution_review_request_message_id": EXEC_REVIEW_REQUEST_ID,
|
"execution_review_passed_at": EXEC_REVIEW_TIME,
|
"citation_allowed": True,
|
"formal_summary_written": True,
|
"formal_summary_path": "ana-doc/wuji/无忌交易系统V1最终案例总结.md",
|
}
|
)
|
write_json(summary_path, summary)
|
|
summary_md = f"""# 无忌 V1 最终结论引用包摘要
|
|
## 当前可引用状态
|
|
当前包基于已通过执行复审的 V1 结果包生成，来源审计 ID 为 `{SOURCE_EXEC_AUDIT_ID}`。本包已通过最终结论引用包执行审核，审计 ID 为 `{EXEC_AUDIT_ID}`。
|
|
允许按 V1 口径、审计 ID 和边界表分层引用；不得写成无边界完整 baseline 结论或策略有效性证明。
|
|
## V1 主口径：V1_PRIMARY_STRICT_CLOSED_CASE
|
|
| 指标 | 读数 |
|
|---|---:|
|
| V1 主口径严格闭合 case | {primary_readout['case_count']} |
|
| V1 主口径正收益 case | {primary_readout['positive_case_count']} |
|
| V1 主口径非正收益 case | {primary_readout['non_positive_case_count']} |
|
| V1 主口径成功率读数 | {primary_readout['success_rate']} |
|
| V1 主口径账户贡献合计读数 | {primary_readout['account_contribution_sum']} |
|
|
## 覆盖口径
|
|
| 指标 | 读数 |
|
|---|---:|
|
| V1 有 BUY case | {coverage_readout['case_count']} |
|
| V1 边界 case | {coverage_readout['boundary_count']} |
|
| 滚动低吸 BUY 订单 | {rolling_readout['lot_count']} |
|
|
## lot 辅助口径
|
|
| 指标 | 读数 |
|
|---|---:|
|
| V1 lot 总数 | {lot_readout['lot_count']} |
|
| V1 边界 lot | {lot_readout['boundary_count']} |
|
|
## 边界
|
|
`v1_boundary_table.csv` 完整保留来源边界表，共 {len(boundary_rows)} 行。必须特别保留 `MARKET_RISK_MINUTE_BREADTH_DATA_GAP_HELD`，它表示本地数据源没有开盘 10 分钟全 A 下跌家数分钟级广度，市场风险卖点不能被无边界化。
|
|
## 禁止外推
|
|
1. 不得把 V1 读数写成旧 V0 包结论。
|
2. 不得写成无边界完整 baseline 成功率、收益率、胜率或回撤。
|
3. 不得作出策略有效性的证明结论。
|
4. 不得省略审计 ID、V1 口径、边界表和市场风险分钟广度数据缺口。
|
"""
|
(OUT_DIR / "v1_final_conclusion_summary.md").write_text(summary_md, encoding="utf-8")
|
|
human_index = f"""# 无忌 V1 最终结论人工审核第一入口
|
|
## 先看这里
|
|
当前 V1 最终结论引用包已通过执行审核：`{EXEC_AUDIT_ID}`。
|
|
可以引用：在 V1 主口径 `V1_PRIMARY_STRICT_CLOSED_CASE` 下，250 个严格闭合 case 中 99 个为正收益，成功率读数为 0.396，账户贡献合计读数为 0.12970642。
|
|
必须同时引用：
|
- 来源 V1 执行复审 ID：`{SOURCE_EXEC_AUDIT_ID}`
|
- 本最终引用包执行审核 ID：`{EXEC_AUDIT_ID}`
|
- `v1_boundary_table.csv`
|
- `MARKET_RISK_MINUTE_BREADTH_DATA_GAP_HELD`
|
|
不能引用：不能把 V1 读数写成旧 V0 包结论，不能写成无边界完整 baseline 结论，不能作出策略有效性的证明结论，不能省略市场风险分钟广度数据缺口。
|
|
## 当前状态
|
|
| 项目 | 内容 |
|
|---|---|
|
| 当前 run | `{RUN_ID}` |
|
| 来源 run | `{SOURCE_RUN_ID}` |
|
| 来源执行复审审计 ID | `{SOURCE_EXEC_AUDIT_ID}` |
|
| 当前设计审核审计 ID | `{DESIGN_AUDIT_ID}` |
|
| 当前执行审核审计 ID | `{EXEC_AUDIT_ID}` |
|
| RETURN_STAT_READY | `false` |
|
| 执行审核状态 | `通过 / 允许按 V1 边界引用` |
|
|
## V1 三层读数
|
|
1. `V1_PRIMARY_STRICT_CLOSED_CASE`：250 个严格闭合 case，正收益 99 个，成功率读数 0.396，账户贡献合计 0.12970642。
|
2. `V1_ALL_BUY_CASE_COVERAGE`：251 个有 BUY case，其中 1 个 case 进入边界；该口径不替代主成功率。
|
3. `V1_STRICT_CLOSED_LOT_RECALC_ONLY`：735 个 lot，其中 734 个闭合、1 个边界；lot 口径只用于复算和问题定位。
|
4. `V1_ROLLING_LOW_BUY`：滚动低吸 BUY 订单 25 笔；只说明 V1 执行数量，不单独构成策略有效性结论。
|
|
## 第一入口链接
|
|
- 来源 V1 图片总入口：[case_image_board.md](../{SOURCE_RUN_ID}/case_image_board.md)
|
- 来源 V1 摘要：[summary.md](../{SOURCE_RUN_ID}/summary.md)
|
- 来源 V1 手工裁决草稿：[manual_decision_external_draft.md](../{SOURCE_RUN_ID}/manual_decision_external_draft.md)
|
- 当前 V1 结论摘要：[v1_final_conclusion_summary.md](v1_final_conclusion_summary.md)
|
- 当前 V1 同事总结：[v1_final_case_summary_for_colleagues.md](v1_final_case_summary_for_colleagues.md)
|
- 当前 V1 读数表：[v1_final_readouts.csv](v1_final_readouts.csv)
|
- 当前 V1 case 索引：[v1_case_readout_index.csv](v1_case_readout_index.csv)
|
- 当前 V1 边界表：[v1_boundary_table.csv](v1_boundary_table.csv)
|
|
## 代表性 case
|
|
主口径正收益较高样例：
|
{chr(10).join(case_line(r) for r in top_positive)}
|
|
主口径负收益较低样例：
|
{chr(10).join(case_line(r) for r in top_negative)}
|
|
边界样例：
|
{chr(10).join(case_line(r) for r in boundary_example)}
|
|
## 阅读提示
|
|
1. 先看本文件的可引用 / 不可引用边界。
|
2. 再看 `v1_final_case_summary_for_colleagues.md`，它是同事阅读版摘要。
|
3. 需要追溯单个案例时，从 `v1_case_readout_index.csv` 找到 `case_id`，再打开对应图片板和故事板。
|
4. 对卖点和滚动低吸的人工裁决来源，优先看 `manual_decision_external_draft.md` 和 `manual_decision_ledger.csv`。
|
"""
|
(OUT_DIR / "v1_final_human_review_index.md").write_text(human_index, encoding="utf-8")
|
|
final_md = f"""# 无忌交易系统 V1 最终案例总结（分层引用版）
|
|
创建人员：case_analysis.analyst / laoan
|
文件职责：给同事阅读的 V1 当前正式总结入口，说明可以引用的读数、必须带上的边界，以及从哪里追溯证据。
|
|
## 一句话结论
|
|
`RUN-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-001` 已通过最终结论引用包执行审核，审计 ID 为 `{EXEC_AUDIT_ID}`。当前允许把 V1 读数按分层口径写给同事看，但不能写成无边界完整 baseline 结论，也不能作出策略有效性的证明结论。
|
|
## 可以引用的 V1 读数
|
|
在 V1 主口径 `V1_PRIMARY_STRICT_CLOSED_CASE` 下，250 个严格闭合 case 中 99 个为正收益，成功率读数为 0.396，账户贡献合计读数为 0.12970642。
|
|
覆盖口径 `V1_ALL_BUY_CASE_COVERAGE` 为 251 个有 BUY case，其中 1 个边界 case；覆盖口径只说明样本覆盖，不替代主成功率分母。
|
|
辅助 lot 口径 `V1_STRICT_CLOSED_LOT_RECALC_ONLY` 为 735 个 lot，其中 734 个闭合、1 个边界；lot 口径只用于复算和问题定位，不包装成 case 成功率。
|
|
滚动低吸 BUY 订单为 25 笔；它只说明 V1 执行数量，不单独构成策略有效性结论。
|
|
## 必须同时写明的边界
|
|
1. 来源 V1 执行复审 ID：`{SOURCE_EXEC_AUDIT_ID}`。
|
2. 本最终引用包执行审核 ID：`{EXEC_AUDIT_ID}`。
|
3. 该读数只覆盖 V1 已审核主口径，不等于无边界完整 baseline。
|
4. `v1_boundary_table.csv` 必须保留，其中包括 `MARKET_RISK_MINUTE_BREADTH_DATA_GAP_HELD`。
|
5. 当前仍保留 `RETURN_STAT_READY=false`。
|
|
## 不可以写的内容
|
|
1. 不得把 V1 读数写成旧 V0 包结论。
|
2. 不得写成无边界完整 baseline 成功率、收益率、胜率或回撤。
|
3. 不得省略 1 个边界 case、1 个边界 lot 和市场风险分钟广度数据缺口。
|
4. 不得把滚动低吸 BUY 25 笔单独包装成策略有效性结论。
|
|
## 给同事看的阅读入口
|
|
1. 先看 V1 人工第一入口：`ana-data/result/RUN-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-001/v1_final_human_review_index.md`。
|
2. 再看 V1 结果包摘要：`ana-data/result/RUN-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-001/v1_final_conclusion_summary.md`。
|
3. 想逐个看案例时，看 `ana-data/result/RUN-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-001/v1_case_readout_index.csv`，再进入对应 case 图片板和 story board。
|
4. 想查买卖和滚动低吸裁决来源时，看 `ana-data/result/RUN-ANA-WUJI-STRICT-SELL-ROLLING-REPAIR-20260609-001/manual_decision_external_draft.md` 和 `manual_decision_ledger.csv`。
|
5. 想复核边界时，看 `ana-data/result/RUN-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-001/v1_boundary_table.csv`。
|
|
## 审计链
|
|
| 阶段 | 审计 ID |
|
|---|---|
|
| V1 精准卖点与滚动渣男执行复审 | `{SOURCE_EXEC_AUDIT_ID}` |
|
| V1 最终结论引用设计审核 | `{DESIGN_AUDIT_ID}` |
|
| V1 最终结论引用包执行审核 | `{EXEC_AUDIT_ID}` |
|
|
## 与旧 V0 总结的关系
|
|
旧 `ana-doc/wuji/无忌交易系统最终案例总结.md` 保留为 V0 / 代理卖点阶段的历史分层引用记录。当前要给同事看 V1 完整精准卖点与滚动低吸返修后的结果，应优先使用本文件和 `RUN-ANA-WUJI-V1-FINAL-CONCLUSION-20260610-001`。
|
"""
|
(OUT_DIR / "v1_final_case_summary_for_colleagues.md").write_text(final_md, encoding="utf-8")
|
|
final_json = {
|
"schema_version": "1.0",
|
"task_id": TASK_ID,
|
"run_id": RUN_ID,
|
"source_run_id": SOURCE_RUN_ID,
|
"source_execution_rereview_audit_id": SOURCE_EXEC_AUDIT_ID,
|
"design_audit_id": DESIGN_AUDIT_ID,
|
"execution_review_audit_id": EXEC_AUDIT_ID,
|
"execution_review_message_id": EXEC_REVIEW_MESSAGE_ID,
|
"generated_at": now_iso(),
|
"citation_allowed": True,
|
"return_stat_ready": False,
|
"readouts": summary["readouts"],
|
"required_boundary": [
|
"V1 scope",
|
SOURCE_EXEC_AUDIT_ID,
|
EXEC_AUDIT_ID,
|
"v1_boundary_table.csv",
|
"MARKET_RISK_MINUTE_BREADTH_DATA_GAP_HELD",
|
],
|
"public_summary_path": "ana-doc/wuji/无忌交易系统V1最终案例总结.md",
|
}
|
write_json(OUT_DIR / "v1_final_case_summary_for_colleagues.json", final_json)
|
|
readme = f"""# 无忌 V1 最终结论引用包
|
|
本包是 V1 执行复审通过后的引用层整理，不重跑候选池、买卖裁决、人工裁决或账本。
|
|
当前执行审核已通过：`{EXEC_AUDIT_ID}`。
|
|
先看：[v1_final_human_review_index.md](v1_final_human_review_index.md)
|
|
给同事看的总结：[v1_final_case_summary_for_colleagues.md](v1_final_case_summary_for_colleagues.md)
|
|
来源执行复审 ID：`{SOURCE_EXEC_AUDIT_ID}`
|
|
设计审核 ID：`{DESIGN_AUDIT_ID}`
|
|
当前状态：允许按 V1 口径、审计 ID 和边界表分层引用；不得写成无边界完整 baseline 结论或策略有效性证明。
|
"""
|
(OUT_DIR / "README.md").write_text(readme, encoding="utf-8")
|
|
items = read_csv(OUT_DIR / "self_check_items.csv")
|
if not any(r.get("item") == "EXECUTION_REVIEW_AUDIT_RECORDED" for r in items):
|
items.append(
|
{
|
"item": "EXECUTION_REVIEW_AUDIT_RECORDED",
|
"status": "PASS",
|
"detail": f"audit={EXEC_AUDIT_ID}, message={EXEC_REVIEW_MESSAGE_ID}",
|
}
|
)
|
write_csv(OUT_DIR / "self_check_items.csv", items, ["item", "status", "detail"])
|
fail_count = sum(1 for r in items if r["status"] != "PASS")
|
self_check = {
|
"schema_version": "1.0",
|
"run_id": RUN_ID,
|
"generated_at": now_iso(),
|
"status": "PASS_FOR_V1_FINAL_CONCLUSION_EXECUTION_REVIEW_PASSED" if fail_count == 0 else "FAIL",
|
"pass_count": len(items) - fail_count,
|
"fail_count": fail_count,
|
"items_path": "self_check_items.csv",
|
}
|
write_json(OUT_DIR / "self_check.json", self_check)
|
(OUT_DIR / "self_check.md").write_text(
|
f"""# 自检摘要
|
|
- status：`{self_check['status']}`
|
- PASS：{self_check['pass_count']}
|
- FAIL：{self_check['fail_count']}
|
- 检查项：`self_check_items.csv`
|
""",
|
encoding="utf-8",
|
)
|
|
package_files = []
|
for p in OUT_DIR.rglob("*"):
|
if not p.is_file():
|
continue
|
if p.name in {"manifest.csv", "manifest.json"}:
|
continue
|
package_files.append(file_row(p))
|
package_files.sort(key=lambda r: str(r["path"]))
|
write_csv(OUT_DIR / "manifest.csv", package_files, ["path", "size", "sha256"])
|
write_json(
|
OUT_DIR / "manifest.json",
|
{
|
"schema_version": "1.0",
|
"run_id": RUN_ID,
|
"generated_at": now_iso(),
|
"files": package_files,
|
},
|
)
|
|
print(
|
json.dumps(
|
{
|
"run_id": RUN_ID,
|
"status": self_check["status"],
|
"execution_review_audit_id": EXEC_AUDIT_ID,
|
"manifest_files": len(package_files),
|
},
|
ensure_ascii=False,
|
)
|
)
|
|
|
if __name__ == "__main__":
|
main()
|
